catalog

type Catalog interface {
	// Get returns a tenant's entry, or CodeNotFound.
	Get(ctx context.Context, tenantID string) (Entry, error)

	// Put writes an entry with optimistic concurrency on UpdatedAt:
	// a zero UpdatedAt creates (CodeAlreadyExists if present); a non-zero
	// UpdatedAt updates iff it matches the stored token
	// (CodeVersionConflict otherwise). Invalid entries are CodeInvalidInput.
	Put(ctx context.Context, e Entry) (Entry, error)

	// List pages through every entry in stable (tenant id) order.
	List(ctx context.Context, cursor Cursor, limit int) ([]Entry, Cursor, error)
}

type Cursor string

type Entry struct {
	TenantID  string `json:"tenantId"`
	ClusterID string `json:"clusterId"`
	Database  string `json:"database"`
	State     State  `json:"state"`
	// Version is the fabriq migration version the tenant database was last
	// observed at (grove migration versions, e.g. "202607030030"). The
	// router fails closed when it is below the binary's floor.
	Version string `json:"version"`
	// Schema is the tenant's Postgres schema in schema-per-tenant
	// consolidation mode (e.g. "tenant_acme"); empty in database mode. When
	// set it selects the tenant's namespace via search_path within the
	// shared consolidation database named by Database.
	Schema string `json:"schema"`
	// UpdatedAt is the optimistic-concurrency token: Put succeeds only when
	// it matches the stored row (zero UpdatedAt = create, must not exist).
	// The store stamps a fresh UpdatedAt on every successful write.
	UpdatedAt time.Time `json:"updatedAt"`
	// FromReplica is a transient routing-provenance flag: true when this entry
	// was served by a read replica during a primary outage (set only by
	// Failover, never persisted or serialized). The directory treats any answer
	// it derives from a replica-sourced entry — a version-gate or not-active
	// CodeUnavailable — as degraded (non-cacheable), because a lagged replica
	// could report a stale-old version or a superseded state.
	FromReplica bool `json:"-"`
}

type Failover struct {
	// contains filtered or unexported fields
}

type State string