queue_service

Jul 14, 2021

Changes in this version

+ const DEFAULT_DIR

+ type Item struct

+ Data []byte

+ ID int

May 24, 2021

Changes in this version

+ func New() (sdk.QueueService, error)

+ func NewWithStorageDriver(driver StorageDriver) (sdk.QueueService, error)

+ type DefaultQueueDriver struct

+ func (s *DefaultQueueDriver) DeleteFile(file string) error

+ func (s *DefaultQueueDriver) EnsureDirExists(dir string) error

+ func (s *DefaultQueueDriver) ExistsOrFail(path string) error

+ func (s *DefaultQueueDriver) ReadFile(file string) ([]byte, error)

+ func (s *DefaultQueueDriver) WriteFile(file string, contents []byte, fileMode os.FileMode) error

+ type DevQueueService struct

+ 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 StorageDriver interface

+ DeleteFile func(string) error

+ EnsureDirExists func(string) error

+ ExistsOrFail func(string) error

+ ReadFile func(string) ([]byte, error)

+ WriteFile func(string, []byte, os.FileMode) error