MCPcopy Create free account

hub / github.com/ShiningRush/fastflow / types & classes

Types & classes135 in github.com/ShiningRush/fastflow

⨍ Functions 525◇ Types & classes 135
↓ 3 callersTypeAliasMapValue
pkg/utils/value/value.go:8
InterfaceAction
Action is the interface that user action must implement
pkg/entity/run/action.go:13
StructActionA
examples/mongo/main.go:25
StructActionParam
examples/mongo/main.go:20
TypeAliasActiveAction
pkg/entity/task.go:62
InterfaceAfterAction
AfterAction run after run action
pkg/entity/run/action.go:24
StructBaseInfo
BaseInfo
pkg/entity/common.go:11
InterfaceBaseInfoGetter
BaseInfoGetter
pkg/entity/common.go:37
InterfaceBeforeAction
BeforeAction run before run action
pkg/entity/run/action.go:19
StructCheck
Check
pkg/entity/task.go:47
InterfaceCloser
Closer means the component need be closeFunc
pkg/mod/mod_define.go:102
StructCommand
Command
pkg/entity/dag.go:300
TypeAliasCommandName
CommandName
pkg/entity/dag.go:306
FuncTypeCommandOptSetter
func(opt *CommandOption)
pkg/mod/mod_define.go:43
StructCommandOption
CommandOption
pkg/mod/mod_define.go:31
InterfaceCommander
Commander used to execute command
pkg/mod/mod_define.go:21
TypeAliasCtxKey
pkg/entity/common.go:41
StructDag
Dag
pkg/entity/dag.go:22
StructDagInstance
DagInstance
pkg/entity/dag.go:86
FuncTypeDagInstanceHookFunc
func(dagIns *DagInstance)
pkg/entity/dag.go:189
StructDagInstanceLifecycleHook
DagInstanceLifecycleHook
pkg/entity/dag.go:192
StructDagInstancePatched
DagInstanceUpdated will raise when dag instance he updated
pkg/event/event.go:28
TypeAliasDagInstanceStatus
DagInstanceStatus
pkg/entity/dag.go:315
StructDagInstanceUpdated
DagInstanceUpdated will raise when dag instance he updated
pkg/event/event.go:18
StructDagInstanceVar
DagInstanceVar
pkg/entity/dag.go:73
TypeAliasDagInstanceVars
DagInstanceVars
pkg/entity/dag.go:168
InterfaceDagReader
DagReader
pkg/utils/file.go:10
TypeAliasDagStatus
DagStatus
pkg/entity/dag.go:78
StructDagVar
DagVar
pkg/entity/dag.go:67
TypeAliasDagVars
pkg/entity/dag.go:64
StructDefCommander
DefCommander used to execute command
pkg/mod/commander.go:16
StructDefDispatcher
DefDispatcher
pkg/mod/dispatcher.go:15
StructDefExecuteContext
Default Executor context
pkg/entity/run/run.go:58
StructDefExecutor
DefExecutor
pkg/mod/executor.go:27
StructDefParser
DefParser
pkg/mod/parser.go:18
StructDefWatchDog
DefWatchDog
pkg/mod/watchdog.go:15
StructDispatchInitDagInsCompleted
DispatchInitDagInsCompleted will raise when leader changed such as campaign success or continue leader failed
pkg/event/event.go:70
InterfaceDistributedMutex
DistributedMutex
pkg/mod/mutex.go:9
StructErrors
Errors
pkg/utils/data/error.go:18
InterfaceExecuteContext
ExecuteContext is a context using by action go:generate mockery --name=ExecuteContext --output=. --inpackage --filename=run_mock.go
pkg/entity/run/run.go:30
InterfaceExecutor
Executor is used to execute task
pkg/mod/mod_define.go:86
StructExecutorCollector
ExecutorCollector
pkg/exporter/collector.go:61
StructFileDagReader
FileDagReader
pkg/utils/file.go:20
InterfaceGenerator
store/store.go:17
StructInitialOption
InitialOption
fastflow.go:43
InterfaceKeeper
Keeper
pkg/mod/mod_define.go:164
StructKeeper
Keeper mongo implement
keeper/mongo/mongo.go:27
StructKeeperOption
KeeperOption
keeper/mongo/mongo.go:45
FuncTypeKeyValueGetter
func(key string) (string, bool)
pkg/utils/utils.go:13
FuncTypeKeyValueIterateFunc
func(key, val string) (stop bool)
pkg/utils/utils.go:15
FuncTypeKeyValueIterator
func(KeyValueIterateFunc)
pkg/utils/utils.go:14
StructLeaderChanged
LeaderChanged will raise when leader changed such as campaign success or continue leader failed
pkg/event/event.go:59
StructLeaderChangedHandler
LeaderChangedHandler used to handle leader chaged event
fastflow.go:128
StructLeaderCollector
ExecutorCollector
pkg/exporter/collector.go:150
StructLeaderPayload
LeaderPayload leader election dto
keeper/mongo/mongo.go:295
StructListDagInput
ListDagInput
pkg/mod/mod_define.go:129
StructListDagInstanceInput
ListDagInstanceInput
pkg/mod/mod_define.go:133
StructListTaskInstanceInput
ListTaskInstanceInput
pkg/mod/mod_define.go:144
StructLockDetail
keeper/mongo/mutex.go:14
StructLockOption
LockOption
pkg/mod/mutex.go:15
FuncTypeLockOptionOp
func(option *LockOption)
pkg/mod/mutex.go:21
InterfaceLogger
Logger
pkg/log/logger.go:73
StructLoopDoOption
LoopDoOption
pkg/entity/run/action.go:54
FuncTypeLoopDoOptionOp
func(loop *LoopDoOption)
pkg/entity/run/action.go:42
FuncTypeMapValueCallback
func(walkContext *WalkContext, v interface{}) error
pkg/utils/value/value.go:12
FuncTypeMapValueStringCallback
func(walkContext *WalkContext, v string) error
pkg/utils/value/value.go:110
StructMockAction
MockAction is an autogenerated mock type for the Action type
pkg/entity/run/action_mock.go:8
StructMockBaseInfoGetter
MockBaseInfoGetter is an autogenerated mock type for the BaseInfoGetter type
pkg/entity/common_mock.go:10
StructMockCloser
MockCloser is an autogenerated mock type for the Closer type
pkg/mod/mod_define_mock.go:9
StructMockDagReader
MockDagReader is an autogenerated mock type for the DagReader type
pkg/utils/file_mock.go:8
StructMockExecuteContext
MockExecuteContext is an autogenerated mock type for the ExecuteContext type
pkg/entity/run/run_mock.go:14
StructMockExecutor
MockExecutor is an autogenerated mock type for the Executor type
pkg/mod/mod_define_mock.go:34
StructMockGenerator
keeper/keeper_test.go:12
StructMockGenerator
store/store_test.go:9
StructMockKeeper
MockKeeper is an autogenerated mock type for the Keeper type
pkg/mod/mod_define_mock.go:58
StructMockLogger
MockLogger is an autogenerated mock type for the Logger type
pkg/log/logger_mock.go:6
StructMockParser
MockParser is an autogenerated mock type for the Parser type
pkg/mod/mod_define_mock.go:19
StructMockStore
MockStore is an autogenerated mock type for the Store type
pkg/mod/mod_define_mock.go:154
StructMockTaskInfoGetter
pkg/mod/mod_define_mock.go:434
StructMongoMutex
keeper/mongo/mutex.go:20
TypeAliasOperator
pkg/entity/task.go:71
InterfaceParameterAction
ParameterAction means action has parameter
pkg/entity/run/action.go:29
StructParseScheduleDagInsCompleted
ParseScheduleDagInsCompleted will raise when leader changed such as campaign success or continue leader failed
pkg/event/event.go:81
InterfaceParser
Parser used to execute command, init dag instance and push task instance
pkg/mod/mod_define.go:185
StructPayload
Payload header beat dto
keeper/mongo/mongo.go:289
TypeAliasPersistPriority
PersistPriority
pkg/entity/run/run.go:155
TypeAliasPreChecks
pkg/entity/task.go:44
StructPrintAction
examples/simple/main.go:15
StructPrintAction
examples/programming/main.go:18
StructPrintAction
examples/kube-statefulset/main.go:16
InterfaceRetryBeforeAction
RetryBeforeAction execute before retry
pkg/entity/run/action.go:34
FuncTypeRunFunc
RunFunc is task concrete action
pkg/entity/run/action.go:10
StructSelector
pkg/utils/data/selector.go:9
TypeAliasSelectorOp
pkg/utils/data/selector.go:15
FuncTypeSetter
func(v interface{})
pkg/utils/value/value.go:10
StructShareData
ShareData can read/write within all tasks and will persist it if you want a high performance just within same task, you can use ExecuteContext's Conte
pkg/entity/dag.go:106
InterfaceShareDataOperator
ShareDataOperator used to operate share data
pkg/entity/run/run.go:50
StructSpecifiedVar
SpecifiedVar
pkg/entity/dag.go:33
StructStdoutLogger
default logger
pkg/log/logger.go:17
InterfaceStore
Store used to persist obj
pkg/mod/mod_define.go:107
next →1–100 of 135, ranked by callers