store

package

Go to main page

Versions in this module

v1

v1.0.5

Aug 22, 2026

v1.0.4

Aug 22, 2026

Changes in this version

+ var ErrAgentChannelState = errors.New("Agent Channel resource is not open")

+ var ErrScheduleCatalogLimit = errors.New("schedule_catalog_limit")

+ type AgentChannelMigrationReport struct

+ Channels []conversation.AgentChannel

+ Conversations []conversation.AgentChannelConversation

+ Pins []conversation.AgentConversationPin

+ Skipped []AgentChannelMigrationSkip

+ type AgentChannelMigrationSkip struct

+ ConversationID string

+ Reason string

type ConversationDetail

+ PrimaryChannel *conversation.PrimaryChannel

type ConversationTurnTarget

+ Authority *conversation.TargetAuthority

+ type CreateAgentChannelConversationTurnParams struct

+ Authority *conversation.TargetAuthority

+ Body string

+ ChannelID string

+ ClientTurnID string

+ Conversation conversation.Conversation

+ CreatedAt time.Time

+ HumanID string

+ ParticipantID string

+ RunID string

+ TargetID string

+ TurnID string

type CreateConversationTurnParams

+ AgentChannelID string

+ PrimarySingleFlight bool

+ type ScheduleChannelLink struct

+ ID string

+ Name string

+ type ScheduleReadDetail struct

+ Recent []scheduler.Occurrence

+ Row ScheduleReadRow

+ Upcoming []scheduler.Occurrence

+ type ScheduleReadRow struct

+ Definition scheduler.Definition

+ LatestOccurrence *scheduler.Occurrence

+ RelatedChannel *ScheduleChannelLink

type Store

+ func (s *Store) AcceptAgentRebind(ctx context.Context, command ledger.AcceptAgentRebindCommand) (ledger.AgentBindingAdvanceResult, error)

+ func (s *Store) AcceptHandoff(ctx context.Context, command ledger.AcceptHandoffCommand) (ledger.HandoffRecord, error)

+ func (s *Store) AdvanceRoutineRun(ctx context.Context, command ledger.AdvanceRoutineRunCommand) (ledger.RoutineRunRecord, error)

+ func (s *Store) AgentConversationOwned(channelID, conversationID string) (bool, error)

+ func (s *Store) AgentCreatedConversationChannel(conversationID string) (conversation.AgentChannel, bool, error)

+ func (s *Store) AnswerConversationTargetWithReceipt(id string, message conversation.Message, receipt conversation.TargetReceipt) (bool, error)

+ func (s *Store) AppendAgentBehavior(ctx context.Context, command ledger.AppendAgentBehaviorCommand) (ledger.AgentBindingAdvanceResult, error)

+ func (s *Store) AppendAgentProfile(ctx context.Context, command ledger.AppendAgentProfileCommand) (ledger.AgentRecord, error)

+ func (s *Store) CancelAgentTarget(ctx context.Context, command ledger.CancelAgentTargetCommand) (ledger.AgentConversationTarget, error)

+ func (s *Store) CancelHandoff(ctx context.Context, command ledger.CancelHandoffCommand) (ledger.HandoffRecord, error)

+ func (s *Store) ClearPrimaryAgentSetting() error

+ func (s *Store) CompleteHandoff(ctx context.Context, command ledger.CompleteHandoffCommand) (ledger.HandoffRecord, error)

+ func (s *Store) CreateAgent(ctx context.Context, command ledger.CreateAgentCommand) (ledger.AgentRecord, error)

+ func (s *Store) CreateAgentChannel(channel conversation.AgentChannel) error

+ func (s *Store) CreateAgentChannelConversation(channelID string, item conversation.Conversation, participantID string) error

+ func (s *Store) CreateAgentChannelConversationTurn(params CreateAgentChannelConversationTurnParams) (conversation.Turn, []conversation.Target, string, error)

+ func (s *Store) CreateGroup(ctx context.Context, command ledger.CreateGroupCommand) (ledger.GroupRecord, error)

