imetrics

type Config struct {
	Prometheus              PrometheusConfig        `yaml:"prometheus,omitempty"`
	Exporter                InternalMetricsExporter `yaml:"exporter,omitempty" env:"OTEL_EBPF_INTERNAL_METRICS_EXPORTER"`
	BpfMetricScrapeInterval time.Duration           `yaml:"bpf_metric_scrape_interval" env:"OTEL_EBPF_BPF_METRIC_SCRAPE_INTERVAL"`
}

type InternalMetricsExporter string

type NoopReporter struct{}

type PrometheusConfig struct {
	Port int    `yaml:"port,omitempty" env:"OTEL_EBPF_INTERNAL_METRICS_PROMETHEUS_PORT"`
	Path string `yaml:"path,omitempty" env:"OTEL_EBPF_INTERNAL_METRICS_PROMETHEUS_PATH"`
}

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

type Reporter interface {
	// Start the reporter
	Start(ctx context.Context)
	// TracerFlush is invoked every time the eBPF tracer flushes a group of len traces.
	TracerFlush(length int)
	// OTELMetricExport is invoked every time the OpenTelemetry Metrics exporter successfully exports metrics to
	// a remote collector. It accounts the length, in metrics, for each invocation.
	OTELMetricExport(length int)
	// OTELMetricExportError is invoked every time the OpenTelemetry Metrics export fails with an error
	OTELMetricExportError(err error)
	// OTELTraceExport is invoked every time the OpenTelemetry Traces exporter successfully exports traces to
	// a remote collector. It accounts the length, in traces, for each invocation.
	OTELTraceExport(i int)
	// OTELTraceExportError is invoked every time the OpenTelemetry Traces export fails with an error
	OTELTraceExportError(err error)
	// PrometheusRequest is invoked every time the Prometheus exporter is invoked, for a given port and path
	PrometheusRequest(port, path string)
	// InstrumentProcess is invoked every time a new process is successfully instrumented
	InstrumentProcess(processName string)
	// UninstrumentProcess is invoked every time a process is removed from the instrumented processes
	UninstrumentProcess(processName string)
	// InstrumentationError is invoked every time an instrumentation attempt fails
	InstrumentationError(processName string, errorType string)
	// AvoidInstrumentationMetrics is invoked every time a service is avoided due to OTLP metrics detection
	AvoidInstrumentationMetrics(serviceName, serviceNamespace, serviceInstanceID string)
	// AvoidInstrumentationTraces is invoked every time a service is avoided due to OTLP traces detection
	AvoidInstrumentationTraces(serviceName, serviceNamespace, serviceInstanceID string)
	// BpfProbeLatency is invoked every time a BPF probe latency is recorded
	BpfProbeLatency(probeID, probeType, probeName string, latencySeconds float64)
	// BpfMapEntries is invoked every time a BPF map size is recorded
	BpfMapEntries(mapID, mapName, mapType string, entriesTotal int)
	// BpfMapMaxEntries is invoked every time a BPF map max size is recorded
	BpfMapMaxEntries(mapID, mapName, mapType string, maxEntries int)
	// BpfInternalMetricsScrapeInterval returns the configured scrape interval for BPF internal metrics
	BpfInternalMetricsScrapeInterval() time.Duration
	// InformerLag shows the lag between a Kubernetes is updated until it's received and stored by OBI
	InformerLag(seconds float64)
}