watchers

Documentation

Index

• Variables
• func StartEndpointsWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*endpointsWatcher, error)
• func StartNamespaceWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*namespaceWatcher, error)
• func StartNetworkPolicyWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*networkPolicyWatcher, error)
• func StartNodeWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*nodeWatcher, error)
• func StartPodWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*podWatcher, error)
• func StartServiceWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*serviceWatcher, error)
• func StopEndpointsWatcher()
• func StopNamespaceWatcher()
• func StopNetworkPolicyWatcher()
• func StopNodeWatcher()
• func StopPodWatcher()
• func StopServiceWatcher()
• type EndpointsUpdate
• type EndpointsUpdatesHandler
• type NamespaceUpdate
• type NamespaceUpdatesHandler
• type NetworkPolicyUpdate
• type NetworkPolicyUpdatesHandler
• type NodeUpdate
• type NodeUpdatesHandler
• type Operation
• type PodUpdate
• type PodUpdatesHandler
• type ServiceUpdate
• type ServiceUpdatesHandler

Variables

var (
	EndpointsWatcher *endpointsWatcher
)

var (
	NamespaceWatcher *namespaceWatcher
)

var (
	NetworkPolicyWatcher *networkPolicyWatcher
)

var (
	NodeWatcher *nodeWatcher
)

var (
	PodWatcher *podWatcher
)

var (
	ServiceWatcher *serviceWatcher
)

Functions

func StartEndpointsWatcher

func StartEndpointsWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*endpointsWatcher, error)

func StartNamespaceWatcher

func StartNamespaceWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*namespaceWatcher, error)

func StartNetworkPolicyWatcher

func StartNetworkPolicyWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*networkPolicyWatcher, error)

func StartNodeWatcher

func StartNodeWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*nodeWatcher, error)

func StartPodWatcher

func StartPodWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*podWatcher, error)

func StartServiceWatcher

func StartServiceWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration) (*serviceWatcher, error)

func StopEndpointsWatcher

func StopEndpointsWatcher()

func StopNamespaceWatcher

func StopNamespaceWatcher()

func StopNetworkPolicyWatcher

func StopNetworkPolicyWatcher()

func StopNodeWatcher

func StopNodeWatcher()

func StopPodWatcher

func StopPodWatcher()

func StopServiceWatcher

func StopServiceWatcher()

Types

type EndpointsUpdate

type EndpointsUpdate struct {
	Endpoints *api.Endpoints
	Op        Operation
}

type EndpointsUpdatesHandler

type EndpointsUpdatesHandler interface {
	OnEndpointsUpdate(endpointsUpdate *EndpointsUpdate)
}

type NamespaceUpdate

type NamespaceUpdate struct {
	Namespace *api.Namespace
	Op        Operation
}

type NamespaceUpdatesHandler

type NamespaceUpdatesHandler interface {
	OnNamespaceUpdate(namespaceUpdate *NamespaceUpdate)
}

type NetworkPolicyUpdate

type NetworkPolicyUpdate struct {
	NetworkPolicy *apiextensions.NetworkPolicy
	Op            Operation
}

type NetworkPolicyUpdatesHandler

type NetworkPolicyUpdatesHandler interface {
	OnNetworkPolicyUpdate(networkPolicyUpdate *NetworkPolicyUpdate)
}

type NodeUpdate

type NodeUpdate struct {
	Node *api.Node
	Op   Operation
}

type NodeUpdatesHandler

type NodeUpdatesHandler interface {
	OnNodeUpdate(nodeUpdate *NodeUpdate)
}

type Operation

type Operation int

const (
	ADD Operation = iota
	UPDATE
	REMOVE
	SYNCED
)

type PodUpdate

type PodUpdate struct {
	Pod *api.Pod
	Op  Operation
}

type PodUpdatesHandler

type PodUpdatesHandler interface {
	OnPodUpdate(podUpdate *PodUpdate)
}

type ServiceUpdate

type ServiceUpdate struct {
	Service *api.Service
	Op      Operation
}

type ServiceUpdatesHandler

type ServiceUpdatesHandler interface {
	OnServiceUpdate(serviceUpdate *ServiceUpdate)
}