controlstatedb

package
v0.1.0-rc.28 Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcceptTeamInvitationParams

type AcceptTeamInvitationParams struct {
	AcceptedAt   pgtype.Timestamptz
	IdentityID   pgtype.Text
	MembershipID pgtype.Text
	InvitationID string
}

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 ApplyIngressUsageReportRow

type ApplyIngressUsageReportRow struct {
	ReportInserted       bool
	BucketUpdated        bool
	PolicyDenialsUpdated bool
}

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 CloseRouteSessionParams struct {
	State          string
	ClosedAt       pgtype.Timestamptz
	CloseReason    pgtype.Text
	RouteSessionID string
}

type CompleteACMEAuthorizationCleanupParams

type CompleteACMEAuthorizationCleanupParams struct {
	CompletedAt pgtype.Timestamptz
	IssuanceID  string
}

type CompleteRouteUsageDeliveryParams

type CompleteRouteUsageDeliveryParams struct {
	CompletedAt pgtype.Timestamptz
	DeliveryID  int64
	WorkOwner   pgtype.Text
	WorkEpoch   int64
}

type ConsumeOIDCAssertionParams

type ConsumeOIDCAssertionParams struct {
	AssertionDigest []byte
	ConsumedAt      pgtype.Timestamptz
	ExpiresAt       pgtype.Timestamptz
}

type ControlAcmeAccount

type ControlAcmeAccount struct {
	ID                     string
	DirectoryUrl           string
	ContactEmail           string
	AccountKeyCiphertext   []byte
	AccountKeyStorageKeyID string
	AccountUrl             pgtype.Text
	AcceptedTermsUrl       pgtype.Text
	CreatedAt              pgtype.Timestamptz
	UpdatedAt              pgtype.Timestamptz
}

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 ControlAdminAuditEvent struct {
	EventID         int64
	ActorIdentityID pgtype.Text
	Actor           string
	RequestID       string
	Operation       string
	TargetKind      string
	TargetID        string
	Details         []byte
	OccurredAt      pgtype.Timestamptz
}

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 ControlControlTlsCache struct {
	DirectoryUrl      string
	CacheKey          string
	CacheCiphertext   []byte
	CacheStorageKeyID string
	UpdatedAt         pgtype.Timestamptz
}

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 ControlIdentity struct {
	ID              string
	Kind            string
	Issuer          pgtype.Text
	Subject         pgtype.Text
	DisplayName     string
	NormalizedEmail pgtype.Text
	EmailVerified   bool
	Administrator   bool
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	DisabledAt      pgtype.Timestamptz
}

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 ControlIngressRoutingTableEvent

