nozzle

Documentation

Index

• type Nozzle
  • func NewNozzle(c StreamConnector, logCacheAddr string, shardId string, opts ...NozzleOption) *Nozzle
  • func (n *Nozzle) Start()
• type NozzleOption
  • func WithNozzleDialOpts(opts ...grpc.DialOption) NozzleOption
  • func WithNozzleLogger(l *log.Logger) NozzleOption
  • func WithNozzleMetrics(metrics metrics.Initializer) NozzleOption
  • func WithNozzleSelectors(selectors ...string) NozzleOption
• type StreamConnector

Types

type Nozzle

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

Nozzle reads envelopes and writes them to LogCache.

func NewNozzle

func NewNozzle(c StreamConnector, logCacheAddr string, shardId string, opts ...NozzleOption) *Nozzle

NewNozzle creates a new Nozzle.

func (*Nozzle) Start

func (n *Nozzle) Start()

Start starts reading envelopes from the logs provider and writes them to LogCache. It blocks indefinitely.

type NozzleOption

type NozzleOption func(*Nozzle)

NozzleOption configures a Nozzle.

func WithNozzleDialOpts

func WithNozzleDialOpts(opts ...grpc.DialOption) NozzleOption

WithNozzleDialOpts returns a NozzleOption that configures the dial options for dialing the LogCache. It defaults to grpc.WithInsecure().

func WithNozzleLogger

func WithNozzleLogger(l *log.Logger) NozzleOption

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

func WithNozzleMetrics

func WithNozzleMetrics(metrics metrics.Initializer) NozzleOption

WithNozzleMetrics returns a NozzleOption that configures the metrics for the Nozzle. It will add metrics to the given map.

func WithNozzleSelectors

func WithNozzleSelectors(selectors ...string) 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.