queue

Documentation

Index

• Variables
• type Queue
  • func NewQueue(client storage.Queue) *Queue
  • func (q *Queue) Dequeue(ctx context.Context) (pb.InjuredSegment, error)
  • func (q *Queue) Enqueue(ctx context.Context, qi *pb.InjuredSegment) error
  • func (q *Queue) Peekqueue(ctx context.Context, limit int) ([]pb.InjuredSegment, error)
• type RepairQueue

Variables

var Error = errs.Class("queue error")

Error is a standard error class for this package.

Types

type Queue

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

Queue implements the RepairQueue interface

func NewQueue

func NewQueue(client storage.Queue) *Queue

NewQueue returns a pointer to a new Queue instance with an initialized connection to Redis

func (*Queue) Dequeue

func (q *Queue) Dequeue(ctx context.Context) (pb.InjuredSegment, error)

Dequeue returns the next repair segement and removes it from the queue

func (*Queue) Enqueue

func (q *Queue) Enqueue(ctx context.Context, qi *pb.InjuredSegment) error

Enqueue adds a repair segment to the queue

func (*Queue) Peekqueue

func (q *Queue) Peekqueue(ctx context.Context, limit int) ([]pb.InjuredSegment, error)

Peekqueue returns upto 'limit' of the entries from the repair queue

type RepairQueue

type RepairQueue interface {
	// Enqueue adds an injured segment.
	Enqueue(ctx context.Context, qi *pb.InjuredSegment) error
	// Dequeue removes an injured segment.
	Dequeue(ctx context.Context) (pb.InjuredSegment, error)
	// Peekqueue lists limit amount of injured segments.
	Peekqueue(ctx context.Context, limit int) ([]pb.InjuredSegment, error)
}

RepairQueue implements queueing for segments that need repairing.