Versions in this module Expand all Collapse all v0 v0.1.0 Aug 5, 2025 Changes in this version + type BadgerStore struct + func NewBadgerStore(config BadgerStoreConfig) (*BadgerStore, error) + func (s *BadgerStore) Close(ctx context.Context) error + func (s *BadgerStore) CreateAgent(ctx context.Context, agent *types.Agent) error + func (s *BadgerStore) CreateWorkflow(ctx context.Context, workflow *types.Workflow) error + func (s *BadgerStore) DeleteAgent(ctx context.Context, agentID string) error + func (s *BadgerStore) DeleteWorkflow(ctx context.Context, workflowID string) error + func (s *BadgerStore) GetAgent(ctx context.Context, agentID string) (*types.Agent, error) + func (s *BadgerStore) GetEvents(ctx context.Context, filter map[string]string, limit int) ([]*types.Event, error) + func (s *BadgerStore) GetTask(ctx context.Context, workflowID, taskID string) (*types.Task, error) + func (s *BadgerStore) GetWorkflow(ctx context.Context, workflowID string) (*types.Workflow, error) + func (s *BadgerStore) HealthCheck(ctx context.Context) error + func (s *BadgerStore) Initialize(ctx context.Context) error + func (s *BadgerStore) ListAgents(ctx context.Context, filter map[string]string) ([]*types.Agent, error) + func (s *BadgerStore) ListWorkflows(ctx context.Context, filter map[string]string) ([]*types.Workflow, error) + func (s *BadgerStore) RecordEvent(ctx context.Context, event *types.Event) error + func (s *BadgerStore) Transaction(ctx context.Context, fn func(tx StateManager) error) error + func (s *BadgerStore) UpdateAgent(ctx context.Context, agent *types.Agent) error + func (s *BadgerStore) UpdateTask(ctx context.Context, workflowID string, task *types.Task) error + func (s *BadgerStore) UpdateWorkflow(ctx context.Context, workflow *types.Workflow) error + type BadgerStoreConfig struct + EventTTL time.Duration + Options badger.Options + Path string + type BadgerStoreFactory struct + func (f *BadgerStoreFactory) Create(config Config) (Store, error) + type Config struct + Options map[string]interface{} + Path string + Type string + URL string + type Factory interface + Create func(config Config) (Store, error) + type MemoryStore struct + func NewMemoryStore() *MemoryStore + func (s *MemoryStore) Close(ctx context.Context) error + func (s *MemoryStore) CreateAgent(ctx context.Context, agent *types.Agent) error + func (s *MemoryStore) CreateWorkflow(ctx context.Context, workflow *types.Workflow) error + func (s *MemoryStore) DeleteAgent(ctx context.Context, agentID string) error + func (s *MemoryStore) DeleteWorkflow(ctx context.Context, workflowID string) error + func (s *MemoryStore) GetAgent(ctx context.Context, agentID string) (*types.Agent, error) + func (s *MemoryStore) GetEvents(ctx context.Context, filter map[string]string, limit int) ([]*types.Event, error) + func (s *MemoryStore) GetTask(ctx context.Context, workflowID, taskID string) (*types.Task, error) + func (s *MemoryStore) GetWorkflow(ctx context.Context, workflowID string) (*types.Workflow, error) + func (s *MemoryStore) HealthCheck(ctx context.Context) error + func (s *MemoryStore) Initialize(ctx context.Context) error + func (s *MemoryStore) ListAgents(ctx context.Context, filter map[string]string) ([]*types.Agent, error) + func (s *MemoryStore) ListWorkflows(ctx context.Context, filter map[string]string) ([]*types.Workflow, error) + func (s *MemoryStore) RecordEvent(ctx context.Context, event *types.Event) error + func (s *MemoryStore) Transaction(ctx context.Context, fn func(tx StateManager) error) error + func (s *MemoryStore) UpdateAgent(ctx context.Context, agent *types.Agent) error + func (s *MemoryStore) UpdateTask(ctx context.Context, workflowID string, task *types.Task) error + func (s *MemoryStore) UpdateWorkflow(ctx context.Context, workflow *types.Workflow) error + type MemoryStoreFactory struct + func (f *MemoryStoreFactory) Create(config Config) (Store, error) + type StateManager interface + CreateAgent func(ctx context.Context, agent *types.Agent) error + CreateWorkflow func(ctx context.Context, workflow *types.Workflow) error + DeleteAgent func(ctx context.Context, agentID string) error + DeleteWorkflow func(ctx context.Context, workflowID string) error + GetAgent func(ctx context.Context, agentID string) (*types.Agent, error) + GetEvents func(ctx context.Context, filter map[string]string, limit int) ([]*types.Event, error) + GetTask func(ctx context.Context, workflowID, taskID string) (*types.Task, error) + GetWorkflow func(ctx context.Context, workflowID string) (*types.Workflow, error) + ListAgents func(ctx context.Context, filter map[string]string) ([]*types.Agent, error) + ListWorkflows func(ctx context.Context, filter map[string]string) ([]*types.Workflow, error) + RecordEvent func(ctx context.Context, event *types.Event) error + Transaction func(ctx context.Context, fn func(tx StateManager) error) error + UpdateAgent func(ctx context.Context, agent *types.Agent) error + UpdateTask func(ctx context.Context, workflowID string, task *types.Task) error + UpdateWorkflow func(ctx context.Context, workflow *types.Workflow) error + type Store interface + Close func(ctx context.Context) error + HealthCheck func(ctx context.Context) error + Initialize func(ctx context.Context) error
Go to main page