nozzle

Documentation

Index

• Constants
• type MetricService
  • func NewMetricService(client *ingressclient.IngressClient, opts ...MetricServiceOptions) *MetricService
  • func (s *MetricService) AllowListedMetric(tags map[string]string) bool
  • func (s *MetricService) Export(_ context.Context, req *metricspb.ExportMetricsServiceRequest) (*metricspb.ExportMetricsServiceResponse, error)
  • func (s *MetricService) StartListening()
  • func (s *MetricService) Stop()
• type MetricServiceOptions
  • func WithMetricFiltering(allowListTags []string, filterToAppMetrics bool) MetricServiceOptions
  • func WithMetricOtelDebugRegistrar(m metrics.Registrar) MetricServiceOptions
  • func WithMetricOtelLogger(l *logger.Logger) MetricServiceOptions
• type Nozzle
  • func NewNozzle(c StreamConnector, ingressAddr string, tlsConfig *tls.Config, shardId string, ...) *Nozzle
  • func (n *Nozzle) Start()
• type Option
  • func WithNozzleDebugRegistrar(m metrics.Registrar) Option
  • func WithNozzleLogger(l *logger.Logger) Option
  • func WithNozzleTimerRollup(interval time.Duration, totalRollupTags, durationRollupTags []string) Option
  • func WithNozzleTimerRollupBufferSize(size uint) Option
• type OtelServer
  • func NewOtelServer(log *logger.Logger, ms *MetricService, ts *TraceService) *OtelServer
  • func (s *OtelServer) Close() error
  • func (s *OtelServer) Start(addr string, otelTlsConfig *tls.Config)
• type StreamConnector
• type TraceService
  • func NewTraceService(client *ingressclient.IngressClient, nodeIndex int, ...) *TraceService
  • func (s *TraceService) Export(_ context.Context, req *tracepb.ExportTraceServiceRequest) (*tracepb.ExportTraceServiceResponse, error)
  • func (s *TraceService) StartListening()
  • func (s *TraceService) Stop()
• type TraceServiceOptions
  • func WithOtelTimerRollup(interval time.Duration, totalRollupTags, durationRollupTags []string) TraceServiceOptions
  • func WithOtelTimerRollupBufferSize(size uint) TraceServiceOptions
  • func WithTraceFiltering(allowListTags []string, filterToAppMetrics bool) TraceServiceOptions
  • func WithTraceOtelDebugRegistrar(m metrics.Registrar) TraceServiceOptions
  • func WithTraceOtelLogger(l *logger.Logger) TraceServiceOptions

Constants

const (
	BATCH_FLUSH_INTERVAL = 500 * time.Millisecond
	BATCH_CHANNEL_SIZE   = 1024
)

Types

type MetricService

type MetricService struct {
	metricspb.MetricsServiceServer
	// contains filtered or unexported fields
}

func NewMetricService

func NewMetricService(client *ingressclient.IngressClient, opts ...MetricServiceOptions) *MetricService

func (*MetricService) AllowListedMetric

func (s *MetricService) AllowListedMetric(tags map[string]string) bool

func (*MetricService) Export

func (s *MetricService) Export(_ context.Context, req *metricspb.ExportMetricsServiceRequest) (*metricspb.ExportMetricsServiceResponse, error)

Export processes received metric data.

func (*MetricService) StartListening

func (s *MetricService) StartListening()

func (*MetricService) Stop

func (s *MetricService) Stop()

type MetricServiceOptions

type MetricServiceOptions func(*MetricService)

func WithMetricFiltering

func WithMetricFiltering(allowListTags []string, filterToAppMetrics bool) MetricServiceOptions

func WithMetricOtelDebugRegistrar

func WithMetricOtelDebugRegistrar(m metrics.Registrar) MetricServiceOptions

func WithMetricOtelLogger

func WithMetricOtelLogger(l *logger.Logger) MetricServiceOptions

type Nozzle

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

Nozzle reads envelopes and writes points to metric-store.

func NewNozzle

func NewNozzle(c StreamConnector, ingressAddr string, tlsConfig *tls.Config, shardId string, nodeIndex int, filterMetrics bool, allowListTags []string, opts ...Option) *Nozzle

func (*Nozzle) Start

func (n *Nozzle) Start()

Start() starts reading envelopes from the logs provider and writes them to metric-store.

type Option

type Option func(*Nozzle)

func WithNozzleDebugRegistrar

func WithNozzleDebugRegistrar(m metrics.Registrar) Option

func WithNozzleLogger

func WithNozzleLogger(l *logger.Logger) Option

WithNozzleLogger returns a Option that configures a nozzle's logger. It defaults to silent logging.

func WithNozzleTimerRollup

func WithNozzleTimerRollup(interval time.Duration, totalRollupTags, durationRollupTags []string) Option

func WithNozzleTimerRollupBufferSize

func WithNozzleTimerRollupBufferSize(size uint) Option

type OtelServer

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

func NewOtelServer

func NewOtelServer(
	log *logger.Logger,
	ms *MetricService,
	ts *TraceService,
) *OtelServer

func (*OtelServer) Close

func (s *OtelServer) Close() error

func (*OtelServer) Start

func (s *OtelServer) Start(addr string, otelTlsConfig *tls.Config)

type StreamConnector

type StreamConnector interface {
	// Stream creates a EnvelopeStream for the given request.
	Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) loggregator.EnvelopeStream
}

StreamConnector reads envelopes from the the logs provider.

type TraceService

type TraceService struct {
	tracepb.TraceServiceServer
	// contains filtered or unexported fields
}

func NewTraceService

func NewTraceService(client *ingressclient.IngressClient, nodeIndex int, opts ...TraceServiceOptions) *TraceService

func (*TraceService) Export

func (s *TraceService) Export(_ context.Context, req *tracepb.ExportTraceServiceRequest) (*tracepb.ExportTraceServiceResponse, error)

Function called with registry of TraceServiceServer

func (*TraceService) StartListening

func (s *TraceService) StartListening()

func (*TraceService) Stop

func (s *TraceService) Stop()

type TraceServiceOptions

type TraceServiceOptions func(*TraceService)

func WithOtelTimerRollup

func WithOtelTimerRollup(interval time.Duration, totalRollupTags, durationRollupTags []string) TraceServiceOptions

func WithOtelTimerRollupBufferSize

func WithOtelTimerRollupBufferSize(size uint) TraceServiceOptions

func WithTraceFiltering

func WithTraceFiltering(allowListTags []string, filterToAppMetrics bool) TraceServiceOptions

func WithTraceOtelDebugRegistrar

func WithTraceOtelDebugRegistrar(m metrics.Registrar) TraceServiceOptions

func WithTraceOtelLogger

func WithTraceOtelLogger(l *logger.Logger) TraceServiceOptions