Documentation
¶
Overview ¶
Package node wires runtime node adapters.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSubWorkflowRunnerFactory ¶
func NewSubWorkflowRunnerFactory(cfg SubWorkflowRunnerConfig) func(context.Context) (runtimeexec.SubWorkflowRunner, error)
NewSubWorkflowRunnerFactory creates recursive child workflow runners.
Types ¶
type DAGStoreFactory ¶
DAGStoreFactory creates the DAG definition store used by local child workflows.
type SubWorkflowRunnerConfig ¶
type SubWorkflowRunnerConfig struct {
DAGRunMgr runtime.Manager
DAGStore exec.DAGStore
DAGStoreFactory DAGStoreFactory
DAGRunStore exec.DAGRunStore
RunStateStore runstate.Store
QueueStore exec.QueueStore
StateStore dagstate.Store
SecretStore secret.Store
ProfileStore profile.Store
ServiceRegistry exec.ServiceRegistry
PeerConfig config.Peer
DefaultExecMode config.ExecutionMode
StatusPusher runtime.StatusPusher
LogWriterFactory exec.LogWriterFactory
ArtifactFinalizer runtime.ArtifactFinalizer
WorkerID string
DAGRunLogDir string
DAGRunArtifactDir string
}
SubWorkflowRunnerConfig contains dependencies for child workflow execution.
Source Files
Click to show internal directories.
Click to hide internal directories.