Documentation
¶
Index ¶
- Variables
- type Workflow
- func (w *Workflow) AddAspect(aspect node.Aspect) error
- func (w *Workflow) AddNode(n node.Node) error
- func (w *Workflow) Close()
- func (w *Workflow) Err() error
- func (w *Workflow) Get(key string) (any, error)
- func (w *Workflow) GetPoolInfo() map[string]any
- func (w *Workflow) GetStats() map[string]any
- func (w *Workflow) Input(key string, value any) error
- func (w *Workflow) IsClosed() bool
- func (w *Workflow) IsRunning() bool
- func (w *Workflow) Reset(ctx context.Context) error
- func (w *Workflow) ResizePool(newSize int) error
- func (w *Workflow) Run(input map[string]any) error
- func (w *Workflow) RunNode(n node.Node)
- func (w *Workflow) Start() error
- func (w *Workflow) Wait() error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrWorkflowRunning = errors.New("workflow is already running") ErrWorkflowResetRunning = errors.New("cannot reset a running workflow") ErrWorkflowSubmitNodeToPool = errors.New("failed to submit node to pool") ErrWorkflowClosed = errors.New("workflow has been closed and cannot be used") )
Functions ¶
This section is empty.
Types ¶
type Workflow ¶
type Workflow struct {
// contains filtered or unexported fields
}
func (*Workflow) GetPoolInfo ¶
func (*Workflow) ResizePool ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.