controller

Documentation

Index

• Constants
• type CloudNetworkConfigController
  • func NewCloudNetworkConfigController(syncs []cache.InformerSynced, ...) *CloudNetworkConfigController
  • func (c *CloudNetworkConfigController) Enqueue(obj interface{})
  • func (c *CloudNetworkConfigController) Run(stopCh <-chan struct{}) error
• type CloudNetworkConfigControllerIntf

Constants

const (

	// ClientTimeout specifies the timeout for our calls to the API server for
	// all client operations
	ClientTimeout = 2 * time.Second
)

Types

type CloudNetworkConfigController

type CloudNetworkConfigController struct {
	// CloudNetworkConfigController implements the generic interface: which
	// allows all derived controllers an abstraction from the "bricks and pipes"
	// of the controller framework, allowing them to implement only their
	// specific control loop functionality and not bother with the rest.
	CloudNetworkConfigControllerIntf
	// contains filtered or unexported fields
}

func NewCloudNetworkConfigController

func NewCloudNetworkConfigController(
	syncs []cache.InformerSynced,
	resourceController CloudNetworkConfigControllerIntf,
	resourceControllerKey string,
	resourceControllerType reflect.Type) *CloudNetworkConfigController

func (*CloudNetworkConfigController) Enqueue

func (c *CloudNetworkConfigController) Enqueue(obj interface{})

Enqueue takes a resource object and converts it into a name/namespace or name string which is then put onto the work queue. This method __should__ not be passed resources of any type other than the dedicated controller object.

func (*CloudNetworkConfigController) Run

func (c *CloudNetworkConfigController) Run(stopCh <-chan struct{}) error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

type CloudNetworkConfigControllerIntf

type CloudNetworkConfigControllerIntf interface {
	SyncHandler(key string) error
}