watcher

package
v0.0.0-...-468f387 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AlertEventListFunc 

func AlertEventListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func AlertEventWatchFunc 

func AlertEventWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func AlertListFunc 

func AlertListFunc(c acs.AppsCodeExtensionInterface) func(kapi.ListOptions) (runtime.Object, error)

func AlertWatchFunc 

func AlertWatchFunc(c acs.AppsCodeExtensionInterface) func(options kapi.ListOptions) (watch.Interface, error)

func CertificateListFunc 

func CertificateListFunc(c acs.AppsCodeExtensionInterface) func(kapi.ListOptions) (runtime.Object, error)

func CertificateWatchFunc 

func CertificateWatchFunc(c acs.AppsCodeExtensionInterface) func(options kapi.ListOptions) (watch.Interface, error)

func DaemonSetListFunc 

func DaemonSetListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func DaemonSetWatchFunc 

func DaemonSetWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func DeploymentListFunc 

func DeploymentListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func DeploymentWatchFunc 

func DeploymentWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func EndpointListFunc 

func EndpointListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func EndpointWatchFunc 

func EndpointWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func ExtendedIngressListFunc 

func ExtendedIngressListFunc(c acs.AppsCodeExtensionInterface) func(kapi.ListOptions) (runtime.Object, error)

func ExtendedIngressWatchFunc 

func ExtendedIngressWatchFunc(c acs.AppsCodeExtensionInterface) func(options kapi.ListOptions) (watch.Interface, error)

func IngressListFunc 

func IngressListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func IngressWatchFunc 

func IngressWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func NamespaceListFunc 

func NamespaceListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func NamespaceWatchFunc 

func NamespaceWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func NodeListFunc 

func NodeListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func NodeWatchFunc 

func NodeWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func PodListFunc 

func PodListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func PodWatchFunc 

func PodWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func ReplicaSetListFunc 

func ReplicaSetListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func ReplicaSetWatchFunc 

func ReplicaSetWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func ReplicationControllerListFunc 

func ReplicationControllerListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func ReplicationControllerWatchFunc 

func ReplicationControllerWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func ServiceListFunc 

func ServiceListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func ServiceWatchFunc 

func ServiceWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

func StatefulSetListFunc 

func StatefulSetListFunc(c clientset.Interface) func(kapi.ListOptions) (runtime.Object, error)

func StatefulSetWatchFunc 

func StatefulSetWatchFunc(c clientset.Interface) func(options kapi.ListOptions) (watch.Interface, error)

Types

type Watcher 

type Watcher struct {
	// kubernetes client to apiserver
	Client clientset.Interface

	// client for getting the appscode extensions
	AppsCodeExtensionClient acs.AppsCodeExtensionInterface

	// sync time to sync the list.
	SyncPeriod time.Duration

	// lister store
	Storage *stash.Storage

	Dispatch func(e *events.Event) error

	sync.Mutex
}

func (*Watcher) Alert 

func (k *Watcher) Alert()

func (*Watcher) AlertEvent 

func (k *Watcher) AlertEvent()

func (*Watcher) Cache 

func (k *Watcher) Cache(resource events.ObjectType, object runtime.Object, lw *cache.ListWatch) (cache.Store, *cache.Controller)

func (*Watcher) CacheIndexer 

func (k *Watcher) CacheIndexer(resource events.ObjectType, object runtime.Object, lw *cache.ListWatch, indexers cache.Indexers) (cache.Indexer, *cache.Controller)

func (*Watcher) CacheStore 

func (k *Watcher) CacheStore(resource events.ObjectType, object runtime.Object, lw *cache.ListWatch) (cache.Store, *cache.Controller)

func (*Watcher) Certificate 

func (k *Watcher) Certificate()

func (*Watcher) DaemonSet 

func (k *Watcher) DaemonSet()

func (*Watcher) Deployment 

func (k *Watcher) Deployment()

func (*Watcher) Endpoint 

func (k *Watcher) Endpoint()

func (*Watcher) ExtendedIngress 

func (k *Watcher) ExtendedIngress()

func (*Watcher) Ingress 

func (k *Watcher) Ingress()

func (*Watcher) Namespace 

func (k *Watcher) Namespace()

func (*Watcher) Node 

func (k *Watcher) Node()

func (*Watcher) Pod 

func (k *Watcher) Pod()

func (*Watcher) RC 

func (k *Watcher) RC()

func (*Watcher) ReplicaSet 

func (k *Watcher) ReplicaSet()

func (*Watcher) Service 

func (k *Watcher) Service()

func (*Watcher) StatefulSet 

func (k *Watcher) StatefulSet()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.