Struct PartitionedFilter 

pub struct PartitionedFilter<T> {
    pub filter: T,
    pub cursor: Option<String>,
    pub limit: Option<u32>,
    pub partition: Option<Partition>,
}

A wrapper around a filter, with cursor, limit, and partition.

Fields

filter: T

Filter results.

cursor: Option<String>

Cursor for pagination.

limit: Option<u32>

Maximum number of results to return.

partition: Option<Partition>

Partition to use.

Implementations

impl<T> PartitionedFilter<T>

pub fn new( filter: T, cursor: Option<String>, limit: Option<u32>, partition: Option<Partition>, ) -> PartitionedFilter<T>

Create a new partitioned filter.

Arguments

• filter - Filter results.
• cursor - Cursor for pagination.
• limit - Maximum number of results to return.
• partition - Partition to use.

Trait Implementations

impl<T: Clone> Clone for PartitionedFilter<T>

fn clone(&self) -> PartitionedFilter<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for PartitionedFilter<T>

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

Formats the value using the given formatter.

impl FilterWithRequest<PartitionedFilter<FileFilter>, FileMetadata> for Files

fn filter( &self, filter: TFilter, ) -> impl Future<Output = Result<ItemsVec<TResponse, Cursor>>> + Send

Filter resources.

fn filter_all( &self, filter: TFilter, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TFilter: SetCursor, TResponse: Send,

Filter resources, following cursors until they are exhausted.

fn filter_all_stream( &self, filter: TFilter, ) -> impl TryStream<Ok = TResponse, Error = Error, Item = Result<TResponse>> + Send

where TFilter: SetCursor, TResponse: Send + 'static,

Filter resources, following cursors. This returns a stream, you can abort the stream whenever you want and only resources retrieved up to that point will be returned.

fn filter_all_partitioned( &self, filter: TFilter, num_partitions: u32, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TFilter: SetCursor + WithPartition, TResponse: Send,

Filter resources using partitioned reads, following cursors until all partitions are exhausted.

fn filter_all_partitioned_stream( &self, filter: TFilter, num_partitions: u32, ) -> impl TryStream<Ok = TResponse, Error = Error, Item = Result<TResponse>> + Send

where TFilter: SetCursor + WithPartition, TResponse: Send + 'static,

Filter resources using partitioned reads, following cursors until all partitions are exhausted. This returns a stream.

impl<T> Serialize for PartitionedFilter<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> SetCursor for PartitionedFilter<T>

fn set_cursor(&mut self, cursor: Option<String>)

Set cursor to the given value.

impl<T> WithPartition for PartitionedFilter<T>

where T: Clone,

fn with_partition(&self, partition: Partition) -> Self

Create a clone of self with given partition.