pipeline

type EventPipeline ¶

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

func NewEventPipeline(size int, sinks ...Sink) *EventPipeline

func (p *EventPipeline) Close() error

func (p *EventPipeline) DroppedEvents() uint64

func (p *EventPipeline) Enqueue(v any) bool

func (p *EventPipeline) Start()

func (p *EventPipeline) WriteFailures() uint64

type OTelExporter ¶

type OTelExporter interface {
	ExportUsageEvent(any) error
	Close() error
}

OTelExporter translates gateway usage events into OpenTelemetry spans, logs, or metrics without forcing an OpenTelemetry dependency into the gateway core.

Sinks are passed to NewEventPipeline at construction time, so wiring an exporter means editing the pipeline setup in caddy/gateway/app.go and standalone/server/server.go. There is no out-of-module registration seam.

type OpenTelemetrySink ¶

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

func NewOpenTelemetrySink(exporter OTelExporter) *OpenTelemetrySink

func (s *OpenTelemetrySink) Close() error

func (s *OpenTelemetrySink) Write(ev any) error

type PrometheusSink ¶

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

PrometheusSink is a dependency-free in-process sink that keeps counters in a shape the Admin API /metrics exposition layer renders into Prometheus text.

func NewPrometheusSink() *PrometheusSink

func (s *PrometheusSink) Close() error

func (s *PrometheusSink) PrometheusSnapshot() usage.PrometheusSnapshot

func (s *PrometheusSink) Snapshot() usage.PrometheusSnapshot

func (s *PrometheusSink) Write(ev any) error

type SQLiteSink ¶

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

func NewSQLiteSink(provider usage.SQLDBProvider, cfg usage.Config) (*SQLiteSink, *sqlite.UsageQueries, error)

func (s *SQLiteSink) Close() error

func (s *SQLiteSink) Write(ev any) error

type Sink ¶

type Sink interface {
	Write(any) error
	Close() error
}