Struct Query

pub struct Query<Q: QueryType> { /* private fields */ }

Represents a query for a specific batch identifier, received from a Collector as part of the collection flow.

Implementations

impl<Q: QueryType> Query<Q>

pub fn new(query_body: Q::QueryBody) -> Self

Constructs a new query from its components.

This method would typically be used for code which is generic over the query type. Query-type specific code will typically call one of Self::new_time_interval or Self::new_fixed_size.

pub fn query_body(&self) -> &Q::QueryBody

Gets the query body included in this query.

This method would typically be used for code which is generic over the query type. Query-type specific code will typically call one of Self::batch_interval or Self::fixed_size_query.

impl Query<TimeInterval>

pub fn new_time_interval(batch_interval: Interval) -> Self

Constructs a new query for a time-interval task.

pub fn batch_interval(&self) -> &Interval

Gets the batch interval associated with this query.

impl Query<FixedSize>

pub fn new_fixed_size(fixed_size_query: FixedSizeQuery) -> Self

Constructs a new query for a fixed-size task.

pub fn fixed_size_query(&self) -> &FixedSizeQuery

Gets the fixed size query associated with this query.

Trait Implementations

impl<Q: Clone + QueryType> Clone for Query<Q>

where Q::QueryBody: Clone,

fn clone(&self) -> Query<Q>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Q: Debug + QueryType> Debug for Query<Q>

where Q::QueryBody: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Q: QueryType> Decode for Query<Q>

fn decode(bytes: &mut Cursor<&[u8]>) -> Result<Self, CodecError>

Read and decode an encoded object from bytes. On success, the decoded value is returned and bytes is advanced by the encoded size of the value. On failure, an error is returned and no further attempt to read from bytes should be made.

fn get_decoded(bytes: &[u8]) -> Result<Self, CodecError>

Convenience method to get a decoded value. Returns an error if Self::decode fails, or if there are any bytes left in bytes after decoding a value.

impl<Q: QueryType> Encode for Query<Q>

fn encode(&self, bytes: &mut Vec<u8>) -> Result<(), CodecError>

Append the encoded form of this object to the end of bytes, growing the vector as needed.

fn encoded_len(&self) -> Option<usize>

Returns an optional hint indicating how many bytes will be required to encode this value, or None by default.

fn get_encoded(&self) -> Result<Vec<u8>, CodecError>

Convenience method to encode a value into a new Vec<u8>.

impl<Q: PartialEq + QueryType> PartialEq for Query<Q>

where Q::QueryBody: PartialEq,

fn eq(&self, other: &Query<Q>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<Q: Eq + QueryType> Eq for Query<Q>

where Q::QueryBody: Eq,

impl<Q: QueryType> StructuralPartialEq for Query<Q>