sqlcgen

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2026 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentToken 

type AgentToken struct {
	ID               string  `json:"id"`
	Name             string  `json:"name"`
	Kind             string  `json:"kind"`
	TokenHash        string  `json:"token_hash"`
	TokenPrefix      string  `json:"token_prefix"`
	RefreshTokenHash *string `json:"refresh_token_hash"`
	OauthClientID    *string `json:"oauth_client_id"`
	Scope            string  `json:"scope"`
	ExpiresAt        *int64  `json:"expires_at"`
	LastUsedAt       *int64  `json:"last_used_at"`
	CreatedAt        int64   `json:"created_at"`
	RevokedAt        *int64  `json:"revoked_at"`
}

type ApiKey 

type ApiKey struct {
	ID              string  `json:"id"`
	Name            string  `json:"name"`
	KeyHash         string  `json:"key_hash"`
	KeyPrefix       string  `json:"key_prefix"`
	RateLimitRpm    int64   `json:"rate_limit_rpm"`
	AllowedModels   string  `json:"allowed_models"`
	PinnedChannelID *string `json:"pinned_channel_id"`
	TimeoutSeconds  int64   `json:"timeout_seconds"`
	Priority        int64   `json:"priority"`
	RequestCount    int64   `json:"request_count"`
	LastUsedAt      *int64  `json:"last_used_at"`
	CreatedAt       int64   `json:"created_at"`
	RevokedAt       *int64  `json:"revoked_at"`
}

type BumpConversationParams 

type BumpConversationParams struct {
	TurnCount     int64   `json:"turn_count"`
	LastRequestID *string `json:"last_request_id"`
	Model         string  `json:"model"`
	UpdatedAt     int64   `json:"updated_at"`
	ID            string  `json:"id"`
}

type CancelAllActiveRequestsParams 

type CancelAllActiveRequestsParams struct {
	ErrorMessage *string `json:"error_message"`
	CompletedAt  *int64  `json:"completed_at"`
}

type CancelRequestParams 

type CancelRequestParams struct {
	ErrorMessage *string `json:"error_message"`
	CompletedAt  *int64  `json:"completed_at"`
	ID           string  `json:"id"`
}

type Channel 

type Channel struct {
	ID             string  `json:"id"`
	Name           string  `json:"name"`
	Description    string  `json:"description"`
	AgentTokenID   *string `json:"agent_token_id"`
	Status         string  `json:"status"`
	Models         string  `json:"models"`
	Concurrency    int64   `json:"concurrency"`
	ServedCount    int64   `json:"served_count"`
	FailedCount    int64   `json:"failed_count"`
	TotalLatencyMs int64   `json:"total_latency_ms"`
	LastSeenAt     int64   `json:"last_seen_at"`
	CreatedAt      int64   `json:"created_at"`
	ClosedAt       *int64  `json:"closed_at"`
}

type ChannelUsageSinceRow 

type ChannelUsageSinceRow struct {
	ChannelID *string `json:"channel_id"`
	Total     int64   `json:"total"`
	Completed int64   `json:"completed"`
	Failed    int64   `json:"failed"`
}

type ClaimRequestParams 

type ClaimRequestParams struct {
	ChannelID      *string `json:"channel_id"`
	ClaimedAt      *int64  `json:"claimed_at"`
	LeaseExpiresAt *int64  `json:"lease_expires_at"`
	ID             string  `json:"id"`
}

type CloseChannelParams 

type CloseChannelParams struct {
	ClosedAt *int64 `json:"closed_at"`
	ID       string `json:"id"`
}

type CompleteRequestParams 

type CompleteRequestParams struct {
	ResponseBody     *string `json:"response_body"`
	ResponseText     *string `json:"response_text"`
	NextHash         *string `json:"next_hash"`
	PromptTokens     int64   `json:"prompt_tokens"`
	CompletionTokens int64   `json:"completion_tokens"`
	UsageEstimated   bool    `json:"usage_estimated"`
	FinishReason     *string `json:"finish_reason"`
	CompletedAt      *int64  `json:"completed_at"`
	FirstTokenAt     *int64  `json:"first_token_at"`
	ID               string  `json:"id"`
	ChannelID        *string `json:"channel_id"`
}

type ConsumeLoginTokenParams 

type ConsumeLoginTokenParams struct {
	UsedAt    *int64 `json:"used_at"`
	TokenHash string `json:"token_hash"`
	ExpiresAt int64  `json:"expires_at"`
}

type ConsumeOAuthCodeParams 

