Struct dataflowd::RemoteClient[−][src]

pub struct RemoteClient {
    pub(crate) client: Partitioned<TcpClient>,
}

Expand description

A convenience type for compatibility.

Fields

client: Partitioned<TcpClient>

Implementations

Construct a client backed by multiple tcp connections

Trait Implementations

Sends a command to the dataflow server.

Receives the next response from the dataflow server. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Performs the conversion.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Performs the conversion.

Should always be Self

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct dataflowd::RemoteClient[−][src]

Fields

Implementations

impl RemoteClient

pub async fn connect(addrs: &[impl ToSocketAddrs]) -> Result<Self, Error>

Trait Implementations

impl Client for RemoteClient

fn send<'life0, 'async_trait>( &'life0 mut self, cmd: Command) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn recv<'life0, 'async_trait>( &'life0 mut self) -> Pin<Box<dyn Future<Output = Option<Response>> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

Auto Trait Implementations

impl RefUnwindSafe for RemoteClient

impl Send for RemoteClient

impl Sync for RemoteClient

impl Unpin for RemoteClient

impl UnwindSafe for RemoteClient

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<C> ComputeClient for C where C: Client,

fn create_instance<'life0, 'async_trait>( &'life0 mut self, instance: usize) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn drop_instance<'life0, 'async_trait>( &'life0 mut self, instance: usize) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn create_dataflows<'life0, 'async_trait>( &'life0 mut self, instance: usize, dataflows: Vec<DataflowDescription<Plan>, Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn drop_sinks<'life0, 'async_trait>( &'life0 mut self, instance: usize, sink_identifiers: Vec<GlobalId, Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn drop_indexes<'life0, 'async_trait>( &'life0 mut self, instance: usize, index_identifiers: Vec<GlobalId, Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn cancel_peek<'life0, 'async_trait>( &'life0 mut self, instance: usize, conn_id: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn allow_index_compaction<'life0, 'async_trait>( &'life0 mut self, instance: usize, frontiers: Vec<(GlobalId, Antichain<u64>), Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn enable_logging<'life0, 'async_trait>( &'life0 mut self, instance: usize, logging_config: LoggingConfig) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> Same<T> for T

type Output = T

impl<C> StorageClient for C where C: Client,

fn create_sources<'life0, 'async_trait>( &'life0 mut self, source_descriptions: Vec<(GlobalId, (SourceDesc, Antichain<u64>)), Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn drop_sources<'life0, 'async_trait>( &'life0 mut self, source_identifiers: Vec<GlobalId, Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn table_insert<'life0, 'async_trait>( &'life0 mut self, id: GlobalId, updates: Vec<Update, Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn update_durability_frontiers<'life0, 'async_trait>( &'life0 mut self, updates: Vec<(GlobalId, Antichain<u64>), Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn add_source_timestamping<'life0, 'async_trait>( &'life0 mut self, id: GlobalId, connector: SourceConnector, bindings: Vec<(PartitionId, u64, MzOffset), Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn allow_source_compaction<'life0, 'async_trait>( &'life0 mut self, frontiers: Vec<(GlobalId, Antichain<u64>), Global>) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn drop_source_timestamping<'life0, 'async_trait>( &'life0 mut self, id: GlobalId) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

fn advance_all_table_timestamps<'life0, 'async_trait>( &'life0 mut self, advance_to: u64) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where 'life0: 'async_trait, Self: 'async_trait + Send,

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

pub async fn connect(addrs: &[impl ToSocketAddrs ]) -> Result<Self, Error>

fn send<'life0, 'async_trait>(
&'life0 mut self,
cmd: Command
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn recv<'life0, 'async_trait>(
&'life0 mut self
) -> Pin<Box<dyn Future<Output = Option<Response>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<C> ComputeClient for C where
C: Client,

fn create_instance<'life0, 'async_trait>(
&'life0 mut self,
instance: usize
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn drop_instance<'life0, 'async_trait>(
&'life0 mut self,
instance: usize
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn create_dataflows<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
dataflows: Vec<DataflowDescription<Plan>, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn drop_sinks<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
sink_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn drop_indexes<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
index_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn cancel_peek<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
conn_id: u32
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn allow_index_compaction<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
frontiers: Vec<(GlobalId, Antichain<u64>), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn enable_logging<'life0, 'async_trait>(
&'life0 mut self,
instance: usize,
logging_config: LoggingConfig
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

impl<T, U> Into<U> for T where
U: From<T>,

impl<C> StorageClient for C where
C: Client,

fn create_sources<'life0, 'async_trait>(
&'life0 mut self,
source_descriptions: Vec<(GlobalId, (SourceDesc, Antichain<u64>)), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn drop_sources<'life0, 'async_trait>(
&'life0 mut self,
source_identifiers: Vec<GlobalId, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn table_insert<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
updates: Vec<Update, Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn update_durability_frontiers<'life0, 'async_trait>(
&'life0 mut self,
updates: Vec<(GlobalId, Antichain<u64>), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn add_source_timestamping<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId,
connector: SourceConnector,
bindings: Vec<(PartitionId, u64, MzOffset ), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn allow_source_compaction<'life0, 'async_trait>(
&'life0 mut self,
frontiers: Vec<(GlobalId, Antichain<u64>), Global>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn drop_source_timestamping<'life0, 'async_trait>(
&'life0 mut self,
id: GlobalId
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

fn advance_all_table_timestamps<'life0, 'async_trait>(
&'life0 mut self,
advance_to: u64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait + Send,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,