Documentation
¶
Index ¶
- func New() (sdk.QueueService, error)
- func NewWithStorageDriver(driver StorageDriver) (sdk.QueueService, error)
- type DefaultQueueDriver
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New() (sdk.QueueService, error)
func NewWithStorageDriver ¶
func NewWithStorageDriver(driver StorageDriver) (sdk.QueueService, error)
Types ¶
type DefaultQueueDriver ¶
type DefaultQueueDriver struct{}
func (*DefaultQueueDriver) DeleteFile ¶
func (s *DefaultQueueDriver) DeleteFile(file string) error
func (*DefaultQueueDriver) EnsureDirExists ¶
func (s *DefaultQueueDriver) EnsureDirExists(dir string) error
EnsureDirExists - Recurively creates directories for the given path
func (*DefaultQueueDriver) ExistsOrFail ¶
func (s *DefaultQueueDriver) ExistsOrFail(path string) error
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 StorageDriver ¶
type StorageDriver interface {
EnsureDirExists(string) error
ExistsOrFail(string) error
WriteFile(string, []byte, os.FileMode) error
ReadFile(string) ([]byte, error)
DeleteFile(string) error
}
StorageDriver - The interface used by the LocalStorage plugin to write/read files from the local file system
Source Files
Click to show internal directories.
Click to hide internal directories.