hdp 0.9.0

All Herodotus Data Processor
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
28
29
30
31
32
33
34
35
36
37

use serde::{Deserialize, Serialize};

use super::{
    block_sampled::BlockSampledDatalake, transactions::TransactionsInBlockDatalake,
    DatalakeCollection,
};

pub type BatchedDatalakes = Vec<DatalakeEnvelope>;

/// Envelope for datalake
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(tag = "type")]
pub enum DatalakeEnvelope {
    BlockSampled(BlockSampledDatalake),
    TransactionsInBlock(TransactionsInBlockDatalake),
}

impl DatalakeEnvelope {
    pub fn get_collection_type(&self) -> Box<dyn DatalakeCollection> {
        match self {
            DatalakeEnvelope::BlockSampled(datalake) => Box::new(datalake.sampled_property),
            DatalakeEnvelope::TransactionsInBlock(datalake) => Box::new(datalake.sampled_property),
        }
    }

    pub fn get_chain_id(&self) -> crate::primitives::ChainId {
        match self {
            DatalakeEnvelope::BlockSampled(datalake) => datalake.chain_id,
            DatalakeEnvelope::TransactionsInBlock(datalake) => datalake.chain_id,
        }
    }
}

/// Default increment for datalake
pub fn default_increment() -> u64 {
    1
}