eventmarshaller

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(batcher EventBatcher) *EventMarshaller

func (m *EventMarshaller) SetWriter(byteWriter BatchChainByteWriter)

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