#distributed #decentralized #event-sourcing

actyxos_sdk

Tools for interacting with the services of an ActyxOS node

14 releases

0.6.0 Nov 20, 2021
0.5.0 Oct 20, 2020
0.4.0 Jul 9, 2020

#2401 in Network programming

Download history 10/week @ 2022-10-08 2/week @ 2022-10-15 4/week @ 2022-10-22 21/week @ 2022-10-29 37/week @ 2022-11-05 4/week @ 2022-11-12 5/week @ 2022-11-19 3/week @ 2022-11-26 4/week @ 2022-12-03 21/week @ 2022-12-10 6/week @ 2022-12-17 3/week @ 2022-12-24 3/week @ 2022-12-31 17/week @ 2023-01-07 23/week @ 2023-01-14 16/week @ 2023-01-21

60 downloads per month
Used in actyxos_data_flow

Apache-2.0

180KB
3.5K SLoC

Latest Version Rust Documentation

ActyxOS SDK

ActyxOS makes it easy to run distributed applications on multiple nodes. It is a piece of software that allows you to run your own apps on one or more edge devices and have these apps seamlessly communicate and share data with each other.

This crate defines the data types needed for communicating with ActyxOS and provides Rust bindings for the ActyxOS APIs.

Examples

Below you find a full example using the EventService client that retrieves some events. Please adapt the semantics to match your stored events in order to see output.

Note: (this example needs the client feature to compile)

use actyxos_sdk::event_service::{EventService,
        EventServiceError, Order, Subscription};
use futures::stream::StreamExt;

#[tokio::main]
pub async fn main() -> Result<(), EventServiceError> {
    // client for locally running ActyxOS Event Service
    let service = EventService::default();

    // retrieve largest currently known event stream cursor
    let offsets = service.get_offsets().await?;

    // all events matching the given subscription
    // sorted backwards, i.e. youngest to oldest
    let sub = vec![Subscription::semantics("MyFish")];
    let mut events = service
        .query_upto(offsets, sub, Order::LamportReverse)
        .await?;

    // print out the payload of each event
    // (cf. Payload::extract for more options)
    while let Some(event) = events.next().await {
        println!("{}", event.payload.json_value());
    }
    Ok(())
 }

Feature flags

The default is to provide only the data types with serialization and deserialization support for serde. The following features can be enabled in addition:

Dependencies

~5–16MB
~310K SLoC