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(nsListener NamespaceListener)
  • func (kc *Cluster) FindPodFromSelector(c context.Context, namespace string, selector map[string]string) (k8sapi.Object, error)
  • 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 (kf *Config) ContextServiceAndFlagsEqual(okf *Config) bool
  • func (kf *Config) GetManagerNamespace() string
• type NamespaceListener
• type StateListener
• type Watcher
  • func NewWatcher(resource, namespace string, getter cache.Getter, objType runtime.Object, ...) *Watcher
  • func (w *Watcher) Active() bool
  • func (w *Watcher) AddStateListener(l *StateListener)
  • func (w *Watcher) Cancel()
  • func (w *Watcher) EnsureStarted(c context.Context, cb func(bool))
  • func (w *Watcher) Get(c context.Context, obj interface{}) (interface{}, bool, error)
  • func (w *Watcher) HasSynced() bool
  • func (w *Watcher) List(c context.Context) []interface{}
  • func (w *Watcher) RemoveStateListener(rl *StateListener)
  • func (w *Watcher) Watch(c context.Context, ready *sync.WaitGroup)

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(nsListener NamespaceListener)

func (*Cluster) FindPodFromSelector

func (kc *Cluster) FindPodFromSelector(c context.Context, namespace string, selector map[string]string) (k8sapi.Object, error)

FindPodFromSelector returns a pod with the given name-hex-hex

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
	// contains filtered or unexported fields
}

func NewConfig

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

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

type NamespaceListener

type NamespaceListener func(context.Context)

type StateListener

type StateListener struct {
	Cb func()
}

type Watcher

type Watcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Watcher watches some resource and can be cancelled

func NewWatcher

func NewWatcher(resource, namespace string, getter cache.Getter, objType runtime.Object, cond *sync.Cond, equals func(runtime.Object, runtime.Object) bool) *Watcher

func (*Watcher) Active

func (w *Watcher) Active() bool

Active returns true if the watcher has been started and not yet cancelled

func (*Watcher) AddStateListener

func (w *Watcher) AddStateListener(l *StateListener)

AddStateListener adds a listener function that will be called when the watcher changes its state (starts or is cancelled)

func (*Watcher) Cancel

func (w *Watcher) Cancel()

func (*Watcher) EnsureStarted

func (w *Watcher) EnsureStarted(c context.Context, cb func(bool))

func (*Watcher) Get

func (w *Watcher) Get(c context.Context, obj interface{}) (interface{}, bool, error)

func (*Watcher) HasSynced

func (w *Watcher) HasSynced() bool

HasSynced returns true if this Watcher's controller has synced, or if this watcher hasn't started yet

func (*Watcher) List

func (w *Watcher) List(c context.Context) []interface{}

func (*Watcher) RemoveStateListener

func (w *Watcher) RemoveStateListener(rl *StateListener)

RemoveStateListener removes a listener function

func (*Watcher) Watch

func (w *Watcher) Watch(c context.Context, ready *sync.WaitGroup)