k8s

Documentation

Index

• type Cluster
  • func NewCluster(c context.Context, kubeFlags *Config, namespaces []string) (*Cluster, error)
  • func (kc *Cluster) ActualNamespace(namespace string) string
  • func (kc *Cluster) AddNamespaceListener(c context.Context, nsListener NamespaceListener)
  • 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) WaitForNSSync(c context.Context)
  • func (kc *Cluster) WithK8sInterface(c context.Context) context.Context
• type Config
  • func NewConfig(c context.Context, flagMap map[string]string) (*Config, error)
  • func NewInClusterConfig(c context.Context, flagMap map[string]string) (*Config, error)
  • func (kf *Config) ContextServiceAndFlagsEqual(okf *Config) bool
  • func (kf *Config) GetManagerNamespace() string
  • func (kf *Config) GetRestConfig() *rest.Config
• type KubeConfig
• type NamespaceListener

Types

type Cluster

type Cluster struct {
	*Config
	// contains filtered or unexported fields
}

Cluster is a Kubernetes cluster reference.

func NewCluster

func NewCluster(c context.Context, kubeFlags *Config, 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 NamespaceListener)

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) WaitForNSSync

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

func (*Cluster) WithK8sInterface

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

type Config

type Config struct {
	Namespace string // default cluster namespace.
	Context   string
	Server    string

	ConfigFlags *genericclioptions.ConfigFlags
	RestConfig  *rest.Config
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(c context.Context, flagMap map[string]string) (*Config, error)

func NewInClusterConfig

func NewInClusterConfig(c context.Context, flagMap map[string]string) (*Config, error)

This represents an inClusterConfig.

func (*Config) ContextServiceAndFlagsEqual

func (kf *Config) ContextServiceAndFlagsEqual(okf *Config) bool

ContextServiceAndFlagsEqual determines if this instance is equal to the given instance with respect to context, server, and flag arguments.

func (*Config) GetManagerNamespace

func (kf *Config) GetManagerNamespace() string

func (*Config) GetRestConfig

func (kf *Config) GetRestConfig() *rest.Config

type KubeConfig

type KubeConfig interface {
	GetRestConfig() *rest.Config
	GetManagerNamespace() string
}

type NamespaceListener

type NamespaceListener func(context.Context)