Struct StreamConfig 

pub struct StreamConfig {

    pub column_mapping: Option<ColumnMapping>,
    pub event_signature: Option<String>,
    pub hex_output: HexOutput,
    pub batch_size: u64,
    pub max_batch_size: u64,
    pub min_batch_size: u64,
    pub concurrency: 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: u64,
    pub response_bytes_floor: u64,
    pub reverse: 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: u64

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

max_batch_size: u64

Maximum batch size that could be used during dynamic adjustment.

min_batch_size: u64

Minimum batch size that could be used during dynamic adjustment.

concurrency: 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: u64

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

response_bytes_floor: u64

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

reverse: bool

Stream data in reverse order

Implementations

impl StreamConfig

pub const fn default_concurrency() -> usize

Default concurrency for stream processing

pub const fn default_batch_size() -> u64

Default initial batch size

pub const fn default_max_batch_size() -> u64

Default maximum batch size

pub const fn default_min_batch_size() -> u64

Default minimum batch size

pub const fn default_response_bytes_ceiling() -> u64

Default response bytes ceiling for dynamic batch adjustment

pub const fn default_response_bytes_floor() -> u64

Default response bytes floor for dynamic batch adjustment

pub const fn default_reverse() -> bool

Default reverse streaming setting

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() -> Self

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 JsonSchema for StreamConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

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.