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§
Enums§
- Connection
State - Hyper
Stack Error - 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.