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 ¶
func (bw BatchEnvelopeWriter) Write(envs []*loggregator_v2.Envelope) error
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 ¶
func (ew EnvelopeWriter) Write(env *loggregator_v2.Envelope) error
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 (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
}
Source Files
Click to show internal directories.
Click to hide internal directories.