Versions in this module Expand all Collapse all v0 v0.13.0 Oct 13, 2026 Changes in this version + const DefaultCallTimeout + const ReasonEngineConvergeFailed + const ReasonEngineNotReady + const ReasonNoDirectory + const ReasonRestored + const Runtime + func ChangeToken(master []byte, ns v1.NamespaceName, name v1.ObjectName) string + func EnginePassword(master []byte, ns v1.NamespaceName, name v1.ObjectName) string + type Backups struct + Client *http.Client + Engines *Engines + Master []byte + func (b Backups) Empty(ctx context.Context, ns v1.NamespaceName, name v1.ObjectName) error + func (b Backups) HasTables(ctx context.Context, ns v1.NamespaceName, name v1.ObjectName) (bool, error) + func (b Backups) Load(ctx context.Context, ns v1.NamespaceName, name v1.ObjectName, file io.Reader) error + func (b Backups) Source(ctx context.Context, ns v1.NamespaceName, name v1.ObjectName) (io.ReadCloser, error) + type Engines struct + func NewEngines() *Engines + func (e *Engines) Address(ns v1.NamespaceName, name v1.ObjectName) (string, bool) + func (e *Engines) Delete(ns v1.NamespaceName, name v1.ObjectName) + func (e *Engines) Set(ns v1.NamespaceName, name v1.ObjectName, addr string) + type Facade struct + func NewFacade(d FacadeDeps) (*Facade, error) + func (f *Facade) CheckRead(ctx context.Context, ns v1.NamespaceName, fn v1.ObjectName, alias string) error + func (f *Facade) Execute(ctx context.Context, ns v1.NamespaceName, fn v1.ObjectName, binding string, ...) ([]local.ExecResult, error) + func (f *Facade) Query(ctx context.Context, ns v1.NamespaceName, fn v1.ObjectName, binding string, ...) ([]local.QueryResult, error) + type FacadeDeps struct + Authorizer auth.Authorizer + CallTimeout time.Duration + Engines *Engines + HTTPClient *http.Client + Logger *slog.Logger + Master []byte + Resolver Resolver + type Feed struct + func NewFeed(d FeedDeps) (*Feed, error) + func (f *Feed) Handler() http.Handler + func (f *Feed) Loaded() + func (f *Feed) Serve(ctx context.Context, host string, port int) error + func (f *Feed) URL(host string, port int) func(ns v1.NamespaceName, name v1.ObjectName) string + type FeedDeps struct + Hold hold.Gate + Logger *slog.Logger + Master []byte + NamespaceHold hold.NamespaceGate + Publisher eventing.Publisher + Store store.Store + Watermarks Watermarks + type MetaReader interface + Get func(ctx context.Context, gvk v1.GroupVersionKind, ns v1.NamespaceName, ...) (v1.Object, error) + type Prober struct + Client *http.Client + Engines *Engines + Master []byte + Volumes provider.Volumes + func (p Prober) HasTables(ctx context.Context, ns v1.NamespaceName, name v1.ObjectName) (bool, error) + type Reconciler struct + func NewReconciler(d ReconcilerDeps) (*Reconciler, error) + func (r *Reconciler) Backups() Backups + func (r *Reconciler) Engines() *Engines + func (r *Reconciler) MapFunction(ctx context.Context, obj v1.Object) []controller.Request + func (r *Reconciler) MapRestore(_ context.Context, obj v1.Object) []controller.Request + func (r *Reconciler) Orphans(ctx context.Context) ([]v1.ObjectRef, error) + func (r *Reconciler) Prober() Prober + func (r *Reconciler) ReclaimOrphans(ctx context.Context) error + func (r *Reconciler) Reconcile(ctx context.Context, req controller.Request) (controller.Result, error) + type ReconcilerDeps struct + ChangeFeedURL func(ns v1.NamespaceName, name v1.ObjectName) string + DurableStorage bool + Engines *Engines + Hold hold.Gate + ImageFor func(runtime string) string + Logger *slog.Logger + Master []byte + Provider provider.Runtime + Store store.Store + SupervisionPeriod time.Duration + Watermarks Watermarks + type Resolver interface + Resolve func(ctx context.Context, ns v1.NamespaceName, fn v1.ObjectName, alias string) (v1.ObjectName, error) + func NewResolver(r MetaReader) (Resolver, error) + type Watermarks interface + Delete func(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName) error + Get func(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName, epoch string) (uint64, error) + Set func(ctx context.Context, ns v1.NamespaceName, database v1.ObjectName, epoch string, ...) error
Go to main page