source

Documentation

Index

• type InformerHolder
• type ManagedClusterResourceEventHandler
  • func (e *ManagedClusterResourceEventHandler) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterResourceEventHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterResourceEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *ManagedClusterResourceEventHandler) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type MapFunc
• type Source
  • func NewAutoImportSecretSource(secretInformer cache.SharedIndexInformer) *Source
  • func NewHostedWorkSource(workInformer cache.SharedIndexInformer) *Source
  • func NewImportSecretSource(secretInformer cache.SharedIndexInformer) *Source
  • func NewKlusterletWorkSource(workInformer cache.SharedIndexInformer) *Source
  • func NewManagedClusterSource(mcInformer cache.SharedIndexInformer) *Source
  • func (s *Source) Start(ctx context.Context, handler handler.EventHandler, ...) 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

	KlusterletConfigLister klusterletconfigv1alpha1lister.KlusterletConfigLister

	ManagedClusterInformer cache.SharedIndexInformer
}

type ManagedClusterResourceEventHandler

type ManagedClusterResourceEventHandler struct {
	MapFunc
}

func (*ManagedClusterResourceEventHandler) Create

func (e *ManagedClusterResourceEventHandler) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterResourceEventHandler) Delete

func (e *ManagedClusterResourceEventHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterResourceEventHandler) Generic

func (e *ManagedClusterResourceEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*ManagedClusterResourceEventHandler) Update

func (e *ManagedClusterResourceEventHandler) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

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) *Source

NewAutoImportSecretSource return a source only for auto import secrets

func NewHostedWorkSource

func NewHostedWorkSource(workInformer cache.SharedIndexInformer) *Source

NewHostedWorkSource return a source only for hosted manifest works

func NewImportSecretSource

func NewImportSecretSource(secretInformer cache.SharedIndexInformer) *Source

NewImportSecretSource return a source only for import secrets

func NewKlusterletWorkSource

func NewKlusterletWorkSource(workInformer cache.SharedIndexInformer) *Source

NewKlusterletWorkSource return a source only for klusterlet manifest works

func NewManagedClusterSource

func NewManagedClusterSource(mcInformer cache.SharedIndexInformer) *Source

NewManagedClusterSource return a source for managed cluster

func (*Source) Start

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

func (*Source) String

func (s *Source) String() string

func (*Source) WaitForSync

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