v2

Documentation

Index

• type CounterAggregator
  • func NewCounterAggregator(w Writer) *CounterAggregator
  • func (ca *CounterAggregator) Write(msgs []*plumbing.Envelope) error
• type MetricClient
• type Nexter
• type Transponder
  • func NewTransponder(n Nexter, w Writer, tags map[string]string, batchSize int, ...) *Transponder
  • func (t *Transponder) Start()
• type Writer

Types

type CounterAggregator

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

func NewCounterAggregator

func NewCounterAggregator(w Writer) *CounterAggregator

func (*CounterAggregator) Write

func (ca *CounterAggregator) Write(msgs []*plumbing.Envelope) error

type MetricClient

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

MetricClient creates new CounterMetrics to be emitted periodically.

type Nexter

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

type Transponder

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

func NewTransponder

func NewTransponder(
	n Nexter,
	w Writer,
	tags map[string]string,
	batchSize int,
	batchInterval time.Duration,
	metricClient MetricClient,
) *Transponder

func (*Transponder) Start

func (t *Transponder) Start()

type Writer

type Writer interface {
	Write(msgs []*v2.Envelope) error
}