Version: v2.3.1+incompatible Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jul 11, 2019 License: Apache-2.0 Imports: 11 Imported by: 0




View Source
const (
	BATCH_FLUSH_INTERVAL = 500 * time.Millisecond


This section is empty.


This section is empty.


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 WithDialOpts

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

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

func WithLogger

func WithLogger(l *log.Logger) NozzleOption

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

func WithMetrics

func WithMetrics(metrics metrics.Initializer) NozzleOption

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

func WithSelectors

func WithSelectors(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.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL