smrqueue

Documentation

Index

• Variables
• func NewModules() fx.Option
• func NewQueue() func(NewQueueParams) *Queue
• type NewQueueParams
• type Queue
  • func (q *Queue) AddTask(taskInfo types.TaskInfo) error
  • func (q *Queue) Count() int
  • func (q *Queue) FinishTask()
  • func (q *Queue) GetTask() (types.TaskInfo, error)

Variables

var (
	ErrQueueFull = errors.New("task queue full")
)

Functions

func NewModules

func NewModules() fx.Option

func NewQueue

func NewQueue() func(NewQueueParams) *Queue

Types

type NewQueueParams

type NewQueueParams struct {
	fx.In

	Logger      *logger.Logger
	RedisClient *datastore.Redis
}

type Queue

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

func (*Queue) AddTask

func (q *Queue) AddTask(taskInfo types.TaskInfo) error

func (*Queue) Count

func (q *Queue) Count() int

func (*Queue) FinishTask

func (q *Queue) FinishTask()

func (*Queue) GetTask

func (q *Queue) GetTask() (types.TaskInfo, error)