k8s

Documentation

Index

• type Api
  • func New(kubeconfig string) (*Api, error)
  • func (api *Api) Dialer(p *TargetPod) (httpstream.Dialer, error)
  • func (api *Api) GetMatchingPod(ctx context.Context, namespace, podName, port string) (*TargetPod, error)
  • func (api *Api) GetMatchingPodForService(ctx context.Context, namespace, serviceName, port string) (*TargetPod, error)
• type TargetPod

Types

type Api

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

func New

func New(kubeconfig string) (*Api, error)

func (*Api) Dialer

func (api *Api) Dialer(p *TargetPod) (httpstream.Dialer, error)

func (*Api) GetMatchingPod

func (api *Api) GetMatchingPod(ctx context.Context, namespace, podName, port string) (*TargetPod, error)

func (*Api) GetMatchingPodForService

func (api *Api) GetMatchingPodForService(ctx context.Context, namespace, serviceName, port string) (*TargetPod, error)

type TargetPod

type TargetPod struct {
	Name      string
	Port      string
	Namespace string
}