Documentation
¶
Index ¶
- func MigrationFS() fs.FS
- type AccountRecoveryAudit
- type AccountRunReservation
- type AcknowledgeCancellationParams
- type AddEarningsParams
- type AddOutputAccountUsageParams
- type AddOutputNodeUsageParams
- type AdvanceDebugletOutputParams
- type AdvanceLegacyDebugletOutputParams
- type AllocationReclamation
- type AllowanceGrant
- type ApproveDeviceLoginParams
- type AttemptCancellationParams
- type AttributionChain
- type AttributionKey
- type AttributionRetention
- type AttributionRun
- type ChainTransfer
- type ClaimDebugletOrderParams
- type CompleteDebugletParams
- type ConsumeDeviceLoginParams
- type ConsumeOAuthAttemptParams
- type ConsumeOAuthAttemptRow
- type ConsumePendingIdentityLinkParams
- type ConsumePendingIdentityLinkRow
- type CountAccountCredentialsParams
- type CreateAPICredentialParams
- type CreateCancellationParams
- type CreateDebugletLogParams
- type CreateDebugletOrderParams
- type CreateDebugletOutputParams
- type CreateDebugletParams
- type CreateDebugletProvenanceParams
- type CreateDeviceLoginParams
- type CreateEarningsParams
- type CreateExecutorEnrollmentTokenParams
- type CreateExternalIdentityParams
- type CreateMeasurementProfileParams
- type CreateOAuthAttemptParams
- type CreateOwnedExecutorParams
- type CreatePayloadTombstoneParams
- type CreateRetryRequestParams
- type CreateSequencedDebugletLogParams
- type CreateSessionParams
- type CreateTransactionParams
- type CreateUserParams
- type CreateUserWithRoleParams
- type DBTX
- type Debuglet
- type DebugletCancellation
- type DebugletLog
- type DebugletOrder
- type DebugletOutput
- type DebugletProvenance
- type DebugletUser
- type DeleteExternalIdentityParams
- type DeleteMeasurementProfileParams
- type DeleteMeasurementTargetsParams
- type DenyDeviceLoginParams
- type DeviceLogin
- type Earning
- type EndAttributionRunParams
- type ExecutorEnrollment
- type ExecutorEnrollmentToken
- type ExtendProbeAddressParams
- type FailCancellationParams
- type FindExternalIdentityParams
- type FinishDebugletOutputParams
- type GetAdmittedRunsRow
- type GetAllowanceGrantParams
- type GetAllowanceGrantRow
- type GetAllowanceParams
- type GetAllowanceRow
- type GetAttributionChainParams
- type GetAttributionKeyParams
- type GetDebugletIdentityByUUIDRow
- type GetDebugletOrderParams
- type GetDebugletOutputRow
- type GetEarningsInParams
- type GetExecutorEnrollmentTokenRow
- type GetIdentitySessionRow
- type GetMeasurementProfileParams
- type GetOrderSettlementParams
- type GetOwnedDebugletByUUIDParams
- type GetOwnedExecutorParams
- type GetOwnedExecutorRow
- type GetPaymentReceiptParams
- type GetResultOutputSizeRow
- type GetRetryRequestParams
- type GetSequencedDebugletLogParams
- type GetSessionBySelectorRow
- type GetUserCredentialParams
- type GetUserCredentialRow
- type InsertAllowanceGrantParams
- type InsertAttributionKeyParams
- type InsertChainTransferParams
- type InsertDebugletUserParams
- type InsertMeasurementRequestParams
- type InsertOrderSettlementParams
- type InsertPaymentReceiptParams
- type InterruptUnresumableOutputParams
- type LatestAttributionKeyParams
- type LatestAttributionKeyRow
- type ListAccountCredentialsParams
- type ListAccountCredentialsRow
- type ListAccountIntentsParams
- type ListAccountIntentsRow
- type ListAccountReservationsRow
- type ListAttributionCandidatesParams
- type ListAttributionCandidatesRow
- type ListAttributionKeysParams
- type ListAttributionKeysRow
- type ListDebugletLogsParams
- type ListDebugletsByUserUUIDParams
- type ListDebugletsParams
- type ListExecutorTransfersParams
- type ListExecutorTransfersRow
- type ListExternalIdentitiesRow
- type ListIntentOrdersRow
- type ListMeasurementProfilesRow
- type ListMeasurementsParams
- type ListMeasurementsRow
- type ListOwnedExecutorsRow
- type ListPendingIdentityLinksParams
- type ListPendingIdentityLinksRow
- type ListPendingSettlementsParams
- type ListPendingSettlementsRow
- type ListUnreclaimedAllocationsParams
- type ListUnresolvedChainTransfersParams
- type MarkRetirementCheckParams
- type MarkTransactionPaidParams
- type MeasurementCountsParams
- type MeasurementCountsRow
- type MeasurementExecution
- type MeasurementProfile
- type MeasurementRequest
- type MeasurementRunCountParams
- type MeasurementRunsParams
- type MeasurementRunsRow
- type MeasurementSummary
- type OauthIdentity
- type OauthLoginAttempt
- type OrderSettlement
- type OutputAccountUsage
- type OutputNodeUsage
- type OwnedExecutor
- type PayloadTombstone
- type PaymentReceipt
- type PendingIdentityLink
- type ProbeAddress
- type ProbeStatus
- type Queries
- func (q *Queries) AcknowledgeCancellation(ctx context.Context, arg AcknowledgeCancellationParams) error
- func (q *Queries) AddEarnings(ctx context.Context, arg AddEarningsParams) error
- func (q *Queries) AddOutputAccountUsage(ctx context.Context, arg AddOutputAccountUsageParams) error
- func (q *Queries) AddOutputNodeUsage(ctx context.Context, arg AddOutputNodeUsageParams) error
- func (q *Queries) AdvanceAttributionRetention(ctx context.Context, cutoffNs int64) error
- func (q *Queries) AdvanceDebugletOutput(ctx context.Context, arg AdvanceDebugletOutputParams) (int64, error)
- func (q *Queries) AdvanceLegacyDebugletOutput(ctx context.Context, arg AdvanceLegacyDebugletOutputParams) (int64, error)
- func (q *Queries) ApproveDeviceLogin(ctx context.Context, arg ApproveDeviceLoginParams) (int64, error)
- func (q *Queries) AttemptCancellation(ctx context.Context, arg AttemptCancellationParams) error
- func (q *Queries) CancelDeviceLogin(ctx context.Context, selector string) error
- func (q *Queries) ClaimDebugletOrder(ctx context.Context, arg ClaimDebugletOrderParams) (int64, error)
- func (q *Queries) CompleteDebuglet(ctx context.Context, arg CompleteDebugletParams) (Debuglet, error)
- func (q *Queries) ConsumeAdminAccountRecovery(ctx context.Context, selector string) error
- func (q *Queries) ConsumeDeviceLogin(ctx context.Context, arg ConsumeDeviceLoginParams) (int64, error)
- func (q *Queries) ConsumeExecutorEnrollmentToken(ctx context.Context, selector string) (int64, error)
- func (q *Queries) ConsumeOAuthAttempt(ctx context.Context, arg ConsumeOAuthAttemptParams) (ConsumeOAuthAttemptRow, error)
- func (q *Queries) ConsumePendingIdentityLink(ctx context.Context, arg ConsumePendingIdentityLinkParams) (ConsumePendingIdentityLinkRow, error)
- func (q *Queries) CountAccountCredentials(ctx context.Context, arg CountAccountCredentialsParams) (int64, error)
- func (q *Queries) CountDeviceLogins(ctx context.Context) (int64, error)
- func (q *Queries) CountRecoveryCredentials(ctx context.Context, userID int64) (int64, error)
- func (q *Queries) CreateAPICredential(ctx context.Context, arg CreateAPICredentialParams) error
- func (q *Queries) CreateCancellation(ctx context.Context, arg CreateCancellationParams) error
- func (q *Queries) CreateDebuglet(ctx context.Context, arg CreateDebugletParams) (Debuglet, error)
- func (q *Queries) CreateDebugletLog(ctx context.Context, arg CreateDebugletLogParams) (DebugletLog, error)
- func (q *Queries) CreateDebugletOrder(ctx context.Context, arg CreateDebugletOrderParams) (DebugletOrder, error)
- func (q *Queries) CreateDebugletOutput(ctx context.Context, arg CreateDebugletOutputParams) error
- func (q *Queries) CreateDebugletProvenance(ctx context.Context, arg CreateDebugletProvenanceParams) error
- func (q *Queries) CreateDeviceLogin(ctx context.Context, arg CreateDeviceLoginParams) error
- func (q *Queries) CreateEarnings(ctx context.Context, arg CreateEarningsParams) (Earning, error)
- func (q *Queries) CreateExecutorEnrollmentToken(ctx context.Context, arg CreateExecutorEnrollmentTokenParams) error
- func (q *Queries) CreateExternalIdentity(ctx context.Context, arg CreateExternalIdentityParams) error
- func (q *Queries) CreateMeasurementProfile(ctx context.Context, arg CreateMeasurementProfileParams) (int64, error)
- func (q *Queries) CreateOAuthAttempt(ctx context.Context, arg CreateOAuthAttemptParams) (int64, error)
- func (q *Queries) CreateOwnedExecutor(ctx context.Context, arg CreateOwnedExecutorParams) (int64, error)
- func (q *Queries) CreatePayloadTombstone(ctx context.Context, arg CreatePayloadTombstoneParams) error
- func (q *Queries) CreateRetryRequest(ctx context.Context, arg CreateRetryRequestParams) error
- func (q *Queries) CreateSequencedDebugletLog(ctx context.Context, arg CreateSequencedDebugletLogParams) (DebugletLog, error)
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
- func (q *Queries) CreateTransaction(ctx context.Context, arg CreateTransactionParams) (Transaction, error)
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
- func (q *Queries) CreateUserWithRole(ctx context.Context, arg CreateUserWithRoleParams) (User, error)
- func (q *Queries) DeleteAdminRecoveryCredential(ctx context.Context, selector string) error
- func (q *Queries) DeleteExecutorEnrollment(ctx context.Context, executorID string) (int64, error)
- func (q *Queries) DeleteExecutorEnrollmentTokens(ctx context.Context, executorID string) (int64, error)
- func (q *Queries) DeleteExpiredDeviceLogins(ctx context.Context, expiresAt int64) error
- func (q *Queries) DeleteExpiredIdentityLinks(ctx context.Context, expiresAt models.UTCTime) error
- func (q *Queries) DeleteExpiredOAuthAttempts(ctx context.Context, expiresAt models.UTCTime) error
- func (q *Queries) DeleteExpiredSessions(ctx context.Context, before models.UTCTime) error
- func (q *Queries) DeleteExternalIdentity(ctx context.Context, arg DeleteExternalIdentityParams) (int64, error)
- func (q *Queries) DeleteMeasurementLogs(ctx context.Context, debugletID int64) error
- func (q *Queries) DeleteMeasurementProfile(ctx context.Context, arg DeleteMeasurementProfileParams) (int64, error)
- func (q *Queries) DeleteMeasurementProvenance(ctx context.Context, debugletID int64) error
- func (q *Queries) DeleteMeasurementTargets(ctx context.Context, arg DeleteMeasurementTargetsParams) error
- func (q *Queries) DenyDeviceLogin(ctx context.Context, arg DenyDeviceLoginParams) (int64, error)
- func (q *Queries) EndAttributionRun(ctx context.Context, arg EndAttributionRunParams) error
- func (q *Queries) EnsureOutputAccountUsage(ctx context.Context, accountID int64) error
- func (q *Queries) ExtendProbeAddress(ctx context.Context, arg ExtendProbeAddressParams) (int64, error)
- func (q *Queries) FailCancellation(ctx context.Context, arg FailCancellationParams) error
- func (q *Queries) FindExternalIdentity(ctx context.Context, arg FindExternalIdentityParams) (int64, error)
- func (q *Queries) FinishDebugletOutput(ctx context.Context, arg FinishDebugletOutputParams) (int64, error)
- func (q *Queries) GetAccountRunReservation(ctx context.Context, debugletID int64) (AccountRunReservation, error)
- func (q *Queries) GetAdmittedRuns(ctx context.Context, transactionID string) ([]GetAdmittedRunsRow, error)
- func (q *Queries) GetAllocationReclamation(ctx context.Context, argUuid uuid.UUID) (models.UTCTime, error)
- func (q *Queries) GetAllowance(ctx context.Context, arg GetAllowanceParams) (GetAllowanceRow, error)
- func (q *Queries) GetAllowanceGrant(ctx context.Context, arg GetAllowanceGrantParams) (GetAllowanceGrantRow, error)
- func (q *Queries) GetAttributionChain(ctx context.Context, arg GetAttributionChainParams) (AttributionChain, error)
- func (q *Queries) GetAttributionKey(ctx context.Context, arg GetAttributionKeyParams) ([]byte, error)
- func (q *Queries) GetAttributionRetention(ctx context.Context) (int64, error)
- func (q *Queries) GetCancellation(ctx context.Context, debugletID int64) (DebugletCancellation, error)
- func (q *Queries) GetCredentialUser(ctx context.Context, id int64) (User, error)
- func (q *Queries) GetDebugletByUUID(ctx context.Context, argUuid uuid.UUID) (Debuglet, error)
- func (q *Queries) GetDebugletIdentityByUUID(ctx context.Context, argUuid uuid.UUID) (GetDebugletIdentityByUUIDRow, error)
- func (q *Queries) GetDebugletOrder(ctx context.Context, arg GetDebugletOrderParams) (DebugletOrder, error)
- func (q *Queries) GetDebugletOutput(ctx context.Context, argUuid uuid.UUID) (GetDebugletOutputRow, error)
- func (q *Queries) GetDebugletOwnerUUID(ctx context.Context, argUuid uuid.UUID) (uuid.UUID, error)
- func (q *Queries) GetDebugletProvenance(ctx context.Context, argUuid uuid.UUID) (string, error)
- func (q *Queries) GetDebugletProvenanceSize(ctx context.Context, debugletID int64) (sql.NullInt64, error)
- func (q *Queries) GetDeviceLogin(ctx context.Context, selector string) (DeviceLogin, error)
- func (q *Queries) GetDeviceLoginByUserCode(ctx context.Context, userCodeHash []byte) (DeviceLogin, error)
- func (q *Queries) GetEarnings(ctx context.Context) ([]Earning, error)
- func (q *Queries) GetEarningsIn(ctx context.Context, arg GetEarningsInParams) (Earning, error)
- func (q *Queries) GetEarningsOf(ctx context.Context, executorID string) ([]Earning, error)
- func (q *Queries) GetExecutorEnrollment(ctx context.Context, executorID string) (string, error)
- func (q *Queries) GetExecutorEnrollmentToken(ctx context.Context, selector string) (GetExecutorEnrollmentTokenRow, error)
- func (q *Queries) GetIdentitySession(ctx context.Context, selector string) (GetIdentitySessionRow, error)
- func (q *Queries) GetLatestRefundTransferState(ctx context.Context, transactionID string) (string, error)
- func (q *Queries) GetMeasurementExecution(ctx context.Context, debugletID int64) (MeasurementExecution, error)
- func (q *Queries) GetMeasurementProfile(ctx context.Context, arg GetMeasurementProfileParams) (string, error)
- func (q *Queries) GetMeasurementRequest(ctx context.Context, debugletID int64) (string, error)
- func (q *Queries) GetOrderSettlement(ctx context.Context, arg GetOrderSettlementParams) (OrderSettlement, error)
- func (q *Queries) GetOutputAccountUsage(ctx context.Context, accountID int64) (OutputAccountUsage, error)
- func (q *Queries) GetOutputNodeUsage(ctx context.Context) (OutputNodeUsage, error)
- func (q *Queries) GetOwnedDebugletByUUID(ctx context.Context, arg GetOwnedDebugletByUUIDParams) (Debuglet, error)
- func (q *Queries) GetOwnedExecutor(ctx context.Context, arg GetOwnedExecutorParams) (GetOwnedExecutorRow, error)
- func (q *Queries) GetPayloadTombstone(ctx context.Context, argUuid uuid.UUID) (PayloadTombstone, error)
- func (q *Queries) GetPaymentReceipt(ctx context.Context, arg GetPaymentReceiptParams) (PaymentReceipt, error)
- func (q *Queries) GetReclaimedDebuglet(ctx context.Context, argUuid uuid.UUID) (Debuglet, error)
- func (q *Queries) GetResultLogs(ctx context.Context, debugletID int64) ([]DebugletLog, error)
- func (q *Queries) GetResultOutputSize(ctx context.Context, debugletID int64) (GetResultOutputSizeRow, error)
- func (q *Queries) GetRetryRequest(ctx context.Context, arg GetRetryRequestParams) (RetryRequest, error)
- func (q *Queries) GetSequencedDebugletLog(ctx context.Context, arg GetSequencedDebugletLogParams) (DebugletLog, error)
- func (q *Queries) GetSessionBySelector(ctx context.Context, selector string) (GetSessionBySelectorRow, error)
- func (q *Queries) GetTransactionByID(ctx context.Context, id string) (Transaction, error)
- func (q *Queries) GetTransactionOrders(ctx context.Context, transactionID string) ([]DebugletOrder, error)
- func (q *Queries) GetTransactionOwnerUUID(ctx context.Context, transactionID string) (uuid.UUID, error)
- func (q *Queries) GetTransactionState(ctx context.Context, key string) (TransactionState, error)
- func (q *Queries) GetUnmappedAccountForRecovery(ctx context.Context, argUuid uuid.UUID) (User, error)
- func (q *Queries) GetUserByUUID(ctx context.Context, argUuid uuid.UUID) (User, error)
- func (q *Queries) GetUserCredential(ctx context.Context, arg GetUserCredentialParams) (GetUserCredentialRow, error)
- func (q *Queries) InsertAllowanceGrant(ctx context.Context, arg InsertAllowanceGrantParams) (int64, error)
- func (q *Queries) InsertAttributionKey(ctx context.Context, arg InsertAttributionKeyParams) error
- func (q *Queries) InsertChainTransfer(ctx context.Context, arg InsertChainTransferParams) (int64, error)
- func (q *Queries) InsertDebugletUser(ctx context.Context, arg InsertDebugletUserParams) error
- func (q *Queries) InsertMeasurementRequest(ctx context.Context, arg InsertMeasurementRequestParams) error
- func (q *Queries) InsertOrderSettlement(ctx context.Context, arg InsertOrderSettlementParams) error
- func (q *Queries) InsertPaymentReceipt(ctx context.Context, arg InsertPaymentReceiptParams) error
- func (q *Queries) InterruptUnresumableOutput(ctx context.Context, arg InterruptUnresumableOutputParams) (int64, error)
- func (q *Queries) LatestAttributionKey(ctx context.Context, arg LatestAttributionKeyParams) (LatestAttributionKeyRow, error)
- func (q *Queries) ListAccountCredentials(ctx context.Context, arg ListAccountCredentialsParams) ([]ListAccountCredentialsRow, error)
- func (q *Queries) ListAccountIntents(ctx context.Context, arg ListAccountIntentsParams) ([]ListAccountIntentsRow, error)
- func (q *Queries) ListAccountReservations(ctx context.Context, accountID int64) ([]ListAccountReservationsRow, error)
- func (q *Queries) ListAttributionCandidates(ctx context.Context, arg ListAttributionCandidatesParams) ([]ListAttributionCandidatesRow, error)
- func (q *Queries) ListAttributionKeys(ctx context.Context, arg ListAttributionKeysParams) ([]ListAttributionKeysRow, error)
- func (q *Queries) ListConnectedProbeIDs(ctx context.Context) ([]string, error)
- func (q *Queries) ListDebugletLogs(ctx context.Context, arg ListDebugletLogsParams) ([]DebugletLog, error)
- func (q *Queries) ListDebuglets(ctx context.Context, arg ListDebugletsParams) ([]Debuglet, error)
- func (q *Queries) ListDebugletsByUserUUID(ctx context.Context, arg ListDebugletsByUserUUIDParams) ([]Debuglet, error)
- func (q *Queries) ListDebugletsEndAfter(ctx context.Context, endTime models.UTCTime) ([]Debuglet, error)
- func (q *Queries) ListEnrolledExecutorIDs(ctx context.Context) ([]string, error)
- func (q *Queries) ListExecutorTransfers(ctx context.Context, arg ListExecutorTransfersParams) ([]ListExecutorTransfersRow, error)
- func (q *Queries) ListExpiredPayloads(ctx context.Context, before sql.NullInt64) ([]uuid.UUID, error)
- func (q *Queries) ListExternalIdentities(ctx context.Context, argUuid uuid.UUID) ([]ListExternalIdentitiesRow, error)
- func (q *Queries) ListIntentOrders(ctx context.Context, transactionID string) ([]ListIntentOrdersRow, error)
- func (q *Queries) ListLatestProbeAddresses(ctx context.Context) ([]ProbeAddress, error)
- func (q *Queries) ListMeasurementProfiles(ctx context.Context, argUuid uuid.UUID) ([]ListMeasurementProfilesRow, error)
- func (q *Queries) ListMeasurements(ctx context.Context, arg ListMeasurementsParams) ([]ListMeasurementsRow, error)
- func (q *Queries) ListOwnedExecutors(ctx context.Context, argUuid uuid.UUID) ([]ListOwnedExecutorsRow, error)
- func (q *Queries) ListPaymentReceiptsByNonce(ctx context.Context, nonce string) ([]PaymentReceipt, error)
- func (q *Queries) ListPendingIdentityLinks(ctx context.Context, arg ListPendingIdentityLinksParams) ([]ListPendingIdentityLinksRow, error)
- func (q *Queries) ListPendingSettlements(ctx context.Context, arg ListPendingSettlementsParams) ([]ListPendingSettlementsRow, error)
- func (q *Queries) ListProbeStatus(ctx context.Context) ([]ProbeStatus, error)
- func (q *Queries) ListRetirementCandidates(ctx context.Context) ([]uuid.UUID, error)
- func (q *Queries) ListUnreclaimedAllocations(ctx context.Context, arg ListUnreclaimedAllocationsParams) ([]Debuglet, error)
- func (q *Queries) ListUnresolvedChainTransfers(ctx context.Context, arg ListUnresolvedChainTransfersParams) ([]ChainTransfer, error)
- func (q *Queries) ListUserUUIDs(ctx context.Context) ([]uuid.UUID, error)
- func (q *Queries) LockAccountForRecovery(ctx context.Context, argUuid uuid.UUID) (int64, error)
- func (q *Queries) LockCredentialSession(ctx context.Context, selector string) error
- func (q *Queries) LockDeviceLogin(ctx context.Context, selector string) error
- func (q *Queries) MarkRetirementCheck(ctx context.Context, arg MarkRetirementCheckParams) error
- func (q *Queries) MarkTransactionPaid(ctx context.Context, arg MarkTransactionPaidParams) (int64, error)
- func (q *Queries) MeasurementCounts(ctx context.Context, arg MeasurementCountsParams) ([]MeasurementCountsRow, error)
- func (q *Queries) MeasurementRunCount(ctx context.Context, arg MeasurementRunCountParams) (int64, error)
- func (q *Queries) MeasurementRuns(ctx context.Context, arg MeasurementRunsParams) ([]MeasurementRunsRow, error)
- func (q *Queries) PruneAttributionChains(ctx context.Context, cutoffNs int64) (int64, error)
- func (q *Queries) PruneAttributionKeys(ctx context.Context, cutoffNs int64) (int64, error)
- func (q *Queries) PruneAttributionRuns(ctx context.Context, cutoffNs int64) (int64, error)
- func (q *Queries) PruneProbeAddresses(ctx context.Context, cutoff int64) (int64, error)
- func (q *Queries) ReclaimAllocation(ctx context.Context, arg ReclaimAllocationParams) error
- func (q *Queries) RecordAdminAccountRecovery(ctx context.Context, arg RecordAdminAccountRecoveryParams) error
- func (q *Queries) RecordAttributionChain(ctx context.Context, arg RecordAttributionChainParams) error
- func (q *Queries) RecordAttributionRun(ctx context.Context, arg RecordAttributionRunParams) error
- func (q *Queries) RecordMeasurementStarted(ctx context.Context, arg RecordMeasurementStartedParams) error
- func (q *Queries) RecordMeasurementTerminal(ctx context.Context, arg RecordMeasurementTerminalParams) error
- func (q *Queries) RecordProbeConnected(ctx context.Context, arg RecordProbeConnectedParams) error
- func (q *Queries) RecordProbeDisconnected(ctx context.Context, executorID string) (int64, error)
- func (q *Queries) RefreshExternalIdentity(ctx context.Context, arg RefreshExternalIdentityParams) error
- func (q *Queries) RefundPaidTransaction(ctx context.Context, arg RefundPaidTransactionParams) (int64, error)
- func (q *Queries) RefundUnadmittedTransaction(ctx context.Context, arg RefundUnadmittedTransactionParams) (int64, error)
- func (q *Queries) ReleaseExpiredAllowanceIntents(ctx context.Context, arg ReleaseExpiredAllowanceIntentsParams) (int64, error)
- func (q *Queries) ReleasePayout(ctx context.Context, arg ReleasePayoutParams) error
- func (q *Queries) ReserveAccountRun(ctx context.Context, arg ReserveAccountRunParams) error
- func (q *Queries) ReserveAllowanceIntent(ctx context.Context, arg ReserveAllowanceIntentParams) (int64, error)
- func (q *Queries) ReservePayout(ctx context.Context, arg ReservePayoutParams) (int64, error)
- func (q *Queries) RetireAccountRun(ctx context.Context, arg RetireAccountRunParams) (int64, error)
- func (q *Queries) RevokeAccountCredential(ctx context.Context, arg RevokeAccountCredentialParams) (int64, error)
- func (q *Queries) RevokeAdminAccountRecovery(ctx context.Context, arg RevokeAdminAccountRecoveryParams) (string, error)
- func (q *Queries) RevokeSessionBySelector(ctx context.Context, selector string) error
- func (q *Queries) RevokeUserSessions(ctx context.Context, argUuid uuid.UUID) error
- func (q *Queries) SetExecutorEnrollment(ctx context.Context, arg SetExecutorEnrollmentParams) error
- func (q *Queries) SetRefundAddress(ctx context.Context, arg SetRefundAddressParams) error
- func (q *Queries) SetTransactionOwner(ctx context.Context, arg SetTransactionOwnerParams) error
- func (q *Queries) SetTransactionPricingRule(ctx context.Context, arg SetTransactionPricingRuleParams) error
- func (q *Queries) SetUserRole(ctx context.Context, arg SetUserRoleParams) (int64, error)
- func (q *Queries) SettleEarning(ctx context.Context, arg SettleEarningParams) error
- func (q *Queries) StartProbeAddress(ctx context.Context, arg StartProbeAddressParams) (int64, error)
- func (q *Queries) StorePendingIdentityLink(ctx context.Context, arg StorePendingIdentityLinkParams) error
- func (q *Queries) TouchAttributionChain(ctx context.Context, arg TouchAttributionChainParams) error
- func (q *Queries) TouchProbeConnected(ctx context.Context, arg TouchProbeConnectedParams) (int64, error)
- func (q *Queries) TransitionDebugletOrder(ctx context.Context, arg TransitionDebugletOrderParams) (int64, error)
- func (q *Queries) UpdateChainTransfer(ctx context.Context, arg UpdateChainTransferParams) (int64, error)
- func (q *Queries) UpdateDebugletOrderState(ctx context.Context, arg UpdateDebugletOrderStateParams) (DebugletOrder, error)
- func (q *Queries) UpdateDebugletState(ctx context.Context, arg UpdateDebugletStateParams) (Debuglet, error)
- func (q *Queries) UpdateDeviceLoginPoll(ctx context.Context, arg UpdateDeviceLoginPollParams) (int64, error)
- func (q *Queries) UpdateMeasurementProfile(ctx context.Context, arg UpdateMeasurementProfileParams) (int64, error)
- func (q *Queries) UpdateTransactionState(ctx context.Context, arg UpdateTransactionStateParams) (TransactionState, error)
- func (q *Queries) UpdateTransactionStatus(ctx context.Context, arg UpdateTransactionStatusParams) error
- func (q *Queries) UpsertUserCredential(ctx context.Context, arg UpsertUserCredentialParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type ReclaimAllocationParams
- type RecordAdminAccountRecoveryParams
- type RecordAttributionChainParams
- type RecordAttributionRunParams
- type RecordMeasurementStartedParams
- type RecordMeasurementTerminalParams
- type RecordProbeConnectedParams
- type RefreshExternalIdentityParams
- type RefundPaidTransactionParams
- type RefundUnadmittedTransactionParams
- type ReleaseExpiredAllowanceIntentsParams
- type ReleasePayoutParams
- type ReserveAccountRunParams
- type ReserveAllowanceIntentParams
- type ReservePayoutParams
- type RetireAccountRunParams
- type RetryRequest
- type RevokeAccountCredentialParams
- type RevokeAdminAccountRecoveryParams
- type Session
- type SetExecutorEnrollmentParams
- type SetRefundAddressParams
- type SetTransactionOwnerParams
- type SetTransactionPricingRuleParams
- type SetUserRoleParams
- type SettleEarningParams
- type StartProbeAddressParams
- type StorePendingIdentityLinkParams
- type TouchAttributionChainParams
- type TouchProbeConnectedParams
- type Transaction
- type TransactionState
- type TransactionUser
- type TransitionDebugletOrderParams
- type UpdateChainTransferParams
- type UpdateDebugletOrderStateParams
- type UpdateDebugletStateParams
- type UpdateDeviceLoginPollParams
- type UpdateMeasurementProfileParams
- type UpdateTransactionStateParams
- type UpdateTransactionStatusParams
- type UpsertUserCredentialParams
- type User
- type UserCredential
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MigrationFS ¶
MigrationFS exposes the canonical SQL migrations without global registration.
Types ¶
type AccountRecoveryAudit ¶ added in v0.3.0
type AccountRunReservation ¶ added in v0.3.0
type AcknowledgeCancellationParams ¶ added in v0.3.0
type AddEarningsParams ¶
type AddOutputAccountUsageParams ¶ added in v0.3.0
type AddOutputNodeUsageParams ¶ added in v0.3.0
type AdvanceDebugletOutputParams ¶ added in v0.3.0
type AdvanceLegacyDebugletOutputParams ¶ added in v0.3.0
type AllocationReclamation ¶ added in v0.3.0
type AllowanceGrant ¶ added in v0.3.0
type ApproveDeviceLoginParams ¶ added in v0.3.0
type AttemptCancellationParams ¶ added in v0.3.0
type AttributionChain ¶ added in v0.3.0
type AttributionKey ¶ added in v0.3.0
type AttributionRetention ¶ added in v0.3.0
type AttributionRun ¶ added in v0.3.0
type ChainTransfer ¶ added in v0.3.0
type CompleteDebugletParams ¶
type CompleteDebugletParams struct {
ExitedState models.DebugletRunState
Error sql.NullString
Uuid uuid.UUID
ExecutorID string
DispatcherIncarnation string
SessionID string
}
type ConsumeDeviceLoginParams ¶ added in v0.3.0
type ConsumeOAuthAttemptParams ¶ added in v0.3.0
type ConsumeOAuthAttemptRow ¶ added in v0.3.0
type ConsumePendingIdentityLinkParams ¶ added in v0.3.0
type ConsumePendingIdentityLinkRow ¶ added in v0.3.0
type CountAccountCredentialsParams ¶ added in v0.3.0
type CreateAPICredentialParams ¶ added in v0.3.0
type CreateCancellationParams ¶ added in v0.3.0
type CreateDebugletLogParams ¶
type CreateDebugletOutputParams ¶ added in v0.3.0
type CreateDebugletParams ¶
type CreateDebugletProvenanceParams ¶ added in v0.3.0
type CreateDeviceLoginParams ¶ added in v0.3.0
type CreateEarningsParams ¶
type CreateExternalIdentityParams ¶ added in v0.3.0
type CreateMeasurementProfileParams ¶ added in v0.3.0
type CreateOAuthAttemptParams ¶ added in v0.3.0
type CreateOwnedExecutorParams ¶ added in v0.3.0
type CreatePayloadTombstoneParams ¶ added in v0.3.0
type CreateRetryRequestParams ¶ added in v0.3.0
type CreateSequencedDebugletLogParams ¶ added in v0.3.0
type CreateSessionParams ¶
type CreateTransactionParams ¶
type CreateUserParams ¶
type Debuglet ¶
type Debuglet struct {
ID int64
Uuid uuid.UUID
StartTime models.UTCTime
EndTime models.UTCTime
Usage int64
CeilBw int64
ExecutorID string
Addresses models.CommaSeparatedList
State models.DebugletRunState
Error sql.NullString
TransactionID string
OrderID int64
DispatcherIncarnation string
SessionID string
}
type DebugletCancellation ¶ added in v0.3.0
type DebugletLog ¶
type DebugletOrder ¶
type DebugletOutput ¶ added in v0.3.0
type DebugletProvenance ¶ added in v0.3.0
type DebugletUser ¶
type DeleteExternalIdentityParams ¶ added in v0.3.0
type DeleteMeasurementProfileParams ¶ added in v0.3.0
type DeleteMeasurementTargetsParams ¶ added in v0.3.0
type DeleteMeasurementTargetsParams struct {
PublicError sql.NullString
DebugletID int64
}
type DenyDeviceLoginParams ¶ added in v0.3.0
type DeviceLogin ¶ added in v0.3.0
type EndAttributionRunParams ¶ added in v0.3.0
type ExecutorEnrollment ¶
type ExecutorEnrollmentToken ¶
type ExtendProbeAddressParams ¶ added in v0.3.0
type FailCancellationParams ¶ added in v0.3.0
type FindExternalIdentityParams ¶ added in v0.3.0
type FinishDebugletOutputParams ¶ added in v0.3.0
type GetAdmittedRunsRow ¶
type GetAllowanceGrantParams ¶ added in v0.3.0
type GetAllowanceGrantRow ¶ added in v0.3.0
type GetAllowanceParams ¶ added in v0.3.0
type GetAllowanceRow ¶ added in v0.3.0
type GetAttributionChainParams ¶ added in v0.3.0
type GetAttributionKeyParams ¶ added in v0.3.0
type GetDebugletOrderParams ¶
type GetDebugletOutputRow ¶ added in v0.3.0
type GetDebugletOutputRow struct {
DebugletID int64
OutputVersion int64
OwnerFingerprint string
AccountID int64
CommittedSequence int64
ByteCount int64
FrameCount int64
LastLogID int64
FinalSequence sql.NullInt64
FinalCursor sql.NullInt64
Status string
Reason string
Uuid uuid.UUID
ExecutorID string
DispatcherIncarnation string
SessionID string
}
type GetEarningsInParams ¶
type GetIdentitySessionRow ¶ added in v0.3.0
type GetMeasurementProfileParams ¶ added in v0.3.0
type GetOrderSettlementParams ¶ added in v0.3.0
type GetOwnedExecutorParams ¶ added in v0.3.0
type GetOwnedExecutorRow ¶ added in v0.3.0
type GetPaymentReceiptParams ¶ added in v0.3.0
type GetResultOutputSizeRow ¶ added in v0.3.0
type GetRetryRequestParams ¶ added in v0.3.0
type GetSequencedDebugletLogParams ¶ added in v0.3.0
type GetSessionBySelectorRow ¶
type GetUserCredentialParams ¶
type GetUserCredentialRow ¶
type InsertAllowanceGrantParams ¶ added in v0.3.0
type InsertAttributionKeyParams ¶ added in v0.3.0
type InsertChainTransferParams ¶ added in v0.3.0
type InsertMeasurementRequestParams ¶ added in v0.3.0
type InsertOrderSettlementParams ¶ added in v0.3.0
type InsertPaymentReceiptParams ¶ added in v0.3.0
type InterruptUnresumableOutputParams ¶ added in v0.3.0
type LatestAttributionKeyParams ¶ added in v0.3.0
type LatestAttributionKeyRow ¶ added in v0.3.0
type ListAccountCredentialsParams ¶ added in v0.3.0
type ListAccountCredentialsRow ¶ added in v0.3.0
type ListAccountIntentsParams ¶ added in v0.3.0
type ListAccountIntentsRow ¶ added in v0.3.0
type ListAccountReservationsRow ¶ added in v0.3.0
type ListAttributionCandidatesParams ¶ added in v0.3.0
type ListAttributionCandidatesRow ¶ added in v0.3.0
type ListAttributionKeysParams ¶ added in v0.3.0
type ListAttributionKeysRow ¶ added in v0.3.0
type ListDebugletLogsParams ¶
type ListDebugletsParams ¶
type ListExecutorTransfersParams ¶ added in v0.3.0
type ListExecutorTransfersRow ¶ added in v0.3.0
type ListExternalIdentitiesRow ¶ added in v0.3.0
type ListIntentOrdersRow ¶ added in v0.3.0
type ListMeasurementProfilesRow ¶ added in v0.3.0
type ListMeasurementsParams ¶ added in v0.3.0
type ListMeasurementsRow ¶ added in v0.3.0
type ListOwnedExecutorsRow ¶ added in v0.3.0
type ListPendingIdentityLinksParams ¶ added in v0.3.0
type ListPendingIdentityLinksRow ¶ added in v0.3.0
type ListPendingSettlementsParams ¶ added in v0.3.0
type ListPendingSettlementsParams struct {
OutstandingState int64
ExitedState models.DebugletRunState
AfterID int64
RowLimit int64
}
type ListPendingSettlementsRow ¶ added in v0.3.0
type ListUnreclaimedAllocationsParams ¶ added in v0.3.0
type ListUnreclaimedAllocationsParams struct {
ExitedState models.DebugletRunState
EndTime models.UTCTime
}
type ListUnresolvedChainTransfersParams ¶ added in v0.3.0
type MarkRetirementCheckParams ¶ added in v0.3.0
type MarkTransactionPaidParams ¶ added in v0.3.0
type MeasurementCountsParams ¶ added in v0.3.0
type MeasurementCountsRow ¶ added in v0.3.0
type MeasurementExecution ¶ added in v0.3.0
type MeasurementProfile ¶ added in v0.3.0
type MeasurementRequest ¶ added in v0.3.0
type MeasurementRunCountParams ¶ added in v0.3.0
type MeasurementRunsParams ¶ added in v0.3.0
type MeasurementRunsRow ¶ added in v0.3.0
type MeasurementSummary ¶ added in v0.3.0
type OauthIdentity ¶
type OauthLoginAttempt ¶ added in v0.3.0
type OrderSettlement ¶ added in v0.3.0
type OutputAccountUsage ¶ added in v0.3.0
type OutputNodeUsage ¶ added in v0.3.0
type OwnedExecutor ¶ added in v0.3.0
type PayloadTombstone ¶ added in v0.3.0
type PayloadTombstone struct {
DebugletID int64
DeletedAt int64
Reason string
WorkloadSha256 sql.NullString
CertificateSha256 sql.NullString
}
type PaymentReceipt ¶ added in v0.3.0
type PendingIdentityLink ¶ added in v0.3.0
type ProbeAddress ¶ added in v0.3.0
type ProbeStatus ¶ added in v0.3.0
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcknowledgeCancellation ¶ added in v0.3.0
func (q *Queries) AcknowledgeCancellation(ctx context.Context, arg AcknowledgeCancellationParams) error
func (*Queries) AddEarnings ¶
func (q *Queries) AddEarnings(ctx context.Context, arg AddEarningsParams) error
func (*Queries) AddOutputAccountUsage ¶ added in v0.3.0
func (q *Queries) AddOutputAccountUsage(ctx context.Context, arg AddOutputAccountUsageParams) error
func (*Queries) AddOutputNodeUsage ¶ added in v0.3.0
func (q *Queries) AddOutputNodeUsage(ctx context.Context, arg AddOutputNodeUsageParams) error
func (*Queries) AdvanceAttributionRetention ¶ added in v0.3.0
func (*Queries) AdvanceDebugletOutput ¶ added in v0.3.0
func (*Queries) AdvanceLegacyDebugletOutput ¶ added in v0.3.0
func (*Queries) ApproveDeviceLogin ¶ added in v0.3.0
func (*Queries) AttemptCancellation ¶ added in v0.3.0
func (q *Queries) AttemptCancellation(ctx context.Context, arg AttemptCancellationParams) error
func (*Queries) CancelDeviceLogin ¶ added in v0.3.0
func (*Queries) ClaimDebugletOrder ¶
func (*Queries) CompleteDebuglet ¶
func (*Queries) ConsumeAdminAccountRecovery ¶ added in v0.3.0
func (*Queries) ConsumeDeviceLogin ¶ added in v0.3.0
func (*Queries) ConsumeExecutorEnrollmentToken ¶
func (*Queries) ConsumeOAuthAttempt ¶ added in v0.3.0
func (q *Queries) ConsumeOAuthAttempt(ctx context.Context, arg ConsumeOAuthAttemptParams) (ConsumeOAuthAttemptRow, error)
func (*Queries) ConsumePendingIdentityLink ¶ added in v0.3.0
func (q *Queries) ConsumePendingIdentityLink(ctx context.Context, arg ConsumePendingIdentityLinkParams) (ConsumePendingIdentityLinkRow, error)
func (*Queries) CountAccountCredentials ¶ added in v0.3.0
func (*Queries) CountDeviceLogins ¶ added in v0.3.0
func (*Queries) CountRecoveryCredentials ¶ added in v0.3.0
func (*Queries) CreateAPICredential ¶ added in v0.3.0
func (q *Queries) CreateAPICredential(ctx context.Context, arg CreateAPICredentialParams) error
func (*Queries) CreateCancellation ¶ added in v0.3.0
func (q *Queries) CreateCancellation(ctx context.Context, arg CreateCancellationParams) error
func (*Queries) CreateDebuglet ¶
func (*Queries) CreateDebugletLog ¶
func (q *Queries) CreateDebugletLog(ctx context.Context, arg CreateDebugletLogParams) (DebugletLog, error)
func (*Queries) CreateDebugletOrder ¶
func (q *Queries) CreateDebugletOrder(ctx context.Context, arg CreateDebugletOrderParams) (DebugletOrder, error)
func (*Queries) CreateDebugletOutput ¶ added in v0.3.0
func (q *Queries) CreateDebugletOutput(ctx context.Context, arg CreateDebugletOutputParams) error
func (*Queries) CreateDebugletProvenance ¶ added in v0.3.0
func (q *Queries) CreateDebugletProvenance(ctx context.Context, arg CreateDebugletProvenanceParams) error
func (*Queries) CreateDeviceLogin ¶ added in v0.3.0
func (q *Queries) CreateDeviceLogin(ctx context.Context, arg CreateDeviceLoginParams) error
func (*Queries) CreateEarnings ¶
func (*Queries) CreateExecutorEnrollmentToken ¶
func (q *Queries) CreateExecutorEnrollmentToken(ctx context.Context, arg CreateExecutorEnrollmentTokenParams) error
func (*Queries) CreateExternalIdentity ¶ added in v0.3.0
func (q *Queries) CreateExternalIdentity(ctx context.Context, arg CreateExternalIdentityParams) error
func (*Queries) CreateMeasurementProfile ¶ added in v0.3.0
func (*Queries) CreateOAuthAttempt ¶ added in v0.3.0
func (*Queries) CreateOwnedExecutor ¶ added in v0.3.0
func (*Queries) CreatePayloadTombstone ¶ added in v0.3.0
func (q *Queries) CreatePayloadTombstone(ctx context.Context, arg CreatePayloadTombstoneParams) error
func (*Queries) CreateRetryRequest ¶ added in v0.3.0
func (q *Queries) CreateRetryRequest(ctx context.Context, arg CreateRetryRequestParams) error
func (*Queries) CreateSequencedDebugletLog ¶ added in v0.3.0
func (q *Queries) CreateSequencedDebugletLog(ctx context.Context, arg CreateSequencedDebugletLogParams) (DebugletLog, error)
func (*Queries) CreateSession ¶
func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
func (*Queries) CreateTransaction ¶
func (q *Queries) CreateTransaction(ctx context.Context, arg CreateTransactionParams) (Transaction, error)
func (*Queries) CreateUser ¶
func (*Queries) CreateUserWithRole ¶
func (*Queries) DeleteAdminRecoveryCredential ¶ added in v0.3.0
func (*Queries) DeleteExecutorEnrollment ¶
func (*Queries) DeleteExecutorEnrollmentTokens ¶
func (*Queries) DeleteExpiredDeviceLogins ¶ added in v0.3.0
func (*Queries) DeleteExpiredIdentityLinks ¶ added in v0.3.0
func (*Queries) DeleteExpiredOAuthAttempts ¶ added in v0.3.0
func (*Queries) DeleteExpiredSessions ¶
func (*Queries) DeleteExternalIdentity ¶ added in v0.3.0
func (*Queries) DeleteMeasurementLogs ¶ added in v0.3.0
func (*Queries) DeleteMeasurementProfile ¶ added in v0.3.0
func (*Queries) DeleteMeasurementProvenance ¶ added in v0.3.0
func (*Queries) DeleteMeasurementTargets ¶ added in v0.3.0
func (q *Queries) DeleteMeasurementTargets(ctx context.Context, arg DeleteMeasurementTargetsParams) error
func (*Queries) DenyDeviceLogin ¶ added in v0.3.0
func (*Queries) EndAttributionRun ¶ added in v0.3.0
func (q *Queries) EndAttributionRun(ctx context.Context, arg EndAttributionRunParams) error
func (*Queries) EnsureOutputAccountUsage ¶ added in v0.3.0
func (*Queries) ExtendProbeAddress ¶ added in v0.3.0
func (q *Queries) ExtendProbeAddress(ctx context.Context, arg ExtendProbeAddressParams) (int64, error)
Extends the family's latest run when it has the same address.
func (*Queries) FailCancellation ¶ added in v0.3.0
func (q *Queries) FailCancellation(ctx context.Context, arg FailCancellationParams) error
func (*Queries) FindExternalIdentity ¶ added in v0.3.0
func (*Queries) FinishDebugletOutput ¶ added in v0.3.0
func (*Queries) GetAccountRunReservation ¶ added in v0.3.0
func (*Queries) GetAdmittedRuns ¶
func (*Queries) GetAllocationReclamation ¶ added in v0.3.0
func (*Queries) GetAllowance ¶ added in v0.3.0
func (q *Queries) GetAllowance(ctx context.Context, arg GetAllowanceParams) (GetAllowanceRow, error)
The allowance of an account in TEST units: the sum of its grants; consumed, the price of its TEST orders that have a settlement, whichever way it went; and reserved, the price of the other orders of its paid TEST intents.
func (*Queries) GetAllowanceGrant ¶ added in v0.3.0
func (q *Queries) GetAllowanceGrant(ctx context.Context, arg GetAllowanceGrantParams) (GetAllowanceGrantRow, error)
func (*Queries) GetAttributionChain ¶ added in v0.3.0
func (q *Queries) GetAttributionChain(ctx context.Context, arg GetAttributionChainParams) (AttributionChain, error)
func (*Queries) GetAttributionKey ¶ added in v0.3.0
func (*Queries) GetAttributionRetention ¶ added in v0.3.0
func (*Queries) GetCancellation ¶ added in v0.3.0
func (*Queries) GetCredentialUser ¶ added in v0.3.0
func (*Queries) GetDebugletByUUID ¶
func (*Queries) GetDebugletIdentityByUUID ¶
func (*Queries) GetDebugletOrder ¶
func (q *Queries) GetDebugletOrder(ctx context.Context, arg GetDebugletOrderParams) (DebugletOrder, error)
func (*Queries) GetDebugletOutput ¶ added in v0.3.0
func (*Queries) GetDebugletOwnerUUID ¶
func (*Queries) GetDebugletProvenance ¶ added in v0.3.0
func (*Queries) GetDebugletProvenanceSize ¶ added in v0.3.0
func (*Queries) GetDeviceLogin ¶ added in v0.3.0
func (*Queries) GetDeviceLoginByUserCode ¶ added in v0.3.0
func (*Queries) GetEarningsIn ¶
func (*Queries) GetEarningsOf ¶
func (*Queries) GetExecutorEnrollment ¶
func (*Queries) GetExecutorEnrollmentToken ¶
func (*Queries) GetIdentitySession ¶ added in v0.3.0
func (*Queries) GetLatestRefundTransferState ¶ added in v0.3.0
func (*Queries) GetMeasurementExecution ¶ added in v0.3.0
func (*Queries) GetMeasurementProfile ¶ added in v0.3.0
func (*Queries) GetMeasurementRequest ¶ added in v0.3.0
func (*Queries) GetOrderSettlement ¶ added in v0.3.0
func (q *Queries) GetOrderSettlement(ctx context.Context, arg GetOrderSettlementParams) (OrderSettlement, error)
func (*Queries) GetOutputAccountUsage ¶ added in v0.3.0
func (*Queries) GetOutputNodeUsage ¶ added in v0.3.0
func (q *Queries) GetOutputNodeUsage(ctx context.Context) (OutputNodeUsage, error)
func (*Queries) GetOwnedDebugletByUUID ¶
func (*Queries) GetOwnedExecutor ¶ added in v0.3.0
func (q *Queries) GetOwnedExecutor(ctx context.Context, arg GetOwnedExecutorParams) (GetOwnedExecutorRow, error)
func (*Queries) GetPayloadTombstone ¶ added in v0.3.0
func (*Queries) GetPaymentReceipt ¶ added in v0.3.0
func (q *Queries) GetPaymentReceipt(ctx context.Context, arg GetPaymentReceiptParams) (PaymentReceipt, error)
func (*Queries) GetReclaimedDebuglet ¶ added in v0.3.0
func (*Queries) GetResultLogs ¶ added in v0.3.0
func (*Queries) GetResultOutputSize ¶ added in v0.3.0
func (*Queries) GetRetryRequest ¶ added in v0.3.0
func (q *Queries) GetRetryRequest(ctx context.Context, arg GetRetryRequestParams) (RetryRequest, error)
func (*Queries) GetSequencedDebugletLog ¶ added in v0.3.0
func (q *Queries) GetSequencedDebugletLog(ctx context.Context, arg GetSequencedDebugletLogParams) (DebugletLog, error)
func (*Queries) GetSessionBySelector ¶
func (*Queries) GetTransactionByID ¶
func (*Queries) GetTransactionOrders ¶
func (*Queries) GetTransactionOwnerUUID ¶
func (*Queries) GetTransactionState ¶
func (*Queries) GetUnmappedAccountForRecovery ¶ added in v0.3.0
func (*Queries) GetUserByUUID ¶
func (*Queries) GetUserCredential ¶
func (q *Queries) GetUserCredential(ctx context.Context, arg GetUserCredentialParams) (GetUserCredentialRow, error)
func (*Queries) InsertAllowanceGrant ¶ added in v0.3.0
func (*Queries) InsertAttributionKey ¶ added in v0.3.0
func (q *Queries) InsertAttributionKey(ctx context.Context, arg InsertAttributionKeyParams) error
func (*Queries) InsertChainTransfer ¶ added in v0.3.0
func (*Queries) InsertDebugletUser ¶
func (q *Queries) InsertDebugletUser(ctx context.Context, arg InsertDebugletUserParams) error
func (*Queries) InsertMeasurementRequest ¶ added in v0.3.0
func (q *Queries) InsertMeasurementRequest(ctx context.Context, arg InsertMeasurementRequestParams) error
func (*Queries) InsertOrderSettlement ¶ added in v0.3.0
func (q *Queries) InsertOrderSettlement(ctx context.Context, arg InsertOrderSettlementParams) error
func (*Queries) InsertPaymentReceipt ¶ added in v0.3.0
func (q *Queries) InsertPaymentReceipt(ctx context.Context, arg InsertPaymentReceiptParams) error
func (*Queries) InterruptUnresumableOutput ¶ added in v0.3.0
func (q *Queries) InterruptUnresumableOutput(ctx context.Context, arg InterruptUnresumableOutputParams) (int64, error)
Output bound to an ended session can continue only over an enrolled credential. Legacy and unenrolled output therefore ends at its committed prefix.
func (*Queries) LatestAttributionKey ¶ added in v0.3.0
func (q *Queries) LatestAttributionKey(ctx context.Context, arg LatestAttributionKeyParams) (LatestAttributionKeyRow, error)
func (*Queries) ListAccountCredentials ¶ added in v0.3.0
func (q *Queries) ListAccountCredentials(ctx context.Context, arg ListAccountCredentialsParams) ([]ListAccountCredentialsRow, error)
func (*Queries) ListAccountIntents ¶ added in v0.3.0
func (q *Queries) ListAccountIntents(ctx context.Context, arg ListAccountIntentsParams) ([]ListAccountIntentsRow, error)
One page of an account's payment intents, newest expiry first. A cursor names the last intent of the previous page; one that is not the account's own intent selects nothing.
func (*Queries) ListAccountReservations ¶ added in v0.3.0
func (*Queries) ListAttributionCandidates ¶ added in v0.3.0
func (q *Queries) ListAttributionCandidates(ctx context.Context, arg ListAttributionCandidatesParams) ([]ListAttributionCandidatesRow, error)
func (*Queries) ListAttributionKeys ¶ added in v0.3.0
func (q *Queries) ListAttributionKeys(ctx context.Context, arg ListAttributionKeysParams) ([]ListAttributionKeysRow, error)
func (*Queries) ListConnectedProbeIDs ¶ added in v0.3.0
func (*Queries) ListDebugletLogs ¶
func (q *Queries) ListDebugletLogs(ctx context.Context, arg ListDebugletLogsParams) ([]DebugletLog, error)
func (*Queries) ListDebuglets ¶
func (*Queries) ListDebugletsByUserUUID ¶
func (*Queries) ListDebugletsEndAfter ¶
func (*Queries) ListEnrolledExecutorIDs ¶ added in v0.3.0
func (*Queries) ListExecutorTransfers ¶ added in v0.3.0
func (q *Queries) ListExecutorTransfers(ctx context.Context, arg ListExecutorTransfersParams) ([]ListExecutorTransfersRow, error)
The newest outbound chain transfers that name an executor.
func (*Queries) ListExpiredPayloads ¶ added in v0.3.0
func (*Queries) ListExternalIdentities ¶ added in v0.3.0
func (*Queries) ListIntentOrders ¶ added in v0.3.0
func (q *Queries) ListIntentOrders(ctx context.Context, transactionID string) ([]ListIntentOrdersRow, error)
The orders of one payment intent with the run each one admitted, if any.
func (*Queries) ListLatestProbeAddresses ¶ added in v0.3.0
func (q *Queries) ListLatestProbeAddresses(ctx context.Context) ([]ProbeAddress, error)
func (*Queries) ListMeasurementProfiles ¶ added in v0.3.0
func (*Queries) ListMeasurements ¶ added in v0.3.0
func (q *Queries) ListMeasurements(ctx context.Context, arg ListMeasurementsParams) ([]ListMeasurementsRow, error)
func (*Queries) ListOwnedExecutors ¶ added in v0.3.0
func (*Queries) ListPaymentReceiptsByNonce ¶ added in v0.3.0
func (*Queries) ListPendingIdentityLinks ¶ added in v0.3.0
func (q *Queries) ListPendingIdentityLinks(ctx context.Context, arg ListPendingIdentityLinksParams) ([]ListPendingIdentityLinksRow, error)
func (*Queries) ListPendingSettlements ¶ added in v0.3.0
func (q *Queries) ListPendingSettlements(ctx context.Context, arg ListPendingSettlementsParams) ([]ListPendingSettlementsRow, error)
An order covered by a refund transfer in any state is never listed: the transfer's own reconciliation resolves it, so a pass cannot send it twice.
func (*Queries) ListProbeStatus ¶ added in v0.3.0
func (q *Queries) ListProbeStatus(ctx context.Context) ([]ProbeStatus, error)
func (*Queries) ListRetirementCandidates ¶ added in v0.3.0
func (*Queries) ListUnreclaimedAllocations ¶ added in v0.3.0
func (*Queries) ListUnresolvedChainTransfers ¶ added in v0.3.0
func (q *Queries) ListUnresolvedChainTransfers(ctx context.Context, arg ListUnresolvedChainTransfersParams) ([]ChainTransfer, error)
func (*Queries) ListUserUUIDs ¶
func (*Queries) LockAccountForRecovery ¶ added in v0.3.0
func (*Queries) LockCredentialSession ¶ added in v0.3.0
func (*Queries) LockDeviceLogin ¶ added in v0.3.0
func (*Queries) MarkRetirementCheck ¶ added in v0.3.0
func (q *Queries) MarkRetirementCheck(ctx context.Context, arg MarkRetirementCheckParams) error
func (*Queries) MarkTransactionPaid ¶ added in v0.3.0
func (*Queries) MeasurementCounts ¶ added in v0.3.0
func (q *Queries) MeasurementCounts(ctx context.Context, arg MeasurementCountsParams) ([]MeasurementCountsRow, error)
func (*Queries) MeasurementRunCount ¶ added in v0.3.0
func (*Queries) MeasurementRuns ¶ added in v0.3.0
func (q *Queries) MeasurementRuns(ctx context.Context, arg MeasurementRunsParams) ([]MeasurementRunsRow, error)
func (*Queries) PruneAttributionChains ¶ added in v0.3.0
func (*Queries) PruneAttributionKeys ¶ added in v0.3.0
A key is kept until its epoch ended more than one epoch before the cutoff, matching the runs kept above. Every key a lookup at or after retained_from needs, of the packet's epoch or a later one it is derived from, is kept.
func (*Queries) PruneAttributionRuns ¶ added in v0.3.0
A lookup at a time t lists the runs active within one epoch of t, so a run stays on record until its interval ended more than one epoch before the cutoff: every lookup at or after retained_from still finds it.
func (*Queries) PruneProbeAddresses ¶ added in v0.3.0
Keeps every family's latest run, whatever its age.
func (*Queries) ReclaimAllocation ¶ added in v0.3.0
func (q *Queries) ReclaimAllocation(ctx context.Context, arg ReclaimAllocationParams) error
func (*Queries) RecordAdminAccountRecovery ¶ added in v0.3.0
func (q *Queries) RecordAdminAccountRecovery(ctx context.Context, arg RecordAdminAccountRecoveryParams) error
func (*Queries) RecordAttributionChain ¶ added in v0.3.0
func (q *Queries) RecordAttributionChain(ctx context.Context, arg RecordAttributionChainParams) error
func (*Queries) RecordAttributionRun ¶ added in v0.3.0
func (q *Queries) RecordAttributionRun(ctx context.Context, arg RecordAttributionRunParams) error
func (*Queries) RecordMeasurementStarted ¶ added in v0.3.0
func (q *Queries) RecordMeasurementStarted(ctx context.Context, arg RecordMeasurementStartedParams) error
func (*Queries) RecordMeasurementTerminal ¶ added in v0.3.0
func (q *Queries) RecordMeasurementTerminal(ctx context.Context, arg RecordMeasurementTerminalParams) error
func (*Queries) RecordProbeConnected ¶ added in v0.3.0
func (q *Queries) RecordProbeConnected(ctx context.Context, arg RecordProbeConnectedParams) error
A registration within 120 seconds (probeStreakGrace) of the last connected record of a connected row (a replacement session, or a dispatcher restart) continues that row's streak and its uptime; otherwise the old streak ended at its last_connected and a new one starts now.
func (*Queries) RecordProbeDisconnected ¶ added in v0.3.0
The executor was last known connected at last_connected; it disconnected then, as far as this record can tell.
func (*Queries) RefreshExternalIdentity ¶ added in v0.3.0
func (q *Queries) RefreshExternalIdentity(ctx context.Context, arg RefreshExternalIdentityParams) error
func (*Queries) RefundPaidTransaction ¶ added in v0.3.0
func (*Queries) RefundUnadmittedTransaction ¶ added in v0.3.0
func (*Queries) ReleaseExpiredAllowanceIntents ¶ added in v0.3.0
func (q *Queries) ReleaseExpiredAllowanceIntents(ctx context.Context, arg ReleaseExpiredAllowanceIntentsParams) (int64, error)
Expires the account's paid TEST intents past their expiry that admitted no run. Admission claims an order only while its transaction is paid, so an intent is either released here or admitted, never both.
func (*Queries) ReleasePayout ¶ added in v0.3.0
func (q *Queries) ReleasePayout(ctx context.Context, arg ReleasePayoutParams) error
func (*Queries) ReserveAccountRun ¶ added in v0.3.0
func (q *Queries) ReserveAccountRun(ctx context.Context, arg ReserveAccountRunParams) error
func (*Queries) ReserveAllowanceIntent ¶ added in v0.3.0
func (q *Queries) ReserveAllowanceIntent(ctx context.Context, arg ReserveAllowanceIntentParams) (int64, error)
Creates a paid TEST transaction for the account only if its remaining allowance, computed as GetAllowance does, covers price. The check and the insert are one statement, so two intents cannot both spend the same rest.
func (*Queries) ReservePayout ¶ added in v0.3.0
func (*Queries) RetireAccountRun ¶ added in v0.3.0
func (*Queries) RevokeAccountCredential ¶ added in v0.3.0
func (*Queries) RevokeAdminAccountRecovery ¶ added in v0.3.0
func (*Queries) RevokeSessionBySelector ¶
func (*Queries) RevokeUserSessions ¶
func (*Queries) SetExecutorEnrollment ¶
func (q *Queries) SetExecutorEnrollment(ctx context.Context, arg SetExecutorEnrollmentParams) error
func (*Queries) SetRefundAddress ¶
func (q *Queries) SetRefundAddress(ctx context.Context, arg SetRefundAddressParams) error
func (*Queries) SetTransactionOwner ¶
func (q *Queries) SetTransactionOwner(ctx context.Context, arg SetTransactionOwnerParams) error
func (*Queries) SetTransactionPricingRule ¶ added in v0.3.0
func (q *Queries) SetTransactionPricingRule(ctx context.Context, arg SetTransactionPricingRuleParams) error
func (*Queries) SetUserRole ¶
func (*Queries) SettleEarning ¶
func (q *Queries) SettleEarning(ctx context.Context, arg SettleEarningParams) error
func (*Queries) StartProbeAddress ¶ added in v0.3.0
func (q *Queries) StartProbeAddress(ctx context.Context, arg StartProbeAddressParams) (int64, error)
Starts a new run, unless a run already covers this time, so an older observation never opens a run after a newer one.
func (*Queries) StorePendingIdentityLink ¶ added in v0.3.0
func (q *Queries) StorePendingIdentityLink(ctx context.Context, arg StorePendingIdentityLinkParams) error
func (*Queries) TouchAttributionChain ¶ added in v0.3.0
func (q *Queries) TouchAttributionChain(ctx context.Context, arg TouchAttributionChainParams) error
func (*Queries) TouchProbeConnected ¶ added in v0.3.0
func (*Queries) TransitionDebugletOrder ¶ added in v0.3.0
func (*Queries) UpdateChainTransfer ¶ added in v0.3.0
func (*Queries) UpdateDebugletOrderState ¶
func (q *Queries) UpdateDebugletOrderState(ctx context.Context, arg UpdateDebugletOrderStateParams) (DebugletOrder, error)
func (*Queries) UpdateDebugletState ¶
func (*Queries) UpdateDeviceLoginPoll ¶ added in v0.3.0
func (*Queries) UpdateMeasurementProfile ¶ added in v0.3.0
func (*Queries) UpdateTransactionState ¶
func (q *Queries) UpdateTransactionState(ctx context.Context, arg UpdateTransactionStateParams) (TransactionState, error)
func (*Queries) UpdateTransactionStatus ¶
func (q *Queries) UpdateTransactionStatus(ctx context.Context, arg UpdateTransactionStatusParams) error
func (*Queries) UpsertUserCredential ¶
func (q *Queries) UpsertUserCredential(ctx context.Context, arg UpsertUserCredentialParams) error
type ReclaimAllocationParams ¶ added in v0.3.0
type RecordAdminAccountRecoveryParams ¶ added in v0.3.0
type RecordAttributionChainParams ¶ added in v0.3.0
type RecordAttributionRunParams ¶ added in v0.3.0
type RecordMeasurementStartedParams ¶ added in v0.3.0
type RecordMeasurementTerminalParams ¶ added in v0.3.0
type RecordProbeConnectedParams ¶ added in v0.3.0
type RefreshExternalIdentityParams ¶ added in v0.3.0
type RefundPaidTransactionParams ¶ added in v0.3.0
type RefundUnadmittedTransactionParams ¶ added in v0.3.0
type ReleaseExpiredAllowanceIntentsParams ¶ added in v0.3.0
type ReleasePayoutParams ¶ added in v0.3.0
type ReserveAccountRunParams ¶ added in v0.3.0
type ReserveAllowanceIntentParams ¶ added in v0.3.0
type ReservePayoutParams ¶ added in v0.3.0
type RetireAccountRunParams ¶ added in v0.3.0
type RetryRequest ¶ added in v0.3.0
type RevokeAccountCredentialParams ¶ added in v0.3.0
type RevokeAdminAccountRecoveryParams ¶ added in v0.3.0
type SetRefundAddressParams ¶
type SetTransactionPricingRuleParams ¶ added in v0.3.0
type SetUserRoleParams ¶
type SettleEarningParams ¶
type StartProbeAddressParams ¶ added in v0.3.0
type StorePendingIdentityLinkParams ¶ added in v0.3.0
type TouchAttributionChainParams ¶ added in v0.3.0
type TouchProbeConnectedParams ¶ added in v0.3.0
type Transaction ¶
type TransactionState ¶
type TransactionUser ¶
type TransitionDebugletOrderParams ¶ added in v0.3.0
type UpdateChainTransferParams ¶ added in v0.3.0
type UpdateDebugletStateParams ¶
type UpdateDebugletStateParams struct {
State models.DebugletRunState
Uuid uuid.UUID
ExitedState models.DebugletRunState
StateRank models.DebugletRunState
ExecutorID string
DispatcherIncarnation string
SessionID string
}
type UpdateDeviceLoginPollParams ¶ added in v0.3.0
type UpdateMeasurementProfileParams ¶ added in v0.3.0
Source Files
¶
- account_limits.sql.go
- account_recovery.sql.go
- allocation_reclamations.sql.go
- allowances.sql.go
- attribution.sql.go
- auth.sql.go
- cancellation.sql.go
- client_credentials.sql.go
- db.go
- debuglet.sql.go
- economics.sql.go
- enrollment.sql.go
- identities.sql.go
- measurement_execution.sql.go
- measurement_profiles.sql.go
- measurements.sql.go
- migrations.go
- models.go
- output.sql.go
- owned_executors.sql.go
- probe_status.sql.go
- result.sql.go
- retry.sql.go
- settlement.sql.go
- transactions.sql.go
- users.sql.go