Struct persist::runtime::RuntimeImpl [−][src]
struct RuntimeImpl<L: Log, B: Blob> {
indexed: Indexed<L, B>,
maintainer: Maintainer<B>,
async_runtime: Arc<AsyncRuntime>,
rx: Receiver<RuntimeCmd>,
tx: Sender<RuntimeCmd>,
metrics: Arc<Metrics>,
prev_step: Instant,
min_step_interval: Duration,
}
Fields
indexed: Indexed<L, B>
maintainer: Maintainer<B>
async_runtime: Arc<AsyncRuntime>
rx: Receiver<RuntimeCmd>
tx: Sender<RuntimeCmd>
metrics: Arc<Metrics>
prev_step: Instant
min_step_interval: Duration
Implementations
fn new(
config: RuntimeConfig,
indexed: Indexed<L, B>,
maintainer: Maintainer<B>,
async_runtime: Arc<AsyncRuntime>,
rx: Receiver<RuntimeCmd>,
tx: Sender<RuntimeCmd>,
metrics: Arc<Metrics>
) -> Self
Auto Trait Implementations
impl<L, B> !RefUnwindSafe for RuntimeImpl<L, B>
impl<L, B> Send for RuntimeImpl<L, B> where
L: Send,
impl<L, B> Sync for RuntimeImpl<L, B> where
L: Sync,
impl<L, B> Unpin for RuntimeImpl<L, B> where
L: Unpin,
impl<L, B> !UnwindSafe for RuntimeImpl<L, B>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more