+ func (s *Store) CreateHumanHandoff(ctx context.Context, command ledger.CreateHumanHandoffCommand) (ledger.HandoffRecord, error)

+ func (s *Store) CreatePrimaryChannel(item conversation.Conversation, participantID string) error

+ func (s *Store) CreateRoutine(ctx context.Context, command ledger.CreateRoutineCommand) (ledger.RoutineRecord, error)

+ func (s *Store) CreateScheduleChannelLink(link conversation.ScheduleChannelLink) error

+ func (s *Store) CreateSecondaryConversation(ctx context.Context, command ledger.CreateSecondaryConversationCommand) (ledger.AgentConversationRecord, error)

+ func (s *Store) EnqueueRoutineOccurrence(ctx context.Context, command ledger.EnqueueRoutineOccurrenceCommand) (ledger.RoutineRunRecord, error)

+ func (s *Store) FindConversationTurnByClientID(conversationID, clientTurnID string) (conversation.Turn, []conversation.Target, bool, error)

+ func (s *Store) GetAgent(ctx context.Context, accountID, agentID string) (ledger.AgentRecord, error)

+ func (s *Store) GetAgentChannel(id string) (conversation.AgentChannelDetail, error)

+ func (s *Store) GetGroup(ctx context.Context, accountID, groupID string) (ledger.GroupRecord, error)

+ func (s *Store) GetHandoff(ctx context.Context, accountID, handoffID string) (ledger.HandoffRecord, error)

+ func (s *Store) GetPrimaryAgentSetting() (conversation.PrimaryAgentSetting, error)

+ func (s *Store) GetRoutine(ctx context.Context, accountID, routineID string) (ledger.RoutineRecord, error)

+ func (s *Store) GetRoutineRun(ctx context.Context, accountID, runID string) (ledger.RoutineRunRecord, error)

+ func (s *Store) GetScheduleChannelLink(scheduleID string) (conversation.ScheduleChannelLink, error)

+ func (s *Store) ImportSourceRoutine(ctx context.Context, command ledger.ImportRoutineCommand) (ledger.RoutineRecord, error)

+ func (s *Store) LatestExecutionSourceConfigObservation(ctx context.Context, accountID, executionSourceID string) (ledger.ExecutionSourceConfigObservation, error)

+ func (s *Store) ListAgentChannels(state string) ([]conversation.AgentChannelDetail, error)

+ func (s *Store) ListAgentConversations(ctx context.Context, accountID, agentID string) ([]ledger.AgentConversationRecord, error)

+ func (s *Store) ListAgents(ctx context.Context, accountID string, state conversation.AgentState) ([]ledger.AgentRecord, error)

+ func (s *Store) ListGroupTurns(ctx context.Context, accountID, groupID string) ([]ledger.GroupTurnRecord, error)

+ func (s *Store) ListGroups(ctx context.Context, accountID string, state conversation.ConversationState) ([]ledger.GroupRecord, error)

+ func (s *Store) ListHandoffs(ctx context.Context, accountID string) ([]ledger.HandoffRecord, error)

+ func (s *Store) ListPrimaryChannels(state string) ([]conversation.PrimaryChannelSummary, error)

+ func (s *Store) ListRoutineRuns(ctx context.Context, accountID, routineID string) ([]ledger.RoutineRunRecord, error)

+ func (s *Store) ListRoutines(ctx context.Context, accountID, agentID string) ([]ledger.RoutineRecord, error)

+ func (s *Store) ListSourceRoutineProjections(ctx context.Context, accountID, executionSourceID string) ([]ledger.SourceRoutineProjection, error)

+ func (s *Store) MigratePrimaryAgentChannels() (AgentChannelMigrationReport, error)

+ func (s *Store) ObserveExecutionSourceConfig(ctx context.Context, command ledger.ObserveExecutionSourceConfigCommand) (ledger.ExecutionSourceConfigObservation, error)

