pub struct Stream {Show 32 fields
pub id: String,
pub name: String,
pub status: String,
pub created_at: String,
pub updated_at: String,
pub sequence: i64,
pub network: String,
pub dataset: String,
pub region: String,
pub start_range: i64,
pub end_range: i64,
pub plan: Option<String>,
pub threshold_fetch_buffer: Option<i64>,
pub dataset_batch_size: Option<i64>,
pub max_batch_size: Option<i64>,
pub max_buffer_range_size: Option<i64>,
pub max_buffer_processing_workers: Option<i64>,
pub keep_distance_from_tip: Option<i64>,
pub filter_function: Option<String>,
pub filter_language: Option<String>,
pub include_stream_metadata: Option<String>,
pub product_type: Option<String>,
pub notification_email: Option<String>,
pub fix_block_reorgs: Option<i32>,
pub current_hash: Option<String>,
pub destination_attributes: Option<DestinationAttributes>,
pub elastic_batch_enabled: Option<bool>,
pub qn_account_id: Option<String>,
pub charge_min_cap: Option<i32>,
pub memo: Option<String>,
pub address_book_config: Option<AddressBookConfig>,
pub extra_destinations: Option<Vec<DestinationAttributes>>,
}Expand description
A stream’s full configuration and current state, as returned by the API.
Fields§
§id: StringUnique stream identifier.
name: StringHuman-readable stream name.
status: StringCurrent operational state (e.g. active, paused).
created_at: StringTimestamp when the stream was created.
updated_at: StringTimestamp of the most recent modification.
sequence: i64Sequence number tracking stream progress.
network: StringBlockchain network the stream is reading from.
dataset: StringDataset being streamed.
region: StringGeographic region where the stream runs.
start_range: i64Starting block for the stream.
end_range: i64Ending block for the stream; -1 indicates continuous operation.
plan: Option<String>Billing plan associated with the stream.
threshold_fetch_buffer: Option<i64>Buffer size used by the stream fetcher before delivery.
dataset_batch_size: Option<i64>Number of blocks grouped together per delivered batch.
max_batch_size: Option<i64>Upper bound on batch size when elastic batching is enabled.
max_buffer_range_size: Option<i64>Maximum number of buffered blocks waiting to be processed.
max_buffer_processing_workers: Option<i64>Maximum number of worker threads processing buffered batches.
keep_distance_from_tip: Option<i64>Number of blocks the stream stays behind the chain tip.
filter_function: Option<String>Base64-encoded filter function applied to each batch.
filter_language: Option<String>Language the filter function is written in.
include_stream_metadata: Option<String>Where stream metadata is included in delivered payloads.
product_type: Option<String>Billing product type the stream is associated with.
notification_email: Option<String>Email address notified of stream termination or failure.
fix_block_reorgs: Option<i32>Whether chain-reorg handling is enabled (0 or 1).
current_hash: Option<String>Most recent block hash processed by the stream.
destination_attributes: Option<DestinationAttributes>Destination-specific configuration (present on single-stream responses).
elastic_batch_enabled: Option<bool>Whether elastic batching is active.
qn_account_id: Option<String>Quicknode account ID that owns the stream.
charge_min_cap: Option<i32>Minimum charge cap applied to the stream’s billing.
memo: Option<String>Free-text memo attached to the stream.
address_book_config: Option<AddressBookConfig>Address book linked to the stream’s filter, if any.
extra_destinations: Option<Vec<DestinationAttributes>>Additional destinations receiving the same batches alongside the primary.