type ConsumeOAuthCodeParams struct {
	UsedAt    *int64 `json:"used_at"`
	CodeHash  string `json:"code_hash"`
	ExpiresAt int64  `json:"expires_at"`
}

type Conversation 

type Conversation struct {
	ID            string  `json:"id"`
	ApiKeyID      string  `json:"api_key_id"`
	RootHash      string  `json:"root_hash"`
	Title         string  `json:"title"`
	Model         string  `json:"model"`
	TurnCount     int64   `json:"turn_count"`
	LastRequestID *string `json:"last_request_id"`
	CreatedAt     int64   `json:"created_at"`
	UpdatedAt     int64   `json:"updated_at"`
}

type CountConversationsParams 

type CountConversationsParams struct {
	ApiKeyID string `json:"api_key_id"`
	Search   string `json:"search"`
}

type CountEventsParams 

type CountEventsParams struct {
	Kind      string  `json:"kind"`
	Level     string  `json:"level"`
	RequestID *string `json:"request_id"`
	ChannelID *string `json:"channel_id"`
	ApiKeyID  *string `json:"api_key_id"`
	Search    string  `json:"search"`
}

type CountRequestsParams 

type CountRequestsParams struct {
	Status         string  `json:"status"`
	ApiKeyID       string  `json:"api_key_id"`
	ChannelID      *string `json:"channel_id"`
	ConversationID *string `json:"conversation_id"`
	Model          string  `json:"model"`
	Search         string  `json:"search"`
}

type CreateAPIKeyParams 

type CreateAPIKeyParams struct {
	ID              string  `json:"id"`
	Name            string  `json:"name"`
	KeyHash         string  `json:"key_hash"`
	KeyPrefix       string  `json:"key_prefix"`
	RateLimitRpm    int64   `json:"rate_limit_rpm"`
	AllowedModels   string  `json:"allowed_models"`
	PinnedChannelID *string `json:"pinned_channel_id"`
	TimeoutSeconds  int64   `json:"timeout_seconds"`
	Priority        int64   `json:"priority"`
	CreatedAt       int64   `json:"created_at"`
}

type CreateAgentTokenParams 

type CreateAgentTokenParams struct {
	ID               string  `json:"id"`
	Name             string  `json:"name"`
	Kind             string  `json:"kind"`
	TokenHash        string  `json:"token_hash"`
	TokenPrefix      string  `json:"token_prefix"`
	RefreshTokenHash *string `json:"refresh_token_hash"`
	OauthClientID    *string `json:"oauth_client_id"`
	Scope            string  `json:"scope"`
	ExpiresAt        *int64  `json:"expires_at"`
	CreatedAt        int64   `json:"created_at"`
}

type CreateChannelParams 

type CreateChannelParams struct {
	ID           string  `json:"id"`
	Name         string  `json:"name"`
	Description  string  `json:"description"`
	AgentTokenID *string `json:"agent_token_id"`
	Status       string  `json:"status"`
	Models       string  `json:"models"`
	Concurrency  int64   `json:"concurrency"`
	LastSeenAt   int64   `json:"last_seen_at"`
	CreatedAt    int64   `json:"created_at"`
}

type CreateConversationParams 

type CreateConversationParams struct {
	ID            string  `json:"id"`
	ApiKeyID      string  `json:"api_key_id"`
	RootHash      string  `json:"root_hash"`
	Title         string  `json:"title"`
	Model         string  `json:"model"`
	TurnCount     int64   `json:"turn_count"`
	LastRequestID *string `json:"last_request_id"`
	CreatedAt     int64   `json:"created_at"`
	UpdatedAt     int64   `json:"updated_at"`
}

type CreateLoginTokenParams 

type CreateLoginTokenParams struct {
	TokenHash string `json:"token_hash"`
	ExpiresAt int64  `json:"expires_at"`
}

type CreateOAuthClientParams 

type CreateOAuthClientParams struct {
	ID                      string  `json:"id"`
	SecretHash              *string `json:"secret_hash"`
	Name                    string  `json:"name"`
	RedirectUris            string  `json:"redirect_uris"`
	GrantTypes              string  `json:"grant_types"`
	TokenEndpointAuthMethod string  `json:"token_endpoint_auth_method"`
	Metadata                string  `json:"metadata"`
	CreatedAt               int64   `json:"created_at"`
}

type CreateOAuthCodeParams 

