volume

Documentation

Index

• func Start(controllerMtx *sync.RWMutex, stopCh <-chan struct{}) error
• type VolController
  • func (c *VolController) Run(threadiness int, stopCh <-chan struct{}) error
• type VolControllerBuilder
  • func NewVolControllerBuilder() *VolControllerBuilder
  • func (cb *VolControllerBuilder) Build() (*VolController, error)

Functions

func Start

func Start(controllerMtx *sync.RWMutex, stopCh <-chan struct{}) error

Start starts the devicevolume controller.

Types

type VolController

type VolController struct {
	VolLister listers.DeviceVolumeLister

	// VolSynced is used for caches sync to get populated
	VolSynced cache.InformerSynced
	// contains filtered or unexported fields
}

VolController is the controller implementation for volume resources

func (*VolController) Run

func (c *VolController) Run(threadiness int, 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 VolControllerBuilder

type VolControllerBuilder struct {
	VolController *VolController
}

VolControllerBuilder is the builder object for controller.

func NewVolControllerBuilder

func NewVolControllerBuilder() *VolControllerBuilder

NewVolControllerBuilder returns an empty instance of controller builder.

func (*VolControllerBuilder) Build

func (cb *VolControllerBuilder) Build() (*VolController, error)

Build returns a controller instance.