+ func (s *Store) PreviewAgentRebind(ctx context.Context, command ledger.PreviewAgentRebindCommand) (ledger.AgentRebindPreview, error)

+ func (s *Store) PreviewPrimaryAgentChannelMigration() (AgentChannelMigrationReport, error)

+ func (s *Store) ReadAgentConversation(ctx context.Context, accountID, agentID, conversationID string) (ledger.AgentConversationProjection, error)

+ func (s *Store) ReadScheduleCatalog(ctx context.Context, enabled *bool, limit int) ([]ScheduleReadRow, error)

+ func (s *Store) ReadScheduleDetail(ctx context.Context, id string, observedAt time.Time, occurrenceLimit int) (ScheduleReadDetail, error)

+ func (s *Store) ReadScheduleOccurrences(ctx context.Context, id string, limit int, before time.Time, beforeID string) ([]scheduler.Occurrence, error)

+ func (s *Store) RecordSourceRoutineProjection(ctx context.Context, projection ledger.SourceRoutineProjection) (ledger.SourceRoutineProjection, error)

+ func (s *Store) RenameAgentChannel(id, name string) error

+ func (s *Store) RenameAgentConversation(ctx context.Context, command ledger.RenameAgentConversationCommand) (ledger.AgentConversationRecord, error)

+ func (s *Store) RenameGroup(ctx context.Context, command ledger.RenameGroupCommand) (ledger.GroupRecord, error)

+ func (s *Store) ReplaceGroupMembers(ctx context.Context, command ledger.ReplaceGroupMembersCommand) (ledger.GroupRecord, error)

+ func (s *Store) RetryAgentConversationTargetWithAdapterRevision(agentChannelID, originalID, newID, newRunID, selectedAdapterRevision string, ...) (ConversationTargetDispatch, error)

+ func (s *Store) RetryAgentTarget(ctx context.Context, command ledger.RetryAgentTargetCommand) (ledger.AgentConversationTarget, error)

+ func (s *Store) RetryConversationTargetWithAdapterRevision(originalID, newID, newRunID, selectedAdapterRevision string, ...) (ConversationTargetDispatch, error)

+ func (s *Store) RevalidateRoutine(ctx context.Context, command ledger.RevalidateRoutineCommand) (ledger.RoutineRecord, error)

+ func (s *Store) SendAgentTurn(ctx context.Context, command ledger.SendAgentTurnCommand) (ledger.AgentTurnDispatch, error)

+ func (s *Store) SendGroupTurn(ctx context.Context, command ledger.SendGroupTurnCommand) (ledger.GroupTurnRecord, error)

+ func (s *Store) SetAgentChannelState(id string, state conversation.AgentChannelState) error

+ func (s *Store) SetAgentConversationPin(ctx context.Context, command ledger.SetAgentConversationPinCommand) (ledger.AgentConversationRecord, error)

+ func (s *Store) SetAgentConversationPinned(channelID, conversationID string, pinned bool, pinnedAt time.Time) error

+ func (s *Store) SetAgentConversationState(ctx context.Context, command ledger.SetAgentConversationStateCommand) (ledger.AgentConversationRecord, error)

+ func (s *Store) SetGroupState(ctx context.Context, command ledger.SetGroupStateCommand) (ledger.GroupRecord, error)

+ func (s *Store) SetPrimaryChannelPinned(id string, pinned bool, pinnedAt time.Time) error

+ func (s *Store) StartHandoff(ctx context.Context, command ledger.StartHandoffCommand) (ledger.HandoffRecord, error)

+ func (s *Store) TransitionConversationTargetWithReceipt(id string, from, to conversation.TargetState, errorCode, errorMessage string, ...) (bool, error)

+ func (s *Store) TransitionRunStatus(id, flowID, from, to string, exitCode int, errMsg string) (bool, error)

+ func (s *Store) UpsertPrimaryAgentSetting(setting conversation.PrimaryAgentSetting) error

v0

v0.13.0

Aug 1, 2026

Changes in this version

+ type ConversationDetail struct

