sync

Oct 13, 2025

Changes in this version

+ const ReasonFilterChanged

Oct 6, 2025

Changes in this version

+ const DefaultSyncRequeueAfterConstant

+ const ReasonRequeueTimeNotElapsed

+ var DefaultSyncRequeueAfter = DefaultSyncRequeueAfterConstant

Sep 30, 2025

Changes in this version

+ type Result struct

+ Hash string

+ ServerCount int

Sep 16, 2025

Changes in this version

+ const ManualSyncReasonAlreadyProcessed

+ const ManualSyncReasonNoAnnotations

+ const ManualSyncReasonNoTrigger

+ const ManualSyncReasonRequested

+ const ReasonAlreadyInProgress

+ const ReasonErrorCheckingChanges

+ const ReasonErrorCheckingSyncNeed

+ const ReasonErrorParsingInterval

+ const ReasonManualNoChanges

+ const ReasonManualWithChanges

+ const ReasonRegistryNotReady

+ const ReasonSourceDataChanged

+ const ReasonUpToDateNoPolicy

+ const ReasonUpToDateWithPolicy

+ const SyncTriggerAnnotation

+ func IsManualSync(reason string) bool

+ type AutomaticSyncChecker interface

+ IsIntervalSyncNeeded func(mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, time.Time, error)

+ type DataChangeDetector interface

+ IsDataChanged func(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, error)

+ type DefaultAutomaticSyncChecker struct

+ func (*DefaultAutomaticSyncChecker) IsIntervalSyncNeeded(mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, time.Time, error)

+ type DefaultDataChangeDetector struct

+ func (d *DefaultDataChangeDetector) IsDataChanged(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, error)

+ type DefaultManualSyncChecker struct

+ func (*DefaultManualSyncChecker) IsManualSyncRequested(mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, string)

+ type DefaultSyncManager struct

+ func NewDefaultSyncManager(k8sClient client.Client, scheme *runtime.Scheme, ...) *DefaultSyncManager

+ func (s *DefaultSyncManager) Delete(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) error

+ func (s *DefaultSyncManager) PerformSync(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (ctrl.Result, error)

+ func (s *DefaultSyncManager) ShouldSync(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, string, *time.Time, error)

+ func (s *DefaultSyncManager) UpdateManualSyncTriggerOnly(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (ctrl.Result, error)

+ type Manager interface

+ Delete func(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) error

+ PerformSync func(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (ctrl.Result, error)

+ ShouldSync func(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, string, *time.Time, error)

+ UpdateManualSyncTriggerOnly func(ctx context.Context, mcpRegistry *mcpv1alpha1.MCPRegistry) (ctrl.Result, error)

+ type ManualSyncChecker interface

+ IsManualSyncRequested func(mcpRegistry *mcpv1alpha1.MCPRegistry) (bool, string)