Skip to main content

Module bytes_exchange

timely::communication::allocator::zero_copy

Module bytes_exchange 

Source
Expand description

Types and traits for sharing Bytes.

Structs§

MergeQueue
An unbounded queue of bytes intended for point-to-point communication between threads. Writer/reader handle pairs are obtained via MergeQueue::new_pair.
SendEndpoint
A BytesPush wrapper which stages writes.

Enums§

QueueEntry
An entry in a MergeQueue. Either Bytes resident in memory, or a handle to bytes previously written out via a SpillPolicy.

Traits§

BytesPull
A source for Bytes.
BytesPush
A target for Bytes.