Documentation
¶
Index ¶
- type WatchFactory
- func (wf *WatchFactory) AddEndpointsHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) AddFilteredNamespaceHandler(namespace string, lsel *metav1.LabelSelector, ...) (uint64, error)
- func (wf *WatchFactory) AddFilteredPodHandler(namespace string, lsel *metav1.LabelSelector, ...) (uint64, error)
- func (wf *WatchFactory) AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) AddNodeHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) AddPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
- func (wf *WatchFactory) RemoveEndpointsHandler(handlerID uint64) error
- func (wf *WatchFactory) RemoveNamespaceHandler(handlerID uint64) error
- func (wf *WatchFactory) RemoveNodeHandler(handlerID uint64) error
- func (wf *WatchFactory) RemovePodHandler(handlerID uint64) error
- func (wf *WatchFactory) RemovePolicyHandler(handlerID uint64) error
- func (wf *WatchFactory) RemoveServiceHandler(handlerID uint64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WatchFactory ¶ added in v0.2.0
type WatchFactory struct {
// contains filtered or unexported fields
}
WatchFactory initializes and manages common kube watches
func NewWatchFactory ¶ added in v0.2.0
func NewWatchFactory(c kubernetes.Interface, stopChan <-chan struct{}) (*WatchFactory, error)
NewWatchFactory initializes a new watch factory
func (*WatchFactory) AddEndpointsHandler ¶ added in v0.3.0
func (wf *WatchFactory) AddEndpointsHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddEndpointsHandler adds a handler function that will be executed on Endpoints object changes
func (*WatchFactory) AddFilteredNamespaceHandler ¶ added in v0.3.0
func (wf *WatchFactory) AddFilteredNamespaceHandler(namespace string, lsel *metav1.LabelSelector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddFilteredNamespaceHandler adds a handler function that will be executed when Namespace objects that match the given filters change
func (*WatchFactory) AddFilteredPodHandler ¶ added in v0.3.0
func (wf *WatchFactory) AddFilteredPodHandler(namespace string, lsel *metav1.LabelSelector, handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddFilteredPodHandler adds a handler function that will be executed when Pod objects that match the given filters change
func (*WatchFactory) AddNamespaceHandler ¶ added in v0.2.0
func (wf *WatchFactory) AddNamespaceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddNamespaceHandler adds a handler function that will be executed on Namespace object changes
func (*WatchFactory) AddNodeHandler ¶ added in v0.2.0
func (wf *WatchFactory) AddNodeHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddNodeHandler adds a handler function that will be executed on Node object changes
func (*WatchFactory) AddPodHandler ¶ added in v0.2.0
func (wf *WatchFactory) AddPodHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddPodHandler adds a handler function that will be executed on Pod object changes
func (*WatchFactory) AddPolicyHandler ¶ added in v0.2.0
func (wf *WatchFactory) AddPolicyHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddPolicyHandler adds a handler function that will be executed on NetworkPolicy object changes
func (*WatchFactory) AddServiceHandler ¶ added in v0.2.0
func (wf *WatchFactory) AddServiceHandler(handlerFuncs cache.ResourceEventHandler, processExisting func([]interface{})) (uint64, error)
AddServiceHandler adds a handler function that will be executed on Service object changes
func (*WatchFactory) RemoveEndpointsHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemoveEndpointsHandler(handlerID uint64) error
RemoveEndpointsHandler removes a Endpoints object event handler function
func (*WatchFactory) RemoveNamespaceHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemoveNamespaceHandler(handlerID uint64) error
RemoveNamespaceHandler removes a Namespace object event handler function
func (*WatchFactory) RemoveNodeHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemoveNodeHandler(handlerID uint64) error
RemoveNodeHandler removes a Node object event handler function
func (*WatchFactory) RemovePodHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemovePodHandler(handlerID uint64) error
RemovePodHandler removes a Pod object event handler function
func (*WatchFactory) RemovePolicyHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemovePolicyHandler(handlerID uint64) error
RemovePolicyHandler removes a NetworkPolicy object event handler function
func (*WatchFactory) RemoveServiceHandler ¶ added in v0.3.0
func (wf *WatchFactory) RemoveServiceHandler(handlerID uint64) error
RemoveServiceHandler removes a Service object event handler function
Source Files