Documentation
¶
Index ¶
- Variables
- func Connect() (*sql.DB, error)
- type AcknowledgeAgencyWakeSignalParams
- type AgencyAgent
- type AgencyConsensusVote
- type AgencyConstitution
- type AgencyContextSnapshot
- type AgencyLedgerEntry
- type AgencyOffice
- type AgencySchedule
- type AgencyWakeSignal
- type AppendAgencyLedgerEntryParams
- type CommitAgencyLedgerEntryParams
- type CreateAgencyAgentParams
- type CreateAgencyConsensusVoteParams
- type CreateAgencyConstitutionParams
- type CreateAgencyContextSnapshotParams
- type CreateAgencyOfficeParams
- type CreateAgencyScheduleParams
- type CreateAgencyWakeSignalParams
- type CreateFileParams
- type CreateMessageParams
- type CreateSessionParams
- type DBTX
- type File
- type GetFileByPathAndSessionParams
- type InsertRoutingLogParams
- type ListAgencyConsensusVotesByQuorumParams
- type ListPendingAgencyWakeSignalsByAgentParams
- type ListPendingAgencyWakeSignalsByOfficeParams
- type MarkAgencyWakeSignalDeliveredParams
- type Message
- type Querier
- type Queries
- func (q *Queries) AcknowledgeAgencyWakeSignal(ctx context.Context, arg AcknowledgeAgencyWakeSignalParams) (AgencyWakeSignal, error)
- func (q *Queries) ActivateAgencyConstitution(ctx context.Context, id string) (AgencyConstitution, error)
- func (q *Queries) AppendAgencyLedgerEntry(ctx context.Context, arg AppendAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
- func (q *Queries) Close() error
- func (q *Queries) CommitAgencyLedgerEntry(ctx context.Context, arg CommitAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
- func (q *Queries) CreateAgencyAgent(ctx context.Context, arg CreateAgencyAgentParams) (AgencyAgent, error)
- func (q *Queries) CreateAgencyConsensusVote(ctx context.Context, arg CreateAgencyConsensusVoteParams) (AgencyConsensusVote, error)
- func (q *Queries) CreateAgencyConstitution(ctx context.Context, arg CreateAgencyConstitutionParams) (AgencyConstitution, error)
- func (q *Queries) CreateAgencyContextSnapshot(ctx context.Context, arg CreateAgencyContextSnapshotParams) (AgencyContextSnapshot, error)
- func (q *Queries) CreateAgencyOffice(ctx context.Context, arg CreateAgencyOfficeParams) (AgencyOffice, error)
- func (q *Queries) CreateAgencySchedule(ctx context.Context, arg CreateAgencyScheduleParams) (AgencySchedule, error)
- func (q *Queries) CreateAgencyWakeSignal(ctx context.Context, arg CreateAgencyWakeSignalParams) (AgencyWakeSignal, error)
- func (q *Queries) CreateFile(ctx context.Context, arg CreateFileParams) (File, error)
- func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error)
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
- func (q *Queries) DeactivateAgencyConstitutionsByOffice(ctx context.Context, officeID string) error
- func (q *Queries) DeleteFile(ctx context.Context, id string) error
- func (q *Queries) DeleteMessage(ctx context.Context, id string) error
- func (q *Queries) DeleteSession(ctx context.Context, id string) error
- func (q *Queries) DeleteSessionFiles(ctx context.Context, sessionID string) error
- func (q *Queries) DeleteSessionMessages(ctx context.Context, sessionID string) error
- func (q *Queries) GetActiveAgencyConstitutionByOffice(ctx context.Context, officeID string) (AgencyConstitution, error)
- func (q *Queries) GetAgencyAgentByID(ctx context.Context, id string) (AgencyAgent, error)
- func (q *Queries) GetAgencyConsensusVoteByID(ctx context.Context, id string) (AgencyConsensusVote, error)
- func (q *Queries) GetAgencyConstitutionByID(ctx context.Context, id string) (AgencyConstitution, error)
- func (q *Queries) GetAgencyContextSnapshotByID(ctx context.Context, id string) (AgencyContextSnapshot, error)
- func (q *Queries) GetAgencyGistLattice(ctx context.Context, agentID string) (string, error)
- func (q *Queries) GetAgencyLedgerEntryByID(ctx context.Context, id string) (AgencyLedgerEntry, error)
- func (q *Queries) GetAgencyOfficeByID(ctx context.Context, id string) (AgencyOffice, error)
- func (q *Queries) GetAgencyOfficeBySlug(ctx context.Context, slug string) (AgencyOffice, error)
- func (q *Queries) GetAgencyScheduleByID(ctx context.Context, id string) (AgencySchedule, error)
- func (q *Queries) GetAgencyWakeSignalByID(ctx context.Context, id string) (AgencyWakeSignal, error)
- func (q *Queries) GetFile(ctx context.Context, id string) (File, error)
- func (q *Queries) GetFileByPathAndSession(ctx context.Context, arg GetFileByPathAndSessionParams) (File, error)
- func (q *Queries) GetLatestAgencyContextSnapshotByOffice(ctx context.Context, officeID string) (AgencyContextSnapshot, error)
- func (q *Queries) GetMessage(ctx context.Context, id string) (Message, error)
- func (q *Queries) GetSessionByID(ctx context.Context, id string) (Session, error)
- func (q *Queries) InsertAgencyRoutingLog(ctx context.Context, p InsertRoutingLogParams) error
- func (q *Queries) ListAgencyAgentsByOffice(ctx context.Context, officeID string) ([]AgencyAgent, error)
- func (q *Queries) ListAgencyChildAgents(ctx context.Context, parentAgentID string) ([]AgencyAgent, error)
- func (q *Queries) ListAgencyConsensusVotesByLedgerEntry(ctx context.Context, ledgerEntryID string) ([]AgencyConsensusVote, error)
- func (q *Queries) ListAgencyConsensusVotesByQuorum(ctx context.Context, arg ListAgencyConsensusVotesByQuorumParams) ([]AgencyConsensusVote, error)
- func (q *Queries) ListAgencyConstitutionsByOffice(ctx context.Context, officeID string) ([]AgencyConstitution, error)
- func (q *Queries) ListAgencyContextSnapshotsByOffice(ctx context.Context, officeID string) ([]AgencyContextSnapshot, error)
- func (q *Queries) ListAgencyLedgerEntriesByOffice(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)
- func (q *Queries) ListAgencyOffices(ctx context.Context) ([]AgencyOffice, error)
- func (q *Queries) ListAgencyOfficesByStatus(ctx context.Context, status string) ([]AgencyOffice, error)
- func (q *Queries) ListAgencySchedulesByOffice(ctx context.Context, officeID string) ([]AgencySchedule, error)
- func (q *Queries) ListDueAgencySchedules(ctx context.Context, nextFireAt int64) ([]AgencySchedule, error)
- func (q *Queries) ListFilesByPath(ctx context.Context, path string) ([]File, error)
- func (q *Queries) ListFilesBySession(ctx context.Context, sessionID string) ([]File, error)
- func (q *Queries) ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)
- func (q *Queries) ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error)
- func (q *Queries) ListNewFiles(ctx context.Context) ([]File, error)
- func (q *Queries) ListPendingAgencyLedgerEntries(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)
- func (q *Queries) ListPendingAgencyWakeSignalsByAgent(ctx context.Context, arg ListPendingAgencyWakeSignalsByAgentParams) ([]AgencyWakeSignal, error)
- func (q *Queries) ListPendingAgencyWakeSignalsByOffice(ctx context.Context, arg ListPendingAgencyWakeSignalsByOfficeParams) ([]AgencyWakeSignal, error)
- func (q *Queries) ListSessions(ctx context.Context) ([]Session, error)
- func (q *Queries) MarkAgencyWakeSignalDelivered(ctx context.Context, arg MarkAgencyWakeSignalDeliveredParams) (AgencyWakeSignal, error)
- func (q *Queries) RejectAgencyLedgerEntry(ctx context.Context, arg RejectAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
- func (q *Queries) UpdateAgencyAgentRuntime(ctx context.Context, arg UpdateAgencyAgentRuntimeParams) (AgencyAgent, error)
- func (q *Queries) UpdateAgencyOfficeStatus(ctx context.Context, arg UpdateAgencyOfficeStatusParams) (AgencyOffice, error)
- func (q *Queries) UpdateAgencyScheduleFireTimes(ctx context.Context, arg UpdateAgencyScheduleFireTimesParams) (AgencySchedule, error)
- func (q *Queries) UpdateFile(ctx context.Context, arg UpdateFileParams) (File, error)
- func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
- func (q *Queries) UpdateSession(ctx context.Context, arg UpdateSessionParams) (Session, error)
- func (q *Queries) UpsertAgencyGistLattice(ctx context.Context, agentID, latticeJSON string) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RejectAgencyLedgerEntryParams
- type Session
- type UpdateAgencyAgentRuntimeParams
- type UpdateAgencyOfficeStatusParams
- type UpdateAgencyScheduleFireTimesParams
- type UpdateFileParams
- type UpdateMessageParams
- type UpdateSessionParams
Constants ¶
This section is empty.
Variables ¶
View Source
var FS embed.FS
Functions ¶
Types ¶
type AgencyAgent ¶
type AgencyAgent struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
ConstitutionID sql.NullString `json:"constitution_id"`
ParentAgentID sql.NullString `json:"parent_agent_id"`
IdentityJson string `json:"identity_json"`
RoleName string `json:"role_name"`
RuntimeStatus string `json:"runtime_status"`
LifecyclePhase string `json:"lifecycle_phase"`
WorkspacePath string `json:"workspace_path"`
InboxChannel string `json:"inbox_channel"`
LastSnapshotID sql.NullString `json:"last_snapshot_id"`
LastWakeSignalID sql.NullString `json:"last_wake_signal_id"`
CapabilitiesJson string `json:"capabilities_json"`
Metadata string `json:"metadata"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
}
type AgencyConsensusVote ¶
type AgencyConsensusVote struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
LedgerEntryID string `json:"ledger_entry_id"`
AgentID string `json:"agent_id"`
QuorumKey string `json:"quorum_key"`
Decision string `json:"decision"`
Rationale string `json:"rationale"`
Weight int64 `json:"weight"`
Metadata string `json:"metadata"`
CreatedAt int64 `json:"created_at"`
}
type AgencyConstitution ¶
type AgencyConstitution struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
Name string `json:"name"`
Kind string `json:"kind"`
IsActive bool `json:"is_active"`
OrgIntent string `json:"org_intent"`
Governance string `json:"governance"`
RoleSpecs string `json:"role_specs"`
CapabilityPacks string `json:"capability_packs"`
SchedulePolicy string `json:"schedule_policy"`
Metadata string `json:"metadata"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
}
type AgencyContextSnapshot ¶
type AgencyLedgerEntry ¶
type AgencyLedgerEntry struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
EntryType string `json:"entry_type"`
ProposalKind string `json:"proposal_kind"`
SnapshotID sql.NullString `json:"snapshot_id"`
ParentEntryID sql.NullString `json:"parent_entry_id"`
Status string `json:"status"`
QuorumKey string `json:"quorum_key"`
QuorumState string `json:"quorum_state"`
ActionPayload string `json:"action_payload"`
ObservationPayload string `json:"observation_payload"`
CommitCertificate string `json:"commit_certificate"`
Metadata string `json:"metadata"`
CommittedAt sql.NullInt64 `json:"committed_at"`
CreatedAt int64 `json:"created_at"`
}
type AgencyOffice ¶
type AgencyOffice struct {
ID string `json:"id"`
Name string `json:"name"`
Slug string `json:"slug"`
Mode string `json:"mode"`
Status string `json:"status"`
BusDriver string `json:"bus_driver"`
ConsensusMode string `json:"consensus_mode"`
WorkspacePath string `json:"workspace_path"`
RedisAddr string `json:"redis_addr"`
LedgerDriver string `json:"ledger_driver"`
Metadata string `json:"metadata"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
}
type AgencySchedule ¶
type AgencySchedule struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Timezone string `json:"timezone"`
CronExpr string `json:"cron_expr"`
WakeEvent string `json:"wake_event"`
Enabled bool `json:"enabled"`
LastFiredAt sql.NullInt64 `json:"last_fired_at"`
NextFireAt sql.NullInt64 `json:"next_fire_at"`
Metadata string `json:"metadata"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
}
type AgencyWakeSignal ¶
type AgencyWakeSignal struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
ScheduleID sql.NullString `json:"schedule_id"`
SignalType string `json:"signal_type"`
Channel string `json:"channel"`
Payload string `json:"payload"`
Status string `json:"status"`
AvailableAt int64 `json:"available_at"`
DeliveredAt sql.NullInt64 `json:"delivered_at"`
AcknowledgedAt sql.NullInt64 `json:"acknowledged_at"`
CreatedAt int64 `json:"created_at"`
}
type AppendAgencyLedgerEntryParams ¶
type AppendAgencyLedgerEntryParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
EntryType string `json:"entry_type"`
ProposalKind string `json:"proposal_kind"`
SnapshotID sql.NullString `json:"snapshot_id"`
ParentEntryID sql.NullString `json:"parent_entry_id"`
Status string `json:"status"`
QuorumKey string `json:"quorum_key"`
QuorumState string `json:"quorum_state"`
ActionPayload string `json:"action_payload"`
ObservationPayload string `json:"observation_payload"`
CommitCertificate string `json:"commit_certificate"`
Metadata string `json:"metadata"`
CommittedAt sql.NullInt64 `json:"committed_at"`
}
type CreateAgencyAgentParams ¶
type CreateAgencyAgentParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
ConstitutionID sql.NullString `json:"constitution_id"`
ParentAgentID sql.NullString `json:"parent_agent_id"`
IdentityJson string `json:"identity_json"`
RoleName string `json:"role_name"`
RuntimeStatus string `json:"runtime_status"`
LifecyclePhase string `json:"lifecycle_phase"`
WorkspacePath string `json:"workspace_path"`
InboxChannel string `json:"inbox_channel"`
LastSnapshotID sql.NullString `json:"last_snapshot_id"`
LastWakeSignalID sql.NullString `json:"last_wake_signal_id"`
CapabilitiesJson string `json:"capabilities_json"`
Metadata string `json:"metadata"`
}
type CreateAgencyConsensusVoteParams ¶
type CreateAgencyConsensusVoteParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
LedgerEntryID string `json:"ledger_entry_id"`
AgentID string `json:"agent_id"`
QuorumKey string `json:"quorum_key"`
Decision string `json:"decision"`
Rationale string `json:"rationale"`
Weight int64 `json:"weight"`
Metadata string `json:"metadata"`
}
type CreateAgencyConstitutionParams ¶
type CreateAgencyConstitutionParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
Name string `json:"name"`
Kind string `json:"kind"`
IsActive bool `json:"is_active"`
OrgIntent string `json:"org_intent"`
Governance string `json:"governance"`
RoleSpecs string `json:"role_specs"`
CapabilityPacks string `json:"capability_packs"`
SchedulePolicy string `json:"schedule_policy"`
Metadata string `json:"metadata"`
}
type CreateAgencyOfficeParams ¶
type CreateAgencyOfficeParams struct {
ID string `json:"id"`
Name string `json:"name"`
Slug string `json:"slug"`
Mode string `json:"mode"`
Status string `json:"status"`
BusDriver string `json:"bus_driver"`
ConsensusMode string `json:"consensus_mode"`
WorkspacePath string `json:"workspace_path"`
RedisAddr string `json:"redis_addr"`
LedgerDriver string `json:"ledger_driver"`
Metadata string `json:"metadata"`
}
type CreateAgencyScheduleParams ¶
type CreateAgencyScheduleParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Timezone string `json:"timezone"`
CronExpr string `json:"cron_expr"`
WakeEvent string `json:"wake_event"`
Enabled bool `json:"enabled"`
LastFiredAt sql.NullInt64 `json:"last_fired_at"`
NextFireAt sql.NullInt64 `json:"next_fire_at"`
Metadata string `json:"metadata"`
}
type CreateAgencyWakeSignalParams ¶
type CreateAgencyWakeSignalParams struct {
ID string `json:"id"`
OfficeID string `json:"office_id"`
AgentID sql.NullString `json:"agent_id"`
ScheduleID sql.NullString `json:"schedule_id"`
SignalType string `json:"signal_type"`
Channel string `json:"channel"`
Payload string `json:"payload"`
Status string `json:"status"`
AvailableAt int64 `json:"available_at"`
DeliveredAt sql.NullInt64 `json:"delivered_at"`
AcknowledgedAt sql.NullInt64 `json:"acknowledged_at"`
}
type CreateFileParams ¶
type CreateMessageParams ¶
type CreateSessionParams ¶
type CreateSessionParams struct {
ID string `json:"id"`
ParentSessionID sql.NullString `json:"parent_session_id"`
Title string `json:"title"`
MessageCount int64 `json:"message_count"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
Cost float64 `json:"cost"`
}
type InsertRoutingLogParams ¶
type InsertRoutingLogParams struct {
ID string
AgentID string
OrgID string
Provider string
ModelID string
ExecutionIntent string
LatencyMs int64
TokensUsed int
GateReason string
}
InsertRoutingLogParams holds a single routing decision to persist.
type Querier ¶
type Querier interface {
AcknowledgeAgencyWakeSignal(ctx context.Context, arg AcknowledgeAgencyWakeSignalParams) (AgencyWakeSignal, error)
ActivateAgencyConstitution(ctx context.Context, id string) (AgencyConstitution, error)
AppendAgencyLedgerEntry(ctx context.Context, arg AppendAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
CommitAgencyLedgerEntry(ctx context.Context, arg CommitAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
CreateFile(ctx context.Context, arg CreateFileParams) (File, error)
CreateAgencyAgent(ctx context.Context, arg CreateAgencyAgentParams) (AgencyAgent, error)
CreateAgencyConsensusVote(ctx context.Context, arg CreateAgencyConsensusVoteParams) (AgencyConsensusVote, error)
CreateAgencyConstitution(ctx context.Context, arg CreateAgencyConstitutionParams) (AgencyConstitution, error)
CreateAgencyContextSnapshot(ctx context.Context, arg CreateAgencyContextSnapshotParams) (AgencyContextSnapshot, error)
CreateAgencyOffice(ctx context.Context, arg CreateAgencyOfficeParams) (AgencyOffice, error)
CreateAgencySchedule(ctx context.Context, arg CreateAgencyScheduleParams) (AgencySchedule, error)
CreateAgencyWakeSignal(ctx context.Context, arg CreateAgencyWakeSignalParams) (AgencyWakeSignal, error)
CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error)
CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
DeactivateAgencyConstitutionsByOffice(ctx context.Context, officeID string) error
DeleteFile(ctx context.Context, id string) error
DeleteMessage(ctx context.Context, id string) error
DeleteSession(ctx context.Context, id string) error
DeleteSessionFiles(ctx context.Context, sessionID string) error
DeleteSessionMessages(ctx context.Context, sessionID string) error
GetActiveAgencyConstitutionByOffice(ctx context.Context, officeID string) (AgencyConstitution, error)
GetAgencyAgentByID(ctx context.Context, id string) (AgencyAgent, error)
GetAgencyConstitutionByID(ctx context.Context, id string) (AgencyConstitution, error)
GetAgencyConsensusVoteByID(ctx context.Context, id string) (AgencyConsensusVote, error)
GetAgencyContextSnapshotByID(ctx context.Context, id string) (AgencyContextSnapshot, error)
GetAgencyLedgerEntryByID(ctx context.Context, id string) (AgencyLedgerEntry, error)
GetAgencyOfficeByID(ctx context.Context, id string) (AgencyOffice, error)
GetAgencyOfficeBySlug(ctx context.Context, slug string) (AgencyOffice, error)
GetAgencyScheduleByID(ctx context.Context, id string) (AgencySchedule, error)
GetAgencyWakeSignalByID(ctx context.Context, id string) (AgencyWakeSignal, error)
GetFile(ctx context.Context, id string) (File, error)
GetFileByPathAndSession(ctx context.Context, arg GetFileByPathAndSessionParams) (File, error)
GetMessage(ctx context.Context, id string) (Message, error)
GetSessionByID(ctx context.Context, id string) (Session, error)
GetLatestAgencyContextSnapshotByOffice(ctx context.Context, officeID string) (AgencyContextSnapshot, error)
ListAgencyAgentsByOffice(ctx context.Context, officeID string) ([]AgencyAgent, error)
ListAgencyChildAgents(ctx context.Context, parentAgentID string) ([]AgencyAgent, error)
ListAgencyConstitutionsByOffice(ctx context.Context, officeID string) ([]AgencyConstitution, error)
ListAgencyConsensusVotesByLedgerEntry(ctx context.Context, ledgerEntryID string) ([]AgencyConsensusVote, error)
ListAgencyConsensusVotesByQuorum(ctx context.Context, arg ListAgencyConsensusVotesByQuorumParams) ([]AgencyConsensusVote, error)
ListAgencyContextSnapshotsByOffice(ctx context.Context, officeID string) ([]AgencyContextSnapshot, error)
ListAgencyLedgerEntriesByOffice(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)
ListAgencyOffices(ctx context.Context) ([]AgencyOffice, error)
ListAgencyOfficesByStatus(ctx context.Context, status string) ([]AgencyOffice, error)
ListAgencySchedulesByOffice(ctx context.Context, officeID string) ([]AgencySchedule, error)
ListDueAgencySchedules(ctx context.Context, nextFireAt int64) ([]AgencySchedule, error)
ListFilesByPath(ctx context.Context, path string) ([]File, error)
ListFilesBySession(ctx context.Context, sessionID string) ([]File, error)
ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)
ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error)
ListNewFiles(ctx context.Context) ([]File, error)
ListPendingAgencyLedgerEntries(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)
ListPendingAgencyWakeSignalsByAgent(ctx context.Context, arg ListPendingAgencyWakeSignalsByAgentParams) ([]AgencyWakeSignal, error)
ListPendingAgencyWakeSignalsByOffice(ctx context.Context, arg ListPendingAgencyWakeSignalsByOfficeParams) ([]AgencyWakeSignal, error)
ListSessions(ctx context.Context) ([]Session, error)
MarkAgencyWakeSignalDelivered(ctx context.Context, arg MarkAgencyWakeSignalDeliveredParams) (AgencyWakeSignal, error)
RejectAgencyLedgerEntry(ctx context.Context, arg RejectAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
UpdateFile(ctx context.Context, arg UpdateFileParams) (File, error)
UpdateAgencyAgentRuntime(ctx context.Context, arg UpdateAgencyAgentRuntimeParams) (AgencyAgent, error)
UpdateAgencyOfficeStatus(ctx context.Context, arg UpdateAgencyOfficeStatusParams) (AgencyOffice, error)
UpdateAgencyScheduleFireTimes(ctx context.Context, arg UpdateAgencyScheduleFireTimesParams) (AgencySchedule, error)
UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
UpdateSession(ctx context.Context, arg UpdateSessionParams) (Session, error)
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcknowledgeAgencyWakeSignal ¶
func (q *Queries) AcknowledgeAgencyWakeSignal(ctx context.Context, arg AcknowledgeAgencyWakeSignalParams) (AgencyWakeSignal, error)
func (*Queries) ActivateAgencyConstitution ¶
func (*Queries) AppendAgencyLedgerEntry ¶
func (q *Queries) AppendAgencyLedgerEntry(ctx context.Context, arg AppendAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
func (*Queries) CommitAgencyLedgerEntry ¶
func (q *Queries) CommitAgencyLedgerEntry(ctx context.Context, arg CommitAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
func (*Queries) CreateAgencyAgent ¶
func (q *Queries) CreateAgencyAgent(ctx context.Context, arg CreateAgencyAgentParams) (AgencyAgent, error)
func (*Queries) CreateAgencyConsensusVote ¶
func (q *Queries) CreateAgencyConsensusVote(ctx context.Context, arg CreateAgencyConsensusVoteParams) (AgencyConsensusVote, error)
func (*Queries) CreateAgencyConstitution ¶
func (q *Queries) CreateAgencyConstitution(ctx context.Context, arg CreateAgencyConstitutionParams) (AgencyConstitution, error)
func (*Queries) CreateAgencyContextSnapshot ¶
func (q *Queries) CreateAgencyContextSnapshot(ctx context.Context, arg CreateAgencyContextSnapshotParams) (AgencyContextSnapshot, error)
func (*Queries) CreateAgencyOffice ¶
func (q *Queries) CreateAgencyOffice(ctx context.Context, arg CreateAgencyOfficeParams) (AgencyOffice, error)
func (*Queries) CreateAgencySchedule ¶
func (q *Queries) CreateAgencySchedule(ctx context.Context, arg CreateAgencyScheduleParams) (AgencySchedule, error)
func (*Queries) CreateAgencyWakeSignal ¶
func (q *Queries) CreateAgencyWakeSignal(ctx context.Context, arg CreateAgencyWakeSignalParams) (AgencyWakeSignal, error)
func (*Queries) CreateFile ¶
func (*Queries) CreateMessage ¶
func (*Queries) CreateSession ¶
func (*Queries) DeactivateAgencyConstitutionsByOffice ¶
func (*Queries) DeleteMessage ¶
func (*Queries) DeleteSession ¶
func (*Queries) DeleteSessionFiles ¶
func (*Queries) DeleteSessionMessages ¶
func (*Queries) GetActiveAgencyConstitutionByOffice ¶
func (*Queries) GetAgencyAgentByID ¶
func (*Queries) GetAgencyConsensusVoteByID ¶
func (*Queries) GetAgencyConstitutionByID ¶
func (*Queries) GetAgencyContextSnapshotByID ¶
func (*Queries) GetAgencyGistLattice ¶
GetAgencyGistLattice returns the persisted lattice JSON for the given agent. Returns empty string (not an error) when no row exists yet.
func (*Queries) GetAgencyLedgerEntryByID ¶
func (*Queries) GetAgencyOfficeByID ¶
func (*Queries) GetAgencyOfficeBySlug ¶
func (*Queries) GetAgencyScheduleByID ¶
func (*Queries) GetAgencyWakeSignalByID ¶
func (*Queries) GetFileByPathAndSession ¶
func (*Queries) GetLatestAgencyContextSnapshotByOffice ¶
func (*Queries) GetMessage ¶
func (*Queries) GetSessionByID ¶
func (*Queries) InsertAgencyRoutingLog ¶
func (q *Queries) InsertAgencyRoutingLog(ctx context.Context, p InsertRoutingLogParams) error
InsertAgencyRoutingLog appends a routing decision to the log table.
func (*Queries) ListAgencyAgentsByOffice ¶
func (*Queries) ListAgencyChildAgents ¶
func (*Queries) ListAgencyConsensusVotesByLedgerEntry ¶
func (*Queries) ListAgencyConsensusVotesByQuorum ¶
func (q *Queries) ListAgencyConsensusVotesByQuorum(ctx context.Context, arg ListAgencyConsensusVotesByQuorumParams) ([]AgencyConsensusVote, error)
func (*Queries) ListAgencyConstitutionsByOffice ¶
func (*Queries) ListAgencyContextSnapshotsByOffice ¶
func (*Queries) ListAgencyLedgerEntriesByOffice ¶
func (*Queries) ListAgencyOffices ¶
func (q *Queries) ListAgencyOffices(ctx context.Context) ([]AgencyOffice, error)
func (*Queries) ListAgencyOfficesByStatus ¶
func (*Queries) ListAgencySchedulesByOffice ¶
func (*Queries) ListDueAgencySchedules ¶
func (*Queries) ListFilesByPath ¶
func (*Queries) ListFilesBySession ¶
func (*Queries) ListLatestSessionFiles ¶
func (*Queries) ListMessagesBySession ¶
func (*Queries) ListPendingAgencyLedgerEntries ¶
func (*Queries) ListPendingAgencyWakeSignalsByAgent ¶
func (q *Queries) ListPendingAgencyWakeSignalsByAgent(ctx context.Context, arg ListPendingAgencyWakeSignalsByAgentParams) ([]AgencyWakeSignal, error)
func (*Queries) ListPendingAgencyWakeSignalsByOffice ¶
func (q *Queries) ListPendingAgencyWakeSignalsByOffice(ctx context.Context, arg ListPendingAgencyWakeSignalsByOfficeParams) ([]AgencyWakeSignal, error)
func (*Queries) ListSessions ¶
func (*Queries) MarkAgencyWakeSignalDelivered ¶
func (q *Queries) MarkAgencyWakeSignalDelivered(ctx context.Context, arg MarkAgencyWakeSignalDeliveredParams) (AgencyWakeSignal, error)
func (*Queries) RejectAgencyLedgerEntry ¶
func (q *Queries) RejectAgencyLedgerEntry(ctx context.Context, arg RejectAgencyLedgerEntryParams) (AgencyLedgerEntry, error)
func (*Queries) UpdateAgencyAgentRuntime ¶
func (q *Queries) UpdateAgencyAgentRuntime(ctx context.Context, arg UpdateAgencyAgentRuntimeParams) (AgencyAgent, error)
func (*Queries) UpdateAgencyOfficeStatus ¶
func (q *Queries) UpdateAgencyOfficeStatus(ctx context.Context, arg UpdateAgencyOfficeStatusParams) (AgencyOffice, error)
func (*Queries) UpdateAgencyScheduleFireTimes ¶
func (q *Queries) UpdateAgencyScheduleFireTimes(ctx context.Context, arg UpdateAgencyScheduleFireTimesParams) (AgencySchedule, error)
func (*Queries) UpdateFile ¶
func (*Queries) UpdateMessage ¶
func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
func (*Queries) UpdateSession ¶
func (*Queries) UpsertAgencyGistLattice ¶
UpsertAgencyGistLattice inserts or replaces the lattice JSON for the given agent.
type Session ¶
type Session struct {
ID string `json:"id"`
ParentSessionID sql.NullString `json:"parent_session_id"`
Title string `json:"title"`
MessageCount int64 `json:"message_count"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
Cost float64 `json:"cost"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
SummaryMessageID sql.NullString `json:"summary_message_id"`
}
type UpdateAgencyAgentRuntimeParams ¶
type UpdateAgencyAgentRuntimeParams struct {
RuntimeStatus string `json:"runtime_status"`
LifecyclePhase string `json:"lifecycle_phase"`
LastSnapshotID sql.NullString `json:"last_snapshot_id"`
LastWakeSignalID sql.NullString `json:"last_wake_signal_id"`
Metadata string `json:"metadata"`
ID string `json:"id"`
}
type UpdateFileParams ¶
type UpdateMessageParams ¶
type UpdateSessionParams ¶
Source Files
¶
- agency_agents.sql.go
- agency_consensus.sql.go
- agency_constitutions.sql.go
- agency_gist_state.go
- agency_ledger.sql.go
- agency_offices.sql.go
- agency_routing_log.go
- agency_schedules.sql.go
- agency_signals.sql.go
- agency_snapshots.sql.go
- connect.go
- db.go
- embed.go
- files.sql.go
- messages.sql.go
- models.go
- querier.go
- sessions.sql.go
Click to show internal directories.
Click to hide internal directories.