Versions in this module Expand all Collapse all v0 v0.2.0 Sep 28, 2022 Changes in this version + const PortUnspecified + var ErrEmptyPodsListed = errors.New("empty pods listed") + type ForwardHandle interface + ErrChan func() <-chan error + LocalPort func(remortPort uint16) uint16 + StopForward func() + func Forward(forwardCtx context.Context, restConfig *rest.Config, namespace string, ...) (ForwardHandle, error) + func ForwardWithReconnect(logger logger.Logger, forwardTimeout time.Duration, ...) (ForwardHandle, error) + type Forwarder struct + type FromRemotePortOption interface + FromRemotePort func(remotePort uint16) Option + func ToLocalPort(localPort uint16) FromRemotePortOption + type Option func(forwarder *Forwarder) error + func FromSelectedPods(labelSelector string) Option + func FromService(serviceName string) Option + func WithLogger(logger kubekit.Logger) Option + type ToLocalPortOption interface + ToLocalPort func(localPort uint16) Option + func FromRemotePort(remotePort uint16) ToLocalPortOption