watchers

Documentation

Index

• Variables
• func StartEndpointsWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration, namespace string, ...) (*endpointsWatcher, error)
• func StartNetworkPolicyWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration, namespace string, ...) (*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.Interface, resyncPeriod time.Duration, namespace string) (*serviceWatcher, error)
• func StopEndpointsWatcher()
• func StopNetworkPolicyWatcher()
• func StopNodeWatcher()
• func StopPodWatcher()
• func StopServiceWatcher()
• type EndpointsUpdate
• type EndpointsUpdatesHandler
• type NetworkPolicyUpdate
• type NetworkPolicyUpdatesHandler
• type NodeUpdate
• type NodeUpdatesHandler
• type PodUpdate
• type PodUpdatesHandler
• type ServiceUpdate
• type ServiceUpdatesHandler

Variables

var (
	EndpointsWatcher *endpointsWatcher
)

var (
	NetworkPolicyWatcher *networkPolicyWatcher
)

var (
	NodeWatcher *nodeWatcher
)

var (
	PodWatcher *podWatcher
)

var (
	ServiceWatcher *serviceWatcher
)

Functions

func StartEndpointsWatcher

func StartEndpointsWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration, namespace string, filter fields.Selector) (*endpointsWatcher, error)

func StartNetworkPolicyWatcher

func StartNetworkPolicyWatcher(clientset *kubernetes.Clientset, resyncPeriod time.Duration, namespace string, filter fields.Selector) (*networkPolicyWatcher, error)

func StartNodeWatcher

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

func StartPodWatcher

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

func StartServiceWatcher

func StartServiceWatcher(clientset kubernetes.Interface, resyncPeriod time.Duration, namespace string) (*serviceWatcher, error)

func StopEndpointsWatcher

func StopEndpointsWatcher()

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        utils.Operation
}

type EndpointsUpdatesHandler

type EndpointsUpdatesHandler interface {
	OnEndpointsUpdate(endpointsUpdate *EndpointsUpdate)
}

type NetworkPolicyUpdate

type NetworkPolicyUpdate struct {
	NetworkPolicy interface{}
	Op            utils.Operation
}

type NetworkPolicyUpdatesHandler

type NetworkPolicyUpdatesHandler interface {
	OnNetworkPolicyUpdate(networkPolicyUpdate *NetworkPolicyUpdate)
}

type NodeUpdate

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

type NodeUpdatesHandler

type NodeUpdatesHandler interface {
	OnNodeUpdate(nodeUpdate *NodeUpdate)
}

type PodUpdate

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

type PodUpdatesHandler

type PodUpdatesHandler interface {
	OnPodUpdate(podUpdate *PodUpdate)
}

type ServiceUpdate

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

type ServiceUpdatesHandler

type ServiceUpdatesHandler interface {
	OnServiceUpdate(serviceUpdate *ServiceUpdate)
}