type CreateOAuthCodeParams struct {
	CodeHash            string `json:"code_hash"`
	ClientID            string `json:"client_id"`
	RedirectUri         string `json:"redirect_uri"`
	CodeChallenge       string `json:"code_challenge"`
	CodeChallengeMethod string `json:"code_challenge_method"`
	Scope               string `json:"scope"`
	Resource            string `json:"resource"`
	ExpiresAt           int64  `json:"expires_at"`
	CreatedAt           int64  `json:"created_at"`
}

type CreateRequestParams 

type CreateRequestParams struct {
	ID             string  `json:"id"`
	ApiKeyID       string  `json:"api_key_id"`
	RouteChannelID *string `json:"route_channel_id"`
	ConversationID *string `json:"conversation_id"`
	TurnIndex      int64   `json:"turn_index"`
	Model          string  `json:"model"`
	Endpoint       string  `json:"endpoint"`
	Stream         bool    `json:"stream"`
	Priority       int64   `json:"priority"`
	RequestBody    string  `json:"request_body"`
	HistoryHash    string  `json:"history_hash"`
	FullHash       string  `json:"full_hash"`
	MessageCount   int64   `json:"message_count"`
	PromptChars    int64   `json:"prompt_chars"`
	PromptTokens   int64   `json:"prompt_tokens"`
	MaxAttempts    int64   `json:"max_attempts"`
	ClientIp       string  `json:"client_ip"`
	UserAgent      string  `json:"user_agent"`
	CreatedAt      int64   `json:"created_at"`
	TimeoutAt      int64   `json:"timeout_at"`
}

type CreateSessionParams 

type CreateSessionParams struct {
	ID        string `json:"id"`
	CreatedAt int64  `json:"created_at"`
	ExpiresAt int64  `json:"expires_at"`
	UserAgent string `json:"user_agent"`
}

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 DeleteExpiredOAuthTokensParams 

type DeleteExpiredOAuthTokensParams struct {
	ExpiresAt *int64 `json:"expires_at"`
	CreatedAt int64  `json:"created_at"`
}

type Event 

type Event struct {
	ID             int64   `json:"id"`
	Ts             int64   `json:"ts"`
	Kind           string  `json:"kind"`
	Level          string  `json:"level"`
	RequestID      *string `json:"request_id"`
	ChannelID      *string `json:"channel_id"`
	ApiKeyID       *string `json:"api_key_id"`
	ConversationID *string `json:"conversation_id"`
	Message        string  `json:"message"`
	Data           string  `json:"data"`
}

type ExpireRequestParams 

type ExpireRequestParams struct {
	ErrorMessage *string `json:"error_message"`
	CompletedAt  *int64  `json:"completed_at"`
	ID           string  `json:"id"`
}

type ExtendRequestLeaseParams 

type ExtendRequestLeaseParams struct {
	LeaseExpiresAt *int64  `json:"lease_expires_at"`
	ID             string  `json:"id"`
	ChannelID      *string `json:"channel_id"`
}

type FailRequestParams 

type FailRequestParams struct {
	ErrorMessage *string `json:"error_message"`
	CompletedAt  *int64  `json:"completed_at"`
	ID           string  `json:"id"`
}

type FindConversationByRootParams 

type FindConversationByRootParams struct {
	ApiKeyID  string `json:"api_key_id"`
	RootHash  string `json:"root_hash"`
	UpdatedAt int64  `json:"updated_at"`
}

type FindRequestByNextHashParams 

type FindRequestByNextHashParams struct {
	ApiKeyID string  `json:"api_key_id"`
	NextHash *string `json:"next_hash"`
}

type GetSessionParams 

type GetSessionParams struct {
	ID        string `json:"id"`
	ExpiresAt int64  `json:"expires_at"`
}

type IncrChannelServedParams 

type IncrChannelServedParams struct {
	TotalLatencyMs int64  `json:"total_latency_ms"`
	ID             string `json:"id"`
}

type InsertEventParams 

type InsertEventParams struct {
	Ts             int64   `json:"ts"`
	Kind           string  `json:"kind"`
	Level          string  `json:"level"`
	RequestID      *string `json:"request_id"`
	ChannelID      *string `json:"channel_id"`
	ApiKeyID       *string `json:"api_key_id"`
	ConversationID *string `json:"conversation_id"`
	Message        string  `json:"message"`
	Data           string  `json:"data"`
}

type KeyUsageSinceRow 

type KeyUsageSinceRow struct {
	ApiKeyID         string `json:"api_key_id"`
	Total            int64  `json:"total"`
	Completed        int64  `json:"completed"`
	PromptTokens     int64  `json:"prompt_tokens"`
	CompletionTokens int64  `json:"completion_tokens"`
}

type LatencySamplesSinceRow 

