Enum re_data_source::data_source::DataSource

pub enum DataSource {
    RrdHttpUrl {
        url: String,
        follow: bool,
    },
    FilePath(FileSource, PathBuf),
    FileContents(FileSource, FileContents),
    WebSocketAddr(String),
    Stdin,
    RerunGrpcUrl {
        url: String,
    },
    MessageProxy {
        url: String,
    },
}

Somewhere we can get Rerun data from.

Variants

RrdHttpUrl

A remote RRD file, served over http.

If follow is true, the viewer will open the stream in Following mode rather than Playing mode.

Could be either an .rrd recording or a .rbl blueprint.

Fields

url: String

follow: bool

FilePath(FileSource, PathBuf)

A path to a local file.

FileContents(FileSource, FileContents)

The contents of a file.

This is what you get when loading a file on Web, or when using drag-n-drop.

WebSocketAddr(String)

A remote Rerun server.

Stdin

RerunGrpcUrl

A file or a metadata catalog on a Rerun Data Platform server, over rerun:// gRPC interface.

Fields

url: String

MessageProxy

A stream of messages over gRPC, relayed from the SDK.

Fields

url: String

Implementations

impl DataSource

pub fn from_uri(file_source: FileSource, uri: String) -> Self

Tried to classify a URI into a DataSource.

Tries to figure out if it looks like a local path, a web-socket address, or a http url.

pub fn file_name(&self) -> Option<String>

pub fn is_blueprint(&self) -> Option<bool>

pub fn stream( self, on_msg: Option<Box<dyn Fn() + Send + Sync>>, ) -> Result<Receiver<LogMsg>>

Stream the data from the given data source.

Will do minimal checks (e.g. that the file exists), for synchronous errors, but the loading is done in a background task.

on_msg can be used to wake up the UI thread on Wasm.

Trait Implementations

impl Clone for DataSource

fn clone(&self) -> DataSource

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DataSource

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

Formats the value using the given formatter.