Struct BufferCacheBuilder 

pub struct BufferCacheBuilder<K, V, S = RandomState> { /* private fields */ }

Builds the cache layout used by DBSP runtime worker pairs.

Implementations

impl<K, V> BufferCacheBuilder<K, V, RandomState>

pub fn new() -> Self

Creates a builder that uses the default hash builder.

impl<K, V, S> BufferCacheBuilder<K, V, S>

pub fn with_buffer_cache_strategy(self, strategy: BufferCacheStrategy) -> Self

Sets the eviction strategy for caches created by this builder.

pub fn with_buffer_max_buckets(self, max_buckets: Option<usize>) -> Self

Sets the optional shard-count override for sharded backends.

pub fn with_buffer_cache_allocation_strategy( self, allocation_strategy: BufferCacheAllocationStrategy, ) -> Self

Sets how caches are shared across each worker pair.

pub fn with_hash_builder<NewS>( self, hash_builder: NewS, ) -> BufferCacheBuilder<K, V, NewS>

Sets the hash builder used for newly constructed caches.

impl<K, V, S> BufferCacheBuilder<K, V, S>

where K: Eq + Hash + Ord + Clone + Debug + Send + Sync + 'static, V: CacheEntry + Clone + Send + Sync + 'static, S: BuildHasher + Clone + Send + Sync + 'static,

pub fn build( &self, worker_pairs: usize, total_capacity_bytes: usize, ) -> Vec<EnumMap<ThreadType, SharedBufferCache<K, V>>>

Builds one cache slot per ThreadType for each worker pair.

pub fn build_single(&self, capacity_bytes: usize) -> SharedBufferCache<K, V>

Builds one cache instance using the currently selected strategy.

Trait Implementations

impl<K, V> Default for BufferCacheBuilder<K, V, RandomState>

fn default() -> Self

Returns the “default value” for a type.