List of all items

Structs

• CallbackListener
• Config
• DbEvent
• SharedSqliteStorage
• SqlContext
• SqliteStorage
• fetcher::SqliteFetcher
• fetcher::SqlitePollFetcher
• sink::SqliteSink

Enums

• SharedPostgresError

Functions

• fetcher::fetch_next
• queries::keep_alive::initial_heartbeat
• queries::keep_alive::keep_alive
• queries::keep_alive::keep_alive_stream
• queries::reenqueue_orphaned::reenqueue_orphaned
• queries::reenqueue_orphaned::reenqueue_orphaned_stream
• queries::register_worker::register_worker
• sink::push_tasks

Type Aliases

• CompactType
• SqlitePool
• SqliteTask