List of all items

Structs

• actor::Actor
• actor::ActorId
• actor::ClusterId
• agent::Agent
• agent::AgentConfig
• agent::AgentInner
• agent::Booked
• agent::BookedVersions
• agent::Bookie
• agent::BookieInner
• agent::CountedOwnedTokioRwLockWriteGuard
• agent::CountedTokioRwLock
• agent::CountedTokioRwLockReadGuard
• agent::CountedTokioRwLockWriteGuard
• agent::CurrentVersion
• agent::GapsChanges
• agent::Limits
• agent::LockMeta
• agent::LockRegistry
• agent::PartialVersion
• agent::SplitPool
• agent::VersionsSnapshot
• agent::WriteConn
• api::ChangeId
• api::ColumnName
• api::ExecResponse
• api::Real
• api::RowId
• api::SqliteValueRef
• api::TableName
• api::TableStatRequest
• api::TableStatResponse
• backoff::Backoff
• backoff::Iter
• base::CrsqlDbVersion
• base::CrsqlSeq
• broadcast::ChangeV1
• broadcast::ChangesetParts
• broadcast::ColumnChange
• broadcast::DispatchRuntime
• broadcast::Timestamp
• change::Change
• change::ChunkedChanges
• change::InsertChangesInfo
• channel::CorroReceiver
• channel::CorroSender
• config::AdminConfig
• config::ApiConfig
• config::Config
• config::ConfigBuilder
• config::ConsulConfig
• config::DbConfig
• config::GossipConfig
• config::LogConfig
• config::PerfConfig
• config::PrometheusConfig
• config::TelemetryConfig
• config::TlsClientConfig
• config::TlsConfig
• consul::AgentCheck
• consul::AgentService
• consul::Client
• consul::config::Config
• consul::config::TlsConfig
• members::MemberState
• members::Members
• members::Rtt
• pubsub::MatchableChange
• pubsub::Matcher
• pubsub::MatcherCreated
• pubsub::MatcherHandle
• pubsub::MatcherStmt
• pubsub::ParsedSelect
• pubsub::SubsManager
• schema::Column
• schema::Generated
• schema::Index
• schema::Schema
• schema::Table
• spawn::CountedFut
• spawn::CountedGuard
• sqlite3_restore::Restored
• sqlite::CrConn
• sqlite_pool::Config
• sqlite_pool::InterruptibleStatement
• sqlite_pool::InterruptibleTransaction
• sqlite_pool::Manager
• sqlite_pool::Metrics
• sqlite_pool::PoolConfig
• sqlite_pool::Statement
• sqlite_pool::Status
• sqlite_pool::Timeouts
• sync::SyncStateV1
• sync::SyncTraceContextV1
• tripwire::PreemptibleFuture
• tripwire::Tripwire
• tripwire::TripwireWorker
• tripwire::Tripwired
• updates::HandleMetrics
• updates::InnerUpdateHandle
• updates::UpdateCreated
• updates::UpdateHandle
• updates::UpdatesManager

Enums

• actor::SqliteValueToActorIdError
• agent::ChangeError
• agent::KnownDbVersion
• agent::LockKind
• agent::LockState
• agent::PoolError
• agent::SplitPoolCreateError
• api::ColumnType
• api::ExecResult
• api::QueryEventMeta
• api::SqliteParam
• api::SqliteValue
• api::Statement
• api::TypedNotifyEvent
• api::TypedQueryEvent
• api::sqlite::ChangeType
• broadcast::AuthzV1
• broadcast::BiPayload
• broadcast::BiPayloadV1
• broadcast::BroadcastDecodeError
• broadcast::BroadcastEncodeError
• broadcast::BroadcastError
• broadcast::BroadcastInput
• broadcast::BroadcastV1
• broadcast::ChangeSource
• broadcast::Changeset
• broadcast::FocaCmd
• broadcast::FocaInput
• broadcast::TimestampParseError
• broadcast::UniPayload
• broadcast::UniPayloadV1
• config::AuthzConfig
• config::ConfigBuilderError
• config::ConfigError
• config::LogFormat
• config::OtelConfig
• consul::ConsulCheckStatus
• consul::Error
• members::MemberAddedResult
• pubsub::MatcherError
• pubsub::MatcherState
• pubsub::NormalizeStatementError
• pubsub::PackError
• pubsub::UnpackError
• schema::ApplySchemaError
• schema::ConstrainedSchemaError
• schema::SchemaError
• schema::SqliteType
• sqlite3_restore::Error
• sqlite3_restore::Locked
• sqlite_pool::Runtime
• sync::SyncMessage
• sync::SyncMessageDecodeError
• sync::SyncMessageEncodeError
• sync::SyncMessageV1
• sync::SyncNeedV1
• sync::SyncRejectionV1
• tls::Error
• tripwire::Outcome
• tripwire::TripwireState

Traits

• sqlite::Migration
• sqlite_pool::Committable
• sqlite_pool::SqliteConn
• tripwire::PreemptibleFutureExt
• tripwire::TimeoutFutureExt
• updates::Handle
• updates::Manager

Functions

• agent::migrate
• broadcast::broadcast_changes
• change::insert_local_changes
• change::row_to_change
• channel::bounded
• config::default_admin_path
• pubsub::normalize_sql
• pubsub::pack_columns
• pubsub::unpack_columns
• schema::apply_schema
• schema::init_schema
• schema::parse_sql
• schema::parse_sql_to_schema
• spawn::spawn_blocking_counted_w_handle
• spawn::spawn_counted
• spawn::spawn_counted_w_handle
• spawn::wait_for_all_pending_handles
• sqlite3_restore::lock_all
• sqlite3_restore::restore
• sqlite::migrate
• sqlite::migration_version
• sqlite::rusqlite_to_crsqlite
• sqlite::rusqlite_to_crsqlite_write
• sqlite::set_migration_version
• sqlite::setup_conn
• sqlite_pool::noop_transform
• sync::generate_sync
• tls::generate_ca
• tls::generate_client_cert
• tls::generate_server_cert
• updates::match_changes
• updates::match_changes_from_db_version

Type Aliases

• agent::BookedInner
• api::NotifyEvent
• api::QueryEvent
• consul::ConsulResult
• pubsub::MatchCandidates
• sqlite::SqlitePool
• sqlite::SqlitePoolError
• sqlite_pool::ConfigError
• sqlite_pool::Connection
• sqlite_pool::CreatePoolError
• sqlite_pool::Hook
• sqlite_pool::HookError
• sqlite_pool::Pool
• sqlite_pool::PoolBuilder
• sqlite_pool::PoolError
• sqlite_pool::RusqliteConnection
• sqlite_pool::RusqlitePool
• sqlite_pool::TransformFn
• sync::SyncRequestV1

Statics

• spawn::PENDING_HANDLES

Constants

• change::MAX_CHANGES_BYTE_SIZE
• config::DEFAULT_GOSSIP_CLIENT_ADDR
• config::DEFAULT_GOSSIP_PORT
• config::DEFAULT_MAX_SYNC_BACKOFF
• pubsub::QUERY_TABLE_NAME
• pubsub::SUB_DB_PATH
• sqlite::CRSQL_EXT
• sqlite::CRSQL_EXT_FILENAME