controller

Documentation

Index

• Constants
• type Controller
  • func NewController(ctx context.Context, kubeclient kubernetes.Interface, ...) *Controller
  • func (c *Controller) Start()
  • func (c *Controller) Wait()
• type Recorder
• type Synchronizer

Constants

const (
	LabelKeyName            = "clustersecrets.core.cs.sap.com/name"
	AnnotationKeyGeneration = "clustersecrets.core.cs.sap.com/generation"
)

const (
	ControllerName = "clustersecret-operator.cs.sap.com"
)

Types

type Controller

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

func NewController

func NewController(ctx context.Context, kubeclient kubernetes.Interface, coreclient coreclients.Interface, synchronizer Synchronizer) *Controller

func (*Controller) Start

func (c *Controller) Start()

this method should not be called more than once on the same receiver; todo: safeguard with some lock

func (*Controller) Wait

func (c *Controller) Wait()

type Recorder

type Recorder interface {
	RecordCreation(runtime.Object)
	RecordUpdate(runtime.Object, runtime.Object)
	RecordDeletion(runtime.Object)
}

type Synchronizer

type Synchronizer interface {
	Init(map[schema.GroupVersionKind]cache.SharedIndexInformer)
	WaitUntilSynced()
}