type LatencySamplesSinceRow struct {
	LatencyMs int64 `json:"latency_ms"`
	TtftMs    int64 `json:"ttft_ms"`
	QueueMs   int64 `json:"queue_ms"`
}

type ListClaimableRequestsParams 

type ListClaimableRequestsParams struct {
	Now       int64   `json:"now"`
	ChannelID *string `json:"channel_id"`
}

type ListConversationsParams 

type ListConversationsParams struct {
	ApiKeyID string `json:"api_key_id"`
	Search   string `json:"search"`
	Off      int64  `json:"off"`
	Lim      int64  `json:"lim"`
}

type ListEventsParams 

type ListEventsParams struct {
	Kind      string  `json:"kind"`
	Level     string  `json:"level"`
	RequestID *string `json:"request_id"`
	ChannelID *string `json:"channel_id"`
	ApiKeyID  *string `json:"api_key_id"`
	Search    string  `json:"search"`
	Off       int64   `json:"off"`
	Lim       int64   `json:"lim"`
}

type ListRequestsParams 

type ListRequestsParams struct {
	Status         string  `json:"status"`
	ApiKeyID       string  `json:"api_key_id"`
	ChannelID      *string `json:"channel_id"`
	ConversationID *string `json:"conversation_id"`
	Model          string  `json:"model"`
	Search         string  `json:"search"`
	Off            int64   `json:"off"`
	Lim            int64   `json:"lim"`
}

type LoginToken 

type LoginToken struct {
	TokenHash string `json:"token_hash"`
	ExpiresAt int64  `json:"expires_at"`
	UsedAt    *int64 `json:"used_at"`
}

type MarkRequestStreamingParams 

type MarkRequestStreamingParams struct {
	FirstTokenAt   *int64  `json:"first_token_at"`
	LeaseExpiresAt *int64  `json:"lease_expires_at"`
	ID             string  `json:"id"`
	ChannelID      *string `json:"channel_id"`
}

type ModelUsageSinceRow 

type ModelUsageSinceRow struct {
	Model            string `json:"model"`
	Total            int64  `json:"total"`
	PromptTokens     int64  `json:"prompt_tokens"`
	CompletionTokens int64  `json:"completion_tokens"`
}

type OauthClient 

type OauthClient struct {
	ID                      string  `json:"id"`
	SecretHash              *string `json:"secret_hash"`
	Name                    string  `json:"name"`
	RedirectUris            string  `json:"redirect_uris"`
	GrantTypes              string  `json:"grant_types"`
	TokenEndpointAuthMethod string  `json:"token_endpoint_auth_method"`
	Metadata                string  `json:"metadata"`
	CreatedAt               int64   `json:"created_at"`
}

type OauthCode 

type OauthCode struct {
	CodeHash            string `json:"code_hash"`
	ClientID            string `json:"client_id"`
	RedirectUri         string `json:"redirect_uri"`
	CodeChallenge       string `json:"code_challenge"`
	CodeChallengeMethod string `json:"code_challenge_method"`
	Scope               string `json:"scope"`
	Resource            string `json:"resource"`
	ExpiresAt           int64  `json:"expires_at"`
	UsedAt              *int64 `json:"used_at"`
	CreatedAt           int64  `json:"created_at"`
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) BumpConversation 

func (q *Queries) BumpConversation(ctx context.Context, arg BumpConversationParams) error

func (*Queries) CancelAllActiveRequests 

func (q *Queries) CancelAllActiveRequests(ctx context.Context, arg CancelAllActiveRequestsParams) (int64, error)

func (*Queries) CancelRequest 

func (q *Queries) CancelRequest(ctx context.Context, arg CancelRequestParams) (int64, error)

func (*Queries) ChannelUsageSince 

func (q *Queries) ChannelUsageSince(ctx context.Context, createdAt int64) ([]ChannelUsageSinceRow, error)

func (*Queries) ClaimRequest 

func (q *Queries) ClaimRequest(ctx context.Context, arg ClaimRequestParams) (int64, error)

func (*Queries) CloseChannel 

func (q *Queries) CloseChannel(ctx context.Context, arg CloseChannelParams) (int64, error)

func (*Queries) CompleteRequest 

func (q *Queries) CompleteRequest(ctx context.Context, arg CompleteRequestParams) (int64, error)

func (*Queries) ConsumeLoginToken 

func (q *Queries) ConsumeLoginToken(ctx context.Context, arg ConsumeLoginTokenParams) (int64, error)

func (*Queries) ConsumeOAuthCode 

