k8s

Documentation

Index

• type Cluster
  • func ConnectCluster(c context.Context, cr *rpc.ConnectRequest, config *client.Kubeconfig) (*Cluster, error)
  • func NewCluster(c context.Context, kubeFlags *client.Kubeconfig, namespaces []string) (*Cluster, error)
  • func (kc *Cluster) ActualNamespace(namespace string) string
  • func (kc *Cluster) AddNamespaceListener(c context.Context, nsListener userd.NamespaceListener)
  • func (kc *Cluster) CanWatchNamespaces(ctx context.Context) bool
  • func (kc *Cluster) GetClusterId(ctx context.Context) string
  • func (kc *Cluster) GetCurrentNamespaces(forClientAccess bool) []string
  • func (kc *Cluster) SetMappedNamespaces(c context.Context, namespaces []string) bool
  • func (kc *Cluster) StartNamespaceWatcher(ctx context.Context)
  • func (kc *Cluster) WithK8sInterface(c context.Context) context.Context

Types

type Cluster

type Cluster struct {
	*client.Kubeconfig
	MappedNamespaces []string
	// contains filtered or unexported fields
}

Cluster is a Kubernetes cluster reference.

func ConnectCluster

func ConnectCluster(c context.Context, cr *rpc.ConnectRequest, config *client.Kubeconfig) (*Cluster, error)

func NewCluster

func NewCluster(c context.Context, kubeFlags *client.Kubeconfig, namespaces []string) (*Cluster, error)

func (*Cluster) ActualNamespace

func (kc *Cluster) ActualNamespace(namespace string) string

func (*Cluster) AddNamespaceListener

func (kc *Cluster) AddNamespaceListener(c context.Context, nsListener userd.NamespaceListener)

func (*Cluster) CanWatchNamespaces

func (kc *Cluster) CanWatchNamespaces(ctx context.Context) bool

CanWatchNamespaces answers the question if this client has the RBAC permissions necessary to watch namespaces. The answer is likely false when using a namespaces scoped installation.

func (*Cluster) GetClusterId

func (kc *Cluster) GetClusterId(ctx context.Context) string

func (*Cluster) GetCurrentNamespaces

func (kc *Cluster) GetCurrentNamespaces(forClientAccess bool) []string

GetCurrentNamespaces returns the names of the namespaces that this client is mapping. If the forClientAccess is true, then the namespaces are restricted to those where an intercept can take place, i.e. the namespaces where this client can Watch and get services and deployments.

func (*Cluster) SetMappedNamespaces

func (kc *Cluster) SetMappedNamespaces(c context.Context, namespaces []string) bool

func (*Cluster) StartNamespaceWatcher

func (kc *Cluster) StartNamespaceWatcher(ctx context.Context)

StartNamespaceWatcher runs a Kubernetes Watcher that provide information about the cluster's namespaces'. The function waits for the first snapshot to arrive before returning.

func (*Cluster) WithK8sInterface

func (kc *Cluster) WithK8sInterface(c context.Context) context.Context