Struct actyx_sdk::HttpClient [−][src]
pub struct HttpClient { /* fields omitted */ }
Implementations
Configures connection to Actyx node with provided Url and AppManifest. All path segments of the Url (if any) are discarded.
Trait Implementations
Returns known offsets across local and replicated streams.
fn publish<'life0, 'async_trait>(
&'life0 self,
request: PublishRequest
) -> Pin<Box<dyn Future<Output = Result<PublishResponse>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn publish<'life0, 'async_trait>(
&'life0 self,
request: PublishRequest
) -> Pin<Box<dyn Future<Output = Result<PublishResponse>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Publishes a set of new events.
fn query<'life0, 'async_trait>(
&'life0 self,
request: QueryRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, QueryResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn query<'life0, 'async_trait>(
&'life0 self,
request: QueryRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, QueryResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Query events known at the time the request was reveived by the service.
fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: SubscribeRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, SubscribeResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: SubscribeRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, SubscribeResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Suscribe to events that are currently known by the service followed by new “live” events.
fn subscribe_monotonic<'life0, 'async_trait>(
&'life0 self,
request: SubscribeMonotonicRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, SubscribeMonotonicResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn subscribe_monotonic<'life0, 'async_trait>(
&'life0 self,
request: SubscribeMonotonicRequest
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, SubscribeMonotonicResponse>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Subscribe to events that are currently known by the service followed by new “live” events until the service learns about events that need to be sorted earlier than an event already received. Read more
Auto Trait Implementations
impl !RefUnwindSafe for HttpClient
impl Send for HttpClient
impl Sync for HttpClient
impl Unpin for HttpClient
impl !UnwindSafe for HttpClient
Blanket Implementations
Mutably borrows from an owned value. Read more
Casts the value.
Casts the value.
Performs the conversion.
Performs the conversion.
Casts the value.
OverflowingCasts the value.
Casts the value.
Casts the value.
Casts the value.
UnwrappedCasts the value.
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
Casts the value.
WrappingCasts the value.