k8s

Documentation

Index

• type Client
  • func NewClient(logger *slog.Logger, restConfig *rest.Config) (Client, error)
  • func (c Client) GetPods(ctx context.Context, namespace, labelSelector string) ([]Pod, error)
• type Forwarder
  • func (f Forwarder) Get(path string, params url.Values) (int, []byte, error)
  • func (f Forwarder) Stop()
• type Pod
• type PortForward
  • func NewPortForward(logger *slog.Logger, restConfig *rest.Config) (PortForward, error)
  • func (p PortForward) Start(namespace, labelSelector, port string) (Forwarder, error)

Types

type Client

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

func NewClient

func NewClient(logger *slog.Logger, restConfig *rest.Config) (Client, error)

func (Client) GetPods

func (c Client) GetPods(ctx context.Context, namespace, labelSelector string) ([]Pod, error)

type Forwarder

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

func (Forwarder) Get

func (f Forwarder) Get(path string, params url.Values) (int, []byte, error)

Get sends http GET request with specified params to port forwarded pod's path and returns status code and response body

func (Forwarder) Stop

func (f Forwarder) Stop()

Stop stops port forwarding

type Pod

type Pod struct {
	Name      string
	Namespace string
}

type PortForward

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

func NewPortForward

func NewPortForward(logger *slog.Logger, restConfig *rest.Config) (PortForward, error)

func (PortForward) Start

func (p PortForward) Start(namespace, labelSelector, port string) (Forwarder, error)

Start starts port forwarding to specified pod