func (q *Queries) ConsumeOAuthCode(ctx context.Context, arg ConsumeOAuthCodeParams) (int64, error)

func (*Queries) CountActiveAPIKeys 

func (q *Queries) CountActiveAPIKeys(ctx context.Context) (int64, error)

func (*Queries) CountChannelInFlight 

func (q *Queries) CountChannelInFlight(ctx context.Context, channelID *string) (int64, error)

func (*Queries) CountChannelsByStatus 

func (q *Queries) CountChannelsByStatus(ctx context.Context, status string) (int64, error)

func (*Queries) CountConversations 

func (q *Queries) CountConversations(ctx context.Context, arg CountConversationsParams) (int64, error)

func (*Queries) CountEvents 

func (q *Queries) CountEvents(ctx context.Context, arg CountEventsParams) (int64, error)

func (*Queries) CountInFlight 

func (q *Queries) CountInFlight(ctx context.Context) (int64, error)

func (*Queries) CountQueued 

func (q *Queries) CountQueued(ctx context.Context) (int64, error)

func (*Queries) CountRequests 

func (q *Queries) CountRequests(ctx context.Context, arg CountRequestsParams) (int64, error)

func (*Queries) CountRequestsByStatus 

func (q *Queries) CountRequestsByStatus(ctx context.Context, status string) (int64, error)

func (*Queries) CreateAPIKey 

func (q *Queries) CreateAPIKey(ctx context.Context, arg CreateAPIKeyParams) (ApiKey, error)

func (*Queries) CreateAgentToken 

func (q *Queries) CreateAgentToken(ctx context.Context, arg CreateAgentTokenParams) (AgentToken, error)

func (*Queries) CreateChannel 

func (q *Queries) CreateChannel(ctx context.Context, arg CreateChannelParams) (Channel, error)

func (*Queries) CreateConversation 

func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (Conversation, error)

func (*Queries) CreateLoginToken 

func (q *Queries) CreateLoginToken(ctx context.Context, arg CreateLoginTokenParams) error

func (*Queries) CreateOAuthClient 

func (q *Queries) CreateOAuthClient(ctx context.Context, arg CreateOAuthClientParams) (OauthClient, error)

func (*Queries) CreateOAuthCode 

func (q *Queries) CreateOAuthCode(ctx context.Context, arg CreateOAuthCodeParams) error

func (*Queries) CreateRequest 

func (q *Queries) CreateRequest(ctx context.Context, arg CreateRequestParams) (Request, error)

func (*Queries) CreateSession 

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

func (*Queries) DeleteAPIKey 

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

func (*Queries) DeleteAgentToken 

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

func (*Queries) DeleteAllSessions 

func (q *Queries) DeleteAllSessions(ctx context.Context) (int64, error)

func (*Queries) DeleteChannel 

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

func (*Queries) DeleteConversation 

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

func (*Queries) DeleteEventsOlderThan 

func (q *Queries) DeleteEventsOlderThan(ctx context.Context, ts int64) (int64, error)

func (*Queries) DeleteExpiredLoginTokens 

func (q *Queries) DeleteExpiredLoginTokens(ctx context.Context, expiresAt int64) (int64, error)

func (*Queries) DeleteExpiredOAuthCodes 

func (q *Queries) DeleteExpiredOAuthCodes(ctx context.Context, expiresAt int64) (int64, error)

func (*Queries) DeleteExpiredOAuthTokens 

func (q *Queries) DeleteExpiredOAuthTokens(ctx context.Context, arg DeleteExpiredOAuthTokensParams) (int64, error)

func (*Queries) DeleteExpiredSessions 

func (q *Queries) DeleteExpiredSessions(ctx context.Context, expiresAt int64) (int64, error)

func (*Queries) DeleteFinishedRequestsOlderThan 

func (q *Queries) DeleteFinishedRequestsOlderThan(ctx context.Context, createdAt int64) (int64, error)

func (*Queries) DeleteOAuthClient 

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

func (*Queries) DeleteOrphanConversations 

func (q *Queries) DeleteOrphanConversations(ctx context.Context) (int64, error)

func (*Queries) DeleteSession 

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

func (*Queries) DeleteSetting 

func (q *Queries) DeleteSetting(ctx context.Context, key string) error

func (*Queries) DistinctEventKinds 

func (q *Queries) DistinctEventKinds(ctx context.Context) ([]string, error)

func (*Queries) DistinctModels 

func (q *Queries) DistinctModels(ctx context.Context) ([]string, error)

func (*Queries) ExpireRequest 

