Documentation
¶
Index ¶
Constants ¶
View Source
const ( // ClientTimeout specifies the timeout for our calls to the API server for // all client operations ClientTimeout = 30 * time.Second // APIResponseSoftLimit specifies the time after which a Warning gets logged if // response from API is not received before that time APIResponseSoftLimit = 2 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
// InitialSync is called once after informer caches are synced but before workers start.
// Use this for one-time cleanup or initialization that requires access to the full
// state of the cluster (e.g., listing all existing resources).
InitialSync() error
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.