class PortForwardEquivalent {
  private static final Logger logger = LoggerFactory.getLogger(PortForwardEquivalent.class);

  public static void main(String[] args) {<FILL_FUNCTION_BODY>}
}

    try (final KubernetesClient k8s = new KubernetesClientBuilder().build()) {
      CountDownLatch countDownLatch = new CountDownLatch(1);
      k8s.pods().inNamespace("default").withName("my-pod")
          .portForward(80, 8080); // (container port , localhost port)

      logger.info("Port forward open for 10 seconds");
      boolean latchTerminationStatus = countDownLatch.await(10, TimeUnit.SECONDS);
      if (!latchTerminationStatus) {
        logger.debug("latch terminated before it's count reaching zero");
      }
      logger.info("Closing port forward");
    } catch (InterruptedException interruptedException) {
      Thread.currentThread().interrupt();
      logger.warn("Interrupted while waiting for the port forward to be ready: {}", interruptedException.getMessage());
    }
  
<no_super_class>