kubernetes

package

v0.0.0-...-869124a Latest Latest Go to latest Published: May 8, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func WaitForDeployment(ctx context.Context, namespace, deployment string, timeout time.Duration) error

WaitForDeployment waits for a deployment to be ready

func WaitForNamespace(ctx context.Context, namespace string, timeout time.Duration) error

WaitForNamespace waits for a namespace to exist

type PortForwarder struct {
	// contains filtered or unexported fields
}

PortForwarder manages port-forwarding to a deployment with automatic reconnection

func NewPortForwarder(namespace, deployment string, remotePort, localPort int) *PortForwarder

NewPortForwarder creates a new port forwarder

func (pf *PortForwarder) GetLocalPort() int

GetLocalPort returns the actual assigned local port

func (pf *PortForwarder) IsConnected() bool

IsConnected returns whether the port-forward is currently connected

func (pf *PortForwarder) Start(ctx context.Context) error

Start starts port-forwarding in the background with automatic reconnection

func (pf *PortForwarder) Stop()

Stop stops the port-forwarding