subscribe_to_all

Build subscribe-to-all requests.

This module contains the sans-IO request builder for persistent gRPC reads against $all. Response decoding is shared with kurrentdb/operation/read_stream.

Types

Configuration

opaque

Configuration for subscribing to $all.

pub opaque type Configuration

Values

configure

pub fn configure() -> Configuration

Create $all subscription configuration with default values.

Defaults are forwards, from the end of $all, link resolution disabled, and no filter.

direction

pub fn direction(
  config: Configuration,
  direction: read_all.Direction,
) -> Configuration

Set the subscription read direction.

filter

pub fn filter(
  config: Configuration,
  filter: read_all.Filter,
) -> Configuration

Set the server-side $all filter.

from_position

pub fn from_position(
  config: Configuration,
  position: read_all.Position,
) -> Configuration

Set the transaction log position from which the subscription should start.

request

pub fn request(
  client: kurrentdb.Client,
  config config: Configuration,
) -> request.Request(BitArray)

Build a Streams/Read subscription request for $all.

The returned request starts a streaming response. Backends should decode each gRPC message with read_stream.decode_message.

resolve_links

pub fn resolve_links(
  config: Configuration,
  resolve_links: Bool,
) -> Configuration

Enable or disable link-to-event resolution.