Struct dataflow::render::sources::BoundedCompactionHandle [−][src]
struct BoundedCompactionHandle {
upper_bound_probe: ProbeHandle<Timestamp>,
compaction_handle: MultiWriteHandle,
}
Expand description
A handle that allows setting a compaction frontier that is bounded by an upper bound.
Fields
upper_bound_probe: ProbeHandle<Timestamp>
Upper frontier up to which we are not allowed to compact.
compaction_handle: MultiWriteHandle
Underlying compaction handle.
Implementations
pub fn new(
upper_bound_probe: ProbeHandle<Timestamp>,
compaction_handle: MultiWriteHandle
) -> Self
pub fn new(
upper_bound_probe: ProbeHandle<Timestamp>,
compaction_handle: MultiWriteHandle
) -> Self
Creates a new BoundedCompactionHandle
that bounds compaction using the given
upper_bound_fn
and forwards compaction requests to the given compaction_handle
Auto Trait Implementations
impl !RefUnwindSafe for BoundedCompactionHandle
impl !Send for BoundedCompactionHandle
impl !Sync for BoundedCompactionHandle
impl Unpin for BoundedCompactionHandle
impl !UnwindSafe for BoundedCompactionHandle
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more