pub struct FlowUpdateService { /* private fields */ }Implementations§
Source§impl FlowUpdateService
impl FlowUpdateService
Sourcepub async fn from_url(
aquila_url: String,
definition_path: &str,
aquila_token: String,
) -> Self
pub async fn from_url( aquila_url: String, definition_path: &str, aquila_token: String, ) -> Self
Create a new FlowUpdateService instance from an Aquila URL and a definition path.
This reads the definition files from the given path as modules and initializes the service with those module definitions.
pub fn with_definition_source(self, source: String) -> Self
pub async fn send(&mut self)
pub async fn send_with_status(&mut self) -> bool
Auto Trait Implementations§
impl Freeze for FlowUpdateService
impl !RefUnwindSafe for FlowUpdateService
impl Send for FlowUpdateService
impl Sync for FlowUpdateService
impl Unpin for FlowUpdateService
impl UnsafeUnpin for FlowUpdateService
impl !UnwindSafe for FlowUpdateService
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request