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.
Click to show internal directories.
Click to hide internal directories.