Struct redis_driver::ZInterUnionStore

source · [−]

pub struct ZInterUnionStore<'a, T>where
    T: SortedSetCommands + ?Sized,{ /* private fields */ }

Expand description

Builder for the zinterstore and zunionstore commands

Implementations

impl<'a, T> ZInterUnionStore<'a, T>where
T: SortedSetCommands + ?Sized,

pub fn weights<W>(self, weights: W) -> Selfwhere
W: SingleArgOrCollection<f64>,

Using the WEIGHTS option, it is possible to specify a multiplication factor for each input sorted set.

This means that the score of every element in every input sorted set is multiplied by this factor before being passed to the aggregation function. When WEIGHTS is not given, the multiplication factors default to 1.

pub fn aggregate(self, aggregate: ZAggregate) -> Self

With the AGGREGATE option, it is possible to specify how the results of the union are aggregated.

This option defaults to SUM, where the score of an element is summed across the inputs where it exists. When this option is set to either MIN or MAX, the resulting set will contain the minimum or maximum score of an element across the inputs where it exists.

pub fn execute(self) -> Pin<Box<dyn Future<Output = Result<usize>> + 'a>>

The number of elements in the resulting sorted set at destination.

Auto Trait Implementations

impl<'a, T: ?Sized> RefUnwindSafe for ZInterUnionStore<'a, T>where
T: RefUnwindSafe,

impl<'a, T: ?Sized> Send for ZInterUnionStore<'a, T>where
T: Sync,

impl<'a, T: ?Sized> Sync for ZInterUnionStore<'a, T>where
T: Sync,

impl<'a, T: ?Sized> Unpin for ZInterUnionStore<'a, T>

impl<'a, T: ?Sized> UnwindSafe for ZInterUnionStore<'a, T>where
T: RefUnwindSafe,

Blanket Implementations

impl<T> Any for Twhere
T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for Twhere
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for Twhere
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more