Define a rule using the clean function API - no manual DeductiveRule construction!

Define a rule using the clean function API - no manual DeductiveRule construction!

Canonical dag-cbor encoding, panicking if the rule has no encodable body. Use on the storage path where the rule is known to be storable (concept/form

Encodes a base key and rank into a fixed-width [`SpecKey`].

Get the normalized endpoint URL.

Returns the environment of already-bound variables for this step.

Estimates the cost of a fact query given what's known about the triple (the, of, is). # Parameters - `the`: Is the attribute known? - `of`: Is the en

Estimate the cost of this concept application given the current environment. A concept is essentially a join over N fact lookups (one per attribute).

Iterate `(cid, arc)` pairs in root-to-leaf order, cloning the inner `Arc`s. For constructing a delegation lookup table — most commonly to hand to `In

Export the database in CSV format. Each row will consist of the data from a single [`Artifact`], laid out in {attribute, entity, value, cause} order.

Extract the parameter pattern and address type from an integration test function so that associated service can be provisioned and test could be execu

Extract Address and Provider types from the return type. Expected return type: `anyhow::Result<Service<Address, Provider>>`

Extract the settings pattern and type from the function's first parameter.

Returns facts data for the specified range of indices. This method triggers loading of facts if they're not yet cached and returns a vector of Promis

Searches for an entry with the given key in this segment. Returns `Ok(None)` if this is an index node or if the key is not found.

Build a remote-site version of this command. The returned [`ForkPublish`] can be executed against an environment that knows how to reach the remote s

Allocate a fresh anonymous variable type with constraint [`Primitive::ALL`].

Deserializes an entity from UTF-8 format for CSV import.

Generate deterministic test data consisting of facts that reference a specified number of [`Entity`]s.

Generate an integration test with service provisioning. Given: ```rs #[dialog_common::test] async fn it_connects(server: ServerAddress) -> anyhow::Re

Generate provider implementation from the annotated function. Given a function like: ```rs use serde::{Deserialize, Serialize}; #[dialog_common::pro

Given a `source` function it generates a unit test by adding attributes for both wasm and native runtimes. ```rs #[dialog_common::test] fn it_works()

Get a map of total operations (reads + writes) per key.

Retrieves a value from the cache, or fetches it using the provided function.

The planned [`Conjunction`] for `rule` under `adornment`, computing and caching it on a miss. `plan` is only called on a miss, so the caller can build

Get only the write operations in the order they occurred.

Matches a string against a simple glob pattern. `*` matches zero or more characters, `?` matches exactly one character. `\` escapes the next characte

Polls for and processes terminal events with a timeout. This method checks for keyboard events with a 100ms timeout, ensuring the UI remains responsi

Handles keyboard input events and updates application state accordingly. # Key Bindings `q` - Quit the application `f/F` - Switch to Facts tab `t/T`

Whether the descended child has any sibling to its right. Cheap: a length comparison, no decoding.

Compute blake3 hash of this attribute descriptor Returns a 32-byte blake3 hash of the CBOR-encoded descriptor

A stable identifier for this address as a URI.

Import data from a CSV laid out like the one produced by [`Artifacts::export`]

Import raw public key bytes as a WebCrypto `CryptoKey`.

Generate the integration logic function containing the actual test body. This function is called by the native test or wasm test. Gated behind `integ

Pairwise intersection of two [`Composite`] shapes. Two products intersect iff they share the same set of field names; two variants iff they share the

Structurally intersect two sets of [`Composite`] shapes. For each `Composite::Product` in `a`, look for a same-field-set `Composite::Product` in `b`

Consume the secret and return the raw bytes.

Resolves this node into a [`Link`] referencing its serialized form, recording any newly created nodes in `delta`. A [`Node::Persistent`] already is a

Unwrap into the scalar lookup, dropping the left-join. The planner uses this to demote an optional lookup whose value variable was narrowed to non-opt

Create an invocable capability directly on this subject.

Convert an IPLD value to a Promised value (for UCAN invocation arguments).

Whether this environment targets Cloudflare R2.

Returns an iterator over all name-parameter pairs in this binding set.

Get an iterator over the statements

Returns an iterator over the cell names in this collection.

Get all keys that have been read.

Get all keys that have been written.

The lexical form of a value, if its kind has one: the string content, the symbol's `namespace/predicate` name, or the entity's URI. This is the form p

Lifts the left spine of the subtree immediately to the right of `path`, so a boundary delete at the end of the leaf reached by `path` can fuse the orp

Load the remote branch (errors if the local cache has no revision).

Reads a node from storage by hash.

Returns the `LockManager` from `navigator.locks`.

Looks up a tree node by its hash, loading it in the background. This method spawns a background task to load the specified node and send it via the c

Returns the path to the lock file for a given key. Lock files are used to coordinate concurrent access during CAS operations. The lock path is derive

Returns a unique temporary file path for atomic writes. The temp path includes the content hash to ensure uniqueness across concurrent writers. This

Rule: a MatchingNote is a Note whose title matches "Hello*"

Bulk insert another [ZSet] into this one (mutating it in-place). Multiplicities will be the sum of the values in both sets

Build a merge revision combining `self` with `upstream`. A merge is a forced sync boundary: the new `period` jumps past both sides and `moment` reset

The schema-metadata [`Changes`] for this layer: every branch's [`BranchMetadata`](super::metadata::BranchMetadata) plus a single [`Session`] (with one

Returns the attribute name.

Rewrite the planner's premises so each variable term carries its rule-level inferred kind. The type environment is *taken*, not recomputed: when the

The narrowing steps recorded during inference, in premise order: which premise constrained which variable, from what to what.

Generate the native integration test. Runs with `cargo test --features integration-tests`. Starts service, runs test, stops service - all in same pro

Filter a selection by a negated plan: keep each incoming match only when evaluating `inner` against it yields no rows.

A shared handle to this branch's node cache, for seeding a read tree.

Rule: a NonDraftNote is a Note whose title does NOT match "Draft:*"