// 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, slug 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 slug-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)