Versions in this module Expand all Collapse all v0 v0.3.0 Sep 23, 2026 v0.2.0 Sep 18, 2026 Changes in this version + const DefaultPollTimeout + const EventNamespace + const FieldMode + const FieldSuspend + const KindSnapshot + const OriginDerive + const OriginStatus + const Version + func EventCount(e eventsv1.Event) int32 + func EventTime(e eventsv1.Event) time.Time + func ListEvents(ctx context.Context, reader client.Reader, wavefront string, ...) ([]eventsv1.Event, error) + func Observe(ctx context.Context, r client.Reader, targets []gitpoll.Target, ...) (map[types.NamespacedName]gitpoll.Observation, []string) + func ParseNodeRef(s string) (adapter.NodeRef, error) + func ParseSource(s string) (types.NamespacedName, error) + func SelectWavefront(ctx context.Context, r client.Reader, name string) (*wavefrontv1alpha1.Wavefront, error) + func SpecOwners(wf *wavefrontv1alpha1.Wavefront) map[string]string + func Waves(nodes []NodeView) map[adapter.NodeRef]int + type AdmissionView struct + From string + Initial bool + Node adapter.NodeRef + ObservedRef string + PendingSince *time.Time + Source string + To string + type ClusterIdent struct + Context string + Server string + WfctlVersion string + type DeriveSource struct + Now func() time.Time + Observations map[types.NamespacedName]gitpoll.Observation + Poll *PollOptions + Reader client.Reader + Wavefront string + func (d *DeriveSource) Capture(ctx context.Context) (*Snapshot, error) + type DerivedStatus struct + Admissions []AdmissionView + Blocked []wavefrontv1alpha1.BlockedNode + BlockedByReason map[string]int + Counts wavefrontv1alpha1.NodeCounts + FetchFailures int + GraphMessage string + GraphReason string + GraphValid bool + Held []wavefrontv1alpha1.HeldNode + Initial []AdmissionView + Phase wavefrontv1alpha1.Phase + type EventFilter struct + Reason string + Since time.Time + Source string + Warnings bool + type FileSource struct + Path string + func (f FileSource) Capture(_ context.Context) (*Snapshot, error) + type GraphView struct + Cycles [][]adapter.NodeRef + Missing []adapter.NodeRef + Unknown []adapter.NodeRef + type HoldView struct + Kind string + Manager string + type NodeView struct + AppliedSHA string + Blocked *wavefrontv1alpha1.BlockedRef + DependsOn []adapter.NodeRef + Failing bool + Held bool + ObservedSHA string + PendingSince *time.Time + Pin string + Ready bool + ReadyMessage string + Ref adapter.NodeRef + Role string + Source *string + State string + Wave int + type PollOptions struct + Lister gitpoll.Lister + PerHostConcurrency int + Strategy selection.Strategy + Timeout time.Duration + type Snapshot struct + APIVersion string + CapturedAt time.Time + Cluster ClusterIdent + Derived DerivedStatus + Diagnostics []string + Evaluated *time.Time + Graph GraphView + Kind string + Nodes []NodeView + Observed bool + Origin string + Replayed bool + Sources []SourceView + Wavefront WavefrontView + type Source interface + Capture func(ctx context.Context) (*Snapshot, error) + type SourceView struct + ArtifactSHA string + CommitOwners []pin.Owner + Conditions []metav1.Condition + FetchFailing bool + FirstObserved *time.Time + Hold *HoldView + Name string + Nodes []adapter.NodeRef + ObservedSHA string + Partial bool + Pin string + Provenance map[string]string + SecretRefName string + Suspended bool + TrackingRef string + URL string + type StatusSource struct + Now func() time.Time + Reader client.Reader + Wavefront string + func (s *StatusSource) Capture(ctx context.Context) (*Snapshot, error) + type WavefrontView struct + Generation int64 + Name string + Spec wavefrontv1alpha1.WavefrontSpec + SpecOwners map[string]string + Status wavefrontv1alpha1.WavefrontStatus v0.1.0 Sep 17, 2026