Struct apache_avro::rabin::Rabin

source ·
pub struct Rabin { /* private fields */ }
Expand description

Implementation of the Rabin fingerprint algorithm using the Digest trait as described in schema_fingerprints.

The digest is returned as the 8-byte little-endian encoding of the Rabin hash. This is what is used for avro single object encoding

use apache_avro::rabin::Rabin;
use digest::Digest;
use hex_literal::hex;

// create the Rabin hasher
let mut hasher = Rabin::new();

// add the data
hasher.update(b"hello world");

// read hash digest and consume hasher
let result = hasher.finalize();

assert_eq!(result[..], hex!("60335ba6d0415528"));

To convert the digest to the commonly used 64-bit integer value, you can use the i64::from_le_bytes() function






let i = i64::from_le_bytes(result.try_into().unwrap());

assert_eq!(i, 2906301498937520992)

Trait Implementations§

source§

impl Clone for Rabin

source§

fn clone(&self) -> Rabin

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Default for Rabin

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl FixedOutput for Rabin

source§

fn finalize_into(self, out: &mut GenericArray<u8, Self::OutputSize>)

Consume value and write result into provided array.
source§

fn finalize_fixed(self) -> GenericArray<u8, Self::OutputSize>

Retrieve result and consume the hasher instance.
source§

impl FixedOutputReset for Rabin

source§

fn finalize_into_reset(&mut self, out: &mut Output<Self>)

Write result into provided array and reset the hasher state.
source§

fn finalize_fixed_reset(&mut self) -> GenericArray<u8, Self::OutputSize>

Retrieve result and reset the hasher state.
source§

impl OutputSizeUser for Rabin

§

type OutputSize = UInt<UInt<UInt<UInt<UTerm, B1>, B0>, B0>, B0>

Size of the output in bytes.
§

fn output_size() -> usize

Return output size in bytes.
source§

impl Reset for Rabin

source§

fn reset(&mut self)

Reset state to its initial value.
source§

impl Update for Rabin

source§

fn update(&mut self, data: &[u8])

Update state using the provided data.
source§

fn chain(self, data: impl AsRef<[u8]>) -> Selfwhere Self: Sized,

Digest input data in a chained manner.
source§

impl HashMarker for Rabin

Auto Trait Implementations§

§

impl RefUnwindSafe for Rabin

§

impl Send for Rabin

§

impl Sync for Rabin

§

impl Unpin for Rabin

§

impl UnwindSafe for Rabin

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<D> Digest for Dwhere D: FixedOutput + Default + Update + HashMarker,

source§

fn new() -> D

Create new hasher instance.
source§

fn new_with_prefix(data: impl AsRef<[u8]>) -> Dwhere D: Default,

Create new hasher instance which has processed the provided data.
source§

fn update(&mut self, data: impl AsRef<[u8]>)

Process data, updating the internal state.
source§

fn chain_update(self, data: impl AsRef<[u8]>) -> D

Process input data in a chained manner.
source§

fn finalize(self) -> GenericArray<u8, <D as OutputSizeUser>::OutputSize>

Retrieve result and consume hasher instance.
source§

fn finalize_into( self, out: &mut GenericArray<u8, <D as OutputSizeUser>::OutputSize> )

Write result into provided array and consume the hasher instance.
source§

fn finalize_reset( &mut self ) -> GenericArray<u8, <D as OutputSizeUser>::OutputSize>where D: FixedOutputReset,

Retrieve result and reset hasher instance.
source§

fn finalize_into_reset( &mut self, out: &mut GenericArray<u8, <D as OutputSizeUser>::OutputSize> )where D: FixedOutputReset,

Write result into provided array and reset the hasher instance.
source§

fn reset(&mut self)where D: Reset,

Reset hasher instance to its initial state.
source§

fn output_size() -> usize

Get output size of the hasher
source§

fn digest( data: impl AsRef<[u8]> ) -> GenericArray<u8, <D as OutputSizeUser>::OutputSize>

Compute hash of data.
source§

impl<D> DynDigest for Dwhere D: Update + FixedOutputReset + Reset + Clone + 'static,

source§

fn update(&mut self, data: &[u8])

Digest input data. Read more
source§

fn finalize_into(self, buf: &mut [u8]) -> Result<(), InvalidBufferSize>

Write result into provided array and consume the hasher instance. Read more
source§

fn finalize_into_reset( &mut self, buf: &mut [u8] ) -> Result<(), InvalidBufferSize>

Write result into provided array and reset the hasher instance. Read more
source§

fn reset(&mut self)

Reset hasher instance to its initial state.
source§

fn output_size(&self) -> usize

Get output size of the hasher
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

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

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.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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.
source§

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

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V