queue

Documentation

Index

• type Handler
• type Info
• type Manager
  • func NewManager(cc container.Container) Manager
• type ServiceProvider
  • func (s ServiceProvider) Boot(app infra.Glacier)
  • func (s ServiceProvider) Daemon(ctx context.Context, app infra.Glacier)
  • func (s ServiceProvider) Register(app container.Container)

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 container.Container) Manager

NewManager create a QueueManager

type ServiceProvider

type ServiceProvider struct{}

func (ServiceProvider) Boot

func (s ServiceProvider) Boot(app infra.Glacier)

func (ServiceProvider) Daemon

func (s ServiceProvider) Daemon(ctx context.Context, app infra.Glacier)

func (ServiceProvider) Register

func (s ServiceProvider) Register(app container.Container)