async fn capabilities() {
    run_no_data_test(Box::new(|state: &mut StepTestState| {
        async move {
            let mut storage_client =
                StorageClient::new(state.cluster().querier().querier_grpc_connection());
            let capabilities_response = storage_client
                .capabilities(Empty {})
                .await
                .unwrap()
                .into_inner();
            assert_eq!(
                capabilities_response.caps.len(),
                3,
                "Response: {:?}",
                capabilities_response
            );
        }
        .boxed()
    }))
    .await
}
/// Validate that capabilities storage endpoint is hooked up
Validate that capabilities storage endpoint is hooked up
Validate that capabilities storage endpoint is hooked up
async fn capabilities() {
    run_no_data_test(Box::new(|state: &mut StepTestState| {
        async move {
            let mut storage_client =
                StorageClient::new(state.cluster().querier().querier_grpc_connection());
            let capabilities_response = storage_client
                .capabilities(Empty {})
                .await
                .unwrap()
                .into_inner();
            assert_eq!(
                capabilities_response.caps.len(),
                3,
                "Response: {:?}",
                capabilities_response
            );
        }
        .boxed()
    }))
    .await
}
async fn capabilities ( ) { run_no_data_test ( Box :: new ( | state : & mut StepTestState | { async move { let mut storage_client = StorageClient :: new ( state . cluster ( ) . querier ( ) . querier_grpc_connection ( ) ) ; let capabilities_response = storage_client . capabilities ( Empty { } ) . await . unwrap ( ) . into_inner ( ) ; assert_eq ! ( capabilities_response caps len ( ) 3 " " capabilities_response ) ; } . boxed ( ) } ) ) . await }
Validate that capabilities storage endpoint is hooked up
Validate that capabilities storage endpoint is hooked up