queueclient

type CompleteOptions struct {
	Queue string
	Task  *Task
}

type CompleteResult struct{}

type FailedTask struct {
	Task    *Task
	Message string
}

type NitricQueueClient struct {
	// contains filtered or unexported fields
}

type QueueClient interface {
	Send(opts *SendOptions) (*SendResult, error)
	SendBatch(opts *SendBatchOptions) (*SendBatchResult, error)
	Receive(opts *ReceiveOptions) (*ReceiveResult, error)
	Complete(opts *CompleteOptions) (*CompleteResult, error)
}

type ReceiveOptions struct {
	Queue string
	Depth int
}

type ReceiveResult struct {
	Tasks []*Task
}

type SendBatchOptions struct {
	Queue string
	Tasks []*Task
}

type SendBatchResult struct {
	FailedTasks []*FailedTask
}

type SendOptions struct {
	Queue string
	Task  *Task
}

type SendResult struct{}

type Task struct {
	// ID - Unique ID for the task
	ID string
	// LeaseID - (Read-Only) LeaseID that can be used to complete this task
	LeaseID string
	// PayloadType - Deserialization hint for interprocess communication
	PayloadType string
	// Payload - The payload to include in this task
	Payload map[string]interface{}
}