Expand description
Rust client SDK for connecting to HyperStack streaming servers.
ⓘ
use hyperstack_sdk::prelude::*;
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(())
}Modules§
- prelude
- Prelude module for convenient imports.
Structs§
- Entity
Stream - Filter
MapStream - Filtered
Stream - Frame
- Hyper
Stack - Hyper
Stack Builder - Hyper
Stack Config - MapStream
- Rich
Entity Stream - Shared
Store - Store
Update - Subscription
Enums§
- Connection
State - Hyper
Stack Error - KeyFilter
- Mode
- Operation
- Rich
Update - Update
- Value
- Represents any valid JSON value.
Traits§
- Entity
- Marker trait for HyperStack entities.
- Entity
Data - Trait that maps a Data type back to its Entity type.
- Filterable
- Optional trait for entities that support server-side filtering.