sql

type Backups struct {
	Engines *Engines
	Master  []byte
	Client  *http.Client // nil ⇒ a node client with no timeout, bounded by each call's context; share one
}

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

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

type FacadeDeps struct {
	Resolver    Resolver
	Authorizer  auth.Authorizer
	Engines     *Engines
	Master      []byte
	HTTPClient  *http.Client  // nil ⇒ a node client bounded by CallTimeout
	CallTimeout time.Duration // 0 ⇒ DefaultCallTimeout
	Logger      *slog.Logger
}

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

type FeedDeps struct {
	Store         store.Store
	Publisher     eventing.Publisher
	Watermarks    Watermarks
	Master        []byte
	Hold          hold.Gate          // nil ⇒ never held
	NamespaceHold hold.NamespaceGate // nil ⇒ no namespace held
	Logger        *slog.Logger
}

type MetaReader interface {
	Get(ctx context.Context, gvk v1.GroupVersionKind, ns v1.NamespaceName, name v1.ObjectName) (v1.Object, error)
}

type Prober struct {
	Engines *Engines
	Master  []byte
	Volumes provider.Volumes
	Client  *http.Client // nil ⇒ a node client with a 5 s timeout
}

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

type ReconcilerDeps struct {
	Store             store.Store
	Provider          provider.Runtime // OwnerKind SQLDatabase; must implement provider.Volumes
	Engines           *Engines
	Master            []byte
	ImageFor          func(runtime string) string
	Hold              hold.Gate // nil ⇒ never held
	Logger            *slog.Logger
	SupervisionPeriod time.Duration
	// ChangeFeedURL is the endpoint each engine posts its changes to (ADR-0235 Decision 1); nil ⇒ no change feed.
	ChangeFeedURL func(ns v1.NamespaceName, name v1.ObjectName) string
	// Watermarks are the change feed's, dropped with a deleted database; nil ⇒ none.
	Watermarks Watermarks
	// DurableStorage is engine storage that outlives a daemon start: only then does a missing directory mean lost
	// data (DataMissing). False with no storage root or with storage.mode memory.
	DurableStorage bool
}

type Resolver interface {
	Resolve(ctx context.Context, ns v1.NamespaceName, fn v1.ObjectName, alias string) (v1.ObjectName, error)
}

type Watermarks interface {
	Get(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName, epoch string) (uint64, error)
	Set(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName, epoch string, index uint64) error
	Delete(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName) error
}