func (q *Queries) ExpireRequest(ctx context.Context, arg ExpireRequestParams) (int64, error)

func (*Queries) ExtendRequestLease 

func (q *Queries) ExtendRequestLease(ctx context.Context, arg ExtendRequestLeaseParams) (int64, error)

func (*Queries) FailRequest 

func (q *Queries) FailRequest(ctx context.Context, arg FailRequestParams) (int64, error)

func (*Queries) FindConversationByRoot 

func (q *Queries) FindConversationByRoot(ctx context.Context, arg FindConversationByRootParams) (Conversation, error)

func (*Queries) FindRequestByNextHash 

func (q *Queries) FindRequestByNextHash(ctx context.Context, arg FindRequestByNextHashParams) (Request, error)

func (*Queries) GetAPIKey 

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

func (*Queries) GetAPIKeyByHash 

func (q *Queries) GetAPIKeyByHash(ctx context.Context, keyHash string) (ApiKey, error)

func (*Queries) GetAgentToken 

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

func (*Queries) GetAgentTokenByHash 

func (q *Queries) GetAgentTokenByHash(ctx context.Context, tokenHash string) (AgentToken, error)

func (*Queries) GetAgentTokenByRefreshHash 

func (q *Queries) GetAgentTokenByRefreshHash(ctx context.Context, refreshTokenHash *string) (AgentToken, error)

func (*Queries) GetChannel 

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

func (*Queries) GetConversation 

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

func (*Queries) GetOAuthClient 

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

func (*Queries) GetOAuthCode 

func (q *Queries) GetOAuthCode(ctx context.Context, codeHash string) (OauthCode, error)

func (*Queries) GetOpenChannelByName 

func (q *Queries) GetOpenChannelByName(ctx context.Context, name string) (Channel, error)

func (*Queries) GetRequest 

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

func (*Queries) GetSession 

func (q *Queries) GetSession(ctx context.Context, arg GetSessionParams) (Session, error)

func (*Queries) GetSetting 

func (q *Queries) GetSetting(ctx context.Context, key string) (string, error)

func (*Queries) IncrChannelFailed 

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

func (*Queries) IncrChannelServed 

func (q *Queries) IncrChannelServed(ctx context.Context, arg IncrChannelServedParams) error

func (*Queries) InsertEvent 

func (q *Queries) InsertEvent(ctx context.Context, arg InsertEventParams) error

func (*Queries) KeyUsageSince 

func (q *Queries) KeyUsageSince(ctx context.Context, createdAt int64) ([]KeyUsageSinceRow, error)

func (*Queries) LatencySamplesSince 

func (q *Queries) LatencySamplesSince(ctx context.Context, createdAt int64) ([]LatencySamplesSinceRow, error)

func (*Queries) ListAPIKeys 

func (q *Queries) ListAPIKeys(ctx context.Context) ([]ApiKey, error)

func (*Queries) ListActiveRequests 

func (q *Queries) ListActiveRequests(ctx context.Context) ([]Request, error)

func (*Queries) ListAgentTokens 

func (q *Queries) ListAgentTokens(ctx context.Context) ([]AgentToken, error)

func (*Queries) ListChannels 

func (q *Queries) ListChannels(ctx context.Context) ([]Channel, error)

func (*Queries) ListClaimableRequests 

func (q *Queries) ListClaimableRequests(ctx context.Context, arg ListClaimableRequestsParams) ([]Request, error)

func (*Queries) ListConversationRequests 

func (q *Queries) ListConversationRequests(ctx context.Context, conversationID *string) ([]Request, error)

func (*Queries) ListConversations 

func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]Conversation, error)

func (*Queries) ListEvents 

func (q *Queries) ListEvents(ctx context.Context, arg ListEventsParams) ([]Event, error)

func (*Queries) ListExpiredLeases 

func (q *Queries) ListExpiredLeases(ctx context.Context, leaseExpiresAt *int64) ([]Request, error)

func (*Queries) ListInFlightForChannel 

func (q *Queries) ListInFlightForChannel(ctx context.Context, channelID *string) ([]Request, error)

func (*Queries) ListOAuthClients 

func (q *Queries) ListOAuthClients(ctx context.Context) ([]OauthClient, error)

func (*Queries) ListOnlineChannels 

func (q *Queries) ListOnlineChannels(ctx context.Context) ([]Channel, error)

func (*Queries) ListOpenChannels 

func (q *Queries) ListOpenChannels(ctx context.Context) ([]Channel, error)

func (*Queries) ListRecentEvents 

