Documentation
¶
Index ¶
- type Config
- type Queue
- func (q *Queue) Dispose() error
- func (q *Queue) ImplName() scene.ImplName
- func (q *Queue) Publish(ctx context.Context, task *asynctask.QueueTask) (*asynctask.QueueTask, error)
- func (q *Queue) RegisterHandler(queueName string, taskType string, handler asynctask.TaskQueueHandler) error
- func (q *Queue) RegisterQueue(queueName string, config asynctask.TaskQueueConfig) error
- func (q *Queue) Setup() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Redis datasource.DatabaseConfig
StreamPrefix string
GroupPrefix string
Block time.Duration
ClaimIdle time.Duration
PollInterval time.Duration
}
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) RegisterHandler ¶
func (*Queue) RegisterQueue ¶
func (q *Queue) RegisterQueue(queueName string, config asynctask.TaskQueueConfig) error
Source Files
Click to show internal directories.
Click to hide internal directories.