NewCircularBuffer creates a new circular buffer with the given capacity.

NewJobQueue creates a new JobQueue instance.

NewJobWithMetadata creates a new JobWithMetadata instance.

NewPriorityQueue creates a new priority queue.

NewScheduler creates a new scheduler instance.

TODO(owen-d): better determine priority when unknown.

BlockScheduler implements the Scheduler interface.

CircularBuffer is a generic circular buffer.

JobQueue is a thread-safe implementation of a job queue with state tracking.

JobWithMetadata wraps a job with additional metadata for tracking its lifecycle.

PriorityQueue is a generic priority queue with constant time lookups.

tries to consume upto targetRecordCount records per partition.

OffsetReader is an interface to list offsets for all partitions of a topic from Kafka.