queue_service

Documentation

Index

• Constants
• func New() (queue.QueueService, error)
• type DevQueueService
  • func (s *DevQueueService) Complete(ctx context.Context, queue string, leaseId string) error
  • func (s *DevQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)
  • func (s *DevQueueService) Send(ctx context.Context, queue string, task queue.NitricTask) error
  • func (s *DevQueueService) SendBatch(ctx context.Context, q string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)
• type Item

Constants

const DEV_SUB_DIRECTORY = "./queues/"

Functions

func New

func New() (queue.QueueService, error)

Types

type DevQueueService

type DevQueueService struct {
	queue.UnimplementedQueuePlugin
	// contains filtered or unexported fields
}

func (*DevQueueService) Complete

func (s *DevQueueService) Complete(ctx context.Context, queue string, leaseId string) error

Completes a previously popped queue item

func (*DevQueueService) Receive

func (s *DevQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)

func (*DevQueueService) Send

func (s *DevQueueService) Send(ctx context.Context, queue string, task queue.NitricTask) error

func (*DevQueueService) SendBatch

func (s *DevQueueService) SendBatch(ctx context.Context, q string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)

type Item

type Item struct {
	ID   int `storm:"id,increment"` // primary key with auto increment
	Data []byte
}