v2

package
v0.0.0-...-14308cf Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchEnvelopeWriter

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

func NewBatchEnvelopeWriter

func NewBatchEnvelopeWriter(w BatchWriter, ps ...EnvelopeProcessor) BatchEnvelopeWriter

func (BatchEnvelopeWriter) Write

type BatchWriter

type BatchWriter interface {
	Write(msgs []*loggregator_v2.Envelope) error
}

type CounterAggregator

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

func NewCounterAggregator

func NewCounterAggregator(tagger Tagger) *CounterAggregator

func (*CounterAggregator) Process

func (ca *CounterAggregator) Process(env *loggregator_v2.Envelope) error

type EnvelopeProcessor

type EnvelopeProcessor interface {
	Process(*loggregator_v2.Envelope) error
}

type EnvelopeWriter

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

func NewEnvelopeWriter

func NewEnvelopeWriter(w Writer, ps ...EnvelopeProcessor) EnvelopeWriter

func (EnvelopeWriter) Write

type MetricClient

type MetricClient interface {
	NewCounter(name string, opts ...metrics.MetricOption) metrics.Counter
}

type Nexter

type Nexter interface {
	TryNext() (*loggregator_v2.Envelope, bool)
}

type Tagger

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

func NewTagger

func NewTagger(ts map[string]string) Tagger

func (Tagger) TagEnvelope

func (t Tagger) TagEnvelope(env *loggregator_v2.Envelope)

type Transponder

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

func NewTransponder

func NewTransponder(
	n Nexter,
	w BatchWriter,
	batchSize int,
	batchInterval time.Duration,
	metricClient MetricClient,
) *Transponder

func (*Transponder) Start

func (t *Transponder) Start()

type Writer

type Writer interface {
	Write(*loggregator_v2.Envelope) error
}

Jump to

Keyboard shortcuts

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