Documentation
¶
Index ¶
- type AcceptTeamInvitationParams
- type ActivateMemberSlugParams
- type AdvanceAuthorityRevisionParams
- type AdvanceTeamPolicyRevisionParams
- type ApplyIngressUsageReportParams
- type ApplyIngressUsageReportRow
- type BeginAdminRelayDrainParams
- type BeginAdminRelayDrainRow
- type BeginDNSAuthorityReleaseParams
- type BeginIngressDrainParams
- type BeginRelayDrainParams
- type BeginRelayDrainRow
- type CancelOpenRouteRecoveryEpisodeParams
- type CancelRouteSessionACMEAuthorizationsParams
- type CancelRouteSessionACMEOrdersParams
- type ClaimACMEOrderWorkParams
- type ClaimDNSAuthorityWorkParams
- type ClaimDNSRouteWorkParams
- type ClaimPublisherConnectionParams
- type ClaimRelayCertificateOrderWorkParams
- type ClaimRelayServiceForCertificateOrderParams
- type ClaimRouteUsageDeliveriesParams
- type CloseRouteSessionConnectionsParams
- type CloseRouteSessionParams
- type CompleteACMEAuthorizationCleanupParams
- type CompleteRouteUsageDeliveryParams
- type ConsumeOIDCAssertionParams
- type ControlAcmeAccount
- type ControlAcmeAuthorization
- type ControlAcmeOrder
- type ControlAdminAuditEvent
- type ControlAuthorityRevisionState
- type ControlControlSession
- type ControlControlTlsCache
- type ControlDnsAuthority
- type ControlDomain
- type ControlIdentity
- type ControlIngressLease
- type ControlIngressRoutingTableClock
- type ControlIngressRoutingTableEvent
- type ControlIngressUsageReport
- type ControlIngressUsageRun
- type ControlMaintenanceControl
- type ControlManagedLabelReservation
- type ControlMemberSlugReservation
- type ControlOidcAssertionExchange
- type ControlRelayCertificateOrder
- type ControlRelayLease
- type ControlRelayService
- type ControlRelayServiceAssignmentTotal
- type ControlRoute
- type ControlRouteRecoveryEpisode
- type ControlRouteRecoveryHistogram
- type ControlRouteSession
- type ControlRouteSessionConnection
- type ControlRouteUsageBucket
- type ControlRouteUsageConfiguration
- type ControlRouteUsageDelivery
- type ControlRuntimeSecret
- type ControlTeam
- type ControlTeamInvitation
- type ControlTeamMembership
- type CountOpenRouteSessionAssignmentsByRelayServiceRow
- type CountRelayActiveConnectionsParams
- type CreateActiveSlugReservationParams
- type CreateClaimedDNSAuthorityParams
- type CreateClaimedDomainParams
- type CreateControlSessionParams
- type CreateIdentityParams
- type CreateManagedDomainParams
- type CreateOIDCIdentityParams
- type CreateOrGetDNSAuthorityParams
- type CreateOrganizationTeamParams
- type CreateOrganizationTeamRow
- type CreateOwnerMembershipParams
- type CreatePersonalTeamParams
- type CreateTeamInvitationParams
- type CreateTeamMembershipParams
- type DBTX
- type DNSAuthorityReleaseReadyParams
- type DeleteControlTLSCacheEntryParams
- type DeleteRouteParams
- type DisconnectPublisherConnectionParams
- type EnsureACMEAccountParams
- type EnsureExternalAuthorityPrincipalParams
- type EnsureExternalRetryMasterKeyParams
- type EnsureExternalRetryMasterKeyRow
- type EnsureIngressUsageRunParams
- type EnsureRouteUsageConfigurationParams
- type ExpirePublisherConnectionParams
- type ExpireTeamInvitationsParams
- type FinalizeRouteUsageBucketsParams
- type FindOIDCIdentityParams
- type GetACMEOrderByIdempotencyParams
- type GetActiveRouteSessionChallengeExpiryParams
- type GetActiveRouteSessionMembershipParams
- type GetActiveRouteSessionMembershipRow
- type GetAdminRuntimeCountsRow
- type GetAuthorizedRouteByHostnameParams
- type GetAuthorizedRouteByHostnameRow
- type GetClaimedDomainByIdempotencyParams
- type GetClaimedDomainByIdempotencyRow
- type GetControlSessionByAccessIDRow
- type GetControlTLSCacheEntryParams
- type GetControlTLSCacheEntryRow
- type GetDNSChallengeContextParams
- type GetDNSChallengeContextRow
- type GetExternalAuthorityRouteParams
- type GetExternalAuthorityRouteRow
- type GetIdentityContextIdentityRow
- type GetIdentityRouteParams
- type GetIdentityRouteRow
- type GetIdentityTeamParams
- type GetIdentityTeamRow
- type GetIngressLeaseParams
- type GetIngressUsageReportParams
- type GetInvitationByIdempotencyParams
- type GetInvitationByIdempotencyRow
- type GetOpenRouteRecoveryEpisodeParams
- type GetOrganizationTeamByIdempotencyParams
- type GetOrganizationTeamByIdempotencyRow
- type GetRelayDNSChallengeContextRow
- type GetRelayLeaseForClaimRow
- type GetRelayLeaseForReadyRow
- type GetRelayTransportCertificateParams
- type GetRouteByCreatorIdempotencyParams
- type GetRouteByCreatorIdempotencyRow
- type GetRouteCreationContextParams
- type GetRouteCreationContextRow
- type GetRouteSessionByIdempotencyParams
- type GetRouteUsageBucketForUpdateParams
- type GetTeamActorContextParams
- type GetTeamActorContextRow
- type GetTeamMembershipContextParams
- type GetTeamMembershipContextRow
- type HeartbeatRouteSessionParams
- type InsertACMEOrderParams
- type InsertAdminAuditEventParams
- type InsertCertificateIssuanceAuditEventParams
- type InsertExpiredEphemeralRouteDeleteAuditEventParams
- type InsertFinalIngressRoutingTableEventParams
- type InsertIngressRoutingTableEventParams
- type InsertRelayCertificateOrderParams
- type InsertRouteCreateAuditEventParams
- type InsertRouteDeleteAuditEventParams
- type InsertRouteParams
- type InsertRouteSessionAuditEventParams
- type InsertRouteSessionConnectionsParams
- type InsertRouteSessionParams
- type InsertRouteUpdateAuditEventParams
- type InsertRouteUsageDeliveryParams
- type LatestIngressRoutingEntryRevisionParams
- type ListAdminRelayLeasesParams
- type ListAdminRelayLeasesRow
- type ListDNSChallengePresentationsRow
- type ListExternalAuthorityRoutesParams
- type ListExternalAuthorityRoutesRow
- type ListIdentityMembershipContextsRow
- type ListIdentityRoutesParams
- type ListIdentityRoutesRow
- type ListIdentityTeamDomainsParams
- type ListIdentityTeamDomainsRow
- type ListIdentityTeamsRow
- type ListIngressRoutingTableEventsParams
- type ListIngressRoutingTableSnapshotParams
- type ListLatestIngressUsageReportsParams
- type ListLatestIngressUsageReportsRow
- type ListRelayDNSChallengePresentationsRow
- type ListTeamInvitationsRow
- type ListTeamMemberNamespaceLabelsRow
- type ListTeamMembershipContextsRow
- type ListValidReadyPublisherConnectionsParams
- type ListValidReadyPublisherConnectionsRow
- type LockACMEOrderForInstallParams
- type LockControlSessionByRefreshIDRow
- type LockDomainRoutesParams
- type LockEligibleRelayLeasesParams
- type LockEligibleRelayLeasesRow
- type LockExpiredEphemeralRoutesParams
- type LockIdentityRouteForDeleteParams
- type LockIdentityRouteForDeleteRow
- type LockIngressLeaseParams
- type LockInvitationByTokenDigestParams
- type LockInvitationByTokenDigestRow
- type LockMembershipRoutesParams
- type LockRouteSessionForUsageParams
- type LockTeamActorContextParams
- type LockTeamActorContextRow
- type LockTeamDomainParams
- type LockTeamDomainRow
- type LockTeamInvitationParams
- type LockTeamInvitationRow
- type LockTeamMembershipParams
- type LockTeamMembershipRow
- type MarkACMEAuthorizationsPresentedParams
- type MarkACMEOrderInstalledParams
- type MarkClaimedDomainReleasingParams
- type MarkDNSAuthorityReleasingParams
- type MarkExpiredIngressUsageRunIncompleteParams
- type MarkIngressUsageRunReportedParams
- type MarkPublisherConnectionReadyParams
- type MarkRouteSessionCertificateInstalledParams
- type MarkRouteSessionReadyParams
- type ObserveAuthorityRevisionParams
- type ObserveRouteRecoveryEpisodeParams
- type OpenRouteRecoveryEpisodeParams
- type PruneIngressRoutingHistoryBatchRow
- type PutControlTLSCacheEntryParams
- type QuarantineMemberSlugParams
- type Querier
- type Queries
- func (q *Queries) AcceptTeamInvitation(ctx context.Context, arg AcceptTeamInvitationParams) (int64, error)
- func (q *Queries) ActivateMemberSlug(ctx context.Context, arg ActivateMemberSlugParams) (int64, error)
- func (q *Queries) AdvanceAuthorityRevision(ctx context.Context, arg AdvanceAuthorityRevisionParams) (int64, error)
- func (q *Queries) AdvanceIngressRoutingRetentionFloor(ctx context.Context, revision int64) (int64, error)
- func (q *Queries) AdvanceTeamPolicyRevision(ctx context.Context, arg AdvanceTeamPolicyRevisionParams) (int64, error)
- func (q *Queries) ApplyIngressUsageReport(ctx context.Context, arg ApplyIngressUsageReportParams) (ApplyIngressUsageReportRow, error)
- func (q *Queries) BeginAdminRelayDrain(ctx context.Context, arg BeginAdminRelayDrainParams) (BeginAdminRelayDrainRow, error)
- func (q *Queries) BeginDNSAuthorityRelease(ctx context.Context, arg BeginDNSAuthorityReleaseParams) (ControlDnsAuthority, error)
- func (q *Queries) BeginIngressDrain(ctx context.Context, arg BeginIngressDrainParams) (ControlIngressLease, error)
- func (q *Queries) BeginRelayDrain(ctx context.Context, arg BeginRelayDrainParams) (BeginRelayDrainRow, error)
- func (q *Queries) CancelOpenRouteRecoveryEpisode(ctx context.Context, arg CancelOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
- func (q *Queries) CancelRouteSessionACMEAuthorizations(ctx context.Context, arg CancelRouteSessionACMEAuthorizationsParams) error
- func (q *Queries) CancelRouteSessionACMEOrders(ctx context.Context, arg CancelRouteSessionACMEOrdersParams) error
- func (q *Queries) ClaimACMEOrderWork(ctx context.Context, arg ClaimACMEOrderWorkParams) (ControlAcmeOrder, error)
- func (q *Queries) ClaimDNSAuthorityWork(ctx context.Context, arg ClaimDNSAuthorityWorkParams) (ControlDnsAuthority, error)
- func (q *Queries) ClaimDNSRouteWork(ctx context.Context, arg ClaimDNSRouteWorkParams) (ControlRoute, error)
- func (q *Queries) ClaimPublisherConnection(ctx context.Context, arg ClaimPublisherConnectionParams) (ControlRouteSessionConnection, error)
- func (q *Queries) ClaimRelayCertificateOrderWork(ctx context.Context, arg ClaimRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
- func (q *Queries) ClaimRelayServiceForCertificateOrder(ctx context.Context, arg ClaimRelayServiceForCertificateOrderParams) (ControlRelayService, error)
- func (q *Queries) ClaimRouteUsageDeliveries(ctx context.Context, arg ClaimRouteUsageDeliveriesParams) ([]ControlRouteUsageDelivery, error)
- func (q *Queries) CloseRouteSession(ctx context.Context, arg CloseRouteSessionParams) (ControlRouteSession, error)
- func (q *Queries) CloseRouteSessionConnections(ctx context.Context, arg CloseRouteSessionConnectionsParams) error
- func (q *Queries) CompleteACMEAuthorizationCleanup(ctx context.Context, arg CompleteACMEAuthorizationCleanupParams) (int64, error)
- func (q *Queries) CompleteRouteUsageDelivery(ctx context.Context, arg CompleteRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
- func (q *Queries) ConsumeOIDCAssertion(ctx context.Context, arg ConsumeOIDCAssertionParams) (int64, error)
- func (q *Queries) CountOpenRouteSessionAssignmentsByRelayService(ctx context.Context) ([]CountOpenRouteSessionAssignmentsByRelayServiceRow, error)
- func (q *Queries) CountRelayActiveConnections(ctx context.Context, arg CountRelayActiveConnectionsParams) (int64, error)
- func (q *Queries) CountTeamOwners(ctx context.Context, teamID string) (int64, error)
- func (q *Queries) CreateActiveSlugReservation(ctx context.Context, arg CreateActiveSlugReservationParams) error
- func (q *Queries) CreateClaimedDNSAuthority(ctx context.Context, arg CreateClaimedDNSAuthorityParams) error
- func (q *Queries) CreateClaimedDomain(ctx context.Context, arg CreateClaimedDomainParams) (ControlDomain, error)
- func (q *Queries) CreateControlSession(ctx context.Context, arg CreateControlSessionParams) error
- func (q *Queries) CreateIdentity(ctx context.Context, arg CreateIdentityParams) error
- func (q *Queries) CreateManagedDomain(ctx context.Context, arg CreateManagedDomainParams) error
- func (q *Queries) CreateOIDCIdentity(ctx context.Context, arg CreateOIDCIdentityParams) (ControlIdentity, error)
- func (q *Queries) CreateOrGetDNSAuthority(ctx context.Context, arg CreateOrGetDNSAuthorityParams) (ControlDnsAuthority, error)
- func (q *Queries) CreateOrganizationTeam(ctx context.Context, arg CreateOrganizationTeamParams) (CreateOrganizationTeamRow, error)
- func (q *Queries) CreateOwnerMembership(ctx context.Context, arg CreateOwnerMembershipParams) error
- func (q *Queries) CreatePersonalTeam(ctx context.Context, arg CreatePersonalTeamParams) error
- func (q *Queries) CreateTeamInvitation(ctx context.Context, arg CreateTeamInvitationParams) (ControlTeamInvitation, error)
- func (q *Queries) CreateTeamMembership(ctx context.Context, arg CreateTeamMembershipParams) error
- func (q *Queries) DNSAuthorityReleaseReady(ctx context.Context, arg DNSAuthorityReleaseReadyParams) (pgtype.Bool, error)
- func (q *Queries) DeleteControlTLSCacheEntry(ctx context.Context, arg DeleteControlTLSCacheEntryParams) error
- func (q *Queries) DeleteExpiredOIDCAssertionExchanges(ctx context.Context, now pgtype.Timestamptz) error
- func (q *Queries) DeleteRoute(ctx context.Context, arg DeleteRouteParams) (int64, error)
- func (q *Queries) DisconnectPublisherConnection(ctx context.Context, arg DisconnectPublisherConnectionParams) (ControlRouteSessionConnection, error)
- func (q *Queries) EnsureACMEAccount(ctx context.Context, arg EnsureACMEAccountParams) (ControlAcmeAccount, error)
- func (q *Queries) EnsureExternalAuthorityPrincipal(ctx context.Context, arg EnsureExternalAuthorityPrincipalParams) (ControlIdentity, error)
- func (q *Queries) EnsureExternalRetryMasterKey(ctx context.Context, arg EnsureExternalRetryMasterKeyParams) (EnsureExternalRetryMasterKeyRow, error)
- func (q *Queries) EnsureIngressUsageRun(ctx context.Context, arg EnsureIngressUsageRunParams) (ControlIngressUsageRun, error)
- func (q *Queries) EnsureRouteUsageConfiguration(ctx context.Context, arg EnsureRouteUsageConfigurationParams) (ControlRouteUsageConfiguration, error)
- func (q *Queries) ExpirePublisherConnection(ctx context.Context, arg ExpirePublisherConnectionParams) (ControlRouteSessionConnection, error)
- func (q *Queries) ExpireTeamInvitations(ctx context.Context, arg ExpireTeamInvitationsParams) ([]string, error)
- func (q *Queries) FinalizeRouteUsageBuckets(ctx context.Context, arg FinalizeRouteUsageBucketsParams) ([]ControlRouteUsageBucket, error)
- func (q *Queries) FindBuiltinIdentity(ctx context.Context) (ControlIdentity, error)
- func (q *Queries) FindInvitationTeamByTokenDigest(ctx context.Context, tokenDigest []byte) (string, error)
- func (q *Queries) FindManagedDomain(ctx context.Context) (ControlDomain, error)
- func (q *Queries) FindOIDCIdentity(ctx context.Context, arg FindOIDCIdentityParams) (ControlIdentity, error)
- func (q *Queries) GetACMEAccountByDirectory(ctx context.Context, directoryUrl string) (ControlAcmeAccount, error)
- func (q *Queries) GetACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)
- func (q *Queries) GetACMEOrderByIdempotency(ctx context.Context, arg GetACMEOrderByIdempotencyParams) (ControlAcmeOrder, error)
- func (q *Queries) GetActiveRouteSessionChallengeExpiry(ctx context.Context, arg GetActiveRouteSessionChallengeExpiryParams) (pgtype.Timestamptz, error)
- func (q *Queries) GetActiveRouteSessionMembership(ctx context.Context, arg GetActiveRouteSessionMembershipParams) (GetActiveRouteSessionMembershipRow, error)
- func (q *Queries) GetAdminRuntimeCounts(ctx context.Context, now pgtype.Timestamptz) (GetAdminRuntimeCountsRow, error)
- func (q *Queries) GetAuthorizedRouteByHostname(ctx context.Context, arg GetAuthorizedRouteByHostnameParams) (GetAuthorizedRouteByHostnameRow, error)
- func (q *Queries) GetClaimedDomainByIdempotency(ctx context.Context, arg GetClaimedDomainByIdempotencyParams) (GetClaimedDomainByIdempotencyRow, error)
- func (q *Queries) GetControlSessionByAccessID(ctx context.Context, accessTokenID string) (GetControlSessionByAccessIDRow, error)
- func (q *Queries) GetControlTLSCacheEntry(ctx context.Context, arg GetControlTLSCacheEntryParams) (GetControlTLSCacheEntryRow, error)
- func (q *Queries) GetDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)
- func (q *Queries) GetDNSAuthorityByReleaseIdempotency(ctx context.Context, releaseIdempotencyKey pgtype.Text) (ControlDnsAuthority, error)
- func (q *Queries) GetDNSChallengeContext(ctx context.Context, arg GetDNSChallengeContextParams) (GetDNSChallengeContextRow, error)
- func (q *Queries) GetExternalAuthorityRoute(ctx context.Context, arg GetExternalAuthorityRouteParams) (GetExternalAuthorityRouteRow, error)
- func (q *Queries) GetIdentityContextIdentity(ctx context.Context, identityID string) (GetIdentityContextIdentityRow, error)
- func (q *Queries) GetIdentityRoute(ctx context.Context, arg GetIdentityRouteParams) (GetIdentityRouteRow, error)
- func (q *Queries) GetIdentityTeam(ctx context.Context, arg GetIdentityTeamParams) (GetIdentityTeamRow, error)
- func (q *Queries) GetIngressLease(ctx context.Context, arg GetIngressLeaseParams) (ControlIngressLease, error)
- func (q *Queries) GetIngressUsageReport(ctx context.Context, arg GetIngressUsageReportParams) (ControlIngressUsageReport, error)
- func (q *Queries) GetInvitationByIdempotency(ctx context.Context, arg GetInvitationByIdempotencyParams) (GetInvitationByIdempotencyRow, error)
- func (q *Queries) GetOpenRouteRecoveryEpisode(ctx context.Context, arg GetOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
- func (q *Queries) GetOpenRouteSession(ctx context.Context, routeID string) (ControlRouteSession, error)
- func (q *Queries) GetOrganizationTeamByIdempotency(ctx context.Context, arg GetOrganizationTeamByIdempotencyParams) (GetOrganizationTeamByIdempotencyRow, error)
- func (q *Queries) GetPublisherConnectionForClaim(ctx context.Context, publisherConnectionID string) (ControlRouteSessionConnection, error)
- func (q *Queries) GetRelayDNSChallengeContext(ctx context.Context, orderID string) (GetRelayDNSChallengeContextRow, error)
- func (q *Queries) GetRelayLeaseForClaim(ctx context.Context, relayID string) (GetRelayLeaseForClaimRow, error)
- func (q *Queries) GetRelayLeaseForReady(ctx context.Context, relayID string) (GetRelayLeaseForReadyRow, error)
- func (q *Queries) GetRelayTransportCertificate(ctx context.Context, arg GetRelayTransportCertificateParams) (ControlRelayService, error)
- func (q *Queries) GetRouteByCreatorIdempotency(ctx context.Context, arg GetRouteByCreatorIdempotencyParams) (GetRouteByCreatorIdempotencyRow, error)
- func (q *Queries) GetRouteCreationContext(ctx context.Context, arg GetRouteCreationContextParams) (GetRouteCreationContextRow, error)
- func (q *Queries) GetRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)
- func (q *Queries) GetRouteSessionByIdempotency(ctx context.Context, arg GetRouteSessionByIdempotencyParams) (ControlRouteSession, error)
- func (q *Queries) GetRouteSessionByTokenID(ctx context.Context, sessionTokenID string) (ControlRouteSession, error)
- func (q *Queries) GetRouteUsageBucketByID(ctx context.Context, bucketID int64) (ControlRouteUsageBucket, error)
- func (q *Queries) GetRouteUsageBucketForUpdate(ctx context.Context, arg GetRouteUsageBucketForUpdateParams) (ControlRouteUsageBucket, error)
- func (q *Queries) GetTeamActorContext(ctx context.Context, arg GetTeamActorContextParams) (GetTeamActorContextRow, error)
- func (q *Queries) GetTeamMembershipContext(ctx context.Context, arg GetTeamMembershipContextParams) (GetTeamMembershipContextRow, error)
- func (q *Queries) HeartbeatRouteSession(ctx context.Context, arg HeartbeatRouteSessionParams) (ControlRouteSession, error)
- func (q *Queries) InsertACMEOrder(ctx context.Context, arg InsertACMEOrderParams) (ControlAcmeOrder, error)
- func (q *Queries) InsertAdminAuditEvent(ctx context.Context, arg InsertAdminAuditEventParams) error
- func (q *Queries) InsertCertificateIssuanceAuditEvent(ctx context.Context, arg InsertCertificateIssuanceAuditEventParams) error
- func (q *Queries) InsertExpiredEphemeralRouteDeleteAuditEvent(ctx context.Context, arg InsertExpiredEphemeralRouteDeleteAuditEventParams) error
- func (q *Queries) InsertFinalIngressRoutingTableEvent(ctx context.Context, arg InsertFinalIngressRoutingTableEventParams) (int64, error)
- func (q *Queries) InsertIngressRoutingTableEvent(ctx context.Context, arg InsertIngressRoutingTableEventParams) (int64, error)
- func (q *Queries) InsertRelayCertificateOrder(ctx context.Context, arg InsertRelayCertificateOrderParams) (ControlRelayCertificateOrder, error)
- func (q *Queries) InsertRoute(ctx context.Context, arg InsertRouteParams) (ControlRoute, error)
- func (q *Queries) InsertRouteCreateAuditEvent(ctx context.Context, arg InsertRouteCreateAuditEventParams) error
- func (q *Queries) InsertRouteDeleteAuditEvent(ctx context.Context, arg InsertRouteDeleteAuditEventParams) error
- func (q *Queries) InsertRouteSession(ctx context.Context, arg InsertRouteSessionParams) (ControlRouteSession, error)
- func (q *Queries) InsertRouteSessionAuditEvent(ctx context.Context, arg InsertRouteSessionAuditEventParams) error
- func (q *Queries) InsertRouteSessionConnections(ctx context.Context, arg InsertRouteSessionConnectionsParams) ([]ControlRouteSessionConnection, error)
- func (q *Queries) InsertRouteUpdateAuditEvent(ctx context.Context, arg InsertRouteUpdateAuditEventParams) error
- func (q *Queries) InsertRouteUsageDelivery(ctx context.Context, arg InsertRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
- func (q *Queries) LatestIngressRoutingEntryRevision(ctx context.Context, arg LatestIngressRoutingEntryRevisionParams) (int64, error)
- func (q *Queries) ListACMEOrderAuthorizations(ctx context.Context, issuanceID string) ([]ControlAcmeAuthorization, error)
- func (q *Queries) ListAdminRelayLeases(ctx context.Context, arg ListAdminRelayLeasesParams) ([]ListAdminRelayLeasesRow, error)
- func (q *Queries) ListCurrentDomainNames(ctx context.Context) ([]string, error)
- func (q *Queries) ListDNSChallengePresentations(ctx context.Context, baseIdentifier string) ([]ListDNSChallengePresentationsRow, error)
- func (q *Queries) ListExternalAuthorityRoutes(ctx context.Context, arg ListExternalAuthorityRoutesParams) ([]ListExternalAuthorityRoutesRow, error)
- func (q *Queries) ListIdentityMembershipContexts(ctx context.Context, identityID string) ([]ListIdentityMembershipContextsRow, error)
- func (q *Queries) ListIdentityRoutes(ctx context.Context, arg ListIdentityRoutesParams) ([]ListIdentityRoutesRow, error)
- func (q *Queries) ListIdentityTeamDomains(ctx context.Context, arg ListIdentityTeamDomainsParams) ([]ListIdentityTeamDomainsRow, error)
- func (q *Queries) ListIdentityTeams(ctx context.Context, identityID string) ([]ListIdentityTeamsRow, error)
- func (q *Queries) ListIngressRoutingTableEvents(ctx context.Context, arg ListIngressRoutingTableEventsParams) ([]ControlIngressRoutingTableEvent, error)
- func (q *Queries) ListIngressRoutingTableSnapshot(ctx context.Context, arg ListIngressRoutingTableSnapshotParams) ([]ControlIngressRoutingTableEvent, error)
- func (q *Queries) ListLatestIngressUsageReports(ctx context.Context, arg ListLatestIngressUsageReportsParams) ([]ListLatestIngressUsageReportsRow, error)
- func (q *Queries) ListMaintenanceControls(ctx context.Context) ([]ControlMaintenanceControl, error)
- func (q *Queries) ListRelayDNSChallengePresentations(ctx context.Context, tlsServerName string) ([]ListRelayDNSChallengePresentationsRow, error)
- func (q *Queries) ListRelayServiceAssignmentTotals(ctx context.Context) ([]ControlRelayServiceAssignmentTotal, error)
- func (q *Queries) ListRouteSessionConnections(ctx context.Context, routeSessionID string) ([]ControlRouteSessionConnection, error)
- func (q *Queries) ListTeamInvitations(ctx context.Context, teamID string) ([]ListTeamInvitationsRow, error)
- func (q *Queries) ListTeamMemberNamespaceLabels(ctx context.Context, teamID string) ([]ListTeamMemberNamespaceLabelsRow, error)
- func (q *Queries) ListTeamMembershipContexts(ctx context.Context, teamID string) ([]ListTeamMembershipContextsRow, error)
- func (q *Queries) ListValidReadyPublisherConnections(ctx context.Context, arg ListValidReadyPublisherConnectionsParams) ([]ListValidReadyPublisherConnectionsRow, error)
- func (q *Queries) LockACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)
- func (q *Queries) LockACMEOrderForInstall(ctx context.Context, arg LockACMEOrderForInstallParams) (ControlAcmeOrder, error)
- func (q *Queries) LockCertificateIssuanceControl(ctx context.Context) (bool, error)
- func (q *Queries) LockControlSessionByRefreshID(ctx context.Context, refreshTokenID string) (LockControlSessionByRefreshIDRow, error)
- func (q *Queries) LockDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)
- func (q *Queries) LockDNSAuthorityLocalDomain(ctx context.Context, authorityReference pgtype.Text) error
- func (q *Queries) LockDNSAuthorityLocalTeam(ctx context.Context, authorityReference pgtype.Text) error
- func (q *Queries) LockDomainRoutes(ctx context.Context, arg LockDomainRoutesParams) ([]ControlRoute, error)
- func (q *Queries) LockEligibleRelayLeases(ctx context.Context, arg LockEligibleRelayLeasesParams) ([]LockEligibleRelayLeasesRow, error)
- func (q *Queries) LockExpiredEphemeralRoutes(ctx context.Context, arg LockExpiredEphemeralRoutesParams) ([]ControlRoute, error)
- func (q *Queries) LockHostedTeamRoutes(ctx context.Context, teamID string) ([]ControlRoute, error)
- func (q *Queries) LockIdentityBootstrap(ctx context.Context) error
- func (q *Queries) LockIdentityForTeamCreation(ctx context.Context, identityID string) (string, error)
- func (q *Queries) LockIdentityRouteForDelete(ctx context.Context, arg LockIdentityRouteForDeleteParams) (LockIdentityRouteForDeleteRow, error)
- func (q *Queries) LockIngressLease(ctx context.Context, arg LockIngressLeaseParams) (ControlIngressLease, error)
- func (q *Queries) LockIngressRoutingTableClock(ctx context.Context) (int64, error)
- func (q *Queries) LockInvalidReadyPublisherConnections(ctx context.Context, now pgtype.Timestamptz) ([]ControlRouteSessionConnection, error)
- func (q *Queries) LockInvitationByTokenDigest(ctx context.Context, arg LockInvitationByTokenDigestParams) (LockInvitationByTokenDigestRow, error)
- func (q *Queries) LockLocalRouteTeamForMutation(ctx context.Context, routeID string) (string, error)
- func (q *Queries) LockLocalTeamForMutation(ctx context.Context, teamID string) (string, error)
- func (q *Queries) LockLocalTeamForSession(ctx context.Context, teamID string) (string, error)
- func (q *Queries) LockManagedDomainForClaim(ctx context.Context) (ControlDomain, error)
- func (q *Queries) LockMembershipRoutes(ctx context.Context, arg LockMembershipRoutesParams) ([]ControlRoute, error)
- func (q *Queries) LockRelayServiceForCertificate(ctx context.Context, relayServiceID string) (string, error)
- func (q *Queries) LockRelayServicesForPlacement(ctx context.Context) ([]string, error)
- func (q *Queries) LockRouteCreationControl(ctx context.Context) (bool, error)
- func (q *Queries) LockRouteCreator(ctx context.Context, identityID string) (string, error)
- func (q *Queries) LockRouteForSession(ctx context.Context, routeID string) (ControlRoute, error)
- func (q *Queries) LockRouteForUsage(ctx context.Context, routeID string) (string, error)
- func (q *Queries) LockRouteRecoveryEpisode(ctx context.Context, recoveryEpisodeID int64) (ControlRouteRecoveryEpisode, error)
- func (q *Queries) LockRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)
- func (q *Queries) LockRouteSessionCreationControl(ctx context.Context) (bool, error)
- func (q *Queries) LockRouteSessionForUsage(ctx context.Context, arg LockRouteSessionForUsageParams) (ControlRouteSession, error)
- func (q *Queries) LockTeamActorContext(ctx context.Context, arg LockTeamActorContextParams) (LockTeamActorContextRow, error)
- func (q *Queries) LockTeamDomain(ctx context.Context, arg LockTeamDomainParams) (LockTeamDomainRow, error)
- func (q *Queries) LockTeamForInvitationAcceptance(ctx context.Context, teamID string) (string, error)
- func (q *Queries) LockTeamInvitation(ctx context.Context, arg LockTeamInvitationParams) (LockTeamInvitationRow, error)
- func (q *Queries) LockTeamMembership(ctx context.Context, arg LockTeamMembershipParams) (LockTeamMembershipRow, error)
- func (q *Queries) MarkACMEAuthorizationsPresented(ctx context.Context, arg MarkACMEAuthorizationsPresentedParams) (int64, error)
- func (q *Queries) MarkACMEOrderInstalled(ctx context.Context, arg MarkACMEOrderInstalledParams) (ControlAcmeOrder, error)
- func (q *Queries) MarkClaimedDomainReleasing(ctx context.Context, arg MarkClaimedDomainReleasingParams) (int64, error)
- func (q *Queries) MarkDNSAuthorityReleasing(ctx context.Context, arg MarkDNSAuthorityReleasingParams) (int64, error)
- func (q *Queries) MarkExpiredIngressUsageRunIncomplete(ctx context.Context, arg MarkExpiredIngressUsageRunIncompleteParams) error
- func (q *Queries) MarkExpiredIngressUsageRunsIncomplete(ctx context.Context, now pgtype.Timestamptz) ([]ControlIngressUsageRun, error)
- func (q *Queries) MarkIngressUsageRunReported(ctx context.Context, arg MarkIngressUsageRunReportedParams) (ControlIngressUsageRun, error)
- func (q *Queries) MarkInvitationExpired(ctx context.Context, invitationID string) (int64, error)
- func (q *Queries) MarkPublisherConnectionReady(ctx context.Context, arg MarkPublisherConnectionReadyParams) (ControlRouteSessionConnection, error)
- func (q *Queries) MarkRouteSessionCertificateInstalled(ctx context.Context, arg MarkRouteSessionCertificateInstalledParams) (ControlRouteSession, error)
- func (q *Queries) MarkRouteSessionReady(ctx context.Context, arg MarkRouteSessionReadyParams) (ControlRouteSession, error)
- func (q *Queries) ObserveAuthorityRevision(ctx context.Context, arg ObserveAuthorityRevisionParams) (int64, error)
- func (q *Queries) ObserveRouteRecoveryEpisode(ctx context.Context, arg ObserveRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
- func (q *Queries) OpenRouteRecoveryEpisode(ctx context.Context, arg OpenRouteRecoveryEpisodeParams) error
- func (q *Queries) PruneIngressRoutingHistoryBatch(ctx context.Context, afterRevision int64) (PruneIngressRoutingHistoryBatchRow, error)
- func (q *Queries) PutControlTLSCacheEntry(ctx context.Context, arg PutControlTLSCacheEntryParams) error
- func (q *Queries) QuarantineMemberSlug(ctx context.Context, arg QuarantineMemberSlugParams) (int64, error)
- func (q *Queries) ReadIngressRoutingTableClock(ctx context.Context) (ControlIngressRoutingTableClock, error)
- func (q *Queries) RegisterIngress(ctx context.Context, arg RegisterIngressParams) (ControlIngressLease, error)
- func (q *Queries) RegisterRelay(ctx context.Context, arg RegisterRelayParams) (RegisterRelayRow, error)
- func (q *Queries) ReleaseInvitedMemberSlug(ctx context.Context, arg ReleaseInvitedMemberSlugParams) (int64, error)
- func (q *Queries) RemoveTeamMembership(ctx context.Context, arg RemoveTeamMembershipParams) (int64, error)
- func (q *Queries) RenewEphemeralRouteExpiry(ctx context.Context, arg RenewEphemeralRouteExpiryParams) (pgtype.Timestamptz, error)
- func (q *Queries) RenewIngress(ctx context.Context, arg RenewIngressParams) (ControlIngressLease, error)
- func (q *Queries) RenewRelay(ctx context.Context, arg RenewRelayParams) (RenewRelayRow, error)
- func (q *Queries) ReplaceRouteSessionConnection(ctx context.Context, arg ReplaceRouteSessionConnectionParams) (ControlRouteSessionConnection, error)
- func (q *Queries) ReserveInvitedMemberSlug(ctx context.Context, arg ReserveInvitedMemberSlugParams) (string, error)
- func (q *Queries) ReserveManagedLabel(ctx context.Context, arg ReserveManagedLabelParams) (string, error)
- func (q *Queries) RetryRouteUsageDelivery(ctx context.Context, arg RetryRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
- func (q *Queries) RevokeControlSession(ctx context.Context, arg RevokeControlSessionParams) (int64, error)
- func (q *Queries) RevokeTeamInvitation(ctx context.Context, arg RevokeTeamInvitationParams) (int64, error)
- func (q *Queries) RotateACMEAccountKey(ctx context.Context, arg RotateACMEAccountKeyParams) error
- func (q *Queries) RotateControlSessionCredentials(ctx context.Context, arg RotateControlSessionCredentialsParams) (int64, error)
- func (q *Queries) RotateControlSessionRetrySecret(ctx context.Context, arg RotateControlSessionRetrySecretParams) error
- func (q *Queries) RotateControlTLSCacheEntry(ctx context.Context, arg RotateControlTLSCacheEntryParams) error
- func (q *Queries) RotateExternalRetryMasterKey(ctx context.Context, arg RotateExternalRetryMasterKeyParams) error
- func (q *Queries) RotateRelayCertificateOrderPrivateKey(ctx context.Context, arg RotateRelayCertificateOrderPrivateKeyParams) error
- func (q *Queries) RotateRelayServicePrivateKey(ctx context.Context, arg RotateRelayServicePrivateKeyParams) error
- func (q *Queries) SaveACMEAuthorizationWork(ctx context.Context, arg SaveACMEAuthorizationWorkParams) (ControlAcmeAuthorization, error)
- func (q *Queries) SaveACMEOrderWork(ctx context.Context, arg SaveACMEOrderWorkParams) (ControlAcmeOrder, error)
- func (q *Queries) SaveDNSAuthorityWork(ctx context.Context, arg SaveDNSAuthorityWorkParams) (ControlDnsAuthority, error)
- func (q *Queries) SaveDNSRouteWork(ctx context.Context, arg SaveDNSRouteWorkParams) (ControlRoute, error)
- func (q *Queries) SaveRelayCertificateOrderWork(ctx context.Context, arg SaveRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
- func (q *Queries) SelectIngressRoutingRetentionFloor(ctx context.Context, cutoff pgtype.Timestamptz) (int64, error)
- func (q *Queries) SetDNSReadyDomainDefault(ctx context.Context, arg SetDNSReadyDomainDefaultParams) (int64, error)
- func (q *Queries) SetDomainAuthorityRevision(ctx context.Context, arg SetDomainAuthorityRevisionParams) error
- func (q *Queries) SetMaintenanceControl(ctx context.Context, arg SetMaintenanceControlParams) (ControlMaintenanceControl, error)
- func (q *Queries) SetPersonalTeamDefaultDomain(ctx context.Context, arg SetPersonalTeamDefaultDomainParams) error
- func (q *Queries) SetTeamDefaultDomain(ctx context.Context, arg SetTeamDefaultDomainParams) (int64, error)
- func (q *Queries) StoreRelayTransportCertificate(ctx context.Context, arg StoreRelayTransportCertificateParams) (ControlRelayService, error)
- func (q *Queries) SuspendAuthorityRoute(ctx context.Context, arg SuspendAuthorityRouteParams) (int64, error)
- func (q *Queries) TeamMembershipIdentityExists(ctx context.Context, arg TeamMembershipIdentityExistsParams) (bool, error)
- func (q *Queries) TryLockIngressRoutingHistoryCleanup(ctx context.Context) (bool, error)
- func (q *Queries) UpdateACMEAccountRegistration(ctx context.Context, arg UpdateACMEAccountRegistrationParams) (ControlAcmeAccount, error)
- func (q *Queries) UpdateLocalDomainForDNSAuthority(ctx context.Context, arg UpdateLocalDomainForDNSAuthorityParams) (UpdateLocalDomainForDNSAuthorityRow, error)
- func (q *Queries) UpdateMembershipRole(ctx context.Context, arg UpdateMembershipRoleParams) (int64, error)
- func (q *Queries) UpdateOIDCIdentity(ctx context.Context, arg UpdateOIDCIdentityParams) (ControlIdentity, error)
- func (q *Queries) UpdateRoute(ctx context.Context, arg UpdateRouteParams) (ControlRoute, error)
- func (q *Queries) UpdateRouteRecoveryHistogram(ctx context.Context, arg UpdateRouteRecoveryHistogramParams) (ControlRouteRecoveryHistogram, error)
- func (q *Queries) WakeACMEOrder(ctx context.Context, arg WakeACMEOrderParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RegisterIngressParams
- type RegisterRelayParams
- type RegisterRelayRow
- type ReleaseInvitedMemberSlugParams
- type RemoveTeamMembershipParams
- type RenewEphemeralRouteExpiryParams
- type RenewIngressParams
- type RenewRelayParams
- type RenewRelayRow
- type ReplaceRouteSessionConnectionParams
- type ReserveInvitedMemberSlugParams
- type ReserveManagedLabelParams
- type RetryRouteUsageDeliveryParams
- type RevokeControlSessionParams
- type RevokeTeamInvitationParams
- type RotateACMEAccountKeyParams
- type RotateControlSessionCredentialsParams
- type RotateControlSessionRetrySecretParams
- type RotateControlTLSCacheEntryParams
- type RotateExternalRetryMasterKeyParams
- type RotateRelayCertificateOrderPrivateKeyParams
- type RotateRelayServicePrivateKeyParams
- type SaveACMEAuthorizationWorkParams
- type SaveACMEOrderWorkParams
- type SaveDNSAuthorityWorkParams
- type SaveDNSRouteWorkParams
- type SaveRelayCertificateOrderWorkParams
- type SetDNSReadyDomainDefaultParams
- type SetDomainAuthorityRevisionParams
- type SetMaintenanceControlParams
- type SetPersonalTeamDefaultDomainParams
- type SetTeamDefaultDomainParams
- type StoreRelayTransportCertificateParams
- type SuspendAuthorityRouteParams
- type TeamMembershipIdentityExistsParams
- type UpdateACMEAccountRegistrationParams
- type UpdateLocalDomainForDNSAuthorityParams
- type UpdateLocalDomainForDNSAuthorityRow
- type UpdateMembershipRoleParams
- type UpdateOIDCIdentityParams
- type UpdateRouteParams
- type UpdateRouteRecoveryHistogramParams
- type WakeACMEOrderParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivateMemberSlugParams ¶
type ActivateMemberSlugParams struct {
IdentityID pgtype.Text
ActivatedAt pgtype.Timestamptz
SlugReservationID string
}
type AdvanceAuthorityRevisionParams ¶
type AdvanceAuthorityRevisionParams struct {
Issuer string
TeamID string
PolicyRevision int64
UpdatedAt pgtype.Timestamptz
}
type AdvanceTeamPolicyRevisionParams ¶
type AdvanceTeamPolicyRevisionParams struct {
UpdatedAt pgtype.Timestamptz
TeamID string
}
type ApplyIngressUsageReportParams ¶
type ApplyIngressUsageReportParams struct {
IngressID string
IngressRunID string
RouteID string
RouteVersion int64
BucketStart pgtype.Timestamptz
BucketEnd pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
ReportRevision int64
ConnectionAttempts int64
PolicyDenials int64
CapacityDenials int64
VisitorStreamOpenFailures int64
SuccessfulStreams int64
ConnectionNanoseconds int64
IngressBytes int64
EgressBytes int64
HistogramData []byte
Final bool
ReceivedAt pgtype.Timestamptz
DeltaConnectionAttempts int64
DeltaPolicyDenials int64
DeltaCapacityDenials int64
DeltaVisitorStreamOpenFailures int64
DeltaSuccessfulStreams int64
DeltaConnectionNanoseconds int64
DeltaIngressBytes int64
DeltaEgressBytes int64
MergedHistogramData []byte
}
type BeginAdminRelayDrainParams ¶
type BeginAdminRelayDrainParams struct {
DrainDeadline pgtype.Timestamptz
DrainedAt pgtype.Timestamptz
RelayID string
RelayRunID string
RelayLeaseRevision int64
}
type BeginAdminRelayDrainRow ¶
type BeginAdminRelayDrainRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type BeginDNSAuthorityReleaseParams ¶
type BeginDNSAuthorityReleaseParams struct {
ReleaseIdempotencyKey pgtype.Text
UpdatedAt pgtype.Timestamptz
AuthorityReference string
}
type BeginIngressDrainParams ¶
type BeginIngressDrainParams struct {
DrainDeadline pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
IngressID string
IngressRunID string
IngressLeaseRevision int64
}
type BeginRelayDrainParams ¶
type BeginRelayDrainParams struct {
DrainDeadline pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
RelayServiceID string
RelayID string
RelayRunID string
RelayLeaseRevision int64
}
type BeginRelayDrainRow ¶
type BeginRelayDrainRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type CancelOpenRouteRecoveryEpisodeParams ¶
type CancelOpenRouteRecoveryEpisodeParams struct {
CanceledAt pgtype.Timestamptz
RouteID string
RouteVersion int64
}
type CancelRouteSessionACMEAuthorizationsParams ¶
type CancelRouteSessionACMEAuthorizationsParams struct {
CanceledAt pgtype.Timestamptz
RouteSessionID string
}
type CancelRouteSessionACMEOrdersParams ¶
type CancelRouteSessionACMEOrdersParams struct {
CanceledAt pgtype.Timestamptz
RouteSessionID string
}
type ClaimACMEOrderWorkParams ¶
type ClaimACMEOrderWorkParams struct {
WorkOwner pgtype.Text
WorkExpiresAt pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
}
type ClaimDNSAuthorityWorkParams ¶
type ClaimDNSAuthorityWorkParams struct {
WorkOwner pgtype.Text
WorkExpiresAt pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
}
type ClaimDNSRouteWorkParams ¶
type ClaimDNSRouteWorkParams struct {
WorkOwner pgtype.Text
WorkExpiresAt pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
}
type ClaimPublisherConnectionParams ¶
type ClaimPublisherConnectionParams struct {
RelayID pgtype.Text
RelayRunID pgtype.Text
RelayLeaseRevision pgtype.Int8
ClaimID pgtype.Text
ConnectedAt pgtype.Timestamptz
PublisherConnectionID string
RouteSessionID string
RouteID string
RouteVersion int64
ConnectionSlot int16
ConnectionAssignmentRevision int64
RelayServiceID string
}
type ClaimRelayCertificateOrderWorkParams ¶
type ClaimRelayCertificateOrderWorkParams struct {
WorkOwner pgtype.Text
WorkExpiresAt pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
}
type ClaimRelayServiceForCertificateOrderParams ¶
type ClaimRelayServiceForCertificateOrderParams struct {
Now pgtype.Timestamptz
RetryFailedAfter pgtype.Timestamptz
}
type ClaimRouteUsageDeliveriesParams ¶
type ClaimRouteUsageDeliveriesParams struct {
WorkOwner pgtype.Text
WorkExpiresAt pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
BatchSize int32
}
type CloseRouteSessionConnectionsParams ¶
type CloseRouteSessionConnectionsParams struct {
ClosedAt pgtype.Timestamptz
RouteSessionID string
}
type CloseRouteSessionParams ¶
type CompleteACMEAuthorizationCleanupParams ¶
type CompleteACMEAuthorizationCleanupParams struct {
CompletedAt pgtype.Timestamptz
IssuanceID string
}
type ConsumeOIDCAssertionParams ¶
type ConsumeOIDCAssertionParams struct {
AssertionDigest []byte
ConsumedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
}
type ControlAcmeAccount ¶
type ControlAcmeAuthorization ¶
type ControlAcmeAuthorization struct {
ID string
OrderID string
Identifier string
AuthorizationUrl string
ChallengeType pgtype.Text
ChallengeUrl pgtype.Text
ChallengeToken pgtype.Text
ChallengeDigest []byte
PresentationReference pgtype.Text
State string
AuthorizationRevision int64
WorkOwner pgtype.Text
WorkEpoch int64
WorkExpiresAt pgtype.Timestamptz
Attempts int64
AvailableAt pgtype.Timestamptz
PresentedAt pgtype.Timestamptz
ValidatedAt pgtype.Timestamptz
CleanupCompletedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlAcmeOrder ¶
type ControlAcmeOrder struct {
ID string
AccountID string
RouteSessionID string
RouteID string
RouteVersion int64
IdempotencyKey string
RequestDigest []byte
CertificateCacheKey string
CertificateScope string
CertificateIdentifiers []string
ChallengeMethod string
CsrDer []byte
CsrDigest []byte
State string
OrderRevision int64
OrderUrl pgtype.Text
FinalizeUrl pgtype.Text
CertificateUrl pgtype.Text
CertificatePem []byte
NotBefore pgtype.Timestamptz
NotAfter pgtype.Timestamptz
RenewAt pgtype.Timestamptz
InstalledAt pgtype.Timestamptz
WorkOwner pgtype.Text
WorkEpoch int64
WorkExpiresAt pgtype.Timestamptz
Attempts int64
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlAdminAuditEvent ¶
type ControlAuthorityRevisionState ¶
type ControlAuthorityRevisionState struct {
Issuer string
TeamID string
ObservedPolicyRevision int64
AppliedPolicyRevision int64
ObservedAt pgtype.Timestamptz
AppliedAt pgtype.Timestamptz
}
type ControlControlSession ¶
type ControlControlSession struct {
ID string
IdentityID string
AuthenticationMethod string
AuthenticationSourceRevision int64
Administrator bool
AccessTokenID string
AccessTokenDigest []byte
AccessExpiresAt pgtype.Timestamptz
RefreshTokenID string
RefreshTokenDigest []byte
RetrySecretCiphertext []byte
RetrySecretStorageKeyID string
RefreshExpiresAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
LastRefreshedAt pgtype.Timestamptz
RevokedAt pgtype.Timestamptz
RevokedBy pgtype.Text
}
type ControlControlTlsCache ¶
type ControlDnsAuthority ¶
type ControlDnsAuthority struct {
AuthorityReference string
TeamID string
DomainID string
CanonicalDomain string
CreateIdempotencyKey string
CreateRequestDigest []byte
ReleaseIdempotencyKey pgtype.Text
Provider string
ProviderZoneID pgtype.Text
State string
Nameservers []string
WorkRevision int64
WorkOwner pgtype.Text
WorkEpoch int64
WorkExpiresAt pgtype.Timestamptz
Attempts int64
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlDomain ¶
type ControlDomain struct {
ID string
Kind string
TeamID pgtype.Text
CanonicalDomain string
DnsAuthorityReference pgtype.Text
State string
AuthorityRevision int64
VerificationTokenDigest []byte
CreatedByIdentityID pgtype.Text
ClaimIdempotencyKey pgtype.Text
ClaimRequestDigest []byte
MakeDefaultWhenReady bool
CreatedAt pgtype.Timestamptz
VerifiedAt pgtype.Timestamptz
ReusableAfter pgtype.Timestamptz
ReleasedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlIdentity ¶
type ControlIngressLease ¶
type ControlIngressLease struct {
IngressID string
IngressRunID string
IngressLeaseRevision int64
ProtocolVersion int64
ConnectionCapacity int64
ReportedConnections int64
RoutingTableRevision int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
}
type ControlIngressRoutingTableClock ¶
type ControlIngressRoutingTableClock struct {
Singleton bool
CurrentRevision int64
RetainedAfterRevision int64
UpdatedAt pgtype.Timestamptz
}
type ControlIngressUsageReport ¶
type ControlIngressUsageReport struct {
ReportID int64
IngressID string
IngressRunID string
RouteID string
RouteVersion int64
BucketStart pgtype.Timestamptz
BucketEnd pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
ReportRevision int64
ConnectionAttempts int64
PolicyDenials int64
CapacityDenials int64
VisitorStreamOpenFailures int64
SuccessfulStreams int64
ConnectionNanoseconds int64
IngressBytes int64
EgressBytes int64
HistogramData []byte
Final bool
ReceivedAt pgtype.Timestamptz
}
type ControlIngressUsageRun ¶
type ControlIngressUsageRun struct {
IngressID string
IngressRunID string
IngressLeaseRevision int64
StartedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
LastReportedAt pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
EndedAt pgtype.Timestamptz
CoverageComplete bool
IncompleteFrom pgtype.Timestamptz
IncompleteUntil pgtype.Timestamptz
}
type ControlManagedLabelReservation ¶
type ControlManagedLabelReservation struct {
Label string
CreatedAt pgtype.Timestamptz
}
type ControlMemberSlugReservation ¶
type ControlMemberSlugReservation struct {
ID string
TeamID string
MemberSlug string
State string
ReservedByIdentityID pgtype.Text
CreatedAt pgtype.Timestamptz
ActivatedAt pgtype.Timestamptz
QuarantinedAt pgtype.Timestamptz
ReusableAfter pgtype.Timestamptz
ReleasedAt pgtype.Timestamptz
}
type ControlOidcAssertionExchange ¶
type ControlOidcAssertionExchange struct {
AssertionDigest []byte
ConsumedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
}
type ControlRelayCertificateOrder ¶
type ControlRelayCertificateOrder struct {
ID string
AccountID string
RelayServiceID string
TlsServerName string
PrivateKeyCiphertext []byte
PrivateKeyStorageKeyID string
CsrDer []byte
CsrDigest []byte
State string
OrderRevision int64
OrderUrl pgtype.Text
FinalizeUrl pgtype.Text
CertificateUrl pgtype.Text
AuthorizationUrl pgtype.Text
ChallengeUrl pgtype.Text
ChallengeToken pgtype.Text
ChallengeDigest []byte
PresentationReference pgtype.Text
CertificatePem []byte
NotBefore pgtype.Timestamptz
NotAfter pgtype.Timestamptz
RenewAt pgtype.Timestamptz
WorkOwner pgtype.Text
WorkEpoch int64
WorkExpiresAt pgtype.Timestamptz
Attempts int64
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlRelayLease ¶
type ControlRelayLease struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
}
type ControlRelayService ¶
type ControlRelayService struct {
RelayServiceID string
RelayAddress string
TlsServerName string
TransportCertificatePem pgtype.Text
TransportPrivateKeyCiphertext []byte
TransportPrivateKeyStorageKeyID pgtype.Text
TransportCertificateSerial pgtype.Text
TransportCertificateExpiresAt pgtype.Timestamptz
Enabled bool
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlRoute ¶
type ControlRoute struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
}
type ControlRouteRecoveryEpisode ¶
type ControlRouteRecoveryEpisode struct {
RecoveryEpisodeID int64
RouteID string
RouteVersion int64
State string
OpenedAt pgtype.Timestamptz
ObservedAt pgtype.Timestamptz
CanceledAt pgtype.Timestamptz
ObservedSeconds pgtype.Float8
}
type ControlRouteRecoveryHistogram ¶
type ControlRouteRecoveryHistogram struct {
Singleton bool
ObservationCount int64
ObservationSumSeconds float64
BucketLe025 int64
BucketLe05 int64
BucketLe1 int64
BucketLe2 int64
BucketLe5 int64
BucketLe10 int64
BucketLe20 int64
BucketLe30 int64
BucketLe45 int64
BucketLe60 int64
BucketLe120 int64
UpdatedAt pgtype.Timestamptz
}
type ControlRouteSession ¶
type ControlRouteSession struct {
ID string
RouteID string
TeamID string
MembershipID pgtype.Text
ActingIdentityID string
RouteVersion int64
IdempotencyKey string
RequestDigest []byte
SessionTokenID string
SessionTokenDigest []byte
PolicyRevision int64
PolicyDenials int64
CertificateCacheKey string
CertificateScope string
CertificateIdentifiers []string
CertificateChallenge string
State string
CreatedAt pgtype.Timestamptz
LastHeartbeatAt pgtype.Timestamptz
PublisherExpiresAt pgtype.Timestamptz
CertificateInstalledAt pgtype.Timestamptz
CertificateIssuanceID pgtype.Text
CertificateNotAfter pgtype.Timestamptz
ReadyAt pgtype.Timestamptz
ClosedAt pgtype.Timestamptz
CloseReason pgtype.Text
AssignmentsOpen pgtype.Bool
}
type ControlRouteSessionConnection ¶
type ControlRouteSessionConnection struct {
RouteSessionID string
RouteID string
RouteVersion int64
ConnectionSlot int16
PublisherConnectionID string
ConnectionAssignmentRevision int64
RelayServiceID string
RelayAddress string
TlsServerName string
PublisherConnectionCredentialDigest []byte
PublisherConnectionCredentialExpiresAt pgtype.Timestamptz
ConnectedRelayID pgtype.Text
ConnectedRelayRunID pgtype.Text
ConnectedRelayLeaseRevision pgtype.Int8
ClaimID pgtype.Text
State string
AssignedAt pgtype.Timestamptz
ConnectedAt pgtype.Timestamptz
ReadyAt pgtype.Timestamptz
DisconnectedAt pgtype.Timestamptz
ClosedAt pgtype.Timestamptz
SessionOpen bool
}
type ControlRouteUsageBucket ¶
type ControlRouteUsageBucket struct {
BucketID int64
RouteID string
RouteVersion int64
TeamID string
ActingIdentityID string
BucketStart pgtype.Timestamptz
BucketEnd pgtype.Timestamptz
BucketRevision int64
ObservedThrough pgtype.Timestamptz
ConnectionAttempts int64
PolicyDenials int64
CapacityDenials int64
VisitorStreamOpenFailures int64
SuccessfulStreams int64
ConnectionNanoseconds int64
IngressBytes int64
EgressBytes int64
HistogramData []byte
Finalized bool
Complete bool
FinalizedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type ControlRouteUsageConfiguration ¶
type ControlRouteUsageConfiguration struct {
Singleton bool
VisitorNetworkHashMasterKey []byte
CreatedAt pgtype.Timestamptz
}
type ControlRouteUsageDelivery ¶
type ControlRouteUsageDelivery struct {
DeliveryID int64
BucketID int64
SourceRevision int64
DeliveryKey string
State string
WorkOwner pgtype.Text
WorkEpoch int64
WorkExpiresAt pgtype.Timestamptz
Attempts int64
AvailableAt pgtype.Timestamptz
LastAttemptedAt pgtype.Timestamptz
DeliveredAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
}
type ControlRuntimeSecret ¶
type ControlRuntimeSecret struct {
Singleton bool
ExternalRetryMasterKeyCiphertext []byte
ExternalRetryMasterKeyStorageKeyID string
CreatedAt pgtype.Timestamptz
}
type ControlTeam ¶
type ControlTeam struct {
ID string
Kind string
DisplayName string
ManagedLabel string
DefaultDomainID pgtype.Text
PolicyRevision int64
CreatedByIdentityID string
CreationIdempotencyKey pgtype.Text
CreationRequestDigest []byte
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
}
type ControlTeamInvitation ¶
type ControlTeamInvitation struct {
ID string
TeamID string
SlugReservationID string
InitialRole string
InvitedByIdentityID string
IdempotencyKey string
RequestDigest []byte
TokenDigest []byte
NormalizedEmailRestriction pgtype.Text
State string
CreatedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
AcceptedAt pgtype.Timestamptz
AcceptedByIdentityID pgtype.Text
AcceptedMembershipID pgtype.Text
RevokedAt pgtype.Timestamptz
RevokedByIdentityID pgtype.Text
}
type ControlTeamMembership ¶
type ControlTeamMembership struct {
ID string
TeamID string
IdentityID string
SlugReservationID string
ManagedLabel string
Role string
AuthorityRevision int64
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
RemovedAt pgtype.Timestamptz
RemovedByIdentityID pgtype.Text
}
type CreateControlSessionParams ¶
type CreateControlSessionParams struct {
ID string
IdentityID string
AuthenticationMethod string
AuthenticationSourceRevision int64
Administrator bool
AccessTokenID string
AccessTokenDigest []byte
AccessExpiresAt pgtype.Timestamptz
RefreshTokenID string
RefreshTokenDigest []byte
RetrySecretCiphertext []byte
RetrySecretStorageKeyID string
RefreshExpiresAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
}
type CreateIdentityParams ¶
type CreateManagedDomainParams ¶
type CreateManagedDomainParams struct {
ID string
CanonicalDomain string
CreatedAt pgtype.Timestamptz
}
type DNSAuthorityReleaseReadyParams ¶
type DNSAuthorityReleaseReadyParams struct {
AuthorityDomainID string
ObservedAt pgtype.Timestamptz
}
type DeleteRouteParams ¶
type DeleteRouteParams struct {
DeletedAt pgtype.Timestamptz
RouteID string
ExpectedMutationRevision int64
}
type DisconnectPublisherConnectionParams ¶
type DisconnectPublisherConnectionParams struct {
DisconnectedAt pgtype.Timestamptz
PublisherConnectionID string
RouteSessionID string
RouteID string
RouteVersion int64
ConnectionSlot int16
ConnectionAssignmentRevision int64
RelayServiceID string
RelayID pgtype.Text
RelayRunID pgtype.Text
RelayLeaseRevision pgtype.Int8
ClaimID pgtype.Text
}
type EnsureACMEAccountParams ¶
type EnsureExternalAuthorityPrincipalParams ¶
type EnsureExternalAuthorityPrincipalParams struct {
IdentityID string
CreatedAt pgtype.Timestamptz
}
type EnsureExternalRetryMasterKeyParams ¶
type EnsureExternalRetryMasterKeyParams struct {
ExternalRetryMasterKeyCiphertext []byte
ExternalRetryMasterKeyStorageKeyID string
CreatedAt pgtype.Timestamptz
}
type EnsureIngressUsageRunParams ¶
type EnsureIngressUsageRunParams struct {
IngressID string
IngressRunID string
IngressLeaseRevision int64
StartedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
}
type EnsureRouteUsageConfigurationParams ¶
type EnsureRouteUsageConfigurationParams struct {
VisitorNetworkHashMasterKey []byte
CreatedAt pgtype.Timestamptz
}
type ExpirePublisherConnectionParams ¶
type ExpirePublisherConnectionParams struct {
ExpiredAt pgtype.Timestamptz
PublisherConnectionID string
RouteSessionID string
ConnectionAssignmentRevision int64
}
type ExpireTeamInvitationsParams ¶
type ExpireTeamInvitationsParams struct {
TeamID string
Now pgtype.Timestamptz
}
type FinalizeRouteUsageBucketsParams ¶
type FinalizeRouteUsageBucketsParams struct {
FinalizedAt pgtype.Timestamptz
Through pgtype.Timestamptz
}
type FindOIDCIdentityParams ¶
type GetActiveRouteSessionChallengeExpiryParams ¶
type GetActiveRouteSessionChallengeExpiryParams struct {
RouteSessionID string
Now pgtype.Timestamptz
}
type GetAuthorizedRouteByHostnameRow ¶
type GetAuthorizedRouteByHostnameRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
}
type GetClaimedDomainByIdempotencyRow ¶
type GetClaimedDomainByIdempotencyRow struct {
ID string
Kind string
TeamID pgtype.Text
CanonicalDomain string
DnsAuthorityReference pgtype.Text
State string
AuthorityRevision int64
VerificationTokenDigest []byte
CreatedByIdentityID pgtype.Text
ClaimIdempotencyKey pgtype.Text
ClaimRequestDigest []byte
MakeDefaultWhenReady bool
CreatedAt pgtype.Timestamptz
VerifiedAt pgtype.Timestamptz
ReusableAfter pgtype.Timestamptz
ReleasedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
Nameservers []string
}
type GetControlSessionByAccessIDRow ¶
type GetControlSessionByAccessIDRow struct {
ID string
IdentityID string
AuthenticationMethod string
AuthenticationSourceRevision int64
AccessTokenDigest []byte
AccessExpiresAt pgtype.Timestamptz
RetrySecretCiphertext []byte
RetrySecretStorageKeyID string
RefreshExpiresAt pgtype.Timestamptz
Administrator bool
}
type GetExternalAuthorityRouteRow ¶
type GetExternalAuthorityRouteRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
AuthorizationRouteVersion int64
}
type GetIdentityRouteParams ¶
type GetIdentityRouteRow ¶
type GetIdentityRouteRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
}
type GetIdentityTeamParams ¶
type GetIdentityTeamRow ¶
type GetIngressLeaseParams ¶
type GetIngressLeaseParams struct {
IngressID string
IngressRunID string
IngressLeaseRevision int64
Now pgtype.Timestamptz
}
type GetInvitationByIdempotencyRow ¶
type GetInvitationByIdempotencyRow struct {
ID string
TeamID string
SlugReservationID string
InitialRole string
InvitedByIdentityID string
IdempotencyKey string
RequestDigest []byte
TokenDigest []byte
NormalizedEmailRestriction pgtype.Text
State string
CreatedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
AcceptedAt pgtype.Timestamptz
AcceptedByIdentityID pgtype.Text
AcceptedMembershipID pgtype.Text
RevokedAt pgtype.Timestamptz
RevokedByIdentityID pgtype.Text
MemberSlug string
}
type GetRelayLeaseForClaimRow ¶
type GetRelayLeaseForClaimRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type GetRelayLeaseForReadyRow ¶
type GetRelayLeaseForReadyRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type GetRouteByCreatorIdempotencyRow ¶
type GetRouteByCreatorIdempotencyRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
}
type GetRouteCreationContextRow ¶
type GetRouteCreationContextRow struct {
TeamKind string
TeamCreatorIdentityID string
PolicyRevision int64
IdentityKind string
ActorMembershipID string
ActorRole string
ActorManagedLabel string
ActorMemberSlug string
DomainKind string
DomainTeamID pgtype.Text
CanonicalDomain string
DomainState string
DnsAuthorityReference pgtype.Text
}
type GetRouteUsageBucketForUpdateParams ¶
type GetRouteUsageBucketForUpdateParams struct {
RouteID string
RouteVersion int64
BucketStart pgtype.Timestamptz
}
type GetTeamActorContextRow ¶
type HeartbeatRouteSessionParams ¶
type HeartbeatRouteSessionParams struct {
HeartbeatAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
RouteSessionID string
RouteID string
RouteVersion int64
}
type InsertACMEOrderParams ¶
type InsertACMEOrderParams struct {
ID string
AccountID string
RouteSessionID string
RouteID string
RouteVersion int64
IdempotencyKey string
RequestDigest []byte
CertificateCacheKey string
CertificateScope string
CertificateIdentifiers []string
ChallengeMethod string
CsrDer []byte
CsrDigest []byte
CreatedAt pgtype.Timestamptz
}
type InsertExpiredEphemeralRouteDeleteAuditEventParams ¶
type InsertExpiredEphemeralRouteDeleteAuditEventParams struct {
RequestID string
RouteID string
OccurredAt pgtype.Timestamptz
}
type InsertFinalIngressRoutingTableEventParams ¶
type InsertFinalIngressRoutingTableEventParams struct {
EventKind string
RouteID string
RouteVersion int64
CanonicalHostname string
EntryRevision int64
Projection []byte
RouteExpiresAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type InsertIngressRoutingTableEventParams ¶
type InsertIngressRoutingTableEventParams struct {
EventKind string
RouteID string
RouteVersion int64
CanonicalHostname string
EntryRevision int64
Projection []byte
RouteExpiresAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
}
type InsertRouteParams ¶
type InsertRouteParams struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
DnsAuthorityReference pgtype.Text
DnsState string
CreatedAt pgtype.Timestamptz
Ephemeral bool
ExpiresAt pgtype.Timestamptz
}
type InsertRouteSessionConnectionsParams ¶
type InsertRouteSessionConnectionsParams struct {
RouteSessionID string
RouteID string
RouteVersion int64
PublisherConnectionIds []string
RelayServiceIds []string
RelayAddresses []string
TlsServerNames []string
CredentialDigests [][]byte
PublisherConnectionCredentialExpiresAt pgtype.Timestamptz
AssignedAt pgtype.Timestamptz
}
type InsertRouteSessionParams ¶
type InsertRouteSessionParams struct {
ID string
RouteID string
TeamID string
MembershipID pgtype.Text
ActingIdentityID string
IdempotencyKey string
RequestDigest []byte
SessionTokenID string
SessionTokenDigest []byte
PolicyRevision int64
CertificateCacheKey string
CertificateScope string
CertificateIdentifiers []string
CertificateChallenge string
CreatedAt pgtype.Timestamptz
LastHeartbeatAt pgtype.Timestamptz
PublisherExpiresAt pgtype.Timestamptz
ExpectedMutationRevision int64
}
type InsertRouteUsageDeliveryParams ¶
type InsertRouteUsageDeliveryParams struct {
BucketID int64
SourceRevision int64
DeliveryKey string
AvailableAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
}
type ListAdminRelayLeasesParams ¶
type ListAdminRelayLeasesParams struct {
Now pgtype.Timestamptz
Cursor pgtype.Text
PageLimit int32
}
type ListAdminRelayLeasesRow ¶
type ListAdminRelayLeasesRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type ListExternalAuthorityRoutesRow ¶
type ListExternalAuthorityRoutesRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
}
type ListIdentityRoutesRow ¶
type ListIdentityRoutesRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
OpenRouteSessionID string
}
type ListIdentityTeamsRow ¶
type ListIngressRoutingTableSnapshotParams ¶
type ListIngressRoutingTableSnapshotParams struct {
Now pgtype.Timestamptz
ThroughRevision int64
}
type ListLatestIngressUsageReportsRow ¶
type ListLatestIngressUsageReportsRow struct {
RouteID string
RouteVersion int64
BucketStart pgtype.Timestamptz
BucketEnd pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
ReportRevision int64
ConnectionAttempts int64
PolicyDenials int64
CapacityDenials int64
VisitorStreamOpenFailures int64
SuccessfulStreams int64
ConnectionNanoseconds int64
IngressBytes int64
EgressBytes int64
Final bool
}
type ListTeamInvitationsRow ¶
type ListTeamInvitationsRow struct {
ID string
TeamID string
SlugReservationID string
InitialRole string
InvitedByIdentityID string
IdempotencyKey string
RequestDigest []byte
TokenDigest []byte
NormalizedEmailRestriction pgtype.Text
State string
CreatedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
AcceptedAt pgtype.Timestamptz
AcceptedByIdentityID pgtype.Text
AcceptedMembershipID pgtype.Text
RevokedAt pgtype.Timestamptz
RevokedByIdentityID pgtype.Text
MemberSlug string
}
type ListValidReadyPublisherConnectionsParams ¶
type ListValidReadyPublisherConnectionsParams struct {
RouteSessionID string
Now pgtype.Timestamptz
}
type ListValidReadyPublisherConnectionsRow ¶
type ListValidReadyPublisherConnectionsRow struct {
RouteSessionID string
RouteID string
RouteVersion int64
ConnectionSlot int16
PublisherConnectionID string
ConnectionAssignmentRevision int64
RelayServiceID string
ConnectedRelayID pgtype.Text
ConnectedRelayRunID pgtype.Text
ConnectedRelayLeaseRevision pgtype.Int8
InternalRelayAddress string
TlsServerName string
LeaseExpiresAt pgtype.Timestamptz
}
type LockACMEOrderForInstallParams ¶
type LockACMEOrderForInstallParams struct {
IssuanceID string
TeamID string
CertificateCacheKey string
CertificateScope string
CertificateIdentifiers []string
ChallengeMethod string
InstalledAt pgtype.Timestamptz
NotAfter pgtype.Timestamptz
}
type LockDomainRoutesParams ¶
type LockEligibleRelayLeasesParams ¶
type LockEligibleRelayLeasesParams struct {
Now pgtype.Timestamptz
RelayServiceIds []string
ProtocolVersion int64
}
type LockEligibleRelayLeasesRow ¶
type LockEligibleRelayLeasesRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type LockExpiredEphemeralRoutesParams ¶
type LockExpiredEphemeralRoutesParams struct {
Now pgtype.Timestamptz
BatchSize int32
}
type LockIdentityRouteForDeleteRow ¶
type LockIdentityRouteForDeleteRow struct {
ID string
TeamID string
DomainID string
MembershipID pgtype.Text
CreatedByIdentityID string
IdempotencyKey string
RequestDigest []byte
CanonicalHostname string
Target string
RouteScope string
PolicyRevision int64
IpPolicy string
AllowedIpPrefixes []netip.Prefix
LifecycleState string
DnsAuthorityReference pgtype.Text
DnsState string
DnsRevision int64
DnsWorkOwner pgtype.Text
DnsWorkEpoch int64
DnsWorkExpiresAt pgtype.Timestamptz
DnsAttempts int64
DnsAvailableAt pgtype.Timestamptz
DnsLastError pgtype.Text
NextRouteVersion int64
MutationRevision int64
Ephemeral bool
ExpiresAt pgtype.Timestamptz
SuspensionRevision int64
SuspensionReason pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
SuspendedAt pgtype.Timestamptz
DeletedAt pgtype.Timestamptz
ActorMembershipID string
ActorRole string
}
type LockIngressLeaseParams ¶
type LockIngressLeaseParams struct {
IngressID string
IngressRunID string
IngressLeaseRevision int64
Now pgtype.Timestamptz
}
type LockInvitationByTokenDigestRow ¶
type LockInvitationByTokenDigestRow struct {
ID string
TeamID string
SlugReservationID string
InitialRole string
InvitedByIdentityID string
IdempotencyKey string
RequestDigest []byte
TokenDigest []byte
NormalizedEmailRestriction pgtype.Text
State string
CreatedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
AcceptedAt pgtype.Timestamptz
AcceptedByIdentityID pgtype.Text
AcceptedMembershipID pgtype.Text
RevokedAt pgtype.Timestamptz
RevokedByIdentityID pgtype.Text
MemberSlug string
TeamKind string
TeamDisplayName string
AcceptingNormalizedEmail pgtype.Text
AcceptingEmailVerified bool
}
type LockTeamActorContextRow ¶
type LockTeamDomainParams ¶
type LockTeamDomainRow ¶
type LockTeamDomainRow struct {
ID string
Kind string
TeamID pgtype.Text
CanonicalDomain string
DnsAuthorityReference pgtype.Text
State string
AuthorityRevision int64
VerificationTokenDigest []byte
CreatedByIdentityID pgtype.Text
ClaimIdempotencyKey pgtype.Text
ClaimRequestDigest []byte
MakeDefaultWhenReady bool
CreatedAt pgtype.Timestamptz
VerifiedAt pgtype.Timestamptz
ReusableAfter pgtype.Timestamptz
ReleasedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
Nameservers []string
}
type LockTeamInvitationRow ¶
type LockTeamInvitationRow struct {
ID string
TeamID string
SlugReservationID string
InitialRole string
InvitedByIdentityID string
IdempotencyKey string
RequestDigest []byte
TokenDigest []byte
NormalizedEmailRestriction pgtype.Text
State string
CreatedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
AcceptedAt pgtype.Timestamptz
AcceptedByIdentityID pgtype.Text
AcceptedMembershipID pgtype.Text
RevokedAt pgtype.Timestamptz
RevokedByIdentityID pgtype.Text
MemberSlug string
}
type LockTeamMembershipRow ¶
type MarkACMEAuthorizationsPresentedParams ¶
type MarkACMEAuthorizationsPresentedParams struct {
PresentedAt pgtype.Timestamptz
IssuanceID string
}
type MarkACMEOrderInstalledParams ¶
type MarkACMEOrderInstalledParams struct {
InstalledAt pgtype.Timestamptz
IssuanceID string
}
type MarkDNSAuthorityReleasingParams ¶
type MarkDNSAuthorityReleasingParams struct {
UpdatedAt pgtype.Timestamptz
AuthorityReference string
}
type MarkExpiredIngressUsageRunIncompleteParams ¶
type MarkExpiredIngressUsageRunIncompleteParams struct {
EndedAt pgtype.Timestamptz
IngressID string
IngressRunID string
}
type MarkIngressUsageRunReportedParams ¶
type MarkIngressUsageRunReportedParams struct {
ReportedAt pgtype.Timestamptz
ObservedThrough pgtype.Timestamptz
Complete bool
IngressID string
IngressRunID string
IngressLeaseRevision int64
}
type MarkPublisherConnectionReadyParams ¶
type MarkPublisherConnectionReadyParams struct {
ReadyAt pgtype.Timestamptz
PublisherConnectionID string
RouteSessionID string
RouteID string
RouteVersion int64
ConnectionSlot int16
ConnectionAssignmentRevision int64
RelayServiceID string
RelayID pgtype.Text
RelayRunID pgtype.Text
RelayLeaseRevision pgtype.Int8
ClaimID pgtype.Text
}
type MarkRouteSessionCertificateInstalledParams ¶
type MarkRouteSessionCertificateInstalledParams struct {
IssuanceID pgtype.Text
InstalledAt pgtype.Timestamptz
NotAfter pgtype.Timestamptz
RouteSessionID string
RouteID string
RouteVersion int64
}
type MarkRouteSessionReadyParams ¶
type MarkRouteSessionReadyParams struct {
ReadyAt pgtype.Timestamptz
RouteSessionID string
RouteID string
RouteVersion int64
}
type ObserveAuthorityRevisionParams ¶
type ObserveAuthorityRevisionParams struct {
Issuer string
TeamID string
PolicyRevision int64
UpdatedAt pgtype.Timestamptz
}
type OpenRouteRecoveryEpisodeParams ¶
type OpenRouteRecoveryEpisodeParams struct {
RouteID string
RouteVersion int64
OpenedAt pgtype.Timestamptz
}
type QuarantineMemberSlugParams ¶
type QuarantineMemberSlugParams struct {
QuarantinedAt pgtype.Timestamptz
SlugReservationID string
}
type Querier ¶
type Querier interface {
AcceptTeamInvitation(ctx context.Context, arg AcceptTeamInvitationParams) (int64, error)
ActivateMemberSlug(ctx context.Context, arg ActivateMemberSlugParams) (int64, error)
AdvanceAuthorityRevision(ctx context.Context, arg AdvanceAuthorityRevisionParams) (int64, error)
// Commit this short clock update BEFORE pruning in a different transaction.
// A crash in between retains excess data, never an advertised but missing suffix.
AdvanceIngressRoutingRetentionFloor(ctx context.Context, revision int64) (int64, error)
AdvanceTeamPolicyRevision(ctx context.Context, arg AdvanceTeamPolicyRevisionParams) (int64, error)
// The caller holds the ingress/run, route/session and existing bucket guards.
// Dependencies make the immutable report, aggregate delta and denial update
// one ordered write command. The caller checks insertion/aggregation and any
// nonzero denial delta, rolling back all writes if a required step was rejected.
ApplyIngressUsageReport(ctx context.Context, arg ApplyIngressUsageReportParams) (ApplyIngressUsageReportRow, error)
BeginAdminRelayDrain(ctx context.Context, arg BeginAdminRelayDrainParams) (BeginAdminRelayDrainRow, error)
BeginDNSAuthorityRelease(ctx context.Context, arg BeginDNSAuthorityReleaseParams) (ControlDnsAuthority, error)
BeginIngressDrain(ctx context.Context, arg BeginIngressDrainParams) (ControlIngressLease, error)
BeginRelayDrain(ctx context.Context, arg BeginRelayDrainParams) (BeginRelayDrainRow, error)
CancelOpenRouteRecoveryEpisode(ctx context.Context, arg CancelOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
CancelRouteSessionACMEAuthorizations(ctx context.Context, arg CancelRouteSessionACMEAuthorizationsParams) error
CancelRouteSessionACMEOrders(ctx context.Context, arg CancelRouteSessionACMEOrdersParams) error
ClaimACMEOrderWork(ctx context.Context, arg ClaimACMEOrderWorkParams) (ControlAcmeOrder, error)
ClaimDNSAuthorityWork(ctx context.Context, arg ClaimDNSAuthorityWorkParams) (ControlDnsAuthority, error)
ClaimDNSRouteWork(ctx context.Context, arg ClaimDNSRouteWorkParams) (ControlRoute, error)
ClaimPublisherConnection(ctx context.Context, arg ClaimPublisherConnectionParams) (ControlRouteSessionConnection, error)
ClaimRelayCertificateOrderWork(ctx context.Context, arg ClaimRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
ClaimRelayServiceForCertificateOrder(ctx context.Context, arg ClaimRelayServiceForCertificateOrderParams) (ControlRelayService, error)
ClaimRouteUsageDeliveries(ctx context.Context, arg ClaimRouteUsageDeliveriesParams) ([]ControlRouteUsageDelivery, error)
CloseRouteSession(ctx context.Context, arg CloseRouteSessionParams) (ControlRouteSession, error)
CloseRouteSessionConnections(ctx context.Context, arg CloseRouteSessionConnectionsParams) error
CompleteACMEAuthorizationCleanup(ctx context.Context, arg CompleteACMEAuthorizationCleanupParams) (int64, error)
CompleteRouteUsageDelivery(ctx context.Context, arg CompleteRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
ConsumeOIDCAssertion(ctx context.Context, arg ConsumeOIDCAssertionParams) (int64, error)
// Diagnostic/test oracle only; placement reads the trigger-maintained totals.
CountOpenRouteSessionAssignmentsByRelayService(ctx context.Context) ([]CountOpenRouteSessionAssignmentsByRelayServiceRow, error)
CountRelayActiveConnections(ctx context.Context, arg CountRelayActiveConnectionsParams) (int64, error)
CountTeamOwners(ctx context.Context, teamID string) (int64, error)
CreateActiveSlugReservation(ctx context.Context, arg CreateActiveSlugReservationParams) error
CreateClaimedDNSAuthority(ctx context.Context, arg CreateClaimedDNSAuthorityParams) error
CreateClaimedDomain(ctx context.Context, arg CreateClaimedDomainParams) (ControlDomain, error)
CreateControlSession(ctx context.Context, arg CreateControlSessionParams) error
CreateIdentity(ctx context.Context, arg CreateIdentityParams) error
CreateManagedDomain(ctx context.Context, arg CreateManagedDomainParams) error
CreateOIDCIdentity(ctx context.Context, arg CreateOIDCIdentityParams) (ControlIdentity, error)
CreateOrGetDNSAuthority(ctx context.Context, arg CreateOrGetDNSAuthorityParams) (ControlDnsAuthority, error)
CreateOrganizationTeam(ctx context.Context, arg CreateOrganizationTeamParams) (CreateOrganizationTeamRow, error)
CreateOwnerMembership(ctx context.Context, arg CreateOwnerMembershipParams) error
CreatePersonalTeam(ctx context.Context, arg CreatePersonalTeamParams) error
CreateTeamInvitation(ctx context.Context, arg CreateTeamInvitationParams) (ControlTeamInvitation, error)
CreateTeamMembership(ctx context.Context, arg CreateTeamMembershipParams) error
DNSAuthorityReleaseReady(ctx context.Context, arg DNSAuthorityReleaseReadyParams) (pgtype.Bool, error)
DeleteControlTLSCacheEntry(ctx context.Context, arg DeleteControlTLSCacheEntryParams) error
DeleteExpiredOIDCAssertionExchanges(ctx context.Context, now pgtype.Timestamptz) error
DeleteRoute(ctx context.Context, arg DeleteRouteParams) (int64, error)
DisconnectPublisherConnection(ctx context.Context, arg DisconnectPublisherConnectionParams) (ControlRouteSessionConnection, error)
EnsureACMEAccount(ctx context.Context, arg EnsureACMEAccountParams) (ControlAcmeAccount, error)
EnsureExternalAuthorityPrincipal(ctx context.Context, arg EnsureExternalAuthorityPrincipalParams) (ControlIdentity, error)
EnsureExternalRetryMasterKey(ctx context.Context, arg EnsureExternalRetryMasterKeyParams) (EnsureExternalRetryMasterKeyRow, error)
EnsureIngressUsageRun(ctx context.Context, arg EnsureIngressUsageRunParams) (ControlIngressUsageRun, error)
EnsureRouteUsageConfiguration(ctx context.Context, arg EnsureRouteUsageConfigurationParams) (ControlRouteUsageConfiguration, error)
ExpirePublisherConnection(ctx context.Context, arg ExpirePublisherConnectionParams) (ControlRouteSessionConnection, error)
ExpireTeamInvitations(ctx context.Context, arg ExpireTeamInvitationsParams) ([]string, error)
FinalizeRouteUsageBuckets(ctx context.Context, arg FinalizeRouteUsageBucketsParams) ([]ControlRouteUsageBucket, error)
FindBuiltinIdentity(ctx context.Context) (ControlIdentity, error)
FindInvitationTeamByTokenDigest(ctx context.Context, tokenDigest []byte) (string, error)
FindManagedDomain(ctx context.Context) (ControlDomain, error)
FindOIDCIdentity(ctx context.Context, arg FindOIDCIdentityParams) (ControlIdentity, error)
GetACMEAccountByDirectory(ctx context.Context, directoryUrl string) (ControlAcmeAccount, error)
GetACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)
GetACMEOrderByIdempotency(ctx context.Context, arg GetACMEOrderByIdempotencyParams) (ControlAcmeOrder, error)
GetActiveRouteSessionChallengeExpiry(ctx context.Context, arg GetActiveRouteSessionChallengeExpiryParams) (pgtype.Timestamptz, error)
GetActiveRouteSessionMembership(ctx context.Context, arg GetActiveRouteSessionMembershipParams) (GetActiveRouteSessionMembershipRow, error)
GetAdminRuntimeCounts(ctx context.Context, now pgtype.Timestamptz) (GetAdminRuntimeCountsRow, error)
GetAuthorizedRouteByHostname(ctx context.Context, arg GetAuthorizedRouteByHostnameParams) (GetAuthorizedRouteByHostnameRow, error)
GetClaimedDomainByIdempotency(ctx context.Context, arg GetClaimedDomainByIdempotencyParams) (GetClaimedDomainByIdempotencyRow, error)
GetControlSessionByAccessID(ctx context.Context, accessTokenID string) (GetControlSessionByAccessIDRow, error)
GetControlTLSCacheEntry(ctx context.Context, arg GetControlTLSCacheEntryParams) (GetControlTLSCacheEntryRow, error)
GetDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)
GetDNSAuthorityByReleaseIdempotency(ctx context.Context, releaseIdempotencyKey pgtype.Text) (ControlDnsAuthority, error)
GetDNSChallengeContext(ctx context.Context, arg GetDNSChallengeContextParams) (GetDNSChallengeContextRow, error)
GetExternalAuthorityRoute(ctx context.Context, arg GetExternalAuthorityRouteParams) (GetExternalAuthorityRouteRow, error)
GetIdentityContextIdentity(ctx context.Context, identityID string) (GetIdentityContextIdentityRow, error)
GetIdentityRoute(ctx context.Context, arg GetIdentityRouteParams) (GetIdentityRouteRow, error)
GetIdentityTeam(ctx context.Context, arg GetIdentityTeamParams) (GetIdentityTeamRow, error)
GetIngressLease(ctx context.Context, arg GetIngressLeaseParams) (ControlIngressLease, error)
GetIngressUsageReport(ctx context.Context, arg GetIngressUsageReportParams) (ControlIngressUsageReport, error)
GetInvitationByIdempotency(ctx context.Context, arg GetInvitationByIdempotencyParams) (GetInvitationByIdempotencyRow, error)
GetOpenRouteRecoveryEpisode(ctx context.Context, arg GetOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
GetOpenRouteSession(ctx context.Context, routeID string) (ControlRouteSession, error)
GetOrganizationTeamByIdempotency(ctx context.Context, arg GetOrganizationTeamByIdempotencyParams) (GetOrganizationTeamByIdempotencyRow, error)
GetPublisherConnectionForClaim(ctx context.Context, publisherConnectionID string) (ControlRouteSessionConnection, error)
GetRelayDNSChallengeContext(ctx context.Context, orderID string) (GetRelayDNSChallengeContextRow, error)
// Claims and readiness read service configuration without changing it. Share
// that guard across processes. Claims exclusively lock the selected lease's
// non-key fields so capacity checks cannot race each other, renewal, or drain.
// NO KEY UPDATE also permits readiness's KEY SHARE guard: becoming ready does
// not consume another connection. Registration and placement take the service
// exclusively before leases; keep that order here too.
GetRelayLeaseForClaim(ctx context.Context, relayID string) (GetRelayLeaseForClaimRow, error)
// Readiness retains the service guard through routing publication so process
// registration/replacement cannot change its identity. KEY SHARE protects the
// lease's existence without serializing claims or other readiness publications.
// Renewal/drain may overlap; readiness validates the lease it reads, and routing
// projection reads independently exclude a lease that has since drained.
GetRelayLeaseForReady(ctx context.Context, relayID string) (GetRelayLeaseForReadyRow, error)
GetRelayTransportCertificate(ctx context.Context, arg GetRelayTransportCertificateParams) (ControlRelayService, error)
GetRouteByCreatorIdempotency(ctx context.Context, arg GetRouteByCreatorIdempotencyParams) (GetRouteByCreatorIdempotencyRow, error)
GetRouteCreationContext(ctx context.Context, arg GetRouteCreationContextParams) (GetRouteCreationContextRow, error)
GetRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)
GetRouteSessionByIdempotency(ctx context.Context, arg GetRouteSessionByIdempotencyParams) (ControlRouteSession, error)
GetRouteSessionByTokenID(ctx context.Context, sessionTokenID string) (ControlRouteSession, error)
GetRouteUsageBucketByID(ctx context.Context, bucketID int64) (ControlRouteUsageBucket, error)
GetRouteUsageBucketForUpdate(ctx context.Context, arg GetRouteUsageBucketForUpdateParams) (ControlRouteUsageBucket, error)
GetTeamActorContext(ctx context.Context, arg GetTeamActorContextParams) (GetTeamActorContextRow, error)
GetTeamMembershipContext(ctx context.Context, arg GetTeamMembershipContextParams) (GetTeamMembershipContextRow, error)
HeartbeatRouteSession(ctx context.Context, arg HeartbeatRouteSessionParams) (ControlRouteSession, error)
InsertACMEOrder(ctx context.Context, arg InsertACMEOrderParams) (ControlAcmeOrder, error)
InsertAdminAuditEvent(ctx context.Context, arg InsertAdminAuditEventParams) error
InsertCertificateIssuanceAuditEvent(ctx context.Context, arg InsertCertificateIssuanceAuditEventParams) error
InsertExpiredEphemeralRouteDeleteAuditEvent(ctx context.Context, arg InsertExpiredEphemeralRouteDeleteAuditEventParams) error
// Acquire the clock before identity allocation in this same command. Single-event
// publishers avoid a separate round trip while holding the global clock; callers
// with earlier events already hold it. Keep the lock through transaction commit.
InsertFinalIngressRoutingTableEvent(ctx context.Context, arg InsertFinalIngressRoutingTableEventParams) (int64, error)
InsertIngressRoutingTableEvent(ctx context.Context, arg InsertIngressRoutingTableEventParams) (int64, error)
InsertRelayCertificateOrder(ctx context.Context, arg InsertRelayCertificateOrderParams) (ControlRelayCertificateOrder, error)
InsertRoute(ctx context.Context, arg InsertRouteParams) (ControlRoute, error)
InsertRouteCreateAuditEvent(ctx context.Context, arg InsertRouteCreateAuditEventParams) error
InsertRouteDeleteAuditEvent(ctx context.Context, arg InsertRouteDeleteAuditEventParams) error
InsertRouteSession(ctx context.Context, arg InsertRouteSessionParams) (ControlRouteSession, error)
InsertRouteSessionAuditEvent(ctx context.Context, arg InsertRouteSessionAuditEventParams) error
InsertRouteSessionConnections(ctx context.Context, arg InsertRouteSessionConnectionsParams) ([]ControlRouteSessionConnection, error)
InsertRouteUpdateAuditEvent(ctx context.Context, arg InsertRouteUpdateAuditEventParams) error
InsertRouteUsageDelivery(ctx context.Context, arg InsertRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
LatestIngressRoutingEntryRevision(ctx context.Context, arg LatestIngressRoutingEntryRevisionParams) (int64, error)
ListACMEOrderAuthorizations(ctx context.Context, issuanceID string) ([]ControlAcmeAuthorization, error)
ListAdminRelayLeases(ctx context.Context, arg ListAdminRelayLeasesParams) ([]ListAdminRelayLeasesRow, error)
ListCurrentDomainNames(ctx context.Context) ([]string, error)
ListDNSChallengePresentations(ctx context.Context, baseIdentifier string) ([]ListDNSChallengePresentationsRow, error)
ListExternalAuthorityRoutes(ctx context.Context, arg ListExternalAuthorityRoutesParams) ([]ListExternalAuthorityRoutesRow, error)
ListIdentityMembershipContexts(ctx context.Context, identityID string) ([]ListIdentityMembershipContextsRow, error)
ListIdentityRoutes(ctx context.Context, arg ListIdentityRoutesParams) ([]ListIdentityRoutesRow, error)
ListIdentityTeamDomains(ctx context.Context, arg ListIdentityTeamDomainsParams) ([]ListIdentityTeamDomainsRow, error)
ListIdentityTeams(ctx context.Context, identityID string) ([]ListIdentityTeamsRow, error)
ListIngressRoutingTableEvents(ctx context.Context, arg ListIngressRoutingTableEventsParams) ([]ControlIngressRoutingTableEvent, error)
// Group only entry keys and revisions across history, then fetch the selected
// payloads. Filter after selection so tombstones/expiry cannot revive old rows.
ListIngressRoutingTableSnapshot(ctx context.Context, arg ListIngressRoutingTableSnapshotParams) ([]ControlIngressRoutingTableEvent, error)
// The ingress/run guards serialize this source's append-only history. Fetch only
// bounded metadata, not histogram blobs; exact replays still load their payload.
ListLatestIngressUsageReports(ctx context.Context, arg ListLatestIngressUsageReportsParams) ([]ListLatestIngressUsageReportsRow, error)
ListMaintenanceControls(ctx context.Context) ([]ControlMaintenanceControl, error)
ListRelayDNSChallengePresentations(ctx context.Context, tlsServerName string) ([]ListRelayDNSChallengePresentationsRow, error)
ListRelayServiceAssignmentTotals(ctx context.Context) ([]ControlRelayServiceAssignmentTotal, error)
ListRouteSessionConnections(ctx context.Context, routeSessionID string) ([]ControlRouteSessionConnection, error)
ListTeamInvitations(ctx context.Context, teamID string) ([]ListTeamInvitationsRow, error)
ListTeamMemberNamespaceLabels(ctx context.Context, teamID string) ([]ListTeamMemberNamespaceLabelsRow, error)
ListTeamMembershipContexts(ctx context.Context, teamID string) ([]ListTeamMembershipContextsRow, error)
ListValidReadyPublisherConnections(ctx context.Context, arg ListValidReadyPublisherConnectionsParams) ([]ListValidReadyPublisherConnectionsRow, error)
LockACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)
LockACMEOrderForInstall(ctx context.Context, arg LockACMEOrderForInstallParams) (ControlAcmeOrder, error)
LockCertificateIssuanceControl(ctx context.Context) (bool, error)
LockControlSessionByRefreshID(ctx context.Context, refreshTokenID string) (LockControlSessionByRefreshIDRow, error)
LockDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)
LockDNSAuthorityLocalDomain(ctx context.Context, authorityReference pgtype.Text) error
LockDNSAuthorityLocalTeam(ctx context.Context, authorityReference pgtype.Text) error
LockDomainRoutes(ctx context.Context, arg LockDomainRoutesParams) ([]ControlRoute, error)
LockEligibleRelayLeases(ctx context.Context, arg LockEligibleRelayLeasesParams) ([]LockEligibleRelayLeasesRow, error)
LockExpiredEphemeralRoutes(ctx context.Context, arg LockExpiredEphemeralRoutesParams) ([]ControlRoute, error)
LockHostedTeamRoutes(ctx context.Context, teamID string) ([]ControlRoute, error)
LockIdentityBootstrap(ctx context.Context) error
LockIdentityForTeamCreation(ctx context.Context, identityID string) (string, error)
LockIdentityRouteForDelete(ctx context.Context, arg LockIdentityRouteForDeleteParams) (LockIdentityRouteForDeleteRow, error)
LockIngressLease(ctx context.Context, arg LockIngressLeaseParams) (ControlIngressLease, error)
LockIngressRoutingTableClock(ctx context.Context) (int64, error)
LockInvalidReadyPublisherConnections(ctx context.Context, now pgtype.Timestamptz) ([]ControlRouteSessionConnection, error)
LockInvitationByTokenDigest(ctx context.Context, arg LockInvitationByTokenDigestParams) (LockInvitationByTokenDigestRow, error)
LockLocalRouteTeamForMutation(ctx context.Context, routeID string) (string, error)
// Local authority mutations lock the team before identities, memberships,
// domains, DNS authorities, and routes. Authorization is rechecked under this
// transaction-held guard; hosted teams never require fabricated local rows.
// Queue writers with the session readers using a transaction advisory lock:
// PostgreSQL row-lock readers alone can bypass a waiting writer indefinitely.
LockLocalTeamForMutation(ctx context.Context, teamID string) (string, error)
// Session creation reads authority under this guard before locking its route.
// Different routes may start together; team/role/domain mutations must wait.
// Callers must not upgrade this guard by writing the team later in the transaction.
LockLocalTeamForSession(ctx context.Context, teamID string) (string, error)
LockManagedDomainForClaim(ctx context.Context) (ControlDomain, error)
LockMembershipRoutes(ctx context.Context, arg LockMembershipRoutesParams) ([]ControlRoute, error)
LockRelayServiceForCertificate(ctx context.Context, relayServiceID string) (string, error)
// Acquire the reservation guard before service guards and rows, in one command.
// Callers finish locking all services before locking leases or checking capacity.
LockRelayServicesForPlacement(ctx context.Context) ([]string, error)
LockRouteCreationControl(ctx context.Context) (bool, error)
// Serialize creators without blocking session and audit foreign-key checks.
LockRouteCreator(ctx context.Context, identityID string) (string, error)
// Session operations serialize route mutations but never change the route's
// identity. Let usage's KEY SHARE references coexist; overlapping usage pages
// can otherwise starve a waiting heartbeat's stronger UPDATE lock.
LockRouteForSession(ctx context.Context, routeID string) (ControlRoute, error)
LockRouteForUsage(ctx context.Context, routeID string) (string, error)
LockRouteRecoveryEpisode(ctx context.Context, recoveryEpisodeID int64) (ControlRouteRecoveryEpisode, error)
LockRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)
LockRouteSessionCreationControl(ctx context.Context) (bool, error)
// Acquire the immutable route reference before the session, in one round trip.
// Read the bucket in a LATER statement: a competing ingress may create it while
// this statement waits for the session lock, after this statement's snapshot.
LockRouteSessionForUsage(ctx context.Context, arg LockRouteSessionForUsageParams) (ControlRouteSession, error)
LockTeamActorContext(ctx context.Context, arg LockTeamActorContextParams) (LockTeamActorContextRow, error)
LockTeamDomain(ctx context.Context, arg LockTeamDomainParams) (LockTeamDomainRow, error)
LockTeamForInvitationAcceptance(ctx context.Context, teamID string) (string, error)
LockTeamInvitation(ctx context.Context, arg LockTeamInvitationParams) (LockTeamInvitationRow, error)
LockTeamMembership(ctx context.Context, arg LockTeamMembershipParams) (LockTeamMembershipRow, error)
MarkACMEAuthorizationsPresented(ctx context.Context, arg MarkACMEAuthorizationsPresentedParams) (int64, error)
MarkACMEOrderInstalled(ctx context.Context, arg MarkACMEOrderInstalledParams) (ControlAcmeOrder, error)
MarkClaimedDomainReleasing(ctx context.Context, arg MarkClaimedDomainReleasingParams) (int64, error)
MarkDNSAuthorityReleasing(ctx context.Context, arg MarkDNSAuthorityReleasingParams) (int64, error)
MarkExpiredIngressUsageRunIncomplete(ctx context.Context, arg MarkExpiredIngressUsageRunIncompleteParams) error
MarkExpiredIngressUsageRunsIncomplete(ctx context.Context, now pgtype.Timestamptz) ([]ControlIngressUsageRun, error)
MarkIngressUsageRunReported(ctx context.Context, arg MarkIngressUsageRunReportedParams) (ControlIngressUsageRun, error)
MarkInvitationExpired(ctx context.Context, invitationID string) (int64, error)
MarkPublisherConnectionReady(ctx context.Context, arg MarkPublisherConnectionReadyParams) (ControlRouteSessionConnection, error)
MarkRouteSessionCertificateInstalled(ctx context.Context, arg MarkRouteSessionCertificateInstalledParams) (ControlRouteSession, error)
MarkRouteSessionReady(ctx context.Context, arg MarkRouteSessionReadyParams) (ControlRouteSession, error)
ObserveAuthorityRevision(ctx context.Context, arg ObserveAuthorityRevisionParams) (int64, error)
ObserveRouteRecoveryEpisode(ctx context.Context, arg ObserveRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
OpenRouteRecoveryEpisode(ctx context.Context, arg OpenRouteRecoveryEpisodeParams) error
// Bound candidates visited as well as rows deleted. Advance past anchors even
// when no row can be removed. Keep the newest hostname/category projection
// (including tombstones/expired entries) AND each route-version's latest revision.
// All checks use this statement's snapshot. Concurrent publications can only
// make an old anchor redundant; they cannot make a superseded event current.
PruneIngressRoutingHistoryBatch(ctx context.Context, afterRevision int64) (PruneIngressRoutingHistoryBatchRow, error)
PutControlTLSCacheEntry(ctx context.Context, arg PutControlTLSCacheEntryParams) error
QuarantineMemberSlug(ctx context.Context, arg QuarantineMemberSlugParams) (int64, error)
ReadIngressRoutingTableClock(ctx context.Context) (ControlIngressRoutingTableClock, error)
RegisterIngress(ctx context.Context, arg RegisterIngressParams) (ControlIngressLease, error)
// Blocking service operations acquire a transaction advisory guard before any
// service/lease row locks. Shared row readers alone can bypass a queued writer;
// the advisory queue lets registration, placement and certificate writes progress.
// SKIP LOCKED certificate preparation and bulk key rotation remain opportunistic
// row-only writers: they never wait for a service row or acquire this guard after
// holding one. Keep their nonblocking behavior rather than adding a lock upgrade.
RegisterRelay(ctx context.Context, arg RegisterRelayParams) (RegisterRelayRow, error)
ReleaseInvitedMemberSlug(ctx context.Context, arg ReleaseInvitedMemberSlugParams) (int64, error)
RemoveTeamMembership(ctx context.Context, arg RemoveTeamMembershipParams) (int64, error)
RenewEphemeralRouteExpiry(ctx context.Context, arg RenewEphemeralRouteExpiryParams) (pgtype.Timestamptz, error)
RenewIngress(ctx context.Context, arg RenewIngressParams) (ControlIngressLease, error)
RenewRelay(ctx context.Context, arg RenewRelayParams) (RenewRelayRow, error)
// A failed ready connection can keep its existing service reservation. This
// atomic ready -> assigned transition has zero counter delta and needs only the
// caller's route/session locks, not placement's global/service/lease guards.
// Check failure and eligible service capacity in the statement snapshot. A
// concurrent lease/configuration change may invalidate the returned assignment,
// just as one immediately after commit can; claim checks the exact current lease
// and process capacity under its exclusive lease guard. No capacity is added here.
// Closed/expired slots have no reservation and require guarded placement first.
ReplaceRouteSessionConnection(ctx context.Context, arg ReplaceRouteSessionConnectionParams) (ControlRouteSessionConnection, error)
ReserveInvitedMemberSlug(ctx context.Context, arg ReserveInvitedMemberSlugParams) (string, error)
ReserveManagedLabel(ctx context.Context, arg ReserveManagedLabelParams) (string, error)
RetryRouteUsageDelivery(ctx context.Context, arg RetryRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
RevokeControlSession(ctx context.Context, arg RevokeControlSessionParams) (int64, error)
RevokeTeamInvitation(ctx context.Context, arg RevokeTeamInvitationParams) (int64, error)
RotateACMEAccountKey(ctx context.Context, arg RotateACMEAccountKeyParams) error
RotateControlSessionCredentials(ctx context.Context, arg RotateControlSessionCredentialsParams) (int64, error)
RotateControlSessionRetrySecret(ctx context.Context, arg RotateControlSessionRetrySecretParams) error
RotateControlTLSCacheEntry(ctx context.Context, arg RotateControlTLSCacheEntryParams) error
RotateExternalRetryMasterKey(ctx context.Context, arg RotateExternalRetryMasterKeyParams) error
RotateRelayCertificateOrderPrivateKey(ctx context.Context, arg RotateRelayCertificateOrderPrivateKeyParams) error
RotateRelayServicePrivateKey(ctx context.Context, arg RotateRelayServicePrivateKeyParams) error
SaveACMEAuthorizationWork(ctx context.Context, arg SaveACMEAuthorizationWorkParams) (ControlAcmeAuthorization, error)
SaveACMEOrderWork(ctx context.Context, arg SaveACMEOrderWorkParams) (ControlAcmeOrder, error)
SaveDNSAuthorityWork(ctx context.Context, arg SaveDNSAuthorityWorkParams) (ControlDnsAuthority, error)
SaveDNSRouteWork(ctx context.Context, arg SaveDNSRouteWorkParams) (ControlRoute, error)
SaveRelayCertificateOrderWork(ctx context.Context, arg SaveRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
// Find an old committed PREFIX, not the largest old timestamp. Request-start
// timestamps can be out of revision order; preserve every still-recent event.
// This scan happens before acquiring the publication clock.
SelectIngressRoutingRetentionFloor(ctx context.Context, cutoff pgtype.Timestamptz) (int64, error)
SetDNSReadyDomainDefault(ctx context.Context, arg SetDNSReadyDomainDefaultParams) (int64, error)
SetDomainAuthorityRevision(ctx context.Context, arg SetDomainAuthorityRevisionParams) error
SetMaintenanceControl(ctx context.Context, arg SetMaintenanceControlParams) (ControlMaintenanceControl, error)
SetPersonalTeamDefaultDomain(ctx context.Context, arg SetPersonalTeamDefaultDomainParams) error
SetTeamDefaultDomain(ctx context.Context, arg SetTeamDefaultDomainParams) (int64, error)
StoreRelayTransportCertificate(ctx context.Context, arg StoreRelayTransportCertificateParams) (ControlRelayService, error)
SuspendAuthorityRoute(ctx context.Context, arg SuspendAuthorityRouteParams) (int64, error)
TeamMembershipIdentityExists(ctx context.Context, arg TeamMembershipIdentityExistsParams) (bool, error)
// Cleanup-only coordination; no route, reservation, service, lease, or clock locks.
TryLockIngressRoutingHistoryCleanup(ctx context.Context) (bool, error)
UpdateACMEAccountRegistration(ctx context.Context, arg UpdateACMEAccountRegistrationParams) (ControlAcmeAccount, error)
UpdateLocalDomainForDNSAuthority(ctx context.Context, arg UpdateLocalDomainForDNSAuthorityParams) (UpdateLocalDomainForDNSAuthorityRow, error)
UpdateMembershipRole(ctx context.Context, arg UpdateMembershipRoleParams) (int64, error)
UpdateOIDCIdentity(ctx context.Context, arg UpdateOIDCIdentityParams) (ControlIdentity, error)
UpdateRoute(ctx context.Context, arg UpdateRouteParams) (ControlRoute, error)
UpdateRouteRecoveryHistogram(ctx context.Context, arg UpdateRouteRecoveryHistogramParams) (ControlRouteRecoveryHistogram, error)
// A publisher transition invalidates the worker's authorization snapshot.
// Call only after changing authorizations while holding the order lock.
WakeACMEOrder(ctx context.Context, arg WakeACMEOrderParams) error
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcceptTeamInvitation ¶
func (*Queries) ActivateMemberSlug ¶
func (*Queries) AdvanceAuthorityRevision ¶
func (*Queries) AdvanceIngressRoutingRetentionFloor ¶
func (q *Queries) AdvanceIngressRoutingRetentionFloor(ctx context.Context, revision int64) (int64, error)
Commit this short clock update BEFORE pruning in a different transaction. A crash in between retains excess data, never an advertised but missing suffix.
func (*Queries) AdvanceTeamPolicyRevision ¶
func (*Queries) ApplyIngressUsageReport ¶
func (q *Queries) ApplyIngressUsageReport(ctx context.Context, arg ApplyIngressUsageReportParams) (ApplyIngressUsageReportRow, error)
The caller holds the ingress/run, route/session and existing bucket guards. Dependencies make the immutable report, aggregate delta and denial update one ordered write command. The caller checks insertion/aggregation and any nonzero denial delta, rolling back all writes if a required step was rejected.
func (*Queries) BeginAdminRelayDrain ¶
func (q *Queries) BeginAdminRelayDrain(ctx context.Context, arg BeginAdminRelayDrainParams) (BeginAdminRelayDrainRow, error)
func (*Queries) BeginDNSAuthorityRelease ¶
func (q *Queries) BeginDNSAuthorityRelease(ctx context.Context, arg BeginDNSAuthorityReleaseParams) (ControlDnsAuthority, error)
func (*Queries) BeginIngressDrain ¶
func (q *Queries) BeginIngressDrain(ctx context.Context, arg BeginIngressDrainParams) (ControlIngressLease, error)
func (*Queries) BeginRelayDrain ¶
func (q *Queries) BeginRelayDrain(ctx context.Context, arg BeginRelayDrainParams) (BeginRelayDrainRow, error)
func (*Queries) CancelOpenRouteRecoveryEpisode ¶
func (q *Queries) CancelOpenRouteRecoveryEpisode(ctx context.Context, arg CancelOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
func (*Queries) CancelRouteSessionACMEAuthorizations ¶
func (q *Queries) CancelRouteSessionACMEAuthorizations(ctx context.Context, arg CancelRouteSessionACMEAuthorizationsParams) error
func (*Queries) CancelRouteSessionACMEOrders ¶
func (q *Queries) CancelRouteSessionACMEOrders(ctx context.Context, arg CancelRouteSessionACMEOrdersParams) error
func (*Queries) ClaimACMEOrderWork ¶
func (q *Queries) ClaimACMEOrderWork(ctx context.Context, arg ClaimACMEOrderWorkParams) (ControlAcmeOrder, error)
func (*Queries) ClaimDNSAuthorityWork ¶
func (q *Queries) ClaimDNSAuthorityWork(ctx context.Context, arg ClaimDNSAuthorityWorkParams) (ControlDnsAuthority, error)
func (*Queries) ClaimDNSRouteWork ¶
func (q *Queries) ClaimDNSRouteWork(ctx context.Context, arg ClaimDNSRouteWorkParams) (ControlRoute, error)
func (*Queries) ClaimPublisherConnection ¶
func (q *Queries) ClaimPublisherConnection(ctx context.Context, arg ClaimPublisherConnectionParams) (ControlRouteSessionConnection, error)
func (*Queries) ClaimRelayCertificateOrderWork ¶
func (q *Queries) ClaimRelayCertificateOrderWork(ctx context.Context, arg ClaimRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
func (*Queries) ClaimRelayServiceForCertificateOrder ¶
func (q *Queries) ClaimRelayServiceForCertificateOrder(ctx context.Context, arg ClaimRelayServiceForCertificateOrderParams) (ControlRelayService, error)
func (*Queries) ClaimRouteUsageDeliveries ¶
func (q *Queries) ClaimRouteUsageDeliveries(ctx context.Context, arg ClaimRouteUsageDeliveriesParams) ([]ControlRouteUsageDelivery, error)
func (*Queries) CloseRouteSession ¶
func (q *Queries) CloseRouteSession(ctx context.Context, arg CloseRouteSessionParams) (ControlRouteSession, error)
func (*Queries) CloseRouteSessionConnections ¶
func (q *Queries) CloseRouteSessionConnections(ctx context.Context, arg CloseRouteSessionConnectionsParams) error
func (*Queries) CompleteACMEAuthorizationCleanup ¶
func (*Queries) CompleteRouteUsageDelivery ¶
func (q *Queries) CompleteRouteUsageDelivery(ctx context.Context, arg CompleteRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
func (*Queries) ConsumeOIDCAssertion ¶
func (*Queries) CountOpenRouteSessionAssignmentsByRelayService ¶
func (q *Queries) CountOpenRouteSessionAssignmentsByRelayService(ctx context.Context) ([]CountOpenRouteSessionAssignmentsByRelayServiceRow, error)
Diagnostic/test oracle only; placement reads the trigger-maintained totals.
func (*Queries) CountRelayActiveConnections ¶
func (*Queries) CountTeamOwners ¶
func (*Queries) CreateActiveSlugReservation ¶
func (q *Queries) CreateActiveSlugReservation(ctx context.Context, arg CreateActiveSlugReservationParams) error
func (*Queries) CreateClaimedDNSAuthority ¶
func (q *Queries) CreateClaimedDNSAuthority(ctx context.Context, arg CreateClaimedDNSAuthorityParams) error
func (*Queries) CreateClaimedDomain ¶
func (q *Queries) CreateClaimedDomain(ctx context.Context, arg CreateClaimedDomainParams) (ControlDomain, error)
func (*Queries) CreateControlSession ¶
func (q *Queries) CreateControlSession(ctx context.Context, arg CreateControlSessionParams) error
func (*Queries) CreateIdentity ¶
func (q *Queries) CreateIdentity(ctx context.Context, arg CreateIdentityParams) error
func (*Queries) CreateManagedDomain ¶
func (q *Queries) CreateManagedDomain(ctx context.Context, arg CreateManagedDomainParams) error
func (*Queries) CreateOIDCIdentity ¶
func (q *Queries) CreateOIDCIdentity(ctx context.Context, arg CreateOIDCIdentityParams) (ControlIdentity, error)
func (*Queries) CreateOrGetDNSAuthority ¶
func (q *Queries) CreateOrGetDNSAuthority(ctx context.Context, arg CreateOrGetDNSAuthorityParams) (ControlDnsAuthority, error)
func (*Queries) CreateOrganizationTeam ¶
func (q *Queries) CreateOrganizationTeam(ctx context.Context, arg CreateOrganizationTeamParams) (CreateOrganizationTeamRow, error)
func (*Queries) CreateOwnerMembership ¶
func (q *Queries) CreateOwnerMembership(ctx context.Context, arg CreateOwnerMembershipParams) error
func (*Queries) CreatePersonalTeam ¶
func (q *Queries) CreatePersonalTeam(ctx context.Context, arg CreatePersonalTeamParams) error
func (*Queries) CreateTeamInvitation ¶
func (q *Queries) CreateTeamInvitation(ctx context.Context, arg CreateTeamInvitationParams) (ControlTeamInvitation, error)
func (*Queries) CreateTeamMembership ¶
func (q *Queries) CreateTeamMembership(ctx context.Context, arg CreateTeamMembershipParams) error
func (*Queries) DNSAuthorityReleaseReady ¶
func (*Queries) DeleteControlTLSCacheEntry ¶
func (q *Queries) DeleteControlTLSCacheEntry(ctx context.Context, arg DeleteControlTLSCacheEntryParams) error
func (*Queries) DeleteExpiredOIDCAssertionExchanges ¶
func (*Queries) DeleteRoute ¶
func (*Queries) DisconnectPublisherConnection ¶
func (q *Queries) DisconnectPublisherConnection(ctx context.Context, arg DisconnectPublisherConnectionParams) (ControlRouteSessionConnection, error)
func (*Queries) EnsureACMEAccount ¶
func (q *Queries) EnsureACMEAccount(ctx context.Context, arg EnsureACMEAccountParams) (ControlAcmeAccount, error)
func (*Queries) EnsureExternalAuthorityPrincipal ¶
func (q *Queries) EnsureExternalAuthorityPrincipal(ctx context.Context, arg EnsureExternalAuthorityPrincipalParams) (ControlIdentity, error)
func (*Queries) EnsureExternalRetryMasterKey ¶
func (q *Queries) EnsureExternalRetryMasterKey(ctx context.Context, arg EnsureExternalRetryMasterKeyParams) (EnsureExternalRetryMasterKeyRow, error)
func (*Queries) EnsureIngressUsageRun ¶
func (q *Queries) EnsureIngressUsageRun(ctx context.Context, arg EnsureIngressUsageRunParams) (ControlIngressUsageRun, error)
func (*Queries) EnsureRouteUsageConfiguration ¶
func (q *Queries) EnsureRouteUsageConfiguration(ctx context.Context, arg EnsureRouteUsageConfigurationParams) (ControlRouteUsageConfiguration, error)
func (*Queries) ExpirePublisherConnection ¶
func (q *Queries) ExpirePublisherConnection(ctx context.Context, arg ExpirePublisherConnectionParams) (ControlRouteSessionConnection, error)
func (*Queries) ExpireTeamInvitations ¶
func (*Queries) FinalizeRouteUsageBuckets ¶
func (q *Queries) FinalizeRouteUsageBuckets(ctx context.Context, arg FinalizeRouteUsageBucketsParams) ([]ControlRouteUsageBucket, error)
func (*Queries) FindBuiltinIdentity ¶
func (q *Queries) FindBuiltinIdentity(ctx context.Context) (ControlIdentity, error)
func (*Queries) FindInvitationTeamByTokenDigest ¶
func (*Queries) FindManagedDomain ¶
func (q *Queries) FindManagedDomain(ctx context.Context) (ControlDomain, error)
func (*Queries) FindOIDCIdentity ¶
func (q *Queries) FindOIDCIdentity(ctx context.Context, arg FindOIDCIdentityParams) (ControlIdentity, error)
func (*Queries) GetACMEAccountByDirectory ¶
func (*Queries) GetACMEOrder ¶
func (*Queries) GetACMEOrderByIdempotency ¶
func (q *Queries) GetACMEOrderByIdempotency(ctx context.Context, arg GetACMEOrderByIdempotencyParams) (ControlAcmeOrder, error)
func (*Queries) GetActiveRouteSessionChallengeExpiry ¶
func (q *Queries) GetActiveRouteSessionChallengeExpiry(ctx context.Context, arg GetActiveRouteSessionChallengeExpiryParams) (pgtype.Timestamptz, error)
func (*Queries) GetActiveRouteSessionMembership ¶
func (q *Queries) GetActiveRouteSessionMembership(ctx context.Context, arg GetActiveRouteSessionMembershipParams) (GetActiveRouteSessionMembershipRow, error)
func (*Queries) GetAdminRuntimeCounts ¶
func (q *Queries) GetAdminRuntimeCounts(ctx context.Context, now pgtype.Timestamptz) (GetAdminRuntimeCountsRow, error)
func (*Queries) GetAuthorizedRouteByHostname ¶
func (q *Queries) GetAuthorizedRouteByHostname(ctx context.Context, arg GetAuthorizedRouteByHostnameParams) (GetAuthorizedRouteByHostnameRow, error)
func (*Queries) GetClaimedDomainByIdempotency ¶
func (q *Queries) GetClaimedDomainByIdempotency(ctx context.Context, arg GetClaimedDomainByIdempotencyParams) (GetClaimedDomainByIdempotencyRow, error)
func (*Queries) GetControlSessionByAccessID ¶
func (*Queries) GetControlTLSCacheEntry ¶
func (q *Queries) GetControlTLSCacheEntry(ctx context.Context, arg GetControlTLSCacheEntryParams) (GetControlTLSCacheEntryRow, error)
func (*Queries) GetDNSAuthority ¶
func (*Queries) GetDNSAuthorityByReleaseIdempotency ¶
func (*Queries) GetDNSChallengeContext ¶
func (q *Queries) GetDNSChallengeContext(ctx context.Context, arg GetDNSChallengeContextParams) (GetDNSChallengeContextRow, error)
func (*Queries) GetExternalAuthorityRoute ¶
func (q *Queries) GetExternalAuthorityRoute(ctx context.Context, arg GetExternalAuthorityRouteParams) (GetExternalAuthorityRouteRow, error)
func (*Queries) GetIdentityContextIdentity ¶
func (*Queries) GetIdentityRoute ¶
func (q *Queries) GetIdentityRoute(ctx context.Context, arg GetIdentityRouteParams) (GetIdentityRouteRow, error)
func (*Queries) GetIdentityTeam ¶
func (q *Queries) GetIdentityTeam(ctx context.Context, arg GetIdentityTeamParams) (GetIdentityTeamRow, error)
func (*Queries) GetIngressLease ¶
func (q *Queries) GetIngressLease(ctx context.Context, arg GetIngressLeaseParams) (ControlIngressLease, error)
func (*Queries) GetIngressUsageReport ¶
func (q *Queries) GetIngressUsageReport(ctx context.Context, arg GetIngressUsageReportParams) (ControlIngressUsageReport, error)
func (*Queries) GetInvitationByIdempotency ¶
func (q *Queries) GetInvitationByIdempotency(ctx context.Context, arg GetInvitationByIdempotencyParams) (GetInvitationByIdempotencyRow, error)
func (*Queries) GetOpenRouteRecoveryEpisode ¶
func (q *Queries) GetOpenRouteRecoveryEpisode(ctx context.Context, arg GetOpenRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
func (*Queries) GetOpenRouteSession ¶
func (*Queries) GetOrganizationTeamByIdempotency ¶
func (q *Queries) GetOrganizationTeamByIdempotency(ctx context.Context, arg GetOrganizationTeamByIdempotencyParams) (GetOrganizationTeamByIdempotencyRow, error)
func (*Queries) GetPublisherConnectionForClaim ¶
func (*Queries) GetRelayDNSChallengeContext ¶
func (*Queries) GetRelayLeaseForClaim ¶
func (q *Queries) GetRelayLeaseForClaim(ctx context.Context, relayID string) (GetRelayLeaseForClaimRow, error)
Claims and readiness read service configuration without changing it. Share that guard across processes. Claims exclusively lock the selected lease's non-key fields so capacity checks cannot race each other, renewal, or drain. NO KEY UPDATE also permits readiness's KEY SHARE guard: becoming ready does not consume another connection. Registration and placement take the service exclusively before leases; keep that order here too.
func (*Queries) GetRelayLeaseForReady ¶
func (q *Queries) GetRelayLeaseForReady(ctx context.Context, relayID string) (GetRelayLeaseForReadyRow, error)
Readiness retains the service guard through routing publication so process registration/replacement cannot change its identity. KEY SHARE protects the lease's existence without serializing claims or other readiness publications. Renewal/drain may overlap; readiness validates the lease it reads, and routing projection reads independently exclude a lease that has since drained.
func (*Queries) GetRelayTransportCertificate ¶
func (q *Queries) GetRelayTransportCertificate(ctx context.Context, arg GetRelayTransportCertificateParams) (ControlRelayService, error)
func (*Queries) GetRouteByCreatorIdempotency ¶
func (q *Queries) GetRouteByCreatorIdempotency(ctx context.Context, arg GetRouteByCreatorIdempotencyParams) (GetRouteByCreatorIdempotencyRow, error)
func (*Queries) GetRouteCreationContext ¶
func (q *Queries) GetRouteCreationContext(ctx context.Context, arg GetRouteCreationContextParams) (GetRouteCreationContextRow, error)
func (*Queries) GetRouteSession ¶
func (*Queries) GetRouteSessionByIdempotency ¶
func (q *Queries) GetRouteSessionByIdempotency(ctx context.Context, arg GetRouteSessionByIdempotencyParams) (ControlRouteSession, error)
func (*Queries) GetRouteSessionByTokenID ¶
func (*Queries) GetRouteUsageBucketByID ¶
func (*Queries) GetRouteUsageBucketForUpdate ¶
func (q *Queries) GetRouteUsageBucketForUpdate(ctx context.Context, arg GetRouteUsageBucketForUpdateParams) (ControlRouteUsageBucket, error)
func (*Queries) GetTeamActorContext ¶
func (q *Queries) GetTeamActorContext(ctx context.Context, arg GetTeamActorContextParams) (GetTeamActorContextRow, error)
func (*Queries) GetTeamMembershipContext ¶
func (q *Queries) GetTeamMembershipContext(ctx context.Context, arg GetTeamMembershipContextParams) (GetTeamMembershipContextRow, error)
func (*Queries) HeartbeatRouteSession ¶
func (q *Queries) HeartbeatRouteSession(ctx context.Context, arg HeartbeatRouteSessionParams) (ControlRouteSession, error)
func (*Queries) InsertACMEOrder ¶
func (q *Queries) InsertACMEOrder(ctx context.Context, arg InsertACMEOrderParams) (ControlAcmeOrder, error)
func (*Queries) InsertAdminAuditEvent ¶
func (q *Queries) InsertAdminAuditEvent(ctx context.Context, arg InsertAdminAuditEventParams) error
func (*Queries) InsertCertificateIssuanceAuditEvent ¶
func (q *Queries) InsertCertificateIssuanceAuditEvent(ctx context.Context, arg InsertCertificateIssuanceAuditEventParams) error
func (*Queries) InsertExpiredEphemeralRouteDeleteAuditEvent ¶
func (q *Queries) InsertExpiredEphemeralRouteDeleteAuditEvent(ctx context.Context, arg InsertExpiredEphemeralRouteDeleteAuditEventParams) error
func (*Queries) InsertFinalIngressRoutingTableEvent ¶
func (q *Queries) InsertFinalIngressRoutingTableEvent(ctx context.Context, arg InsertFinalIngressRoutingTableEventParams) (int64, error)
Acquire the clock before identity allocation in this same command. Single-event publishers avoid a separate round trip while holding the global clock; callers with earlier events already hold it. Keep the lock through transaction commit.
func (*Queries) InsertIngressRoutingTableEvent ¶
func (*Queries) InsertRelayCertificateOrder ¶
func (q *Queries) InsertRelayCertificateOrder(ctx context.Context, arg InsertRelayCertificateOrderParams) (ControlRelayCertificateOrder, error)
func (*Queries) InsertRoute ¶
func (q *Queries) InsertRoute(ctx context.Context, arg InsertRouteParams) (ControlRoute, error)
func (*Queries) InsertRouteCreateAuditEvent ¶
func (q *Queries) InsertRouteCreateAuditEvent(ctx context.Context, arg InsertRouteCreateAuditEventParams) error
func (*Queries) InsertRouteDeleteAuditEvent ¶
func (q *Queries) InsertRouteDeleteAuditEvent(ctx context.Context, arg InsertRouteDeleteAuditEventParams) error
func (*Queries) InsertRouteSession ¶
func (q *Queries) InsertRouteSession(ctx context.Context, arg InsertRouteSessionParams) (ControlRouteSession, error)
func (*Queries) InsertRouteSessionAuditEvent ¶
func (q *Queries) InsertRouteSessionAuditEvent(ctx context.Context, arg InsertRouteSessionAuditEventParams) error
func (*Queries) InsertRouteSessionConnections ¶
func (q *Queries) InsertRouteSessionConnections(ctx context.Context, arg InsertRouteSessionConnectionsParams) ([]ControlRouteSessionConnection, error)
func (*Queries) InsertRouteUpdateAuditEvent ¶
func (q *Queries) InsertRouteUpdateAuditEvent(ctx context.Context, arg InsertRouteUpdateAuditEventParams) error
func (*Queries) InsertRouteUsageDelivery ¶
func (q *Queries) InsertRouteUsageDelivery(ctx context.Context, arg InsertRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
func (*Queries) LatestIngressRoutingEntryRevision ¶
func (*Queries) ListACMEOrderAuthorizations ¶
func (*Queries) ListAdminRelayLeases ¶
func (q *Queries) ListAdminRelayLeases(ctx context.Context, arg ListAdminRelayLeasesParams) ([]ListAdminRelayLeasesRow, error)
func (*Queries) ListCurrentDomainNames ¶
func (*Queries) ListDNSChallengePresentations ¶
func (*Queries) ListExternalAuthorityRoutes ¶
func (q *Queries) ListExternalAuthorityRoutes(ctx context.Context, arg ListExternalAuthorityRoutesParams) ([]ListExternalAuthorityRoutesRow, error)
func (*Queries) ListIdentityMembershipContexts ¶
func (*Queries) ListIdentityRoutes ¶
func (q *Queries) ListIdentityRoutes(ctx context.Context, arg ListIdentityRoutesParams) ([]ListIdentityRoutesRow, error)
func (*Queries) ListIdentityTeamDomains ¶
func (q *Queries) ListIdentityTeamDomains(ctx context.Context, arg ListIdentityTeamDomainsParams) ([]ListIdentityTeamDomainsRow, error)
func (*Queries) ListIdentityTeams ¶
func (*Queries) ListIngressRoutingTableEvents ¶
func (q *Queries) ListIngressRoutingTableEvents(ctx context.Context, arg ListIngressRoutingTableEventsParams) ([]ControlIngressRoutingTableEvent, error)
func (*Queries) ListIngressRoutingTableSnapshot ¶
func (q *Queries) ListIngressRoutingTableSnapshot(ctx context.Context, arg ListIngressRoutingTableSnapshotParams) ([]ControlIngressRoutingTableEvent, error)
Group only entry keys and revisions across history, then fetch the selected payloads. Filter after selection so tombstones/expiry cannot revive old rows.
func (*Queries) ListLatestIngressUsageReports ¶
func (q *Queries) ListLatestIngressUsageReports(ctx context.Context, arg ListLatestIngressUsageReportsParams) ([]ListLatestIngressUsageReportsRow, error)
The ingress/run guards serialize this source's append-only history. Fetch only bounded metadata, not histogram blobs; exact replays still load their payload.
func (*Queries) ListMaintenanceControls ¶
func (q *Queries) ListMaintenanceControls(ctx context.Context) ([]ControlMaintenanceControl, error)
func (*Queries) ListRelayDNSChallengePresentations ¶
func (*Queries) ListRelayServiceAssignmentTotals ¶
func (q *Queries) ListRelayServiceAssignmentTotals(ctx context.Context) ([]ControlRelayServiceAssignmentTotal, error)
func (*Queries) ListRouteSessionConnections ¶
func (*Queries) ListTeamInvitations ¶
func (*Queries) ListTeamMemberNamespaceLabels ¶
func (*Queries) ListTeamMembershipContexts ¶
func (*Queries) ListValidReadyPublisherConnections ¶
func (q *Queries) ListValidReadyPublisherConnections(ctx context.Context, arg ListValidReadyPublisherConnectionsParams) ([]ListValidReadyPublisherConnectionsRow, error)
func (*Queries) LockACMEOrder ¶
func (*Queries) LockACMEOrderForInstall ¶
func (q *Queries) LockACMEOrderForInstall(ctx context.Context, arg LockACMEOrderForInstallParams) (ControlAcmeOrder, error)
func (*Queries) LockCertificateIssuanceControl ¶
func (*Queries) LockControlSessionByRefreshID ¶
func (*Queries) LockDNSAuthority ¶
func (*Queries) LockDNSAuthorityLocalDomain ¶
func (*Queries) LockDNSAuthorityLocalTeam ¶
func (*Queries) LockDomainRoutes ¶
func (q *Queries) LockDomainRoutes(ctx context.Context, arg LockDomainRoutesParams) ([]ControlRoute, error)
func (*Queries) LockEligibleRelayLeases ¶
func (q *Queries) LockEligibleRelayLeases(ctx context.Context, arg LockEligibleRelayLeasesParams) ([]LockEligibleRelayLeasesRow, error)
func (*Queries) LockExpiredEphemeralRoutes ¶
func (q *Queries) LockExpiredEphemeralRoutes(ctx context.Context, arg LockExpiredEphemeralRoutesParams) ([]ControlRoute, error)
func (*Queries) LockHostedTeamRoutes ¶
func (*Queries) LockIdentityBootstrap ¶
func (*Queries) LockIdentityForTeamCreation ¶
func (*Queries) LockIdentityRouteForDelete ¶
func (q *Queries) LockIdentityRouteForDelete(ctx context.Context, arg LockIdentityRouteForDeleteParams) (LockIdentityRouteForDeleteRow, error)
func (*Queries) LockIngressLease ¶
func (q *Queries) LockIngressLease(ctx context.Context, arg LockIngressLeaseParams) (ControlIngressLease, error)
func (*Queries) LockIngressRoutingTableClock ¶
func (*Queries) LockInvalidReadyPublisherConnections ¶
func (q *Queries) LockInvalidReadyPublisherConnections(ctx context.Context, now pgtype.Timestamptz) ([]ControlRouteSessionConnection, error)
func (*Queries) LockInvitationByTokenDigest ¶
func (q *Queries) LockInvitationByTokenDigest(ctx context.Context, arg LockInvitationByTokenDigestParams) (LockInvitationByTokenDigestRow, error)
func (*Queries) LockLocalRouteTeamForMutation ¶
func (*Queries) LockLocalTeamForMutation ¶
Local authority mutations lock the team before identities, memberships, domains, DNS authorities, and routes. Authorization is rechecked under this transaction-held guard; hosted teams never require fabricated local rows. Queue writers with the session readers using a transaction advisory lock: PostgreSQL row-lock readers alone can bypass a waiting writer indefinitely.
func (*Queries) LockLocalTeamForSession ¶
Session creation reads authority under this guard before locking its route. Different routes may start together; team/role/domain mutations must wait. Callers must not upgrade this guard by writing the team later in the transaction.
func (*Queries) LockManagedDomainForClaim ¶
func (q *Queries) LockManagedDomainForClaim(ctx context.Context) (ControlDomain, error)
func (*Queries) LockMembershipRoutes ¶
func (q *Queries) LockMembershipRoutes(ctx context.Context, arg LockMembershipRoutesParams) ([]ControlRoute, error)
func (*Queries) LockRelayServiceForCertificate ¶
func (*Queries) LockRelayServicesForPlacement ¶
Acquire the reservation guard before service guards and rows, in one command. Callers finish locking all services before locking leases or checking capacity.
func (*Queries) LockRouteCreationControl ¶
func (*Queries) LockRouteCreator ¶
Serialize creators without blocking session and audit foreign-key checks.
func (*Queries) LockRouteForSession ¶
Session operations serialize route mutations but never change the route's identity. Let usage's KEY SHARE references coexist; overlapping usage pages can otherwise starve a waiting heartbeat's stronger UPDATE lock.
func (*Queries) LockRouteForUsage ¶
func (*Queries) LockRouteRecoveryEpisode ¶
func (*Queries) LockRouteSession ¶
func (*Queries) LockRouteSessionCreationControl ¶
func (*Queries) LockRouteSessionForUsage ¶
func (q *Queries) LockRouteSessionForUsage(ctx context.Context, arg LockRouteSessionForUsageParams) (ControlRouteSession, error)
Acquire the immutable route reference before the session, in one round trip. Read the bucket in a LATER statement: a competing ingress may create it while this statement waits for the session lock, after this statement's snapshot.
func (*Queries) LockTeamActorContext ¶
func (q *Queries) LockTeamActorContext(ctx context.Context, arg LockTeamActorContextParams) (LockTeamActorContextRow, error)
func (*Queries) LockTeamDomain ¶
func (q *Queries) LockTeamDomain(ctx context.Context, arg LockTeamDomainParams) (LockTeamDomainRow, error)
func (*Queries) LockTeamForInvitationAcceptance ¶
func (*Queries) LockTeamInvitation ¶
func (q *Queries) LockTeamInvitation(ctx context.Context, arg LockTeamInvitationParams) (LockTeamInvitationRow, error)
func (*Queries) LockTeamMembership ¶
func (q *Queries) LockTeamMembership(ctx context.Context, arg LockTeamMembershipParams) (LockTeamMembershipRow, error)
func (*Queries) MarkACMEAuthorizationsPresented ¶
func (*Queries) MarkACMEOrderInstalled ¶
func (q *Queries) MarkACMEOrderInstalled(ctx context.Context, arg MarkACMEOrderInstalledParams) (ControlAcmeOrder, error)
func (*Queries) MarkClaimedDomainReleasing ¶
func (*Queries) MarkDNSAuthorityReleasing ¶
func (*Queries) MarkExpiredIngressUsageRunIncomplete ¶
func (q *Queries) MarkExpiredIngressUsageRunIncomplete(ctx context.Context, arg MarkExpiredIngressUsageRunIncompleteParams) error
func (*Queries) MarkExpiredIngressUsageRunsIncomplete ¶
func (q *Queries) MarkExpiredIngressUsageRunsIncomplete(ctx context.Context, now pgtype.Timestamptz) ([]ControlIngressUsageRun, error)
func (*Queries) MarkIngressUsageRunReported ¶
func (q *Queries) MarkIngressUsageRunReported(ctx context.Context, arg MarkIngressUsageRunReportedParams) (ControlIngressUsageRun, error)
func (*Queries) MarkInvitationExpired ¶
func (*Queries) MarkPublisherConnectionReady ¶
func (q *Queries) MarkPublisherConnectionReady(ctx context.Context, arg MarkPublisherConnectionReadyParams) (ControlRouteSessionConnection, error)
func (*Queries) MarkRouteSessionCertificateInstalled ¶
func (q *Queries) MarkRouteSessionCertificateInstalled(ctx context.Context, arg MarkRouteSessionCertificateInstalledParams) (ControlRouteSession, error)
func (*Queries) MarkRouteSessionReady ¶
func (q *Queries) MarkRouteSessionReady(ctx context.Context, arg MarkRouteSessionReadyParams) (ControlRouteSession, error)
func (*Queries) ObserveAuthorityRevision ¶
func (*Queries) ObserveRouteRecoveryEpisode ¶
func (q *Queries) ObserveRouteRecoveryEpisode(ctx context.Context, arg ObserveRouteRecoveryEpisodeParams) (ControlRouteRecoveryEpisode, error)
func (*Queries) OpenRouteRecoveryEpisode ¶
func (q *Queries) OpenRouteRecoveryEpisode(ctx context.Context, arg OpenRouteRecoveryEpisodeParams) error
func (*Queries) PruneIngressRoutingHistoryBatch ¶
func (q *Queries) PruneIngressRoutingHistoryBatch(ctx context.Context, afterRevision int64) (PruneIngressRoutingHistoryBatchRow, error)
Bound candidates visited as well as rows deleted. Advance past anchors even when no row can be removed. Keep the newest hostname/category projection (including tombstones/expired entries) AND each route-version's latest revision. All checks use this statement's snapshot. Concurrent publications can only make an old anchor redundant; they cannot make a superseded event current.
func (*Queries) PutControlTLSCacheEntry ¶
func (q *Queries) PutControlTLSCacheEntry(ctx context.Context, arg PutControlTLSCacheEntryParams) error
func (*Queries) QuarantineMemberSlug ¶
func (*Queries) ReadIngressRoutingTableClock ¶
func (q *Queries) ReadIngressRoutingTableClock(ctx context.Context) (ControlIngressRoutingTableClock, error)
func (*Queries) RegisterIngress ¶
func (q *Queries) RegisterIngress(ctx context.Context, arg RegisterIngressParams) (ControlIngressLease, error)
func (*Queries) RegisterRelay ¶
func (q *Queries) RegisterRelay(ctx context.Context, arg RegisterRelayParams) (RegisterRelayRow, error)
Blocking service operations acquire a transaction advisory guard before any service/lease row locks. Shared row readers alone can bypass a queued writer; the advisory queue lets registration, placement and certificate writes progress. SKIP LOCKED certificate preparation and bulk key rotation remain opportunistic row-only writers: they never wait for a service row or acquire this guard after holding one. Keep their nonblocking behavior rather than adding a lock upgrade.
func (*Queries) ReleaseInvitedMemberSlug ¶
func (*Queries) RemoveTeamMembership ¶
func (*Queries) RenewEphemeralRouteExpiry ¶
func (q *Queries) RenewEphemeralRouteExpiry(ctx context.Context, arg RenewEphemeralRouteExpiryParams) (pgtype.Timestamptz, error)
func (*Queries) RenewIngress ¶
func (q *Queries) RenewIngress(ctx context.Context, arg RenewIngressParams) (ControlIngressLease, error)
func (*Queries) RenewRelay ¶
func (q *Queries) RenewRelay(ctx context.Context, arg RenewRelayParams) (RenewRelayRow, error)
func (*Queries) ReplaceRouteSessionConnection ¶
func (q *Queries) ReplaceRouteSessionConnection(ctx context.Context, arg ReplaceRouteSessionConnectionParams) (ControlRouteSessionConnection, error)
A failed ready connection can keep its existing service reservation. This atomic ready -> assigned transition has zero counter delta and needs only the caller's route/session locks, not placement's global/service/lease guards. Check failure and eligible service capacity in the statement snapshot. A concurrent lease/configuration change may invalidate the returned assignment, just as one immediately after commit can; claim checks the exact current lease and process capacity under its exclusive lease guard. No capacity is added here. Closed/expired slots have no reservation and require guarded placement first.
func (*Queries) ReserveInvitedMemberSlug ¶
func (*Queries) ReserveManagedLabel ¶
func (*Queries) RetryRouteUsageDelivery ¶
func (q *Queries) RetryRouteUsageDelivery(ctx context.Context, arg RetryRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)
func (*Queries) RevokeControlSession ¶
func (*Queries) RevokeTeamInvitation ¶
func (*Queries) RotateACMEAccountKey ¶
func (q *Queries) RotateACMEAccountKey(ctx context.Context, arg RotateACMEAccountKeyParams) error
func (*Queries) RotateControlSessionCredentials ¶
func (*Queries) RotateControlSessionRetrySecret ¶
func (q *Queries) RotateControlSessionRetrySecret(ctx context.Context, arg RotateControlSessionRetrySecretParams) error
func (*Queries) RotateControlTLSCacheEntry ¶
func (q *Queries) RotateControlTLSCacheEntry(ctx context.Context, arg RotateControlTLSCacheEntryParams) error
func (*Queries) RotateExternalRetryMasterKey ¶
func (q *Queries) RotateExternalRetryMasterKey(ctx context.Context, arg RotateExternalRetryMasterKeyParams) error
func (*Queries) RotateRelayCertificateOrderPrivateKey ¶
func (q *Queries) RotateRelayCertificateOrderPrivateKey(ctx context.Context, arg RotateRelayCertificateOrderPrivateKeyParams) error
func (*Queries) RotateRelayServicePrivateKey ¶
func (q *Queries) RotateRelayServicePrivateKey(ctx context.Context, arg RotateRelayServicePrivateKeyParams) error
func (*Queries) SaveACMEAuthorizationWork ¶
func (q *Queries) SaveACMEAuthorizationWork(ctx context.Context, arg SaveACMEAuthorizationWorkParams) (ControlAcmeAuthorization, error)
func (*Queries) SaveACMEOrderWork ¶
func (q *Queries) SaveACMEOrderWork(ctx context.Context, arg SaveACMEOrderWorkParams) (ControlAcmeOrder, error)
func (*Queries) SaveDNSAuthorityWork ¶
func (q *Queries) SaveDNSAuthorityWork(ctx context.Context, arg SaveDNSAuthorityWorkParams) (ControlDnsAuthority, error)
func (*Queries) SaveDNSRouteWork ¶
func (q *Queries) SaveDNSRouteWork(ctx context.Context, arg SaveDNSRouteWorkParams) (ControlRoute, error)
func (*Queries) SaveRelayCertificateOrderWork ¶
func (q *Queries) SaveRelayCertificateOrderWork(ctx context.Context, arg SaveRelayCertificateOrderWorkParams) (ControlRelayCertificateOrder, error)
func (*Queries) SelectIngressRoutingRetentionFloor ¶
func (q *Queries) SelectIngressRoutingRetentionFloor(ctx context.Context, cutoff pgtype.Timestamptz) (int64, error)
Find an old committed PREFIX, not the largest old timestamp. Request-start timestamps can be out of revision order; preserve every still-recent event. This scan happens before acquiring the publication clock.
func (*Queries) SetDNSReadyDomainDefault ¶
func (*Queries) SetDomainAuthorityRevision ¶
func (q *Queries) SetDomainAuthorityRevision(ctx context.Context, arg SetDomainAuthorityRevisionParams) error
func (*Queries) SetMaintenanceControl ¶
func (q *Queries) SetMaintenanceControl(ctx context.Context, arg SetMaintenanceControlParams) (ControlMaintenanceControl, error)
func (*Queries) SetPersonalTeamDefaultDomain ¶
func (q *Queries) SetPersonalTeamDefaultDomain(ctx context.Context, arg SetPersonalTeamDefaultDomainParams) error
func (*Queries) SetTeamDefaultDomain ¶
func (*Queries) StoreRelayTransportCertificate ¶
func (q *Queries) StoreRelayTransportCertificate(ctx context.Context, arg StoreRelayTransportCertificateParams) (ControlRelayService, error)
func (*Queries) SuspendAuthorityRoute ¶
func (*Queries) TeamMembershipIdentityExists ¶
func (*Queries) TryLockIngressRoutingHistoryCleanup ¶
Cleanup-only coordination; no route, reservation, service, lease, or clock locks.
func (*Queries) UpdateACMEAccountRegistration ¶
func (q *Queries) UpdateACMEAccountRegistration(ctx context.Context, arg UpdateACMEAccountRegistrationParams) (ControlAcmeAccount, error)
func (*Queries) UpdateLocalDomainForDNSAuthority ¶
func (q *Queries) UpdateLocalDomainForDNSAuthority(ctx context.Context, arg UpdateLocalDomainForDNSAuthorityParams) (UpdateLocalDomainForDNSAuthorityRow, error)
func (*Queries) UpdateMembershipRole ¶
func (*Queries) UpdateOIDCIdentity ¶
func (q *Queries) UpdateOIDCIdentity(ctx context.Context, arg UpdateOIDCIdentityParams) (ControlIdentity, error)
func (*Queries) UpdateRoute ¶
func (q *Queries) UpdateRoute(ctx context.Context, arg UpdateRouteParams) (ControlRoute, error)
func (*Queries) UpdateRouteRecoveryHistogram ¶
func (q *Queries) UpdateRouteRecoveryHistogram(ctx context.Context, arg UpdateRouteRecoveryHistogramParams) (ControlRouteRecoveryHistogram, error)
func (*Queries) WakeACMEOrder ¶
func (q *Queries) WakeACMEOrder(ctx context.Context, arg WakeACMEOrderParams) error
A publisher transition invalidates the worker's authorization snapshot. Call only after changing authorizations while holding the order lock.
type RegisterIngressParams ¶
type RegisterIngressParams struct {
IngressID string
IngressRunID string
ProtocolVersion int64
ConnectionCapacity int64
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
}
type RegisterRelayParams ¶
type RegisterRelayParams struct {
RelayServiceID string
RelayAddress string
TlsServerName string
RegisteredAt pgtype.Timestamptz
RelayID string
RelayRunID string
ProtocolVersion int64
InternalRelayAddress string
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
}
type RegisterRelayRow ¶
type RegisterRelayRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type ReleaseInvitedMemberSlugParams ¶
type ReleaseInvitedMemberSlugParams struct {
ReleasedAt pgtype.Timestamptz
SlugReservationID string
}
type RenewEphemeralRouteExpiryParams ¶
type RenewEphemeralRouteExpiryParams struct {
ExpiresAt pgtype.Timestamptz
RouteID string
}
type RenewIngressParams ¶
type RenewIngressParams struct {
ReportedConnections int64
RoutingTableRevision int64
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
IngressID string
IngressRunID string
IngressLeaseRevision int64
}
type RenewRelayParams ¶
type RenewRelayParams struct {
ReportedConnections int64
ReportedStreams int64
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayServiceID string
RelayID string
RelayRunID string
RelayLeaseRevision int64
}
type RenewRelayRow ¶
type RenewRelayRow struct {
RelayID string
RelayServiceID string
RelayRunID string
RelayLeaseRevision int64
ProtocolVersion int64
InternalRelayAddress string
ObservedAddress *netip.Addr
InternalNetworks []netip.Prefix
ConnectionCapacity int64
StreamCapacity int64
ReportedConnections int64
ReportedStreams int64
Draining bool
DrainDeadline pgtype.Timestamptz
RegisteredAt pgtype.Timestamptz
RenewedAt pgtype.Timestamptz
LeaseExpiresAt pgtype.Timestamptz
RelayAddress string
TlsServerName string
}
type ReplaceRouteSessionConnectionParams ¶
type ReplaceRouteSessionConnectionParams struct {
NewPublisherConnectionID string
NewConnectionAssignmentRevision int64
RelayServiceID string
RelayAddress string
TlsServerName string
PublisherConnectionCredentialDigest []byte
PublisherConnectionCredentialExpiresAt pgtype.Timestamptz
AssignedAt pgtype.Timestamptz
RouteSessionID string
ConnectionSlot int16
PreviousPublisherConnectionID string
PreviousConnectionAssignmentRevision int64
}
type ReserveManagedLabelParams ¶
type ReserveManagedLabelParams struct {
Label string
CreatedAt pgtype.Timestamptz
}
type RetryRouteUsageDeliveryParams ¶
type RetryRouteUsageDeliveryParams struct {
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
DeliveryID int64
WorkOwner pgtype.Text
WorkEpoch int64
CompletedAt pgtype.Timestamptz
}
type RevokeControlSessionParams ¶
type RevokeControlSessionParams struct {
RevokedAt pgtype.Timestamptz
RevokedBy pgtype.Text
ID string
}
type RevokeTeamInvitationParams ¶
type RevokeTeamInvitationParams struct {
RevokedAt pgtype.Timestamptz
IdentityID pgtype.Text
InvitationID string
}
type RotateControlSessionCredentialsParams ¶
type RotateControlSessionCredentialsParams struct {
AccessTokenID string
AccessTokenDigest []byte
AccessExpiresAt pgtype.Timestamptz
RefreshTokenID string
RefreshTokenDigest []byte
RefreshedAt pgtype.Timestamptz
ID string
}
type SaveACMEAuthorizationWorkParams ¶
type SaveACMEAuthorizationWorkParams struct {
ID string
OrderID string
Identifier string
AuthorizationUrl string
ChallengeType pgtype.Text
ChallengeUrl pgtype.Text
ChallengeToken pgtype.Text
ChallengeDigest []byte
PresentationReference pgtype.Text
State string
AuthorizationRevision int64
Attempts int64
AvailableAt pgtype.Timestamptz
PresentedAt pgtype.Timestamptz
ValidatedAt pgtype.Timestamptz
CleanupCompletedAt pgtype.Timestamptz
ExpiresAt pgtype.Timestamptz
LastError pgtype.Text
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
ExpectedAuthorizationRevision int64
}
type SaveACMEOrderWorkParams ¶
type SaveACMEOrderWorkParams struct {
State string
OrderUrl pgtype.Text
FinalizeUrl pgtype.Text
CertificateUrl pgtype.Text
CertificatePem []byte
NotBefore pgtype.Timestamptz
NotAfter pgtype.Timestamptz
RenewAt pgtype.Timestamptz
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
CompletedAt pgtype.Timestamptz
IssuanceID string
WorkOwner pgtype.Text
WorkEpoch int64
ExpectedOrderRevision int64
}
type SaveDNSRouteWorkParams ¶
type SaveRelayCertificateOrderWorkParams ¶
type SaveRelayCertificateOrderWorkParams struct {
State string
OrderUrl pgtype.Text
FinalizeUrl pgtype.Text
CertificateUrl pgtype.Text
AuthorizationUrl pgtype.Text
ChallengeUrl pgtype.Text
ChallengeToken pgtype.Text
ChallengeDigest []byte
PresentationReference pgtype.Text
CertificatePem []byte
NotBefore pgtype.Timestamptz
NotAfter pgtype.Timestamptz
RenewAt pgtype.Timestamptz
AvailableAt pgtype.Timestamptz
LastError pgtype.Text
CompletedAt pgtype.Timestamptz
OrderID string
WorkOwner pgtype.Text
WorkEpoch int64
ExpectedOrderRevision int64
}
type SetDNSReadyDomainDefaultParams ¶
type SetDNSReadyDomainDefaultParams struct {
UpdatedAt pgtype.Timestamptz
AuthorityReference pgtype.Text
}
type SetDomainAuthorityRevisionParams ¶
type SetDomainAuthorityRevisionParams struct {
AuthorityRevision int64
UpdatedAt pgtype.Timestamptz
AuthorityReference pgtype.Text
}
type SetMaintenanceControlParams ¶
type SetMaintenanceControlParams struct {
Allowed bool
UpdatedAt pgtype.Timestamptz
UpdatedBy string
ControlName string
}
type SetPersonalTeamDefaultDomainParams ¶
type SetPersonalTeamDefaultDomainParams struct {
DomainID pgtype.Text
UpdatedAt pgtype.Timestamptz
TeamID string
}
type SetTeamDefaultDomainParams ¶
type SetTeamDefaultDomainParams struct {
DomainID pgtype.Text
UpdatedAt pgtype.Timestamptz
TeamID string
}
type StoreRelayTransportCertificateParams ¶
type StoreRelayTransportCertificateParams struct {
TransportCertificatePem pgtype.Text
TransportPrivateKeyCiphertext []byte
TransportPrivateKeyStorageKeyID pgtype.Text
TransportCertificateSerial pgtype.Text
TransportCertificateExpiresAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
RelayServiceID string
TlsServerName string
}
type SuspendAuthorityRouteParams ¶
type SuspendAuthorityRouteParams struct {
SuspendedAt pgtype.Timestamptz
SuspensionReason pgtype.Text
RouteID string
}
type UpdateLocalDomainForDNSAuthorityParams ¶
type UpdateLocalDomainForDNSAuthorityParams struct {
State string
UpdatedAt pgtype.Timestamptz
AuthorityReference pgtype.Text
}
type UpdateRouteParams ¶
type UpdateRouteRecoveryHistogramParams ¶
type UpdateRouteRecoveryHistogramParams struct {
ObservedSeconds float64
UpdatedAt pgtype.Timestamptz
}
type WakeACMEOrderParams ¶
type WakeACMEOrderParams struct {
AvailableAt pgtype.Timestamptz
IssuanceID string
}
Source Files
¶
- admin.sql.go
- authentication.sql.go
- certificates.sql.go
- db.go
- dns_authorities.sql.go
- dns_challenges.sql.go
- dns_routes.sql.go
- external_authority.sql.go
- ingress_routing_table.sql.go
- ingresses.sql.go
- models.go
- publisher_connections.sql.go
- querier.go
- relay_certificates.sql.go
- relays.sql.go
- route_lifecycle.sql.go
- route_sessions.sql.go
- routes.sql.go
- routing_history.sql.go
- teams.sql.go
- usage.sql.go