Struct dbcrossbarlib::SharedArguments

pub struct SharedArguments<S: ArgumentState> { /* fields omitted */ }

Arguments used by both the data source and destination.

Implementations

impl<S: ArgumentState> SharedArguments<S>

pub fn max_streams(&self) -> usize

How many concurrent data streams should we attempt to process at once?

This is available even for unvalidated arguments because it’s used by our top-level code as well as some of the individual drivers.

impl SharedArguments<Unverified>

pub fn new(
    schema: Schema,
    temporary_storage: TemporaryStorage,
    max_streams: usize
) -> Self

Create a new SharedArguments structure.

pub fn verify(self, _features: Features) -> Result<SharedArguments<Verified>>

Verify that this structure only contains supported arguments. This uses the type state pattern to keep track of whether our arguments have been verified to be supported.

impl SharedArguments<Verified>

pub fn schema(&self) -> &Schema

Get the table scheme used for this transfer.

pub fn temporary_storage(&self) -> &TemporaryStorage

Get the temporary storage available for use by this transfer.

Trait Implementations

impl<S: Clone + ArgumentState> Clone for SharedArguments<S>

fn clone(&self) -> SharedArguments<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug + ArgumentState> Debug for SharedArguments<S>

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

Formats the value using the given formatter.