queue

type BackendIDGetter ¶

type BackendIDGetter interface {
	GetBackendID() int64
}

type EtcdGetter ¶

type EtcdGetter struct {
	Client          *clientv3.Client
	BackendIDGetter BackendIDGetter
}

EtcdGetter provides access to the etcd client for creating a new queue.

func (e EtcdGetter) GetQueue(path ...string) types.Queue

type Item ¶

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

Item is a Queue item.

func (i *Item) Ack(ctx context.Context) error

func (i *Item) Key() string

func (i *Item) Nack(ctx context.Context) error

func (i *Item) Value() string

type Memory ¶

type Memory struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Memory is an implementation of types.Queue in memory, provided for testing purposes.

func (m *Memory) Dequeue(context.Context) (types.QueueItem, error)

func (m *Memory) Enqueue(_ context.Context, val string) error

type MemoryGetter ¶

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

MemoryGetter is a types.QueueGetter.

func NewMemoryGetter() *MemoryGetter

func (m *MemoryGetter) GetQueue(path ...string) types.Queue

type MemoryItem ¶

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

MemoryItem is an item from MemoryQueue.

func (m *MemoryItem) Ack(context.Context) error

func (m *MemoryItem) Nack(context.Context) error

func (m *MemoryItem) Value() string

type Queue ¶

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

Queue is a non-durable FIFO queue that is backed by etcd. When an item is received by a client, it is deleted from the work lane, and added to the in-flight lane. The item stays in the in-flight lane until it is Acked by the client, or returned to the work lane with Nack.

func New(name string, client *clientv3.Client, backendIDGetter BackendIDGetter) *Queue

func (q *Queue) Dequeue(ctx context.Context) (types.QueueItem, error)

func (q *Queue) Enqueue(ctx context.Context, value string) error