factory

Documentation

Index

• type Handler
• type WatchFactory
  • func NewWatchFactory(c kubernetes.Interface, stopChan chan struct{}) (*WatchFactory, error)
  • func (wf *WatchFactory) AddEndpointsHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) AddFilteredNamespaceHandler(namespace string, lsel *metav1.LabelSelector, ...) (*Handler, error)
  • func (wf *WatchFactory) AddFilteredPodHandler(namespace string, lsel *metav1.LabelSelector, ...) (*Handler, error)
  • func (wf *WatchFactory) AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) AddNodeHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) AddPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)
  • func (wf *WatchFactory) RemoveEndpointsHandler(handler *Handler) error
  • func (wf *WatchFactory) RemoveNamespaceHandler(handler *Handler) error
  • func (wf *WatchFactory) RemoveNodeHandler(handler *Handler) error
  • func (wf *WatchFactory) RemovePodHandler(handler *Handler) error
  • func (wf *WatchFactory) RemovePolicyHandler(handler *Handler) error
  • func (wf *WatchFactory) RemoveServiceHandler(handler *Handler) error
  • func (wf *WatchFactory) Shutdown()

Types

type Handler

type Handler struct {
	cache.FilteringResourceEventHandler
	// contains filtered or unexported fields
}

Handler represents an event handler and is private to the factory module

type WatchFactory

type WatchFactory struct {
	// contains filtered or unexported fields
}

WatchFactory initializes and manages common kube watches

func NewWatchFactory

func NewWatchFactory(c kubernetes.Interface, stopChan chan struct{}) (*WatchFactory, error)

NewWatchFactory initializes a new watch factory

func (*WatchFactory) AddEndpointsHandler

func (wf *WatchFactory) AddEndpointsHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddEndpointsHandler adds a handler function that will be executed on Endpoints object changes

func (*WatchFactory) AddFilteredNamespaceHandler

func (wf *WatchFactory) AddFilteredNamespaceHandler(namespace string, lsel *metav1.LabelSelector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddFilteredNamespaceHandler adds a handler function that will be executed when Namespace objects that match the given filters change

func (*WatchFactory) AddFilteredPodHandler

func (wf *WatchFactory) AddFilteredPodHandler(namespace string, lsel *metav1.LabelSelector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddFilteredPodHandler adds a handler function that will be executed when Pod objects that match the given filters change

func (*WatchFactory) AddNamespaceHandler

func (wf *WatchFactory) AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddNamespaceHandler adds a handler function that will be executed on Namespace object changes

func (*WatchFactory) AddNodeHandler

func (wf *WatchFactory) AddNodeHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddNodeHandler adds a handler function that will be executed on Node object changes

func (*WatchFactory) AddPodHandler

func (wf *WatchFactory) AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddPodHandler adds a handler function that will be executed on Pod object changes

func (*WatchFactory) AddPolicyHandler

func (wf *WatchFactory) AddPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddPolicyHandler adds a handler function that will be executed on NetworkPolicy object changes

func (*WatchFactory) AddServiceHandler

func (wf *WatchFactory) AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (*Handler, error)

AddServiceHandler adds a handler function that will be executed on Service object changes

func (*WatchFactory) RemoveEndpointsHandler

func (wf *WatchFactory) RemoveEndpointsHandler(handler *Handler) error

RemoveEndpointsHandler removes a Endpoints object event handler function

func (*WatchFactory) RemoveNamespaceHandler

func (wf *WatchFactory) RemoveNamespaceHandler(handler *Handler) error

RemoveNamespaceHandler removes a Namespace object event handler function

func (*WatchFactory) RemoveNodeHandler

func (wf *WatchFactory) RemoveNodeHandler(handler *Handler) error

RemoveNodeHandler removes a Node object event handler function

func (*WatchFactory) RemovePodHandler

func (wf *WatchFactory) RemovePodHandler(handler *Handler) error

RemovePodHandler removes a Pod object event handler function

func (*WatchFactory) RemovePolicyHandler

func (wf *WatchFactory) RemovePolicyHandler(handler *Handler) error

RemovePolicyHandler removes a NetworkPolicy object event handler function

func (*WatchFactory) RemoveServiceHandler

func (wf *WatchFactory) RemoveServiceHandler(handler *Handler) error

RemoveServiceHandler removes a Service object event handler function

func (*WatchFactory) Shutdown

func (wf *WatchFactory) Shutdown()

Shutdown removes all handlers