List of all items
Structs
- batch::BatchConfig
- batch::BatchProcessor
- batch::BatchResult
- batch::SharedBatchProcessor
- circuit_breaker::CircuitBreaker
- circuit_breaker::CircuitConfig
- circuit_breaker::SyncEngineCircuit
- circuit_breaker::SyncEngineCircuitMetrics
- config::ColdPathConfig
- config::CursorConfig
- config::HotPathConfig
- config::PeerConfig
- config::PeerHealthConfig
- config::ReplicationEngineConfig
- config::ReplicationEngineSettings
- config::SloConfig
- coordinator::HealthCheck
- coordinator::PeerHealth
- coordinator::ReplicationEngine
- cursor::CursorEntry
- cursor::CursorStore
- peer::PeerConnection
- peer::PeerManager
- resilience::Bulkhead
- resilience::BulkheadFull
- resilience::RateLimitConfig
- resilience::RateLimiter
- resilience::RetryConfig
- stream::CdcEvent
- stream::CdcMeta
- stream::StreamTailer
- sync_engine::NoOpSyncEngine
- sync_engine::SyncError
- sync_engine::SyncItem
Enums
- circuit_breaker::CircuitError
- circuit_breaker::CircuitState
- coordinator::EngineState
- error::ReplicationError
- peer::PeerCircuitState
- peer::PeerState
- stream::CdcOp
- stream::ReadResult
- sync_engine::BackpressureLevel
Traits
Functions
- metrics::cursor_retries_total
- metrics::record_adaptive_batch_size
- metrics::record_backpressure_pause
- metrics::record_batch_dedup
- metrics::record_batch_flush
- metrics::record_cdc_events_applied
- metrics::record_cdc_events_deduped
- metrics::record_cdc_events_read
- metrics::record_circuit_call
- metrics::record_circuit_rejection
- metrics::record_cursor_flush
- metrics::record_cursor_persist
- metrics::record_error
- metrics::record_event_processing_latency
- metrics::record_merkle_divergence
- metrics::record_peer_circuit_state
- metrics::record_peer_connection
- metrics::record_peer_operation_latency
- metrics::record_peer_ping
- metrics::record_peer_ping_latency
- metrics::record_peer_state
- metrics::record_repair_cycle
- metrics::record_repair_cycle_complete
- metrics::record_repair_skipped
- metrics::record_replication_lag
- metrics::record_replication_lag_events
- metrics::record_replication_lag_ms
- metrics::record_slo_violation
- metrics::record_stream_read
- metrics::record_stream_read_latency
- metrics::record_stream_trimmed
- metrics::set_circuit_state
- metrics::set_connected_peers
- metrics::set_engine_state
- metrics::set_replication_lag_slo
- stream::calculate_lag_ms
- stream::compare_stream_ids
- stream::maybe_decompress
- stream::parse_stream_id_timestamp