metrics

Documentation

Overview

Package metrics initialises an OpenTelemetry MeterProvider backed by both a Prometheus exporter (for scraping) and an optional OTLP gRPC exporter (for push-based delivery to any OTel-compatible backend).

Index

• Constants
• Variables
• type Recorder
  • func New(instanceID string, numWorkers int, otlpEndpoint string, ...) (*Recorder, error)
  • func (r *Recorder) BeaconAdvertSent()
  • func (r *Recorder) CacheError()
  • func (r *Recorder) CacheHit()
  • func (r *Recorder) CacheMiss()
  • func (r *Recorder) CacheSize(size int64)
  • func (r *Recorder) FrameCached()
  • func (r *Recorder) FrameDropped(reason string)
  • func (r *Recorder) FrameReceived()
  • func (r *Recorder) NACKRequest()
  • func (r *Recorder) ProxyFailed(reason string)
  • func (r *Recorder) ProxyInflightDedup()
  • func (r *Recorder) ProxyQueueDropped()
  • func (r *Recorder) ProxyRecovered()
  • func (r *Recorder) ProxyRequest()
  • func (r *Recorder) RateLimitDrop(level string)
  • func (r *Recorder) ResponseSendError(typ string)
  • func (r *Recorder) ResponseSent(typ string)
  • func (r *Recorder) Retransmit()
  • func (r *Recorder) RetransmitDedup()
  • func (r *Recorder) Serve(addr string, done <-chan struct{})
  • func (r *Recorder) SetDraining()
  • func (r *Recorder) SetHostInfo(inv hostinfo.Inventory)
  • func (r *Recorder) SetLevelVar(lvl *slog.LevelVar)
  • func (r *Recorder) Shutdown(ctx context.Context)
  • func (r *Recorder) UnicastRetransmit()
  • func (r *Recorder) WorkerDone()
  • func (r *Recorder) WorkerReady()

Constants

const ServiceName = "retry-endpoint"

Variables

var Version = "dev"

Types

type Recorder

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

func New

func New(instanceID string, numWorkers int, otlpEndpoint string, otlpInterval time.Duration) (*Recorder, error)

func (*Recorder) BeaconAdvertSent

func (r *Recorder) BeaconAdvertSent()

BeaconAdvertSent records an ADVERT beacon datagram sent successfully.

func (*Recorder) CacheError

func (r *Recorder) CacheError()

func (*Recorder) CacheHit

func (r *Recorder) CacheHit()

func (*Recorder) CacheMiss

func (r *Recorder) CacheMiss()

func (*Recorder) CacheSize

func (r *Recorder) CacheSize(size int64)

func (*Recorder) FrameCached

func (r *Recorder) FrameCached()

func (*Recorder) FrameDropped

func (r *Recorder) FrameDropped(reason string)

func (*Recorder) FrameReceived

func (r *Recorder) FrameReceived()

func (*Recorder) NACKRequest

func (r *Recorder) NACKRequest()

func (*Recorder) ProxyFailed

func (r *Recorder) ProxyFailed(reason string)

ProxyFailed records a proxy job that found no frame upstream. reason is a low-cardinality label (e.g. "exhausted").

func (*Recorder) ProxyInflightDedup

func (r *Recorder) ProxyInflightDedup()

ProxyInflightDedup records a proxy job skipped due to a sibling's in-flight claim.

func (*Recorder) ProxyQueueDropped

func (r *Recorder) ProxyQueueDropped()

ProxyQueueDropped records a proxy job dropped because the queue was full.

func (*Recorder) ProxyRecovered

func (r *Recorder) ProxyRecovered()

ProxyRecovered records a frame recovered from upstream and re-cached.

func (*Recorder) ProxyRequest

func (r *Recorder) ProxyRequest()

ProxyRequest records a cross-domain proxy recovery job start.

func (*Recorder) RateLimitDrop

func (r *Recorder) RateLimitDrop(level string)

func (*Recorder) ResponseSendError

func (r *Recorder) ResponseSendError(typ string)

ResponseSendError records a failed WriteTo for an ACK or MISS response.

func (*Recorder) ResponseSent

func (r *Recorder) ResponseSent(typ string)

ResponseSent records an ACK, MISS, or THROTTLED datagram successfully written to the NACK socket. typ must be "ack", "miss", or "throttled".

func (*Recorder) Retransmit

func (r *Recorder) Retransmit()

func (*Recorder) RetransmitDedup

func (r *Recorder) RetransmitDedup()

func (*Recorder) Serve

func (r *Recorder) Serve(addr string, done <-chan struct{})

func (*Recorder) SetDraining

func (r *Recorder) SetDraining()

func (*Recorder) SetHostInfo

func (r *Recorder) SetHostInfo(inv hostinfo.Inventory)

SetHostInfo publishes a slim bre_host_info gauge (value 1) carrying low-cardinality host facts as labels, joining the host.inventory log event emitted at startup. Best-effort; registration errors are ignored.

func (*Recorder) SetLevelVar

func (r *Recorder) SetLevelVar(lvl *slog.LevelVar)

SetLevelVar registers the runtime log-level variable so Recorder.Serve exposes a /loglevel endpoint for runtime level change.

func (*Recorder) Shutdown

func (r *Recorder) Shutdown(ctx context.Context)

func (*Recorder) UnicastRetransmit

func (r *Recorder) UnicastRetransmit()

func (*Recorder) WorkerDone

func (r *Recorder) WorkerDone()

func (*Recorder) WorkerReady

func (r *Recorder) WorkerReady()