Files
member-console/internal/integration/querier.go
T
cgalo5758 dd3962990b Adopt entity keys and add invoice numbers
Replace the entity slugs on organizations, workspaces, resource pools,
and
plan ladders with nullable `key` columns and add keys to products,
prices,
and entitlement sets. Rename `providers.slug` to `provider` and add
partial
unique indexes for system and org role names.

Assign invoice numbers per billing account from a gapless transactional
counter; Stripe's number moves to the invoice mapping as an external
reference.

Seeds, fixtures, and the operator lookup address rows by key, and the
returning-login resync no longer blanks a display name when the IdP
sends
no `name` claim.
2026-08-29 20:12:04 -05:00

59 lines
3.1 KiB
Go

// Code generated by sqlc. DO NOT EDIT.
// versions:
// sqlc v1.29.0
package integration
import (
"context"
)
type Querier interface {
AddProviderOperation(ctx context.Context, arg AddProviderOperationParams) error
AddProviderState(ctx context.Context, arg AddProviderStateParams) error
// Operator overview "System" panel: the health of the integration delivery
// queue in one round trip.
//
// The three buckets mean different things to an operator and are therefore
// reported separately rather than summed:
// pending — enqueued, not yet attempted or waiting on next_attempt_at.
// A steady non-zero value is normal.
// failed — attempted and errored, still inside max_attempts, so the
// poller will retry. In-flight, not lost.
// dead_letter — exhausted its retries. Nothing will move this without an
// operator, so it is the only bucket that warrants an alarm.
//
// Enqueue-side writes go through integration.Enqueue (internal/integration/
// outbox.go); this is a read-only health probe over the same table.
CountOutboxByStatus(ctx context.Context) (CountOutboxByStatusRow, error)
DeleteConfigOverride(ctx context.Context, key string) (int64, error)
// Boot reconciliation: drop operations a provider no longer declares.
DeleteProviderOperationsNotIn(ctx context.Context, arg DeleteProviderOperationsNotInParams) error
// Boot reconciliation: drop states a provider no longer declares.
DeleteProviderStatesNotIn(ctx context.Context, arg DeleteProviderStatesNotInParams) error
GetProvider(ctx context.Context, provider string) (Provider, error)
ListAllProviderOperations(ctx context.Context) ([]ListAllProviderOperationsRow, error)
ListAllProviderStates(ctx context.Context) ([]ListAllProviderStatesRow, error)
ListConfigOverrides(ctx context.Context) ([]ConfigOverride, error)
// Platform-owned (unprefixed) resource keys, for the provider-key hygiene
// nesting check.
ListPlatformResourceKeys(ctx context.Context) ([]string, error)
ListProviderOperations(ctx context.Context, provider string) ([]string, error)
ListProviderStates(ctx context.Context, provider string) ([]string, error)
ListProviders(ctx context.Context) ([]Provider, error)
ListProvidersByKind(ctx context.Context, providerKind string) ([]Provider, error)
// Operational mutation (operator-editable), distinct from capability registration.
SetProviderStatus(ctx context.Context, arg SetProviderStatusParams) error
// Stamp provider ownership on a resource key (cross-schema write, enabled by the
// resource_keys.provider FK + this package's core_writer grant on the core
// schema). Returns rows affected so a manifest referencing a non-existent key
// can be detected at registration.
SetResourceKeyProvider(ctx context.Context, arg SetResourceKeyProviderParams) (int64, error)
UpsertConfigOverride(ctx context.Context, arg UpsertConfigOverrideParams) error
// Boot-time capability registration. On re-registration, capability fields
// (kind, display_name) are refreshed; operational `status` is preserved.
UpsertProvider(ctx context.Context, arg UpsertProviderParams) (Provider, error)
}
var _ Querier = (*Queries)(nil)