source

package

v0.0.0-...-243bbe7 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation ¶

Index ¶

type InformerHolder
type ManagedClusterResourceEventHandler
type MapFunc
type Source

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

	ControllerConfigInformer cache.SharedIndexInformer
	ControllerConfigLister   corev1listers.ConfigMapLister

	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

Source Files ¶

View all Source files

source.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL