pub struct ClusterClient<Client, Worker, C, R>where
Worker: AsRunnableWorker<C, R>,{
inner: Option<Client>,
timely_container: TimelyContainerRef<C, R, Worker::Activatable>,
persist_clients: Arc<PersistClientCache>,
txns_ctx: TxnsContext,
tokio_handle: Handle,
tracing_handle: Arc<TracingHandle>,
worker: Worker,
}
Expand description
A client managing access to the local portion of a Timely cluster
Fields§
§inner: Option<Client>
The actual client to talk to the cluster
timely_container: TimelyContainerRef<C, R, Worker::Activatable>
The running timely instance
persist_clients: Arc<PersistClientCache>
Handle to the persist infrastructure.
txns_ctx: TxnsContext
Context necessary for rendering txn-wal operators.
tokio_handle: Handle
The handle to the Tokio runtime.
tracing_handle: Arc<TracingHandle>
A process-global handle to tracing configuration.
worker: Worker
Implementations§
Source§impl<Worker, C, R> ClusterClient<Partitioned<LocalClient<C, R, Worker::Activatable>, C, R>, Worker, C, R>where
C: Send + 'static,
R: Send + 'static,
(C, R): Partitionable<C, R>,
Worker: AsRunnableWorker<C, R> + Clone + Send + Sync + 'static,
impl<Worker, C, R> ClusterClient<Partitioned<LocalClient<C, R, Worker::Activatable>, C, R>, Worker, C, R>where
C: Send + 'static,
R: Send + 'static,
(C, R): Partitionable<C, R>,
Worker: AsRunnableWorker<C, R> + Clone + Send + Sync + 'static,
fn new( timely_container: TimelyContainerRef<C, R, Worker::Activatable>, persist_clients: Arc<PersistClientCache>, txns_ctx: TxnsContext, tokio_handle: Handle, tracing_handle: Arc<TracingHandle>, worker_config: Worker, ) -> Self
async fn build_timely( user_worker_config: Worker, config: TimelyConfig, epoch: ClusterStartupEpoch, persist_clients: Arc<PersistClientCache>, txns_ctx: TxnsContext, tracing_handle: Arc<TracingHandle>, tokio_executor: Handle, ) -> Result<TimelyContainer<C, R, Worker::Activatable>, Error>
async fn build( &mut self, config: TimelyConfig, epoch: ClusterStartupEpoch, ) -> Result<(), Error>
Trait Implementations§
Source§impl<Client: Debug, Worker: AsRunnableWorker<C, R>, C, R> Debug for ClusterClient<Client, Worker, C, R>
impl<Client: Debug, Worker: AsRunnableWorker<C, R>, C, R> Debug for ClusterClient<Client, Worker, C, R>
Source§impl<Worker, C, R> GenericClient<C, R> for ClusterClient<Partitioned<LocalClient<C, R, Worker::Activatable>, C, R>, Worker, C, R>where
C: Send + Debug + TryIntoTimelyConfig + 'static,
R: Send + Debug + 'static,
(C, R): Partitionable<C, R>,
Worker: AsRunnableWorker<C, R> + Send + Sync + Clone + 'static,
Worker::Activatable: Send + Sync + 'static + Debug,
impl<Worker, C, R> GenericClient<C, R> for ClusterClient<Partitioned<LocalClient<C, R, Worker::Activatable>, C, R>, Worker, C, R>where
C: Send + Debug + TryIntoTimelyConfig + 'static,
R: Send + Debug + 'static,
(C, R): Partitionable<C, R>,
Worker: AsRunnableWorker<C, R> + Send + Sync + Clone + 'static,
Worker::Activatable: Send + Sync + 'static + Debug,
Source§fn recv<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Option<R>, Error>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn recv<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Option<R>, Error>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
§Cancel safety
This method is cancel safe. If recv
is used as the event in a tokio::select!
statement and some other branch completes first, it is guaranteed that no messages were
received by this client.
Auto Trait Implementations§
impl<Client, Worker, C, R> Freeze for ClusterClient<Client, Worker, C, R>
impl<Client, Worker, C, R> !RefUnwindSafe for ClusterClient<Client, Worker, C, R>
impl<Client, Worker, C, R> Send for ClusterClient<Client, Worker, C, R>
impl<Client, Worker, C, R> Sync for ClusterClient<Client, Worker, C, R>
impl<Client, Worker, C, R> Unpin for ClusterClient<Client, Worker, C, R>
impl<Client, Worker, C, R> !UnwindSafe for ClusterClient<Client, Worker, C, R>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
Source§impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
Source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.Source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.Source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
Source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.