factory

package

v0.2.0 Latest Latest Go to latest Published: Mar 28, 2018 License: Apache-2.0 Imports: 5 Imported by: 51

Details

This section is empty.

This section is empty.

This section is empty.

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

WatchFactory initializes and manages common kube watches

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

NewWatchFactory initializes a new watch factory

func (wf *WatchFactory) AddEndpointHandler(handler cache.ResourceEventHandler, processExisting func([]interface{}))

AddEndpointHandler adds a handler function that will be executed on Endpoint object changes

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

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

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

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

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

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

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

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

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

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