func (q *Queries) ListRecentEvents(ctx context.Context, limit int64) ([]Event, error)

func (*Queries) ListRecentRequests 

func (q *Queries) ListRecentRequests(ctx context.Context, limit int64) ([]Request, error)

func (*Queries) ListRequestEvents 

func (q *Queries) ListRequestEvents(ctx context.Context, requestID *string) ([]Event, error)

func (*Queries) ListRequests 

func (q *Queries) ListRequests(ctx context.Context, arg ListRequestsParams) ([]Request, error)

func (*Queries) ListSettings 

func (q *Queries) ListSettings(ctx context.Context) ([]Setting, error)

func (*Queries) ListStaleOnlineChannels 

func (q *Queries) ListStaleOnlineChannels(ctx context.Context, lastSeenAt int64) ([]Channel, error)

func (*Queries) ListTimedOutRequests 

func (q *Queries) ListTimedOutRequests(ctx context.Context, timeoutAt int64) ([]Request, error)

func (*Queries) MarkRequestStreaming 

func (q *Queries) MarkRequestStreaming(ctx context.Context, arg MarkRequestStreamingParams) (int64, error)

func (*Queries) ModelUsageSince 

func (q *Queries) ModelUsageSince(ctx context.Context, createdAt int64) ([]ModelUsageSinceRow, error)

func (*Queries) ReopenChannel 

func (q *Queries) ReopenChannel(ctx context.Context, arg ReopenChannelParams) error

func (*Queries) RequestStatsSince 

func (q *Queries) RequestStatsSince(ctx context.Context, createdAt int64) (RequestStatsSinceRow, error)

func (*Queries) RequeueRequest 

func (q *Queries) RequeueRequest(ctx context.Context, arg RequeueRequestParams) (int64, error)

func (*Queries) RevokeAPIKey 

func (q *Queries) RevokeAPIKey(ctx context.Context, arg RevokeAPIKeyParams) (int64, error)

func (*Queries) RevokeAgentToken 

func (q *Queries) RevokeAgentToken(ctx context.Context, arg RevokeAgentTokenParams) (int64, error)

func (*Queries) RotateAgentToken 

func (q *Queries) RotateAgentToken(ctx context.Context, arg RotateAgentTokenParams) (int64, error)

func (*Queries) SetChannelStatus 

func (q *Queries) SetChannelStatus(ctx context.Context, arg SetChannelStatusParams) error

func (*Queries) SetSetting 

func (q *Queries) SetSetting(ctx context.Context, arg SetSettingParams) error

func (*Queries) ThroughputBuckets 

func (q *Queries) ThroughputBuckets(ctx context.Context, arg ThroughputBucketsParams) ([]ThroughputBucketsRow, error)

func (*Queries) TouchAPIKey 

func (q *Queries) TouchAPIKey(ctx context.Context, arg TouchAPIKeyParams) error

func (*Queries) TouchAgentToken 

func (q *Queries) TouchAgentToken(ctx context.Context, arg TouchAgentTokenParams) error

func (*Queries) TouchChannel 

func (q *Queries) TouchChannel(ctx context.Context, arg TouchChannelParams) error

func (*Queries) UpdateAPIKey 

func (q *Queries) UpdateAPIKey(ctx context.Context, arg UpdateAPIKeyParams) error

func (*Queries) UpdateChannelConfig 

func (q *Queries) UpdateChannelConfig(ctx context.Context, arg UpdateChannelConfigParams) error

func (*Queries) WithTx 

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

type ReopenChannelParams 

type ReopenChannelParams struct {
	LastSeenAt   int64   `json:"last_seen_at"`
	AgentTokenID *string `json:"agent_token_id"`
	Models       string  `json:"models"`
	Concurrency  int64   `json:"concurrency"`
	Description  string  `json:"description"`
	ID           string  `json:"id"`
}

type Request 

