Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

taskengine

package

Go to main page

Versions in this module

v5

v5.9.5

Apr 21, 2023

v5.9.4

Mar 23, 2023

v5.9.3

Feb 10, 2023

v5.9.2

Feb 9, 2023

v5.9.1

Jan 10, 2023

v5.9.0

Jan 9, 2023

v5.8.6

Nov 23, 2022

v5.8.5

Nov 23, 2022

v5.8.4

Nov 7, 2022

v5.8.3

Oct 26, 2022

v5.8.2

Oct 21, 2022

v5.8.1

Oct 13, 2022

v5.8.0

Oct 13, 2022

v5.7.2

Oct 11, 2022

v5.7.1

Oct 6, 2022

v5.7.0

Oct 6, 2022

v5.6.5

Oct 5, 2022

v5.6.4

Aug 5, 2022

Changes in this version

+ const LinkTaskALLDEPENDSON

+ const LinkTaskALLNEXTTASKS

+ const LinkTaskHEAD

+ const LinkTaskHEADTASKS

+ const LinkTaskTAIL

+ const LinkTaskTAILTASKS

+ const LoadingTASK_WITH_INTERVALS

type Task

+ AllDependsOn []*Task

+ AllNextTasks []*Task

+ Head *Task

+ HeadTasks []*Task

+ Tail *Task

+ TailTasks []*Task

+ func (thisTask *Task) GetAllDependsOn() []*Task

+ func (thisTask *Task) GetAllNextTasks() []*Task

v5.6.3

Jul 13, 2022

v5.6.2

May 17, 2022

v5.6.1

May 16, 2022

v5.6.0

May 16, 2022

Changes in this version

+ const FieldTaskConfigGLOBALREFERENCE

+ const FieldTaskConfigNAME

+ const FieldTaskFlowConfigNAME

+ const FieldTaskFlowConfigREFERENCE

+ const FieldTaskFlowREFERENCE

+ const FieldTaskGroupConfigGLOBALREFERENCE

+ const FieldTaskGroupConfigNAME

+ const FieldTaskParameterGLOBALREFERENCE

+ const FieldTaskParameterPARAMID

+ const FieldTaskParameterVALUE

+ const LinkTaskConfigDEPENDSON

+ const LinkTaskConfigFLOW

+ const LinkTaskConfigGROUP

+ const LinkTaskConfigNEXTTASKS

+ const LinkTaskConfigPARAMS

+ const LinkTaskConfigRUNNINGTASKS

+ const LinkTaskDEPENDSON

+ const LinkTaskFLOW

+ const LinkTaskFlowCONFIG

+ const LinkTaskFlowConfigGROUPS

+ const LinkTaskFlowConfigRUNNINGFLOWS

+ const LinkTaskFlowConfigTASKS

+ const LinkTaskFlowGROUPS

+ const LinkTaskFlowLOGS

+ const LinkTaskFlowTASKS

+ const LinkTaskGROUP

+ const LinkTaskGroupConfigFLOW

+ const LinkTaskGroupConfigRUNNINGGROUPS

+ const LinkTaskGroupConfigTASKS

+ const LinkTaskGroupFLOW

+ const LinkTaskGroupGROUPCONFIG

+ const LinkTaskGroupTASKS

+ const LinkTaskLOGS

+ const LinkTaskLogFLOW

+ const LinkTaskLogTASK

+ const LinkTaskNEXTTASKS

+ const LinkTaskParameterTASK

+ const LinkTaskTASKCONFIG

+ const LoadingGROUPCONF4WEB

+ const LoadingTASK4WEB

+ const LoadingTASKCONF4WEB

+ const LoadingTASKCONFPARAMS

+ const LoadingTASKFLOW4WEB

+ const LoadingTASKFLOWCONFIG4WEB

+ const LoadingTASKFLOWCONFIGFULL

+ const LoadingTASKFLOWTASKS

+ const LoadingTASKWITHFLOW

+ const LoadingTASK_WITH_NEXT

+ const TaskActionDISPLAY

+ const TaskActionRUN

+ var KindTASK = g.RegisterKind(&Task{}, "")

+ var KindTASKCONFIG = g.RegisterKind(&TaskConfig{}, "")

+ var KindTASKFLOW = g.RegisterKind(&TaskFlow{}, "")

+ var KindTASKFLOWCONFIG = g.RegisterKind(&TaskFlowConfig{}, "")

+ var KindTASKGROUP = g.RegisterKind(&TaskGroup{}, "")

+ var KindTASKGROUPCONFIG = g.RegisterKind(&TaskGroupConfig{}, "")

+ var KindTASKLOG = g.RegisterKind(&TaskLog{}, "")

+ var KindTASKPARAMETER = g.RegisterKind(&TaskParameter{}, "")

+ func RegisterTaskFunction(functionName TaskFunctionName, function taskFunction)

