pub struct OpaqueOutputPublisher;Expand description
Broadcast output publication requiring no point-to-point or barrier capability.
Trait Implementations§
Source§impl Clone for OpaqueOutputPublisher
impl Clone for OpaqueOutputPublisher
Source§fn clone(&self) -> OpaqueOutputPublisher
fn clone(&self) -> OpaqueOutputPublisher
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for OpaqueOutputPublisher
Source§impl Debug for OpaqueOutputPublisher
impl Debug for OpaqueOutputPublisher
Source§impl Default for OpaqueOutputPublisher
impl Default for OpaqueOutputPublisher
Source§fn default() -> OpaqueOutputPublisher
fn default() -> OpaqueOutputPublisher
Returns the “default value” for a type. Read more
Source§impl<B, G, R, I> PartitionOutputPublisher<B, G, R, I> for OpaqueOutputPublisherwhere
B: CommunicationBackend + BroadcastBackend,
G: Borrow<B::CommunicationGroup>,
R: Borrow<B::CommunicationRoute>,
I: CommunicationTensorMetadata<B>,
impl<B, G, R, I> PartitionOutputPublisher<B, G, R, I> for OpaqueOutputPublisherwhere
B: CommunicationBackend + BroadcastBackend,
G: Borrow<B::CommunicationGroup>,
R: Borrow<B::CommunicationRoute>,
I: CommunicationTensorMetadata<B>,
Source§fn publish(
&mut self,
communication: &PartitionCommunication<B, G, R, I>,
value: B::Tensor,
publication: PartitionOutputPublication,
phase: DistributedExecutionPhase,
executor: &B::Executor,
) -> Result<B::Tensor, PartitionExecutionError>
fn publish( &mut self, communication: &PartitionCommunication<B, G, R, I>, value: B::Tensor, publication: PartitionOutputPublication, phase: DistributedExecutionPhase, executor: &B::Executor, ) -> Result<B::Tensor, PartitionExecutionError>
Publishes source data on root and destination storage on other members.
Auto Trait Implementations§
impl Freeze for OpaqueOutputPublisher
impl RefUnwindSafe for OpaqueOutputPublisher
impl Send for OpaqueOutputPublisher
impl Sync for OpaqueOutputPublisher
impl Unpin for OpaqueOutputPublisher
impl UnsafeUnpin for OpaqueOutputPublisher
impl UnwindSafe for OpaqueOutputPublisher
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