type Request struct {
	ID               string  `json:"id"`
	ApiKeyID         string  `json:"api_key_id"`
	ChannelID        *string `json:"channel_id"`
	RouteChannelID   *string `json:"route_channel_id"`
	ConversationID   *string `json:"conversation_id"`
	TurnIndex        int64   `json:"turn_index"`
	Status           string  `json:"status"`
	Model            string  `json:"model"`
	Endpoint         string  `json:"endpoint"`
	Stream           bool    `json:"stream"`
	Priority         int64   `json:"priority"`
	RequestBody      string  `json:"request_body"`
	ResponseBody     *string `json:"response_body"`
	ResponseText     *string `json:"response_text"`
	ErrorMessage     *string `json:"error_message"`
	HistoryHash      string  `json:"history_hash"`
	FullHash         string  `json:"full_hash"`
	NextHash         *string `json:"next_hash"`
	MessageCount     int64   `json:"message_count"`
	PromptChars      int64   `json:"prompt_chars"`
	PromptTokens     int64   `json:"prompt_tokens"`
	CompletionTokens int64   `json:"completion_tokens"`
	UsageEstimated   bool    `json:"usage_estimated"`
	Attempts         int64   `json:"attempts"`
	MaxAttempts      int64   `json:"max_attempts"`
	ClientIp         string  `json:"client_ip"`
	UserAgent        string  `json:"user_agent"`
	FinishReason     *string `json:"finish_reason"`
	CreatedAt        int64   `json:"created_at"`
	ClaimedAt        *int64  `json:"claimed_at"`
	FirstTokenAt     *int64  `json:"first_token_at"`
	CompletedAt      *int64  `json:"completed_at"`
	LeaseExpiresAt   *int64  `json:"lease_expires_at"`
	TimeoutAt        int64   `json:"timeout_at"`
}

type RequestStatsSinceRow 

type RequestStatsSinceRow struct {
	Total            int64 `json:"total"`
	Completed        int64 `json:"completed"`
	Failed           int64 `json:"failed"`
	Dropped          int64 `json:"dropped"`
	PromptTokens     int64 `json:"prompt_tokens"`
	CompletionTokens int64 `json:"completion_tokens"`
}

type RequeueRequestParams 

type RequeueRequestParams struct {
	ErrorMessage *string `json:"error_message"`
	ID           string  `json:"id"`
}

type RevokeAPIKeyParams 

type RevokeAPIKeyParams struct {
	RevokedAt *int64 `json:"revoked_at"`
	ID        string `json:"id"`
}

type RevokeAgentTokenParams 

type RevokeAgentTokenParams struct {
	RevokedAt *int64 `json:"revoked_at"`
	ID        string `json:"id"`
}

type RotateAgentTokenParams 

type RotateAgentTokenParams struct {
	TokenHash           string  `json:"token_hash"`
	TokenPrefix         string  `json:"token_prefix"`
	RefreshTokenHash    *string `json:"refresh_token_hash"`
	ExpiresAt           *int64  `json:"expires_at"`
	ID                  string  `json:"id"`
	PreviousRefreshHash *string `json:"previous_refresh_hash"`
}

type Session 

type Session struct {
	ID        string `json:"id"`
	CreatedAt int64  `json:"created_at"`
	ExpiresAt int64  `json:"expires_at"`
	UserAgent string `json:"user_agent"`
}

type SetChannelStatusParams 

type SetChannelStatusParams struct {
	Status string `json:"status"`
	ID     string `json:"id"`
}

type SetSettingParams 

type SetSettingParams struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	UpdatedAt int64  `json:"updated_at"`
}

type Setting 

type Setting struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	UpdatedAt int64  `json:"updated_at"`
}

type ThroughputBucketsParams 

type ThroughputBucketsParams struct {
	BucketMs int64 `json:"bucket_ms"`
	Since    int64 `json:"since"`
}

type ThroughputBucketsRow 

type ThroughputBucketsRow struct {
	Bucket    int64 `json:"bucket"`
	Total     int64 `json:"total"`
	Completed int64 `json:"completed"`
	Failed    int64 `json:"failed"`
}

type TouchAPIKeyParams 

type TouchAPIKeyParams struct {
	LastUsedAt *int64 `json:"last_used_at"`
	ID         string `json:"id"`
}

type TouchAgentTokenParams 

type TouchAgentTokenParams struct {
	LastUsedAt *int64 `json:"last_used_at"`
	ID         string `json:"id"`
}

type TouchChannelParams 

type TouchChannelParams struct {
	LastSeenAt int64  `json:"last_seen_at"`
	ID         string `json:"id"`
}

type UpdateAPIKeyParams 

type UpdateAPIKeyParams struct {
	Name            string  `json:"name"`
	RateLimitRpm    int64   `json:"rate_limit_rpm"`
	AllowedModels   string  `json:"allowed_models"`
	PinnedChannelID *string `json:"pinned_channel_id"`
	TimeoutSeconds  int64   `json:"timeout_seconds"`
	Priority        int64   `json:"priority"`
	ID              string  `json:"id"`
}

type UpdateChannelConfigParams 

type UpdateChannelConfigParams struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Models      string `json:"models"`
	Concurrency int64  `json:"concurrency"`
	ID          string `json:"id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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