MCPcopy Create free account

hub / github.com/ShiningRush/fastflow / functions

Functions525 in github.com/ShiningRush/fastflow

⨍ Functions 525◇ Types & classes 135
↓ 1 callersFunctionNewTaskInstance
NewTaskInstance
pkg/entity/task.go:165
↓ 1 callersFunctionNewTaskNodeFromGetter
NewTaskNodeFromGetter
pkg/mod/tasktree.go:114
↓ 1 callersFunctionNewTestRenderParam
()
pkg/mod/executor_test.go:48
↓ 1 callersFunctionNewTraceOption
NewTraceOption
pkg/entity/run/run.go:135
↓ 1 callersFunctionNextID
NextID
store/store.go:56
↓ 1 callersFunctionNextStringID
NextStringID
store/store.go:65
↓ 1 callersMethodParameterNew
()
pkg/entity/run/action.go:30
↓ 1 callersFunctionParseDuration
ParseDuration
pkg/actions/wait.go:57
↓ 1 callersMethodPush
Push task to execute
pkg/mod/executor.go:122
↓ 1 callersMethodReadDag
(path string)
pkg/utils/file.go:12
↓ 1 callersMethodReadPathsFromDir
(dir string)
pkg/utils/file.go:11
↓ 1 callersMethodReadPathsFromDir
ReadPathsFromDir
pkg/utils/file.go:24
↓ 1 callersMethodRender
Render variables
pkg/entity/dag.go:288
↓ 1 callersMethodRetryBefore
(ctx ExecuteContext, params interface{})
pkg/entity/run/action.go:35
↓ 1 callersMethodRetryDagIns
RetryDagIns
pkg/mod/commander.go:38
↓ 1 callersMethodRetryTask
RetryTask
pkg/mod/commander.go:47
↓ 1 callersMethodRun
Run used to build a new DagInstance, then you also need save it to Store
pkg/entity/dag.go:39
↓ 1 callersMethodRun
Success the dag instance
pkg/entity/dag.go:221
↓ 1 callersMethodRunAfter
(ctx ExecuteContext, params interface{})
pkg/entity/run/action.go:25
↓ 1 callersMethodRunBefore
(ctx ExecuteContext, params interface{})
pkg/entity/run/action.go:20
↓ 1 callersMethodRunDag
RunDag
pkg/mod/commander.go:20
↓ 1 callersFunctionSetCommander
SetCommander
pkg/mod/mod_define.go:76
↓ 1 callersMethodUpdateDag
UpdateDag
store/mongo/mongo.go:226
↓ 1 callersMethodUpdateDagIns
UpdateDagIns
store/mongo/mongo.go:236
↓ 1 callersMethodUpdateTaskIns
UpdateTaskIns
store/mongo/mongo.go:246
↓ 1 callersMethodUpdateTaskIns
(taskIns *entity.TaskInstance)
pkg/mod/mod_define.go:116
↓ 1 callersFunctionWarn
Warn
pkg/log/logger.go:107
↓ 1 callersMethodWarn
(msg string, fields ...interface{})
pkg/log/logger.go:78
↓ 1 callersMethodWarnf
(msg string, args ...interface{})
pkg/log/logger.go:79
↓ 1 callersMethodWatchInitDags
WatchInitDags
pkg/mod/dispatcher.go:35
↓ 1 callersMethodWorkerKey
WorkerKey must match `xxxx-1` format
keeper/mongo/mongo.go:235
↓ 1 callersMethodWorkerNumber
WorkerNumber get the the key number of Worker key, if here is a WorkKey like `worker-1`, then it will return "1"
keeper/mongo/mongo.go:240
↓ 1 callersFunctionbfsCheckCycle
(waitQueue []*TaskNode, visited map[string]struct{}, incomplete map[string]*TaskNode)
pkg/mod/tasktree.go:152
↓ 1 callersFunctionboolPtr
(b bool)
keeper/mongo/mongo.go:455
↓ 1 callersFunctionbuildGraphNodeMap
(tasks []TaskInfoGetter)
pkg/mod/tasktree.go:96
↓ 1 callersMethodcacheGetTpl
(tplText string)
pkg/render/tpl.go:23
↓ 1 callersMethodcacheSetTpl
(tplText string, template *template.Template)
pkg/render/tpl.go:33
↓ 1 callersMethodcampaign
()
keeper/mongo/mongo.go:334
↓ 1 callersMethodcontinueLeader
()
keeper/mongo/mongo.go:392
↓ 1 callersFunctioncreateDagAndInstance
()
examples/simple/main.go:69
↓ 1 callersFunctioncreateDagAndInstance
()
examples/programming/main.go:70
↓ 1 callersFunctioncreateDagAndInstance
()
examples/kube-statefulset/main.go:71
↓ 1 callersFunctiondfsWalk
( root *TaskNode, walkFunc func(node *TaskNode) bool, walkChildrenIgnoreStatus bool)
pkg/mod/tasktree.go:214
↓ 1 callersMethodelect
()
keeper/mongo/mongo.go:315
↓ 1 callersFunctionensureDagCreated
()
examples/mongo/main.go:59
↓ 1 callersFunctionensureDagCreated
(dag *entity.Dag)
examples/programming/main.go:103
↓ 1 callersFunctionensureDagLatest
(dag *entity.Dag)
fastflow.go:255
↓ 1 callersMethodgetTaskTree
(dagInsId string)
pkg/mod/parser.go:301
↓ 1 callersFunctiongetTasksMap
(tasks []*entity.TaskInstance)
pkg/mod/parser.go:207
↓ 1 callersFunctiongetTrimKeyValue
(str string, opIdx, opLen int)
pkg/utils/data/selector.go:103
↓ 1 callersMethodgoElect
()
keeper/mongo/mongo.go:301
↓ 1 callersMethodgoHeartBeat
()
keeper/mongo/mongo.go:414
↓ 1 callersMethodgoWorker
(queue <-chan *entity.TaskInstance)
pkg/mod/parser.go:125
↓ 1 callersMethodhandleErr
(err error)
pkg/mod/watchdog.go:112
↓ 1 callersMethodhandleExpiredTaskIns
()
pkg/mod/watchdog.go:60
↓ 1 callersMethodhandleLeftBehindDagIns
()
pkg/mod/watchdog.go:91
↓ 1 callersMethodhandleTaskError
(taskIns *entity.TaskInstance, err error)
pkg/mod/executor.go:274
↓ 1 callersMethodhandlerErr
(err error)
pkg/mod/dispatcher.go:90
↓ 1 callersMethodheartBeat
()
keeper/mongo/mongo.go:434
↓ 1 callersFunctioninitCommonComponent
(opt *InitialOption)
fastflow.go:199
↓ 1 callersFunctioninitLeaderChangedHandler
(opt *InitialOption)
fastflow.go:101
↓ 1 callersMethodparseTpl
(tplText string)
pkg/render/tpl.go:52
↓ 1 callersMethodpushTasks
(dagIns *entity.DagInstance, ids []string)
pkg/mod/parser.go:257
↓ 1 callersMethodreadOpt
()
keeper/mongo/mongo.go:148
↓ 1 callersMethodreadOpt
()
store/mongo/mongo.go:74
↓ 1 callersMethodrunAction
(taskIns *entity.TaskInstance)
pkg/mod/executor.go:184
↓ 1 callersFunctionrunInstance
()
examples/mongo/main.go:156
↓ 1 callersFunctionscanAllSplits
(s string)
pkg/utils/data/selector.go:63
↓ 1 callersMethodsendToChannel
(mod int, taskIns *entity.TaskInstance, newRoutineWhenFull bool)
pkg/mod/parser.go:319
↓ 1 callersFunctionsplitArgsAndOpt
splitArgsAndOpt split args and opt, opt must be placed at the end of args
pkg/entity/run/run.go:98
↓ 1 callersFunctionsplitStringsWithIdx
(s string, idx []int)
pkg/utils/data/selector.go:85
↓ 1 callersMethodsubWorkerQueue
()
pkg/mod/executor.go:71
↓ 1 callersMethodwalkSlice
(walkContext *WalkContext, slice []interface{}, callback MapValueCallback)
pkg/utils/value/value.go:68
↓ 1 callersMethodwatchDagInsCmd
()
pkg/mod/parser.go:103
↓ 1 callersMethodwatchInitQueue
()
pkg/mod/executor.go:90
↓ 1 callersMethodwatchScheduledDagIns
()
pkg/mod/parser.go:73
↓ 1 callersFunctionweakDecode
(input interface{}, output interface{})
pkg/mod/executor.go:216
↓ 1 callersMethodworkerDo
(taskIns *entity.TaskInstance)
pkg/mod/executor.go:163
MethodAliveNodes
AliveNodes get all alive nodes
keeper/mongo/mongo.go:187
MethodAliveNodes
AliveNodes provides a mock function with given fields:
pkg/mod/mod_define_mock.go:63
MethodBatchCreatTaskIns
BatchCreatTaskIns provides a mock function with given fields: taskIns
pkg/mod/mod_define_mock.go:159
MethodBatchUpdateDagIns
BatchUpdateDagIns
store/mongo/mongo.go:268
MethodBatchUpdateDagIns
BatchUpdateDagIns provides a mock function with given fields: dagIns
pkg/mod/mod_define_mock.go:173
MethodBatchUpdateTaskIns
BatchUpdateTaskIns
store/mongo/mongo.go:300
MethodBatchUpdateTaskIns
(taskIns []*entity.TaskInstance)
pkg/mod/mod_define.go:118
MethodBatchUpdateTaskIns
BatchUpdateTaskIns provides a mock function with given fields: taskIns
pkg/mod/mod_define_mock.go:187
MethodCancelTask
(taskInsIds []string, ops ...CommandOptSetter)
pkg/mod/mod_define.go:25
MethodCancelTask
CancelTask
pkg/mod/commander.go:62
MethodCancelTaskIns
CancelTaskIns
pkg/mod/executor.go:79
MethodCancelTaskIns
CancelTaskIns provides a mock function with given fields: taskInsId
pkg/mod/mod_define_mock.go:39
MethodClose
close component
keeper/mongo/mongo.go:254
MethodClose
Close component when we not use it anymore
store/mongo/mongo.go:97
MethodClose
Close provides a mock function with given fields:
pkg/mod/mod_define_mock.go:14
MethodClose
Close provides a mock function with given fields:
pkg/mod/mod_define_mock.go:91
MethodClose
Close provides a mock function with given fields:
pkg/mod/mod_define_mock.go:201
MethodCollect
Collect
pkg/exporter/collector.go:109
MethodCollect
Collect
pkg/exporter/collector.go:176
MethodContext
Context provides a mock function with given fields:
pkg/entity/run/run_mock.go:19
MethodContext
Context
pkg/entity/run/run.go:67
MethodContinueDagIns
(dagInsId string, ops ...CommandOptSetter)
pkg/mod/mod_define.go:26
← previousnext →201–300 of 525, ranked by callers