Documentation
¶
Overview ¶
Package telemetry owns the operator's operational telemetry policy.
Index ¶
- Constants
- func Admission(ctx context.Context, outcome string, elapsed time.Duration)
- func ConfigureEndpoint(ctx context.Context, base string) (bool, error)
- func Init(ctx context.Context, cfg otelsetup.ProviderConfig, enabled bool) (func(context.Context) error, error)
- func Kind(command string) string
- func ObserveAdmission(size, capacity func() int) (metric.Registration, error)
- func ObservePool(running, waiting, capacity func() int) (metric.Registration, error)
- func Reconcile(ctx context.Context) (context.Context, func(error))
- type Recorder
Constants ¶
View Source
const Scope = "github.com/kubescape/operator/telemetry"
Variables ¶
This section is empty.
Functions ¶
func ConfigureEndpoint ¶
ConfigureEndpoint returns false for explicit global opt-out. An explicitly empty base skips discovery but still allows per-signal overrides.
func Init ¶
func Init(ctx context.Context, cfg otelsetup.ProviderConfig, enabled bool) (func(context.Context) error, error)
Init uses exactly one shared provider set. Conservative defaults can be overridden via standard SDK environment variables (see docs/telemetry.md).
func ObserveAdmission ¶
func ObserveAdmission(size, capacity func() int) (metric.Registration, error)
func ObservePool ¶
func ObservePool(running, waiting, capacity func() int) (metric.Registration, error)
ObservePool reports pressure independently of workload identity. Registration is owned by the pool's lifetime and must be released on shutdown.
Types ¶
type Recorder ¶
type Recorder struct {
// contains filtered or unexported fields
}
func NewRecorder ¶
func NewRecorder() *Recorder
Click to show internal directories.
Click to hide internal directories.