watch

Oct 6, 2026

Changes in this version

+ const ReasonCollectionOverlap

+ const StreamReasonBranchIntakePaused

type Manager

+ func (m *Manager) CollectionOverlapForClusterWatchRule(rule configv1alpha3.ClusterWatchRule) (bool, string)

+ func (m *Manager) CollectionOverlapForWatchRule(rule configv1alpha3.WatchRule) (bool, string)

Oct 2, 2026

Changes in this version

type EventRouter

+ func (r *EventRouter) WithdrawCommitRequest(ctx context.Context, attach git.AttachCommitRequest) (git.FinalizeResult, bool, error)

Sep 30, 2026

Changes in this version

+ const ReasonInvalidObjectSelector

+ const ReasonObjectSelectorConflict

+ const TriggerReasonWorkerReplaced

type AuthorQuery

+ FilteredRemoval bool

+ Terminating bool

type GitPathAcceptanceStatus

+ RefusedCollection types.CollectionKey

+ RefusedCollectionSet bool

type Manager

+ func (m *Manager) ForcedRecheckTargetsForTest() []string

+ func (m *Manager) MarkTargetGitPathScanAccepted(gitDest types.ResourceReference)

+ func (m *Manager) MarkTargetGitPathScanRefused(gitDest types.ResourceReference, reason, message string)

+ func (m *Manager) ObjectSelectorConflictForClusterWatchRule(rule configv1alpha3.ClusterWatchRule) (bool, string)

+ func (m *Manager) ObjectSelectorConflictForWatchRule(rule configv1alpha3.WatchRule) (bool, string)

+ func (m *Manager) ReportGitPathScan(gitDest types.ResourceReference, ...)

+ func (m *Manager) RequestRecheckForGitTarget(gitDest types.ResourceReference)

+ type ObjectSelectorError struct

+ Message string

+ func (e *ObjectSelectorError) Error() string

type RetentionSummary

+ LastChangedAt time.Time

type WatchedType

+ NamespaceScopes map[string]string

Sep 11, 2026

Changes in this version

type GitPathAcceptanceStatus

+ RefusedCell types.CellKey

+ RefusedCellSet bool

type Manager

+ func (m *Manager) MarkTargetGitPathScopeAccepted(gitDest types.ResourceReference, cell types.CellKey)

+ func (m *Manager) MarkTargetGitPathScopeRefused(gitDest types.ResourceReference, cell types.CellKey, reason string, ...)

Sep 8, 2026

Changes in this version

type RetentionSummary

+ LastChangedTime time.Time

Sep 3, 2026

Changes in this version

type Manager

+ func (m *Manager) LayoutForGitTarget(gitDest types.ResourceReference) (git.LayoutReport, bool)

+ func (m *Manager) ReportLayoutResolved(gitDest types.ResourceReference, report git.LayoutReport)

Aug 28, 2026

Changes in this version

+ const TriggerReasonDeclare

+ const TriggerReasonPeriodic

+ const TriggerReasonRuleChange

+ const TriggerReasonSharedRefresh

+ type DeclareStatus struct

+ ClusterID string

+ Declared bool

+ Failures int

+ LastError string

+ Pending bool

+ func (s DeclareStatus) Settled() bool

type Manager

+ func (m *Manager) DeclareStatusForGitTarget(gitDest types.ResourceReference) DeclareStatus

+ func (m *Manager) StreamStateEvents() <-chan event.GenericEvent

+ func (m *Manager) TriggerAllRuleChange()

+ func (m *Manager) TriggerRuleChange(gitDest types.ResourceReference)

Jul 30, 2026

Changes in this version

type AttributionLookup

+ Await func(ctx context.Context, query queue.FactQuery, grace time.Duration) queue.AuthorResolution

+ type AuthorQuery struct

+ AuditRoute string

+ ExactCapable bool

+ GVR schema.GroupVersionResource

+ Labels map[string]string

+ Name string

+ Namespace string

+ ResourceVersion string

+ UID k8stypes.UID

type Manager

+ FactStreams *queue.FactStreamSet

Jul 22, 2026

Changes in this version

+ const ClusterWatchRuleNamespacedScopeMessage

+ const ClusterWatchRuleReasonGitTargetNamespaceNotAuthorized

+ const ClusterWatchRuleReasonScopeNotSupported

+ func CompileWatchRule(ctx context.Context, reader client.Reader, store *rulestore.RuleStore, ...) (authz.ResolvedSourceScope, error)

+ func SourceScopeSpecHash(rule *configv1alpha3.WatchRule) string

+ type ClusterWatchRuleDecision struct

+ Admitted bool

+ Message string

+ Reason string

+ func CompileClusterWatchRule(ctx context.Context, reader client.Reader, store *rulestore.RuleStore, ...) (ClusterWatchRuleDecision, error)

type Manager

+ func (m *Manager) EnumerateSourceNamespaces(_ context.Context, target *configv1alpha3.GitTarget) ([]string, authz.SourceScopeResult)

+ func (m *Manager) ForgetSourceScopeGrant(rule k8stypes.NamespacedName)

