taskq

package

v0.0.0-...-28699d0 Latest Latest Go to latest Published: Sep 30, 2022 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func DefaultRecover()

func RegisterTaskHandler(name string, handler *TaskHandler)

type DefaultLimiter struct{}

func (*DefaultLimiter) Acquire()

func (*DefaultLimiter) Release()

type ITaskQueue interface {
	AddTask(context.Context, *Task) error
	CancelTask(context.Context, string) error
	StartConsumer()
	Close()
}

func NewTaskQueue(option *TaskQueueOption) ITaskQueue

type Limiter interface {
	Acquire()
	Release()
}

type Task struct {
	TaskID   string
	StreamID string
	Name     string
	Delay    time.Duration
	Arg      []byte
}

type TaskHandler struct {
	Handle  func(Arg []byte)
	Recover func()
}

func GetTask(name string) *TaskHandler

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

func (queue *TaskQueue) AddTask(ctx context.Context, task *Task) error

func (queue *TaskQueue) CancelTask(ctx context.Context, taskID string) error

func (queue *TaskQueue) Close()

func (queue *TaskQueue) StartConsumer()

type TaskQueueOption struct {
	Name string

	Limiter  Limiter
	Interval time.Duration
	// contains filtered or unexported fields
}