Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ShiningRush/fastflow
/ functions
Functions
525 in github.com/ShiningRush/fastflow
⨍
Functions
525
◇
Types & classes
135
Method
Run
Run
pkg/actions/wait.go:37
Method
Run
Run action
pkg/entity/task.go:240
Method
Run
Run provides a mock function with given fields: ctx, params
pkg/entity/run/action_mock.go:27
Method
Run
(ctx run.ExecuteContext, params interface{})
examples/mongo/main.go:41
Method
Run
(ctx run.ExecuteContext, params interface{})
examples/simple/main.go:22
Method
Run
(ctx run.ExecuteContext, params interface{})
examples/programming/main.go:25
Method
Run
(ctx run.ExecuteContext, params interface{})
examples/kube-statefulset/main.go:23
Method
RunAfter
RunAfter provides a mock function with given fields: ctx, params
pkg/entity/run/action_mock.go:41
Method
RunAfter
(ctx run.ExecuteContext, params interface{})
examples/mongo/main.go:49
Method
RunBefore
RunBefore provides a mock function with given fields: ctx, params
pkg/entity/run/action_mock.go:55
Method
RunBefore
(ctx run.ExecuteContext, params interface{})
examples/mongo/main.go:32
Method
Set
Set value to share data, it is thread-safe.
pkg/entity/dag.go:152
Function
SetDagInstanceLifecycleHook
SetDagInstanceLifecycleHook set hook handler for fastflow IMPORTANT: you MUST set hook before you call Init or Start to avoid lost changes. (because c
fastflow.go:123
Method
ShareData
ShareData provides a mock function with given fields:
pkg/entity/run/run_mock.go:61
Method
ShareData
ShareData
pkg/entity/run/run.go:77
Function
TestBaseInfo_Initial
(t *testing.T)
pkg/entity/common_test.go:11
Function
TestBaseInfo_Update
(t *testing.T)
pkg/entity/common_test.go:26
Function
TestBuildRootNode
(t *testing.T)
pkg/mod/tasktree_test.go:108
Function
TestCachedTplGetter_GetTpl
(t *testing.T)
pkg/render/tpl_test.go:9
Function
TestCheckWorkerKey
(t *testing.T)
keeper/keeper_test.go:18
Function
TestCommAsync
(t *testing.T)
pkg/mod/mod_define_test.go:10
Function
TestCommInterval
(t *testing.T)
pkg/mod/mod_define_test.go:24
Function
TestCommTimeout
(t *testing.T)
pkg/mod/mod_define_test.go:16
Function
TestCtxVar
(t *testing.T)
pkg/entity/common_test.go:33
Function
TestCustomGenerator
(t *testing.T)
store/store_test.go:15
Function
TestDagInstanceVars_Render
(t *testing.T)
pkg/entity/dag_test.go:163
Function
TestDagInstance_Block
(t *testing.T)
pkg/entity/dag_test.go:105
Function
TestDagInstance_Continue
(t *testing.T)
pkg/entity/dag_test.go:112
Function
TestDagInstance_Fail
(t *testing.T)
pkg/entity/dag_test.go:82
Function
TestDagInstance_Retry
(t *testing.T)
pkg/entity/dag_test.go:96
Function
TestDagInstance_Run
(t *testing.T)
pkg/entity/dag_test.go:89
Function
TestDagInstance_Success
(t *testing.T)
pkg/entity/dag_test.go:75
Function
TestDagInstance_VarsGetter
(t *testing.T)
pkg/entity/dag_test.go:50
Function
TestDagInstance_VarsIterator
(t *testing.T)
pkg/entity/dag_test.go:10
Function
TestDefCommander_CancelTask
(t *testing.T)
pkg/mod/commander_test.go:332
Function
TestDefCommander_OpDagIns
(t *testing.T)
pkg/mod/commander_test.go:102
Function
TestDefCommander_OpTask
(t *testing.T)
pkg/mod/commander_test.go:233
Function
TestDefCommander_RunDag
(t *testing.T)
pkg/mod/commander_test.go:13
Function
TestDefCommander_ensureCmdExecuted
(t *testing.T)
pkg/mod/commander_test.go:517
Function
TestDefCommander_executeCommand
(t *testing.T)
pkg/mod/commander_test.go:371
Function
TestDefCommander_initOption
(t *testing.T)
pkg/mod/commander_test.go:336
Function
TestDefDispatcher_Do
(t *testing.T)
pkg/mod/dispatcher_test.go:15
Function
TestDefDispatcher_InitAndClose
(t *testing.T)
pkg/mod/dispatcher_test.go:127
Function
TestDefExecuteContext_Tracef
(t *testing.T)
pkg/entity/run/run_test.go:10
Function
TestDefExecutor
(t *testing.T)
pkg/mod/executor_test.go:520
Function
TestDefExecutor_CancelTaskIns
(t *testing.T)
pkg/mod/executor_test.go:58
Function
TestDefExecutor_WorkerDo
(t *testing.T)
pkg/mod/executor_test.go:208
Function
TestDefExecutor_getFromTaskInstance
(t *testing.T)
pkg/mod/executor_test.go:547
Function
TestDefExecutor_initWorkerTask
(t *testing.T)
pkg/mod/executor_test.go:104
Function
TestDefExecutor_renderParams
(t *testing.T)
pkg/mod/executor_test.go:691
Function
TestDefParser
(t *testing.T)
pkg/mod/parser_test.go:1292
Function
TestDefParser_EntryTaskIns
(t *testing.T)
pkg/mod/parser_test.go:449
Function
TestDefParser_InitialDagIns
(t *testing.T)
pkg/mod/parser_test.go:568
Function
TestDefParser_ParseCmd
(t *testing.T)
pkg/mod/parser_test.go:1125
Function
TestDefParser_ParseScheduleDagIns
(t *testing.T)
pkg/mod/parser_test.go:970
Function
TestDefParser_PublisherDo
(t *testing.T)
pkg/mod/parser_test.go:899
Function
TestDefParser_WatchDagInsCmd
(t *testing.T)
pkg/mod/parser_test.go:804
Function
TestDefParser_WatchScheduledDagIns
(t *testing.T)
pkg/mod/parser_test.go:710
Function
TestDefParser_cancelChildTask
(t *testing.T)
pkg/mod/parser_test.go:16
Function
TestDefParser_executeNext
(t *testing.T)
pkg/mod/parser_test.go:213
Function
TestDefWatchDog
(t *testing.T)
pkg/mod/watchdog_test.go:277
Function
TestDefWatchDog_HandleExpiredTaskIns
(t *testing.T)
pkg/mod/watchdog_test.go:13
Function
TestDefWatchDog_HandleLeftBehindDagIns
(t *testing.T)
pkg/mod/watchdog_test.go:176
Function
TestFileDagReader_ReadPathsFromDir
(t *testing.T)
pkg/utils/file_test.go:10
Function
TestKeeper_Concurrency
(t *testing.T)
keeper/mongo/mongo_integ_test.go:61
Function
TestKeeper_Crash
(t *testing.T)
keeper/mongo/mongo_integ_test.go:42
Function
TestKeeper_Reconnect
(t *testing.T)
keeper/mongo/mongo_integ_test.go:109
Function
TestKeeper_Sanity
(t *testing.T)
keeper/mongo/mongo_integ_test.go:19
Function
TestLoopDo
(t *testing.T)
pkg/entity/run/action_test.go:12
Function
TestMongoMutex_Sanity
(t *testing.T)
keeper/mongo/mutex_integ_test.go:17
Function
TestRenderParamYaml
(t *testing.T)
pkg/mod/executor_test.go:52
Function
TestShareData_Get
(t *testing.T)
pkg/entity/dag_test.go:220
Function
TestShareData_Set
(t *testing.T)
pkg/entity/dag_test.go:247
Function
TestStore_Dag
(t *testing.T)
store/mongo/mongo_integ_test.go:18
Function
TestStore_DagIns
(t *testing.T)
store/mongo/mongo_integ_test.go:85
Function
TestStore_TaskIns
(t *testing.T)
store/mongo/mongo_integ_test.go:151
Function
TestTaskConditionSource_BuildKvGetter
(t *testing.T)
pkg/entity/task_test.go:335
Function
TestTaskInstance_DoPreCheck
(t *testing.T)
pkg/entity/task_test.go:405
Function
TestTaskInstance_Run
(t *testing.T)
pkg/entity/task_test.go:161
Function
TestTaskInstance_SetStatus
(t *testing.T)
pkg/entity/task_test.go:14
Function
TestTaskInstance_Trace
(t *testing.T)
pkg/entity/task_test.go:82
Function
TestTaskNode_ComputeStatus
(t *testing.T)
pkg/mod/tasktree_test.go:11
Function
TestTaskNode_Executable
(t *testing.T)
pkg/mod/tasktree_test.go:970
Function
TestTaskNode_GetExecutableTaskIds
(t *testing.T)
pkg/mod/tasktree_test.go:776
Function
TestTaskNode_GetNextTaskIds
(t *testing.T)
pkg/mod/tasktree_test.go:380
Function
TestValue_Walk
(t *testing.T)
pkg/utils/value/value_test.go:49
Function
TestValue_WalkString
(t *testing.T)
pkg/utils/value/value_test.go:160
Function
Test_LeaderChangeHandler
(t *testing.T)
fastflow_test.go:196
Function
Test_checkOption
(t *testing.T)
fastflow_test.go:18
Function
Test_readDagFromDir
(t *testing.T)
fastflow_test.go:61
Method
Topic
Topic
fastflow.go:136
Method
Topic
Topic is goevent's topic
pkg/exporter/collector.go:72
Method
Topic
Topic is goevent's topic
pkg/exporter/collector.go:156
Method
Topic
Topic
pkg/event/event.go:23
Method
Topic
Topic
pkg/event/event.go:34
Method
Topic
Topic
pkg/event/event.go:44
Method
Topic
Topic
pkg/event/event.go:54
Method
Topic
Topic
pkg/event/event.go:65
Method
Topic
Topic
pkg/event/event.go:76
Method
Topic
Topic
pkg/event/event.go:87
← previous
next →
401–500 of 525, ranked by callers