cgalo5758
56a743fb32
Back the operator landing surface with live deployment counts and integration health signals, one sqlc query per owning module. CountDeliveringGrants joins core.pool_provisions rather than filtering grants.status: grants.status is an issuance ledger recording what was written down and whether it was later revoked, not whether service is flowing. The current-delivery fact lives on pool_provisions.status, and a grant can sit at status='active' with every provision ended. Counting the ledger alone would overstate delivery. CountClaimsByLifecycle and CountOutboxByStatus each return their buckets in a single row, so the halves that get printed together are read at the same instant and the landing surface pays one round trip rather than one per bucket.
58 lines
3.1 KiB
Go
58 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, 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)
|