watch

Documentation

Index

• func Channel() <-chan Event
• func ClientFromCluster() (client *kubernetes.Clientset, err error)
• func ClientFromFile(masterURL, kubeconfigPath string) (client *kubernetes.Clientset, err error)
• func Close()
• func ComponentStatuses(opts metav1.ListOptions)
• func ConfigMaps(opts metav1.ListOptions)
• func DaemonSets(opts metav1.ListOptions)
• func Deployments(opts metav1.ListOptions)
• func Endpoints(opts metav1.ListOptions)
• func Ingresses(opts metav1.ListOptions)
• func LimitRanges(opts metav1.ListOptions)
• func Namespaces(opts metav1.ListOptions)
• func Nodes(opts metav1.ListOptions)
• func PersistentVolumeClaims(opts metav1.ListOptions)
• func PersistentVolumes(opts metav1.ListOptions)
• func PodSecurityPolicies(opts metav1.ListOptions)
• func Pods(opts metav1.ListOptions)
• func Register(identifier string, cl *kubernetes.Clientset, namespace ...string)
• func ReplicaSets(opts metav1.ListOptions)
• func ServiceAccounts(opts metav1.ListOptions)
• func Services(opts metav1.ListOptions)
• func Watchers(opts metav1.ListOptions, name string, fn Watcher)
• type CloseComplete
  • func (cc CloseComplete) DeepCopyObject() runtime.Object
  • func (cc CloseComplete) GetObjectKind() schema.ObjectKind
• type ErrWatcher
  • func (err ErrWatcher) DeepCopyObject() runtime.Object
  • func (err ErrWatcher) Error() string
  • func (err ErrWatcher) GetObjectKind() schema.ObjectKind
• type Event
• type Metadata
• type Watcher

Functions

func Channel

func Channel() <-chan Event

func ClientFromCluster

func ClientFromCluster() (client *kubernetes.Clientset, err error)

func ClientFromFile

func ClientFromFile(masterURL, kubeconfigPath string) (client *kubernetes.Clientset, err error)

func Close

func Close()

func ComponentStatuses

func ComponentStatuses(opts metav1.ListOptions)

func ConfigMaps

func ConfigMaps(opts metav1.ListOptions)

func DaemonSets

func DaemonSets(opts metav1.ListOptions)

func Deployments

func Deployments(opts metav1.ListOptions)

func Endpoints

func Endpoints(opts metav1.ListOptions)

func Ingresses

func Ingresses(opts metav1.ListOptions)

func LimitRanges

func LimitRanges(opts metav1.ListOptions)

func Namespaces

func Namespaces(opts metav1.ListOptions)

func Nodes

func Nodes(opts metav1.ListOptions)

func PersistentVolumeClaims

func PersistentVolumeClaims(opts metav1.ListOptions)

func PersistentVolumes

func PersistentVolumes(opts metav1.ListOptions)

func PodSecurityPolicies

func PodSecurityPolicies(opts metav1.ListOptions)

func Pods

func Pods(opts metav1.ListOptions)

func Register

func Register(identifier string, cl *kubernetes.Clientset, namespace ...string)

func ReplicaSets

func ReplicaSets(opts metav1.ListOptions)

func ServiceAccounts

func ServiceAccounts(opts metav1.ListOptions)

func Services

func Services(opts metav1.ListOptions)

func Watchers

func Watchers(opts metav1.ListOptions, name string, fn Watcher)

Types

type CloseComplete

type CloseComplete struct{}

func (CloseComplete) DeepCopyObject

func (cc CloseComplete) DeepCopyObject() runtime.Object

func (CloseComplete) GetObjectKind

func (cc CloseComplete) GetObjectKind() schema.ObjectKind

type ErrWatcher

type ErrWatcher Metadata

func (ErrWatcher) DeepCopyObject

func (err ErrWatcher) DeepCopyObject() runtime.Object

func (ErrWatcher) Error

func (err ErrWatcher) Error() string

func (ErrWatcher) GetObjectKind

func (err ErrWatcher) GetObjectKind() schema.ObjectKind

type Event

type Event struct {
	Event    watch.Event
	Metadata Metadata
}

type Metadata

type Metadata struct {
	Function, Identifier, Namespace string
}

type Watcher

type Watcher func(*client, string, metav1.ListOptions) (watch.Interface, error)