queue

type FailedTask struct {
	Task    *NitricTask
	Message string
}

type NitricTask struct {
	ID          string                 `json:"id,omitempty" log:"ID"`
	LeaseID     string                 `json:"leaseId,omitempty" log:"LeaseID"`
	PayloadType string                 `json:"payloadType,omitempty" log:"PayLoadType"`
	Payload     map[string]interface{} `json:"payload,omitempty"`
}

type QueueService interface {
	// Send - Send a single task to a queue
	Send(queue string, task NitricTask) error
	// SendBatch - sends multiple tasks to a queue
	SendBatch(queue string, tasks []NitricTask) (*SendBatchResponse, error)
	// Receive - Receives one or more tasks(s) off a queue
	Receive(options ReceiveOptions) ([]NitricTask, error)
	// Complete - Marks a received task as completed
	Complete(queue string, leaseId string) error
}

type ReceiveOptions struct {
	// Nitric name for the queue.
	//
	// queueName is a required field
	QueueName string `type:"string" required:"true" log:"QueueName"`

	// Max depth of queue messages to receive from the queue.
	//
	// If nil or 0, defaults to depth 1.
	Depth *uint32 `type:"int" required:"false" log:"Depth"`
}

type SendBatchResponse struct {
	FailedTasks []*FailedTask
}

type UnimplementedQueuePlugin struct {
	QueueService
}