Struct actyx_sdk::HttpClient

pub struct HttpClient { /* fields omitted */ }

Implementations

impl HttpClient

pub async fn new(origin: Url, app_manifest: AppManifest) -> Result<Self>

Configures connection to Actyx node with provided Url and AppManifest. All path segments of the Url (if any) are discarded.

pub fn node_id(&self) -> NodeId

pub async fn files_post(
    &self,
    files: impl IntoIterator<Item = Part>
) -> Result<Cid>

pub async fn files_get(&self, cid_or_name: &str) -> Result<FilesGetResponse>

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventService for HttpClient

fn offsets<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<OffsetsResponse>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

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, 

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, 

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, 

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, 

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.