queue_service

Documentation

Index

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

Constants

const DEFAULT_DIR = "nitric/queues/"

Functions

func New

func New() (sdk.QueueService, error)

Types

type DevQueueService

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

func (*DevQueueService) Complete

func (s *DevQueueService) Complete(queue string, leaseId string) error

Completes a previously popped queue item

func (*DevQueueService) Receive

func (s *DevQueueService) Receive(options sdk.ReceiveOptions) ([]sdk.NitricTask, error)

func (*DevQueueService) Send

func (s *DevQueueService) Send(queue string, task sdk.NitricTask) error

func (*DevQueueService) SendBatch

func (s *DevQueueService) SendBatch(queue string, tasks []sdk.NitricTask) (*sdk.SendBatchResponse, error)

type Item

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