source

Documentation

Index

• type InformerHolder
• type ManagedClusterResourceEventHandler
  • func (e *ManagedClusterResourceEventHandler) Create(ctx context.Context, evt event.TypedCreateEvent[client.Object], ...)
  • func (e *ManagedClusterResourceEventHandler) Delete(ctx context.Context, evt event.TypedDeleteEvent[client.Object], ...)
  • func (e *ManagedClusterResourceEventHandler) Generic(ctx context.Context, evt event.TypedGenericEvent[client.Object], ...)
  • func (e *ManagedClusterResourceEventHandler) Update(ctx context.Context, evt event.TypedUpdateEvent[client.Object], ...)
• type MapFunc
• type Source
  • func NewAutoImportSecretSource(secretInformer cache.SharedIndexInformer, handler handler.EventHandler, ...) *Source
  • func NewHostedWorkSource(workInformer cache.SharedIndexInformer, handler handler.EventHandler, ...) *Source
  • func NewImportSecretSource(secretInformer cache.SharedIndexInformer, handler handler.EventHandler, ...) *Source
  • func NewKlusterletWorkSource(workInformer cache.SharedIndexInformer, handler handler.EventHandler, ...) *Source
  • func (s *Source) Start(ctx context.Context, ...) error
  • func (s *Source) String() string
  • func (s *Source) WaitForSync(ctx context.Context) error

Types

type InformerHolder

type InformerHolder struct {
	ImportSecretInformer cache.SharedIndexInformer
	ImportSecretLister   corev1listers.SecretLister

	AutoImportSecretInformer cache.SharedIndexInformer
	AutoImportSecretLister   corev1listers.SecretLister

	KlusterletWorkInformer cache.SharedIndexInformer
	KlusterletWorkLister   workv1lister.ManifestWorkLister

	HostedWorkInformer cache.SharedIndexInformer
	HostedWorkLister   workv1lister.ManifestWorkLister

	KlusterletConfigInformer cache.SharedIndexInformer
	KlusterletConfigLister   klusterletconfigv1alpha1lister.KlusterletConfigLister

	ManagedClusterInformer cache.SharedIndexInformer
}

type ManagedClusterResourceEventHandler

type ManagedClusterResourceEventHandler struct {
	MapFunc
}

func (*ManagedClusterResourceEventHandler) Create

func (e *ManagedClusterResourceEventHandler) Create(ctx context.Context, evt event.TypedCreateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*ManagedClusterResourceEventHandler) Delete

func (e *ManagedClusterResourceEventHandler) Delete(ctx context.Context, evt event.TypedDeleteEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*ManagedClusterResourceEventHandler) Generic

func (e *ManagedClusterResourceEventHandler) Generic(ctx context.Context, evt event.TypedGenericEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*ManagedClusterResourceEventHandler) Update

func (e *ManagedClusterResourceEventHandler) Update(ctx context.Context, evt event.TypedUpdateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request])

type MapFunc

type MapFunc func(client.Object) reconcile.Request

Map a client object to reconcile request

type Source

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

Source is the event source of specified objects

func NewAutoImportSecretSource

func NewAutoImportSecretSource(secretInformer cache.SharedIndexInformer,
	handler handler.EventHandler,
	predicates ...predicate.Predicate) *Source

NewAutoImportSecretSource return a source only for auto import secrets

func NewHostedWorkSource

func NewHostedWorkSource(workInformer cache.SharedIndexInformer,
	handler handler.EventHandler,
	predicates ...predicate.Predicate) *Source

NewHostedWorkSource return a source only for hosted manifest works

func NewImportSecretSource

func NewImportSecretSource(secretInformer cache.SharedIndexInformer,
	handler handler.EventHandler,
	predicates ...predicate.Predicate) *Source

NewImportSecretSource return a source only for import secrets

func NewKlusterletWorkSource

func NewKlusterletWorkSource(workInformer cache.SharedIndexInformer,
	handler handler.EventHandler,
	predicates ...predicate.Predicate) *Source

NewKlusterletWorkSource return a source only for klusterlet manifest works

func (*Source) Start

func (s *Source) Start(ctx context.Context, queue workqueue.TypedRateLimitingInterface[reconcile.Request]) error

func (*Source) String

func (s *Source) String() string

func (*Source) WaitForSync

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