task

Sep 11, 2019

Changes in this version

type Manager

+ func (svc *Manager) Close(ctx context.Context) error

type MemoScheduler

+ func (scheduler *MemoScheduler) Close(ctx context.Context) error

+ func (scheduler *MemoScheduler) NewStageID(ctx context.Context, taskKey string) (seq int64, err error)

type Scheduler

+ Close func(ctx context.Context) error

+ NewStageID func(ctx context.Context, taskKey string) (stageID int64, err error)

type Task

+ Stage int64

Sep 6, 2019

Changes in this version

+ type Awaken struct

+ OverLapped *Task

+ Task Task

type Context

+ func (cb Context) ExecCount() int32

+ func (cb Context) Task() Task

type Desc

+ Overlap bool

+ type ExecConfig struct

+ ExpectStartTime time.Time

+ MaxExecDuration time.Duration

+ Priority int32

+ RemainExecCount int32

type ExecResult

+ ResultCode int64

+ type ExecSummery struct

+ CurrentIndex int32

+ ExpectExecTime time.Time

+ MaxDuration time.Duration

type Execution

+ Available bool

+ Config ExecConfig

type Info

+ CreateTime time.Time

+ ExecConfig ExecConfig

+ ExecCount int32

type Manager

+ func (svc *Manager) CloseTask(ctx context.Context, taskKey string) error

type MemoScheduler

+ func (scheduler *MemoScheduler) NextSeqID(ctx context.Context, taskKey string) (seq int64, err error)

type Schedule

+ AwakenTime time.Time

type Scheduler

+ NextSeqID func(ctx context.Context, taskKey string) (seq int64, err error)

type Task

+ Execution Execution

+ Seq int64

+ func (t *Task) NewExec()

Sep 2, 2019

Changes in this version

type Desc

+ ExecDesc ExecDesc

+ Tags []string

+ type ExecDesc struct

+ ExpectStartTime time.Time

+ MaxExecDuration time.Duration

+ Priority int32

+ RemainExecCount int32

type ExecResult

+ NextExec ExecDesc

type Execution

+ ID int64

+ MaxExecDuration time.Duration

+ TaskID string

+ func (er *Execution) CanRetry() bool

+ func (er *Execution) OverExecTime(t time.Time) bool

+ type ExecutionRepository interface

+ FindExecution func(ctx context.Context, taskKey string, executionID int64) (*Execution, error)

+ NewExecutionID func(ctx context.Context, taskKey string) (int64, error)

+ UpdateExecution func(ctx context.Context, execution *Execution) error

+ type Info struct

+ ExecDes ExecDesc

+ Executing bool

+ ExecutionID int64

+ Tags []string

+ type MemoExecRepository struct

+ func (ms *MemoExecRepository) FindExecution(ctx context.Context, taskKey string, executionID int64) (*Execution, error)

+ func (ms *MemoExecRepository) NewExecutionID(ctx context.Context, taskKey string) (int64, error)

+ func (ms *MemoExecRepository) Run(ctx context.Context) error

+ func (ms *MemoExecRepository) UpdateExecution(ctx context.Context, execution *Execution) error

type MemoScheduler

+ func (scheduler *MemoScheduler) CloseTaskSchedule(ctx context.Context, taskKey string) error

+ func (scheduler *MemoScheduler) ReadTask(ctx context.Context, taskKey string) (*Task, error)

+ func (scheduler *MemoScheduler) ScheduleTask(ctx context.Context, taskKey string, info Info, schedule Schedule) error

+ func (scheduler *MemoScheduler) TaskSummery(ctx context.Context) (*Summery, error)

+ func (scheduler *MemoScheduler) WaitTaskSchedule(ctx context.Context) (task *Task, err error)

+ type Schedule struct

+ AcceptTime time.Time

+ ExpectTime time.Time

+ Priority int32

type Scheduler

+ CloseTaskSchedule func(ctx context.Context, taskKey string) error

+ ReadTask func(ctx context.Context, taskKey string) (*Task, error)

+ ScheduleTask func(ctx context.Context, taskKey string, info Info, schedule Schedule) error

+ TaskSummery func(ctx context.Context) (*Summery, error)

+ WaitTaskSchedule func(ctx context.Context) (task *Task, err error)

+ type StatusCode int

+ func (status StatusCode) String() string

type Task

+ Info Info

+ Schedule Schedule

Aug 29, 2019

Changes in this version

type Desc

+ TaskKey string

type Execution

+ func NewExecution(seq int, expectStartTime time.Time) *Execution

+ func (er *Execution) End(result ExecResult, t time.Time)

+ func (er *Execution) Executing(t time.Time) bool

+ func (er *Execution) Seq() int

+ func (er *Execution) Start(t time.Time)

type Profile

+ TaskKey string

type Task

+ Key string

Aug 29, 2019

Changes in this version

+ var ErrExecuting = errors.New("is executing")

+ var ErrOverMaxRetry = errors.New("over max retry")

+ type CloseType int

+ const CloseTypeCanceled

+ const CloseTypeNoExecutor

+ const CloseTypeNoMoreRetry

+ const CloseTypeNotInited

+ const CloseTypeSuccess

+ const CloseTypeUnexpect

+ type Context struct

+ func (cb *Context) Callback(ctx context.Context, res ExecResult) error

+ func (cb *Context) Execution() Execution

+ func (cb *Context) TaskKey() string

+ type Desc struct

+ Strategy ExecStrategy

+ Unique string

+ type ExecResult struct

+ ExecResultType ResultType