+ type FlowStatus int

+ const FlowStatusCANCELED

+ const FlowStatusCREATED

+ const FlowStatusFINISHED

+ const FlowStatusONGOING

+ const FlowStatusPAUSED

+ const FlowStatusWAITING

+ func (thisFlowStatus FlowStatus) String() string

+ func (thisFlowStatus FlowStatus) Val() int

+ func (thisFlowStatus FlowStatus) Values() map[int]string

+ type Task struct

+ CompactView bool

+ CurrentProgress int

+ DependsOn []*Task

+ ETA time.Duration

+ ETAString string

+ Finished *time.Time

+ Flow *TaskFlow

+ FlowRef string

+ FunctionName TaskFunctionName

+ GlobalReference string

+ Group *TaskGroup

+ IntervalMax float64

+ IntervalMin float64

+ LastComment string

+ Logs []*TaskLog

+ Manual bool

+ Name string

+ NbParallelIntervals int

+ NextTasks []*Task

+ Num int

+ Reference string

+ Started *time.Time

+ Status TaskStatus

+ StatusString string

+ TaskConfig *TaskConfig

+ TotalElapsed string

+ Updated *time.Time

+ func NewTask() *Task

+ func (thisTask *Task) BeforeJSON(loadingID g.LoadingID) g.IEntity

+ func (thisTask *Task) BoolParam(logger g.ILogger, paramID TaskParameterID) bool

+ func (thisTask *Task) CanBeUpdated(biContext g.BiContext, instore g.IEntity) g.Error

+ func (thisTask *Task) ChangeBeforeInsert(biContext g.BiContext) g.Error

+ func (thisTask *Task) ChangeBeforeUpdate(biContext g.BiContext) g.Error

+ func (thisTask *Task) DefineLoadingPlan(loadingID g.LoadingID) g.ILoadingPlan

+ func (thisTask *Task) DoAfterRead(biContext g.BiContext, loadingID g.LoadingID) g.Error

+ func (thisTask *Task) DurationParam(logger g.ILogger, paramID TaskParameterID, defaultValue time.Duration) time.Duration

+ func (thisTask *Task) InitSchema() *g.EntitySchema

+ func (thisTask *Task) IntParam(logger g.ILogger, paramID TaskParameterID, defaultValue int) int

+ func (thisTask *Task) LogProgress(biContext g.BiContext, progress int, commentFmt string, ...)

+ func (thisTask *Task) NumParam(logger g.ILogger, paramID TaskParameterID, defaultValue float64) float64

+ func (thisTask *Task) String() string

+ func (thisTask *Task) StringParam(logger g.ILogger, paramID TaskParameterID, defaultValue string) string

+ type TaskActionType int

+ func (thisActionType TaskActionType) GetActionName() string

+ func (thisActionType TaskActionType) String() string

+ func (thisActionType TaskActionType) Val() int

+ func (thisActionType TaskActionType) Values() map[int]string

+ type TaskConfig struct

+ CompactView bool

+ DependsOn []*TaskConfig

+ Description string

+ Flow *TaskFlowConfig

+ FunctionName TaskFunctionName

+ GlobalReference string

+ Group *TaskGroupConfig

+ Intervals string

+ Manual bool

+ Name string

+ NbParallelIntervals int

+ NextTasks []*TaskConfig

+ Params []*TaskParameter

+ Reference string

+ RunningTasks []*Task

+ func NewTaskConfig() *TaskConfig

+ func (thisTask *TaskConfig) BeforeJSON(loadingID g.LoadingID) g.IEntity

+ func (thisTaskConfig *TaskConfig) ChangeBeforeInsert(biContext g.BiContext) g.Error

+ func (thisTaskConfig *TaskConfig) ChangeBeforeUpdate(biContext g.BiContext) g.Error

+ func (thisTaskConfig *TaskConfig) DefineLoadingPlan(loadingID g.LoadingID) g.ILoadingPlan

+ func (thisTaskConfig *TaskConfig) GetIntervals() (float64, float64, float64, g.Error)

+ func (thisTaskConfig *TaskConfig) InitSchema() *g.EntitySchema

+ func (thisTaskConfig *TaskConfig) IsValid(biContext g.BiContext) g.Error

+ func (thisTaskConfig *TaskConfig) Param(paramID TaskParameterID) *TaskParameter

+ func (thisTaskConfig *TaskConfig) ScanForLoop() g.Error

+ type TaskFlow struct

+ ConfigRef string

+ CustomReference string

+ Finished *time.Time

+ FlowConfig *TaskFlowConfig

+ Groups []*TaskGroup

+ Logs []*TaskLog

+ MaxParallelTasks int

+ MermaidString string

+ Name string

+ Reference string

+ RefreshViewEvery string

+ RefreshViewEveryNum int64

+ Started *time.Time

+ Status FlowStatus

+ StatusString string

