source

Documentation

Index

• type ManagedClusterSecretEventHandler
  • func (e *ManagedClusterSecretEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterSecretEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterSecretEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterSecretEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type SecretSource
  • func NewAutoImportSecretSource(secretInformer cache.SharedIndexInformer) *SecretSource
  • func NewImportSecretSource(secretInformer cache.SharedIndexInformer) *SecretSource
  • func (s *SecretSource) Start(ctx context.Context, handler handler.EventHandler, ...) error
  • func (s *SecretSource) WaitForSync(ctx context.Context) error

Types

type ManagedClusterSecretEventHandler

type ManagedClusterSecretEventHandler struct{}

func (*ManagedClusterSecretEventHandler) Create

func (e *ManagedClusterSecretEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterSecretEventHandler) Delete

func (e *ManagedClusterSecretEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterSecretEventHandler) Generic

func (e *ManagedClusterSecretEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterSecretEventHandler) Update

func (e *ManagedClusterSecretEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type SecretSource

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

SecretSource is the event source of specified secrets

func NewAutoImportSecretSource

func NewAutoImportSecretSource(secretInformer cache.SharedIndexInformer) *SecretSource

NewAutoImportSecretSource return a SecretSource only for auto import secrets

func NewImportSecretSource

func NewImportSecretSource(secretInformer cache.SharedIndexInformer) *SecretSource

NewImportSecretSource return a SecretSource only for import secrets

func (*SecretSource) Start

func (s *SecretSource) Start(ctx context.Context, handler handler.EventHandler, queue workqueue.RateLimitingInterface,
	predicates ...predicate.Predicate) error

func (*SecretSource) WaitForSync

func (s *SecretSource) WaitForSync(ctx context.Context) error