Struct eventstore::commands::ReadStreamEvents [−][src]
pub struct ReadStreamEvents<'a> { /* fields omitted */ }
A command that reads several events from a stream. It can read events forward or backward.
Methods
impl<'a> ReadStreamEvents<'a>
[src]
impl<'a> ReadStreamEvents<'a>
pub fn forward(self) -> ReadStreamEvents<'a>
[src]
pub fn forward(self) -> ReadStreamEvents<'a>
Asks the command to read forward (toward the end of the stream). That's the default behavior.
pub fn backward(self) -> ReadStreamEvents<'a>
[src]
pub fn backward(self) -> ReadStreamEvents<'a>
Asks the command to read backward (toward the begining of the stream).
pub fn credentials(self, value: Credentials) -> ReadStreamEvents<'a>
[src]
pub fn credentials(self, value: Credentials) -> ReadStreamEvents<'a>
Performs the command with the given credentials.
pub fn max_count(self, max_count: i32) -> ReadStreamEvents<'a>
[src]
pub fn max_count(self, max_count: i32) -> ReadStreamEvents<'a>
Max batch size.
pub fn start_from(self, start: i64) -> ReadStreamEvents<'a>
[src]
pub fn start_from(self, start: i64) -> ReadStreamEvents<'a>
Starts the read ot the given event number. By default, it starts at
pub fn require_master(self, require_master: bool) -> ReadStreamEvents<'a>
[src]
pub fn require_master(self, require_master: bool) -> ReadStreamEvents<'a>
Asks the server receiving the command to be the master of the cluster
in order to perform the write. Default: false
.
pub fn resolve_link_tos(self, resolve_link_tos: bool) -> ReadStreamEvents<'a>
[src]
pub fn resolve_link_tos(self, resolve_link_tos: bool) -> ReadStreamEvents<'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 execute(
self
) -> impl Future<Item = ReadStreamStatus<StreamSlice>, Error = OperationError>
[src]
pub fn execute(
self
) -> impl Future<Item = ReadStreamStatus<StreamSlice>, Error = OperationError>
Sends asynchronously the read command to the server.
Auto Trait Implementations
impl<'a> Send for ReadStreamEvents<'a>
impl<'a> Send for ReadStreamEvents<'a>
impl<'a> Sync for ReadStreamEvents<'a>
impl<'a> Sync for ReadStreamEvents<'a>