state

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

type CollectorOptions struct {
	Dynamic   dynamic.Interface
	Metadata  metadata.Interface
	Discovery discovery.DiscoveryInterface
	Tracker   *Tracker
	Sink      Sink
	// OnSynced receives the state once every scope finished its first attempt; ops before it are not sent to Sink.
	OnSynced func(st *protocol.State)
	// Namespaces selects the namespace profile; empty collects cluster-wide.
	Namespaces        []string
	ExcludeNamespaces []string
	// Resources lists configured resource names; empty selects every catalog kind.
	Resources []string
	Logger    *slog.Logger
	Clock     func() time.Time
	// RetryBase and RetryMax bound the exponential backoff after access failures, default 30s and 30m.
	RetryBase, RetryMax time.Duration
	// FlushInterval is the event count flush period, default 30s.
	FlushInterval time.Duration
	// Wait sleeps for d or until ctx is done, reporting whether to continue; default uses a timer.
	Wait             func(ctx context.Context, d time.Duration) bool
	ReflectorBackoff *wait.Backoff
}

type Coverage struct {
	Scopes      []ScopeReport
	Unsupported []string
}

type Field struct {
	Path      string
	Source    string
	Type      FieldType
	Redaction Redaction
	Default   bool
}

type FieldType string

type KindSpec struct {
	Kind         string
	GVR          schema.GroupVersionResource
	APIKind      string
	Namespaced   bool
	MetadataOnly bool
	Aggregated   bool
	Fields       []Field
	// contains filtered or unexported fields
}

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

type Options struct {
	// LabelAllowlist and AnnotationAllowlist hold exact keys or prefixes ending in "*"; nil selects the defaults.
	LabelAllowlist      []string
	AnnotationAllowlist []string
	// Fields selects non-default catalog fields as "<kind>:<path>", for example "Pod:containers.<container>.args".
	Fields   []string
	Redactor *redact.Redactor
}

type Placement struct {
	Claim        string
	Volume       string
	StorageClass string
	AccessModes  []string
	Driver       string
	NodeAffinity string
	// PinnedNodes lists hostnames the volume is restricted to when affinity uses kubernetes.io/hostname.
	PinnedNodes []string
	Pinned      bool
	// Zonal reports affinity to a topology zone without pinning to one node.
	Zonal       bool
	Limitations []string
}

type Redaction string

type ScopeReport struct {
	Key       string
	Kind      string
	Namespace string
	State     protocol.ScopeState
	Reason    string
	Attempts  int
}

type Series struct {
	Labels labels.Labels
	Value  float64
	T      int64
}

type SeriesSpec struct {
	Name   string
	Kind   string
	Labels []string
	Source string
}

type Sink func(ops []protocol.Op, synthetic bool, uncertain *protocol.Interval)

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

type TrackerOptions struct {
	Normalizer *Normalizer
	Clock      func() time.Time
	// EventWindow is the sliding window for Warning event counts, default 1h.
	EventWindow time.Duration
	// EventInterval bounds how often event counts of one object are updated, default 5m.
	EventInterval time.Duration
}