dummyqueue

Documentation

Index

• type DummyQueue
  • func New() *DummyQueue
  • func (q *DummyQueue) Fossils() []*fossilizer.Fossil
  • func (q *DummyQueue) Pop(_ context.Context, count int) ([]*fossilizer.Fossil, error)
  • func (q *DummyQueue) PopCount() int
  • func (q *DummyQueue) Push(_ context.Context, f *fossilizer.Fossil) error
  • func (q *DummyQueue) PushCount() int

Types

type DummyQueue

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

DummyQueue is a basic in-memory queue.

func New

func New() *DummyQueue

New creates a new dummy queue.

func (*DummyQueue) Fossils

func (q *DummyQueue) Fossils() []*fossilizer.Fossil

Fossils returns all the fossils in the queue for testing purposes.

func (*DummyQueue) Pop

func (q *DummyQueue) Pop(_ context.Context, count int) ([]*fossilizer.Fossil, error)

Pop fossils from the queue.

func (*DummyQueue) PopCount

func (q *DummyQueue) PopCount() int

PopCount returns the number of fossils popped.

func (*DummyQueue) Push

func (q *DummyQueue) Push(_ context.Context, f *fossilizer.Fossil) error

Push a fossil to the queue.

func (*DummyQueue) PushCount

func (q *DummyQueue) PushCount() int

PushCount returns the number of fossils pushed.