queues

Documentation

Index

• type Lease
• type LocalQueuesService
  • func NewLocalQueuesService() (*LocalQueuesService, error)
  • func (l *LocalQueuesService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)
  • func (l *LocalQueuesService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)
  • func (l *LocalQueuesService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)
• type QueueItem
• type State

Types

type Lease

type Lease struct {
	Id     string
	Expiry time.Time
}

type LocalQueuesService

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

func NewLocalQueuesService

func NewLocalQueuesService() (*LocalQueuesService, error)

Create new Dev EventService

func (*LocalQueuesService) Complete

func (l *LocalQueuesService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)

Complete an item previously popped from a queue

func (*LocalQueuesService) Dequeue

func (l *LocalQueuesService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)

Receive message(s) from a queue

func (*LocalQueuesService) Enqueue

func (l *LocalQueuesService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)

Send messages to a queue

type QueueItem

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

type State

type State = map[queueName]map[serviceName]int