MCPcopy Create free account

hub / github.com/ShiningRush/fastflow / functions

Functions525 in github.com/ShiningRush/fastflow

⨍ Functions 525◇ Types & classes 135
↓ 2 callersFunctionGetParser
GetParser
pkg/mod/mod_define.go:196
↓ 2 callersMethodGetTpl
(tplText string)
pkg/render/tpl.go:39
↓ 2 callersMethodHandle
Handle
fastflow.go:141
↓ 2 callersFunctionInit
Init will not block, but you need to close fastflow after application closing
fastflow.go:83
↓ 2 callersMethodInit
Init
pkg/mod/executor.go:61
↓ 2 callersMethodInit
Init
pkg/mod/parser.go:40
↓ 2 callersMethodInit
Init
pkg/mod/watchdog.go:31
↓ 2 callersMethodInit
Init
pkg/mod/dispatcher.go:29
↓ 2 callersFunctionInitCustomGenerator
InitCustomGenerator if you give a custom generator, it will be used to generate id and not check worker number format anymore
store/store.go:23
↓ 2 callersFunctionInitFlakeGenerator
InitFlakeGenerator
store/store.go:40
↓ 2 callersMethodInitialDep
InitialDep
pkg/entity/task.go:200
↓ 2 callersFunctionMapTasksToGetter
MapTasksToGetter
pkg/mod/tasktree.go:31
↓ 2 callersMethodName
()
pkg/entity/run/action.go:14
↓ 2 callersFunctionNewDefExecutor
NewDefExecutor
pkg/mod/executor.go:49
↓ 2 callersFunctionNewDefParser
NewDefParser
pkg/mod/parser.go:30
↓ 2 callersFunctionNewDefWatchDog
NewDefWatchDog
pkg/mod/watchdog.go:23
↓ 2 callersMethodNewMutex
(key string)
pkg/mod/mod_define.go:171
↓ 2 callersFunctionNewWalkContext
()
pkg/utils/value/value.go:19
↓ 2 callersMethodNextID
()
store/store.go:18
↓ 2 callersMethodPath
()
pkg/utils/value/value.go:30
↓ 2 callersMethodPush
(dagIns *entity.DagInstance, taskIns *entity.TaskInstance)
pkg/mod/mod_define.go:87
↓ 2 callersFunctionReentrant
Reentrant mean lock it reentrant
pkg/mod/mutex.go:47
↓ 2 callersMethodRender
(tplText string, data interface{})
pkg/render/render.go:23
↓ 2 callersMethodRetry
Retry tasks, it is just set a command, command will execute by Parser
pkg/entity/dag.go:248
↓ 2 callersMethodRunDag
(dagId string, specVar map[string]string)
pkg/mod/mod_define.go:22
↓ 2 callersMethodSet
(key string, val string)
pkg/entity/run/run.go:52
↓ 2 callersMethodShareData
()
pkg/entity/run/run.go:35
↓ 2 callersMethodTrace
Trace print msg to the TaskInstance.Traces.
pkg/entity/run/run.go:82
↓ 2 callersMethodTracef
Tracef print msg to the TaskInstance.Traces. Arguments are handled in the manner of fmt.Printf. Opt can only be placed at the end of args. Tracef("{fo
pkg/entity/run/run.go:44
↓ 2 callersMethodWalk
(callback MapValueCallback)
pkg/utils/value/value.go:46
↓ 2 callersFunctionWarnf
Warnf
pkg/log/logger.go:112
↓ 2 callersMethodWithValue
WithValue can attach value to context,so can share data between action however it is base on memory, it is possible to lose changes such as applicatio
pkg/entity/run/run.go:34
↓ 2 callersMethodautoLoopDagTasks
( dagInsId string, status []entity.TaskInstanceStatus, cmdOp func(taskInsIds []string, ops ...CommandOptSet
pkg/mod/commander.go:96
↓ 2 callersMethodcancelChildTasks
(tree *TaskTree, ids []string)
pkg/mod/parser.go:271
↓ 2 callersFunctioncheckOption
(opt *InitialOption)
fastflow.go:176
↓ 2 callersFunctionensureCmdExecuted
(dagInsId string, opt CommandOption)
pkg/mod/commander.go:197
↓ 2 callersMethodexecuteNext
(taskIns *entity.TaskInstance)
pkg/mod/parser.go:215
↓ 2 callersMethodforceClose
this function is just for testing
keeper/mongo/mongo.go:283
↓ 2 callersMethodgenCmd
(taskInsIds []string, cmdName CommandName)
pkg/entity/dag.go:257
↓ 2 callersMethodgetFromTaskInstance
(taskIns *entity.TaskInstance, params interface{})
pkg/mod/executor.go:207
↓ 2 callersMethodhandleErr
(err error)
pkg/mod/parser.go:514
↓ 2 callersFunctioninitSanityWorker
(t *testing.T)
keeper/mongo/mongo_integ_test.go:129
↓ 2 callersMethodinitWorkerTask
(dagIns *entity.DagInstance, taskIns *entity.TaskInstance)
pkg/mod/executor.go:97
↓ 2 callersMethodinitialRunningDagIns
()
pkg/mod/parser.go:134
↓ 2 callersFunctionisStrInArray
(str string, arr []string)
pkg/entity/task.go:123
↓ 2 callersMethodloopTaskThenInitialDagIns
( dagIns *entity.DagInstance, status []entity.TaskInstanceStatus, loopFunc func(*entity.TaskInstance) bool)
pkg/mod/parser.go:461
↓ 2 callersMethodparseCmd
(dagIns *entity.DagInstance)
pkg/mod/parser.go:404
↓ 2 callersMethodparseScheduleDagIns
(dagIns *entity.DagInstance)
pkg/mod/parser.go:351
↓ 2 callersMethodpushPath
(path string)
pkg/utils/value/value.go:26
↓ 2 callersFunctionreadDagFromDir
(dir string)
fastflow.go:224
↓ 2 callersMethodrenderParams
(taskIns *entity.TaskInstance)
pkg/mod/executor.go:232
↓ 2 callersMethodreset
()
pkg/utils/value/value.go:41
↓ 2 callersMethodspinLock
(ctx context.Context, opt *mod.LockOption)
keeper/mongo/mutex.go:57
↓ 2 callersMethodstartWatcher
(do func() error)
pkg/mod/parser.go:57
↓ 2 callersMethodwalkValue
(walkContext *WalkContext, v interface{}, setter Setter, callback MapValueCallback)
pkg/utils/value/value.go:87
↓ 2 callersMethodwatchWrapper
(do func() error)
pkg/mod/watchdog.go:44
↓ 2 callersMethodworkerDo
(taskIns *entity.TaskInstance)
pkg/mod/parser.go:347
↓ 1 callersMethodAppend
Append
pkg/utils/data/error.go:28
↓ 1 callersMethodAppendChild
AppendChild
pkg/mod/tasktree.go:243
↓ 1 callersMethodBatchCreatTaskIns
BatchCreatTaskIns
store/mongo/mongo.go:144
↓ 1 callersMethodBatchCreatTaskIns
(taskIns []*entity.TaskInstance)
pkg/mod/mod_define.go:111
↓ 1 callersMethodBatchDeleteDag
BatchDeleteDag
store/mongo/mongo.go:466
↓ 1 callersMethodBatchDeleteDagIns
BatchDeleteDagIns
store/mongo/mongo.go:471
↓ 1 callersMethodBatchDeleteTaskIns
BatchDeleteTaskIns
store/mongo/mongo.go:476
↓ 1 callersMethodCanBeExecuted
CanBeExecuted check whether task could be executed
pkg/mod/tasktree.go:258
↓ 1 callersMethodCanBlock
()
pkg/entity/task.go:340
↓ 1 callersMethodCanModifyStatus
CanChange indicate if the dag instance can modify status
pkg/entity/dag.go:283
↓ 1 callersMethodCancel
Cancel a task, it is just set a command, command will execute by Parser
pkg/entity/dag.go:171
↓ 1 callersFunctionClose
Close all closer
fastflow.go:169
↓ 1 callersMethodClose
Close leader component
fastflow.go:161
↓ 1 callersMethodClose
Close
pkg/mod/executor.go:261
↓ 1 callersMethodClose
Close
pkg/mod/parser.go:497
↓ 1 callersMethodClose
Close
pkg/mod/watchdog.go:39
↓ 1 callersMethodClose
Close component
pkg/mod/dispatcher.go:97
↓ 1 callersMethodContinueDagIns
ContinueDagIns using to continue a blocked dag instance
pkg/mod/commander.go:73
↓ 1 callersMethodContinueTask
ContinueTask using to continue many blocked task instances
pkg/mod/commander.go:82
↓ 1 callersMethodCreateDag
CreateDag
store/mongo/mongo.go:107
↓ 1 callersMethodCreateDagIns
CreateDagIns
store/mongo/mongo.go:117
↓ 1 callersMethodDebug
(msg string, fields ...interface{})
pkg/log/logger.go:74
↓ 1 callersMethodDebugf
(msg string, args ...interface{})
pkg/log/logger.go:75
↓ 1 callersFunctionFatalf
Fatalf
pkg/log/logger.go:132
↓ 1 callersMethodGetID
()
pkg/mod/tasktree.go:17
↓ 1 callersMethodGetStatus
()
pkg/mod/tasktree.go:19
↓ 1 callersMethodHasCycle
HasCycle
pkg/mod/tasktree.go:140
↓ 1 callersFunctionHttpHandler
HttpHandler used to handle metrics request you can use it like that http.Handle("/metrics", exporter.HttpHandler) because it depend on Keeper, so y
pkg/exporter/collector.go:197
↓ 1 callersMethodInfo
(msg string, fields ...interface{})
pkg/log/logger.go:76
↓ 1 callersFunctionInfof
Infof
pkg/log/logger.go:102
↓ 1 callersMethodInfof
(msg string, args ...interface{})
pkg/log/logger.go:77
↓ 1 callersMethodInitialDagIns
(dagIns *entity.DagInstance)
pkg/mod/mod_define.go:186
↓ 1 callersMethodIsAlive
(workerKey string)
pkg/mod/mod_define.go:167
↓ 1 callersMethodIsLastState
()
pkg/entity/task.go:331
↓ 1 callersMethodIsMeet
IsMeet return if check is meet
pkg/entity/task.go:53
↓ 1 callersFunctionLockTTL
LockTTL configured lock ttl, default values: 30s
pkg/mod/mutex.go:38
↓ 1 callersFunctionLoopDo
LoopDo help you to complete loop action,for example LoopDo(ctx, func(){ log.Println("check status") })
pkg/entity/run/action.go:63
↓ 1 callersFunctionLoopInterval
LoopInterval indicate the interval of loop
pkg/entity/run/action.go:45
↓ 1 callersFunctionMapMockTasksToGetter
MapMockTasksToGetter
pkg/mod/tasktree.go:39
↓ 1 callersFunctionMustBuildRootNode
MustBuildRootNode
pkg/mod/tasktree.go:47
↓ 1 callersFunctionNewDefExecuteContext
NewDefExecuteContext
pkg/entity/run/run.go:11
↓ 1 callersFunctionNewKeeper
NewKeeper
keeper/mongo/mongo.go:60
↓ 1 callersFunctionNewLockOption
NewLockOption
pkg/mod/mutex.go:24
← previousnext →101–200 of 525, ranked by callers