controller

package
v0.0.0-...-c3d1141 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AerospikeClusterController

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

AerospikeClusterController is the controller for AerospikeCluster resources

func NewAerospikeClusterController

func NewAerospikeClusterController(
	kubeClient kubernetes.Interface,
	aerospikeClient aerospikeclientset.Interface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	aerospikeInformerFactory aerospikeinformers.SharedInformerFactory) *AerospikeClusterController

NewAerospikeClusterController returns a new controller for AerospikeCluster resources

func (AerospikeClusterController) Run

func (c AerospikeClusterController) 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 AerospikeGarbageCollectorController

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

AerospikeGarbageCollectorController is the controller for AerospikeNamespaceBackup resources

func NewGarbageCollectorController

func NewGarbageCollectorController(
	kubeClient kubernetes.Interface,
	aerospikeClient aerospikeclientset.Interface,
	kubeInformerFactory informers.SharedInformerFactory,
	aerospikeInformerFactory aerospikeinformers.SharedInformerFactory) *AerospikeGarbageCollectorController

NewGarbageCollectorController returns a new controller for AerospikeNamespaceBackup resources

func (AerospikeGarbageCollectorController) Run

func (c AerospikeGarbageCollectorController) 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 AerospikeNamespaceBackupController

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

AerospikeNamespaceBackupController is the controller for AerospikeNamespaceBackup resources

func NewAerospikeNamespaceBackupController

func NewAerospikeNamespaceBackupController(
	kubeClient kubernetes.Interface,
	aerospikeClient aerospikeclientset.Interface,
	kubeInformerFactory informers.SharedInformerFactory,
	aerospikeInformerFactory aerospikeinformers.SharedInformerFactory) *AerospikeNamespaceBackupController

NewAerospikeNamespaceBackupController returns a new controller for AerospikeNamespaceBackup resources

func (AerospikeNamespaceBackupController) Run

func (c AerospikeNamespaceBackupController) 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 AerospikeNamespaceRestoreController

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

AerospikeNamespaceRestoreController is the controller for AerospikeNamespaceRestore resources

func NewAerospikeNamespaceRestoreController

func NewAerospikeNamespaceRestoreController(
	kubeClient kubernetes.Interface,
	aerospikeClient aerospikeclientset.Interface,
	kubeInformerFactory informers.SharedInformerFactory,
	aerospikeInformerFactory aerospikeinformers.SharedInformerFactory) *AerospikeNamespaceRestoreController

NewAerospikeNamespaceRestoreController returns a new controller for AerospikeNamespaceRestore objects

func (AerospikeNamespaceRestoreController) Run

func (c AerospikeNamespaceRestoreController) 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 Controller

type Controller interface {
	// Run instructs the workers to start processing items from the queue.
	Run(stopCh <-chan struct{}) error
}

Controller encapsulates a controller for Kubernetes resources.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL