[−][src]Struct eventstore::commands::WriteEvents
Command that sends events to a given stream.
Methods
impl WriteEvents
[src]
pub fn set_events(self, events: Vec<EventData>) -> Self
[src]
Sets events to write in the command. This function will replace previously added events.
pub fn push_event(self, event: EventData) -> Self
[src]
Adds an event to the current list of events to send to the server.
pub fn append_events<T>(self, events: T) -> Self where
T: IntoIterator<Item = EventData>,
[src]
T: IntoIterator<Item = EventData>,
Extends the current set of events to send the the server with the given iterator.
pub fn require_master(self, require_master: bool) -> Self
[src]
Asks the server receiving the command to be the master of the cluster
in order to perform the write. Default: false
.
pub fn expected_version(self, version: ExpectedVersion) -> Self
[src]
Asks the server to check that the stream receiving the event is at
the given expected version. Default: types::ExpectedVersion::Any
.
pub fn credentials(self, creds: Credentials) -> Self
[src]
Performs the command with the given credentials.
pub async fn execute(self) -> Result<WriteResult, OperationError>
[src]
Sends asynchronously the write command to the server.
Auto Trait Implementations
impl !RefUnwindSafe for WriteEvents
impl Send for WriteEvents
impl Sync for WriteEvents
impl Unpin for WriteEvents
impl !UnwindSafe for WriteEvents
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,