+ ResultInfo string

+ type ExecStrategy struct

+ ExpectStartTime time.Time

+ MaxDuration time.Duration

+ MaxRetryTimes int

+ MaxRetryWait time.Duration

+ MinRetryWait time.Duration

+ type Execution struct

+ CreateTime time.Time

+ EndTime time.Time

+ ExecSeq int

+ ExpectStartTime time.Time

+ Result ExecResult

+ Session Session

+ StartTime time.Time

+ func (er Execution) Ended(t time.Time) bool

+ func (er Execution) ReadyToStart(t time.Time) bool

+ func (er Execution) Started(t time.Time) bool

+ func (er Execution) WaitingStart(t time.Time) bool

+ type Executor interface

+ StartExecution func(cb *Context) error

+ type FuncExecutor func(cb *Context) error

+ func (fe FuncExecutor) StartExecution(cb *Context) error

+ type Manager struct

+ func NewManager(repository Repository, scheduler Scheduler, executor Executor) *Manager

+ func (svc *Manager) ApplyNewTask(ctx context.Context, desc Desc) (*Task, error)

+ func (svc *Manager) GetTaskSummary(ctx context.Context) (*Summery, error)

+ func (svc *Manager) Run(ctx context.Context) error

+ func (svc *Manager) TaskCallback(ctx context.Context, unique string, session Session, result ExecResult) error

+ type MemoRepository struct

+ func NewMemoRepository() *MemoRepository

+ func (ms *MemoRepository) GetTaskSummary(ctx context.Context) (*Summery, error)

+ func (ms *MemoRepository) OccupyTask(ctx context.Context, unique string, sessionTimeout time.Duration) (*Task, error)

+ func (ms *MemoRepository) ReadSessionTask(ctx context.Context, unique string, session Session) (*Task, error)

+ func (ms *MemoRepository) ReadTask(ctx context.Context, unique string) (*Task, error)

+ func (ms *MemoRepository) ReleaseTaskSession(ctx context.Context, unique string, sessionID int64) error

+ func (ms *MemoRepository) Run(ctx context.Context) error

+ func (ms *MemoRepository) UpdateTask(ctx context.Context, task *Task) error

+ type MemoScheduler struct

+ func NewMemoScheduler() *MemoScheduler

+ func (scheduler *MemoScheduler) DisableTaskClock(ctx context.Context, taskKey string)

+ func (scheduler *MemoScheduler) EnableTaskClock(ctx context.Context, taskKey string, expectStartTime time.Time) error

+ func (scheduler *MemoScheduler) WaitTaskAwaken(ctx context.Context) (taskKey string, expectStartTime time.Time, err error)

+ type Profile struct

+ Executions []Execution

+ Status Status

+ TaskUnique string

+ type Repository interface

+ GetTaskSummary func(ctx context.Context) (*Summery, error)

+ OccupyTask func(ctx context.Context, unique string, sessionTimeout time.Duration) (task *Task, err error)

+ ReadSessionTask func(ctx context.Context, unique string, session Session) (*Task, error)

+ ReadTask func(ctx context.Context, unique string) (*Task, error)

+ ReleaseTaskSession func(ctx context.Context, unique string, sessionID int64) error

+ UpdateTask func(ctx context.Context, task *Task) error

+ type ResultType int

+ const ExecResultTypeCancel

+ const ExecResultTypeErr

+ const ExecResultTypeSuccess

+ const ExecResultTypeTimeOut

+ const ExecResultTypeUnfinished

+ type Scheduler interface

+ DisableTaskClock func(ctx context.Context, taskKey string)

+ EnableTaskClock func(ctx context.Context, taskKey string, expectStartTime time.Time) error

+ WaitTaskAwaken func(ctx context.Context) (taskKey string, expectStartTime time.Time, err error)

+ type Session struct

+ SessionExpires time.Time

+ SessionID int64

+ type Status int

+ const StatusClosed

+ const StatusCreated

+ const StatusExecuteFinished

+ const StatusExecuting

+ const StatusInit

+ const StatusUnknown

+ const StatusWaitingExec

+ func (status Status) String() string

+ type StatusProfile struct

+ Count int64

+ Profiles []Profile

+ Total int64

+ type Summery struct

+ StatusCount map[Status]int64

+ type Task struct

+ CloseType CloseType

+ CreateTime time.Time

+ EndTime time.Time

+ ExecStrategy ExecStrategy

+ Executions []Execution

+ HandlerID int64

+ HandlerSequence int64

+ HandlerTimeout time.Duration

+ LiveTime time.Time

+ Session Session

+ Unique string

+ func TaskFromDesc(desc Desc) *Task

+ func (task *Task) CanRetry() bool

+ func (task *Task) CancelExec(info string) bool

+ func (task *Task) Close(closeType CloseType)

+ func (task *Task) CloseExec(result ExecResult) bool

+ func (task *Task) Closed() bool

+ func (task *Task) CurrentExecution() (Execution, bool)

+ func (task *Task) ExecOvertime(now time.Time) bool

+ func (task *Task) Init()

+ func (task *Task) OnExecution() bool

+ func (task *Task) Profile() Profile

+ func (task *Task) ReadyExec(now time.Time) bool

+ func (task *Task) ReadyNewExec(force bool, session Session) (err error)

+ func (task *Task) StartCurrentExec(now time.Time) (Execution, bool)

+ func (task *Task) Status() Status

+ func (task *Task) UpdateExecStrategy(strategy ExecStrategy)

+ func (task *Task) WaitOvertime(now time.Time) bool