+ func (m *Manager) MarkTargetRetention(gitDest types.ResourceReference, key targetWatchKey, epoch uint64, ...)

+ func (m *Manager) RecordSourceScopeGrant(rule k8stypes.NamespacedName, specHash string, namespaces [][]string)

+ func (m *Manager) ResolveSourceNamespace(_ context.Context, target *configv1alpha3.GitTarget, namespace string) authz.SourceScopeResult

+ func (m *Manager) RetainedSourceScope(rule k8stypes.NamespacedName, specHash string) ([][]string, bool)

+ func (m *Manager) RetentionForGitTarget(gitDest types.ResourceReference) RetentionSummary

+ func (m *Manager) SourceNamespaceEvents() <-chan event.GenericEvent

+ func (m *Manager) SourceScope() SourceScopeService

+ type RetentionSummary struct

+ Mode v1alpha3.PruneMode

+ ObservedTime time.Time

+ Reported bool

+ RetainedDocuments int

+ type SourceScopeService interface

+ ForgetSourceScopeGrant func(rule k8stypes.NamespacedName)

+ RecordSourceScopeGrant func(rule k8stypes.NamespacedName, specHash string, namespaces [][]string)

+ RetainedSourceScope func(rule k8stypes.NamespacedName, specHash string) ([][]string, bool)

type WatchedType

+ func (t WatchedType) WatchScopes() []string

Jul 19, 2026

Changes in this version

type Manager

+ SourceClusters SourceClusterResolver

+ func (m *Manager) ClusterTypeLookup(clusterID string) typeset.Lookup

+ func (m *Manager) DeclaredSourceCluster(gitDest types.ResourceReference) (string, bool)

+ func (m *Manager) SourceClusterReachable(clusterID string) SourceClusterReachableStatus

+ type SourceClusterReachableStatus struct

+ Message string

+ Reason string

+ State string

+ type SourceClusterResolver interface

+ ResolveSourceCluster func(ctx context.Context, providerName string) (cfg *rest.Config, version string, err error)

+ func NewSecretSourceClusterResolver(c client.Client, operatorNamespace string, safety kubeconfig.SafetyPolicy, ...) SourceClusterResolver

Jul 16, 2026

Changes in this version

type Manager

+ func (m *Manager) MarkTargetRenderFidelityDiverged(target types.ResourceReference, divergence manifestanalyzer.RenderDivergence)

+ func (m *Manager) MarkTargetRenderFidelityScopeClean(target types.ResourceReference, epoch uint64, key targetWatchKey)

+ func (m *Manager) MarkTargetRenderFidelityScopeDiverged(target types.ResourceReference, epoch uint64, key targetWatchKey, ...)

+ func (m *Manager) RenderFidelityEpochForGitTarget(target types.ResourceReference) uint64

+ func (m *Manager) RenderFidelityForGitTarget(target types.ResourceReference) RenderFidelityStatus

+ type RenderFidelityStatus = git.RenderFidelityStatus

Jul 14, 2026

Changes in this version

+ const DefaultAttributionGraceWindow

+ const StreamReasonAllStreamsReady

+ const StreamReasonExpiredResourceVersion

+ const StreamReasonInitialReplay

+ const StreamReasonNoResolvedTypes

+ const StreamReasonReplaying

+ const StreamReasonResumeReplay

+ const StreamReasonWatchError

+ const StreamReasonWatchNotPermitted

+ type APIResourceCatalog struct

+ func NewAPIResourceCatalog() *APIResourceCatalog

+ func (c *APIResourceCatalog) DegradedGroupVersions() []schema.GroupVersion

+ func (c *APIResourceCatalog) Generation() uint64

+ func (c *APIResourceCatalog) Ready() bool

+ func (c *APIResourceCatalog) Refresh(disco apiResourceDiscovery) (bool, error)

+ func (c *APIResourceCatalog) Scan(sensitive types.SensitiveResourcePolicy) (typeset.Scan, bool)

+ func (c *APIResourceCatalog) ServesWatchable(gvr schema.GroupVersionResource) bool

+ func (c *APIResourceCatalog) Stats() CatalogStats

+ type AttributionLookup interface

+ LookupAuthorResolution func(ctx context.Context, gvr schema.GroupVersionResource, uid k8stypes.UID, ...) queue.AuthorResolution

+ type AuthorResolver interface

+ ResolveAuthor func(ctx context.Context, gvr schema.GroupVersionResource, uid k8stypes.UID, ...) (git.UserInfo, bool)

+ func NewAuthorResolver(lookup AttributionLookup, grace time.Duration, log logr.Logger) AuthorResolver

+ type CatalogStats struct

+ AllowedResources int

+ DegradedGroupVersions int

+ ExcludedResources int

+ Generation uint64

+ TrustedGroupVersions int

+ type ClusterSnapshot struct

+ CoverageHead string

+ Desired []manifestanalyzer.DesiredResource

+ Revision string

+ type CursorStore interface

