queue

Documentation

Index

• type Handler
• type Info
• type Manager
  • func NewManager(cc infra.Resolver) Manager
• type Provider
  • func (s Provider) Boot(app infra.Resolver)
  • func (s Provider) Daemon(ctx context.Context, app infra.Resolver)
  • func (s Provider) Register(app infra.Binder)

Types

type Handler

type Handler func(item repository.QueueJob) error

Handler 队列消息处理器

type Info

type Info struct {
	StartAt        time.Time `json:"start_at"`
	WorkerNum      int       `json:"worker_num"`
	ProcessedCount int64     `json:"processed_count"`
	FailedCount    int64     `json:"failed_count"`
}

Info 队列状态信息

type Manager

type Manager interface {
	Enqueue(item repository.QueueJob) (string, error)
	StartWorker(ctx context.Context, workerID string)
	Pause(pause bool)
	Paused() bool
	Info() Info
	RegisterHandler(name string, handler Handler)
}

Manager 队列管理接口

func NewManager

func NewManager(cc infra.Resolver) Manager

NewManager create a QueueManager

type Provider

type Provider struct{}

func (Provider) Boot

func (s Provider) Boot(app infra.Resolver)

func (Provider) Daemon

func (s Provider) Daemon(ctx context.Context, app infra.Resolver)

func (Provider) Register

func (s Provider) Register(app infra.Binder)