type ControlIngressRoutingTableEvent struct {
	RoutingTableRevision int64
	EventKind            string
	RouteID              string
	RouteVersion         int64
	CanonicalHostname    string
	EntryRevision        int64
	Projection           []byte
	RouteExpiresAt       pgtype.Timestamptz
	CreatedAt            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 ControlMaintenanceControl

type ControlMaintenanceControl struct {
	ControlName string
	Allowed     bool
	Revision    int64
	UpdatedAt   pgtype.Timestamptz
	UpdatedBy   string
}

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 ControlRelayServiceAssignmentTotal

type ControlRelayServiceAssignmentTotal struct {
	RelayServiceID  string
	AssignmentCount int64
}

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 CountOpenRouteSessionAssignmentsByRelayServiceRow

type CountOpenRouteSessionAssignmentsByRelayServiceRow struct {
	RelayServiceID  string
	AssignmentCount int64
}

type CountRelayActiveConnectionsParams

type CountRelayActiveConnectionsParams struct {
	RelayID            pgtype.Text
	RelayRunID         pgtype.Text
	RelayLeaseRevision pgtype.Int8
}

type CreateActiveSlugReservationParams

type CreateActiveSlugReservationParams struct {
	ID         string
	TeamID     string
	MemberSlug string
	IdentityID pgtype.Text
	CreatedAt  pgtype.Timestamptz
}

type CreateClaimedDNSAuthorityParams

type CreateClaimedDNSAuthorityParams struct {
	AuthorityReference   string
	TeamID               string
	DomainID             string
	CanonicalDomain      string
	CreateIdempotencyKey string
	CreateRequestDigest  []byte
	CreatedAt            pgtype.Timestamptz
}

type CreateClaimedDomainParams

type CreateClaimedDomainParams struct {
	ID                    string
	TeamID                pgtype.Text
	CanonicalDomain       string
	DnsAuthorityReference pgtype.Text
	AuthorityRevision     int64
	CreatedByIdentityID   pgtype.Text
	ClaimIdempotencyKey   pgtype.Text
	ClaimRequestDigest    []byte
	MakeDefaultWhenReady  bool
	CreatedAt             pgtype.Timestamptz
}

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 CreateIdentityParams struct {
	ID              string
	Kind            string
	DisplayName     string
	NormalizedEmail pgtype.Text
	EmailVerified   bool
	Administrator   bool
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type CreateManagedDomainParams

type CreateManagedDomainParams struct {
	ID              string
	CanonicalDomain string
	CreatedAt       pgtype.Timestamptz
}

type CreateOIDCIdentityParams

type CreateOIDCIdentityParams struct {
	ID              string
	Issuer          pgtype.Text
	Subject         pgtype.Text
	DisplayName     string
	NormalizedEmail pgtype.Text
	EmailVerified   bool
	CreatedAt       pgtype.Timestamptz
}

type CreateOrGetDNSAuthorityParams

type CreateOrGetDNSAuthorityParams struct {
	AuthorityReference   string
	TeamID               string
	DomainID             string
	CanonicalDomain      string
	CreateIdempotencyKey string
	CreateRequestDigest  []byte
	CreatedAt            pgtype.Timestamptz
}

type CreateOrganizationTeamParams

type CreateOrganizationTeamParams struct {
	ID                     string
	DisplayName            string
	ManagedLabel           string
	DefaultDomainID        pgtype.Text
	CreatedByIdentityID    string
	CreationIdempotencyKey pgtype.Text
	CreationRequestDigest  []byte
	CreatedAt              pgtype.Timestamptz
}

type CreateOrganizationTeamRow

type CreateOrganizationTeamRow struct {
	ID              string
	Kind            string
	DisplayName     string
	ManagedLabel    string
	DefaultDomainID pgtype.Text
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type CreateOwnerMembershipParams

type CreateOwnerMembershipParams struct {
	ID                string
	TeamID            string
	IdentityID        string
	SlugReservationID string
	ManagedLabel      string
	CreatedAt         pgtype.Timestamptz
}

type CreatePersonalTeamParams

type CreatePersonalTeamParams struct {
	ID                  string
	DisplayName         string
	ManagedLabel        string
	CreatedByIdentityID string
	CreatedAt           pgtype.Timestamptz
}

type CreateTeamInvitationParams

type CreateTeamInvitationParams struct {
	ID                         string
	TeamID                     string
	SlugReservationID          string
	InitialRole                string
	InvitedByIdentityID        string
	IdempotencyKey             string
	RequestDigest              []byte
	TokenDigest                []byte
	NormalizedEmailRestriction pgtype.Text
	CreatedAt                  pgtype.Timestamptz
	ExpiresAt                  pgtype.Timestamptz
}

type CreateTeamMembershipParams

type CreateTeamMembershipParams struct {
	ID                string
	TeamID            string
	IdentityID        string
	SlugReservationID string
	ManagedLabel      string
	Role              string
	AuthorityRevision int64
	CreatedAt         pgtype.Timestamptz
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DNSAuthorityReleaseReadyParams

type DNSAuthorityReleaseReadyParams struct {
	AuthorityDomainID string
	ObservedAt        pgtype.Timestamptz
}

type DeleteControlTLSCacheEntryParams

type DeleteControlTLSCacheEntryParams struct {
	DirectoryUrl string
	CacheKey     string
}

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 EnsureACMEAccountParams struct {
	ID                     string
	DirectoryUrl           string
	ContactEmail           string
	AccountKeyCiphertext   []byte
	AccountKeyStorageKeyID string
	CreatedAt              pgtype.Timestamptz
}

type EnsureExternalAuthorityPrincipalParams

type EnsureExternalAuthorityPrincipalParams struct {
	IdentityID string
	CreatedAt  pgtype.Timestamptz
}

type EnsureExternalRetryMasterKeyParams

type EnsureExternalRetryMasterKeyParams struct {
	ExternalRetryMasterKeyCiphertext   []byte
	ExternalRetryMasterKeyStorageKeyID string
	CreatedAt                          pgtype.Timestamptz
}

type EnsureExternalRetryMasterKeyRow

type EnsureExternalRetryMasterKeyRow struct {
	ExternalRetryMasterKeyCiphertext   []byte
	ExternalRetryMasterKeyStorageKeyID string
}

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 FindOIDCIdentityParams struct {
	Issuer  pgtype.Text
	Subject pgtype.Text
}

type GetACMEOrderByIdempotencyParams

type GetACMEOrderByIdempotencyParams struct {
	RouteSessionID string
	IdempotencyKey string
}

type GetActiveRouteSessionChallengeExpiryParams

type GetActiveRouteSessionChallengeExpiryParams struct {
	RouteSessionID string
	Now            pgtype.Timestamptz
}

type GetActiveRouteSessionMembershipParams

type GetActiveRouteSessionMembershipParams struct {
	TeamID     string
	IdentityID string
}

type GetActiveRouteSessionMembershipRow

type GetActiveRouteSessionMembershipRow struct {
	ID             string
	Role           string
	PolicyRevision int64
}

type GetAdminRuntimeCountsRow

type GetAdminRuntimeCountsRow struct {
	EnabledRoutes         int64
	SuspendedRoutes       int64
	StartingRouteSessions int64
	ReadyRouteSessions    int64
	IngressLeases         int64
	RelayLeases           int64
}

type GetAuthorizedRouteByHostnameParams

type GetAuthorizedRouteByHostnameParams struct {
	TeamID            string
	CanonicalHostname string
}

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 GetClaimedDomainByIdempotencyParams

type GetClaimedDomainByIdempotencyParams struct {
	IdentityID     pgtype.Text
	TeamID         pgtype.Text
	IdempotencyKey pgtype.Text
}

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 GetControlTLSCacheEntryParams

type GetControlTLSCacheEntryParams struct {
	DirectoryUrl string
	CacheKey     string
}

type GetControlTLSCacheEntryRow

type GetControlTLSCacheEntryRow struct {
	CacheCiphertext   []byte
	CacheStorageKeyID string
}

type GetDNSChallengeContextParams

type GetDNSChallengeContextParams struct {
	RouteID         string
	AuthorizationID string
}

type GetDNSChallengeContextRow

type GetDNSChallengeContextRow struct {
	RouteID               string
	TeamID                string
	DomainID              string
	DnsAuthorityReference pgtype.Text
	CanonicalHostname     string
	CanonicalDomain       string
	AuthorizationID       string
	Identifier            string
	ChallengeDigest       []byte
	PresentationReference pgtype.Text
	State                 string
}

type GetExternalAuthorityRouteParams

type GetExternalAuthorityRouteParams struct {
	RouteSessionIdempotencyKey string
	RouteID                    string
}

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 GetIdentityContextIdentityRow

type GetIdentityContextIdentityRow struct {
	ID              string
	DisplayName     string
	NormalizedEmail pgtype.Text
	EmailVerified   bool
	Administrator   bool
	CreatedAt       pgtype.Timestamptz
	PersonalTeamID  string
}

type GetIdentityRouteParams

type GetIdentityRouteParams struct {
	RouteID    string
	IdentityID string
}

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 GetIdentityTeamParams struct {
	IdentityID string
	TeamID     string
}

type GetIdentityTeamRow

type GetIdentityTeamRow struct {
	ID              string
	Kind            string
	DisplayName     string
	ManagedLabel    string
	DefaultDomainID pgtype.Text
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type GetIngressLeaseParams

type GetIngressLeaseParams struct {
	IngressID            string
	IngressRunID         string
	IngressLeaseRevision int64
	Now                  pgtype.Timestamptz
}

type GetIngressUsageReportParams

type GetIngressUsageReportParams struct {
	IngressID      string
	IngressRunID   string
	RouteID        string
	RouteVersion   int64
	BucketStart    pgtype.Timestamptz
	ReportRevision int64
}

type GetInvitationByIdempotencyParams

type GetInvitationByIdempotencyParams struct {
	IdentityID     string
	TeamID         string
	IdempotencyKey string
}

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 GetOpenRouteRecoveryEpisodeParams

type GetOpenRouteRecoveryEpisodeParams struct {
	RouteID      string
	RouteVersion int64
}

type GetOrganizationTeamByIdempotencyParams

type GetOrganizationTeamByIdempotencyParams struct {
	IdentityID     string
	IdempotencyKey pgtype.Text
}

type GetOrganizationTeamByIdempotencyRow

type GetOrganizationTeamByIdempotencyRow struct {
	ID                    string
	Kind                  string
	DisplayName           string
	ManagedLabel          string
	DefaultDomainID       pgtype.Text
	PolicyRevision        int64
	CreationRequestDigest []byte
	CreatedAt             pgtype.Timestamptz
	UpdatedAt             pgtype.Timestamptz
}

type GetRelayDNSChallengeContextRow

type GetRelayDNSChallengeContextRow struct {
	ID                    string
	RelayServiceID        string
	TlsServerName         string
	State                 string
	ChallengeDigest       []byte
	PresentationReference pgtype.Text
}

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 GetRelayTransportCertificateParams

type GetRelayTransportCertificateParams struct {
	RelayServiceID     string
	RelayID            string
	RelayRunID         string
	RelayLeaseRevision int64
	Now                pgtype.Timestamptz
}

type GetRouteByCreatorIdempotencyParams

type GetRouteByCreatorIdempotencyParams struct {
	IdentityID     string
	IdempotencyKey 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 GetRouteCreationContextParams

type GetRouteCreationContextParams struct {
	IdentityID string
	DomainID   string
	TeamID     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 GetRouteSessionByIdempotencyParams

type GetRouteSessionByIdempotencyParams struct {
	RouteID        string
	IdempotencyKey string
}

type GetRouteUsageBucketForUpdateParams

type GetRouteUsageBucketForUpdateParams struct {
	RouteID      string
	RouteVersion int64
	BucketStart  pgtype.Timestamptz
}

type GetTeamActorContextParams

type GetTeamActorContextParams struct {
	IdentityID string
	TeamID     string
}

type GetTeamActorContextRow

type GetTeamActorContextRow struct {
	ID                string
	Kind              string
	DisplayName       string
	ManagedLabel      string
	DefaultDomainID   pgtype.Text
	PolicyRevision    int64
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	ActorMembershipID string
	ActorRole         string
}

type GetTeamMembershipContextParams

type GetTeamMembershipContextParams struct {
	MembershipID string
	TeamID       string
}

type GetTeamMembershipContextRow

type GetTeamMembershipContextRow struct {
	ID              string
	TeamID          string
	IdentityID      string
	TeamDisplayName string
	TeamKind        string
	Role            string
	MemberSlug      string
	ManagedLabel    string
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

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 InsertAdminAuditEventParams

type InsertAdminAuditEventParams struct {
	ActorIdentityID pgtype.Text
	Actor           string
	RequestID       string
	Operation       string
	TargetKind      string
	TargetID        string
	Details         []byte
	OccurredAt      pgtype.Timestamptz
}

type InsertCertificateIssuanceAuditEventParams

type InsertCertificateIssuanceAuditEventParams struct {
	ActorIdentityID pgtype.Text
	RequestID       string
	IssuanceID      string
	OccurredAt      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 InsertRelayCertificateOrderParams

type InsertRelayCertificateOrderParams struct {
	ID                     string
	AccountID              string
	RelayServiceID         string
	TlsServerName          string
	PrivateKeyCiphertext   []byte
	PrivateKeyStorageKeyID string
	CsrDer                 []byte
	CsrDigest              []byte
	CreatedAt              pgtype.Timestamptz
}

type InsertRouteCreateAuditEventParams

type InsertRouteCreateAuditEventParams struct {
	ActorIdentityID pgtype.Text
	RequestID       string
	RouteID         string
	OccurredAt      pgtype.Timestamptz
}

type InsertRouteDeleteAuditEventParams

type InsertRouteDeleteAuditEventParams struct {
	ActorIdentityID pgtype.Text
	RequestID       string
	RouteID         string
	OccurredAt      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 InsertRouteSessionAuditEventParams

type InsertRouteSessionAuditEventParams struct {
	ActorIdentityID pgtype.Text
	Actor           string
	RequestID       string
	RouteSessionID  string
	OccurredAt      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 InsertRouteUpdateAuditEventParams

type InsertRouteUpdateAuditEventParams struct {
	ActorIdentityID pgtype.Text
	RequestID       string
	RouteID         string
	OccurredAt      pgtype.Timestamptz
}

type InsertRouteUsageDeliveryParams

type InsertRouteUsageDeliveryParams struct {
	BucketID       int64
	SourceRevision int64
	DeliveryKey    string
	AvailableAt    pgtype.Timestamptz
	CreatedAt      pgtype.Timestamptz
}

type LatestIngressRoutingEntryRevisionParams

type LatestIngressRoutingEntryRevisionParams struct {
	RouteID      string
	RouteVersion int64
}

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 ListDNSChallengePresentationsRow

type ListDNSChallengePresentationsRow struct {
	ChallengeDigest []byte
	State           string
}

type ListExternalAuthorityRoutesParams

type ListExternalAuthorityRoutesParams struct {
	TeamID string
	Cursor pgtype.Text
}

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 ListIdentityMembershipContextsRow

type ListIdentityMembershipContextsRow struct {
	ID              string
	TeamID          string
	IdentityID      string
	TeamDisplayName string
	TeamKind        string
	Role            string
	MemberSlug      string
	ManagedLabel    string
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type ListIdentityRoutesParams

type ListIdentityRoutesParams struct {
	TeamID     string
	Cursor     pgtype.Text
	IdentityID 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 ListIdentityTeamDomainsParams

type ListIdentityTeamDomainsParams struct {
	TeamID     pgtype.Text
	IdentityID string
}

type ListIdentityTeamDomainsRow

type ListIdentityTeamDomainsRow struct {
	ID                    string
	Kind                  string
	TeamID                pgtype.Text
	CanonicalDomain       string
	DnsAuthorityReference pgtype.Text
	State                 string
	AuthorityRevision     int64
	Nameservers           []string
	CreatedAt             pgtype.Timestamptz
	VerifiedAt            pgtype.Timestamptz
	UpdatedAt             pgtype.Timestamptz
}

type ListIdentityTeamsRow

type ListIdentityTeamsRow struct {
	ID              string
	Kind            string
	DisplayName     string
	ManagedLabel    string
	DefaultDomainID pgtype.Text
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type ListIngressRoutingTableEventsParams

type ListIngressRoutingTableEventsParams struct {
	AfterRevision   int64
	ThroughRevision int64
	PageLimit       int32
}

type ListIngressRoutingTableSnapshotParams

type ListIngressRoutingTableSnapshotParams struct {
	Now             pgtype.Timestamptz
	ThroughRevision int64
}

type ListLatestIngressUsageReportsParams

type ListLatestIngressUsageReportsParams struct {
	IngressID     string
	IngressRunID  string
	RouteIds      []string
	RouteVersions []int64
	BucketStarts  []pgtype.Timestamptz
}

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 ListRelayDNSChallengePresentationsRow

type ListRelayDNSChallengePresentationsRow struct {
	ChallengeDigest []byte
	State           string
}

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 ListTeamMemberNamespaceLabelsRow

type ListTeamMemberNamespaceLabelsRow struct {
	ManagedLabel string
	MemberSlug   string
}

type ListTeamMembershipContextsRow

type ListTeamMembershipContextsRow struct {
	ID              string
	TeamID          string
	IdentityID      string
	TeamDisplayName string
	TeamKind        string
	Role            string
	MemberSlug      string
	ManagedLabel    string
	PolicyRevision  int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

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 LockControlSessionByRefreshIDRow

type LockControlSessionByRefreshIDRow struct {
	ID                           string
	IdentityID                   string
	AuthenticationMethod         string
	AuthenticationSourceRevision int64
	RefreshTokenDigest           []byte
	RefreshExpiresAt             pgtype.Timestamptz
	Administrator                bool
}

type LockDomainRoutesParams

type LockDomainRoutesParams struct {
	TeamID   string
	DomainID string
}

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 LockIdentityRouteForDeleteParams

type LockIdentityRouteForDeleteParams struct {
	IdentityID string
	RouteID    string
}

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 LockInvitationByTokenDigestParams

type LockInvitationByTokenDigestParams struct {
	IdentityID  string
	TokenDigest []byte
}

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 LockMembershipRoutesParams

type LockMembershipRoutesParams struct {
	TeamID       string
	MembershipID pgtype.Text
}

type LockRouteSessionForUsageParams

type LockRouteSessionForUsageParams struct {
	RouteVersion int64
	RouteID      string
}

type LockTeamActorContextParams

type LockTeamActorContextParams struct {
	IdentityID string
	TeamID     string
}

type LockTeamActorContextRow

type LockTeamActorContextRow struct {
	ID                string
	Kind              string
	DisplayName       string
	ManagedLabel      string
	DefaultDomainID   pgtype.Text
	PolicyRevision    int64
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	ActorMembershipID string
	ActorRole         string
}

type LockTeamDomainParams

type LockTeamDomainParams struct {
	DomainID string
	TeamID   pgtype.Text
}

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 LockTeamInvitationParams

type LockTeamInvitationParams struct {
	InvitationID string
	TeamID       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 LockTeamMembershipParams

type LockTeamMembershipParams struct {
	MembershipID string
	TeamID       string
}

type LockTeamMembershipRow

type LockTeamMembershipRow 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
	MemberSlug          string
}

type MarkACMEAuthorizationsPresentedParams

type MarkACMEAuthorizationsPresentedParams struct {
	PresentedAt pgtype.Timestamptz
	IssuanceID  string
}

type MarkACMEOrderInstalledParams

type MarkACMEOrderInstalledParams struct {
	InstalledAt pgtype.Timestamptz
	IssuanceID  string
}

type MarkClaimedDomainReleasingParams

type MarkClaimedDomainReleasingParams struct {
	AuthorityRevision int64
	UpdatedAt         pgtype.Timestamptz
	DomainID          string
	TeamID            pgtype.Text
}

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 ObserveRouteRecoveryEpisodeParams

type ObserveRouteRecoveryEpisodeParams struct {
	ObservedAt        pgtype.Timestamptz
	ObservedSeconds   pgtype.Float8
	RecoveryEpisodeID int64
	RouteID           string
	RouteVersion      int64
}

type OpenRouteRecoveryEpisodeParams

type OpenRouteRecoveryEpisodeParams struct {
	RouteID      string
	RouteVersion int64
	OpenedAt     pgtype.Timestamptz
}

type PruneIngressRoutingHistoryBatchRow

type PruneIngressRoutingHistoryBatchRow struct {
	NextRevision int64
	Scanned      int64
	Deleted      int64
}

type PutControlTLSCacheEntryParams

type PutControlTLSCacheEntryParams struct {
	DirectoryUrl      string
	CacheKey          string
	CacheCiphertext   []byte
	CacheStorageKeyID string
	UpdatedAt         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 New

func New(db DBTX) *Queries

func (*Queries) AcceptTeamInvitation

func (q *Queries) AcceptTeamInvitation(ctx context.Context, arg AcceptTeamInvitationParams) (int64, error)

func (*Queries) ActivateMemberSlug

func (q *Queries) ActivateMemberSlug(ctx context.Context, arg ActivateMemberSlugParams) (int64, error)

func (*Queries) AdvanceAuthorityRevision

func (q *Queries) AdvanceAuthorityRevision(ctx context.Context, arg AdvanceAuthorityRevisionParams) (int64, error)

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

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

func (*Queries) CompleteRouteUsageDelivery

func (q *Queries) CompleteRouteUsageDelivery(ctx context.Context, arg CompleteRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)

func (*Queries) ConsumeOIDCAssertion

func (q *Queries) ConsumeOIDCAssertion(ctx context.Context, arg ConsumeOIDCAssertionParams) (int64, error)

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

func (*Queries) CountTeamOwners

func (q *Queries) CountTeamOwners(ctx context.Context, teamID string) (int64, error)

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 (q *Queries) DNSAuthorityReleaseReady(ctx context.Context, arg DNSAuthorityReleaseReadyParams) (pgtype.Bool, error)

func (*Queries) DeleteControlTLSCacheEntry

func (q *Queries) DeleteControlTLSCacheEntry(ctx context.Context, arg DeleteControlTLSCacheEntryParams) error

func (*Queries) DeleteExpiredOIDCAssertionExchanges

func (q *Queries) DeleteExpiredOIDCAssertionExchanges(ctx context.Context, now pgtype.Timestamptz) error

func (*Queries) DeleteRoute

func (q *Queries) DeleteRoute(ctx context.Context, arg DeleteRouteParams) (int64, 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) EnsureIngressUsageRun

func (q *Queries) EnsureIngressUsageRun(ctx context.Context, arg EnsureIngressUsageRunParams) (ControlIngressUsageRun, error)

func (*Queries) ExpireTeamInvitations

func (q *Queries) ExpireTeamInvitations(ctx context.Context, arg ExpireTeamInvitationsParams) ([]string, error)

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 (q *Queries) FindInvitationTeamByTokenDigest(ctx context.Context, tokenDigest []byte) (string, error)

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

func (*Queries) GetACMEOrder

func (q *Queries) GetACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)

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) GetAdminRuntimeCounts

func (q *Queries) GetAdminRuntimeCounts(ctx context.Context, now pgtype.Timestamptz) (GetAdminRuntimeCountsRow, error)

func (*Queries) GetControlSessionByAccessID

func (q *Queries) GetControlSessionByAccessID(ctx context.Context, accessTokenID string) (GetControlSessionByAccessIDRow, error)

func (*Queries) GetControlTLSCacheEntry

func (q *Queries) GetControlTLSCacheEntry(ctx context.Context, arg GetControlTLSCacheEntryParams) (GetControlTLSCacheEntryRow, error)

func (*Queries) GetDNSAuthority

func (q *Queries) GetDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)

func (*Queries) GetDNSAuthorityByReleaseIdempotency

func (q *Queries) GetDNSAuthorityByReleaseIdempotency(ctx context.Context, releaseIdempotencyKey pgtype.Text) (ControlDnsAuthority, error)

func (*Queries) GetDNSChallengeContext

func (q *Queries) GetDNSChallengeContext(ctx context.Context, arg GetDNSChallengeContextParams) (GetDNSChallengeContextRow, error)

func (*Queries) GetIdentityContextIdentity

func (q *Queries) GetIdentityContextIdentity(ctx context.Context, identityID string) (GetIdentityContextIdentityRow, error)

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) GetOpenRouteSession

func (q *Queries) GetOpenRouteSession(ctx context.Context, routeID string) (ControlRouteSession, error)

func (*Queries) GetPublisherConnectionForClaim

func (q *Queries) GetPublisherConnectionForClaim(ctx context.Context, publisherConnectionID string) (ControlRouteSessionConnection, error)

func (*Queries) GetRelayDNSChallengeContext

func (q *Queries) GetRelayDNSChallengeContext(ctx context.Context, orderID string) (GetRelayDNSChallengeContextRow, error)

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) GetRouteCreationContext

func (q *Queries) GetRouteCreationContext(ctx context.Context, arg GetRouteCreationContextParams) (GetRouteCreationContextRow, error)

func (*Queries) GetRouteSession

func (q *Queries) GetRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)

func (*Queries) GetRouteSessionByIdempotency

func (q *Queries) GetRouteSessionByIdempotency(ctx context.Context, arg GetRouteSessionByIdempotencyParams) (ControlRouteSession, error)

func (*Queries) GetRouteSessionByTokenID

func (q *Queries) GetRouteSessionByTokenID(ctx context.Context, sessionTokenID string) (ControlRouteSession, error)

func (*Queries) GetRouteUsageBucketByID

func (q *Queries) GetRouteUsageBucketByID(ctx context.Context, bucketID int64) (ControlRouteUsageBucket, error)

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 (*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 (q *Queries) InsertIngressRoutingTableEvent(ctx context.Context, arg InsertIngressRoutingTableEventParams) (int64, 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) 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 (q *Queries) LatestIngressRoutingEntryRevision(ctx context.Context, arg LatestIngressRoutingEntryRevisionParams) (int64, error)

func (*Queries) ListACMEOrderAuthorizations

func (q *Queries) ListACMEOrderAuthorizations(ctx context.Context, issuanceID string) ([]ControlAcmeAuthorization, error)

func (*Queries) ListAdminRelayLeases

func (q *Queries) ListAdminRelayLeases(ctx context.Context, arg ListAdminRelayLeasesParams) ([]ListAdminRelayLeasesRow, error)

func (*Queries) ListCurrentDomainNames

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

func (*Queries) ListDNSChallengePresentations

func (q *Queries) ListDNSChallengePresentations(ctx context.Context, baseIdentifier string) ([]ListDNSChallengePresentationsRow, error)

func (*Queries) ListIdentityMembershipContexts

func (q *Queries) ListIdentityMembershipContexts(ctx context.Context, identityID string) ([]ListIdentityMembershipContextsRow, error)

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 (q *Queries) ListIdentityTeams(ctx context.Context, identityID string) ([]ListIdentityTeamsRow, 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 (q *Queries) ListRelayDNSChallengePresentations(ctx context.Context, tlsServerName string) ([]ListRelayDNSChallengePresentationsRow, error)

func (*Queries) ListRelayServiceAssignmentTotals

func (q *Queries) ListRelayServiceAssignmentTotals(ctx context.Context) ([]ControlRelayServiceAssignmentTotal, error)

func (*Queries) ListRouteSessionConnections

func (q *Queries) ListRouteSessionConnections(ctx context.Context, routeSessionID string) ([]ControlRouteSessionConnection, error)

func (*Queries) ListTeamInvitations

func (q *Queries) ListTeamInvitations(ctx context.Context, teamID string) ([]ListTeamInvitationsRow, error)

func (*Queries) ListTeamMemberNamespaceLabels

func (q *Queries) ListTeamMemberNamespaceLabels(ctx context.Context, teamID string) ([]ListTeamMemberNamespaceLabelsRow, error)

func (*Queries) ListTeamMembershipContexts

func (q *Queries) ListTeamMembershipContexts(ctx context.Context, teamID string) ([]ListTeamMembershipContextsRow, error)

func (*Queries) LockACMEOrder

func (q *Queries) LockACMEOrder(ctx context.Context, issuanceID string) (ControlAcmeOrder, error)

func (*Queries) LockACMEOrderForInstall

func (q *Queries) LockACMEOrderForInstall(ctx context.Context, arg LockACMEOrderForInstallParams) (ControlAcmeOrder, error)

func (*Queries) LockCertificateIssuanceControl

func (q *Queries) LockCertificateIssuanceControl(ctx context.Context) (bool, error)

func (*Queries) LockControlSessionByRefreshID

func (q *Queries) LockControlSessionByRefreshID(ctx context.Context, refreshTokenID string) (LockControlSessionByRefreshIDRow, error)

func (*Queries) LockDNSAuthority

func (q *Queries) LockDNSAuthority(ctx context.Context, authorityReference string) (ControlDnsAuthority, error)

func (*Queries) LockDNSAuthorityLocalDomain

func (q *Queries) LockDNSAuthorityLocalDomain(ctx context.Context, authorityReference pgtype.Text) error

func (*Queries) LockDNSAuthorityLocalTeam

func (q *Queries) LockDNSAuthorityLocalTeam(ctx context.Context, authorityReference pgtype.Text) error

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 (q *Queries) LockHostedTeamRoutes(ctx context.Context, teamID string) ([]ControlRoute, error)

func (*Queries) LockIdentityBootstrap

func (q *Queries) LockIdentityBootstrap(ctx context.Context) error

func (*Queries) LockIdentityForTeamCreation

func (q *Queries) LockIdentityForTeamCreation(ctx context.Context, identityID string) (string, error)

func (*Queries) LockIngressLease

func (q *Queries) LockIngressLease(ctx context.Context, arg LockIngressLeaseParams) (ControlIngressLease, error)

func (*Queries) LockIngressRoutingTableClock

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

func (*Queries) LockInvalidReadyPublisherConnections

func (q *Queries) LockInvalidReadyPublisherConnections(ctx context.Context, now pgtype.Timestamptz) ([]ControlRouteSessionConnection, error)

func (*Queries) LockLocalRouteTeamForMutation

func (q *Queries) LockLocalRouteTeamForMutation(ctx context.Context, routeID string) (string, error)

func (*Queries) LockLocalTeamForMutation

func (q *Queries) LockLocalTeamForMutation(ctx context.Context, teamID 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.

func (*Queries) LockLocalTeamForSession

func (q *Queries) LockLocalTeamForSession(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.

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

func (*Queries) LockRelayServicesForPlacement

func (q *Queries) LockRelayServicesForPlacement(ctx context.Context) ([]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.

func (*Queries) LockRouteCreationControl

func (q *Queries) LockRouteCreationControl(ctx context.Context) (bool, error)

func (*Queries) LockRouteCreator

func (q *Queries) LockRouteCreator(ctx context.Context, identityID string) (string, error)

Serialize creators without blocking session and audit foreign-key checks.

func (*Queries) LockRouteForSession

func (q *Queries) LockRouteForSession(ctx context.Context, routeID string) (ControlRoute, 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.

func (*Queries) LockRouteForUsage

func (q *Queries) LockRouteForUsage(ctx context.Context, routeID string) (string, error)

func (*Queries) LockRouteRecoveryEpisode

func (q *Queries) LockRouteRecoveryEpisode(ctx context.Context, recoveryEpisodeID int64) (ControlRouteRecoveryEpisode, error)

func (*Queries) LockRouteSession

func (q *Queries) LockRouteSession(ctx context.Context, routeSessionID string) (ControlRouteSession, error)

func (*Queries) LockRouteSessionCreationControl

func (q *Queries) LockRouteSessionCreationControl(ctx context.Context) (bool, error)

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

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

func (*Queries) MarkACMEOrderInstalled

func (q *Queries) MarkACMEOrderInstalled(ctx context.Context, arg MarkACMEOrderInstalledParams) (ControlAcmeOrder, error)

func (*Queries) MarkClaimedDomainReleasing

func (q *Queries) MarkClaimedDomainReleasing(ctx context.Context, arg MarkClaimedDomainReleasingParams) (int64, error)

func (*Queries) MarkDNSAuthorityReleasing

func (q *Queries) MarkDNSAuthorityReleasing(ctx context.Context, arg MarkDNSAuthorityReleasingParams) (int64, error)

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 (q *Queries) MarkInvitationExpired(ctx context.Context, invitationID string) (int64, 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 (q *Queries) ObserveAuthorityRevision(ctx context.Context, arg ObserveAuthorityRevisionParams) (int64, 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 (q *Queries) QuarantineMemberSlug(ctx context.Context, arg QuarantineMemberSlugParams) (int64, error)

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

func (*Queries) RemoveTeamMembership

func (q *Queries) RemoveTeamMembership(ctx context.Context, arg RemoveTeamMembershipParams) (int64, error)

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

func (*Queries) ReserveManagedLabel

func (q *Queries) ReserveManagedLabel(ctx context.Context, arg ReserveManagedLabelParams) (string, error)

func (*Queries) RetryRouteUsageDelivery

func (q *Queries) RetryRouteUsageDelivery(ctx context.Context, arg RetryRouteUsageDeliveryParams) (ControlRouteUsageDelivery, error)

func (*Queries) RevokeControlSession

func (q *Queries) RevokeControlSession(ctx context.Context, arg RevokeControlSessionParams) (int64, error)

func (*Queries) RevokeTeamInvitation

func (q *Queries) RevokeTeamInvitation(ctx context.Context, arg RevokeTeamInvitationParams) (int64, error)

func (*Queries) RotateACMEAccountKey

func (q *Queries) RotateACMEAccountKey(ctx context.Context, arg RotateACMEAccountKeyParams) error

func (*Queries) RotateControlSessionCredentials

func (q *Queries) RotateControlSessionCredentials(ctx context.Context, arg RotateControlSessionCredentialsParams) (int64, error)

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

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

func (*Queries) StoreRelayTransportCertificate

func (q *Queries) StoreRelayTransportCertificate(ctx context.Context, arg StoreRelayTransportCertificateParams) (ControlRelayService, error)

func (*Queries) SuspendAuthorityRoute

func (q *Queries) SuspendAuthorityRoute(ctx context.Context, arg SuspendAuthorityRouteParams) (int64, error)

func (*Queries) TeamMembershipIdentityExists

func (q *Queries) TeamMembershipIdentityExists(ctx context.Context, arg TeamMembershipIdentityExistsParams) (bool, error)

func (*Queries) TryLockIngressRoutingHistoryCleanup

func (q *Queries) TryLockIngressRoutingHistoryCleanup(ctx context.Context) (bool, error)

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) UpdateMembershipRole

func (q *Queries) UpdateMembershipRole(ctx context.Context, arg UpdateMembershipRoleParams) (int64, error)

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) 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.

func (*Queries) WithTx

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

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 RemoveTeamMembershipParams

type RemoveTeamMembershipParams struct {
	AuthorityRevision   int64
	RemovedAt           pgtype.Timestamptz
	RemovedByIdentityID pgtype.Text
	MembershipID        string
	TeamID              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 ReserveInvitedMemberSlugParams

type ReserveInvitedMemberSlugParams struct {
	ID                   string
	TeamID               string
	MemberSlug           string
	ReservedByIdentityID pgtype.Text
	CreatedAt            pgtype.Timestamptz
}

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 RotateACMEAccountKeyParams

type RotateACMEAccountKeyParams struct {
	AccountKeyCiphertext   []byte
	AccountKeyStorageKeyID string
	UpdatedAt              pgtype.Timestamptz
	AccountID              string
	PreviousKeyID          string
	PreviousCiphertext     []byte
}

type RotateControlSessionCredentialsParams

type RotateControlSessionCredentialsParams struct {
	AccessTokenID      string
	AccessTokenDigest  []byte
	AccessExpiresAt    pgtype.Timestamptz
	RefreshTokenID     string
	RefreshTokenDigest []byte
	RefreshedAt        pgtype.Timestamptz
	ID                 string
}

type RotateControlSessionRetrySecretParams

type RotateControlSessionRetrySecretParams struct {
	RetrySecretCiphertext   []byte
	RetrySecretStorageKeyID string
	ID                      string
	PreviousKeyID           string
	PreviousCiphertext      []byte
}

type RotateControlTLSCacheEntryParams

type RotateControlTLSCacheEntryParams struct {
	CacheCiphertext    []byte
	CacheStorageKeyID  string
	UpdatedAt          pgtype.Timestamptz
	DirectoryUrl       string
	CacheKey           string
	PreviousKeyID      string
	PreviousCiphertext []byte
}

type RotateExternalRetryMasterKeyParams

type RotateExternalRetryMasterKeyParams struct {
	ExternalRetryMasterKeyCiphertext   []byte
	ExternalRetryMasterKeyStorageKeyID string
	PreviousKeyID                      string
	PreviousCiphertext                 []byte
}

type RotateRelayCertificateOrderPrivateKeyParams

type RotateRelayCertificateOrderPrivateKeyParams struct {
	PrivateKeyCiphertext   []byte
	PrivateKeyStorageKeyID string
	UpdatedAt              pgtype.Timestamptz
	OrderID                string
	PreviousKeyID          string
	PreviousCiphertext     []byte
}

type RotateRelayServicePrivateKeyParams

type RotateRelayServicePrivateKeyParams struct {
	TransportPrivateKeyCiphertext   []byte
	TransportPrivateKeyStorageKeyID pgtype.Text
	UpdatedAt                       pgtype.Timestamptz
	RelayServiceID                  string
	PreviousKeyID                   pgtype.Text
	PreviousCiphertext              []byte
}

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 SaveDNSAuthorityWorkParams

type SaveDNSAuthorityWorkParams struct {
	ProviderZoneID       pgtype.Text
	State                string
	Nameservers          []string
	AvailableAt          pgtype.Timestamptz
	LastError            pgtype.Text
	CompletedAt          pgtype.Timestamptz
	AuthorityReference   string
	WorkOwner            pgtype.Text
	WorkEpoch            int64
	ExpectedWorkRevision int64
}

type SaveDNSRouteWorkParams

type SaveDNSRouteWorkParams struct {
	DnsState            string
	DnsAvailableAt      pgtype.Timestamptz
	DnsLastError        pgtype.Text
	CompletedAt         pgtype.Timestamptz
	RouteID             string
	WorkOwner           pgtype.Text
	WorkEpoch           int64
	ExpectedDnsRevision int64
}

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 TeamMembershipIdentityExistsParams

type TeamMembershipIdentityExistsParams struct {
	TeamID     string
	IdentityID string
}

type UpdateACMEAccountRegistrationParams

type UpdateACMEAccountRegistrationParams struct {
	ContactEmail     string
	AccountUrl       pgtype.Text
	AcceptedTermsUrl pgtype.Text
	UpdatedAt        pgtype.Timestamptz
	AccountID        string
}

type UpdateLocalDomainForDNSAuthorityParams

type UpdateLocalDomainForDNSAuthorityParams struct {
	State              string
	UpdatedAt          pgtype.Timestamptz
	AuthorityReference pgtype.Text
}

type UpdateLocalDomainForDNSAuthorityRow

type UpdateLocalDomainForDNSAuthorityRow struct {
	ID                   string
	TeamID               pgtype.Text
	MakeDefaultWhenReady bool
}

type UpdateMembershipRoleParams

type UpdateMembershipRoleParams struct {
	Role              string
	AuthorityRevision int64
	UpdatedAt         pgtype.Timestamptz
	MembershipID      string
	TeamID            string
}

type UpdateOIDCIdentityParams

type UpdateOIDCIdentityParams struct {
	DisplayName     string
	NormalizedEmail pgtype.Text
	EmailVerified   bool
	UpdatedAt       pgtype.Timestamptz
	ID              string
}

type UpdateRouteParams

type UpdateRouteParams struct {
	Target                   string
	PolicyRevision           int64
	IpPolicy                 string
	AllowedIpPrefixes        []netip.Prefix
	UpdatedAt                pgtype.Timestamptz
	RouteID                  string
	ExpectedMutationRevision int64
}

type UpdateRouteRecoveryHistogramParams

type UpdateRouteRecoveryHistogramParams struct {
	ObservedSeconds float64
	UpdatedAt       pgtype.Timestamptz
}

type WakeACMEOrderParams

type WakeACMEOrderParams struct {
	AvailableAt pgtype.Timestamptz
	IssuanceID  string
}

Jump to

Keyboard shortcuts

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