Skip to main content

Module v1

Module v1 

Source

Modules§

__buffa
cell

Structs§

Cell
Typed scalar for one row cell. Mirrors every column kind supported by KvSchema. Servers MUST always set kind; clients MUST treat a missing kind as a protocol error rather than as NULL.
CellView
Typed scalar for one row cell. Mirrors every column kind supported by KvSchema. Servers MUST always set kind; clients MUST treat a missing kind as a protocol error rather than as NULL.
Column
One column of a registered Table.
ColumnView
One column of a registered Table.
Index
Secondary index declared on a Table.
IndexView
Secondary index declared on a Table.
ListValue
Ordered list of scalar cells. Used for List<...> columns. Elements must all carry the same inner kind (Int64, Float64, Boolean, or Utf8).
ListValueView
Ordered list of scalar cells. Used for List<...> columns. Elements must all carry the same inner kind (Int64, Float64, Boolean, or Utf8).
Null
Explicit NULL marker for SQL NULL cells. Distinct from a Cell whose kind oneof is unset - that indicates a malformed wire message, not NULL.
NullView
Explicit NULL marker for SQL NULL cells. Distinct from a Cell whose kind oneof is unset - that indicates a malformed wire message, not NULL.
QueryRequest
Ad-hoc SQL statement.
QueryRequestView
Ad-hoc SQL statement.
QueryResponse
Result set from Query.
QueryResponseView
Result set from Query.
Row
Typed row. cells[i] aligns with column[i] in the parent message.
RowView
Typed row. cells[i] aligns with column[i] in the parent message.
ServiceClient
Client for this service.
ServiceServer
Monomorphic dispatcher for Service.
SubscribeRequest
Stream every batch whose rows match where_sql.
SubscribeRequestView
Stream every batch whose rows match where_sql.
SubscribeResponse
Rows from one atomic ingest batch that matched the subscriber’s predicate.
SubscribeResponseView
Rows from one atomic ingest batch that matched the subscriber’s predicate.
Table
Server-registered table.
TableView
Server-registered table.
TablesRequest
Discovery request; currently has no parameters.
TablesRequestView
Discovery request; currently has no parameters.
TablesResponse
Describes every table registered in the server-side KvSchema.
TablesResponseView
Describes every table registered in the server-side KvSchema.

Enums§

IndexLayout
Key layout of a secondary index.

Constants§

SERVICE_QUERY_SPEC
Static Spec for the server-side Query RPC.
SERVICE_SERVICE_NAME
Full service name for this service.
SERVICE_SUBSCRIBE_SPEC
Static Spec for the server-side Subscribe RPC.
SERVICE_TABLES_SPEC
Static Spec for the server-side Tables RPC.

Traits§

Service
Streaming SQL predicate service over a server-side KvSchema. The server registers a fixed set of SQL tables at startup (schema lives on the server, not the wire). Each RPC names one of those tables.
ServiceExt
Extension trait for registering a service implementation with a Router.

Type Aliases§

OwnedQueryRequestView
Shorthand for OwnedView<QueryRequestView<'static>>.
OwnedQueryResponseView
Shorthand for OwnedView<QueryResponseView<'static>>.
OwnedSubscribeRequestView
Shorthand for OwnedView<SubscribeRequestView<'static>>.
OwnedSubscribeResponseView
Shorthand for OwnedView<SubscribeResponseView<'static>>.
OwnedTablesRequestView
Shorthand for OwnedView<TablesRequestView<'static>>.
OwnedTablesResponseView
Shorthand for OwnedView<TablesResponseView<'static>>.