ih_muse::preludeTrait Transport
Source pub trait Transport {
// Required methods
fn health_check<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
fn get_node_state<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<NodeState, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
fn get_finest_resolution<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<TimestampResolution, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
fn register_element_kinds<'life0, 'life1, 'async_trait>(
&'life0 self,
element_kinds: &'life1 [ElementKindRegistration],
) -> Pin<Box<dyn Future<Output = Result<(), MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait;
fn register_elements<'life0, 'life1, 'async_trait>(
&'life0 self,
elements: &'life1 [ElementRegistration],
) -> Pin<Box<dyn Future<Output = Result<Vec<Result<u64, MuseError>>, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait;
fn get_node_elem_ranges<'life0, 'async_trait>(
&'life0 self,
ini: Option<u64>,
end: Option<u64>,
) -> Pin<Box<dyn Future<Output = Result<Vec<NodeElementRange>, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
fn register_metrics<'life0, 'life1, 'async_trait>(
&'life0 self,
payload: &'life1 [MetricDefinition],
) -> Pin<Box<dyn Future<Output = Result<(), MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait;
fn get_metric_order<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Vec<MetricDefinition>, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
fn get_metrics<'life0, 'life1, 'async_trait>(
&'life0 self,
query: &'life1 MetricQuery,
node_addr: Option<SocketAddr>,
) -> Pin<Box<dyn Future<Output = Result<Vec<MetricPayload>, MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait;
fn send_metrics<'life0, 'async_trait>(
&'life0 self,
payload: Vec<MetricPayload>,
node_addr: Option<SocketAddr>,
) -> Pin<Box<dyn Future<Output = Result<(), MuseError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
}