Struct KumoApiClient 

pub struct KumoApiClient { /* private fields */ }

Implementations

impl KumoApiClient

pub fn new(endpoint: Url) -> Self

pub async fn admin_bounce_v1( &self, params: &BounceV1Request, ) -> Result<BounceV1Response>

pub async fn machine_info(&self) -> Result<MachineInfoV1>

pub async fn admin_bounce_list_v1(&self) -> Result<Vec<BounceV1ListEntry>>

pub async fn admin_bounce_cancel_v1( &self, params: &BounceV1CancelRequest, ) -> Result<String>

pub async fn admin_inspect_sched_q_v1( &self, get_params: &InspectQueueV1Request, ) -> Result<InspectQueueV1Response>

pub async fn admin_inspect_message_v1( &self, get_params: &InspectMessageV1Request, ) -> Result<InspectMessageV1Response>

pub async fn admin_xfer_v1( &self, params: &XferV1Request, ) -> Result<XferV1Response>

pub async fn admin_suspend_list_v1(&self) -> Result<Vec<SuspendV1ListEntry>>

pub async fn admin_suspend_ready_q_list_v1( &self, ) -> Result<Vec<SuspendReadyQueueV1ListEntry>>

pub async fn admin_xfer_cancel_v1( &self, params: &XferCancelV1Request, ) -> Result<XferCancelV1Response>

pub async fn admin_rebind_v1( &self, params: &RebindV1Request, ) -> Result<RebindV1Response>

pub async fn admin_suspend_ready_q_v1( &self, params: &SuspendReadyQueueV1Request, ) -> Result<SuspendV1Response>

pub async fn admin_suspend_ready_q_cancel_v1( &self, params: &SuspendV1CancelRequest, ) -> Result<String>

pub async fn admin_suspend_v1( &self, params: &SuspendV1Request, ) -> Result<SuspendV1Response>

pub async fn admin_suspend_cancel_v1( &self, params: &SuspendV1CancelRequest, ) -> Result<String>

pub async fn admin_ready_q_states_v1( &self, get_params: &ReadyQueueStateRequest, ) -> Result<ReadyQueueStateResponse>

pub async fn admin_set_diagnostic_log_filter_v1( &self, params: &SetDiagnosticFilterRequest, ) -> Result<String>

pub async fn request_with_text_response<T: IntoUrl, B: Serialize>( &self, method: Method, url: T, body: &B, ) -> Result<String>

pub async fn request_with_streaming_text_response<T: IntoUrl, B: Serialize>( &self, method: Method, url: T, body: &B, ) -> Result<impl Stream<Item = Result<Bytes>>>

pub async fn request_with_json_response<T: IntoUrl, B: Serialize, R: DeserializeOwned>( &self, method: Method, url: T, body: &B, ) -> Result<R>

pub async fn get_metrics<T, F: FnMut(&Metric) -> Option<T>>( &self, filter_map: F, ) -> Result<Vec<T>>