async fn offsets() {
    run_no_data_test(Box::new(|state: &mut StepTestState| {
        async move {
            let mut storage_client =
                StorageClient::new(state.cluster().querier().querier_grpc_connection());
            let offsets_response = storage_client.offsets(Empty {}).await.unwrap().into_inner();
            let expected = OffsetsResponse {
                partitions: vec![PartitionOffsetResponse { id: 0, offset: 1 }],
            };
            assert_eq!(offsets_response, expected);
        }
        .boxed()
    }))
    .await
}
/// Validate that storage offsets endpoint is hooked up (required by internal Influx cloud)
Validate that storage offsets endpoint is hooked up (required by internal Influx cloud)
Validate that storage offsets endpoint is hooked up ( required by internal Influx cloud )
async fn offsets() {
    run_no_data_test(Box::new(|state: &mut StepTestState| {
        async move {
            let mut storage_client =
                StorageClient::new(state.cluster().querier().querier_grpc_connection());
            let offsets_response = storage_client.offsets(Empty {}).await.unwrap().into_inner();
            let expected = OffsetsResponse {
                partitions: vec![PartitionOffsetResponse { id: 0, offset: 1 }],
            };
            assert_eq!(offsets_response, expected);
        }
        .boxed()
    }))
    .await
}
async fn offsets ( ) { run_no_data_test ( Box :: new ( | state : & mut StepTestState | { async move { let mut storage_client = StorageClient :: new ( state . cluster ( ) . querier ( ) . querier_grpc_connection ( ) ) ; let offsets_response = storage_client . offsets ( Empty { } ) . await . unwrap ( ) . into_inner ( ) ; let expected = OffsetsResponse { partitions : vec ! [ PartitionOffsetResponse { id 0 offset 1 } ] , } ; assert_eq ! ( offsets_response expected ) ; } . boxed ( ) } ) ) . await }
Validate that storage offsets endpoint is hooked up (required by internal Influx cloud)
Validate that storage offsets endpoint is hooked up ( required by internal Influx cloud )