Struct kitsune_p2p::event::QueryOpHashesEvt [−][src]
pub struct QueryOpHashesEvt {
pub space: Arc<KitsuneSpace>,
pub agents: Vec<(Arc<KitsuneAgent>, DhtArcSet)>,
pub window: TimeWindow,
pub max_ops: usize,
pub include_limbo: bool,
}
Expand description
Gather a list of op-hashes from our implementor that meet criteria. Also get the start and end times for ops within a time window up to a maximum number.
Fields
space: Arc<KitsuneSpace>
The “space” context.
agents: Vec<(Arc<KitsuneAgent>, DhtArcSet)>
The agents from which to fetch, along with a DhtArcSet to filter by.
window: TimeWindow
The time window to search within.
max_ops: usize
Maximum number of ops to return.
include_limbo: bool
Include ops that are still in limbo (not yet validated or integrated).
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for QueryOpHashesEvt
impl Send for QueryOpHashesEvt
impl Sync for QueryOpHashesEvt
impl Unpin for QueryOpHashesEvt
impl UnwindSafe for QueryOpHashesEvt
Blanket Implementations
Mutably borrows from an owned value. Read more
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
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
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