memoryqueue

Documentation

Index

• func IsHandlerNotFound(err error) bool
• type MemoryQueue
  • func NewMemoryQueue() *MemoryQueue
  • func (m *MemoryQueue) ImplName() scene.ImplName
  • func (m *MemoryQueue) Publish(_ context.Context, task *asynctask.QueueTask) (*asynctask.QueueTask, error)
  • func (m *MemoryQueue) RegisterHandler(queue string, taskType string, handler asynctask.TaskQueueHandler) error
  • func (m *MemoryQueue) RegisterQueue(queue string, config asynctask.TaskQueueConfig) error

Functions

func IsHandlerNotFound

func IsHandlerNotFound(err error) bool

Types

type MemoryQueue

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

func NewMemoryQueue

func NewMemoryQueue() *MemoryQueue

func (*MemoryQueue) ImplName

func (m *MemoryQueue) ImplName() scene.ImplName

func (*MemoryQueue) Publish

func (m *MemoryQueue) Publish(_ context.Context, task *asynctask.QueueTask) (*asynctask.QueueTask, error)

func (*MemoryQueue) RegisterHandler

func (m *MemoryQueue) RegisterHandler(queue string, taskType string, handler asynctask.TaskQueueHandler) error

func (*MemoryQueue) RegisterQueue

func (m *MemoryQueue) RegisterQueue(queue string, config asynctask.TaskQueueConfig) error