Struct StorageRuntime 

pub struct StorageRuntime { /* private fields */ }

Runtime options for storage that cannot be serialized.

This struct holds non-serializable runtime configuration like tokio runtime handles. Users can configure these options and pass them to system builders (e.g., LogDbBuilder, TsdbBuilder).

Example

use common::StorageRuntime;

// Create a separate runtime for compaction
let compaction_runtime = tokio::runtime::Builder::new_multi_thread()
    .worker_threads(2)
    .enable_all()
    .build()
    .unwrap();

let runtime = StorageRuntime::new()
    .with_compaction_runtime(compaction_runtime.handle().clone());

// Pass to a system builder
let mut builder = LogDbBuilder::new(config);
*builder.storage_mut() = runtime;
let log = builder.build().await?;

Implementations

impl StorageRuntime

pub fn new() -> Self

Creates a new storage runtime with default options.

pub fn with_compaction_runtime(self, handle: Handle) -> Self

Sets a separate runtime for SlateDB compaction tasks.

When provided, SlateDB’s compaction tasks will run on this runtime instead of the runtime used for user operations. This is important when calling the database from sync code using block_on, as it prevents deadlocks between user operations and background compaction.

This option only affects SlateDB storage; it is ignored for in-memory storage.

Trait Implementations

impl Default for StorageRuntime

fn default() -> StorageRuntime

Returns the “default value” for a type.