task

Documentation

Index

• type Manager
• type TaskExtension
  • func (t *TaskExtension) ClearEndTime()
  • func (t *TaskExtension) Ctx() context.Context
  • func (t *TaskExtension) GetCreator() *model.User
  • func (t *TaskExtension) GetEndTime() *time.Time
  • func (t *TaskExtension) GetStartTime() *time.Time
  • func (t *TaskExtension) GetTotalBytes() int64
  • func (t *TaskExtension) ReinitCtx()
  • func (t *TaskExtension) SetCreator(creator *model.User)
  • func (t *TaskExtension) SetEndTime(endTime time.Time)
  • func (t *TaskExtension) SetStartTime(startTime time.Time)
  • func (t *TaskExtension) SetTotalBytes(totalBytes int64)
• type TaskExtensionInfo

Types

type Manager

type Manager[T tache.Task] interface {
	Add(task T)
	Cancel(id string)
	CancelAll()
	CancelByCondition(condition func(task T) bool)
	GetAll() []T
	GetByID(id string) (T, bool)
	GetByState(state ...tache.State) []T
	GetByCondition(condition func(task T) bool) []T
	Remove(id string)
	RemoveAll()
	RemoveByState(state ...tache.State)
	RemoveByCondition(condition func(task T) bool)
	Retry(id string)
	RetryAllFailed()
}

type TaskExtension

type TaskExtension struct {
	tache.Base

	Creator *model.User
	// contains filtered or unexported fields
}

func (*TaskExtension) ClearEndTime

func (t *TaskExtension) ClearEndTime()

func (*TaskExtension) Ctx

func (t *TaskExtension) Ctx() context.Context

func (*TaskExtension) GetCreator

func (t *TaskExtension) GetCreator() *model.User

func (*TaskExtension) GetEndTime

func (t *TaskExtension) GetEndTime() *time.Time

func (*TaskExtension) GetStartTime

func (t *TaskExtension) GetStartTime() *time.Time

func (*TaskExtension) GetTotalBytes

func (t *TaskExtension) GetTotalBytes() int64

func (*TaskExtension) ReinitCtx

func (t *TaskExtension) ReinitCtx()

func (*TaskExtension) SetCreator

func (t *TaskExtension) SetCreator(creator *model.User)

func (*TaskExtension) SetEndTime

func (t *TaskExtension) SetEndTime(endTime time.Time)

func (*TaskExtension) SetStartTime

func (t *TaskExtension) SetStartTime(startTime time.Time)

func (*TaskExtension) SetTotalBytes

func (t *TaskExtension) SetTotalBytes(totalBytes int64)

type TaskExtensionInfo

type TaskExtensionInfo interface {
	tache.TaskWithInfo
	GetCreator() *model.User
	GetStartTime() *time.Time
	GetEndTime() *time.Time
	GetTotalBytes() int64
}