queue_service

package

v0.9.6 Latest Latest Go to latest Published: Aug 20, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Details

View Source

const DEFAULT_DIR = "nitric/queues/"

This section is empty.

func New() (queue.QueueService, error)

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

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

Completes a previously popped queue item

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

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

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

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