+ Conversation conversation.Conversation

+ Messages []conversation.Message

+ Participants []conversation.Participant

+ Targets []conversation.Target

+ Turns []conversation.Turn

+ type ConversationTargetDispatch struct

+ Conversation conversation.Conversation

+ Participant conversation.Participant

+ Target conversation.Target

+ Turn conversation.Turn

+ type ConversationTurnTarget struct

+ ID string

+ ParticipantID string

+ RunID string

+ type CreateConversationTurnParams struct

+ Body string

+ ClientTurnID string

+ ConversationID string

+ CreatedAt time.Time

+ HumanID string

+ Targets []ConversationTurnTarget

+ TurnID string

type Run

+ Model string

+ Profile string

type Store

+ func (s *Store) AddConversationParticipant(participant conversation.Participant) error

+ func (s *Store) AnswerConversationTarget(id string, message conversation.Message) (bool, error)

+ func (s *Store) AppendConversationMessage(message conversation.Message) (conversation.Message, error)

+ func (s *Store) ConversationContext(conversationID string, throughMessageID int64) (string, error)

+ func (s *Store) CreateConversation(item conversation.Conversation, participants []conversation.Participant) error

+ func (s *Store) CreateConversationTurn(params CreateConversationTurnParams) (conversation.Turn, []conversation.Target, string, error)

+ func (s *Store) CreateProject(project conversation.Project) error

+ func (s *Store) CreateSchedule(definition scheduler.Definition) error

+ func (s *Store) DecideWaitingGate(id, status, output string) (bool, error)

+ func (s *Store) DeleteConversation(id string) error

+ func (s *Store) DeleteProject(id string) error

+ func (s *Store) FailInterruptedConversationTargets(reason string) (int, error)

+ func (s *Store) FailInterruptedDirectRuns(reason string) (int, error)

+ func (s *Store) GetConversation(id string) (ConversationDetail, error)

+ func (s *Store) GetConversationTargetDispatch(id string) (ConversationTargetDispatch, error)

+ func (s *Store) ListConversationTargetDispatches(states ...conversation.TargetState) ([]ConversationTargetDispatch, error)

+ func (s *Store) ListConversations(scope string) ([]conversation.Conversation, error)

+ func (s *Store) ListProjects() ([]conversation.Project, error)

+ func (s *Store) ListSchedules() ([]scheduler.Definition, error)

+ func (s *Store) MoveConversation(id, projectID string) error

+ func (s *Store) RemoveConversationParticipant(conversationID, participantID string, removedAt time.Time) error

+ func (s *Store) RenameConversation(id, title string) error

+ func (s *Store) RenameProject(id, name string) error

+ func (s *Store) RetryConversationTarget(originalID, newID, newRunID string, createdAt time.Time) (ConversationTargetDispatch, error)

+ func (s *Store) ScheduleOccurrencesBetween(start, end time.Time) ([]scheduler.Occurrence, error)

+ func (s *Store) SetConversationState(id string, state conversation.ConversationState) error

+ func (s *Store) TouchConversationTargetActivity(id string, observedAt time.Time) error

+ func (s *Store) TransitionConversationTarget(id string, from, to conversation.TargetState, errorMessage string) (bool, error)

+ func (s *Store) TransitionConversationTargetWithCode(id string, from, to conversation.TargetState, errorCode, errorMessage string) (bool, error)

+ func (s *Store) TransitionScheduleOccurrence(id string, from, to scheduler.OccurrenceState, runID, errorMessage string) (bool, error)

+ func (s *Store) UpdateScheduleFire(id string, lastFireAt, nextFireAt time.Time) error

+ func (s *Store) UpsertScheduleOccurrence(occurrence scheduler.Occurrence) error

v0.12.0

Jul 22, 2026

Changes in this version

+ var ErrPlaybookRevisionStale = errors.New("store: stale playbook revision")

+ type PlaybookRevision struct

+ CreatedAt time.Time

+ Data string

+ ID string

+ Revision int

type Store

