Help us shape the future of Go! Take the 2026 Go Developer Survey

store

package
v0.13.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 1, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Memory 

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

func NewMemory 

func NewMemory() *Memory

func (*Memory) AppendArtifact 

func (m *Memory) AppendArtifact(_ context.Context, artifact *agentcore.AgentRunArtifact) error

func (*Memory) AppendEvent 

func (m *Memory) AppendEvent(_ context.Context, event *agentcore.AgentRunEvent) error

func (*Memory) AppendInteraction 

func (m *Memory) AppendInteraction(_ context.Context, interaction *agentcore.AgentRunInteraction) error

func (*Memory) AppendMessage 

func (m *Memory) AppendMessage(_ context.Context, message *agentcore.AgentRunMessage) error

func (*Memory) AppendToolCall 

func (m *Memory) AppendToolCall(_ context.Context, call *agentcore.ToolCall) error

func (*Memory) ClearRunMCPCredentials 

func (m *Memory) ClearRunMCPCredentials(_ context.Context, appID, runID string) error

func (*Memory) ClearRunModelCredential 

func (m *Memory) ClearRunModelCredential(_ context.Context, appID, runID string) error

func (*Memory) CreateAgent 

func (m *Memory) CreateAgent(_ context.Context, agent *agentcore.Agent) error

func (*Memory) CreateRun 

func (m *Memory) CreateRun(ctx context.Context, run *agentcore.AgentRun) error

func (*Memory) CreateRunWithMCP 

func (m *Memory) CreateRunWithMCP(ctx context.Context, run *agentcore.AgentRun, servers []agentcore.RunMCPServer) error

func (*Memory) CreateRunWithModelCredential 

func (m *Memory) CreateRunWithModelCredential(_ context.Context, run *agentcore.AgentRun, servers []agentcore.RunMCPServer, credential *agentcore.RunModelCredential) error

func (*Memory) GetAgent 

func (m *Memory) GetAgent(_ context.Context, appID, agentID string) (*agentcore.Agent, error)

func (*Memory) GetRun 

func (m *Memory) GetRun(_ context.Context, appID, runID string) (*agentcore.AgentRun, error)

func (*Memory) GetRunByHostRunID 

func (m *Memory) GetRunByHostRunID(_ context.Context, appID, hostRunID string) (*agentcore.AgentRun, error)

func (*Memory) GetRunModelCredential 

func (m *Memory) GetRunModelCredential(_ context.Context, appID, runID string) (*agentcore.RunModelCredential, error)

func (*Memory) ListAgents 

func (m *Memory) ListAgents(_ context.Context, appID string) ([]agentcore.Agent, error)

func (*Memory) ListArtifacts 

func (m *Memory) ListArtifacts(_ context.Context, appID, runID string) ([]agentcore.AgentRunArtifact, error)

func (*Memory) ListEvents 

func (m *Memory) ListEvents(_ context.Context, appID, runID string) ([]agentcore.AgentRunEvent, error)

func (*Memory) ListEventsAfter 

func (m *Memory) ListEventsAfter(_ context.Context, appID, runID string, afterSequence int64, limit int) ([]agentcore.AgentRunEvent, error)

ListEventsAfter returns an ordered, bounded slice of a run's durable event log. It is an optional store extension used by paged v2 consumers; the core Store contract remains unchanged for existing callers.

func (*Memory) ListInteractions 

func (m *Memory) ListInteractions(_ context.Context, appID, runID string) ([]agentcore.AgentRunInteraction, error)

func (*Memory) ListMessages 

func (m *Memory) ListMessages(_ context.Context, appID, runID string) ([]agentcore.AgentRunMessage, error)

func (*Memory) ListRunMCPServers 

func (m *Memory) ListRunMCPServers(_ context.Context, appID, runID string) ([]agentcore.RunMCPServer, error)

func (*Memory) ListRuns 

func (m *Memory) ListRuns(_ context.Context, appID string) ([]agentcore.AgentRun, error)

func (*Memory) ListRunsByStatus 

func (m *Memory) ListRunsByStatus(_ context.Context, statuses ...string) ([]agentcore.AgentRun, error)

func (*Memory) ListToolCalls 

func (m *Memory) ListToolCalls(_ context.Context, appID, runID string) ([]agentcore.ToolCall, error)

func (*Memory) LoadNativeState 

func (m *Memory) LoadNativeState(_ context.Context, appID, runID string) (*agentcore.NativeState, error)

LoadNativeState reads an isolated copy of the checkpoint.

