Struct Runtime 

pub struct Runtime { /* private fields */ }

Iceberg’s runtime abstraction.

Contains separate handles for IO-bound and CPU-bound work. When constructed with a single tokio runtime, both io() and cpu() route to the same one. Use Runtime::new_with_split to provide dedicated runtimes for each category.

Lifetime

A Runtime stores only tokio::runtime::Handles (weak references). The caller owns the tokio runtime’s lifetime. If the underlying runtime is dropped while iceberg is still using it, subsequent spawns will surface as task cancellation errors via [JoinHandle].

Cloning is cheap.

Implementations

impl Runtime

pub fn new(runtime: &Runtime) -> Self

Create a Runtime backed by a single tokio runtime for all work.

pub fn new_with_split(io_runtime: &Runtime, cpu_runtime: &Runtime) -> Self

Create a Runtime with separate tokio runtimes for IO and CPU work.

pub fn current() -> Self

Borrows the tokio runtime the caller is currently running in.

Panics if called outside a tokio runtime context. Use Runtime::try_current for a fallible version.

Iceberg never implicitly spawns its own runtime; callers outside a tokio context must construct one explicitly via Runtime::new or Runtime::new_with_split.

pub fn try_current() -> Result<Self>

Fallible variant of Runtime::current. Returns an error if no tokio runtime is available in the current context.

pub fn io(&self) -> &RuntimeHandle

Handle for IO-bound work (network fetches, file reads).

pub fn cpu(&self) -> &RuntimeHandle

Handle for CPU-bound work (decoding, predicate eval, projection).

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Runtime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.