Struct StreamConfig 

pub struct StreamConfig {

    pub column_mapping: Option<ColumnMapping>,
    pub event_signature: Option<String>,
    pub hex_output: HexOutput,
    pub batch_size: Option<u64>,
    pub max_batch_size: Option<u64>,
    pub min_batch_size: Option<u64>,
    pub concurrency: Option<usize>,
    pub max_num_blocks: Option<usize>,
    pub max_num_transactions: Option<usize>,
    pub max_num_logs: Option<usize>,
    pub max_num_traces: Option<usize>,
    pub response_bytes_ceiling: Option<u64>,
    pub response_bytes_floor: Option<u64>,
    pub reverse: Option<bool>,
}

Config for hypersync event streaming.

Fields

column_mapping: Option<ColumnMapping>

Column mapping for stream function output. It lets you map columns you want into the DataTypes you want.

event_signature: Option<String>

Event signature used to populate decode logs. Decode logs would be empty if set to None.

hex_output: HexOutput

Determines formatting of binary columns numbers into utf8 hex.

batch_size: Option<u64>

Initial batch size. Size would be adjusted based on response size during execution.

max_batch_size: Option<u64>

Maximum batch size that could be used during dynamic adjustment.

min_batch_size: Option<u64>

Minimum batch size that could be used during dynamic adjustment.

concurrency: Option<usize>

Number of async threads that would be spawned to execute different block ranges of queries.

max_num_blocks: Option<usize>

Max number of blocks to fetch in a single request.

max_num_transactions: Option<usize>

Max number of transactions to fetch in a single request.

max_num_logs: Option<usize>

Max number of logs to fetch in a single request.

max_num_traces: Option<usize>

Max number of traces to fetch in a single request.

response_bytes_ceiling: Option<u64>

Size of a response in bytes from which step size will be lowered

response_bytes_floor: Option<u64>

Size of a response in bytes from which step size will be increased

reverse: Option<bool>

Stream data in reverse order

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> StreamConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.