A literal string value

Adds a default value for the `column`.

Tracks the span of `body` under the label `abi_call`.

Helper to consume all bytes from a BytesSource

<summary> Create a <see cref="Uuid"/> `v4` from explicit random bytes. </summary> <remarks> This method assumes the provided bytes are already suffici

<summary> This sender guarantees that that messages are sent out in the order they are received. Our websocket library only allows us to await one sen

Return a handle that can cancel this task.

Ergonomic wrapper for `tokio::task::spawn_blocking(f).await`. If `f` panics, it will be bubbled up to the calling task.

Run a future to completion with std-hosted determinism guards installed. This wraps [`sim::Runtime::block_on`] and is the normal entry point for DST

Timestamp BSATN implementation

Given an `AlgebraicTypeUse`, add every referenced type’s generated header name (`"<FTypeName>.g.h"`) into `out` (a `HashSet` avoids dups).

Read the current module's [`Identity`].

Consumes the counter and returns the final count.

Map this config key to a different clap argument name. When fetching values the key that is defined should be used. Example: Key::new("module-path").f

Get a column of the `TableDef`.

Returns the schema for this table.

Hashes `slice` by converting to bytes first, as done in the standard library.

Returns whether this is the special case of `spacetimedb_lib::Identity`. Does not follow `Ref`s.

Returns whether this sum type is like on in C without data attached to the variants.

Returns an iterator over all the [`PageOffset`]s of the fixed rows in this page. The rows are assumed to be `fixed_row_size` bytes long. NOTE: This

Determine the maximum transaction offset considered durable. The offset is `None` if the log hasn't been flushed to disk yet.

Causes requests which start with `path` to be processed by `sub_router`. `sub_router` will be used by stripping the leading `path` from the path of t

Returns self, but if any of the sources are None then we take it from fallback

Registers into `DESCRIBERS` a function `f` to modify the module builder.

* @brief Release ownership of the buffer * * The buffer will NOT be returned to the pool when this IterBuf * is destroyed. Use this wh

Restart the SpacetimeDB server. This stops the current server process and starts a new one with the same data directory. All data is preserved across

Estimate the cardinality of a physical plan.

Construct an implementor of `VarLenMembers`, which visits the var-len members in a row of `ty`. This is a potentially expensive operation, so the res

IMPORTANT! This function is relatively expensive, and much more expensive than `row_type_for_table_mut_tx`. Prefer `row_type_for_table_mut_tx` if you

Returns an iterator yielding all rows in this index for `key`. Matching is defined by `Eq for AlgebraicValue`.

Executes a SQL query with the --confirmed flag.

Increment `num_subscribers` in `st_view_sub` to effectively subscribe a caller to a view. We insert a row if there are no current subscribers and the

Extract the value and replace it with a dummy one that is cheap to make.

Convert this `Identity` to a BIG-ENDIAN byte array.

Returns this `Identity` as a byte array.

* Consumes self and issues an `Unsubscribe` message, * removing this query from the client's set of subscribed queries. * It is only valid to ca

Update the database according to the migration plan. The update is performed within the transactional context `tx`. NOTE: Manual migration support is

Serialize `x` as an [`AlgebraicValue`].

Returns the workspace root directory.

Prompt the user for `y` or `n` from stdin. Return `false` unless the input is `y`.