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
ContinueTask
(taskInsIds []string, ops ...CommandOptSetter)
pkg/mod/mod_define.go:27
Method
CreateDag
CreateDag provides a mock function with given fields: dag
pkg/mod/mod_define_mock.go:206
Method
CreateDagIns
CreateDagIns provides a mock function with given fields: dagIns
pkg/mod/mod_define_mock.go:220
Method
CreateTaskIns
CreateTaskIns
store/mongo/mongo.go:122
Function
Debug
Debug
pkg/log/logger.go:87
Method
Debug
Debug
pkg/log/logger.go:21
Method
Debug
Debug provides a mock function with given fields: msg, fields
pkg/log/logger_mock.go:11
Function
Debugf
Debugf
pkg/log/logger.go:92
Method
Debugf
Debugf
pkg/log/logger.go:26
Method
Debugf
Debugf provides a mock function with given fields: msg, args
pkg/log/logger_mock.go:19
Method
Describe
Describe
pkg/exporter/collector.go:104
Method
Describe
Describe
pkg/exporter/collector.go:171
Method
EntryTaskIns
EntryTaskIns
pkg/mod/parser.go:311
Method
EntryTaskIns
EntryTaskIns provides a mock function with given fields: taskIns
pkg/mod/mod_define_mock.go:24
Method
Error
Error
pkg/utils/data/error.go:33
Method
Error
Error
pkg/log/logger.go:51
Method
Error
Error provides a mock function with given fields: msg, fields
pkg/log/logger_mock.go:27
Method
Errorf
Errorf
pkg/log/logger.go:56
Method
Errorf
Errorf provides a mock function with given fields: msg, args
pkg/log/logger_mock.go:35
Function
Fatal
Fatal
pkg/log/logger.go:127
Method
Fatal
Fatal
pkg/log/logger.go:61
Method
Fatal
Fatal provides a mock function with given fields: msg, fields
pkg/log/logger_mock.go:43
Method
Fatalf
Fatalf
pkg/log/logger.go:67
Method
Fatalf
Fatalf provides a mock function with given fields: msg, args
pkg/log/logger_mock.go:51
Method
Get
Get value from share data, it is thread-safe.
pkg/entity/dag.go:140
Function
GetAction
GetAction
fastflow.go:37
Method
GetBaseInfo
GetBaseInfo provides a mock function with given fields:
pkg/entity/common_mock.go:15
Method
GetBaseInfo
GetBaseInfo getter
pkg/entity/common.go:18
Method
GetDag
GetDag
store/mongo/mongo.go:325
Method
GetDag
GetDag provides a mock function with given fields: dagId
pkg/mod/mod_define_mock.go:234
Method
GetDagInstance
GetDagInstance
store/mongo/mongo.go:335
Method
GetDagInstance
GetDagInstance provides a mock function with given fields: dagInsId
pkg/mod/mod_define_mock.go:257
Method
GetDepend
GetDepend provides a mock function with given fields:
pkg/mod/mod_define_mock.go:441
Method
GetDepend
GetDepend
pkg/entity/task.go:35
Method
GetDepend
GetDepend
pkg/entity/task.go:190
Method
GetGraphID
GetGraphID provides a mock function with given fields:
pkg/mod/mod_define_mock.go:446
Method
GetGraphID
GetGraphID
pkg/entity/task.go:25
Method
GetGraphID
GetGraphID
pkg/entity/task.go:180
Method
GetID
GetID provides a mock function with given fields:
pkg/mod/mod_define_mock.go:451
Method
GetID
GetID
pkg/entity/task.go:30
Method
GetID
GetID
pkg/entity/task.go:185
Method
GetStatus
GetStatus provides a mock function with given fields:
pkg/mod/mod_define_mock.go:456
Method
GetStatus
GetStatus
pkg/entity/task.go:40
Method
GetStatus
GetStatus
pkg/entity/task.go:195
Method
GetTaskIns
GetTaskIns
store/mongo/mongo.go:315
Method
GetTaskIns
(taskIns string)
pkg/mod/mod_define.go:119
Method
GetTaskIns
GetTaskIns provides a mock function with given fields: taskIns
pkg/mod/mod_define_mock.go:280
Method
GetVar
GetVar provides a mock function with given fields: varName
pkg/entity/run/run_mock.go:35
Method
GetVar
(varName string)
pkg/entity/run/run.go:45
Method
GetVar
GetVar used to get key from ShareData
pkg/entity/run/run.go:119
Method
Handle
Handle is goevent's handler
pkg/exporter/collector.go:77
Method
Handle
Handle is goevent's handler
pkg/exporter/collector.go:161
Method
Info
Info
pkg/log/logger.go:31
Method
Info
Info provides a mock function with given fields: msg, fields
pkg/log/logger_mock.go:59
Method
Infof
Infof
pkg/log/logger.go:36
Method
Infof
Infof provides a mock function with given fields: msg, args
pkg/log/logger_mock.go:67
Method
InitialDagIns
InitialDagIns provides a mock function with given fields: dagIns
pkg/mod/mod_define_mock.go:29
Method
IsAlive
IsAlive check if a worker still alive
keeper/mongo/mongo.go:213
Method
IsAlive
(workerKey string)
pkg/mod/mod_define_mock.go:85
Method
IsLeader
IsLeader indicate the component if is leader node
keeper/mongo/mongo.go:182
Method
IsLeader
IsLeader provides a mock function with given fields:
pkg/mod/mod_define_mock.go:96
Method
IsMeet
IsMeet return if check is meet
pkg/entity/task.go:106
Method
IterateVars
IterateVars provides a mock function with given fields: iterateFunc
pkg/entity/run/run_mock.go:56
Method
IterateVars
(iterateFunc utils.KeyValueIterateFunc)
pkg/entity/run/run.go:46
Method
IterateVars
IterateVars used to iterate ShareData
pkg/entity/run/run.go:124
Method
Len
Len
pkg/utils/data/error.go:23
Method
ListDagInstance
ListDagInstance provides a mock function with given fields: input
pkg/mod/mod_define_mock.go:303
Method
ListTaskInstance
ListTaskInstance provides a mock function with given fields: input
pkg/mod/mod_define_mock.go:326
Method
Lock
(ctx context.Context, ops ...mod.LockOptionOp)
keeper/mongo/mutex.go:28
Method
Marshal
Marshal
store/mongo/mongo.go:497
Method
Marshal
(obj interface{})
pkg/mod/mod_define_mock.go:425
Method
MarshalBSON
MarshalBSON used by mongo
pkg/entity/dag.go:114
Method
MarshalJSON
MarshalJSON used by json
pkg/entity/dag.go:127
Method
Name
Name
pkg/actions/wait.go:27
Method
Name
Name provides a mock function with given fields:
pkg/entity/run/action_mock.go:13
Method
Name
Name define the unique action identity, it will be used by Task
examples/simple/main.go:19
Method
Name
Name define the unique action identity, it will be used by Task
examples/programming/main.go:22
Method
Name
Name define the unique action identity, it will be used by Task
examples/kube-statefulset/main.go:20
Function
NewDag
NewDag new a dag
pkg/entity/dag.go:15
Method
NewMutex
NewMutex(key string) create a new distributed mutex
keeper/mongo/mongo.go:245
Method
NewMutex
NewMutex provides a mock function with given fields: key
pkg/mod/mod_define_mock.go:138
Function
NewTestParam
()
pkg/mod/executor_test.go:21
Function
NewTestParamInt
()
pkg/mod/executor_test.go:29
Method
NextID
()
keeper/keeper_test.go:14
Method
NextID
()
store/store_test.go:11
Method
ParameterNew
ParameterNew
pkg/actions/wait.go:32
Method
ParameterNew
ParameterNew provides a mock function with given fields:
pkg/entity/run/action_mock.go:69
Method
ParameterNew
()
examples/mongo/main.go:55
Function
PareSelectors
(selector string)
pkg/utils/data/selector.go:22
Method
PatchDagIns
PatchDagIns
store/mongo/mongo.go:187
Method
PatchDagIns
PatchDagIns provides a mock function with given fields: dagIns, mustsPatchFields
pkg/mod/mod_define_mock.go:363
Method
PatchTaskIns
PatchTaskIns
store/mongo/mongo.go:158
Method
PatchTaskIns
PatchTaskIns provides a mock function with given fields: taskIns
pkg/mod/mod_define_mock.go:349
Method
Push
Push provides a mock function with given fields: dagIns, taskIns
pkg/mod/mod_define_mock.go:53
Method
ReadDag
ReadDag
pkg/utils/file.go:45
Method
ReadDag
ReadDag provides a mock function with given fields: path
pkg/utils/file_mock.go:13
Method
ReadPathsFromDir
ReadPathsFromDir provides a mock function with given fields: dir
pkg/utils/file_mock.go:36
Method
RetryBefore
RetryBefore provides a mock function with given fields: ctx, params
pkg/entity/run/action_mock.go:85
Method
RetryDagIns
(dagInsId string, ops ...CommandOptSetter)
pkg/mod/mod_define.go:23
Method
RetryTask
(taskInsIds []string, ops ...CommandOptSetter)
pkg/mod/mod_define.go:24
← previous
next →
301–400 of 525, ranked by callers