package
0.0.0-20180929164314-b5bdc3694f97
Repository: https://github.com/m3db/m3aggregator.git
Documentation: pkg.go.dev

# Functions

NewConnectionOptions create a new set of connection options.
NewMockQueue creates a new mock instance.
NewQueue creates a new queue.
NewQueueOptions create a new set of queue options.
NewRefCountedBuffer creates a new refcounted buffer.

# Structs

MockQueue is a mock of Queue interface.
MockQueueMockRecorder is the mock recorder for MockQueue.
RefCountedBuffer is a refcounted buffer.

# Interfaces

ConnectionOptions provide a set of connection options.
Queue is a queue for queuing encoded data and sending them to backend servers.
QueueOptions provide a set of queue options.