+ func (s *Store) LatestPlaybookRevisions() ([]PlaybookRevision, error)

+ func (s *Store) PlaybookRevision(id string, revision int) (PlaybookRevision, error)

+ func (s *Store) SavePlaybookRevision(id, data string) (PlaybookRevision, error)

+ func (s *Store) SavePlaybookRevisionIfLatest(id string, expected int, data string) (PlaybookRevision, error)

+ func (s *Store) SeedPlaybookRevisions(revisions []PlaybookRevision) error

v0.11.0

Jul 19, 2026

Changes in this version

type Store

+ func (s *Store) AllNodeRuns() ([]NodeRun, error)

+ func (s *Store) UpdateBacklogAgent(id, agent string) error

v0.10.4

Jul 10, 2026

v0.10.3

Jul 9, 2026

v0.10.2

Jul 9, 2026

v0.10.1

Jul 9, 2026

v0.10.0

Jul 9, 2026

Changes in this version

type Run

+ Body string

v0.9.0

Jul 7, 2026

Changes in this version

type Event

+ NodeID string

v0.8.0

Jul 7, 2026

v0.7.0

Jul 6, 2026

Changes in this version

+ type BacklogItem struct

+ Agent string

+ Body string

+ CreatedAt time.Time

+ ID string

+ Labels []string

+ Machine string

+ Source string

+ Title string

type Store

+ func (s *Store) CreateBacklogItem(b BacklogItem) error

+ func (s *Store) DeleteBacklogItem(id string) error

+ func (s *Store) GetBacklogItem(id string) (BacklogItem, error)

+ func (s *Store) ListBacklog() ([]BacklogItem, error)

v0.6.1

Jul 6, 2026

v0.6.0

Jul 5, 2026

Changes in this version

+ var ErrInviteExpired = errors.New("store: invite expired")

+ var ErrInviteInvalid = errors.New("store: invite invalid or already used")

type Store

+ func (s *Store) CheckInvite(codeHash string, now time.Time) error

+ func (s *Store) CreateInvite(codeHash string, expires time.Time) error

+ func (s *Store) MarkInviteUsed(codeHash string, now time.Time) error

v0.5.1

Jul 1, 2026

v0.5.0

Jul 1, 2026

Changes in this version

+ type Event struct

+ Code int

+ CreatedAt time.Time

+ Data string

+ ID int64

+ RunID string

+ Type string

+ type NodeRun struct

+ Attempts int

+ CreatedAt time.Time

+ ID string

+ Input string

+ NodeID string

+ Output string

+ RunID string

+ Status string

+ Type string

+ UpdatedAt time.Time

+ type RouteDecision struct

+ CreatedAt time.Time

+ ID string

+ IsDefault bool

+ MatchedRule string

+ Reason string

+ Route string

+ TaskID string

+ type Run struct

+ Agent string

+ CreatedAt time.Time

+ Error string

+ ExitCode int

+ FlowID string

+ ID string

+ Machine string

+ MatchedRule string

+ Status string

+ Title string

+ UpdatedAt time.Time

+ type Store struct

+ func Open(path string) (*Store, error)

+ func (s *Store) AppendEvent(e Event) (int64, error)

+ func (s *Store) Close() error

+ func (s *Store) CreateRun(r Run) error

+ func (s *Store) Events(runID string) ([]Event, error)

+ func (s *Store) EventsSince(cursor int64) ([]Event, error)

+ func (s *Store) GetRun(id string) (Run, error)

+ func (s *Store) ListRuns() ([]Run, error)

+ func (s *Store) NodeRuns(runID string) ([]NodeRun, error)

+ func (s *Store) RouteDecisions(taskID string) ([]RouteDecision, error)

+ func (s *Store) SaveRouteDecision(d RouteDecision) error

+ func (s *Store) UpdateRunStatus(id, status string, exitCode int, errMsg string) error

+ func (s *Store) UpsertNodeRun(n NodeRun) error

+ func (s *Store) WaitingGates() ([]NodeRun, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL