List of all items

Structs

• common::chunk::Chunk
• common::chunk::ChunkCompleted
• common::chunk::ChunkFailed
• common::chunk::ChunkId
• common::chunk::ChunkIndex
• common::chunk::ChunkSize
• common::errors::ChunkNotFound
• common::errors::DatabaseError
• common::errors::IncorrectUsage
• common::errors::LimitIsZero
• common::errors::SubmissionNotFound
• common::errors::TryFromIntError
• common::errors::UnexpectedOpsqueueConsumerServerResponse
• common::submission::Submission
• common::submission::SubmissionCompleted
• common::submission::SubmissionFailed
• common::submission::SubmissionId
• config::Config
• consumer::common::ConsumerConfig
• consumer::common::Envelope
• consumer::dispatcher::Dispatcher
• consumer::dispatcher::metastate::MetaState
• consumer::dispatcher::metastate::MetaStateField
• consumer::dispatcher::reserver::Reserver
• consumer::server::Completer
• consumer::server::ServerState
• consumer::server::conn::ConsumerConn
• consumer::server::conn::ConsumerConnectionId
• consumer::server::conn::RetryReservation
• consumer::server::state::ConsumerState
• db::DBPools
• db::Pool
• db::conn::Conn
• db::conn::Tx
• producer::common::InsertSubmission
• producer::server::InsertSubmissionResponse
• producer::server::ServerState

Enums

• common::errors::E
• common::submission::SubmissionStatus
• consumer::common::AsyncServerToClientMessage
• consumer::common::ClientToServerMessage
• consumer::common::ServerToClientMessage
• consumer::common::SyncServerToClientResponse
• consumer::server::CompleterMessage
• consumer::server::conn::ConsumerConnError
• consumer::strategy::Strategy
• db::conn::NoTransaction
• db::magic::False
• db::magic::True
• producer::common::ChunkContents

Traits

• db::Connection
• db::WriterConnection
• db::magic::Bool

Macros

• E
• fold_both
• map_both

Functions

• common::chunk::db::complete_chunk
• common::chunk::db::complete_chunk_raw
• common::chunk::db::count_chunks
• common::chunk::db::count_chunks_completed
• common::chunk::db::count_chunks_failed
• common::chunk::db::count_ops_in_backlog_estimate
• common::chunk::db::get_chunk
• common::chunk::db::get_chunk_completed
• common::chunk::db::get_chunk_failed
• common::chunk::db::get_chunk_strategic_metadata
• common::chunk::db::insert_chunk
• common::chunk::db::insert_chunk_metadata
• common::chunk::db::insert_many_chunks
• common::chunk::db::insert_many_chunks_metadata
• common::chunk::db::move_chunk_to_failed_chunks
• common::chunk::db::retry_or_fail_chunk
• common::chunk::db::skip_remaining_chunks
• common::submission::db::cleanup_old
• common::submission::db::count_submissions
• common::submission::db::count_submissions_completed
• common::submission::db::count_submissions_failed
• common::submission::db::fail_submission
• common::submission::db::fail_submission_notx
• common::submission::db::get_submission
• common::submission::db::get_submission_strategic_metadata
• common::submission::db::insert_submission_from_chunks
• common::submission::db::insert_submission_metadata_raw
• common::submission::db::insert_submission_raw
• common::submission::db::lookup_id_by_prefix
• common::submission::db::maybe_complete_submission
• common::submission::db::periodically_cleanup_old
• common::submission::db::submission_status
• consumer::server::serve_for_tests
• db::open_and_setup
• producer::server::serve_for_tests
• prometheus::calculate_scaling_metrics
• prometheus::describe_metrics
• prometheus::periodically_calculate_scaling_metrics
• prometheus::setup_prometheus
• prometheus::time_delta_as_f64
• server::app_watchdog
• server::build_router
• server::serve_producer_and_consumer
• server::version_endpoint
• tracing::context_from_headers
• tracing::context_to_headers
• tracing::context_to_json
• tracing::current_context_to_json
• tracing::json_to_carrier
• tracing::json_to_context
• tracing::propagator
• version_info

Type Aliases

• common::MetaStateVal
• common::StrategicMetadataMap
• common::chunk::ChunkCount
• common::chunk::Content
• common::submission::Metadata
• consumer::dispatcher::metastate::Bytes
• consumer::dispatcher::metastate::MetaStateVal
• consumer::strategy::ChunkStream
• db::ReaderPool
• db::WriterPool
• db::conn::Reader
• db::conn::Writer
• prometheus::PrometheusConfig
• tracing::CarrierMap

Constants

• VERSION_CARGO_SEMVER
• prometheus::CHUNKS_BACKLOG_GAUGE
• prometheus::CHUNKS_COMPLETED_COUNTER
• prometheus::CHUNKS_DURATION_COMPLETED_HISTOGRAM
• prometheus::CHUNKS_DURATION_FAILED_HISTOGRAM
• prometheus::CHUNKS_FAILED_COUNTER
• prometheus::CHUNKS_RETRIED_COUNTER
• prometheus::CHUNKS_SKIPPED_COUNTER
• prometheus::CHUNKS_TOTAL_COUNTER
• prometheus::CONSUMERS_CONNECTED_GAUGE
• prometheus::CONSUMER_COMPLETE_CHUNK_DURATION
• prometheus::CONSUMER_FAIL_CHUNK_DURATION
• prometheus::CONSUMER_FETCH_AND_RESERVE_CHUNKS_HISTOGRAM
• prometheus::OPERATIONS_BACKLOG_GAUGE
• prometheus::RESERVER_CHUNKS_RESERVED_GAUGE
• prometheus::RESERVER_RESERVATIONS_FAILED_COUNTER
• prometheus::RESERVER_RESERVATIONS_SUCCEEDED_COUNTER
• prometheus::SUBMISSIONS_COMPLETED_COUNTER
• prometheus::SUBMISSIONS_DURATION_COMPLETE_HISTOGRAM
• prometheus::SUBMISSIONS_DURATION_FAIL_HISTOGRAM
• prometheus::SUBMISSIONS_FAILED_COUNTER
• prometheus::SUBMISSIONS_TOTAL_COUNTER