Struct mz_persist_client::fetch::BatchFetcher

pub struct BatchFetcher<K, V, T, D>
where
    T: Timestamp + Lattice + Codec64,
    K: Debug + Codec,
    V: Debug + Codec,
    D: Semigroup + Codec64 + Send + Sync,
{
    pub(crate) cfg: BatchFetcherConfig,
    pub(crate) blob: Arc<dyn Blob>,
    pub(crate) metrics: Arc<Metrics>,
    pub(crate) shard_metrics: Arc<ShardMetrics>,
    pub(crate) shard_id: ShardId,
    pub(crate) read_schemas: Schemas<K, V>,
    pub(crate) schema_cache: SchemaCache<K, V, T, D>,
    pub(crate) is_transient: bool,
    pub(crate) _phantom: PhantomData<fn() -> (K, V, T, D)>,
}

Capable of fetching LeasedBatchPart while not holding any capabilities.

Fields

cfg: BatchFetcherConfig

blob: Arc<dyn Blob>

metrics: Arc<Metrics>

shard_metrics: Arc<ShardMetrics>

shard_id: ShardId

read_schemas: Schemas<K, V>

schema_cache: SchemaCache<K, V, T, D>

is_transient: bool

_phantom: PhantomData<fn() -> (K, V, T, D)>

Implementations

impl<K, V, T, D> BatchFetcher<K, V, T, D>

where K: Debug + Codec, V: Debug + Codec, T: Timestamp + Lattice + Codec64 + Sync, D: Semigroup + Codec64 + Send + Sync,

pub fn leased_part_from_exchangeable( &self, x: SerdeLeasedBatchPart, ) -> LeasedBatchPart<T>

Takes a SerdeLeasedBatchPart into a LeasedBatchPart.

pub async fn fetch_leased_part( &mut self, part: &LeasedBatchPart<T>, ) -> Result<FetchedBlob<K, V, T, D>, InvalidUsage<T>>

Trade in an exchange-able LeasedBatchPart for the data it represents.

Note to check the LeasedBatchPart documentation for how to handle the returned value.

Trait Implementations

impl<K, V, T, D> Debug for BatchFetcher<K, V, T, D>

where T: Timestamp + Lattice + Codec64 + Debug, K: Debug + Codec + Debug, V: Debug + Codec + Debug, D: Semigroup + Codec64 + Send + Sync + Debug,

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

Formats the value using the given formatter.