eventmarshaller

Documentation

Index

• type BatchChainByteWriter
• type EventBatcher
• type EventMarshaller
  • func New(batcher EventBatcher) *EventMarshaller
  • func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)
  • func (m *EventMarshaller) Write(envelope *events.Envelope)

Types

type BatchChainByteWriter

type BatchChainByteWriter interface {
	Write(message []byte, chainers ...metricbatcher.BatchCounterChainer) (err error)
}

BatchChainByteWriter is a byte writer than can accept a series of metricbatcher.BatchCounterChainer values. It should add any additional tags it needs and send the chainer when the message is successfully sent.

type EventBatcher

type EventBatcher interface {
	BatchCounter(name string) (chainer metricbatcher.BatchCounterChainer)
	BatchIncrementCounter(name string)
}

type EventMarshaller

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

func New

func New(batcher EventBatcher) *EventMarshaller

func (*EventMarshaller) SetWriter

func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)

func (*EventMarshaller) Write

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