servicers

Documentation

Index

• func NewDirectoryIndexer() protos.IndexerServer
• func NewOrchestratorStreamProviderServicer() streamer_protos.StreamProviderServer
• func NewPushExporterServicer(pushAddrs []string) protos.MetricsExporterServer
• type PushExporterServicer
  • func (s *PushExporterServicer) Submit(ctx context.Context, req *protos.SubmitMetricsRequest) (*protos.SubmitMetricsResponse, error)

Functions

func NewDirectoryIndexer

func NewDirectoryIndexer() protos.IndexerServer

NewDirectoryIndexer returns the state indexer for directoryd.

The directoryd indexer performs the following indexing functions:

• sidToIMSI: map session ID to IMSI

sidToIMSI

Directoryd records are reported as {IMSI -> {records...}}. The sidToIMSI function is an online generation of the derived reverse map, producing {session ID -> IMSI}. NOTE: the indexer provides a best-effort generation of the session ID -> IMSI mapping, meaning

• a {session ID -> IMSI} mapping may be missing even though the IMSI has a session ID record
• a {session ID -> IMSI} mapping may be stale

func NewOrchestratorStreamProviderServicer

func NewOrchestratorStreamProviderServicer() streamer_protos.StreamProviderServer

func NewPushExporterServicer

func NewPushExporterServicer(pushAddrs []string) protos.MetricsExporterServer

NewPushExporterServicer returns an exporter pushing metrics to Prometheus pushgateways at the passed addresses.

Types

type PushExporterServicer

type PushExporterServicer struct {
	FamiliesByName map[string]*io_prometheus_client.MetricFamily
	ExportInterval time.Duration
	PushAddresses  []string
	sync.Mutex
}

func (*PushExporterServicer) Submit

func (s *PushExporterServicer) Submit(ctx context.Context, req *protos.SubmitMetricsRequest) (*protos.SubmitMetricsResponse, error)