Skip to main content

read_object

risingwave_object_store::benchmark::read

Function read_object 

Source 
pub(super) async fn read_object(
    store: Arc<ObjectStoreImpl>,
    key: String,
    config: Arc<BenchmarkConfig>,
    mode: ReadMode,
    reader_id: usize,
    token: CancellationToken,
) -> Outcome
Expand description

Consume whole SDK stream chunks without an AsyncRead adapter or background draining task.