Skip to main content

Module stream

Module stream 

Source

Structs§

AddressBookConfig
Links a stream’s filter to an address book so JSON paths resolve against its managed address set.
AzureAttributes
Configuration for delivering stream batches to Azure Blob Storage.
ClickhouseAttributes
Configuration for delivering stream batches to a ClickHouse cluster.
CreateStreamParams
Parameters for creating a new stream.
EnabledCountResponse
Result of get_enabled_count.
KafkaAttributes
Configuration for delivering stream batches to a Kafka topic.
ListStreamsParams
Parameters for list_streams.
ListStreamsResponse
Paginated response from list_streams.
MongoAttributes
Configuration for delivering stream batches to a MongoDB database.
MysqlAttributes
Configuration for delivering stream batches to a MySQL database.
PageInfo
Pagination metadata returned alongside a paginated result set.
PostgresAttributes
Configuration for delivering stream batches to a PostgreSQL database.
RedisAttributes
Configuration for delivering stream batches to a Redis instance.
S3Attributes
Configuration for delivering stream batches to an S3-compatible object store.
SnowflakeAttributes
Configuration for delivering stream batches to a Snowflake data warehouse.
Stream
A stream’s full configuration and current state, as returned by the API.
TestFilterParams
Parameters for test_filter.
TestFilterResponse
Result of a test_filter call.
UpdateStreamParams
Parameters for update_stream. Only fields that are set are modified; omitted fields leave the current value unchanged.
WebhookAttributes
Configuration for delivering stream batches to an HTTP webhook endpoint.

Enums§

DestinationAttributes
Destination-specific configuration for a stream. Exactly one variant selects where and how batches are delivered.
FilterLanguage
Language a stream’s filter function is written in.
ProductType
Billing product type the stream is associated with.
StreamDataset
Type of on-chain data a stream delivers (blocks, transactions, logs, etc.).
StreamDestination
Destination kind a stream delivers to (webhook, S3, Postgres, etc.).
StreamMetadataLocation
Where stream metadata is included in delivered payloads.
StreamRegion
Geographic region where a stream runs.
StreamStatus
Operational state of a stream.