Crate hyperstack_sdk

Crate hyperstack_sdk 

Source
Expand description

Rust client SDK for connecting to HyperStack streaming servers.

use hyperstack_sdk::{HyperStack, Entity, Update};
use futures_util::StreamExt;
use my_stack::{PumpfunToken, PumpfunTokenEntity};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let hs = HyperStack::connect("wss://mainnet.hyperstack.xyz").await?;
     
    if let Some(token) = hs.get::<PumpfunTokenEntity>("mint_address").await {
        println!("Token: {:?}", token);
    }
     
    let mut stream = hs.watch::<PumpfunTokenEntity>().await;
    while let Some(update) = stream.next().await {
        match update {
            Update::Upsert { key, data } => println!("Updated: {}", key),
            Update::Delete { key } => println!("Deleted: {}", key),
            _ => {}
        }
    }
     
    Ok(())
}

Structs§

EntityStream
Frame
HyperStack
HyperStackBuilder
HyperStackConfig
SharedStore
StoreUpdate
Subscription

Enums§

ConnectionState
HyperStackError
Mode
Operation
Update
Value
Represents any valid JSON value.

Traits§

Entity
Marker trait for HyperStack entities.
Filterable
Optional trait for entities that support server-side filtering.