Struct eventstore::prelude::ProjectionClient
source[−]pub struct ProjectionClient { /* private fields */ }
Implementations
pub async fn create<Name>(
&self,
name: Name,
query: String,
options: &CreateProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn update<Name>(
&self,
name: Name,
query: String,
options: &UpdateProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn delete<Name>(
&self,
name: Name,
options: &DeleteProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn get_status<Name>(
&self,
name: Name,
options: &GenericProjectionOptions
) -> Result<Option<ProjectionStatus>> where
Name: AsRef<str>,
pub async fn list(
&self,
options: &GenericProjectionOptions
) -> Result<BoxStream<'_, Result<ProjectionStatus>>>
pub async fn enable<Name>(
&self,
name: Name,
options: &GenericProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn reset<Name>(
&self,
name: Name,
options: &GenericProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn disable<Name>(
&self,
name: Name,
options: &GenericProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn abort<Name>(
&self,
name: Name,
options: &GenericProjectionOptions
) -> Result<()> where
Name: AsRef<str>,
pub async fn get_state<Name, A>(
&self,
name: Name,
options: &GetStateProjectionOptions
) -> Result<Result<A>> where
Name: AsRef<str>,
A: DeserializeOwned + Send,
pub async fn get_result<Name, A>(
&self,
name: Name,
options: &GetResultProjectionOptions
) -> Result<Result<A>> where
Name: AsRef<str>,
A: DeserializeOwned + Send,
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for ProjectionClient
impl Send for ProjectionClient
impl Sync for ProjectionClient
impl Unpin for ProjectionClient
impl !UnwindSafe for ProjectionClient
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more