Struct re_sdk::recording_stream::RecordingStreamInner

struct RecordingStreamInner {
    info: StoreInfo,
    tick: AtomicI64,
    cmds_tx: Sender<Command>,
    batcher: ChunkBatcher,
    batcher_to_sink_handle: Option<JoinHandle<()>>,
    dataloader_handles: Mutex<Vec<JoinHandle<()>>>,
    pid_at_creation: u32,
}

Fields

info: StoreInfo

tick: AtomicI64

cmds_tx: Sender<Command>

The one and only entrypoint into the pipeline: this is never cloned nor publicly exposed, therefore the Drop implementation is guaranteed that no more data can come in while it’s running.

batcher: ChunkBatcher

batcher_to_sink_handle: Option<JoinHandle<()>>

dataloader_handles: Mutex<Vec<JoinHandle<()>>>

Keeps track of the top-level threads that were spawned in order to execute the DataLoader machinery in the context of this RecordingStream.

See RecordingStream::log_file_from_path and RecordingStream::log_file_from_contents.

pid_at_creation: u32

Implementations

impl RecordingStreamInner

fn new( info: StoreInfo, batcher_config: ChunkBatcherConfig, sink: Box<dyn LogSink> ) -> RecordingStreamResult<Self>

pub fn is_forked_child(&self) -> bool

fn wait_for_dataloaders(&self)

Make sure all pending top-level DataLoader threads that were started from the SDK run to completion.

Trait Implementations

impl Debug for RecordingStreamInner

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

Formats the value using the given formatter.

impl Drop for RecordingStreamInner

fn drop(&mut self)

Executes the destructor for this type.