func (*Memory) MarkRunManuallyPaused added in v0.13.2 

func (m *Memory) MarkRunManuallyPaused(_ context.Context, appID, runID string) (bool, error)

MarkRunManuallyPaused changes only an active run, preserving a concurrent cancellation.

func (*Memory) ReplaceRunModelCredential 

func (m *Memory) ReplaceRunModelCredential(_ context.Context, c *agentcore.RunModelCredential, version int64) (bool, error)

func (*Memory) SaveNativeState 

func (m *Memory) SaveNativeState(_ context.Context, state *agentcore.NativeState, records []json.RawMessage) error

SaveNativeState atomically archives records and advances the checkpoint version.

func (*Memory) SearchRuns 

func (m *Memory) SearchRuns(_ context.Context, search agentcore.RunSearch) (*agentcore.RunPage, error)

func (*Memory) UpdateAgent 

func (m *Memory) UpdateAgent(_ context.Context, agent *agentcore.Agent) error

func (*Memory) UpdateInteraction 

func (m *Memory) UpdateInteraction(_ context.Context, interaction *agentcore.AgentRunInteraction) error

func (*Memory) UpdateRun 

func (m *Memory) UpdateRun(_ context.Context, run *agentcore.AgentRun) error

func (*Memory) UpdateRunMCPCredential 

func (m *Memory) UpdateRunMCPCredential(_ context.Context, appID, runID, serverID string, encryptedCredential []byte) error

func (*Memory) UpdateRunOutputSummary 

func (m *Memory) UpdateRunOutputSummary(ctx context.Context, appID, runID string, summary json.RawMessage) error

UpdateRunOutputSummary changes only output under the store lock.

type ResolvedConfig 

type ResolvedConfig struct {
	Driver   string
	DSN      string
	InMemory bool
}

func ResolveConfigFromEnv 

func ResolveConfigFromEnv(getenv func(string) string) (ResolvedConfig, error)

type SQL 

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

func NewSQL 

func NewSQL(db *gorm.DB) *SQL

func OpenSQL 

func OpenSQL(cfg SQLConfig) (*SQL, error)

func (*SQL) AcquireRunLock added in v0.13.0 

func (s *SQL) AcquireRunLock(ctx context.Context, appID, runID string, waiting func()) (context.Context, func(), error)

AcquireRunLock holds a PostgreSQL advisory lock on a dedicated connection. A lost connection cancels the returned execution context. Call release only AFTER execution (including child-process cancellation) has finished. Never return a session-locked connection to the pool.

func (*SQL) AppendArtifact 

func (s *SQL) AppendArtifact(ctx context.Context, artifact *agentcore.AgentRunArtifact) error

func (*SQL) AppendEvent 

func (s *SQL) AppendEvent(ctx context.Context, event *agentcore.AgentRunEvent) error

func (*SQL) AppendInteraction 

func (s *SQL) AppendInteraction(ctx context.Context, interaction *agentcore.AgentRunInteraction) error

func (*SQL) AppendMessage 

func (s *SQL) AppendMessage(ctx context.Context, message *agentcore.AgentRunMessage) error

func (*SQL) AppendToolCall 

func (s *SQL) AppendToolCall(ctx context.Context, call *agentcore.ToolCall) error

func (*SQL) AutoMigrate 

func (s *SQL) AutoMigrate() error

func (*SQL) ClearRunMCPCredentials 

func (s *SQL) ClearRunMCPCredentials(ctx context.Context, appID, runID string) error

func (*SQL) ClearRunModelCredential 

func (s *SQL) ClearRunModelCredential(ctx context.Context, appID, runID string) error

func (*SQL) CreateAgent 

func (s *SQL) CreateAgent(ctx context.Context, agent *agentcore.Agent) error

func (*SQL) CreateRun 

func (s *SQL) CreateRun(ctx context.Context, run *agentcore.AgentRun) error

func (*SQL) CreateRunWithMCP 

func (s *SQL) CreateRunWithMCP(ctx context.Context, run *agentcore.AgentRun, servers []agentcore.RunMCPServer) error

func (*SQL) CreateRunWithModelCredential 

func (s *SQL) CreateRunWithModelCredential(ctx context.Context, run *agentcore.AgentRun, servers []agentcore.RunMCPServer, credential *agentcore.RunModelCredential) error

func (*SQL) DB 

func (s *SQL) DB() *gorm.DB

func (*SQL) GetAgent 

func (s *SQL) GetAgent(ctx context.Context, appID, agentID string) (*agentcore.Agent, error)

