Struct dbcrossbarlib::SharedArguments
source · pub struct SharedArguments<S: ArgumentState> { /* private fields */ }
Expand description
Arguments used by both the data source and destination.
Implementations
sourcepub fn max_streams(&self) -> usize
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.
sourcepub fn new(
schema: Schema,
temporary_storage: TemporaryStorage,
max_streams: usize
) -> Self
pub fn new(
schema: Schema,
temporary_storage: TemporaryStorage,
max_streams: usize
) -> Self
Create a new SharedArguments
structure.
sourcepub fn verify(self, _features: Features) -> Result<SharedArguments<Verified>>
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.
sourcepub fn temporary_storage(&self) -> &TemporaryStorage
pub fn temporary_storage(&self) -> &TemporaryStorage
Get the temporary storage available for use by this transfer.
Trait Implementations
sourcefn clone(&self) -> SharedArguments<S>
fn clone(&self) -> SharedArguments<S>
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations
Blanket Implementations
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
type Output = T
type Output = T
Should always be
Self