v1

Documentation

Index

• Variables
• type BatchChainByteWriter
• type EnvelopeWriter
• type EventMarshaller
  • func NewMarshaller(mc MetricClient) *EventMarshaller
  • func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)
  • func (m *EventMarshaller) Write(envelope *events.Envelope)
• type EventWriter
  • func New(origin string) *EventWriter
  • func (e *EventWriter) Emit(event events.Event) error
  • func (e *EventWriter) EmitEnvelope(envelope *events.Envelope) error
  • func (e *EventWriter) Origin() string
  • func (e *EventWriter) SetWriter(writer EnvelopeWriter)
• type MessageAggregator
  • func NewAggregator(outputWriter EnvelopeWriter) *MessageAggregator
  • func (m *MessageAggregator) Write(envelope *events.Envelope)
• type MetricClient
• type Tagger
  • func NewTagger(deploymentName, job, index, ip string, outputWriter EnvelopeWriter) *Tagger
  • func (t *Tagger) Write(envelope *events.Envelope)

Variables

var ErrorMissingOrigin = errors.New("Event not emitted due to missing origin information")

var ErrorUnknownEventType = errors.New("Cannot create envelope for unknown event type")

var MaxTTL = time.Minute

Types

type BatchChainByteWriter

type BatchChainByteWriter interface {
	Write(message []byte) (err error)
}

type EnvelopeWriter

type EnvelopeWriter interface {
	Write(event *events.Envelope)
}

type EventMarshaller

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

func NewMarshaller

func NewMarshaller(mc MetricClient) *EventMarshaller

func (*EventMarshaller) SetWriter

func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)

func (*EventMarshaller) Write

func (m *EventMarshaller) Write(envelope *events.Envelope)

type EventWriter

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

func New

func New(origin string) *EventWriter

func (*EventWriter) Emit

func (e *EventWriter) Emit(event events.Event) error

func (*EventWriter) EmitEnvelope

func (e *EventWriter) EmitEnvelope(envelope *events.Envelope) error

func (*EventWriter) Origin

func (e *EventWriter) Origin() string

func (*EventWriter) SetWriter

func (e *EventWriter) SetWriter(writer EnvelopeWriter)

type MessageAggregator

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

func NewAggregator

func NewAggregator(outputWriter EnvelopeWriter) *MessageAggregator

func (*MessageAggregator) Write

func (m *MessageAggregator) Write(envelope *events.Envelope)

type MetricClient

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

MetricClient creates new CounterMetrics to be emitted periodically.

type Tagger

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

func NewTagger

func NewTagger(deploymentName, job, index, ip string, outputWriter EnvelopeWriter) *Tagger

func (*Tagger) Write

func (t *Tagger) Write(envelope *events.Envelope)