risingwave_object_store::object

Function retry_request

source
async fn retry_request<F, T, B>(
    builder: B,
    config: &ObjectStoreConfig,
    operation_type: OperationType,
    object_store_metrics: Arc<ObjectStoreMetrics>,
    media_type: &'static str,
) -> ObjectResult<T>
where B: Fn() -> F, F: Future<Output = ObjectResult<T>>,