Documentation
¶
Index ¶
- type AcquireOutboxMessagesParams
- type AcquireTaskLeaseParams
- type AdvanceIdempotencyRecoveryPointParams
- type AgentAccountStatus
- type AgentAction
- type AgentArtifact
- type AgentConfig
- type AgentDefinition
- type AgentDefinitionTool
- type AgentMemory
- type AgentRun
- type AgentRunEvent
- type AgentTokenUsage
- type CountDeletedRecordsByResourceAndResourceIDParams
- type CreateIdempotencyKeyParams
- type CreateOutboxMessageParams
- type DBTX
- type DeleteAgentAccountStatusParams
- type DeleteAgentMemoryParams
- type DeletedRecord
- type GetAgentAccountStatusParams
- type GetAgentConfigByAccountAndDefinitionParams
- type GetAgentDefinitionByAccountAndSlugParams
- type GetAgentMemoriesByIDsParams
- type GetAgentTokenUsageByAccountAndDateParams
- type GetIdempotencyKeyByScopeHashParams
- type GetInboxRecordByMessageAndHandlerParams
- type GetMonthlyTokenUsageByAccountParams
- type GetMonthlyTokenUsageByAccountRow
- type InsertAgentActionParams
- type InsertAgentArtifactParams
- type InsertAgentConfigParams
- type InsertAgentDefinitionParams
- type InsertAgentDefinitionToolParams
- type InsertAgentMemoryParams
- type InsertAgentRunEventParams
- type InsertAgentRunParams
- type InsertAgentTokenUsageParams
- type InsertDeletedRecordParams
- type ListAccountMemoriesParams
- type ListAgentDefinitionsByAccountCursorParams
- type ListAgentDefinitionsByAccountFilteredParams
- type ListAgentMemoriesByAccountCursorParams
- type ListAgentMemoriesByAccountParams
- type ListAgentRunsByAccountFilteredParams
- type ListAgentRunsByAccountParams
- type ListAgentTokenUsageByAccountParams
- type ListEnabledConfigsWithScheduleRow
- type ListMemoriesByEntityParams
- type ListToolsByAgentDefinitionIDRow
- type MarkAgentActionReviewedParams
- type MarkInboxRecordFailedParams
- type MarkOutboxMessageFailedParams
- type MessageInbox
- type MessageOutbox
- type PurgeProcessedInboxMessagesParams
- type PurgePublishedOutboxMessagesParams
- type Queries
- func (q *Queries) AcquireOutboxMessages(ctx context.Context, arg AcquireOutboxMessagesParams) error
- func (q *Queries) AcquireTaskLease(ctx context.Context, arg AcquireTaskLeaseParams) (int64, error)
- func (q *Queries) AdvanceIdempotencyRecoveryPoint(ctx context.Context, arg AdvanceIdempotencyRecoveryPointParams) error
- func (q *Queries) CleanupExpiredOutboxLocks(ctx context.Context, limit int32) (int64, error)
- func (q *Queries) CountDeletedRecordsByResourceAndResourceID(ctx context.Context, arg CountDeletedRecordsByResourceAndResourceIDParams) (int64, error)
- func (q *Queries) CreateIdempotencyKey(ctx context.Context, arg CreateIdempotencyKeyParams) (int64, error)
- func (q *Queries) CreateOutboxMessage(ctx context.Context, arg CreateOutboxMessageParams) (int64, error)
- func (q *Queries) DeleteAgentAccountStatus(ctx context.Context, arg DeleteAgentAccountStatusParams) error
- func (q *Queries) DeleteAgentDefinitionToolsByAgentID(ctx context.Context, agentDefinitionID string) error
- func (q *Queries) DeleteAgentMemory(ctx context.Context, arg DeleteAgentMemoryParams) error
- func (q *Queries) GetAgentAccountStatus(ctx context.Context, arg GetAgentAccountStatusParams) (AgentAccountStatus, error)
- func (q *Queries) GetAgentActionByID(ctx context.Context, id string) (AgentAction, error)
- func (q *Queries) GetAgentArtifactByID(ctx context.Context, id string) (AgentArtifact, error)
- func (q *Queries) GetAgentConfigByAccountAndDefinition(ctx context.Context, arg GetAgentConfigByAccountAndDefinitionParams) (AgentConfig, error)
- func (q *Queries) GetAgentConfigByID(ctx context.Context, id string) (AgentConfig, error)
- func (q *Queries) GetAgentDefinitionByAccountAndSlug(ctx context.Context, arg GetAgentDefinitionByAccountAndSlugParams) (AgentDefinition, error)
- func (q *Queries) GetAgentDefinitionByID(ctx context.Context, id string) (AgentDefinition, error)
- func (q *Queries) GetAgentDefinitionBySlug(ctx context.Context, slug string) (AgentDefinition, error)
- func (q *Queries) GetAgentMemoriesByIDs(ctx context.Context, arg GetAgentMemoriesByIDsParams) ([]AgentMemory, error)
- func (q *Queries) GetAgentMemoryByID(ctx context.Context, id string) (AgentMemory, error)
- func (q *Queries) GetAgentRunByID(ctx context.Context, id string) (AgentRun, error)
- func (q *Queries) GetAgentTokenUsageByAccountAndDate(ctx context.Context, arg GetAgentTokenUsageByAccountAndDateParams) (AgentTokenUsage, error)
- func (q *Queries) GetIdempotencyKeyByScopeHash(ctx context.Context, arg GetIdempotencyKeyByScopeHashParams) (ServiceIdempotencyKey, error)
- func (q *Queries) GetIdempotencyRecoveryPoint(ctx context.Context, typeID string) (string, error)
- func (q *Queries) GetInboxRecordByMessageAndHandler(ctx context.Context, arg GetInboxRecordByMessageAndHandlerParams) (MessageInbox, error)
- func (q *Queries) GetLastRunByConfigID(ctx context.Context, agentConfigID pgtype.Text) (AgentRun, error)
- func (q *Queries) GetLockedOutboxMessages(ctx context.Context, lockOwner pgtype.Text) ([]MessageOutbox, error)
- func (q *Queries) GetMaxAgentRunEventSequence(ctx context.Context, agentRunID string) (int32, error)
- func (q *Queries) GetMonthlyTokenUsageByAccount(ctx context.Context, arg GetMonthlyTokenUsageByAccountParams) (GetMonthlyTokenUsageByAccountRow, error)
- func (q *Queries) InsertAgentAction(ctx context.Context, arg InsertAgentActionParams) error
- func (q *Queries) InsertAgentArtifact(ctx context.Context, arg InsertAgentArtifactParams) error
- func (q *Queries) InsertAgentConfig(ctx context.Context, arg InsertAgentConfigParams) error
- func (q *Queries) InsertAgentDefinition(ctx context.Context, arg InsertAgentDefinitionParams) error
- func (q *Queries) InsertAgentDefinitionTool(ctx context.Context, arg InsertAgentDefinitionToolParams) error
- func (q *Queries) InsertAgentMemory(ctx context.Context, arg InsertAgentMemoryParams) error
- func (q *Queries) InsertAgentRun(ctx context.Context, arg InsertAgentRunParams) error
- func (q *Queries) InsertAgentRunEvent(ctx context.Context, arg InsertAgentRunEventParams) error
- func (q *Queries) InsertAgentTokenUsage(ctx context.Context, arg InsertAgentTokenUsageParams) error
- func (q *Queries) InsertDeletedRecord(ctx context.Context, arg InsertDeletedRecordParams) error
- func (q *Queries) ListAccountMemories(ctx context.Context, arg ListAccountMemoriesParams) ([]AgentMemory, error)
- func (q *Queries) ListAgentAccountStatusesByAccount(ctx context.Context, accountID string) ([]AgentAccountStatus, error)
- func (q *Queries) ListAgentActionsByRun(ctx context.Context, agentRunID string) ([]AgentAction, error)
- func (q *Queries) ListAgentArtifactsByAction(ctx context.Context, agentActionID string) ([]AgentArtifact, error)
- func (q *Queries) ListAgentConfigsByAccount(ctx context.Context, accountID string) ([]AgentConfig, error)
- func (q *Queries) ListAgentDefinitions(ctx context.Context) ([]AgentDefinition, error)
- func (q *Queries) ListAgentDefinitionsByAccount(ctx context.Context, accountID pgtype.Text) ([]AgentDefinition, error)
- func (q *Queries) ListAgentDefinitionsByAccountCursor(ctx context.Context, arg ListAgentDefinitionsByAccountCursorParams) ([]AgentDefinition, error)
- func (q *Queries) ListAgentDefinitionsByAccountFiltered(ctx context.Context, arg ListAgentDefinitionsByAccountFilteredParams) ([]AgentDefinition, error)
- func (q *Queries) ListAgentMemoriesByAccount(ctx context.Context, arg ListAgentMemoriesByAccountParams) ([]AgentMemory, error)
- func (q *Queries) ListAgentMemoriesByAccountCursor(ctx context.Context, arg ListAgentMemoriesByAccountCursorParams) ([]AgentMemory, error)
- func (q *Queries) ListAgentRunEventsByRunID(ctx context.Context, agentRunID string) ([]AgentRunEvent, error)
- func (q *Queries) ListAgentRunsByAccount(ctx context.Context, arg ListAgentRunsByAccountParams) ([]AgentRun, error)
- func (q *Queries) ListAgentRunsByAccountFiltered(ctx context.Context, arg ListAgentRunsByAccountFilteredParams) ([]AgentRun, error)
- func (q *Queries) ListAgentTokenUsageByAccount(ctx context.Context, arg ListAgentTokenUsageByAccountParams) ([]AgentTokenUsage, error)
- func (q *Queries) ListEnabledConfigsWithSchedule(ctx context.Context) ([]ListEnabledConfigsWithScheduleRow, error)
- func (q *Queries) ListMemoriesByEntity(ctx context.Context, arg ListMemoriesByEntityParams) ([]AgentMemory, error)
- func (q *Queries) ListToolsByAgentDefinitionID(ctx context.Context, agentDefinitionID string) ([]ListToolsByAgentDefinitionIDRow, error)
- func (q *Queries) MarkAgentActionReviewed(ctx context.Context, arg MarkAgentActionReviewedParams) error
- func (q *Queries) MarkAgentRunAutoRetrying(ctx context.Context, id string) (int32, error)
- func (q *Queries) MarkAgentRunCancelledByUser(ctx context.Context, id string) error
- func (q *Queries) MarkAgentRunDivergedFromConversation(ctx context.Context, id string) error
- func (q *Queries) MarkAgentRunRetrying(ctx context.Context, id string) (int32, error)
- func (q *Queries) MarkInboxRecordFailed(ctx context.Context, arg MarkInboxRecordFailedParams) error
- func (q *Queries) MarkInboxRecordProcessed(ctx context.Context, id int64) error
- func (q *Queries) MarkOutboxMessageFailed(ctx context.Context, arg MarkOutboxMessageFailedParams) error
- func (q *Queries) MarkOutboxMessagesPublished(ctx context.Context, ids []int64) error
- func (q *Queries) PurgeProcessedInboxMessages(ctx context.Context, arg PurgeProcessedInboxMessagesParams) (int64, error)
- func (q *Queries) PurgePublishedOutboxMessages(ctx context.Context, arg PurgePublishedOutboxMessagesParams) (int64, error)
- func (q *Queries) ReapStalledRuns(ctx context.Context, arg ReapStalledRunsParams) ([]ReapStalledRunsRow, error)
- func (q *Queries) ReleaseTaskLease(ctx context.Context, arg ReleaseTaskLeaseParams) error
- func (q *Queries) RenewTaskLease(ctx context.Context, arg RenewTaskLeaseParams) (int64, error)
- func (q *Queries) SetIdempotencyResponse(ctx context.Context, arg SetIdempotencyResponseParams) error
- func (q *Queries) SoftDeleteAgentDefinition(ctx context.Context, arg SoftDeleteAgentDefinitionParams) error
- func (q *Queries) TryInsertInboxRecord(ctx context.Context, arg TryInsertInboxRecordParams) (int64, error)
- func (q *Queries) UpdateAgentActionStatus(ctx context.Context, arg UpdateAgentActionStatusParams) error
- func (q *Queries) UpdateAgentConfigEnabled(ctx context.Context, arg UpdateAgentConfigEnabledParams) error
- func (q *Queries) UpdateAgentDefinition(ctx context.Context, arg UpdateAgentDefinitionParams) error
- func (q *Queries) UpdateAgentMemory(ctx context.Context, arg UpdateAgentMemoryParams) error
- func (q *Queries) UpdateAgentRunCancelled(ctx context.Context, arg UpdateAgentRunCancelledParams) error
- func (q *Queries) UpdateAgentRunCompleted(ctx context.Context, arg UpdateAgentRunCompletedParams) error
- func (q *Queries) UpdateAgentRunFailed(ctx context.Context, arg UpdateAgentRunFailedParams) error
- func (q *Queries) UpdateAgentRunStarted(ctx context.Context, id string) (int64, error)
- func (q *Queries) UpdateAgentRunStatus(ctx context.Context, arg UpdateAgentRunStatusParams) error
- func (q *Queries) UpsertAgentAccountStatus(ctx context.Context, arg UpsertAgentAccountStatusParams) error
- func (q *Queries) UpsertAgentTokenUsage(ctx context.Context, arg UpsertAgentTokenUsageParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type ReapStalledRunsParams
- type ReapStalledRunsRow
- type ReleaseTaskLeaseParams
- type RenewTaskLeaseParams
- type ServiceIdempotencyKey
- type SetIdempotencyResponseParams
- type SoftDeleteAgentDefinitionParams
- type TaskLease
- type TryInsertInboxRecordParams
- type UpdateAgentActionStatusParams
- type UpdateAgentConfigEnabledParams
- type UpdateAgentDefinitionParams
- type UpdateAgentMemoryParams
- type UpdateAgentRunCancelledParams
- type UpdateAgentRunCompletedParams
- type UpdateAgentRunFailedParams
- type UpdateAgentRunStatusParams
- type UpsertAgentAccountStatusParams
- type UpsertAgentTokenUsageParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcquireTaskLeaseParams ¶
type AgentAccountStatus ¶
type AgentAccountStatus struct {
ID string
AccountID string
AgentDefinitionID string
StatusCode string
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type AgentAction ¶
type AgentAction struct {
ID string
AccountID string
AgentRunID string
ToolSlug string
StatusCode string
Label pgtype.Text
Description pgtype.Text
Input []byte
Output []byte
ErrorMessage pgtype.Text
EntityType pgtype.Text
EntityID pgtype.Text
RequiresReview bool
ReviewedAt pgtype.Timestamptz
ReviewedBy pgtype.Text
ReviewedByActorType pgtype.Text
ReviewedByActorName pgtype.Text
ExecutedAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type AgentArtifact ¶
type AgentConfig ¶
type AgentDefinition ¶
type AgentDefinitionTool ¶
type AgentDefinitionTool struct {
ID string
AgentDefinitionID string
Config []byte
SortOrder int32
RequireReview bool
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
ToolSlug string
}
type AgentMemory ¶
type AgentRun ¶
type AgentRun struct {
ID string
AccountID string
AgentDefinitionID string
AgentConfigID pgtype.Text
StatusCode string
TriggerType string
Input []byte
Output []byte
ErrorMessage pgtype.Text
StartedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
DurationMs pgtype.Int4
TotalInputTokens int64
TotalOutputTokens int64
TriggeredByActorID pgtype.Text
TriggeredByIdentityType pgtype.Text
TriggeredByActorName pgtype.Text
AllowedToolSlugs []byte
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
ConversationID pgtype.Text
TriggerMessageID pgtype.Text
DivergedFromConversation bool
RetryCount int32
}
type AgentRunEvent ¶
type AgentTokenUsage ¶
type DeleteAgentMemoryParams ¶
type DeletedRecord ¶
type InsertAgentActionParams ¶
type InsertAgentConfigParams ¶
type InsertAgentMemoryParams ¶
type InsertAgentRunParams ¶
type InsertAgentRunParams struct {
ID string
AccountID string
AgentDefinitionID string
AgentConfigID pgtype.Text
StatusCode string
TriggerType string
Input []byte
Output []byte
TriggeredByActorID pgtype.Text
TriggeredByIdentityType pgtype.Text
TriggeredByActorName pgtype.Text
ConversationID pgtype.Text
TriggerMessageID pgtype.Text
}
type ListToolsByAgentDefinitionIDRow ¶
type ListToolsByAgentDefinitionIDRow struct {
ID string
AgentDefinitionID string
ToolSlug string
Config []byte
SortOrder int32
RequireReview bool
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type MessageInbox ¶
type MessageOutbox ¶
type MessageOutbox struct {
ID int64
MessageID string
ServiceName string
MessageType string
Destination string
RoutingKey pgtype.Text
Headers db.NullableRawMessage
Payload []byte
Status string
Attempts int32
MaxAttempts int32
NextRunAt pgtype.Timestamptz
LockedAt pgtype.Timestamptz
LockOwner pgtype.Text
LockExpiresAt pgtype.Timestamptz
LastError pgtype.Text
PublishedAt pgtype.Timestamptz
RequestID pgtype.Text
ParentMessageID pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcquireOutboxMessages ¶
func (q *Queries) AcquireOutboxMessages(ctx context.Context, arg AcquireOutboxMessagesParams) error
func (*Queries) AcquireTaskLease ¶
func (*Queries) AdvanceIdempotencyRecoveryPoint ¶
func (q *Queries) AdvanceIdempotencyRecoveryPoint(ctx context.Context, arg AdvanceIdempotencyRecoveryPointParams) error
func (*Queries) CleanupExpiredOutboxLocks ¶
func (*Queries) CountDeletedRecordsByResourceAndResourceID ¶
func (*Queries) CreateIdempotencyKey ¶
func (*Queries) CreateOutboxMessage ¶
func (*Queries) DeleteAgentAccountStatus ¶
func (q *Queries) DeleteAgentAccountStatus(ctx context.Context, arg DeleteAgentAccountStatusParams) error
func (*Queries) DeleteAgentDefinitionToolsByAgentID ¶
func (*Queries) DeleteAgentMemory ¶
func (q *Queries) DeleteAgentMemory(ctx context.Context, arg DeleteAgentMemoryParams) error
func (*Queries) GetAgentAccountStatus ¶
func (q *Queries) GetAgentAccountStatus(ctx context.Context, arg GetAgentAccountStatusParams) (AgentAccountStatus, error)
Agent Account Status queries
func (*Queries) GetAgentActionByID ¶
func (*Queries) GetAgentArtifactByID ¶
func (*Queries) GetAgentConfigByAccountAndDefinition ¶
func (q *Queries) GetAgentConfigByAccountAndDefinition(ctx context.Context, arg GetAgentConfigByAccountAndDefinitionParams) (AgentConfig, error)
func (*Queries) GetAgentConfigByID ¶
func (*Queries) GetAgentDefinitionByAccountAndSlug ¶
func (q *Queries) GetAgentDefinitionByAccountAndSlug(ctx context.Context, arg GetAgentDefinitionByAccountAndSlugParams) (AgentDefinition, error)
func (*Queries) GetAgentDefinitionByID ¶
Agent Definition queries
func (*Queries) GetAgentDefinitionBySlug ¶
func (*Queries) GetAgentMemoriesByIDs ¶
func (q *Queries) GetAgentMemoriesByIDs(ctx context.Context, arg GetAgentMemoriesByIDsParams) ([]AgentMemory, error)
Returns agent memories matching the given IDs that belong to the caller's account. Used by the api-gateway resourcekit resolver.
func (*Queries) GetAgentMemoryByID ¶
func (*Queries) GetAgentRunByID ¶
func (*Queries) GetAgentTokenUsageByAccountAndDate ¶
func (q *Queries) GetAgentTokenUsageByAccountAndDate(ctx context.Context, arg GetAgentTokenUsageByAccountAndDateParams) (AgentTokenUsage, error)
func (*Queries) GetIdempotencyKeyByScopeHash ¶
func (q *Queries) GetIdempotencyKeyByScopeHash(ctx context.Context, arg GetIdempotencyKeyByScopeHashParams) (ServiceIdempotencyKey, error)
func (*Queries) GetIdempotencyRecoveryPoint ¶
func (*Queries) GetInboxRecordByMessageAndHandler ¶
func (q *Queries) GetInboxRecordByMessageAndHandler(ctx context.Context, arg GetInboxRecordByMessageAndHandlerParams) (MessageInbox, error)
func (*Queries) GetLastRunByConfigID ¶
func (*Queries) GetLockedOutboxMessages ¶
func (*Queries) GetMaxAgentRunEventSequence ¶
func (*Queries) GetMonthlyTokenUsageByAccount ¶
func (q *Queries) GetMonthlyTokenUsageByAccount(ctx context.Context, arg GetMonthlyTokenUsageByAccountParams) (GetMonthlyTokenUsageByAccountRow, error)
func (*Queries) InsertAgentAction ¶
func (q *Queries) InsertAgentAction(ctx context.Context, arg InsertAgentActionParams) error
Agent Action queries
func (*Queries) InsertAgentArtifact ¶
func (q *Queries) InsertAgentArtifact(ctx context.Context, arg InsertAgentArtifactParams) error
Agent Artifact queries
func (*Queries) InsertAgentConfig ¶
func (q *Queries) InsertAgentConfig(ctx context.Context, arg InsertAgentConfigParams) error
Agent Config queries
func (*Queries) InsertAgentDefinition ¶
func (q *Queries) InsertAgentDefinition(ctx context.Context, arg InsertAgentDefinitionParams) error
func (*Queries) InsertAgentDefinitionTool ¶
func (q *Queries) InsertAgentDefinitionTool(ctx context.Context, arg InsertAgentDefinitionToolParams) error
Agent Definition Tool queries Tool definitions (built-in tools) live in the code catalog (agents.BuiltinTools); agent_definition_tool references them by slug. Display metadata is resolved from the catalog, so these queries only touch agent_definition_tool.
func (*Queries) InsertAgentMemory ¶
func (q *Queries) InsertAgentMemory(ctx context.Context, arg InsertAgentMemoryParams) error
Agent Memory queries
func (*Queries) InsertAgentRun ¶
func (q *Queries) InsertAgentRun(ctx context.Context, arg InsertAgentRunParams) error
Agent Run queries
func (*Queries) InsertAgentRunEvent ¶
func (q *Queries) InsertAgentRunEvent(ctx context.Context, arg InsertAgentRunEventParams) error
Agent Run Event queries
func (*Queries) InsertAgentTokenUsage ¶
func (q *Queries) InsertAgentTokenUsage(ctx context.Context, arg InsertAgentTokenUsageParams) error
Agent Token Usage queries
func (*Queries) InsertDeletedRecord ¶
func (q *Queries) InsertDeletedRecord(ctx context.Context, arg InsertDeletedRecordParams) error
func (*Queries) ListAccountMemories ¶
func (q *Queries) ListAccountMemories(ctx context.Context, arg ListAccountMemoriesParams) ([]AgentMemory, error)
func (*Queries) ListAgentAccountStatusesByAccount ¶
func (*Queries) ListAgentActionsByRun ¶
func (*Queries) ListAgentArtifactsByAction ¶
func (*Queries) ListAgentConfigsByAccount ¶
func (*Queries) ListAgentDefinitions ¶
func (q *Queries) ListAgentDefinitions(ctx context.Context) ([]AgentDefinition, error)
func (*Queries) ListAgentDefinitionsByAccount ¶
func (*Queries) ListAgentDefinitionsByAccountCursor ¶
func (q *Queries) ListAgentDefinitionsByAccountCursor(ctx context.Context, arg ListAgentDefinitionsByAccountCursorParams) ([]AgentDefinition, error)
func (*Queries) ListAgentDefinitionsByAccountFiltered ¶
func (q *Queries) ListAgentDefinitionsByAccountFiltered(ctx context.Context, arg ListAgentDefinitionsByAccountFilteredParams) ([]AgentDefinition, error)
func (*Queries) ListAgentMemoriesByAccount ¶
func (q *Queries) ListAgentMemoriesByAccount(ctx context.Context, arg ListAgentMemoriesByAccountParams) ([]AgentMemory, error)
func (*Queries) ListAgentMemoriesByAccountCursor ¶
func (q *Queries) ListAgentMemoriesByAccountCursor(ctx context.Context, arg ListAgentMemoriesByAccountCursorParams) ([]AgentMemory, error)
func (*Queries) ListAgentRunEventsByRunID ¶
func (*Queries) ListAgentRunsByAccount ¶
func (*Queries) ListAgentRunsByAccountFiltered ¶
func (*Queries) ListAgentTokenUsageByAccount ¶
func (q *Queries) ListAgentTokenUsageByAccount(ctx context.Context, arg ListAgentTokenUsageByAccountParams) ([]AgentTokenUsage, error)
func (*Queries) ListEnabledConfigsWithSchedule ¶
func (q *Queries) ListEnabledConfigsWithSchedule(ctx context.Context) ([]ListEnabledConfigsWithScheduleRow, error)
Scheduler queries
func (*Queries) ListMemoriesByEntity ¶
func (q *Queries) ListMemoriesByEntity(ctx context.Context, arg ListMemoriesByEntityParams) ([]AgentMemory, error)
Memory queries
func (*Queries) ListToolsByAgentDefinitionID ¶
func (*Queries) MarkAgentActionReviewed ¶
func (q *Queries) MarkAgentActionReviewed(ctx context.Context, arg MarkAgentActionReviewedParams) error
func (*Queries) MarkAgentRunAutoRetrying ¶
Bump the retry counter for a run the runner is about to transparently re-enqueue after a transient, whole-chain-unavailable failure. Unlike MarkAgentRunRetrying (manual path, guarded on 'failed'), this fires mid-flight before the run is ever marked failed, so it guards on 'running' and leaves the status 'running' — the run is not surfaced as failed, it is simply re-queued. The guard makes this a no-op (no rows) if the run already left the running state, preventing a double re-enqueue.
func (*Queries) MarkAgentRunCancelledByUser ¶
func (*Queries) MarkAgentRunDivergedFromConversation ¶
func (*Queries) MarkAgentRunRetrying ¶
Atomically move a failed run back to running and bump its retry counter. The status guard makes this a no-op (returns no rows) when the run isn't failed, preventing double-retry races. Clears the prior error so a successful re-attempt doesn't leave a stale error_message behind.
func (*Queries) MarkInboxRecordFailed ¶
func (q *Queries) MarkInboxRecordFailed(ctx context.Context, arg MarkInboxRecordFailedParams) error
func (*Queries) MarkInboxRecordProcessed ¶
func (*Queries) MarkOutboxMessageFailed ¶
func (q *Queries) MarkOutboxMessageFailed(ctx context.Context, arg MarkOutboxMessageFailedParams) error
func (*Queries) MarkOutboxMessagesPublished ¶
func (*Queries) PurgeProcessedInboxMessages ¶
func (*Queries) PurgePublishedOutboxMessages ¶
func (*Queries) ReapStalledRuns ¶
func (q *Queries) ReapStalledRuns(ctx context.Context, arg ReapStalledRunsParams) ([]ReapStalledRunsRow, error)
Safety net for runs orphaned by a process kill (OOM/liveness/SIGTERM) mid-flight: the goroutine that would finalize them is gone, so they are stuck in 'running' forever. Fail any run that has been 'running' since before the cutoff so its status (and any chat bubble keyed to it) resolves instead of hanging. Guarded on status_code = 'running' so it never disturbs a run that has since paused/completed/cancelled. Returns the reaped ids for logging.
func (*Queries) ReleaseTaskLease ¶
func (q *Queries) ReleaseTaskLease(ctx context.Context, arg ReleaseTaskLeaseParams) error
func (*Queries) RenewTaskLease ¶
func (*Queries) SetIdempotencyResponse ¶
func (q *Queries) SetIdempotencyResponse(ctx context.Context, arg SetIdempotencyResponseParams) error
func (*Queries) SoftDeleteAgentDefinition ¶
func (q *Queries) SoftDeleteAgentDefinition(ctx context.Context, arg SoftDeleteAgentDefinitionParams) error
func (*Queries) TryInsertInboxRecord ¶
func (*Queries) UpdateAgentActionStatus ¶
func (q *Queries) UpdateAgentActionStatus(ctx context.Context, arg UpdateAgentActionStatusParams) error
func (*Queries) UpdateAgentConfigEnabled ¶
func (q *Queries) UpdateAgentConfigEnabled(ctx context.Context, arg UpdateAgentConfigEnabledParams) error
func (*Queries) UpdateAgentDefinition ¶
func (q *Queries) UpdateAgentDefinition(ctx context.Context, arg UpdateAgentDefinitionParams) error
func (*Queries) UpdateAgentMemory ¶
func (q *Queries) UpdateAgentMemory(ctx context.Context, arg UpdateAgentMemoryParams) error
func (*Queries) UpdateAgentRunCancelled ¶
func (q *Queries) UpdateAgentRunCancelled(ctx context.Context, arg UpdateAgentRunCancelledParams) error
func (*Queries) UpdateAgentRunCompleted ¶
func (q *Queries) UpdateAgentRunCompleted(ctx context.Context, arg UpdateAgentRunCompletedParams) error
func (*Queries) UpdateAgentRunFailed ¶
func (q *Queries) UpdateAgentRunFailed(ctx context.Context, arg UpdateAgentRunFailedParams) error
func (*Queries) UpdateAgentRunStarted ¶
Run lifecycle queries
func (*Queries) UpdateAgentRunStatus ¶
func (q *Queries) UpdateAgentRunStatus(ctx context.Context, arg UpdateAgentRunStatusParams) error
func (*Queries) UpsertAgentAccountStatus ¶
func (q *Queries) UpsertAgentAccountStatus(ctx context.Context, arg UpsertAgentAccountStatusParams) error
func (*Queries) UpsertAgentTokenUsage ¶
func (q *Queries) UpsertAgentTokenUsage(ctx context.Context, arg UpsertAgentTokenUsageParams) error
type ReapStalledRunsParams ¶
type ReapStalledRunsParams struct {
ErrorMessage pgtype.Text
StartedAt pgtype.Timestamptz
}
type ReapStalledRunsRow ¶
type ReleaseTaskLeaseParams ¶
type RenewTaskLeaseParams ¶
type ServiceIdempotencyKey ¶
type ServiceIdempotencyKey struct {
ID int64
TypeID string
ServiceName string
Handler string
IdempotencyKey string
ActorID pgtype.Text
IdentityType string
ScopeHash string
ResponseCode pgtype.Int4
ResponseBody []byte
RecoveryPoint string
LockedAt pgtype.Timestamptz
LockOwner pgtype.Text
LockExpiresAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
LastRunAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
}
type TaskLease ¶
type TaskLease struct {
Name string
Holder string
AcquiredAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
}