+ LookupWatchCursor func(ctx context.Context, gitTargetUID string, gvr schema.GroupVersionResource, ...) (string, bool)

+ RecordWatchCursor func(ctx context.Context, gitTargetUID string, gvr schema.GroupVersionResource, ...) error

+ type EventRouter struct

+ Client client.Client

+ Log logr.Logger

+ WatchManager *Manager

+ WorkerManager *git.WorkerManager

+ func NewEventRouter(workerManager *git.WorkerManager, watchManager *Manager, client client.Client, ...) *EventRouter

+ func (r *EventRouter) GetGitTargetEventStream(gitDest types.ResourceReference) *reconcile.GitTargetEventStream

+ func (r *EventRouter) RegisterGitTargetEventStream(gitDest types.ResourceReference, stream *reconcile.GitTargetEventStream)

+ func (r *EventRouter) RouteEvent(providerName, providerNamespace string, branch string, event git.Event) error

+ func (r *EventRouter) RouteToGitTargetEventStream(event git.Event, gitDest types.ResourceReference) error

+ func (r *EventRouter) ServiceCommitRequest(ctx context.Context, attach git.AttachCommitRequest) (git.FinalizeResult, bool, error)

+ func (r *EventRouter) UnregisterGitTargetEventStream(gitDest types.ResourceReference)

+ type GVR struct

+ Group string

+ Resource string

+ Scope configv1alpha3.ResourceScope

+ Version string

+ type GitPathAcceptanceStatus struct

+ Accepted bool

+ At metav1.Time

+ Message string

+ Reason string

+ type Manager struct

+ AuthorResolver AuthorResolver

+ Client client.Client

+ EventRouter *EventRouter

+ Log logr.Logger

+ RuleStore *rulestore.RuleStore

+ SensitiveResources types.SensitiveResourcePolicy

+ WatchCursorStore CursorStore

+ func (m *Manager) ComputeRequestedGVRs() []GVR

+ func (m *Manager) DeclareForGitTarget(ctx context.Context, gitDest types.ResourceReference, forceRecheck ...bool) error

+ func (m *Manager) EnsureGitTargetWatches(ctx context.Context, gitDest types.ResourceReference, forceRecheck ...bool) error

+ func (m *Manager) FollowableTypeRecords() []typeset.TypeRecord

+ func (m *Manager) ForgetGitTargetDeclaration(gitDest types.ResourceReference)

+ func (m *Manager) GitPathAcceptanceForGitTarget(gitDest types.ResourceReference) GitPathAcceptanceStatus

+ func (m *Manager) GitPathEvents() <-chan event.GenericEvent

+ func (m *Manager) MarkTargetGitPathAccepted(gitDest types.ResourceReference)

+ func (m *Manager) MarkTargetGitPathRefused(gitDest types.ResourceReference, reason, message string)

+ func (m *Manager) NeedLeaderElection() bool

+ func (m *Manager) ReconcileForRuleChange(ctx context.Context) error

+ func (m *Manager) RefreshAPIResourceCatalog(ctx context.Context) error

+ func (m *Manager) ReportGitPathRefusal(gitDest types.ResourceReference, ...)

+ func (m *Manager) ResolveClusterWatchRuleResources(_ context.Context, rule configv1alpha3.ClusterWatchRule) (bool, string)

+ func (m *Manager) ResolveWatchRuleResources(_ context.Context, rule configv1alpha3.WatchRule) (bool, string)

+ func (m *Manager) SetupWithManager(mgr ctrl.Manager) error

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) StreamSummaryForClusterWatchRule(rule configv1alpha3.ClusterWatchRule) StreamSummary

+ func (m *Manager) StreamSummaryForGitTarget(gitDest types.ResourceReference) StreamSummary

+ func (m *Manager) StreamSummaryForWatchRule(rule configv1alpha3.WatchRule) StreamSummary

+ func (m *Manager) TypeRecords() []typeset.TypeRecord

+ func (m *Manager) TypeRegistry() *typeset.Registry

+ type OperationSet map[string]struct

+ func (s OperationSet) Match(op string) bool

+ func (s OperationSet) Sorted() []string

+ type StreamState string

+ const StreamStateBlocked

+ const StreamStateReplaying

+ const StreamStateStreaming

+ type StreamSummary struct

+ Blocked int

+ Message string

+ ObservedTime metav1.Time

+ PendingSample []string

+ Ready int

+ Reason string

+ Replaying int

+ Total int

+ func (s StreamSummary) StreamsRunning() bool

+ func (s StreamSummary) Summary() string

+ type WatchedType struct

+ GVK schema.GroupVersionKind

+ GVR schema.GroupVersionResource

+ NamespaceOps map[string]OperationSet

+ Namespaced bool

+ Preferred bool

+ Scope configv1alpha3.ResourceScope

+ ServedVersion string

+ func (t WatchedType) ClusterWide() bool

+ func (t WatchedType) SnapshotNamespaces() []string

+ type WatchedTypeTable struct

+ Dest string

+ GitDest types.ResourceReference

+ ResolvedAt uint64

+ Types []WatchedType