store

Documentation

Index

• type InMemoryState
  • func (s *InMemoryState) Load() (PipelineState, error)
  • func (s *InMemoryState) Save(state PipelineState) error
• type PipelineState

Types

type InMemoryState

type InMemoryState struct {
	// contains filtered or unexported fields
}

func (*InMemoryState) Load

func (s *InMemoryState) Load() (PipelineState, error)

func (*InMemoryState) Save

func (s *InMemoryState) Save(state PipelineState) error

type PipelineState

type PipelineState struct {
	CurrentStageIndex int
	// 如果Stage内部有多个Unit并行或串行执行的上下文，也需要记录当前Unit的进度
	CurrentUnitIndex int
	Status           string
	// 可以存储上一阶段的输出数据，用于从中间点恢复
	LastOutput any
}