controller

Documentation

Index

• Constants
• func NewEdgeSyncConfigController(logger klog.Logger, syncConfigClient edgev1alpha1typed.EdgeSyncConfigInterface, ...) (*edgeSyncConfigController, error)
• func NewSyncerConfigController(logger klog.Logger, syncerConfigClient edgev1alpha1typed.SyncerConfigInterface, ...) (*syncerConfigController, error)
• type SyncConfigManager
  • func NewSyncConfigManager(logger klog.Logger) *SyncConfigManager
  • func (s *SyncConfigManager) GetConversions() []edgev1alpha1.EdgeSynConversion
  • func (s *SyncConfigManager) GetDownSyncedResources() []edgev1alpha1.EdgeSyncConfigResource
  • func (s *SyncConfigManager) GetDownUnsyncedResources() []edgev1alpha1.EdgeSyncConfigResource
  • func (s *SyncConfigManager) GetUpSyncedResources() []edgev1alpha1.EdgeSyncConfigResource
  • func (s *SyncConfigManager) GetUpUnsyncedResources() []edgev1alpha1.EdgeSyncConfigResource
• type SyncerConfigManager
  • func NewSyncerConfigManager(logger klog.Logger, syncConfigManager *SyncConfigManager, ...) *SyncerConfigManager
  • func (s *SyncerConfigManager) Refresh()

Constants

const (
	DOWNSYNC_NAMESPACED_SUFFIX    string = "_downsync_namespaced"
	DOWNSYNC_CLUSTERSCOPED_SUFFIX string = "_downsync_clusterscoped"
	UPSYNC_SUFFIX                 string = "_upsync"
)

Functions

func NewEdgeSyncConfigController

func NewEdgeSyncConfigController(
	logger klog.Logger,
	syncConfigClient edgev1alpha1typed.EdgeSyncConfigInterface,
	syncConfigInformer edgev1alpha1informers.EdgeSyncConfigInformer,
	syncConfigManager *SyncConfigManager,
	upSyncer syncers.SyncerInterface,
	downSyncer syncers.SyncerInterface,
	reconcileInterval time.Duration,
) (*edgeSyncConfigController, error)

NewEdgeSyncConfigController returns a edgeSyncConfigController watching a [edge.kcp.io.EdgeSyncConfig] and update down/up syncer,

func NewSyncerConfigController

func NewSyncerConfigController(
	logger klog.Logger,
	syncerConfigClient edgev1alpha1typed.SyncerConfigInterface,
	syncerConfigInformer edgev1alpha1informers.SyncerConfigInformer,
	syncerConfigManager *SyncerConfigManager,
	reconcileInterval time.Duration,
) (*syncerConfigController, error)

Types

type SyncConfigManager

type SyncConfigManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSyncConfigManager

func NewSyncConfigManager(logger klog.Logger) *SyncConfigManager

func (*SyncConfigManager) GetConversions

func (s *SyncConfigManager) GetConversions() []edgev1alpha1.EdgeSynConversion

func (*SyncConfigManager) GetDownSyncedResources

func (s *SyncConfigManager) GetDownSyncedResources() []edgev1alpha1.EdgeSyncConfigResource

func (*SyncConfigManager) GetDownUnsyncedResources

func (s *SyncConfigManager) GetDownUnsyncedResources() []edgev1alpha1.EdgeSyncConfigResource

func (*SyncConfigManager) GetUpSyncedResources

func (s *SyncConfigManager) GetUpSyncedResources() []edgev1alpha1.EdgeSyncConfigResource

func (*SyncConfigManager) GetUpUnsyncedResources

func (s *SyncConfigManager) GetUpUnsyncedResources() []edgev1alpha1.EdgeSyncConfigResource

type SyncerConfigManager

type SyncerConfigManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSyncerConfigManager

func NewSyncerConfigManager(logger klog.Logger, syncConfigManager *SyncConfigManager, upstreamClientFactory clientfactory.ClientFactory, downstreamClientFactory clientfactory.ClientFactory) *SyncerConfigManager

func (*SyncerConfigManager) Refresh

func (s *SyncerConfigManager) Refresh()