func (*SQL) GetRun 

func (s *SQL) GetRun(ctx context.Context, appID, runID string) (*agentcore.AgentRun, error)

func (*SQL) GetRunByHostRunID 

func (s *SQL) GetRunByHostRunID(ctx context.Context, appID, hostRunID string) (*agentcore.AgentRun, error)

func (*SQL) GetRunModelCredential 

func (s *SQL) GetRunModelCredential(ctx context.Context, appID, runID string) (*agentcore.RunModelCredential, error)

func (*SQL) ListAgents 

func (s *SQL) ListAgents(ctx context.Context, appID string) ([]agentcore.Agent, error)

func (*SQL) ListArtifacts 

func (s *SQL) ListArtifacts(ctx context.Context, appID, runID string) ([]agentcore.AgentRunArtifact, error)

func (*SQL) ListEvents 

func (s *SQL) ListEvents(ctx context.Context, appID, runID string) ([]agentcore.AgentRunEvent, error)

func (*SQL) ListEventsAfter 

func (s *SQL) ListEventsAfter(ctx context.Context, appID, runID string, afterSequence int64, limit int) ([]agentcore.AgentRunEvent, error)

ListEventsAfter reads only the requested suffix of a run's event log so a replay does not need to materialize the full history in the runtime process.

func (*SQL) ListInteractions 

func (s *SQL) ListInteractions(ctx context.Context, appID, runID string) ([]agentcore.AgentRunInteraction, error)

func (*SQL) ListMessages 

func (s *SQL) ListMessages(ctx context.Context, appID, runID string) ([]agentcore.AgentRunMessage, error)

func (*SQL) ListRunMCPServers 

func (s *SQL) ListRunMCPServers(ctx context.Context, appID, runID string) ([]agentcore.RunMCPServer, error)

func (*SQL) ListRuns 

func (s *SQL) ListRuns(ctx context.Context, appID string) ([]agentcore.AgentRun, error)

func (*SQL) ListRunsByStatus 

func (s *SQL) ListRunsByStatus(ctx context.Context, statuses ...string) ([]agentcore.AgentRun, error)

func (*SQL) ListToolCalls 

func (s *SQL) ListToolCalls(ctx context.Context, appID, runID string) ([]agentcore.ToolCall, error)

func (*SQL) LoadNativeState 

func (s *SQL) LoadNativeState(ctx context.Context, appID, runID string) (*agentcore.NativeState, error)

LoadNativeState reads the latest private checkpoint for this app and run.

func (*SQL) MarkRunManuallyPaused added in v0.13.2 

func (s *SQL) MarkRunManuallyPaused(ctx context.Context, appID, runID string) (bool, error)

MarkRunManuallyPaused changes only an active run, preserving a concurrent cancellation.

func (*SQL) MigratePostgres 

func (s *SQL) MigratePostgres(ctx context.Context) error

func (*SQL) ReplaceRunModelCredential 

func (s *SQL) ReplaceRunModelCredential(ctx context.Context, c *agentcore.RunModelCredential, version int64) (bool, error)

func (*SQL) SaveNativeState 

func (s *SQL) SaveNativeState(ctx context.Context, state *agentcore.NativeState, records []json.RawMessage) error

SaveNativeState uses the supplied version as a compare-and-swap condition.

func (*SQL) SearchRuns 

func (s *SQL) SearchRuns(ctx context.Context, search agentcore.RunSearch) (*agentcore.RunPage, error)

func (*SQL) SupportsRunLock added in v0.13.0 

func (s *SQL) SupportsRunLock() bool

func (*SQL) UpdateAgent 

func (s *SQL) UpdateAgent(ctx context.Context, agent *agentcore.Agent) error

func (*SQL) UpdateInteraction 

func (s *SQL) UpdateInteraction(ctx context.Context, interaction *agentcore.AgentRunInteraction) error

func (*SQL) UpdateRun 

func (s *SQL) UpdateRun(ctx context.Context, run *agentcore.AgentRun) error

func (*SQL) UpdateRunMCPCredential 

func (s *SQL) UpdateRunMCPCredential(ctx context.Context, appID, runID, serverID string, encryptedCredential []byte) error

func (*SQL) UpdateRunOutputSummary 

func (s *SQL) UpdateRunOutputSummary(ctx context.Context, appID, runID string, summary json.RawMessage) error

UpdateRunOutputSummary cannot change a run's cancellation or completion state.

type SQLConfig 

type SQLConfig struct {
	Driver string
	DSN    string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.