bindings/dotnet/src/validators/layer.rs

// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License.  You may obtain a copy of the License at
//
//   http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied.  See the License for the
// specific language governing permissions and limitations
// under the License.

use crate::error::OpenDALError;
use crate::utils::config_invalid_error;
use crate::validators::{
    validate_non_zero_u32, validate_non_zero_u64, validate_non_zero_usize,
    validate_positive_finite_f32,
};

/// Validate retry layer options.
pub fn validate_retry_options(
    factor: f32,
    min_delay_nanos: u64,
    max_delay_nanos: u64,
) -> Result<(), OpenDALError> {
    validate_positive_finite_f32(factor, "retry factor")?;

    if max_delay_nanos < min_delay_nanos {
        return Err(config_invalid_error(
            "max_delay_nanos must be greater than or equal to min_delay_nanos",
        ));
    }

    Ok(())
}

/// Validate timeout layer options.
pub fn validate_timeout_options(
    timeout_nanos: u64,
    io_timeout_nanos: u64,
) -> Result<(), OpenDALError> {
    validate_non_zero_u64(timeout_nanos, "timeout_nanos")?;
    validate_non_zero_u64(io_timeout_nanos, "io_timeout_nanos")?;

    Ok(())
}

/// Validate concurrent-limit layer options.
pub fn validate_concurrent_limit_options(
    permits: usize,
    http_permits: Option<usize>,
) -> Result<(), OpenDALError> {
    validate_non_zero_usize(permits, "permits")?;
    if let Some(http_permits) = http_permits {
        validate_non_zero_usize(http_permits, "http_permits")?;
    }

    Ok(())
}

/// Validate throttle layer options.
///
/// `ThrottleLayer::new` asserts on zero values, and a panic across the `extern "C"`
/// boundary aborts the process, so both values must be rejected here first.
pub fn validate_throttle_options(bandwidth: u32, burst: u32) -> Result<(), OpenDALError> {
    validate_non_zero_u32(bandwidth, "bandwidth")?;
    validate_non_zero_u32(burst, "burst")?;

    Ok(())
}