memory

package

v1.0.6 Latest Latest Go to latest Published: Jul 7, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

AwaitStore 是 AwaitStore 的纯内存实现。用于测试。

func NewAwaitStore() *AwaitStore

func (s *AwaitStore) CreateBinding(_ context.Context, binding store.AwaitBinding) error

func (s *AwaitStore) FindByProviderTaskID(_ context.Context, providerTaskID string) (*store.AwaitBinding, error)

func (s *AwaitStore) ListByTask(_ context.Context, taskID string) ([]store.AwaitBinding, error)

func (s *AwaitStore) ListPending(_ context.Context) ([]store.AwaitBinding, error)

func (s *AwaitStore) ResolveBinding(_ context.Context, bindingID string) (bool, error)

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

TraceStore 是 TraceStore 的纯内存实现。用于测试。

func NewTraceStore() *TraceStore

func (s *TraceStore) AppendTrace(_ context.Context, taskID string, events []runtime.TraceEvent) error

func (s *TraceStore) ReplayTrace(_ context.Context, taskID string, sinceSeq int64) ([]runtime.TraceEvent, error)

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

WorkflowStore 是 WorkflowStore 的纯内存实现。用于测试。

func NewWorkflowStore() *WorkflowStore

func (s *WorkflowStore) CreateRun(_ context.Context, meta store.RunMeta) (*store.WorkflowRun, error)

func (s *WorkflowStore) CreateTask(_ context.Context, runID string, meta store.TaskMeta) (*store.Task, error)

func (s *WorkflowStore) ListTasks(_ context.Context, runID string) ([]store.Task, error)

func (s *WorkflowStore) LoadNodeStates(_ context.Context, taskID string) ([]store.NodeRecord, error)

func (s *WorkflowStore) LoadPlan(_ context.Context, taskID string) (*runtime.Plan, error)

func (s *WorkflowStore) LoadRun(_ context.Context, runID string) (*store.WorkflowRun, error)

func (s *WorkflowStore) LoadTask(_ context.Context, taskID string) (*store.Task, error)

func (s *WorkflowStore) PersistNode(_ context.Context, taskID string, nodeName string, state runtime.NodeState, output map[string]any) error

func (s *WorkflowStore) SavePlan(_ context.Context, taskID string, plan *runtime.Plan) error

func (s *WorkflowStore) UpdateRunStatus(_ context.Context, runID string, status string) error