database

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MigrationFS

func MigrationFS() fs.FS

MigrationFS exposes the canonical SQL migrations without global registration.

Types

type AccountRecoveryAudit added in v0.3.0

type AccountRecoveryAudit struct {
	Selector            string
	UserID              int64
	CaseReference       string
	IssuedByUid         int64
	IssuedAt            int64
	ExpiresAt           int64
	ConsumedAt          int64
	RevokedAt           int64
	RevokedByUid        sql.NullInt64
	RevocationReference string
}

type AccountRunReservation added in v0.3.0

type AccountRunReservation struct {
	DebugletID          int64
	AccountID           int64
	QueuedBytes         int64
	RetiredAt           sql.NullInt64
	LastRetirementCheck int64
}

type AcknowledgeCancellationParams added in v0.3.0

type AcknowledgeCancellationParams struct {
	AcknowledgedAt sql.NullInt64
	DebugletID     int64
}

type AddEarningsParams

type AddEarningsParams struct {
	Amount     int64
	ExecutorID string
	Currency   string
}

type AddOutputAccountUsageParams added in v0.3.0

type AddOutputAccountUsageParams struct {
	Bytes     int64
	Frames    int64
	AccountID int64
}

type AddOutputNodeUsageParams added in v0.3.0

type AddOutputNodeUsageParams struct {
	Bytes  int64
	Frames int64
}

type AdvanceDebugletOutputParams added in v0.3.0

type AdvanceDebugletOutputParams struct {
	Sequence   int64
	Bytes      int64
	LogID      int64
	DebugletID int64
}

type AdvanceLegacyDebugletOutputParams added in v0.3.0

type AdvanceLegacyDebugletOutputParams struct {
	Bytes      int64
	LogID      int64
	DebugletID int64
}

type AllocationReclamation added in v0.3.0

type AllocationReclamation struct {
	DebugletID  int64
	ReclaimedAt models.UTCTime
}

type AllowanceGrant added in v0.3.0

type AllowanceGrant struct {
	ID             int64
	UserID         int64
	Amount         int64
	Currency       string
	GrantedBy      int64
	Reason         string
	IdempotencyKey string
	GrantedAt      models.UTCTime
}

type ApproveDeviceLoginParams added in v0.3.0

type ApproveDeviceLoginParams struct {
	UserID          sql.NullInt64
	ApproverSession string
	Selector        string
	Now             int64
}

type AttemptCancellationParams added in v0.3.0

type AttemptCancellationParams struct {
	AttemptedAt sql.NullInt64
	DebugletID  int64
}

type AttributionChain added in v0.3.0

type AttributionChain struct {
	ExecutorID    string
	ChainID       string
	Anchor        []byte
	T0Ns          int64
	IntervalNs    int64
	DelayEpochs   int64
	ChainLength   int64
	TagSpec       int64
	FirstSeenNs   int64
	LastSeenNs    int64
	ScheduleProof []byte
}

type AttributionKey added in v0.3.0

type AttributionKey struct {
	ExecutorID    string
	ChainID       string
	Epoch         int64
	Key           []byte
	DisclosedAtNs int64
}

type AttributionReceiptKey added in v0.3.0

type AttributionReceiptKey struct {
	KeyID       string
	PublicKey   []byte
	ValidFromNs int64
	ValidToNs   sql.NullInt64
}

type AttributionRetention added in v0.3.0

type AttributionRetention struct {
	Singleton      int64
	RetainedFromNs int64
}

type AttributionRun added in v0.3.0

type AttributionRun struct {
	DebugletID       int64
	ChainID          string
	SourceIp         string
	SourceIpObserved int64
	ActiveFromNs     int64
	ActiveToNs       int64
}

type AttributionVerifyBudget added in v0.3.0

type AttributionVerifyBudget struct {
	ExecutorID string
	ChainID    string
	Epoch      int64
	Used       int64
}

type ChainTransfer added in v0.3.0

type ChainTransfer struct {
	ID                int64
	Kind              string
	ExecutorID        string
	TransactionID     string
	OrderID           sql.NullInt64
	Amount            int64
	Currency          string
	Receiver          string
	State             string
	Digest            string
	SignedTransaction []byte
	Signature         string
	Detail            string
	CreatedAt         models.UTCTime
	UpdatedAt         models.UTCTime
}

type ClaimDebugletOrderParams

type ClaimDebugletOrderParams struct {
	DebugletID       sql.NullInt64
	TransactionID    string
	OrderID          int64
	OutstandingState int64
	PaidStatus       int64
}

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 ConsumeDeviceLoginParams struct {
	Selector string
	Now      int64
}

type ConsumeOAuthAttemptParams added in v0.3.0

type ConsumeOAuthAttemptParams struct {
	StateHash []byte
	Provider  string
	ExpiresAt models.UTCTime
}

type ConsumeOAuthAttemptRow added in v0.3.0

type ConsumeOAuthAttemptRow struct {
	Verifier        string
	Nonce           string
	Purpose         string
	SessionSelector string
}

type ConsumePendingIdentityLinkParams added in v0.3.0

