controller

Documentation

Index

• Constants
• type Controller
  • func New(kubeClientset kubernetes.Interface, cryptClientset clientset.Interface, ...) *Controller
  • func (c *Controller) Run(workers int, stopChan <-chan struct{}) error
• type Option
  • func WithEventRecorder(recorder record.EventRecorder) Option

Constants

const (
	ComponentName = "crypt-controller"

	// SuccessSynced is used as part of the Event 'reason' when a Crypt is synced
	SuccessSynced = "Synced"

	// MessageResourceSynced is the message used for an Event fired when a Crypt is synced successfully
	MessageResourceSynced = "Crypt synced successfully"
)

Types

type Controller

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

func New

func New(
	kubeClientset kubernetes.Interface,
	cryptClientset clientset.Interface,
	namespaceInformer coreinformers.NamespaceInformer,
	secreteInformer coreinformers.SecretInformer,
	cryptInformer informers.CryptInformer,
	store store.Store,
	opts ...Option,
) *Controller

func (*Controller) Run

func (c *Controller) Run(workers int, stopChan <-chan struct{}) error

type Option

type Option func(*Controller)

func WithEventRecorder

func WithEventRecorder(recorder record.EventRecorder) Option