async_driver

Async data engine and enterprise driver-layer contracts for M48.

Types

Benchmark

Deterministic benchmark sample.

pub type Benchmark {
  Benchmark(
    driver: String,
    profile: BenchmarkProfile,
    p50_latency_ms: Int,
    p95_latency_ms: Int,
    timeout_rate_bps: Int,
    retry_rate_bps: Int,
    throughput_ops_per_sec: Int,
  )
}

Constructors

Benchmark(
  driver: String,
  profile: BenchmarkProfile,
  p50_latency_ms: Int,
  p95_latency_ms: Int,
  timeout_rate_bps: Int,
  retry_rate_bps: Int,
  throughput_ops_per_sec: Int,
)

BenchmarkProfile

Benchmark profile class for M48 coverage.

pub type BenchmarkProfile {
  HeavyData
  MixedLatency
}

Constructors

```
HeavyData
```
```
MixedLatency
```

Budget

Budget for one benchmark profile.

pub type Budget {
  Budget(
    profile: BenchmarkProfile,
    max_p95_latency_ms: Int,
    max_timeout_rate_bps: Int,
    max_retry_rate_bps: Int,
    min_throughput_ops_per_sec: Int,
  )
}

Constructors

Budget(
  profile: BenchmarkProfile,
  max_p95_latency_ms: Int,
  max_timeout_rate_bps: Int,
  max_retry_rate_bps: Int,
  min_throughput_ops_per_sec: Int,
)

BudgetResult

One budget-check result.

pub type BudgetResult {
  BudgetResult(
    driver: String,
    profile: BenchmarkProfile,
    passed: Bool,
    reason: String,
  )
}

Constructors

BudgetResult(
  driver: String,
  profile: BenchmarkProfile,
  passed: Bool,
  reason: String,
)

DriverCapability

Driver capability contract.

pub type DriverCapability {
  NonBlockingExecute
  BoundedConcurrency
  TimeoutTelemetry
  RetryTelemetry
  BatchRead
  BatchWrite
  CheckpointResume
  IdempotentWrite
  MixedLatencyTolerance
}

Constructors

```
NonBlockingExecute
```
```
BoundedConcurrency
```
```
TimeoutTelemetry
```
```
RetryTelemetry
```
```
BatchRead
```
```
BatchWrite
```
```
CheckpointResume
```
```
IdempotentWrite
```
```
MixedLatencyTolerance
```

DriverClass

Enterprise driver boundary class.

pub type DriverClass {
  RelationalAdapter
  ColumnarAdapter
  StreamAdapter
  ObjectStoreAdapter
}

Constructors

```
RelationalAdapter
```
```
ColumnarAdapter
```
```
StreamAdapter
```
```
ObjectStoreAdapter
```

DriverContract

One enterprise async driver contract.

pub type DriverContract {
  DriverContract(
    name: String,
    class: DriverClass,
    provider_module: String,
    max_in_flight: Int,
    max_queue_depth: Int,
    timeout_policy: TimeoutPolicy,
    retry_policy: RetryPolicy,
    telemetry: TelemetryProfile,
    capabilities: List(DriverCapability),
    support_tier: String,
    tuning_guide: String,
  )
}

Constructors

DriverContract(
  name: String,
  class: DriverClass,
  provider_module: String,
  max_in_flight: Int,
  max_queue_depth: Int,
  timeout_policy: TimeoutPolicy,
  retry_policy: RetryPolicy,
  telemetry: TelemetryProfile,
  capabilities: List(DriverCapability),
  support_tier: String,
  tuning_guide: String,
)

RetryPolicy

Retry policy for one driver.

pub type RetryPolicy {
  RetryPolicy(
    max_attempts: Int,
    base_backoff_ms: Int,
    max_backoff_ms: Int,
    jitter_percent: Int,
  )
}

Constructors

RetryPolicy(
  max_attempts: Int,
  base_backoff_ms: Int,
  max_backoff_ms: Int,
  jitter_percent: Int,
)

TelemetryProfile

Timeout/retry/in-flight telemetry profile.

pub type TelemetryProfile {
  TelemetryProfile(
    timeout_metric: String,
    retry_metric: String,
    latency_metric: String,
    in_flight_metric: String,
  )
}

Constructors

TelemetryProfile(
  timeout_metric: String,
  retry_metric: String,
  latency_metric: String,
  in_flight_metric: String,
)

TimeoutPolicy

Timeout policy for one driver.

pub type TimeoutPolicy {
  TimeoutPolicy(connect_ms: Int, request_ms: Int, idle_ms: Int)
}

Constructors

TimeoutPolicy(connect_ms: Int, request_ms: Int, idle_ms: Int)

Values

benchmark_signature

pub fn benchmark_signature(benchmark: Benchmark) -> String

Stable benchmark signature.

budget_failures

pub fn budget_failures(results: List(BudgetResult)) -> Int

Count failing budget checks.

budget_result_signature

pub fn budget_result_signature(result: BudgetResult) -> String

Stable budget-check result signature.

capabilities

pub fn capabilities(
  driver: DriverContract,
) -> List(DriverCapability)

Driver capabilities accessor.

capability_label

pub fn capability_label(capability: DriverCapability) -> String

Stable capability label.

capability_matrix_signature

pub fn capability_matrix_signature() -> String

Stable adapter capability matrix signature.

class_label

pub fn class_label(class: DriverClass) -> String

Stable class label.

clickhouse_async_driver

pub fn clickhouse_async_driver() -> DriverContract

Columnar analytics async driver.

contracts_consistent

pub fn contracts_consistent() -> Bool

True when all supported drivers are valid and policy-consistent.

default_budgets

pub fn default_budgets() -> List(Budget)

M48 default benchmark budgets.

driver_signature

pub fn driver_signature(driver: DriverContract) -> String

Stable driver contract signature.

evaluate_budgets

pub fn evaluate_budgets(
  benchmarks: List(Benchmark),
  budgets: List(Budget),
) -> List(BudgetResult)

Evaluate benchmarks against M48 budgets.

kafka_async_driver

pub fn kafka_async_driver() -> DriverContract

Streaming async driver.

name

pub fn name(driver: DriverContract) -> String

Driver name accessor.

object_store_async_driver

pub fn object_store_async_driver() -> DriverContract

Object-store batch async driver.

postgres_async_driver

pub fn postgres_async_driver() -> DriverContract

Relational async driver.

profile_label

pub fn profile_label(profile: BenchmarkProfile) -> String

Stable benchmark-profile label.

run_enterprise_benchmarks

pub fn run_enterprise_benchmarks() -> List(Benchmark)

Run deterministic heavy-data and mixed-latency benchmark profiles.

supported_drivers

pub fn supported_drivers() -> List(DriverContract)

Supported M48 enterprise drivers.

telemetry

pub fn telemetry(driver: DriverContract) -> TelemetryProfile

Driver telemetry accessor.

timeout_retry_telemetry_parity

pub fn timeout_retry_telemetry_parity() -> Bool

True when timeout/retry telemetry contracts are consistent across drivers.

valid

pub fn valid(driver: DriverContract) -> Bool

Validate one driver contract.