kubeproxy

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultLocalAPIPort = 22322
)

Variables

This section is empty.

Functions

func ExtractTunnelAddressFromEnv

func ExtractTunnelAddressFromEnv(localPort int, kubeProxyPort string) string

Types

type BaseKubeProxy

type BaseKubeProxy struct {
	KubeProxyPort string
	LocalPort     string
	// contains filtered or unexported fields
}

func NewBaseKubeProxy

func NewBaseKubeProxy(runner Runner, sett settings.Settings, sess *session.Session) *BaseKubeProxy

func (*BaseKubeProxy) Start

func (k *BaseKubeProxy) Start(useLocalPort int) (string, error)

func (*BaseKubeProxy) Stop

func (k *BaseKubeProxy) Stop(startID int)

func (*BaseKubeProxy) StopAll

func (k *BaseKubeProxy) StopAll()

type PortProvider

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

func NewPortProvider

func NewPortProvider(startPort int) *PortProvider

func (*PortProvider) Next

func (p *PortProvider) Next() int

type Runner

type Runner interface {
	StartCommand(params StartCommandParams) (connection.KubeProxyCommand, error)
	UpTunnel(localPort int, kubeProxyPort string) (connection.Tunnel, string, error)
	ClientID() string
}

type StartCommandParams

type StartCommandParams struct {
	OnStart       func()
	StdoutHandler func(string)
	WaitHandler   func(err error)
	Cmd           string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL