Struct External

Source

pub struct External<'a, Tag> { /* private fields */ }

Expand description

A handle representing an external process that can communicate with the Hydro dataflow.

External processes live outside the compiled dataflow graph and interact with it by sending and receiving data through ports. Use methods on Location such as source_external_bytes, source_external_bincode, and bind_single_client to establish communication channels between a location and an external process.

The Tag type parameter is a user-defined marker type that distinguishes different external process roles at the type level.

External

Struct External Copy item path

Trait Implementations§

impl<P> Clone for External<'_, P>

fn clone(&self) -> Self

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

Auto Trait Implementations§

impl<'a, Tag> Freeze for External<'a, Tag>

impl<'a, Tag> !RefUnwindSafe for External<'a, Tag>

impl<'a, Tag> !Send for External<'a, Tag>

impl<'a, Tag> !Sync for External<'a, Tag>

impl<'a, Tag> Unpin for External<'a, Tag>where Tag: Unpin,

impl<'a, Tag> UnsafeUnpin for External<'a, Tag>

impl<'a, Tag> !UnwindSafe for External<'a, Tag>

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

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 Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T> ToSinkBuild for T

fn iter_to_sink_build(self) -> SendIterBuild<Self>where Self: Sized + Iterator,

fn stream_to_sink_build(self) -> SendStreamBuild<Self>where Self: Sized + Stream,

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

type Error = Infallible

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

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

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

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

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

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> ⓘ

Struct External

impl<'a, Tag> Unpin for External<'a, Tag>
where Tag: Unpin,

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<T> CloneToUninit for T
where T: Clone,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

impl<T> ToOwned for T
where T: Clone,

fn iter_to_sink_build(self) -> SendIterBuild<Self>
where Self: Sized + Iterator,

fn stream_to_sink_build(self) -> SendStreamBuild<Self>
where Self: Sized + Stream,

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>,