nozzle

Documentation

Index

• Constants
• type Nozzle
  • func NewNozzle(c StreamConnector, metricStoreAddr, ingressAddr string, tlsConfig *tls.Config, ...) *Nozzle
  • func (n *Nozzle) Start()
• type NozzleOption
  • func WithNozzleDebugRegistrar(m debug.MetricRegistrar) NozzleOption
  • func WithNozzleLogger(l *logger.Logger) NozzleOption
  • func WithNozzleTimerRollup(interval time.Duration, metricName string, ...) NozzleOption
  • func WithNozzleTimerRollupBufferSize(size uint) NozzleOption
• type StreamConnector

Constants

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

Types

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, metricStoreAddr, ingressAddr string, tlsConfig *tls.Config, shardId string, nodeIndex int, opts ...NozzleOption) *Nozzle

func (*Nozzle) Start

func (n *Nozzle) Start()

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

type NozzleOption

type NozzleOption func(*Nozzle)

func WithNozzleDebugRegistrar

func WithNozzleDebugRegistrar(m debug.MetricRegistrar) NozzleOption

func WithNozzleLogger

func WithNozzleLogger(l *logger.Logger) NozzleOption

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

func WithNozzleTimerRollup

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

func WithNozzleTimerRollupBufferSize

func WithNozzleTimerRollupBufferSize(size uint) NozzleOption

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.