task

Jun 18, 2020

Changes in this version

+ func CreateMigrateTask(doer, u *models.User, opts base.MigrateOptions) (*models.Task, error)

Nov 14, 2019

Changes in this version

+ func Init() error

+ func MigrateRepository(doer, u *models.User, opts base.MigrateOptions) error

+ func Run(t *models.Task) error

+ type ChannelQueue struct

+ func NewChannelQueue(queueLen int) *ChannelQueue

+ func (c *ChannelQueue) Push(task *models.Task) error

+ func (c *ChannelQueue) Run() error

+ func (c *ChannelQueue) Stop()

+ type Queue interface

+ Push func(*models.Task) error

+ Run func() error

+ Stop func()

+ type RedisQueue struct

+ func NewRedisQueue(addrs string, password string, dbIdx int) (*RedisQueue, error)

+ func (r *RedisQueue) Push(task *models.Task) error

+ func (r *RedisQueue) Run() error

+ func (r *RedisQueue) Stop()