controller

Documentation

Index

• func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, ...) bool
• type SnapshotController
  • func NewSnapshotController(client *rest.RESTClient, scheme *runtime.Scheme, ...) SnapshotController

Functions

func WaitForCacheSync

func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, cacheSyncs ...kcache.InformerSynced) bool

WaitForCacheSync is a wrapper around cache.WaitForCacheSync that generates log messages indicating that the controller identified by controllerName is waiting for syncs, followed by either a successful or failed sync. Taken from k8s 1.12

Types

type SnapshotController

type SnapshotController interface {
	Run(stopCh <-chan struct{})
}

SnapshotController is a controller that handles snapshot operations

func NewSnapshotController

func NewSnapshotController(client *rest.RESTClient,
	scheme *runtime.Scheme,
	clientset kubernetes.Interface,
	volumePlugins *map[string]volume.Plugin,
	syncDuration time.Duration) SnapshotController

NewSnapshotController creates a new SnapshotController