syncer

Documentation

Index

• func StrategyRegister(hookContext genericapiserver.PostStartHookContext) error
• type MultiClusterSyncManager
  • func NewMultiClusterSyncManager(baseContext context.Context, controller controller.Controller, ...) MultiClusterSyncManager
• type ResourceSyncer
  • func NewResourceSyncer(cluster string, dynamicClient dynamic.Interface, rsr v1beta1.ResourceSyncRule, ...) *ResourceSyncer
  • func (s *ResourceSyncer) OnAdd(obj client.Object)
  • func (s *ResourceSyncer) OnDelete(obj client.Object)
  • func (s *ResourceSyncer) OnGeneric(obj client.Object)
  • func (s *ResourceSyncer) OnUpdate(obj client.Object)
  • func (s *ResourceSyncer) Run(ctx context.Context) error
  • func (s *ResourceSyncer) Source() SyncSource
  • func (s *ResourceSyncer) Stop(ctx context.Context) error
  • func (s *ResourceSyncer) SyncRule() v1beta1.ResourceSyncRule
• type SingleClusterSyncManager
  • func NewSingleClusterSyncManager(baseContext context.Context, clusterName string, config *rest.Config, ...) (SingleClusterSyncManager, error)
• type SyncReconciler
  • func NewSyncReconciler(storage storage.Storage) *SyncReconciler
  • func (r *SyncReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *SyncReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SyncSource
  • func NewSource(cluster string, client dynamic.Interface, rsr v1beta1.ResourceSyncRule, ...) SyncSource

Functions

func StrategyRegister

func StrategyRegister(hookContext genericapiserver.PostStartHookContext) error

Types

type MultiClusterSyncManager

type MultiClusterSyncManager interface {
	Create(ctx context.Context, clusterName string, config *rest.Config) (SingleClusterSyncManager, error)
	Start(ctx context.Context, clusterName string) error
	Stop(ctx context.Context, clusterName string)
	GetForCluster(clusterName string) (SingleClusterSyncManager, bool)
}

func NewMultiClusterSyncManager

func NewMultiClusterSyncManager(baseContext context.Context, controller controller.Controller, storage storage.Storage) MultiClusterSyncManager

type ResourceSyncer

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

func NewResourceSyncer

func NewResourceSyncer(cluster string, dynamicClient dynamic.Interface, rsr v1beta1.ResourceSyncRule, storage storage.Storage) *ResourceSyncer

func (*ResourceSyncer) OnAdd

func (s *ResourceSyncer) OnAdd(obj client.Object)

func (*ResourceSyncer) OnDelete

func (s *ResourceSyncer) OnDelete(obj client.Object)

func (*ResourceSyncer) OnGeneric

func (s *ResourceSyncer) OnGeneric(obj client.Object)

func (*ResourceSyncer) OnUpdate

func (s *ResourceSyncer) OnUpdate(obj client.Object)

func (*ResourceSyncer) Run

func (s *ResourceSyncer) Run(ctx context.Context) error

func (*ResourceSyncer) Source

func (s *ResourceSyncer) Source() SyncSource

func (*ResourceSyncer) Stop

func (s *ResourceSyncer) Stop(ctx context.Context) error

func (*ResourceSyncer) SyncRule

func (s *ResourceSyncer) SyncRule() v1beta1.ResourceSyncRule

type SingleClusterSyncManager

type SingleClusterSyncManager interface {
	Start(context.Context) error
	Started() bool
	Stop(context.Context)
	Stopped() bool
	UpdateSyncResources(context.Context, []*searchv1beta1.ResourceSyncRule) error
	HasSyncResource(schema.GroupVersionResource) bool
	ClusterConfig() *rest.Config
}

func NewSingleClusterSyncManager

func NewSingleClusterSyncManager(baseContext context.Context,
	clusterName string,
	config *rest.Config,
	controller controller.Controller,
	storage storage.Storage,
) (SingleClusterSyncManager, error)

type SyncReconciler

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

func NewSyncReconciler

func NewSyncReconciler(storage storage.Storage) *SyncReconciler

func (*SyncReconciler) Reconcile

func (r *SyncReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SyncReconciler) SetupWithManager

func (r *SyncReconciler) SetupWithManager(mgr ctrl.Manager) error

type SyncSource

type SyncSource interface {
	source.Source
	clientgocache.Store
	Cluster() string
	SyncRule() v1beta1.ResourceSyncRule
	Stop(context.Context) error
	HasSynced() bool
}

func NewSource

func NewSource(cluster string, client dynamic.Interface, rsr v1beta1.ResourceSyncRule, storage storage.Storage) SyncSource