taskq

type DefaultLimiter struct{}

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

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()
}

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

type TaskQueueOption struct {
	Name string

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