Set the earliest time the claim is valid.

Get the 'of' (entity) term.

Computes the rank of a node from its hash using a geometric distribution.

Resolve this term against a match. If the term is a variable bound to a [`Binding::Present`](crate::Binding::Present) value, returns a constant term w

The site connection info.

The subject.

Verify a signature using WebCrypto.

Get the cardinality of this query.

Create a typed cell within this remote's space.

The composite part of this type, or `None` if the type has only a primitive part.

Read the cached content.

Returns a reference to the underlying hash.

Merge another layer in: union the branches, fold the other layer's changes via its `Statement` impl. Accepts anything convertible into a `QueryLayer`

Get the raw byte representation of the [`Entity`] as it should be formatted for use in an index key.

Construct the lowest possible [`EntityKey`] (all bits are zero)

Execute the fetch operation, returning the upstream revision. Returns `None` if the upstream has no revision yet.

Execute the commit, returning the newly-published [`Revision`]. Load the branch's current search tree, apply every change in the stream to the three

Update the cache with a new edition.

The [`Value`] (or object) that selected [`Artifact`]s should refer to.

The full remote address (site + subject).

Attenuate this capability with another policy/attenuation.

The [`Attribute`] (or predicate) used in any selected [`Artifact`]s

Compute the checksum of the given data using this algorithm.

Compute the logical AND of `left` and `right`

Returns the expected value type, or `None` if any type is accepted.

The [`Entity`] (or subject) that selected [`Artifact`]s should refer to

Evaluate: row-local `.map`, for each input row, decide whether to bind `is` from `source` or from `fallback`. Never consumes the input stream into a b

Flushes a delta's pending nodes into `storage`, so the persisted tree's root becomes reachable from storage alone. Used by the canonical-form tests, w

Returns `true` iff this set has no members.

* Open an artifacts store * @param address The store address configuration * @returns A task that resolves to a Querier and Transactor interface

Helper: build a person concept predicate with name and age attributes.

Extract a policy or ability from this chain.

Write a block to the remote archive.

The wrapped scalar lookup.

Redeem this authorization for a presigned URL permit. With a credential, signs the captured request via SigV4. Without, builds an unsigned request.

Retract a claim from this transaction.

Retract a claim.

Same shape but reading a different person attribute — a *distinct rule body, so a distinct content-addressed identity.

Store a delegation's certificates as files for future lookups.

* Select artifacts that match the given selector * @param selector The selection criteria * @returns A task that resolves to matching artifacts

Spawns a future on the executor and returns its output. This function schedules the given future to run on the async executor and returns a future th

Create a deterministic test signer from a seed.

Get the 'the' (attribute) term.

Interprets this node as an index, erroring if it is a segment. Mirrors [`PersistentNode::as_index`](crate::PersistentNode::as_index).

Authorize a UCAN container. # Arguments `container` - CBOR-encoded UCAN container following the [UCAN Container spec](https://github.com/ucan-wg/con

Get a reference to the interior `StorageBackend`

Builds and validates the concept instance.

Decode a DAG-JSON bytes value `{"/": {"bytes": "..."}}` into raw bytes using `serde_ipld_dagjson`.

Evaluates the constraint against the current selection of matches. This method processes each match in the input selection and: - **Filters** matches

Execute the select against the given content-addressed store. Unlike [`perform`](Self::perform) this does not pick a store for you — useful when call

Returns a reference to the field with the given name, if present.

Returns a reference to the cell with the given name, if it exists.

The index catalog for tree node storage.

Iterate the [`ValueType`] members in discriminant order. Does **not** yield the `Nothing` atom.

Returns an iterator over field names, sorted.

Construct the highest possible [`EntityKey`] (all bits are one)

Set the [`Entity`] field (the subject) of the [`ArtifactSelector`]

Total reads (including repeats) recorded since the last [`clear`]. [`clear`]: ReadJournal::clear

Marks this cell as required, returning `self` for chaining.

Reset the root of the database to `revision_hash` if provided, or else reset to the stored root if available, or else to an empty database.

Stage a query against this transaction's view. Call [`perform`](TransactionSelectQuery::perform) to execute.

The signing credential.

Select a site credential by address identifier.

Queues a future to be executed when [`join`](Self::join) is called. The future must return `Result<(), DialogAsyncError>`. All queued futures will be

Verify only the signature of this invocation using a resolver. The resolver resolves the issuer DID to a verifier, then verifies the signature. # Er

Acquire rules for the given concept. Creates the default rule from the predicate's attributes on first access, so this always returns a ConceptRules r