pub(crate) struct ContextInner {
pub task_id: i32,
pub sample_path: PathBuf,
pub config: HashMap<String, String>,
pub emitter: Arc<dyn TransportEmitter + Send + Sync>,
pub result_tx: Mutex<Option<ResultSender>>,
pub stash: Option<Arc<ResultStash>>,
pub claimed_paths: Mutex<HashSet<PathBuf>>,
}Fields§
§task_id: i32§sample_path: PathBuf§config: HashMap<String, String>§emitter: Arc<dyn TransportEmitter + Send + Sync>§result_tx: Mutex<Option<ResultSender>>§stash: Option<Arc<ResultStash>>§claimed_paths: Mutex<HashSet<PathBuf>>Auto Trait Implementations§
impl !Freeze for ContextInner
impl !RefUnwindSafe for ContextInner
impl Send for ContextInner
impl Sync for ContextInner
impl Unpin for ContextInner
impl UnsafeUnpin for ContextInner
impl !UnwindSafe for ContextInner
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].