controller

Documentation

Index

• type Base
  • func NewBase[KeyType comparable](controllerName string, scheme *runtime.Scheme, kubeClient kubernetes.Interface, ...) (*Base[KeyType], error)
  • func (bc *Base[KeyType]) Run(ctx context.Context, workers int)
• type BaseControls
• type RunExtensionFunc
• type SyncFunc

Types

type Base

type Base[KeyType comparable] struct {
	ControllerName string
	KubeClient     kubernetes.Interface
	EventRecorder  record.EventRecorder

	Queue workqueue.TypedRateLimitingInterface[KeyType]
	// contains filtered or unexported fields
}

func NewBase

func NewBase[KeyType comparable](
	controllerName string,
	scheme *runtime.Scheme,
	kubeClient kubernetes.Interface,
	cachesToSync []cache.InformerSynced,
	baseControls BaseControls[KeyType],
) (*Base[KeyType], error)

func (*Base[KeyType]) Run

func (bc *Base[KeyType]) Run(ctx context.Context, workers int)

type BaseControls

type BaseControls[KeyType comparable] struct {
	SyncFunc         SyncFunc[KeyType]
	RunExtensionFunc RunExtensionFunc
}

type RunExtensionFunc

type RunExtensionFunc func(ctx context.Context, wg *wait.Group)

type SyncFunc

type SyncFunc[KeyType comparable] func(ctx context.Context, key KeyType) error