List of all items

Structs

• Indexer
• IndexerArgs
• cluster::Args
• cluster::IndexerCluster
• ingestion::ClientArgs
• ingestion::IngestionConfig
• ingestion::IngestionService
• ingestion::client::IngestionClient
• metrics::IndexerMetrics
• pipeline::CommitterConfig
• pipeline::concurrent::ConcurrentConfig
• pipeline::concurrent::PrunerConfig
• pipeline::sequential::SequentialConfig
• postgres::Connection
• postgres::Db
• postgres::DbArgs
• postgres::query::Query
• postgres::schema::watermarks::checkpoint_hi_inclusive
• postgres::schema::watermarks::columns::checkpoint_hi_inclusive
• postgres::schema::watermarks::columns::epoch_hi_inclusive
• postgres::schema::watermarks::columns::pipeline
• postgres::schema::watermarks::columns::pruner_hi
• postgres::schema::watermarks::columns::pruner_timestamp
• postgres::schema::watermarks::columns::reader_lo
• postgres::schema::watermarks::columns::star
• postgres::schema::watermarks::columns::timestamp_ms_hi_inclusive
• postgres::schema::watermarks::columns::tx_hi
• postgres::schema::watermarks::dsl::checkpoint_hi_inclusive
• postgres::schema::watermarks::dsl::epoch_hi_inclusive
• postgres::schema::watermarks::dsl::pipeline
• postgres::schema::watermarks::dsl::pruner_hi
• postgres::schema::watermarks::dsl::pruner_timestamp
• postgres::schema::watermarks::dsl::reader_lo
• postgres::schema::watermarks::dsl::timestamp_ms_hi_inclusive
• postgres::schema::watermarks::dsl::tx_hi
• postgres::schema::watermarks::dsl::watermarks
• postgres::schema::watermarks::epoch_hi_inclusive
• postgres::schema::watermarks::pipeline
• postgres::schema::watermarks::pruner_hi
• postgres::schema::watermarks::pruner_timestamp
• postgres::schema::watermarks::reader_lo
• postgres::schema::watermarks::star
• postgres::schema::watermarks::table
• postgres::schema::watermarks::timestamp_ms_hi_inclusive
• postgres::schema::watermarks::tx_hi
• postgres::temp::LocalDatabase
• postgres::temp::TempDb

Enums

• ingestion::client::FetchData
• ingestion::client::FetchError
• ingestion::error::Error

Traits

• FieldCount
• pipeline::Processor
• pipeline::concurrent::Handler
• pipeline::sequential::Handler
• postgres::FieldCount
• postgres::store::Store
• task::TrySpawnStreamExt

Macros

• postgres::sql

Derive Macros

• FieldCount
• postgres::FieldCount

Functions

• postgres::merge_migrations
• postgres::reset_database
• postgres::temp::get_available_port

Type Aliases

• Result
• ingestion::client::FetchResult
• ingestion::error::Result
• postgres::schema::watermarks::BoxedQuery
• postgres::schema::watermarks::SqlType

Constants

• postgres::MIGRATIONS
• postgres::schema::watermarks::all_columns