cluster

Documentation

Index

• func PodListenerWithNamespace(client kubernetes.Interface, namespace string, stopCh <-chan struct{}) (lister v1.PodLister, err error)
• type Watcher
  • func Construct(client kubernetes.Interface, config *rest.Config) (w Watcher, err error)
  • func (w *Watcher) Endpoints(stopCh <-chan struct{}) (lister v1.EndpointsLister, err error)
  • func (w *Watcher) Namespaces(stopCh <-chan struct{}) (lister v1.NamespaceLister, err error)
  • func (w *Watcher) Pods(stopCh <-chan struct{}) (lister v1.PodLister, err error)
  • func (w *Watcher) PodsWithNamespace(namespace string, stopCh <-chan struct{}) (lister v1.PodLister, err error)
  • func (w *Watcher) Services(stopCh <-chan struct{}) (lister v1.ServiceLister, err error)

Functions

func PodListenerWithNamespace

func PodListenerWithNamespace(client kubernetes.Interface, namespace string, stopCh <-chan struct{}) (lister v1.PodLister, err error)

PodListenerWithNamespace PodListener

Types

type Watcher

type Watcher struct {
	Client          kubernetes.Interface
	Config          *rest.Config
	NamespaceLister v1.NamespaceLister
	PodLister       v1.PodLister
	ServiceLister   v1.ServiceLister
	EndpointsLister v1.EndpointsLister
}

Watcher Kubernetes resource watch

func Construct

func Construct(client kubernetes.Interface, config *rest.Config) (w Watcher, err error)

Construct for watcher

func (*Watcher) Endpoints

func (w *Watcher) Endpoints(stopCh <-chan struct{}) (lister v1.EndpointsLister, err error)

Endpoints informer of endpoints

func (*Watcher) Namespaces

func (w *Watcher) Namespaces(stopCh <-chan struct{}) (lister v1.NamespaceLister, err error)

Namespaces informer of namespace

func (*Watcher) Pods

func (w *Watcher) Pods(stopCh <-chan struct{}) (lister v1.PodLister, err error)

Pods watch pods change

func (*Watcher) PodsWithNamespace

func (w *Watcher) PodsWithNamespace(namespace string, stopCh <-chan struct{}) (lister v1.PodLister, err error)

PodsWithNamespace watch pods change

func (*Watcher) Services

func (w *Watcher) Services(stopCh <-chan struct{}) (lister v1.ServiceLister, err error)

Services informer of service