Enum ParallelStrategy 

pub enum ParallelStrategy {
    None,
    Batches(usize),
    Auto,
}

Strategy for parallel processing of Redis operations.

Controls how batch fetching is parallelized to improve throughput on large datasets.

Example

use polars_redis::options::{ScanOptions, ParallelStrategy};

// Use 4 parallel workers for batch fetching
let opts = ScanOptions::new("user:*")
    .with_parallel(ParallelStrategy::Batches(4));

// Let the library choose based on dataset size
let opts = ScanOptions::new("user:*")
    .with_parallel(ParallelStrategy::Auto);

Variants

None

Sequential processing (default, current behavior).

Keys are scanned and fetched one batch at a time. Best for small datasets or when ordering matters.

Batches(usize)

Parallel batch fetching with N workers.

A single SCAN operation feeds keys to N parallel fetch workers. Each worker fetches data for a subset of keys concurrently.

Recommended values: 2-8 workers depending on Redis server capacity.

Auto

Automatically select strategy based on hints.

• Uses None for small datasets (< 1000 keys)
• Uses Batches(4) for larger datasets

Implementations

impl ParallelStrategy

pub fn batches(n: usize) -> Self

Create a parallel strategy with the given number of workers.

pub fn is_parallel(&self) -> bool

Check if this strategy enables parallel processing.

pub fn worker_count(&self) -> usize

Get the number of workers for this strategy.

Returns 1 for None, the specified count for Batches, and a default of 4 for Auto.

pub fn resolve(&self, estimated_keys: Option<usize>) -> ParallelStrategy

Resolve Auto strategy based on estimated key count.

Trait Implementations

impl Clone for ParallelStrategy

fn clone(&self) -> ParallelStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelStrategy

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

Formats the value using the given formatter.

impl Default for ParallelStrategy

fn default() -> ParallelStrategy

Returns the “default value” for a type.

impl Hash for ParallelStrategy

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ParallelStrategy

fn eq(&self, other: &ParallelStrategy) -> 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 Copy for ParallelStrategy

impl Eq for ParallelStrategy

impl StructuralPartialEq for ParallelStrategy