queue

Documentation

Index

• type ServiceProvider
  • func (s *ServiceProvider) Boot(app *glacier.Glacier)
  • func (s *ServiceProvider) Daemon(ctx context.Context, app *glacier.Glacier)
  • func (s *ServiceProvider) Register(app *container.Container)
• type SyncQueue
  • func NewSyncQueue(cc *container.Container, queue storage.QueueStore, ...) SyncQueue

Types

type ServiceProvider

type ServiceProvider struct{}

func (*ServiceProvider) Boot

func (s *ServiceProvider) Boot(app *glacier.Glacier)

func (*ServiceProvider) Daemon

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

func (*ServiceProvider) Register

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

type SyncQueue

type SyncQueue interface {
	// Enqueue 添加任务到队列
	Enqueue(jobs ...job.FileSyncJob) error
	// EnqueueOneByDef 根据定义名称添加任务到队列
	EnqueueOneByDef(def string) (*job.FileSyncJob, error)
	// Worker 执行任务队列消费
	Worker(ctx context.Context)
	// RunningJobs 获取运行中的任务
	RunningJobs() []storage.JobHistoryItem
}

SyncQueue 任务同步队列接口

func NewSyncQueue

func NewSyncQueue(cc *container.Container, queue storage.QueueStore, failedStore storage.FailedJobStore) SyncQueue

NewSyncQueue 创建一个任务队列