Struct eventstore::commands::AllCatchupSubscribe

pub struct AllCatchupSubscribe<'a> { /* fields omitted */ }

Like RegularCatchupSubscribe but specific to the system stream '$all'.

Methods

impl<'a> AllCatchupSubscribe<'a>

pub fn resolve_link_tos(self, resolve_link_tos: bool) -> AllCatchupSubscribe<'a>

When using projections, you can have links placed into another stream. If you set true, the server will resolve those links and will return the event that the link points to. Default: false.

pub fn require_master(self, require_master: bool) -> AllCatchupSubscribe<'a>

Asks the server receiving the command to be the master of the cluster in order to perform the write. Default: false.

pub fn start_position(self, start_pos: Position) -> AllCatchupSubscribe<'a>

Starting point in the transaction journal log. By default, it will start at types::Position::start.

pub fn credentials(self, creds: Credentials) -> AllCatchupSubscribe<'a>

Performs the command with the given credentials.

pub fn execute(self) -> Subscription

Preforms the catching up phase of the subscription asynchronously. When it will reach the head of stream, the command will emit a volatile subscription request.