pub struct DistributorImpl { /* private fields */ }Expand description
Concrete Distributor implementation.
Implementations§
Source§impl DistributorImpl
impl DistributorImpl
Sourcepub fn new(hmac_key: Vec<u8>, corrector: Box<dyn ErrorCorrector>) -> Self
pub fn new(hmac_key: Vec<u8>, corrector: Box<dyn ErrorCorrector>) -> Self
Create a new distributor with the given HMAC key and error corrector.
Sourcepub fn new_with_shard_config(
hmac_key: Vec<u8>,
data_shards: u8,
parity_shards: u8,
corrector: Box<dyn ErrorCorrector>,
) -> Self
pub fn new_with_shard_config( hmac_key: Vec<u8>, data_shards: u8, parity_shards: u8, corrector: Box<dyn ErrorCorrector>, ) -> Self
Create a new distributor with explicit data/parity shard counts.
Sourcepub fn generate_hmac_key() -> Vec<u8> ⓘ
pub fn generate_hmac_key() -> Vec<u8> ⓘ
Generate a random 32-byte HMAC key.
Trait Implementations§
Source§impl Default for DistributorImpl
impl Default for DistributorImpl
Source§impl Distributor for DistributorImpl
impl Distributor for DistributorImpl
Source§fn distribute(
&self,
payload: &Payload,
profile: &EmbeddingProfile,
covers: Vec<CoverMedia>,
embedder: &dyn EmbedTechnique,
) -> Result<Vec<CoverMedia>, DistributionError>
fn distribute( &self, payload: &Payload, profile: &EmbeddingProfile, covers: Vec<CoverMedia>, embedder: &dyn EmbedTechnique, ) -> Result<Vec<CoverMedia>, DistributionError>
Auto Trait Implementations§
impl Freeze for DistributorImpl
impl !RefUnwindSafe for DistributorImpl
impl !Send for DistributorImpl
impl !Sync for DistributorImpl
impl Unpin for DistributorImpl
impl UnsafeUnpin for DistributorImpl
impl !UnwindSafe for DistributorImpl
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more