Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Migrator ¶
type Migrator interface {
MigrateState(ctx context.Context, workflowID, fromWorker, toWorker string) error
}
Migrator defines the interface for state migration between nodes or workers.
type StateMigrator ¶
type StateMigrator struct {
// contains filtered or unexported fields
}
StateMigrator implements zero-downtime state migration.
func NewStateMigrator ¶
func NewStateMigrator(store hermod.StateStore) *StateMigrator
NewStateMigrator creates a new StateMigrator.
func (*StateMigrator) MigrateState ¶
func (m *StateMigrator) MigrateState(ctx context.Context, workflowID, from, to string) error
MigrateState performs a coordinated migration of state.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
noderetry
Package noderetry is the per-step retry policy any workflow node can carry.
|
Package noderetry is the per-step retry policy any workflow node can carry. |
|
nodes
Package nodes is the one import that makes every workflow node type available.
|
Package nodes is the one import that makes every workflow node type available. |
|
nodes/ai
Package ai holds the workflow node executors that call a language model and route on its answer.
|
Package ai holds the workflow node executors that call a language model and route on its answer. |
|
nodes/ai/agent
Package agent is the ai_agent node: a bounded tool-use loop in which a language model works towards a goal by calling the tools the node allows.
|
Package agent is the ai_agent node: a bounded tool-use loop in which a language model works towards a goal by calling the tools the node allows. |
|
nodes/ai/agent/mcptool
Package mcptool lets the ai_agent node use one tool of a remote MCP server over the Streamable HTTP transport.
|
Package mcptool lets the ai_agent node use one tool of a remote MCP server over the Streamable HTTP transport. |
Click to show internal directories.
Click to hide internal directories.