rejig

s2-streamstore · Nov 20, 2024 · 0807c1d · 0807c1d
1 parent f39cb52
commit 0807c1d
Show file tree

Hide file tree

Showing 6 changed files with 170 additions and 260 deletions.
diff --git a/examples/basic.rs b/examples/basic.rs
@@ -3,7 +3,7 @@ use std::time::Duration;
 use futures::StreamExt;
 use streamstore::{
     batching::AppendRecordsBatchingStream,
-    client::{Client, ClientConfig, ClientError, HostEndpoints},
+    client::{Client, ClientConfig, ClientError},
     types::{
         AppendInput, AppendRecord, BasinName, CreateBasinRequest, CreateStreamRequest,
         DeleteBasinRequest, DeleteStreamRequest, ListBasinsRequest, ListStreamsRequest,
@@ -15,11 +15,7 @@ use streamstore::{
 async fn main() {
     let token = std::env::var("S2_AUTH_TOKEN").unwrap();
 
-    let host_endpoints = HostEndpoints::from_env().unwrap();
-
-    let config = ClientConfig::new(token)
-        .with_host_endpoints(host_endpoints)
-        .with_request_timeout(Duration::from_secs(10));
+    let config = ClientConfig::new(token).with_request_timeout(Duration::from_secs(10));
 
     println!("Connecting with {config:#?}");