cluster

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 29, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PodListenerWithNamespace added in v0.1.0

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 added in v0.1.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL