asap_sketchlib 0.2.1

A high-performance sketching library for approximate stream processing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Native MessagePack codec impls for [`crate::sketches::hll`].

use crate::message_pack_format::{Error, MessagePackCodec};
use crate::sketches::hll::{HyperLogLogHIPImpl, HyperLogLogImpl};
use crate::{HllRegisterStorage, SketchHasher};

impl<Variant, Registers: HllRegisterStorage, H: SketchHasher> MessagePackCodec
    for HyperLogLogImpl<Variant, Registers, H>
{
    fn to_msgpack(&self) -> Result<Vec<u8>, Error> {
        Ok(self.serialize_to_bytes()?)
    }

    fn from_msgpack(bytes: &[u8]) -> Result<Self, Error> {
        Ok(Self::deserialize_from_bytes(bytes)?)
    }
}

impl<Registers: HllRegisterStorage> MessagePackCodec for HyperLogLogHIPImpl<Registers> {
    fn to_msgpack(&self) -> Result<Vec<u8>, Error> {
        Ok(self.serialize_to_bytes()?)
    }

    fn from_msgpack(bytes: &[u8]) -> Result<Self, Error> {
        Ok(Self::deserialize_from_bytes(bytes)?)
    }
}