persistence

type Backend interface {
	// Probe verifies the datastore is reachable.
	Probe(ctx context.Context) error
	// SchemaVersion returns the current schema (or index-template) version. An
	// empty string means no schema is present yet.
	SchemaVersion(ctx context.Context) (string, error)
	// EnsureSchema applies schema inline when the backend manages schema itself
	// (Elasticsearch index templates). It returns inline=true when it handled
	// the schema; Job-based backends (SQL, Cassandra) return inline=false and do
	// nothing, leaving Job orchestration to the caller.
	EnsureSchema(ctx context.Context, minVersion string) (inline bool, err error)
	// Kind returns "sql", "cassandra", or "elasticsearch".
	Kind() string
}

type BackendFactory func(store temporalv1alpha1.DatastoreSpec, cred ResolvedCredential, dbName string) (Backend, error)

type Prober interface {
	// Probe opens a connection described by dsn, performs a trivial liveness
	// query, and returns an error if the datastore is unreachable.
	Probe(ctx context.Context, dsn string) error
}

type ResolvedCredential struct {
	// Password is a static password (password-auth).
	Password string
	// PasswordCommand is a command that emits a short-lived credential
	// (Temporal 1.31+ IAM auth). When set, Password is empty.
	PasswordCommand string
}

type SQLProber struct {
	// Timeout bounds each probe/query. Defaults to 5s when zero.
	Timeout time.Duration
}

type SchemaInspector interface {
	// CurrentSchemaVersion returns the current schema version recorded for the
	// given logical database. An empty string means no schema is present yet
	// (bootstrap required).
	CurrentSchemaVersion(ctx context.Context, dsn, dbName string) (string, error)
}

type SecretResolver struct {
	Client    client.Client
	Namespace string
}