util

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

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

type MetricsGroup struct {
	Events      metrics.Counter
	Errors      metrics.Counter
	QueueLength metrics.Gauge
}

type SequentialBuffer interface {
	CanAdd() bool
	Add(payload []byte) (seq int, err error)
	Ack(seq int) uint
	//Unacked() [][]byte //guaranteed only on first call
	Len() int
	Reset() [][]byte
}

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

type StreamingMetrics struct {
	Reg       metrics.Registry
	OpGroups  map[string]MetricsGroup // Each Op can have an associated metrics group
	StartTime int64                   // How long we've been running for
}