kube

Documentation

Index

• type Kube
  • func MustNew(kubeConf string, namespace string) *Kube
  • func New(kubeConf string, namespace string) (kube *Kube, err error)
  • func (k *Kube) ConnectivityCheck() error
  • func (k *Kube) CreateKubeTunnelResource(resourceSpec models.KubeTunnelResourceSpec) error
  • func (k *Kube) GetPodLabelsByLabelSelector(namespace string, podLabelSelectors map[string]string) (map[string]string, error)
  • func (k *Kube) GetServiceContext(name string) (*servicecontext.ServiceContext, error)
  • func (k *Kube) GetServiceContextWithNamespace(name string, namespace string) (*servicecontext.ServiceContext, error)
  • func (k *Kube) ListServiceNamesWithoutKubeTunnel() (serviceNames []string, err error)
  • func (k *Kube) PortForward(serviceName string, port string) (listeningPort int, err error)
  • func (k *Kube) RBACCheck() error
• type PatchOperation

Types

type Kube

type Kube struct {
	InnerKubeClient *kubernetes.Clientset
	Config          *rest.Config
	Namespace       string
}

func MustNew

func MustNew(kubeConf string, namespace string) *Kube

func New

func New(kubeConf string, namespace string) (kube *Kube, err error)

func (*Kube) ConnectivityCheck

func (k *Kube) ConnectivityCheck() error

func (*Kube) CreateKubeTunnelResource

func (k *Kube) CreateKubeTunnelResource(resourceSpec models.KubeTunnelResourceSpec) error

func (*Kube) GetPodLabelsByLabelSelector

func (k *Kube) GetPodLabelsByLabelSelector(namespace string, podLabelSelectors map[string]string) (map[string]string, error)

func (*Kube) GetServiceContext

func (k *Kube) GetServiceContext(name string) (*servicecontext.ServiceContext, error)

func (*Kube) GetServiceContextWithNamespace

func (k *Kube) GetServiceContextWithNamespace(name string, namespace string) (*servicecontext.ServiceContext, error)

func (*Kube) ListServiceNamesWithoutKubeTunnel

func (k *Kube) ListServiceNamesWithoutKubeTunnel() (serviceNames []string, err error)

func (*Kube) PortForward

func (k *Kube) PortForward(serviceName string, port string) (listeningPort int, err error)

func (*Kube) RBACCheck

func (k *Kube) RBACCheck() error

type PatchOperation

type PatchOperation struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value string `json:"value"`
}