nozzle

Documentation

Index

• Constants
• 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 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, ingressAddr string, tlsConfig *tls.Config, shardId string, nodeIndex int, enableEnvelopeSelector bool, envelopSelectorTags []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 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.