type ConsumePendingIdentityLinkParams struct {
	UserID          int64
	Provider        string
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type ConsumePendingIdentityLinkRow added in v0.3.0

type ConsumePendingIdentityLinkRow struct {
	Issuer  string
	Subject string
	Login   string
}

type CountAccountCredentialsParams added in v0.3.0

type CountAccountCredentialsParams struct {
	UserID int64
	Now    models.UTCTime
}

type CreateAPICredentialParams added in v0.3.0

type CreateAPICredentialParams struct {
	Selector     string
	VerifierHash []byte
	UserID       int64
	CreatedAt    models.UTCTime
	ExpiresAt    models.UTCTime
	Audience     string
	Scopes       string
	Label        string
}

type CreateCancellationParams added in v0.3.0

type CreateCancellationParams struct {
	DebugletID  int64
	RequestID   string
	Reason      string
	RequestedAt int64
}

type CreateDebugletLogParams

type CreateDebugletLogParams struct {
	Timestamp             models.UTCTime
	Output                []byte
	Uuid                  uuid.UUID
	ExecutorID            string
	DispatcherIncarnation string
	SessionID             string
}

type CreateDebugletOrderParams

type CreateDebugletOrderParams struct {
	TransactionID string
	OrderID       int64
	ExecutorID    string
	Price         int64
	Currency      string
	RefundAddress string
	State         int64
}

type CreateDebugletOutputParams added in v0.3.0

type CreateDebugletOutputParams struct {
	OutputVersion    int64
	OwnerFingerprint string
	Uuid             uuid.UUID
}

type CreateDebugletParams

type CreateDebugletParams struct {
	Uuid                  uuid.UUID
	StartTime             models.UTCTime
	EndTime               models.UTCTime
	Usage                 int64
	CeilBw                int64
	ExecutorID            string
	Addresses             models.CommaSeparatedList
	State                 models.DebugletRunState
	TransactionID         string
	OrderID               int64
	DispatcherIncarnation string
	SessionID             string
}

type CreateDebugletProvenanceParams added in v0.3.0

type CreateDebugletProvenanceParams struct {
	DebugletID int64
	Document   string
}

type CreateDeviceLoginParams added in v0.3.0

type CreateDeviceLoginParams struct {
	Selector     string
	VerifierHash []byte
	UserCodeHash []byte
	Audience     string
	Scopes       string
	Label        string
	ExpiresAt    int64
	NextPollAt   int64
}

type CreateEarningsParams

type CreateEarningsParams struct {
	ExecutorID       string
	Currency         string
	SuiWalletAddress string
}

type CreateExecutorEnrollmentTokenParams

type CreateExecutorEnrollmentTokenParams struct {
	Selector   string
	ExecutorID string
	SecretHash []byte
	CreatedAt  models.UTCTime
	ExpiresAt  models.UTCTime
}

type CreateExperimentBarrierParams added in v0.3.0

type CreateExperimentBarrierParams struct {
	TransactionID string
	DeadlineNs    int64
}

type CreateExternalIdentityParams added in v0.3.0

type CreateExternalIdentityParams struct {
	Provider  string
	Issuer    string
	Subject   string
	UserID    int64
	Login     string
	CreatedAt models.UTCTime
	UpdatedAt models.UTCTime
}

type CreateMeasurementProfileParams added in v0.3.0

type CreateMeasurementProfileParams struct {
	ID       string
	Document string
	Uuid     uuid.UUID
}

type CreateOAuthAttemptParams added in v0.3.0

type CreateOAuthAttemptParams struct {
	StateHash       []byte
	Provider        string
	Verifier        string
	Nonce           string
	Purpose         string
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type CreateOwnedExecutorParams added in v0.3.0

type CreateOwnedExecutorParams struct {
	ExecutorID string
	Name       string
	CreatedAt  models.UTCTime
	Uuid       uuid.UUID
}

type CreatePayloadTombstoneParams added in v0.3.0

type CreatePayloadTombstoneParams struct {
	DeletedAt  int64
	Reason     string
	DebugletID int64
}

type CreateRetryRequestParams added in v0.3.0

type CreateRetryRequestParams struct {
	CallerScope    string
	RequestID      string
	ParentRunID    string
	TransactionID  string
	RequestHash    string
	IntentMetadata string
}

type CreateSequencedDebugletLogParams added in v0.3.0

type CreateSequencedDebugletLogParams struct {
	DebugletID     int64
	Timestamp      models.UTCTime
	Output         []byte
	SourceSequence sql.NullInt64
}

type CreateSessionParams

type CreateSessionParams struct {
	Selector        string
	VerifierHash    []byte
	CsrfHash        []byte
	UserID          int64
	CreatedAt       models.UTCTime
	ExpiresAt       models.UTCTime
	AuthenticatedAt models.UTCTime
}

type CreateTransactionParams

type CreateTransactionParams struct {
	ID        string
	AuthKey   string
	Price     int64
	Currency  string
	Method    string
	ExpiresAt models.UTCTime
	Status    int64
	Hash      string
}

type CreateUserParams

type CreateUserParams struct {
	Uuid uuid.UUID
	Name string
}

type CreateUserWithRoleParams

type CreateUserWithRoleParams struct {
	Uuid uuid.UUID
	Name string
	Role string
}

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 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 DebugletCancellation struct {
	DebugletID         int64
	RequestID          string
	Reason             string
	RequestedAt        int64
	AttemptedAt        sql.NullInt64
	AcknowledgedAt     sql.NullInt64
	Failure            string
	TerminalRecordedAt sql.NullInt64
}

type DebugletLog

type DebugletLog struct {
	ID             int64
	DebugletID     int64
	Timestamp      models.UTCTime
	Output         []byte
	SourceSequence sql.NullInt64
}

type DebugletOrder

type DebugletOrder struct {
	TransactionID string
	OrderID       int64
	ExecutorID    string
	Price         int64
	Currency      string
	State         int64
	RefundAddress string
	DebugletID    sql.NullInt64
}

type DebugletOutput added in v0.3.0

type DebugletOutput 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
}

type DebugletProvenance added in v0.3.0

type DebugletProvenance struct {
	DebugletID int64
	Document   string
}

type DebugletUser

type DebugletUser struct {
	DebugletID int64
	UserID     int64
}

type DeleteExternalIdentityParams added in v0.3.0

type DeleteExternalIdentityParams struct {
	Provider string
	UserID   int64
}

type DeleteMeasurementProfileParams added in v0.3.0

type DeleteMeasurementProfileParams struct {
	ID   string
	Uuid uuid.UUID
}

type DeleteMeasurementTargetsParams added in v0.3.0

type DeleteMeasurementTargetsParams struct {
	PublicError sql.NullString
	DebugletID  int64
}

type DenyDeviceLoginParams added in v0.3.0

type DenyDeviceLoginParams struct {
	Selector string
	Now      int64
}

type DestinationPolicyEvent added in v0.3.0

type DestinationPolicyEvent struct {
	ID            int64
	Destination   string
	Kind          string
	LimitBps      sql.NullInt64
	Reason        string
	Actor         string
	RequestedAtNs int64
	ExpiresAtNs   sql.NullInt64
	Revision      int64
}

type DeviceLogin added in v0.3.0

type DeviceLogin struct {
	Selector        string
	VerifierHash    []byte
	UserCodeHash    []byte
	Audience        string
	Scopes          string
	Label           string
	ExpiresAt       int64
	NextPollAt      int64
	PollInterval    int64
	State           string
	ApproverSession string
	UserID          sql.NullInt64
}

type Earning

type Earning struct {
	ExecutorID       string
	Currency         string
	TotalIncome      int64
	CurrentBalance   int64
	SuiWalletAddress string
}

type EgressClock added in v0.3.0

type EgressClock struct {
	ID         int64
	ObservedAt int64
}

type EgressGrant added in v0.3.0

type EgressGrant struct {
	RunUuid     string
	PolicyHash  string
	WindowStart int64
	WindowEnd   int64
	GrantJson   []byte
}

type EgressReservation added in v0.3.0

type EgressReservation struct {
	RunUuid           string
	Bucket            string
	BitsPerSecond     int64
	BurstBytes        int64
	Bytes             int64
	AttemptsPerSecond int64
	AttemptBurst      int64
	Attempts          int64
	Targets           int64
}

type EndAttributionRunParams added in v0.3.0

type EndAttributionRunParams struct {
	EndedNs int64
	Uuid    uuid.UUID
}

type ExecutorEnrollment

type ExecutorEnrollment struct {
	ExecutorID  string
	Fingerprint string
	EnrolledAt  models.UTCTime
}

type ExecutorEnrollmentToken

type ExecutorEnrollmentToken struct {
	Selector   string
	ExecutorID string
	SecretHash []byte
	CreatedAt  models.UTCTime
	ExpiresAt  models.UTCTime
}

type ExperimentBarrier added in v0.3.0

type ExperimentBarrier struct {
	TransactionID string
	DeadlineNs    int64
	StartTimeNs   int64
}

type ExperimentReadiness added in v0.3.0

type ExperimentReadiness struct {
	DebugletID int64
	Metadata   []byte
	ReadyAtNs  int64
}

type ExtendProbeAddressParams added in v0.3.0

type ExtendProbeAddressParams struct {
	At         int64
	ExecutorID string
	Family     int64
	Address    string
}

type FailCancellationParams added in v0.3.0

type FailCancellationParams struct {
	Failure    string
	DebugletID int64
}

type FindExternalIdentityParams added in v0.3.0

type FindExternalIdentityParams struct {
	Issuer  string
	Subject string
}

type FinishDebugletOutputParams added in v0.3.0

type FinishDebugletOutputParams struct {
	Status     string
	Reason     string
	DebugletID int64
	Sequence   int64
}

type GetAdmittedRunsRow

type GetAdmittedRunsRow struct {
	OrderID int64
	Uuid    uuid.UUID
}

type GetAllowanceGrantParams added in v0.3.0

type GetAllowanceGrantParams struct {
	UserUuid       uuid.UUID
	IdempotencyKey string
}

type GetAllowanceGrantRow added in v0.3.0

type GetAllowanceGrantRow struct {
	ID             int64
	Amount         int64
	Currency       string
	Reason         string
	IdempotencyKey string
	GrantedAt      models.UTCTime
	GrantedBy      uuid.UUID
}

type GetAllowanceParams added in v0.3.0

type GetAllowanceParams struct {
	PaidStatus int64
	UserUuid   uuid.UUID
}

type GetAllowanceRow added in v0.3.0

type GetAllowanceRow struct {
	Granted  int64
	Consumed int64
	Reserved int64
}

type GetAttributionChainParams added in v0.3.0

type GetAttributionChainParams struct {
	ExecutorID string
	ChainID    string
}

type GetAttributionKeyParams added in v0.3.0

type GetAttributionKeyParams struct {
	ExecutorID string
	ChainID    string
	Epoch      int64
}

type GetAttributionVerifyBudgetParams added in v0.3.0

type GetAttributionVerifyBudgetParams struct {
	ExecutorID string
	ChainID    string
	Epoch      int64
}

type GetDebugletIdentityByUUIDRow

type GetDebugletIdentityByUUIDRow struct {
	ExecutorID            string
	DispatcherIncarnation string
	SessionID             string
}

type GetDebugletOrderParams

type GetDebugletOrderParams struct {
	TransactionID string
	OrderID       int64
}

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 GetEarningsInParams struct {
	ExecutorID string
	Currency   string
}

type GetExecutorEnrollmentTokenRow

type GetExecutorEnrollmentTokenRow struct {
	ExecutorID string
	SecretHash []byte
	ExpiresAt  models.UTCTime
}

type GetExperimentMembersRow added in v0.3.0

type GetExperimentMembersRow struct {
	Debuglet  Debuglet
	Metadata  []byte
	ReadyAtNs sql.NullInt64
	Cancelled bool
	Reclaimed bool
}

type GetIdentitySessionRow added in v0.3.0

type GetIdentitySessionRow struct {
	UserID          int64
	CreatedAt       models.UTCTime
	AuthenticatedAt models.UTCTime
	ExpiresAt       models.UTCTime
	Revoked         int64
	Uuid            uuid.UUID
}

type GetMeasurementProfileParams added in v0.3.0

type GetMeasurementProfileParams struct {
	ID   string
	Uuid uuid.UUID
}

type GetOrderSettlementParams added in v0.3.0

type GetOrderSettlementParams struct {
	TransactionID string
	OrderID       int64
}

type GetOwnedDebugletByUUIDParams

type GetOwnedDebugletByUUIDParams struct {
	Uuid                  uuid.UUID
	ExecutorID            string
	DispatcherIncarnation string
	SessionID             string
}

type GetOwnedExecutorParams added in v0.3.0

type GetOwnedExecutorParams struct {
	Uuid       uuid.UUID
	ExecutorID string
}

type GetOwnedExecutorRow added in v0.3.0

type GetOwnedExecutorRow struct {
	ExecutorID  string
	Name        string
	DisplayName string
	City        string
	Country     string
	Network     string
	Enrolled    bool
}

type GetPaymentReceiptParams added in v0.3.0

type GetPaymentReceiptParams struct {
	TxDigest string
	EventSeq int64
}

type GetResultOutputSizeRow added in v0.3.0

type GetResultOutputSizeRow struct {
	Frames int64
	Bytes  int64
}

type GetRetryRequestParams added in v0.3.0

type GetRetryRequestParams struct {
	CallerScope string
	RequestID   string
}

type GetSequencedDebugletLogParams added in v0.3.0

type GetSequencedDebugletLogParams struct {
	DebugletID     int64
	SourceSequence sql.NullInt64
}

type GetSessionBySelectorRow

type GetSessionBySelectorRow struct {
	VerifierHash    []byte
	CsrfHash        []byte
	ExpiresAt       models.UTCTime
	Revoked         int64
	Kind            string
	Audience        string
	Scopes          string
	CreatedAt       models.UTCTime
	AuthenticatedAt models.UTCTime
	Uuid            uuid.UUID
	Name            string
	Role            string
}

type GetUserCredentialParams

type GetUserCredentialParams struct {
	Selector string
	Kind     string
}

type GetUserCredentialRow

type GetUserCredentialRow struct {
	UserID     int64
	SecretHash []byte
	Uuid       uuid.UUID
	Name       string
	Role       string
}

type InsertAllowanceGrantParams added in v0.3.0

type InsertAllowanceGrantParams struct {
	Amount         int64
	Reason         string
	IdempotencyKey string
	GrantedAt      models.UTCTime
	GrantedBy      uuid.UUID
	UserUuid       uuid.UUID
}

type InsertAttributionKeyParams added in v0.3.0

type InsertAttributionKeyParams struct {
	ExecutorID    string
	ChainID       string
	Epoch         int64
	Key           []byte
	DisclosedAtNs int64
}

type InsertAttributionReceiptKeyParams added in v0.3.0

type InsertAttributionReceiptKeyParams struct {
	KeyID       string
	PublicKey   []byte
	ValidFromNs int64
}

type InsertChainTransferParams added in v0.3.0

type InsertChainTransferParams struct {
	Kind              string
	ExecutorID        string
	TransactionID     string
	OrderID           sql.NullInt64
	Amount            int64
	Currency          string
	Receiver          string
	State             string
	Digest            string
	SignedTransaction []byte
	Signature         string
	Detail            string
	CreatedAt         models.UTCTime
	UpdatedAt         models.UTCTime
}

type InsertDebugletUserParams

type InsertDebugletUserParams struct {
	DebUuid  uuid.UUID
	UserUuid uuid.UUID
}

type InsertMeasurementRequestParams added in v0.3.0

type InsertMeasurementRequestParams struct {
	DebugletID int64
	Document   string
}

type InsertOrderSettlementParams added in v0.3.0

type InsertOrderSettlementParams struct {
	TransactionID string
	OrderID       int64
	Kind          string
	Amount        int64
	Currency      string
	ExecutorID    string
	DebugletID    sql.NullInt64
	RecordedAt    models.UTCTime
}

type InsertPaymentReceiptParams added in v0.3.0

type InsertPaymentReceiptParams struct {
	TxDigest    string
	EventSeq    int64
	Nonce       string
	Disposition string
	Amount      string
	CoinType    string
	Receiver    string
	Checkpoint  sql.NullInt64
	ObservedAt  models.UTCTime
	Detail      string
}

type InterruptUnresumableOutputParams added in v0.3.0

type InterruptUnresumableOutputParams struct {
	DispatcherIncarnation string
	SessionID             string
}

type LatestAttributionKeyParams added in v0.3.0

type LatestAttributionKeyParams struct {
	ExecutorID string
	ChainID    string
}

type LatestAttributionKeyRow added in v0.3.0

type LatestAttributionKeyRow struct {
	Epoch int64
	Key   []byte
}

type ListAccountCredentialsParams added in v0.3.0

type ListAccountCredentialsParams struct {
	Uuid uuid.UUID
	Now  models.UTCTime
}

type ListAccountCredentialsRow added in v0.3.0

type ListAccountCredentialsRow struct {
	Selector  string
	Kind      string
	Audience  string
	Scopes    string
	Label     string
	CreatedAt models.UTCTime
	ExpiresAt models.UTCTime
}

type ListAccountIntentsParams added in v0.3.0

type ListAccountIntentsParams struct {
	UserUuid  uuid.UUID
	Before    string
	PageLimit int64
}

type ListAccountIntentsRow added in v0.3.0

type ListAccountIntentsRow struct {
	ID          string
	Method      string
	Status      int64
	Price       int64
	Currency    string
	ExpiresAt   models.UTCTime
	PricingRule string
}

type ListAccountReservationsRow added in v0.3.0

type ListAccountReservationsRow struct {
	DebugletID  int64
	QueuedBytes int64
	StartTime   models.UTCTime
	EndTime     models.UTCTime
}

type ListAttributionCandidatesParams added in v0.3.0

type ListAttributionCandidatesParams struct {
	SourceIp string
	AtNs     int64
	MaxRows  int64
}

type ListAttributionCandidatesRow added in v0.3.0

type ListAttributionCandidatesRow struct {
	Uuid                 uuid.UUID
	ExecutorID           string
	SourceIpObserved     int64
	ActiveFromNs         int64
	ActiveToNs           int64
	ChainID              string
	Anchor               []byte
	T0Ns                 int64
	IntervalNs           int64
	DelayEpochs          int64
	ChainLength          int64
	TagSpec              int64
	ScheduleProof        []byte
	DisclosedThrough     int64
	DisclosedThroughAtNs int64
}

type ListAttributionKeysParams added in v0.3.0

type ListAttributionKeysParams struct {
	ExecutorID string
	ChainID    string
	FromEpoch  int64
	ToEpoch    int64
}

type ListAttributionKeysRow added in v0.3.0

type ListAttributionKeysRow struct {
	Epoch int64
	Key   []byte
}

type ListDebugletLogsParams

type ListDebugletLogsParams struct {
	Uuid  uuid.UUID
	After int64
	Limit int64
}

type ListDebugletsByUserUUIDParams

type ListDebugletsByUserUUIDParams struct {
	Uuid   uuid.UUID
	Limit  int64
	Offset int64
}

type ListDebugletsParams

type ListDebugletsParams struct {
	Limit  int64
	Offset int64
}

type ListExecutorTransfersParams added in v0.3.0

type ListExecutorTransfersParams struct {
	ExecutorID string
	RowLimit   int64
}

type ListExecutorTransfersRow added in v0.3.0

type ListExecutorTransfersRow struct {
	ID        int64
	Kind      string
	Amount    int64
	Currency  string
	Receiver  string
	State     string
	Digest    string
	CreatedAt models.UTCTime
	UpdatedAt models.UTCTime
}

type ListExternalIdentitiesRow added in v0.3.0

type ListExternalIdentitiesRow struct {
	Provider  string
	Issuer    string
	Login     string
	CreatedAt models.UTCTime
}

type ListIntentOrdersRow added in v0.3.0

type ListIntentOrdersRow struct {
	OrderID    int64
	ExecutorID string
	Price      int64
	Currency   string
	State      int64
	RunID      uuid.UUID
}

type ListMeasurementProfilesRow added in v0.3.0

type ListMeasurementProfilesRow struct {
	ID            string
	Name          string
	ProgramSha256 string
}

type ListMeasurementsParams added in v0.3.0

type ListMeasurementsParams struct {
	UserUuid   uuid.UUID
	State      interface{}
	Search     string
	PageOffset int64
	PageLimit  int64
}

type ListMeasurementsRow added in v0.3.0

type ListMeasurementsRow struct {
	ID             string
	Label          string
	State          string
	Children       int64
	ScheduledStart models.UTCTime
}

type ListOwnedExecutorsRow added in v0.3.0

type ListOwnedExecutorsRow struct {
	ExecutorID  string
	Name        string
	DisplayName string
	City        string
	Country     string
	Network     string
	Enrolled    bool
}

type ListOwnerDisplaysRow added in v0.3.0

type ListOwnerDisplaysRow struct {
	ExecutorID  string
	DisplayName string
	City        string
	Country     string
	Network     string
}

type ListPendingIdentityLinksParams added in v0.3.0

type ListPendingIdentityLinksParams struct {
	UserID          int64
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type ListPendingIdentityLinksRow added in v0.3.0

type ListPendingIdentityLinksRow struct {
	Provider  string
	Login     string
	ExpiresAt models.UTCTime
}

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 ListPendingSettlementsRow struct {
	Debuglet Debuglet
	ExitCode sql.NullInt64
	Currency string
}

type ListUnreclaimedAllocationsParams added in v0.3.0

type ListUnreclaimedAllocationsParams struct {
	ExitedState models.DebugletRunState
	EndTime     models.UTCTime
}

type ListUnresolvedChainTransfersParams added in v0.3.0

type ListUnresolvedChainTransfersParams struct {
	ReservedBefore models.UTCTime
	RowLimit       int64
}

type MarkRetirementCheckParams added in v0.3.0

type MarkRetirementCheckParams struct {
	LastRetirementCheck int64
	DebugletID          int64
}

type MarkTransactionPaidParams added in v0.3.0

type MarkTransactionPaidParams struct {
	Paid        int64
	ID          string
	Outstanding int64
}

type MeasurementCountsParams added in v0.3.0

type MeasurementCountsParams struct {
	UserUuid uuid.UUID
	Search   string
}

type MeasurementCountsRow added in v0.3.0

type MeasurementCountsRow struct {
	State string
	Count int64
}

type MeasurementExecution added in v0.3.0

type MeasurementExecution struct {
	DebugletID         int64
	StartedObservedNs  sql.NullInt64
	TerminalObservedNs sql.NullInt64
	ExitCode           sql.NullInt64
	TcpEndpoint        string
}

type MeasurementProfile added in v0.3.0

type MeasurementProfile struct {
	ID       string
	UserID   int64
	Document string
}

type MeasurementRequest added in v0.3.0

type MeasurementRequest struct {
	DebugletID int64
	Document   string
}

type MeasurementRunCountParams added in v0.3.0

type MeasurementRunCountParams struct {
	BatchID  string
	UserUuid uuid.UUID
}

type MeasurementRunsParams added in v0.3.0

type MeasurementRunsParams struct {
	BatchID    string
	UserUuid   uuid.UUID
	PageOffset int64
	PageLimit  int64
}

type MeasurementRunsRow added in v0.3.0

type MeasurementRunsRow struct {
	Uuid        uuid.UUID
	ExecutorID  string
	OrderID     int64
	State       models.DebugletRunState
	Label       string
	ProgramName string
}

type MeasurementSummary added in v0.3.0

type MeasurementSummary struct {
	ID       string
	Sequence interface{}
	Label    interface{}
	Children int64
	State    string
}

type NextAttributionKeyParams added in v0.3.0

type NextAttributionKeyParams struct {
	ExecutorID string
	ChainID    string
	Epoch      int64
}

type NextAttributionKeyRow added in v0.3.0

type NextAttributionKeyRow struct {
	Epoch int64
	Key   []byte
}

type OauthIdentity

type OauthIdentity struct {
	Provider  string
	Issuer    string
	Subject   string
	UserID    int64
	Login     string
	CreatedAt models.UTCTime
	UpdatedAt models.UTCTime
}

type OauthLoginAttempt added in v0.3.0

type OauthLoginAttempt struct {
	StateHash       []byte
	Provider        string
	Verifier        string
	Nonce           string
	Purpose         string
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type OrderSettlement added in v0.3.0

type OrderSettlement struct {
	TransactionID string
	OrderID       int64
	Kind          string
	Amount        int64
	Currency      string
	ExecutorID    string
	DebugletID    sql.NullInt64
	RecordedAt    models.UTCTime
}

type OutputAccountUsage added in v0.3.0

type OutputAccountUsage struct {
	AccountID    int64
	ChargedBytes int64
	FrameCount   int64
}

type OutputNodeUsage added in v0.3.0

type OutputNodeUsage struct {
	Singleton    int64
	ChargedBytes int64
	FrameCount   int64
}

type OwnedExecutor added in v0.3.0

type OwnedExecutor struct {
	ExecutorID  string
	UserID      int64
	Name        string
	CreatedAt   models.UTCTime
	DisplayName string
	City        string
	Country     string
	Network     string
}

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 PaymentReceipt struct {
	TxDigest    string
	EventSeq    int64
	Nonce       string
	Disposition string
	Amount      string
	CoinType    string
	Receiver    string
	Checkpoint  sql.NullInt64
	ObservedAt  models.UTCTime
	Detail      string
}
type PendingIdentityLink struct {
	UserID          int64
	Provider        string
	Issuer          string
	Subject         string
	Login           string
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type ProbeAddress added in v0.3.0

type ProbeAddress struct {
	ExecutorID    string
	Family        int64
	Address       string
	Via           string
	FirstObserved int64
	LastObserved  int64
}

type ProbeStatus added in v0.3.0

type ProbeStatus struct {
	ExecutorID     string
	FirstConnected int64
	LastConnected  int64
	Connected      int64
	StatusSince    int64
	TotalUptime    int64
	IsPublic       int64
	HostTags       string
	Version        string
}

type Queries

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

func New

func New(db DBTX) *Queries

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 (q *Queries) AdvanceAttributionRetention(ctx context.Context, cutoffNs int64) error

func (*Queries) AdvanceDebugletOutput added in v0.3.0

func (q *Queries) AdvanceDebugletOutput(ctx context.Context, arg AdvanceDebugletOutputParams) (int64, error)

func (*Queries) AdvanceLegacyDebugletOutput added in v0.3.0

func (q *Queries) AdvanceLegacyDebugletOutput(ctx context.Context, arg AdvanceLegacyDebugletOutputParams) (int64, error)

func (*Queries) ApproveDeviceLogin added in v0.3.0

func (q *Queries) ApproveDeviceLogin(ctx context.Context, arg ApproveDeviceLoginParams) (int64, error)

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

func (*Queries) ClaimDebugletOrder

func (q *Queries) ClaimDebugletOrder(ctx context.Context, arg ClaimDebugletOrderParams) (int64, error)

func (*Queries) CompleteDebuglet

func (q *Queries) CompleteDebuglet(ctx context.Context, arg CompleteDebugletParams) (Debuglet, error)

func (*Queries) ConsumeAdminAccountRecovery added in v0.3.0

func (q *Queries) ConsumeAdminAccountRecovery(ctx context.Context, selector string) error

func (*Queries) ConsumeDeviceLogin added in v0.3.0

func (q *Queries) ConsumeDeviceLogin(ctx context.Context, arg ConsumeDeviceLoginParams) (int64, error)

func (*Queries) ConsumeExecutorEnrollmentToken

func (q *Queries) ConsumeExecutorEnrollmentToken(ctx context.Context, selector string) (int64, error)

func (*Queries) ConsumeOAuthAttempt added in v0.3.0

func (q *Queries) ConsumeOAuthAttempt(ctx context.Context, arg ConsumeOAuthAttemptParams) (ConsumeOAuthAttemptRow, error)

func (*Queries) CountAccountCredentials added in v0.3.0

func (q *Queries) CountAccountCredentials(ctx context.Context, arg CountAccountCredentialsParams) (int64, error)

func (*Queries) CountDeviceLogins added in v0.3.0

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

func (*Queries) CountExperimentOrders added in v0.3.0

func (q *Queries) CountExperimentOrders(ctx context.Context, transactionID string) (int64, error)

func (*Queries) CountRecoveryCredentials added in v0.3.0

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

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 (q *Queries) CreateDebuglet(ctx context.Context, arg CreateDebugletParams) (Debuglet, error)

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 (q *Queries) CreateEarnings(ctx context.Context, arg CreateEarningsParams) (Earning, error)

func (*Queries) CreateExecutorEnrollmentToken

func (q *Queries) CreateExecutorEnrollmentToken(ctx context.Context, arg CreateExecutorEnrollmentTokenParams) error

func (*Queries) CreateExperimentBarrier added in v0.3.0

func (q *Queries) CreateExperimentBarrier(ctx context.Context, arg CreateExperimentBarrierParams) 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 (q *Queries) CreateMeasurementProfile(ctx context.Context, arg CreateMeasurementProfileParams) (int64, error)

func (*Queries) CreateOAuthAttempt added in v0.3.0

func (q *Queries) CreateOAuthAttempt(ctx context.Context, arg CreateOAuthAttemptParams) (int64, error)

func (*Queries) CreateOwnedExecutor added in v0.3.0

func (q *Queries) CreateOwnedExecutor(ctx context.Context, arg CreateOwnedExecutorParams) (int64, error)

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 (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

func (*Queries) CreateUserWithRole

func (q *Queries) CreateUserWithRole(ctx context.Context, arg CreateUserWithRoleParams) (User, error)

func (*Queries) DeleteAdminRecoveryCredential added in v0.3.0

func (q *Queries) DeleteAdminRecoveryCredential(ctx context.Context, selector string) error

func (*Queries) DeleteExecutorEnrollment

func (q *Queries) DeleteExecutorEnrollment(ctx context.Context, executorID string) (int64, error)

func (*Queries) DeleteExecutorEnrollmentTokens

func (q *Queries) DeleteExecutorEnrollmentTokens(ctx context.Context, executorID string) (int64, error)

func (*Queries) DeleteExpiredDeviceLogins added in v0.3.0

func (q *Queries) DeleteExpiredDeviceLogins(ctx context.Context, expiresAt int64) error
func (q *Queries) DeleteExpiredIdentityLinks(ctx context.Context, expiresAt models.UTCTime) error

func (*Queries) DeleteExpiredOAuthAttempts added in v0.3.0

func (q *Queries) DeleteExpiredOAuthAttempts(ctx context.Context, expiresAt models.UTCTime) error

func (*Queries) DeleteExpiredSessions

func (q *Queries) DeleteExpiredSessions(ctx context.Context, before models.UTCTime) error

func (*Queries) DeleteExternalIdentity added in v0.3.0

func (q *Queries) DeleteExternalIdentity(ctx context.Context, arg DeleteExternalIdentityParams) (int64, error)

func (*Queries) DeleteMeasurementLogs added in v0.3.0

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

func (*Queries) DeleteMeasurementProfile added in v0.3.0

func (q *Queries) DeleteMeasurementProfile(ctx context.Context, arg DeleteMeasurementProfileParams) (int64, error)

func (*Queries) DeleteMeasurementProvenance added in v0.3.0

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

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 (q *Queries) DenyDeviceLogin(ctx context.Context, arg DenyDeviceLoginParams) (int64, error)

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 (q *Queries) EnsureOutputAccountUsage(ctx context.Context, accountID int64) error

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 (q *Queries) FindExternalIdentity(ctx context.Context, arg FindExternalIdentityParams) (int64, error)

func (*Queries) FinishDebugletOutput added in v0.3.0

func (q *Queries) FinishDebugletOutput(ctx context.Context, arg FinishDebugletOutputParams) (int64, error)

func (*Queries) GetAccountRunReservation added in v0.3.0

func (q *Queries) GetAccountRunReservation(ctx context.Context, debugletID int64) (AccountRunReservation, error)

func (*Queries) GetAdmittedRuns

func (q *Queries) GetAdmittedRuns(ctx context.Context, transactionID string) ([]GetAdmittedRunsRow, error)

func (*Queries) GetAllocationReclamation added in v0.3.0

func (q *Queries) GetAllocationReclamation(ctx context.Context, argUuid uuid.UUID) (models.UTCTime, error)

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 (q *Queries) GetAttributionKey(ctx context.Context, arg GetAttributionKeyParams) ([]byte, error)

func (*Queries) GetAttributionRetention added in v0.3.0

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

func (*Queries) GetAttributionVerifyBudget added in v0.3.0

func (q *Queries) GetAttributionVerifyBudget(ctx context.Context, arg GetAttributionVerifyBudgetParams) (int64, error)

func (*Queries) GetCancellation added in v0.3.0

func (q *Queries) GetCancellation(ctx context.Context, debugletID int64) (DebugletCancellation, error)

func (*Queries) GetCredentialUser added in v0.3.0

func (q *Queries) GetCredentialUser(ctx context.Context, id int64) (User, error)

func (*Queries) GetDebugletByUUID

func (q *Queries) GetDebugletByUUID(ctx context.Context, argUuid uuid.UUID) (Debuglet, error)

func (*Queries) GetDebugletIdentityByUUID

func (q *Queries) GetDebugletIdentityByUUID(ctx context.Context, argUuid uuid.UUID) (GetDebugletIdentityByUUIDRow, error)

func (*Queries) GetDebugletOrder

func (q *Queries) GetDebugletOrder(ctx context.Context, arg GetDebugletOrderParams) (DebugletOrder, error)

func (*Queries) GetDebugletOutput added in v0.3.0

func (q *Queries) GetDebugletOutput(ctx context.Context, argUuid uuid.UUID) (GetDebugletOutputRow, error)

func (*Queries) GetDebugletOwnerUUID

func (q *Queries) GetDebugletOwnerUUID(ctx context.Context, argUuid uuid.UUID) (uuid.UUID, error)

func (*Queries) GetDebugletProvenance added in v0.3.0

func (q *Queries) GetDebugletProvenance(ctx context.Context, argUuid uuid.UUID) (string, error)

func (*Queries) GetDebugletProvenanceSize added in v0.3.0

func (q *Queries) GetDebugletProvenanceSize(ctx context.Context, debugletID int64) (sql.NullInt64, error)

func (*Queries) GetDeviceLogin added in v0.3.0

func (q *Queries) GetDeviceLogin(ctx context.Context, selector string) (DeviceLogin, error)

func (*Queries) GetDeviceLoginByUserCode added in v0.3.0

func (q *Queries) GetDeviceLoginByUserCode(ctx context.Context, userCodeHash []byte) (DeviceLogin, error)

func (*Queries) GetEarnings

func (q *Queries) GetEarnings(ctx context.Context) ([]Earning, error)

func (*Queries) GetEarningsIn

func (q *Queries) GetEarningsIn(ctx context.Context, arg GetEarningsInParams) (Earning, error)

func (*Queries) GetEarningsOf

func (q *Queries) GetEarningsOf(ctx context.Context, executorID string) ([]Earning, error)

func (*Queries) GetExecutorEnrollment

func (q *Queries) GetExecutorEnrollment(ctx context.Context, executorID string) (string, error)

func (*Queries) GetExecutorEnrollmentToken

func (q *Queries) GetExecutorEnrollmentToken(ctx context.Context, selector string) (GetExecutorEnrollmentTokenRow, error)

func (*Queries) GetExperimentBarrier added in v0.3.0

func (q *Queries) GetExperimentBarrier(ctx context.Context, transactionID string) (ExperimentBarrier, error)

func (*Queries) GetExperimentMembers added in v0.3.0

func (q *Queries) GetExperimentMembers(ctx context.Context, transactionID string) ([]GetExperimentMembersRow, error)

func (*Queries) GetIdentitySession added in v0.3.0

func (q *Queries) GetIdentitySession(ctx context.Context, selector string) (GetIdentitySessionRow, error)

func (*Queries) GetLatestRefundTransferState added in v0.3.0

func (q *Queries) GetLatestRefundTransferState(ctx context.Context, transactionID string) (string, error)

func (*Queries) GetMeasurementExecution added in v0.3.0

func (q *Queries) GetMeasurementExecution(ctx context.Context, debugletID int64) (MeasurementExecution, error)

func (*Queries) GetMeasurementProfile added in v0.3.0

func (q *Queries) GetMeasurementProfile(ctx context.Context, arg GetMeasurementProfileParams) (string, error)

func (*Queries) GetMeasurementRequest added in v0.3.0

func (q *Queries) GetMeasurementRequest(ctx context.Context, debugletID int64) (string, error)

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 (q *Queries) GetOutputAccountUsage(ctx context.Context, accountID int64) (OutputAccountUsage, error)

func (*Queries) GetOutputNodeUsage added in v0.3.0

func (q *Queries) GetOutputNodeUsage(ctx context.Context) (OutputNodeUsage, error)

func (*Queries) GetOwnedDebugletByUUID

func (q *Queries) GetOwnedDebugletByUUID(ctx context.Context, arg GetOwnedDebugletByUUIDParams) (Debuglet, error)

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 (q *Queries) GetPayloadTombstone(ctx context.Context, argUuid uuid.UUID) (PayloadTombstone, error)

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 (q *Queries) GetReclaimedDebuglet(ctx context.Context, argUuid uuid.UUID) (Debuglet, error)

func (*Queries) GetResultLogs added in v0.3.0

func (q *Queries) GetResultLogs(ctx context.Context, debugletID int64) ([]DebugletLog, error)

func (*Queries) GetResultOutputSize added in v0.3.0

func (q *Queries) GetResultOutputSize(ctx context.Context, debugletID int64) (GetResultOutputSizeRow, error)

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 (q *Queries) GetSessionBySelector(ctx context.Context, selector string) (GetSessionBySelectorRow, error)

func (*Queries) GetTransactionByID

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

func (*Queries) GetTransactionOrders

func (q *Queries) GetTransactionOrders(ctx context.Context, transactionID string) ([]DebugletOrder, error)

func (*Queries) GetTransactionOwnerUUID

func (q *Queries) GetTransactionOwnerUUID(ctx context.Context, transactionID string) (uuid.UUID, error)

func (*Queries) GetTransactionState

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

func (*Queries) GetUnmappedAccountForRecovery added in v0.3.0

func (q *Queries) GetUnmappedAccountForRecovery(ctx context.Context, argUuid uuid.UUID) (User, error)

func (*Queries) GetUserByUUID

func (q *Queries) GetUserByUUID(ctx context.Context, argUuid uuid.UUID) (User, error)

func (*Queries) GetUserCredential

func (q *Queries) GetUserCredential(ctx context.Context, arg GetUserCredentialParams) (GetUserCredentialRow, error)

func (*Queries) InsertAllowanceGrant added in v0.3.0

func (q *Queries) InsertAllowanceGrant(ctx context.Context, arg InsertAllowanceGrantParams) (int64, error)

func (*Queries) InsertAttributionKey added in v0.3.0

func (q *Queries) InsertAttributionKey(ctx context.Context, arg InsertAttributionKeyParams) error

func (*Queries) InsertAttributionReceiptKey added in v0.3.0

func (q *Queries) InsertAttributionReceiptKey(ctx context.Context, arg InsertAttributionReceiptKeyParams) error

func (*Queries) InsertChainTransfer added in v0.3.0

func (q *Queries) InsertChainTransfer(ctx context.Context, arg InsertChainTransferParams) (int64, error)

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) LatestDestinationPolicyRevision added in v0.3.0

func (q *Queries) LatestDestinationPolicyRevision(ctx context.Context, destination string) (int64, 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 (q *Queries) ListAccountReservations(ctx context.Context, accountID int64) ([]ListAccountReservationsRow, error)

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) ListAttributionReceiptKeys added in v0.3.0

func (q *Queries) ListAttributionReceiptKeys(ctx context.Context) ([]AttributionReceiptKey, error)

func (*Queries) ListConnectedProbeIDs added in v0.3.0

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

func (*Queries) ListCurrentDestinationPolicies added in v0.3.0

func (q *Queries) ListCurrentDestinationPolicies(ctx context.Context) ([]DestinationPolicyEvent, error)

func (*Queries) ListDebugletLogs

func (q *Queries) ListDebugletLogs(ctx context.Context, arg ListDebugletLogsParams) ([]DebugletLog, error)

func (*Queries) ListDebuglets

func (q *Queries) ListDebuglets(ctx context.Context, arg ListDebugletsParams) ([]Debuglet, error)

func (*Queries) ListDebugletsByUserUUID

func (q *Queries) ListDebugletsByUserUUID(ctx context.Context, arg ListDebugletsByUserUUIDParams) ([]Debuglet, error)

func (*Queries) ListDebugletsEndAfter

func (q *Queries) ListDebugletsEndAfter(ctx context.Context, endTime models.UTCTime) ([]Debuglet, error)

func (*Queries) ListEnrolledExecutorIDs added in v0.3.0

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

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 (q *Queries) ListExpiredPayloads(ctx context.Context, before sql.NullInt64) ([]uuid.UUID, error)

func (*Queries) ListExternalIdentities added in v0.3.0

func (q *Queries) ListExternalIdentities(ctx context.Context, argUuid uuid.UUID) ([]ListExternalIdentitiesRow, error)

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 (q *Queries) ListMeasurementProfiles(ctx context.Context, argUuid uuid.UUID) ([]ListMeasurementProfilesRow, error)

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 (q *Queries) ListOwnedExecutors(ctx context.Context, argUuid uuid.UUID) ([]ListOwnedExecutorsRow, error)

func (*Queries) ListOwnerDisplays added in v0.3.0

func (q *Queries) ListOwnerDisplays(ctx context.Context) ([]ListOwnerDisplaysRow, error)

func (*Queries) ListPaymentReceiptsByNonce added in v0.3.0

func (q *Queries) ListPaymentReceiptsByNonce(ctx context.Context, nonce string) ([]PaymentReceipt, error)
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 (q *Queries) ListRetirementCandidates(ctx context.Context) ([]uuid.UUID, error)

func (*Queries) ListUnreclaimedAllocations added in v0.3.0

func (q *Queries) ListUnreclaimedAllocations(ctx context.Context, arg ListUnreclaimedAllocationsParams) ([]Debuglet, error)

func (*Queries) ListUnresolvedChainTransfers added in v0.3.0

func (q *Queries) ListUnresolvedChainTransfers(ctx context.Context, arg ListUnresolvedChainTransfersParams) ([]ChainTransfer, error)

func (*Queries) ListUserUUIDs

func (q *Queries) ListUserUUIDs(ctx context.Context) ([]uuid.UUID, error)

func (*Queries) LockAccountForRecovery added in v0.3.0

func (q *Queries) LockAccountForRecovery(ctx context.Context, argUuid uuid.UUID) (int64, error)

func (*Queries) LockCredentialSession added in v0.3.0

func (q *Queries) LockCredentialSession(ctx context.Context, selector string) error

func (*Queries) LockDeviceLogin added in v0.3.0

func (q *Queries) LockDeviceLogin(ctx context.Context, selector string) error

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 (q *Queries) MarkTransactionPaid(ctx context.Context, arg MarkTransactionPaidParams) (int64, error)

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 (q *Queries) MeasurementRunCount(ctx context.Context, arg MeasurementRunCountParams) (int64, error)

func (*Queries) MeasurementRuns added in v0.3.0

func (q *Queries) MeasurementRuns(ctx context.Context, arg MeasurementRunsParams) ([]MeasurementRunsRow, error)

func (*Queries) NextAttributionKey added in v0.3.0

func (q *Queries) NextAttributionKey(ctx context.Context, arg NextAttributionKeyParams) (NextAttributionKeyRow, error)

The smallest disclosed key of a chain at or above an epoch: every lower key of the chain is derived from it by hashing.

func (*Queries) PruneAttributionChains added in v0.3.0

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

func (*Queries) PruneAttributionKeys added in v0.3.0

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

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

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

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) PruneAttributionVerifyBudget added in v0.3.0

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

Deletes the counts of epochs whose key is due for disclosure, and those of chains no longer on record.

func (*Queries) PruneExperimentMetadata added in v0.3.0

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

func (*Queries) PruneProbeAddresses added in v0.3.0

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

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) RecordAttributionScheduleProof added in v0.3.0

func (q *Queries) RecordAttributionScheduleProof(ctx context.Context, arg RecordAttributionScheduleProofParams) (int64, error)

func (*Queries) RecordCancellationTerminal added in v0.3.0

func (q *Queries) RecordCancellationTerminal(ctx context.Context, arg RecordCancellationTerminalParams) (int64, error)

func (*Queries) RecordDestinationPolicy added in v0.3.0

func (q *Queries) RecordDestinationPolicy(ctx context.Context, arg RecordDestinationPolicyParams) (DestinationPolicyEvent, error)

func (*Queries) RecordExperimentReady added in v0.3.0

func (q *Queries) RecordExperimentReady(ctx context.Context, arg RecordExperimentReadyParams) 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

func (q *Queries) RecordProbeDisconnected(ctx context.Context, executorID string) (int64, error)

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 (q *Queries) RefundPaidTransaction(ctx context.Context, arg RefundPaidTransactionParams) (int64, error)

func (*Queries) RefundUnadmittedTransaction added in v0.3.0

func (q *Queries) RefundUnadmittedTransaction(ctx context.Context, arg RefundUnadmittedTransactionParams) (int64, error)

func (*Queries) ReleaseExperiment added in v0.3.0

func (q *Queries) ReleaseExperiment(ctx context.Context, arg ReleaseExperimentParams) error

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 (q *Queries) ReservePayout(ctx context.Context, arg ReservePayoutParams) (int64, error)

func (*Queries) RetireAccountRun added in v0.3.0

func (q *Queries) RetireAccountRun(ctx context.Context, arg RetireAccountRunParams) (int64, error)

func (*Queries) RetireAttributionReceiptKeys added in v0.3.0

func (q *Queries) RetireAttributionReceiptKeys(ctx context.Context, arg RetireAttributionReceiptKeysParams) error

func (*Queries) RevokeAccountCredential added in v0.3.0

func (q *Queries) RevokeAccountCredential(ctx context.Context, arg RevokeAccountCredentialParams) (int64, error)

func (*Queries) RevokeAdminAccountRecovery added in v0.3.0

func (q *Queries) RevokeAdminAccountRecovery(ctx context.Context, arg RevokeAdminAccountRecoveryParams) (string, error)

func (*Queries) RevokeSessionBySelector

func (q *Queries) RevokeSessionBySelector(ctx context.Context, selector string) error

func (*Queries) RevokeUserSessions

func (q *Queries) RevokeUserSessions(ctx context.Context, argUuid uuid.UUID) error

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 (q *Queries) SetUserRole(ctx context.Context, arg SetUserRoleParams) (int64, error)

func (*Queries) SettleEarning

func (q *Queries) SettleEarning(ctx context.Context, arg SettleEarningParams) error

func (*Queries) SpendAttributionVerifyBudget added in v0.3.0

func (q *Queries) SpendAttributionVerifyBudget(ctx context.Context, arg SpendAttributionVerifyBudgetParams) (int64, error)

Charges the candidate trials of one executor query (one per candidate run) to a chain epoch, unless they would exceed the limit R = 16 (dispatcher.VerifyBudget): then no row is returned and nothing is charged. The caller never asks for more than 16 trials, so a first charge always fits. One statement, so concurrent requests never both take the last trials.

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 (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 (q *Queries) TouchProbeConnected(ctx context.Context, arg TouchProbeConnectedParams) (int64, error)

func (*Queries) TransitionDebugletOrder added in v0.3.0

func (q *Queries) TransitionDebugletOrder(ctx context.Context, arg TransitionDebugletOrderParams) (int64, error)

func (*Queries) UpdateChainTransfer added in v0.3.0

func (q *Queries) UpdateChainTransfer(ctx context.Context, arg UpdateChainTransferParams) (int64, error)

func (*Queries) UpdateDebugletOrderState

func (q *Queries) UpdateDebugletOrderState(ctx context.Context, arg UpdateDebugletOrderStateParams) (DebugletOrder, error)

func (*Queries) UpdateDebugletState

func (q *Queries) UpdateDebugletState(ctx context.Context, arg UpdateDebugletStateParams) (Debuglet, error)

func (*Queries) UpdateDeviceLoginPoll added in v0.3.0

func (q *Queries) UpdateDeviceLoginPoll(ctx context.Context, arg UpdateDeviceLoginPollParams) (int64, error)

func (*Queries) UpdateMeasurementProfile added in v0.3.0

func (q *Queries) UpdateMeasurementProfile(ctx context.Context, arg UpdateMeasurementProfileParams) (int64, error)

func (*Queries) UpdateOwnedExecutorDisplay 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

func (*Queries) WithTx

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

type ReclaimAllocationParams added in v0.3.0

type ReclaimAllocationParams struct {
	ReclaimedAt           models.UTCTime
	Uuid                  uuid.UUID
	ExitedState           models.DebugletRunState
	ExecutorID            string
	DispatcherIncarnation string
	SessionID             string
}

type RecordAdminAccountRecoveryParams added in v0.3.0

type RecordAdminAccountRecoveryParams struct {
	Selector      string
	UserID        int64
	CaseReference string
	IssuedByUid   int64
	IssuedAt      int64
	ExpiresAt     int64
}

type RecordAttributionChainParams added in v0.3.0

type RecordAttributionChainParams struct {
	ExecutorID  string
	ChainID     string
	Anchor      []byte
	T0Ns        int64
	IntervalNs  int64
	DelayEpochs int64
	ChainLength int64
	TagSpec     int64
	SeenNs      int64
}

type RecordAttributionRunParams added in v0.3.0

type RecordAttributionRunParams struct {
	DebugletID       int64
	ChainID          string
	SourceIp         string
	SourceIpObserved int64
	ActiveFromNs     int64
	ActiveToNs       int64
}

type RecordAttributionScheduleProofParams added in v0.3.0

type RecordAttributionScheduleProofParams struct {
	ScheduleProof []byte
	ExecutorID    string
	ChainID       string
}

type RecordCancellationTerminalParams added in v0.3.0

type RecordCancellationTerminalParams struct {
	TerminalRecordedAt sql.NullInt64
	DebugletID         int64
}

type RecordDestinationPolicyParams added in v0.3.0

type RecordDestinationPolicyParams struct {
	Destination   string
	Kind          string
	LimitBps      sql.NullInt64
	Reason        string
	Actor         string
	RequestedAtNs int64
	ExpiresAtNs   sql.NullInt64
	Revision      int64
}

type RecordExperimentReadyParams added in v0.3.0

type RecordExperimentReadyParams struct {
	DebugletID int64
	Metadata   []byte
	ReadyAtNs  int64
}

type RecordMeasurementStartedParams added in v0.3.0

type RecordMeasurementStartedParams struct {
	DebugletID        int64
	StartedObservedNs sql.NullInt64
	TcpEndpoint       string
}

type RecordMeasurementTerminalParams added in v0.3.0

type RecordMeasurementTerminalParams struct {
	DebugletID         int64
	TerminalObservedNs sql.NullInt64
	ExitCode           sql.NullInt64
}

type RecordProbeConnectedParams added in v0.3.0

type RecordProbeConnectedParams struct {
	ExecutorID string
	Now        int64
	IsPublic   int64
	HostTags   string
	Version    string
}

type RefreshExternalIdentityParams added in v0.3.0

type RefreshExternalIdentityParams struct {
	Login     string
	UpdatedAt models.UTCTime
	Issuer    string
	Subject   string
}

type RefundPaidTransactionParams added in v0.3.0

type RefundPaidTransactionParams struct {
	Refunded int64
	ID       string
	Paid     int64
}

type RefundUnadmittedTransactionParams added in v0.3.0

type RefundUnadmittedTransactionParams struct {
	RefundedStatus int64
	TransactionID  string
	PaidStatus     int64
}

type ReleaseExperimentParams added in v0.3.0

type ReleaseExperimentParams struct {
	StartTimeNs   int64
	TransactionID string
}

type ReleaseExpiredAllowanceIntentsParams added in v0.3.0

type ReleaseExpiredAllowanceIntentsParams struct {
	ExpiredStatus int64
	PaidStatus    int64
	Now           models.UTCTime
	UserUuid      uuid.UUID
}

type ReleasePayoutParams added in v0.3.0

type ReleasePayoutParams struct {
	Amount     int64
	ExecutorID string
	Currency   string
}

type ReserveAccountRunParams added in v0.3.0

type ReserveAccountRunParams struct {
	DebugletID  int64
	AccountID   int64
	QueuedBytes int64
}

type ReserveAllowanceIntentParams added in v0.3.0

type ReserveAllowanceIntentParams struct {
	ID         string
	Price      int64
	ExpiresAt  models.UTCTime
	PaidStatus int64
	Hash       string
	UserUuid   uuid.UUID
}

type ReservePayoutParams added in v0.3.0

type ReservePayoutParams struct {
	Amount     int64
	ExecutorID string
	Currency   string
}

type RetireAccountRunParams added in v0.3.0

type RetireAccountRunParams struct {
	RetiredAt  sql.NullInt64
	DebugletID int64
}

type RetireAttributionReceiptKeysParams added in v0.3.0

type RetireAttributionReceiptKeysParams struct {
	NowNs int64
	KeyID string
}

type RetryRequest added in v0.3.0

type RetryRequest struct {
	CallerScope    string
	RequestID      string
	ParentRunID    string
	TransactionID  string
	RequestHash    string
	IntentMetadata string
}

type RevokeAccountCredentialParams added in v0.3.0

type RevokeAccountCredentialParams struct {
	Selector string
	Uuid     uuid.UUID
}

type RevokeAdminAccountRecoveryParams added in v0.3.0

type RevokeAdminAccountRecoveryParams struct {
	RevokedByUid        sql.NullInt64
	RevocationReference string
	Uuid                uuid.UUID
}

type Session

type Session struct {
	ID              int64
	Selector        string
	VerifierHash    []byte
	CsrfHash        []byte
	UserID          int64
	CreatedAt       models.UTCTime
	ExpiresAt       models.UTCTime
	Revoked         int64
	Kind            string
	Audience        string
	Scopes          string
	Label           string
	AuthenticatedAt models.UTCTime
}

type SetExecutorEnrollmentParams

type SetExecutorEnrollmentParams struct {
	ExecutorID  string
	Fingerprint string
	EnrolledAt  models.UTCTime
}

type SetRefundAddressParams

type SetRefundAddressParams struct {
	RefundAddress string
	TransactionID string
	OrderID       int64
}

type SetTransactionOwnerParams

type SetTransactionOwnerParams struct {
	TransactionID string
	Uuid          uuid.UUID
}

type SetTransactionPricingRuleParams added in v0.3.0

type SetTransactionPricingRuleParams struct {
	PricingRule string
	ID          string
}

type SetUserRoleParams

type SetUserRoleParams struct {
	Role string
	Uuid uuid.UUID
}

type SettleEarningParams

type SettleEarningParams struct {
	ExecutorID string
	Currency   string
}

type SpendAttributionVerifyBudgetParams added in v0.3.0

type SpendAttributionVerifyBudgetParams struct {
	ExecutorID string
	ChainID    string
	Epoch      int64
	Used       int64
}

type StartProbeAddressParams added in v0.3.0

type StartProbeAddressParams struct {
	ExecutorID string
	Family     int64
	Address    string
	Via        string
	At         int64
}

type StorePendingIdentityLinkParams added in v0.3.0

type StorePendingIdentityLinkParams struct {
	UserID          int64
	Provider        string
	Issuer          string
	Subject         string
	Login           string
	SessionSelector string
	ExpiresAt       models.UTCTime
}

type TouchAttributionChainParams added in v0.3.0

type TouchAttributionChainParams struct {
	SeenNs     int64
	ExecutorID string
	ChainID    string
}

type TouchProbeConnectedParams added in v0.3.0

type TouchProbeConnectedParams struct {
	Now        int64
	ExecutorID string
}

type Transaction

type Transaction struct {
	ID          string
	AuthKey     string
	Price       int64
	Method      string
	ExpiresAt   models.UTCTime
	Hash        string
	Currency    string
	Status      int64
	PricingRule string
}

type TransactionState

type TransactionState struct {
	Key   string
	Value string
}

type TransactionUser

type TransactionUser struct {
	TransactionID string
	UserID        int64
}

type TransitionDebugletOrderParams added in v0.3.0

type TransitionDebugletOrderParams struct {
	ToState       int64
	TransactionID string
	OrderID       int64
	FromState     int64
}

type UpdateChainTransferParams added in v0.3.0

type UpdateChainTransferParams struct {
	State     string
	Digest    string
	Detail    string
	UpdatedAt models.UTCTime
	ID        int64
	FromState string
}

type UpdateDebugletOrderStateParams

type UpdateDebugletOrderStateParams struct {
	State         int64
	TransactionID string
	OrderID       int64
}

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 UpdateDeviceLoginPollParams struct {
	NextPollAt   int64
	PollInterval int64
	Selector     string
}

type UpdateMeasurementProfileParams added in v0.3.0

type UpdateMeasurementProfileParams struct {
	Document string
	ID       string
	Uuid     uuid.UUID
}

type UpdateOwnedExecutorDisplayParams added in v0.3.0

type UpdateOwnedExecutorDisplayParams struct {
	DisplayName sql.NullString
	City        sql.NullString
	Country     sql.NullString
	Network     sql.NullString
	ExecutorID  string
	Uuid        uuid.UUID
}

type UpdateOwnedExecutorDisplayRow added in v0.3.0

type UpdateOwnedExecutorDisplayRow struct {
	ExecutorID  string
	DisplayName string
	City        string
	Country     string
	Network     string
}

type UpdateTransactionStateParams

type UpdateTransactionStateParams struct {
	Key   string
	Value string
}

type UpdateTransactionStatusParams

type UpdateTransactionStatusParams struct {
	Status int64
	ID     string
}

type UpsertUserCredentialParams

type UpsertUserCredentialParams struct {
	UserID     int64
	Kind       string
	Selector   string
	SecretHash []byte
	CreatedAt  models.UTCTime
}

type User

type User struct {
	ID   int64
	Uuid uuid.UUID
	Name string
	Role string
}

type UserCredential

type UserCredential struct {
	UserID     int64
	Kind       string
	Selector   string
	SecretHash []byte
	CreatedAt  models.UTCTime
}

Jump to

Keyboard shortcuts

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