db

package
v0.0.0-...-237f1dd Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func Connect

func Connect() (*sql.DB, error)

Types

type AcknowledgeAgencyWakeSignalParams

type AcknowledgeAgencyWakeSignalParams struct {
	AcknowledgedAt sql.NullInt64 `json:"acknowledged_at"`
	DeliveredAt    sql.NullInt64 `json:"delivered_at"`
	ID             string        `json:"id"`
}

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 AgencyContextSnapshot struct {
	ID            string         `json:"id"`
	OfficeID      string         `json:"office_id"`
	SourceEntryID sql.NullString `json:"source_entry_id"`
	SnapshotKind  string         `json:"snapshot_kind"`
	Payload       string         `json:"payload"`
	CreatedAt     int64          `json:"created_at"`
}

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"`
	SharedVolumePath string `json:"shared_volume_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 CommitAgencyLedgerEntryParams

type CommitAgencyLedgerEntryParams struct {
	Status            string        `json:"status"`
	QuorumState       string        `json:"quorum_state"`
	CommitCertificate string        `json:"commit_certificate"`
	Metadata          string        `json:"metadata"`
	CommittedAt       sql.NullInt64 `json:"committed_at"`
	ID                string        `json:"id"`
}

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 CreateAgencyContextSnapshotParams

type CreateAgencyContextSnapshotParams struct {
	ID            string         `json:"id"`
	OfficeID      string         `json:"office_id"`
	SourceEntryID sql.NullString `json:"source_entry_id"`
	SnapshotKind  string         `json:"snapshot_kind"`
	Payload       string         `json:"payload"`
}

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"`
	SharedVolumePath string `json:"shared_volume_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 CreateFileParams struct {
	ID        string `json:"id"`
	SessionID string `json:"session_id"`
	Path      string `json:"path"`
	Content   string `json:"content"`
	Version   string `json:"version"`
}

type CreateMessageParams

type CreateMessageParams struct {
	ID        string         `json:"id"`
	SessionID string         `json:"session_id"`
	Role      string         `json:"role"`
	Parts     string         `json:"parts"`
	Model     sql.NullString `json:"model"`
}

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 DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type File

type File struct {
	ID        string `json:"id"`
	SessionID string `json:"session_id"`
	Path      string `json:"path"`
	Content   string `json:"content"`
	Version   string `json:"version"`
	CreatedAt int64  `json:"created_at"`
	UpdatedAt int64  `json:"updated_at"`
}

type GetFileByPathAndSessionParams

type GetFileByPathAndSessionParams struct {
	Path      string `json:"path"`
	SessionID string `json:"session_id"`
}

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 ListAgencyConsensusVotesByQuorumParams

type ListAgencyConsensusVotesByQuorumParams struct {
	OfficeID  string `json:"office_id"`
	QuorumKey string `json:"quorum_key"`
}

type ListPendingAgencyWakeSignalsByAgentParams

type ListPendingAgencyWakeSignalsByAgentParams struct {
	AgentID     string `json:"agent_id"`
	AvailableAt int64  `json:"available_at"`
}

type ListPendingAgencyWakeSignalsByOfficeParams

type ListPendingAgencyWakeSignalsByOfficeParams struct {
	OfficeID    string `json:"office_id"`
	AvailableAt int64  `json:"available_at"`
}

type MarkAgencyWakeSignalDeliveredParams

type MarkAgencyWakeSignalDeliveredParams struct {
	DeliveredAt sql.NullInt64 `json:"delivered_at"`
	ID          string        `json:"id"`
}

type Message

type Message struct {
	ID         string         `json:"id"`
	SessionID  string         `json:"session_id"`
	Role       string         `json:"role"`
	Parts      string         `json:"parts"`
	Model      sql.NullString `json:"model"`
	CreatedAt  int64          `json:"created_at"`
	UpdatedAt  int64          `json:"updated_at"`
	FinishedAt sql.NullInt64  `json:"finished_at"`
}

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 New

func New(db DBTX) *Queries

func Prepare

func Prepare(ctx context.Context, db DBTX) (*Queries, error)

func (*Queries) AcknowledgeAgencyWakeSignal

func (q *Queries) AcknowledgeAgencyWakeSignal(ctx context.Context, arg AcknowledgeAgencyWakeSignalParams) (AgencyWakeSignal, error)

func (*Queries) ActivateAgencyConstitution

func (q *Queries) ActivateAgencyConstitution(ctx context.Context, id string) (AgencyConstitution, error)

func (*Queries) AppendAgencyLedgerEntry

func (q *Queries) AppendAgencyLedgerEntry(ctx context.Context, arg AppendAgencyLedgerEntryParams) (AgencyLedgerEntry, error)

func (*Queries) Close

func (q *Queries) Close() 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 (q *Queries) CreateFile(ctx context.Context, arg CreateFileParams) (File, error)

func (*Queries) CreateMessage

func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error)

func (*Queries) CreateSession

func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)

func (*Queries) DeactivateAgencyConstitutionsByOffice

func (q *Queries) DeactivateAgencyConstitutionsByOffice(ctx context.Context, officeID string) error

func (*Queries) DeleteFile

func (q *Queries) DeleteFile(ctx context.Context, id string) error

func (*Queries) DeleteMessage

func (q *Queries) DeleteMessage(ctx context.Context, id string) error

func (*Queries) DeleteSession

func (q *Queries) DeleteSession(ctx context.Context, id string) error

func (*Queries) DeleteSessionFiles

func (q *Queries) DeleteSessionFiles(ctx context.Context, sessionID string) error

func (*Queries) DeleteSessionMessages

func (q *Queries) DeleteSessionMessages(ctx context.Context, sessionID string) error

func (*Queries) GetActiveAgencyConstitutionByOffice

func (q *Queries) GetActiveAgencyConstitutionByOffice(ctx context.Context, officeID string) (AgencyConstitution, error)

func (*Queries) GetAgencyAgentByID

func (q *Queries) GetAgencyAgentByID(ctx context.Context, id string) (AgencyAgent, error)

func (*Queries) GetAgencyConsensusVoteByID

func (q *Queries) GetAgencyConsensusVoteByID(ctx context.Context, id string) (AgencyConsensusVote, error)

func (*Queries) GetAgencyConstitutionByID

func (q *Queries) GetAgencyConstitutionByID(ctx context.Context, id string) (AgencyConstitution, error)

func (*Queries) GetAgencyContextSnapshotByID

func (q *Queries) GetAgencyContextSnapshotByID(ctx context.Context, id string) (AgencyContextSnapshot, error)

func (*Queries) GetAgencyGistLattice

func (q *Queries) GetAgencyGistLattice(ctx context.Context, agentID string) (string, error)

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 (q *Queries) GetAgencyLedgerEntryByID(ctx context.Context, id string) (AgencyLedgerEntry, error)

func (*Queries) GetAgencyOfficeByID

func (q *Queries) GetAgencyOfficeByID(ctx context.Context, id string) (AgencyOffice, error)

func (*Queries) GetAgencyOfficeBySlug

func (q *Queries) GetAgencyOfficeBySlug(ctx context.Context, slug string) (AgencyOffice, error)

func (*Queries) GetAgencyScheduleByID

func (q *Queries) GetAgencyScheduleByID(ctx context.Context, id string) (AgencySchedule, error)

func (*Queries) GetAgencyWakeSignalByID

func (q *Queries) GetAgencyWakeSignalByID(ctx context.Context, id string) (AgencyWakeSignal, error)

func (*Queries) GetFile

func (q *Queries) GetFile(ctx context.Context, id string) (File, error)

func (*Queries) GetFileByPathAndSession

func (q *Queries) GetFileByPathAndSession(ctx context.Context, arg GetFileByPathAndSessionParams) (File, error)

func (*Queries) GetLatestAgencyContextSnapshotByOffice

func (q *Queries) GetLatestAgencyContextSnapshotByOffice(ctx context.Context, officeID string) (AgencyContextSnapshot, error)

func (*Queries) GetMessage

func (q *Queries) GetMessage(ctx context.Context, id string) (Message, error)

func (*Queries) GetSessionByID

func (q *Queries) GetSessionByID(ctx context.Context, id string) (Session, error)

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 (q *Queries) ListAgencyAgentsByOffice(ctx context.Context, officeID string) ([]AgencyAgent, error)

func (*Queries) ListAgencyChildAgents

func (q *Queries) ListAgencyChildAgents(ctx context.Context, parentAgentID string) ([]AgencyAgent, error)

func (*Queries) ListAgencyConsensusVotesByLedgerEntry

func (q *Queries) ListAgencyConsensusVotesByLedgerEntry(ctx context.Context, ledgerEntryID string) ([]AgencyConsensusVote, error)

func (*Queries) ListAgencyConsensusVotesByQuorum

func (q *Queries) ListAgencyConsensusVotesByQuorum(ctx context.Context, arg ListAgencyConsensusVotesByQuorumParams) ([]AgencyConsensusVote, error)

func (*Queries) ListAgencyConstitutionsByOffice

func (q *Queries) ListAgencyConstitutionsByOffice(ctx context.Context, officeID string) ([]AgencyConstitution, error)

func (*Queries) ListAgencyContextSnapshotsByOffice

func (q *Queries) ListAgencyContextSnapshotsByOffice(ctx context.Context, officeID string) ([]AgencyContextSnapshot, error)

func (*Queries) ListAgencyLedgerEntriesByOffice

func (q *Queries) ListAgencyLedgerEntriesByOffice(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)

func (*Queries) ListAgencyOffices

func (q *Queries) ListAgencyOffices(ctx context.Context) ([]AgencyOffice, error)

func (*Queries) ListAgencyOfficesByStatus

func (q *Queries) ListAgencyOfficesByStatus(ctx context.Context, status string) ([]AgencyOffice, error)

func (*Queries) ListAgencySchedulesByOffice

func (q *Queries) ListAgencySchedulesByOffice(ctx context.Context, officeID string) ([]AgencySchedule, error)

func (*Queries) ListDueAgencySchedules

func (q *Queries) ListDueAgencySchedules(ctx context.Context, nextFireAt int64) ([]AgencySchedule, error)

func (*Queries) ListFilesByPath

func (q *Queries) ListFilesByPath(ctx context.Context, path string) ([]File, error)

func (*Queries) ListFilesBySession

func (q *Queries) ListFilesBySession(ctx context.Context, sessionID string) ([]File, error)

func (*Queries) ListLatestSessionFiles

func (q *Queries) ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)

func (*Queries) ListMessagesBySession

func (q *Queries) ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error)

func (*Queries) ListNewFiles

func (q *Queries) ListNewFiles(ctx context.Context) ([]File, error)

func (*Queries) ListPendingAgencyLedgerEntries

func (q *Queries) ListPendingAgencyLedgerEntries(ctx context.Context, officeID string) ([]AgencyLedgerEntry, error)

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 (q *Queries) ListSessions(ctx context.Context) ([]Session, error)

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 (q *Queries) UpdateFile(ctx context.Context, arg UpdateFileParams) (File, error)

func (*Queries) UpdateMessage

func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error

func (*Queries) UpdateSession

func (q *Queries) UpdateSession(ctx context.Context, arg UpdateSessionParams) (Session, error)

func (*Queries) UpsertAgencyGistLattice

func (q *Queries) UpsertAgencyGistLattice(ctx context.Context, agentID, latticeJSON string) error

UpsertAgencyGistLattice inserts or replaces the lattice JSON for the given agent.

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type RejectAgencyLedgerEntryParams

type RejectAgencyLedgerEntryParams struct {
	QuorumState string `json:"quorum_state"`
	Metadata    string `json:"metadata"`
	ID          string `json:"id"`
}

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 UpdateAgencyOfficeStatusParams

type UpdateAgencyOfficeStatusParams struct {
	Status   string `json:"status"`
	Metadata string `json:"metadata"`
	ID       string `json:"id"`
}

type UpdateAgencyScheduleFireTimesParams

type UpdateAgencyScheduleFireTimesParams struct {
	LastFiredAt sql.NullInt64 `json:"last_fired_at"`
	NextFireAt  sql.NullInt64 `json:"next_fire_at"`
	Metadata    string        `json:"metadata"`
	ID          string        `json:"id"`
}

type UpdateFileParams

type UpdateFileParams struct {
	Content string `json:"content"`
	Version string `json:"version"`
	ID      string `json:"id"`
}

type UpdateMessageParams

type UpdateMessageParams struct {
	Parts      string        `json:"parts"`
	FinishedAt sql.NullInt64 `json:"finished_at"`
	ID         string        `json:"id"`
}

type UpdateSessionParams

type UpdateSessionParams struct {
	Title            string         `json:"title"`
	PromptTokens     int64          `json:"prompt_tokens"`
	CompletionTokens int64          `json:"completion_tokens"`
	SummaryMessageID sql.NullString `json:"summary_message_id"`
	Cost             float64        `json:"cost"`
	ID               string         `json:"id"`
}

Jump to

Keyboard shortcuts

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