+ Tasks []*Task

+ TotalElapsed string

+ func NewTaskFlow() *TaskFlow

+ func (thisTaskFlow *TaskFlow) BeforeJSON(loadingID g.LoadingID) g.IEntity

+ func (thisTaskFlow *TaskFlow) DefineLoadingPlan(loadingID g.LoadingID) g.ILoadingPlan

+ func (thisTaskFlow *TaskFlow) DoAfterRead(biContext g.BiContext, loadingID g.LoadingID) g.Error

+ func (thisTaskFlow *TaskFlow) InitSchema() *g.EntitySchema

+ type TaskFlowConfig struct

+ Description string

+ Groups []*TaskGroupConfig

+ MaxParallelTasks int

+ MermaidString string

+ Name string

+ Reference string

+ RefreshViewEvery string

+ RunningFlows []*TaskFlow

+ TaskNameMaxWitdh int

+ Tasks []*TaskConfig

+ func NewTaskFlowConfig() *TaskFlowConfig

+ func (TaskFlowConfig *TaskFlowConfig) InitSchema() *g.EntitySchema

+ func (thisTaskFlowConfig *TaskFlowConfig) BeforeJSON(loadingID g.LoadingID) g.IEntity

+ func (thisTaskFlowConfig *TaskFlowConfig) ChangeBeforeInsert(biContext g.BiContext) g.Error

+ func (thisTaskFlowConfig *TaskFlowConfig) ChangeBeforeUpdate(biContext g.BiContext) g.Error

+ func (thisTaskFlowConfig *TaskFlowConfig) CompleteInfo(recursive bool) g.Error

+ func (thisTaskFlowConfig *TaskFlowConfig) DefineLoadingPlan(loadingID g.LoadingID) g.ILoadingPlan

+ func (thisTaskFlowConfig *TaskFlowConfig) GetGroup(groupGlobalRef string) *TaskGroupConfig

+ func (thisTaskFlowConfig *TaskFlowConfig) GetTask(taskGlobalRef string) *TaskConfig

+ func (thisTaskFlowConfig *TaskFlowConfig) IsValid(biContext g.BiContext) g.Error

+ func (thisTaskFlowConfig *TaskFlowConfig) ScanForLoops() g.Error

+ type TaskFunctionName string

+ type TaskGroup struct

+ Flow *TaskFlow

+ GroupConfig *TaskGroupConfig

+ Name string

+ Reference string

+ Tasks []*Task

+ func NewTaskGroup() *TaskGroup

+ func (thisTaskGroup *TaskGroup) InitSchema() *g.EntitySchema

+ type TaskGroupConfig struct

+ Description string

+ Flow *TaskFlowConfig

+ GlobalReference string

+ Name string

+ Reference string

+ RunningGroups []*TaskGroup

+ Tasks []*TaskConfig

+ func NewTaskGroupConfig() *TaskGroupConfig

+ func (thisTaskGroupConfig *TaskGroupConfig) ChangeBeforeInsert(biContext g.BiContext) g.Error

+ func (thisTaskGroupConfig *TaskGroupConfig) ChangeBeforeUpdate(biContext g.BiContext) g.Error

+ func (thisTaskGroupConfig *TaskGroupConfig) DefineLoadingPlan(loadingID g.LoadingID) g.ILoadingPlan

+ func (thisTaskGroupConfig *TaskGroupConfig) InitSchema() *g.EntitySchema

+ func (thisTaskGroupConfig *TaskGroupConfig) IsValid(biContext g.BiContext) g.Error

+ type TaskLog struct

+ Comment string

+ Elapsed time.Duration

+ ElapsedString string

+ Flow *TaskFlow

+ Progress int

+ Task *Task

+ TaskName string

+ TaskRef string

+ func NewTaskLog() *TaskLog

+ func (thisTaskLog *TaskLog) InitSchema() *g.EntitySchema

+ type TaskParameter struct

+ GlobalReference string

+ ParamID TaskParameterID

+ Task *TaskConfig

+ Value string

+ func NewTaskParameter() *TaskParameter

+ func (thisTaskParameter *TaskParameter) ChangeBeforeInsert(biContext g.BiContext) g.Error

+ func (thisTaskParameter *TaskParameter) ChangeBeforeUpdate(biContext g.BiContext) g.Error

+ func (thisTaskParameter *TaskParameter) InitSchema() *g.EntitySchema

+ type TaskParameterID string

+ type TaskStatus int

+ const TaskStatusERROR

+ const TaskStatusFINISHED

+ const TaskStatusONGOING

+ const TaskStatusSTANDBY

+ func (thisTaskStatus TaskStatus) String() string

+ func (thisTaskStatus TaskStatus) Val() int

+ func (thisTaskStatus TaskStatus) Values() map[int]string

Other modules containing this package

bitbucket.org/oscaroscar/vostok/v6