use nakadi_types::event_type::*; use nakadi_types::RandomFlowId; use nakadion::api::{ApiClient, MonitoringApi, SchemaRegistryApi}; #[cfg(feature = "reqwest")] #[tokio::main] async fn main() -> Result<(), Box> { let client = ApiClient::default_builder().finish_from_env()?; let event_type_name = EventTypeName::from_env()?; let event_type = client .get_event_type(&event_type_name, RandomFlowId) .await?; println!("{:#?}", event_type); let event_type = client .get_event_type_partitions(&event_type_name, RandomFlowId) .await?; println!("{:#?}", event_type); Ok(()) } #[cfg(not(feature = "reqwest"))] fn main() { println!("Please enable the `reqwest` feature which is a default feature"); }