Versions in this module Expand all Collapse all v1 v1.1.0 Oct 12, 2026 v1.0.0 Sep 19, 2026 Changes in this version + const DefaultStorePath + func NewRuntimeHandler(rt *Runtime, auth channel.Authenticator) http.Handler + func RunHTTPServerWithBindings(ctx context.Context, addr, storePath string, loaded channel.LoadedBindings, ...) error + func ServeRuntime(ctx context.Context, addr string, rt *Runtime, auth channel.Authenticator, ...) error + type Bridge struct + func NewBridge(newID, now func() string) *Bridge + func (br *Bridge) Stamp(b ResolvedBinding, dispatchedOn projection.Projection, trigger contract.Event, ...) (contract.Event, error) + type ControlServer struct + func New(s *store.Store, k *kernel.Kernel, rules rule.RuleSet, ...) *ControlServer + func (cs *ControlServer) Ingest(principal contract.ActorID, env contract.ObservationEnvelope) (int64, bool, error) + func (cs *ControlServer) PullProjection(principal contract.ActorID, sub contract.Subscription) (projection.Projection, error) + func (cs *ControlServer) Tick() ([]contract.Decision, error) + type ResolvedBinding struct + Actor contract.ActorID + Emits string + type Runtime struct + func OpenRuntime(storePath string, cfg RuntimeConfig) (*Runtime, error) + func (r *Runtime) API() channel.ServerAPI + func (r *Runtime) Close() error + func (r *Runtime) DecisionLedger() ([]contract.Decision, error) + func (r *Runtime) DrainOutbox() ([]contract.ResourceRef, int, error) + func (r *Runtime) GetCursor(name string) int64 + func (r *Runtime) IngestTrusted(principal contract.ActorID, env contract.ObservationEnvelope) (int64, bool, error) + func (r *Runtime) MarkSyncCommitStatus(originReplicaID, localDecisionID string, ref contract.ResourceRef, ...) error + func (r *Runtime) PendingEvents(afterSeq int64) ([]contract.Event, error) + func (r *Runtime) PendingSyncCommits() ([]contract.LocalCommit, error) + func (r *Runtime) ReplicaID() (string, error) + func (r *Runtime) Resource(ref contract.ResourceRef) (contract.Version, map[string]any, error) + func (r *Runtime) SetCursor(name string, seq int64) error + func (r *Runtime) Status(principal contract.ActorID) (contract.ChannelStatus, error) + func (r *Runtime) StorePath() string + func (r *Runtime) SyncPull(principal contract.ActorID, req contract.SyncPullRequest) (contract.SyncPullResponse, error) + func (r *Runtime) SyncPush(principal contract.ActorID, req contract.SyncPushRequest) (contract.SyncPushResponse, error) + func (r *Runtime) SyncStatus(principal contract.ActorID) (contract.SyncStatusResponse, error) + func (r *Runtime) Tick() ([]contract.Decision, error) + type RuntimeConfig struct + Authority kernel.AuthorityRules + Bindings []channel.ChannelBinding + Modes contract.Modes + NewID func() string + Now func() string + Rules rule.RuleSet + SchemaGuard kernel.SchemaGuard + Subs map[contract.ActorID]contract.Subscription + SyncableKinds []contract.ResourceKind
Go to main page