MCPcopy Create free account

hub / github.com/ShiningRush/fastflow / functions

Functions525 in github.com/ShiningRush/fastflow

⨍ Functions 525◇ Types & classes 135
↓ 185 callersMethodErrorf
(msg string, args ...interface{})
pkg/log/logger.go:81
↓ 132 callersMethodGet
(key string)
pkg/entity/run/run.go:51
↓ 117 callersMethodRun
(ctx ExecuteContext, params interface{})
pkg/entity/run/action.go:15
↓ 45 callersFunctionGetStore
GetStore
pkg/mod/mod_define.go:159
↓ 33 callersMethodError
(msg string, fields ...interface{})
pkg/log/logger.go:80
↓ 23 callersFunctionSetStore
SetStore
pkg/mod/mod_define.go:154
↓ 17 callersFunctionErrorf
Errorf
pkg/log/logger.go:122
↓ 15 callersFunctionGetKeeper
GetKeeper
pkg/mod/mod_define.go:180
↓ 14 callersMethodClose
()
pkg/mod/mod_define.go:103
↓ 14 callersMethodWorkerKey
()
pkg/mod/mod_define.go:169
↓ 13 callersMethodFatal
(msg string, fields ...interface{})
pkg/log/logger.go:82
↓ 13 callersMethodLock
(ctx context.Context, ops ...LockOptionOp)
pkg/mod/mutex.go:10
↓ 12 callersMethodUnlock
(ctx context.Context)
pkg/mod/mutex.go:11
↓ 11 callersMethodIsLeader
()
pkg/mod/mod_define.go:166
↓ 11 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:92
↓ 10 callersFunctionSetKeeper
SetKeeper
pkg/mod/mod_define.go:175
↓ 8 callersMethodAliveNodes
()
pkg/mod/mod_define.go:168
↓ 8 callersFunctionBuildRootNode
BuildRootNode
pkg/mod/tasktree.go:56
↓ 8 callersMethodPatchDagIns
(dagIns *entity.DagInstance, mustsPatchFields ...string)
pkg/mod/mod_define.go:113
↓ 8 callersFunctioninitWorker
(t *testing.T, key string)
keeper/mongo/mongo_integ_test.go:119
↓ 7 callersMethodGetGraphID
()
pkg/mod/tasktree.go:18
↓ 7 callersMethodInit
Init store
store/mongo/mongo.go:53
↓ 7 callersMethodListTaskInstance
(input *ListTaskInstanceInput)
pkg/mod/mod_define.go:123
↓ 7 callersMethodLog
Log Log
pkg/utils/value/value_test.go:40
↓ 6 callersMethodContext
()
pkg/entity/run/run.go:31
↓ 6 callersMethodGetDag
(dagId string)
pkg/mod/mod_define.go:120
↓ 6 callersMethodLogs
Logs Logs
pkg/utils/value/value_test.go:45
↓ 6 callersMethodSetStatus
SetStatus will persist task instance
pkg/entity/task.go:207
↓ 6 callersMethodTrace
Trace print msg to the TaskInstance.Traces.
pkg/entity/run/run.go:37
↓ 6 callersMethodexecuteHook
(hookFunc DagInstanceHookFunc)
pkg/entity/dag.go:276
↓ 6 callersFunctiontestHook
(t *testing.T, dagIns *DagInstance, wantRet string, wantStatus DagInstanceStatus, call func())
pkg/entity/dag_test.go:129
↓ 5 callersFunctionError
Error
pkg/log/logger.go:117
↓ 5 callersMethodFail
Fail the dag instance
pkg/entity/dag.go:235
↓ 5 callersMethodInit
Init
keeper/mongo/mongo.go:71
↓ 5 callersMethodListDagInstance
(input *ListDagInstanceInput)
pkg/mod/mod_define.go:122
↓ 5 callersFunctionMapTaskInsToGetter
MapTaskInsToGetter
pkg/mod/tasktree.go:23
↓ 5 callersFunctionRegisterAction
RegisterAction you need register all used action to it
fastflow.go:30
↓ 5 callersFunctionSetExecutor
SetExecutor
pkg/mod/mod_define.go:92
↓ 4 callersMethodCanExecuteChild
CanExecuteChild
pkg/mod/tasktree.go:253
↓ 4 callersMethodComputeStatus
ComputeStatus
pkg/mod/tasktree.go:185
↓ 4 callersMethodInitial
Initial base info
pkg/entity/common.go:23
↓ 4 callersFunctionNewTplRender
()
pkg/render/render.go:17
↓ 4 callersMethodPatchTaskIns
(taskIns *entity.TaskInstance)
pkg/mod/mod_define.go:112
↓ 4 callersMethodUpdate
Update
pkg/entity/common.go:32
↓ 4 callersFunctionexecuteCommand
( taskInsIds []string, perform func(dagIns *entity.DagInstance, isWorkerAlive bool) error, opt CommandOptio
pkg/mod/commander.go:130
↓ 4 callersFunctioninitOption
(opSetter []CommandOptSetter)
pkg/mod/commander.go:121
↓ 4 callersMethodsetLeaderFlag
(isLeader bool)
keeper/mongo/mongo.go:111
↓ 4 callersFunctionwalkNode
(root *TaskNode, walkFunc func(node *TaskNode) bool, walkChildrenIgnoreStatus bool)
pkg/mod/tasktree.go:210
↓ 3 callersMethodBlock
Block the dag instance
pkg/entity/dag.go:242
↓ 3 callersMethodContinue
Continue tasks, it is just set a command, command will execute by Parser
pkg/entity/dag.go:253
↓ 3 callersMethodCreateDag
(dag *entity.Dag)
pkg/mod/mod_define.go:109
↓ 3 callersMethodCreateDagIns
(dagIns *entity.DagInstance)
pkg/mod/mod_define.go:110
↓ 3 callersFunctionCtxRunningTaskIns
(ctx context.Context)
pkg/entity/common.go:51
↓ 3 callersMethodEntryTaskIns
(taskIns *entity.TaskInstance)
pkg/mod/mod_define.go:187
↓ 3 callersMethodExecutable
Executable
pkg/mod/tasktree.go:311
↓ 3 callersMethodFatalf
(msg string, args ...interface{})
pkg/log/logger.go:83
↓ 3 callersMethodGetDepend
()
pkg/mod/tasktree.go:16
↓ 3 callersFunctionGetExecutor
GetExecutor
pkg/mod/mod_define.go:97
↓ 3 callersFunctionInfo
Info
pkg/log/logger.go:97
↓ 3 callersMethodInitialDagIns
InitialDagIns
pkg/mod/parser.go:152
↓ 3 callersFunctionIsCustomGenerator
IsCustomGenerator returns whether the custom generator is initialized.
store/store.go:35
↓ 3 callersMethodListDag
ListDag
store/mongo/mongo.go:359
↓ 3 callersMethodListDagInstance
ListDagInstance
store/mongo/mongo.go:371
↓ 3 callersMethodListTaskInstance
ListTaskInstance
store/mongo/mongo.go:405
↓ 3 callersMethodMarshal
(obj interface{})
pkg/mod/mod_define.go:124
↓ 3 callersMethodName
()
examples/mongo/main.go:29
↓ 3 callersFunctionNewCachedTplProvider
(maxSize int)
pkg/render/tpl.go:15
↓ 3 callersFunctionNewDefDispatcher
NewDefDispatcher
pkg/mod/dispatcher.go:22
↓ 3 callersFunctionNewStore
NewStore
store/mongo/mongo.go:46
↓ 3 callersFunctionSetLogger
SetLogger for testing
pkg/log/logger.go:12
↓ 3 callersFunctionSetParser
SetParser
pkg/mod/mod_define.go:191
↓ 3 callersFunctionStart
Start will block until accept system signal, if you don't want block, plz check "Init"
fastflow.go:62
↓ 3 callersFunctionStringsContain
StringsContain
pkg/utils/utils.go:4
↓ 3 callersMethodSuccess
Success the dag instance
pkg/entity/dag.go:228
↓ 3 callersMethodUnmarshal
(bytes []byte, ptr interface{})
pkg/mod/mod_define.go:125
↓ 3 callersMethodUpdateDag
(dagIns *entity.Dag)
pkg/mod/mod_define.go:114
↓ 3 callersMethodVarsGetter
VarsGetter
pkg/entity/dag.go:202
↓ 3 callersMethodVarsIterator
VarsIterator
pkg/entity/dag.go:210
↓ 3 callersMethodWalkString
(callback MapValueStringCallback)
pkg/utils/value/value.go:112
↓ 3 callersFunctioncheckParentAndRemoveIt
(t *testing.T, node, pNode *TaskNode)
pkg/mod/tasktree_test.go:357
↓ 3 callersMethodensureTtlIndex
(ctx context.Context, clsName, field string, ttl int32)
keeper/mongo/mongo.go:119
↓ 3 callersMethodgenericBatchDelete
(ids []string, clsName string)
store/mongo/mongo.go:480
↓ 3 callersMethodgenericCreate
(input entity.BaseInfoGetter, clsName string)
store/mongo/mongo.go:126
↓ 3 callersMethodgenericGet
(clsName, id string, ret interface{})
store/mongo/mongo.go:344
↓ 3 callersMethodgenericList
(ret interface{}, clsName string, query bson.M, opts ...*options.FindOptions)
store/mongo/mongo.go:451
↓ 3 callersMethodgenericUpdate
genericUpdate
store/mongo/mongo.go:251
↓ 3 callersMethodwalk
(walkContext *WalkContext, callback MapValueCallback)
pkg/utils/value/value.go:50
↓ 2 callersMethodAppendParent
AppendParent
pkg/mod/tasktree.go:248
↓ 2 callersMethodBatchUpdateDagIns
(dagIns []*entity.DagInstance)
pkg/mod/mod_define.go:117
↓ 2 callersMethodBuildKvGetter
BuildKvGetter
pkg/entity/task.go:86
↓ 2 callersMethodCancelTaskIns
(taskInsIds []string)
pkg/mod/mod_define.go:88
↓ 2 callersFunctionCheckWorkerKey
CheckWorkerKey check if worker key is correct, the format must be "xxxxx-{{number}}" number must in range 0~65535(sonyflake machine id is uint16) if y
keeper/keeper.go:17
↓ 2 callersFunctionCtxWithRunningTaskIns
(ctx context.Context, task *TaskInstance)
pkg/entity/common.go:47
↓ 2 callersMethodDo
Do dispatch
pkg/mod/dispatcher.go:57
↓ 2 callersMethodDoPreCheck
DoPreCheck
pkg/entity/task.go:303
↓ 2 callersMethodGetBaseInfo
()
pkg/entity/common.go:38
↓ 2 callersFunctionGetCommander
GetCommander
pkg/mod/mod_define.go:81
↓ 2 callersMethodGetDagInstance
(dagInsId string)
pkg/mod/mod_define.go:121
↓ 2 callersMethodGetExecutableTaskIds
GetExecutableTaskIds is unique task id map
pkg/mod/tasktree.go:272
↓ 2 callersMethodGetNextTaskIds
GetNextTaskIds
pkg/mod/tasktree.go:283
next →1–100 of 525, ranked by callers