pub mod magic_sync
pub use magic_sync::Columns
pub use magic_sync::Row
pub mod magic_sync::envelope
pub struct magic_sync::envelope::Limits
impl magic_sync::envelope::Limits
pub fn magic_sync::envelope::Limits::bytes(&self) -> usize
pub fn magic_sync::envelope::Limits::new(usize, usize) -> core::result::Result<Self, magic_sync::Error>
pub fn magic_sync::envelope::Limits::rows(&self) -> usize
impl core::clone::Clone for magic_sync::envelope::Limits
pub fn magic_sync::envelope::Limits::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::envelope::Limits
impl core::cmp::PartialEq for magic_sync::envelope::Limits
pub fn magic_sync::envelope::Limits::eq(&self, &Self) -> bool
impl core::default::Default for magic_sync::envelope::Limits
pub fn magic_sync::envelope::Limits::default() -> Self
impl core::fmt::Debug for magic_sync::envelope::Limits
pub fn magic_sync::envelope::Limits::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::envelope::Limits
impl core::marker::StructuralPartialEq for magic_sync::envelope::Limits
impl core::marker::Freeze for magic_sync::envelope::Limits
impl core::marker::Send for magic_sync::envelope::Limits
impl core::marker::Sync for magic_sync::envelope::Limits
impl core::marker::Unpin for magic_sync::envelope::Limits
impl core::marker::UnsafeUnpin for magic_sync::envelope::Limits
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::envelope::Limits
impl core::panic::unwind_safe::UnwindSafe for magic_sync::envelope::Limits
pub const magic_sync::envelope::ENVELOPE_ROOM: usize
pub const magic_sync::envelope::PROTOCOL: u32
pub mod magic_sync::plan
pub struct magic_sync::plan::Engine
impl magic_sync::plan::Engine
pub async fn magic_sync::plan::Engine::health(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>, u32) -> core::result::Result<magic_sync::status::Health, magic_sync::Error>
pub async fn magic_sync::plan::Engine::listing(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>, core::option::Option<magic_sync::status::ReplicaState>, magic_sync::status::Page) -> core::result::Result<magic_sync::status::Listing, magic_sync::Error>
pub async fn magic_sync::plan::Engine::overview(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>, u32) -> core::result::Result<magic_sync::status::Overview, magic_sync::Error>
pub async fn magic_sync::plan::Engine::progress(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>) -> core::result::Result<magic_sync::status::Progress, magic_sync::Error>
pub async fn magic_sync::plan::Engine::row_progress(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>, &str, &str) -> core::result::Result<magic_sync::status::RowProgress, magic_sync::Error>
pub async fn magic_sync::plan::Engine::wishes(&self, &mut magic_sync::Conn, magic_sync::status::Scope<'_>, core::option::Option<magic_sync::status::WishState>, magic_sync::status::Page) -> core::result::Result<magic_sync::status::WishListing, magic_sync::Error>
impl magic_sync::plan::Engine
pub async fn magic_sync::plan::Engine::indexes<P: core::marker::Sync + 'static>(&mut magic_sync::Conn, &[magic_sync::wire::Codec<P>], magic_sync::plan::Replicas) -> core::result::Result<alloc::string::String, magic_sync::Error>
pub async fn magic_sync::plan::Engine::triggers<P: core::marker::Sync + 'static>(&mut magic_sync::Conn, &[magic_sync::wire::Codec<P>], magic_sync::plan::Replicas) -> core::result::Result<alloc::string::String, magic_sync::Error>
impl core::fmt::Debug for magic_sync::plan::Engine
pub fn magic_sync::plan::Engine::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for magic_sync::plan::Engine
impl core::marker::Send for magic_sync::plan::Engine
impl core::marker::Sync for magic_sync::plan::Engine
impl core::marker::Unpin for magic_sync::plan::Engine
impl core::marker::UnsafeUnpin for magic_sync::plan::Engine
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::plan::Engine
impl core::panic::unwind_safe::UnwindSafe for magic_sync::plan::Engine
pub struct magic_sync::plan::Replicas
impl magic_sync::plan::Replicas
pub const fn magic_sync::plan::Replicas::live(self, &'static str) -> Self
pub const fn magic_sync::plan::Replicas::new(&'static str, &'static str) -> Self
pub const fn magic_sync::plan::Replicas::partitioned_by(self, &'static str) -> Self
impl core::clone::Clone for magic_sync::plan::Replicas
pub fn magic_sync::plan::Replicas::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::plan::Replicas
pub fn magic_sync::plan::Replicas::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::plan::Replicas
impl core::marker::Freeze for magic_sync::plan::Replicas
impl core::marker::Send for magic_sync::plan::Replicas
impl core::marker::Sync for magic_sync::plan::Replicas
impl core::marker::Unpin for magic_sync::plan::Replicas
impl core::marker::UnsafeUnpin for magic_sync::plan::Replicas
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::plan::Replicas
impl core::panic::unwind_safe::UnwindSafe for magic_sync::plan::Replicas
pub fn magic_sync::plan::migration(i32) -> core::option::Option<alloc::string::String>
pub async fn magic_sync::plan::note_resync(&mut magic_sync::Conn, uuid::Uuid, core::option::Option<uuid::Uuid>) -> core::result::Result<(), magic_sync::Error>
pub mod magic_sync::row
#[non_exhaustive] pub enum magic_sync::row::Apply
pub magic_sync::row::Apply::Always
pub magic_sync::row::Apply::IfUnchanged
impl core::clone::Clone for magic_sync::row::Apply
pub fn magic_sync::row::Apply::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::row::Apply
impl core::cmp::PartialEq for magic_sync::row::Apply
pub fn magic_sync::row::Apply::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::row::Apply
pub fn magic_sync::row::Apply::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::row::Apply
impl core::marker::StructuralPartialEq for magic_sync::row::Apply
impl core::marker::Freeze for magic_sync::row::Apply
impl core::marker::Send for magic_sync::row::Apply
impl core::marker::Sync for magic_sync::row::Apply
impl core::marker::Unpin for magic_sync::row::Apply
impl core::marker::UnsafeUnpin for magic_sync::row::Apply
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::row::Apply
impl core::panic::unwind_safe::UnwindSafe for magic_sync::row::Apply
#[non_exhaustive] pub enum magic_sync::row::KeyKind
pub magic_sync::row::KeyKind::Integer
pub magic_sync::row::KeyKind::Uuid
impl core::clone::Clone for magic_sync::row::KeyKind
pub fn magic_sync::row::KeyKind::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::row::KeyKind
impl core::cmp::PartialEq for magic_sync::row::KeyKind
pub fn magic_sync::row::KeyKind::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::row::KeyKind
pub fn magic_sync::row::KeyKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::row::KeyKind
impl core::marker::StructuralPartialEq for magic_sync::row::KeyKind
impl core::marker::Freeze for magic_sync::row::KeyKind
impl core::marker::Send for magic_sync::row::KeyKind
impl core::marker::Sync for magic_sync::row::KeyKind
impl core::marker::Unpin for magic_sync::row::KeyKind
impl core::marker::UnsafeUnpin for magic_sync::row::KeyKind
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::row::KeyKind
impl core::panic::unwind_safe::UnwindSafe for magic_sync::row::KeyKind
#[non_exhaustive] pub enum magic_sync::row::KeyPart
pub magic_sync::row::KeyPart::Int(i64)
pub magic_sync::row::KeyPart::Uuid(uuid::Uuid)
impl core::clone::Clone for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::row::KeyPart
impl core::cmp::Ord for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::cmp(&self, &Self) -> core::cmp::Ordering
impl core::cmp::PartialEq for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::eq(&self, &Self) -> bool
impl core::cmp::PartialOrd for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::partial_cmp(&self, &Self) -> core::option::Option<core::cmp::Ordering>
impl core::fmt::Debug for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for magic_sync::row::KeyPart
pub fn magic_sync::row::KeyPart::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for magic_sync::row::KeyPart
impl core::marker::StructuralPartialEq for magic_sync::row::KeyPart
impl core::marker::Freeze for magic_sync::row::KeyPart
impl core::marker::Send for magic_sync::row::KeyPart
impl core::marker::Sync for magic_sync::row::KeyPart
impl core::marker::Unpin for magic_sync::row::KeyPart
impl core::marker::UnsafeUnpin for magic_sync::row::KeyPart
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::row::KeyPart
impl core::panic::unwind_safe::UnwindSafe for magic_sync::row::KeyPart
#[non_exhaustive] pub enum magic_sync::row::Mirror
pub magic_sync::row::Mirror::Both
pub magic_sync::row::Mirror::Catalog
pub magic_sync::row::Mirror::Record
pub magic_sync::row::Mirror::Setting
impl core::clone::Clone for magic_sync::row::Mirror
pub fn magic_sync::row::Mirror::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::row::Mirror
impl core::cmp::PartialEq for magic_sync::row::Mirror
pub fn magic_sync::row::Mirror::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::row::Mirror
pub fn magic_sync::row::Mirror::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::row::Mirror
impl core::marker::StructuralPartialEq for magic_sync::row::Mirror
impl core::marker::Freeze for magic_sync::row::Mirror
impl core::marker::Send for magic_sync::row::Mirror
impl core::marker::Sync for magic_sync::row::Mirror
impl core::marker::Unpin for magic_sync::row::Mirror
impl core::marker::UnsafeUnpin for magic_sync::row::Mirror
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::row::Mirror
impl core::panic::unwind_safe::UnwindSafe for magic_sync::row::Mirror
#[non_exhaustive] pub enum magic_sync::row::VersionKind
pub magic_sync::row::VersionKind::Instant
pub magic_sync::row::VersionKind::Integer
impl core::clone::Clone for magic_sync::row::VersionKind
pub fn magic_sync::row::VersionKind::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::row::VersionKind
impl core::cmp::PartialEq for magic_sync::row::VersionKind
pub fn magic_sync::row::VersionKind::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::row::VersionKind
pub fn magic_sync::row::VersionKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::row::VersionKind
impl core::marker::StructuralPartialEq for magic_sync::row::VersionKind
impl core::marker::Freeze for magic_sync::row::VersionKind
impl core::marker::Send for magic_sync::row::VersionKind
impl core::marker::Sync for magic_sync::row::VersionKind
impl core::marker::Unpin for magic_sync::row::VersionKind
impl core::marker::UnsafeUnpin for magic_sync::row::VersionKind
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::row::VersionKind
impl core::panic::unwind_safe::UnwindSafe for magic_sync::row::VersionKind
pub trait magic_sync::row::Columns: crate::__private::Sealed
pub trait magic_sync::row::KeyValue
pub const magic_sync::row::KeyValue::KIND: magic_sync::row::KeyKind
pub fn magic_sync::row::KeyValue::key_part(&self) -> magic_sync::row::KeyPart
impl magic_sync::row::KeyValue for i16
pub const i16::KIND: magic_sync::row::KeyKind
pub fn i16::key_part(&self) -> magic_sync::row::KeyPart
impl magic_sync::row::KeyValue for i32
pub const i32::KIND: magic_sync::row::KeyKind
pub fn i32::key_part(&self) -> magic_sync::row::KeyPart
impl magic_sync::row::KeyValue for i64
pub const i64::KIND: magic_sync::row::KeyKind
pub fn i64::key_part(&self) -> magic_sync::row::KeyPart
impl magic_sync::row::KeyValue for uuid::Uuid
pub const uuid::Uuid::KIND: magic_sync::row::KeyKind
pub fn uuid::Uuid::key_part(&self) -> magic_sync::row::KeyPart
pub trait magic_sync::row::Row: magic_sync::row::Columns + for<'r> sqlx_core::from_row::FromRow<'r, <__private::Db as sqlx_core::database::Database>::Row> + core::marker::Send + core::marker::Unpin + 'static
pub const magic_sync::row::Row::KEY: &'static [&'static str]
pub const magic_sync::row::Row::MIRROR: magic_sync::row::Mirror
pub const magic_sync::row::Row::SCHEMA: &'static str
pub const magic_sync::row::Row::TABLE: &'static str
pub fn magic_sync::row::Row::key(&self) -> magic_sync::row::Key
pub fn magic_sync::row::Row::key_text(&self) -> alloc::string::String
pub trait magic_sync::row::Setting: magic_sync::row::Row + core::clone::Clone + core::marker::Sync
pub trait magic_sync::row::Version: core::marker::Sized
pub const magic_sync::row::Version::KIND: magic_sync::row::VersionKind
pub fn magic_sync::row::Version::raised(&self) -> Self
pub fn magic_sync::row::Version::text(&self) -> alloc::string::String
impl magic_sync::row::Version for chrono::naive::datetime::NaiveDateTime
pub const chrono::naive::datetime::NaiveDateTime::KIND: magic_sync::row::VersionKind
pub fn chrono::naive::datetime::NaiveDateTime::raised(&self) -> Self
pub fn chrono::naive::datetime::NaiveDateTime::text(&self) -> alloc::string::String
impl magic_sync::row::Version for i16
pub const i16::KIND: magic_sync::row::VersionKind
pub fn i16::raised(&self) -> Self
pub fn i16::text(&self) -> alloc::string::String
impl magic_sync::row::Version for i32
pub const i32::KIND: magic_sync::row::VersionKind
pub fn i32::raised(&self) -> Self
pub fn i32::text(&self) -> alloc::string::String
impl magic_sync::row::Version for i64
pub const i64::KIND: magic_sync::row::VersionKind
pub fn i64::raised(&self) -> Self
pub fn i64::text(&self) -> alloc::string::String
impl<Tz: chrono::offset::TimeZone> magic_sync::row::Version for chrono::datetime::DateTime<Tz>
pub const chrono::datetime::DateTime<Tz>::KIND: magic_sync::row::VersionKind
pub fn chrono::datetime::DateTime<Tz>::raised(&self) -> Self
pub fn chrono::datetime::DateTime<Tz>::text(&self) -> alloc::string::String
pub type magic_sync::row::Key = alloc::vec::Vec<magic_sync::row::KeyPart>
pub mod magic_sync::run
pub mod magic_sync::run::server
pub struct magic_sync::run::server::Anyone(_)
impl magic_sync::run::server::Anyone
pub fn magic_sync::run::server::Anyone::new(sqlx_postgres::PgPool) -> Self
impl core::fmt::Debug for magic_sync::run::server::Anyone
pub fn magic_sync::run::server::Anyone::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl magic_sync::run::server::Senders for magic_sync::run::server::Anyone
pub type magic_sync::run::server::Anyone::Known = ()
pub async fn magic_sync::run::server::Anyone::filing(&self, &()) -> core::result::Result<sqlx_core::transaction::Transaction<'static, sqlx_postgres::database::Postgres>, magic_sync::Error>
pub async fn magic_sync::run::server::Anyone::known(&self, uuid::Uuid) -> core::result::Result<core::option::Option<()>, magic_sync::Error>
impl core::marker::Freeze for magic_sync::run::server::Anyone
impl core::marker::Send for magic_sync::run::server::Anyone
impl core::marker::Sync for magic_sync::run::server::Anyone
impl core::marker::Unpin for magic_sync::run::server::Anyone
impl core::marker::UnsafeUnpin for magic_sync::run::server::Anyone
impl !core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::Anyone
impl !core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::Anyone
#[non_exhaustive] pub struct magic_sync::run::server::Filed
pub magic_sync::run::server::Filed::gone: alloc::vec::Vec<magic_sync::row::Key>
pub magic_sync::run::server::Filed::table: alloc::string::String
pub magic_sync::run::server::Filed::written: alloc::vec::Vec<magic_sync::row::Key>
impl core::fmt::Debug for magic_sync::run::server::Filed
pub fn magic_sync::run::server::Filed::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for magic_sync::run::server::Filed
impl core::marker::Send for magic_sync::run::server::Filed
impl core::marker::Sync for magic_sync::run::server::Filed
impl core::marker::Unpin for magic_sync::run::server::Filed
impl core::marker::UnsafeUnpin for magic_sync::run::server::Filed
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::Filed
impl core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::Filed
pub struct magic_sync::run::server::Server<S: magic_sync::run::server::Senders, T: magic_sync::run::server::Transport>
impl<S: magic_sync::run::server::Senders, T: magic_sync::run::server::Transport> magic_sync::run::server::Server<S, T>
pub async fn magic_sync::run::server::Server<S, T>::begin(&self) -> core::result::Result<sqlx_core::transaction::Transaction<'static, sqlx_postgres::database::Postgres>, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::desire<R: magic_sync::row::Setting>(&self, &mut magic_sync::Conn, R, core::option::Option<&str>) -> core::result::Result<magic_sync::run::server::Wished, magic_sync::Error>
pub fn magic_sync::run::server::Server<S, T>::engine(&self) -> &magic_sync::plan::Engine
pub async fn magic_sync::run::server::Server<S, T>::install(sqlx_postgres::PgPool, alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>, magic_sync::plan::Replicas, T, S, magic_sync::run::server::Settings) -> core::result::Result<Self, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::new(sqlx_postgres::PgPool, alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>, magic_sync::plan::Replicas, T, S, magic_sync::run::server::Settings) -> core::result::Result<Self, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::pass_now(&self) -> core::result::Result<core::option::Option<usize>, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::receive(&self, uuid::Uuid, &[u8]) -> core::result::Result<alloc::vec::Vec<magic_sync::run::server::Filed>, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::run(&self, impl core::future::future::Future<Output = ()>)
pub async fn magic_sync::run::server::Server<S, T>::wishes<R: magic_sync::row::Setting>(&self, &mut magic_sync::Conn, &[magic_sync::row::Key]) -> core::result::Result<alloc::vec::Vec<magic_sync::run::server::WishOf<R>>, magic_sync::Error>
pub async fn magic_sync::run::server::Server<S, T>::withdraw<R: magic_sync::row::Setting>(&self, &mut magic_sync::Conn, &magic_sync::row::Key) -> core::result::Result<bool, magic_sync::Error>
impl<S: magic_sync::run::server::Senders, T: magic_sync::run::server::Transport> core::fmt::Debug for magic_sync::run::server::Server<S, T>
pub fn magic_sync::run::server::Server<S, T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<S, T> core::marker::Freeze for magic_sync::run::server::Server<S, T> where alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>: core::marker::Freeze, T: core::marker::Freeze, S: core::marker::Freeze
impl<S, T> core::marker::Send for magic_sync::run::server::Server<S, T> where alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>: core::marker::Send
impl<S, T> core::marker::Sync for magic_sync::run::server::Server<S, T> where alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>: core::marker::Sync
impl<S, T> core::marker::Unpin for magic_sync::run::server::Server<S, T> where alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>: core::marker::Unpin, T: core::marker::Unpin, S: core::marker::Unpin
impl<S, T> core::marker::UnsafeUnpin for magic_sync::run::server::Server<S, T> where alloc::vec::Vec<magic_sync::wire::Codec<<S as magic_sync::run::server::Senders>::Known>>: core::marker::UnsafeUnpin, T: core::marker::UnsafeUnpin, S: core::marker::UnsafeUnpin
impl<S, T> !core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::Server<S, T>
impl<S, T> !core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::Server<S, T>
#[non_exhaustive] pub struct magic_sync::run::server::Settings
pub magic_sync::run::server::Settings::backoff: magic_sync::run::Backoff
pub magic_sync::run::server::Settings::batch: core::num::nonzero::NonZeroU32
pub magic_sync::run::server::Settings::concurrency: core::num::nonzero::NonZeroU32
pub magic_sync::run::server::Settings::idle: core::time::Duration
pub magic_sync::run::server::Settings::inbox: core::num::nonzero::NonZeroU32
pub magic_sync::run::server::Settings::limits: magic_sync::envelope::Limits
pub magic_sync::run::server::Settings::outbox_bytes: core::num::nonzero::NonZeroU64
pub magic_sync::run::server::Settings::outbox_messages: core::num::nonzero::NonZeroU32
pub magic_sync::run::server::Settings::prune_after: core::time::Duration
pub magic_sync::run::server::Settings::replica_backoff: magic_sync::run::Backoff
pub magic_sync::run::server::Settings::retry_every: core::time::Duration
pub magic_sync::run::server::Settings::role: core::option::Option<alloc::string::String>
pub magic_sync::run::server::Settings::send_timeout: core::time::Duration
pub magic_sync::run::server::Settings::standby: core::time::Duration
pub magic_sync::run::server::Settings::stuck_after: core::time::Duration
pub magic_sync::run::server::Settings::unconfirmed_after: core::time::Duration
pub magic_sync::run::server::Settings::watch_every: core::time::Duration
impl core::clone::Clone for magic_sync::run::server::Settings
pub fn magic_sync::run::server::Settings::clone(&self) -> Self
impl core::default::Default for magic_sync::run::server::Settings
pub fn magic_sync::run::server::Settings::default() -> Self
impl core::fmt::Debug for magic_sync::run::server::Settings
pub fn magic_sync::run::server::Settings::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for magic_sync::run::server::Settings
impl core::marker::Send for magic_sync::run::server::Settings
impl core::marker::Sync for magic_sync::run::server::Settings
impl core::marker::Unpin for magic_sync::run::server::Settings
impl core::marker::UnsafeUnpin for magic_sync::run::server::Settings
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::Settings
impl core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::Settings
#[non_exhaustive] pub struct magic_sync::run::server::WishOf<R>
pub magic_sync::run::server::WishOf::answered_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::run::server::WishOf::key: magic_sync::row::Key
pub magic_sync::run::server::WishOf::note: core::option::Option<alloc::string::String>
pub magic_sync::run::server::WishOf::reason: core::option::Option<alloc::string::String>
pub magic_sync::run::server::WishOf::state: magic_sync::status::WishState
pub magic_sync::run::server::WishOf::version: i64
pub magic_sync::run::server::WishOf::wanted: R
pub magic_sync::run::server::WishOf::wished_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
impl<R: core::clone::Clone> core::clone::Clone for magic_sync::run::server::WishOf<R>
pub fn magic_sync::run::server::WishOf<R>::clone(&self) -> Self
impl<R: core::fmt::Debug> core::fmt::Debug for magic_sync::run::server::WishOf<R>
pub fn magic_sync::run::server::WishOf<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R> core::marker::Freeze for magic_sync::run::server::WishOf<R> where R: core::marker::Freeze
impl<R> core::marker::Send for magic_sync::run::server::WishOf<R> where R: core::marker::Send
impl<R> core::marker::Sync for magic_sync::run::server::WishOf<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for magic_sync::run::server::WishOf<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for magic_sync::run::server::WishOf<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::WishOf<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::WishOf<R> where R: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct magic_sync::run::server::Wished
pub magic_sync::run::server::Wished::id: uuid::Uuid
pub magic_sync::run::server::Wished::version: i64
impl core::clone::Clone for magic_sync::run::server::Wished
pub fn magic_sync::run::server::Wished::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::run::server::Wished
impl core::cmp::PartialEq for magic_sync::run::server::Wished
pub fn magic_sync::run::server::Wished::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::run::server::Wished
pub fn magic_sync::run::server::Wished::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::run::server::Wished
impl core::marker::StructuralPartialEq for magic_sync::run::server::Wished
impl core::marker::Freeze for magic_sync::run::server::Wished
impl core::marker::Send for magic_sync::run::server::Wished
impl core::marker::Sync for magic_sync::run::server::Wished
impl core::marker::Unpin for magic_sync::run::server::Wished
impl core::marker::UnsafeUnpin for magic_sync::run::server::Wished
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::server::Wished
impl core::panic::unwind_safe::UnwindSafe for magic_sync::run::server::Wished
pub const magic_sync::run::server::LOCK_KEY: i64
pub trait magic_sync::run::server::Senders: core::marker::Send + core::marker::Sync + 'static
pub type magic_sync::run::server::Senders::Known: core::marker::Send + core::marker::Sync + 'static
pub fn magic_sync::run::server::Senders::filing(&self, &Self::Known) -> impl core::future::future::Future<Output = core::result::Result<sqlx_core::transaction::Transaction<'static, sqlx_postgres::database::Postgres>, magic_sync::Error>> + core::marker::Send
pub fn magic_sync::run::server::Senders::known(&self, uuid::Uuid) -> impl core::future::future::Future<Output = core::result::Result<core::option::Option<Self::Known>, magic_sync::Error>> + core::marker::Send
impl magic_sync::run::server::Senders for magic_sync::run::server::Anyone
pub type magic_sync::run::server::Anyone::Known = ()
pub async fn magic_sync::run::server::Anyone::filing(&self, &()) -> core::result::Result<sqlx_core::transaction::Transaction<'static, sqlx_postgres::database::Postgres>, magic_sync::Error>
pub async fn magic_sync::run::server::Anyone::known(&self, uuid::Uuid) -> core::result::Result<core::option::Option<()>, magic_sync::Error>
pub trait magic_sync::run::server::Transport: core::marker::Send + core::marker::Sync + 'static
pub fn magic_sync::run::server::Transport::send(&self, uuid::Uuid, alloc::vec::Vec<u8>, &str) -> impl core::future::future::Future<Output = core::result::Result<(), magic_sync::Error>> + core::marker::Send
#[non_exhaustive] pub struct magic_sync::run::Backoff
pub magic_sync::run::Backoff::first: core::time::Duration
pub magic_sync::run::Backoff::max: core::time::Duration
impl magic_sync::run::Backoff
pub const fn magic_sync::run::Backoff::new(core::time::Duration, core::time::Duration) -> Self
impl core::clone::Clone for magic_sync::run::Backoff
pub fn magic_sync::run::Backoff::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::run::Backoff
impl core::cmp::PartialEq for magic_sync::run::Backoff
pub fn magic_sync::run::Backoff::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::run::Backoff
pub fn magic_sync::run::Backoff::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::run::Backoff
impl core::marker::StructuralPartialEq for magic_sync::run::Backoff
impl core::marker::Freeze for magic_sync::run::Backoff
impl core::marker::Send for magic_sync::run::Backoff
impl core::marker::Sync for magic_sync::run::Backoff
impl core::marker::Unpin for magic_sync::run::Backoff
impl core::marker::UnsafeUnpin for magic_sync::run::Backoff
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::run::Backoff
impl core::panic::unwind_safe::UnwindSafe for magic_sync::run::Backoff
pub mod magic_sync::status
#[non_exhaustive] pub enum magic_sync::status::NoteKind
pub magic_sync::status::NoteKind::Assigned
pub magic_sync::status::NoteKind::Members
pub magic_sync::status::NoteKind::Resync
pub magic_sync::status::NoteKind::Row
impl core::clone::Clone for magic_sync::status::NoteKind
pub fn magic_sync::status::NoteKind::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::NoteKind
impl core::cmp::PartialEq for magic_sync::status::NoteKind
pub fn magic_sync::status::NoteKind::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::status::NoteKind
pub fn magic_sync::status::NoteKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::NoteKind
impl core::marker::StructuralPartialEq for magic_sync::status::NoteKind
impl serde_core::ser::Serialize for magic_sync::status::NoteKind
pub fn magic_sync::status::NoteKind::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::NoteKind
impl core::marker::Send for magic_sync::status::NoteKind
impl core::marker::Sync for magic_sync::status::NoteKind
impl core::marker::Unpin for magic_sync::status::NoteKind
impl core::marker::UnsafeUnpin for magic_sync::status::NoteKind
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::NoteKind
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::NoteKind
#[non_exhaustive] pub enum magic_sync::status::ReplicaState
pub magic_sync::status::ReplicaState::AwaitingFix
pub magic_sync::status::ReplicaState::CatchingUp
pub magic_sync::status::ReplicaState::Synced
pub magic_sync::status::ReplicaState::Unreachable
impl core::clone::Clone for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::ReplicaState
impl core::cmp::Ord for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::cmp(&self, &Self) -> core::cmp::Ordering
impl core::cmp::PartialEq for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::eq(&self, &Self) -> bool
impl core::cmp::PartialOrd for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::partial_cmp(&self, &Self) -> core::option::Option<core::cmp::Ordering>
impl core::fmt::Debug for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for magic_sync::status::ReplicaState
impl core::marker::StructuralPartialEq for magic_sync::status::ReplicaState
impl serde_core::ser::Serialize for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl<'de> serde_core::de::Deserialize<'de> for magic_sync::status::ReplicaState
pub fn magic_sync::status::ReplicaState::deserialize<__D>(__D) -> core::result::Result<Self, <__D as serde_core::de::Deserializer>::Error> where __D: serde_core::de::Deserializer<'de>
impl core::marker::Freeze for magic_sync::status::ReplicaState
impl core::marker::Send for magic_sync::status::ReplicaState
impl core::marker::Sync for magic_sync::status::ReplicaState
impl core::marker::Unpin for magic_sync::status::ReplicaState
impl core::marker::UnsafeUnpin for magic_sync::status::ReplicaState
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::ReplicaState
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::ReplicaState
#[non_exhaustive] pub enum magic_sync::status::RowState
pub magic_sync::status::RowState::Holds
pub magic_sync::status::RowState::Leaving
pub magic_sync::status::RowState::Missing
pub magic_sync::status::RowState::OnItsWay
pub magic_sync::status::RowState::Outdated
pub magic_sync::status::RowState::Quarantined
impl core::clone::Clone for magic_sync::status::RowState
pub fn magic_sync::status::RowState::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::RowState
impl core::cmp::Ord for magic_sync::status::RowState
pub fn magic_sync::status::RowState::cmp(&self, &Self) -> core::cmp::Ordering
impl core::cmp::PartialEq for magic_sync::status::RowState
pub fn magic_sync::status::RowState::eq(&self, &Self) -> bool
impl core::cmp::PartialOrd for magic_sync::status::RowState
pub fn magic_sync::status::RowState::partial_cmp(&self, &Self) -> core::option::Option<core::cmp::Ordering>
impl core::fmt::Debug for magic_sync::status::RowState
pub fn magic_sync::status::RowState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::RowState
impl core::marker::StructuralPartialEq for magic_sync::status::RowState
impl serde_core::ser::Serialize for magic_sync::status::RowState
pub fn magic_sync::status::RowState::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::RowState
impl core::marker::Send for magic_sync::status::RowState
impl core::marker::Sync for magic_sync::status::RowState
impl core::marker::Unpin for magic_sync::status::RowState
impl core::marker::UnsafeUnpin for magic_sync::status::RowState
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::RowState
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::RowState
#[non_exhaustive] pub enum magic_sync::status::Scope<'a>
pub magic_sync::status::Scope::All
pub magic_sync::status::Scope::Partition(uuid::Uuid)
pub magic_sync::status::Scope::Replicas(&'a [uuid::Uuid])
impl<'a> core::clone::Clone for magic_sync::status::Scope<'a>
pub fn magic_sync::status::Scope<'a>::clone(&self) -> Self
impl<'a> core::fmt::Debug for magic_sync::status::Scope<'a>
pub fn magic_sync::status::Scope<'a>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<'a> core::marker::Copy for magic_sync::status::Scope<'a>
impl<'a> core::marker::Freeze for magic_sync::status::Scope<'a>
impl<'a> core::marker::Send for magic_sync::status::Scope<'a>
impl<'a> core::marker::Sync for magic_sync::status::Scope<'a>
impl<'a> core::marker::Unpin for magic_sync::status::Scope<'a>
impl<'a> core::marker::UnsafeUnpin for magic_sync::status::Scope<'a>
impl<'a> core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Scope<'a>
impl<'a> core::panic::unwind_safe::UnwindSafe for magic_sync::status::Scope<'a>
#[non_exhaustive] pub enum magic_sync::status::WishState
pub magic_sync::status::WishState::Applied
pub magic_sync::status::WishState::Pending
pub magic_sync::status::WishState::Refused
pub magic_sync::status::WishState::Superseded
pub magic_sync::status::WishState::Waiting
impl magic_sync::status::WishState
pub fn magic_sync::status::WishState::as_str(self) -> &'static str
pub fn magic_sync::status::WishState::of(&str) -> core::option::Option<Self>
impl core::clone::Clone for magic_sync::status::WishState
pub fn magic_sync::status::WishState::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::WishState
impl core::cmp::PartialEq for magic_sync::status::WishState
pub fn magic_sync::status::WishState::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::status::WishState
pub fn magic_sync::status::WishState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for magic_sync::status::WishState
pub fn magic_sync::status::WishState::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for magic_sync::status::WishState
impl core::marker::StructuralPartialEq for magic_sync::status::WishState
impl serde_core::ser::Serialize for magic_sync::status::WishState
pub fn magic_sync::status::WishState::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl<'de> serde_core::de::Deserialize<'de> for magic_sync::status::WishState
pub fn magic_sync::status::WishState::deserialize<__D>(__D) -> core::result::Result<Self, <__D as serde_core::de::Deserializer>::Error> where __D: serde_core::de::Deserializer<'de>
impl core::marker::Freeze for magic_sync::status::WishState
impl core::marker::Send for magic_sync::status::WishState
impl core::marker::Sync for magic_sync::status::WishState
impl core::marker::Unpin for magic_sync::status::WishState
impl core::marker::UnsafeUnpin for magic_sync::status::WishState
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::WishState
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::WishState
#[non_exhaustive] pub struct magic_sync::status::Backlog
pub magic_sync::status::Backlog::at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Backlog::tables: alloc::vec::Vec<magic_sync::status::UpProgress>
impl core::clone::Clone for magic_sync::status::Backlog
pub fn magic_sync::status::Backlog::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Backlog
pub fn magic_sync::status::Backlog::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Backlog
pub fn magic_sync::status::Backlog::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Backlog
impl core::marker::Send for magic_sync::status::Backlog
impl core::marker::Sync for magic_sync::status::Backlog
impl core::marker::Unpin for magic_sync::status::Backlog
impl core::marker::UnsafeUnpin for magic_sync::status::Backlog
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Backlog
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Backlog
#[non_exhaustive] pub struct magic_sync::status::Failing
pub magic_sync::status::Failing::failures: i32
pub magic_sync::status::Failing::last_error: core::option::Option<alloc::string::String>
pub magic_sync::status::Failing::replica: uuid::Uuid
pub magic_sync::status::Failing::retry_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
impl core::clone::Clone for magic_sync::status::Failing
pub fn magic_sync::status::Failing::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Failing
pub fn magic_sync::status::Failing::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Failing
pub fn magic_sync::status::Failing::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Failing
impl core::marker::Send for magic_sync::status::Failing
impl core::marker::Sync for magic_sync::status::Failing
impl core::marker::Unpin for magic_sync::status::Failing
impl core::marker::UnsafeUnpin for magic_sync::status::Failing
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Failing
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Failing
#[non_exhaustive] pub struct magic_sync::status::Health
pub magic_sync::status::Health::failing: magic_sync::status::Listed<magic_sync::status::Failing>
pub magic_sync::status::Health::healthy: bool
pub magic_sync::status::Health::inbox: magic_sync::status::Listed<magic_sync::status::Unfiled>
pub magic_sync::status::Health::oldest: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::Health::parked: magic_sync::status::Listed<magic_sync::status::Parked>
pub magic_sync::status::Health::pending: i64
pub magic_sync::status::Health::quarantine: magic_sync::status::Listed<magic_sync::status::Quarantined>
impl core::clone::Clone for magic_sync::status::Health
pub fn magic_sync::status::Health::clone(&self) -> Self
impl core::default::Default for magic_sync::status::Health
pub fn magic_sync::status::Health::default() -> Self
impl core::fmt::Debug for magic_sync::status::Health
pub fn magic_sync::status::Health::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Health
pub fn magic_sync::status::Health::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Health
impl core::marker::Send for magic_sync::status::Health
impl core::marker::Sync for magic_sync::status::Health
impl core::marker::Unpin for magic_sync::status::Health
impl core::marker::UnsafeUnpin for magic_sync::status::Health
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Health
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Health
#[non_exhaustive] pub struct magic_sync::status::Listed<T>
pub magic_sync::status::Listed::first: alloc::vec::Vec<T>
pub magic_sync::status::Listed::total: i64
impl<T: core::clone::Clone> core::clone::Clone for magic_sync::status::Listed<T>
pub fn magic_sync::status::Listed<T>::clone(&self) -> Self
impl<T: core::fmt::Debug> core::fmt::Debug for magic_sync::status::Listed<T>
pub fn magic_sync::status::Listed<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T> core::default::Default for magic_sync::status::Listed<T>
pub fn magic_sync::status::Listed<T>::default() -> Self
impl<T> serde_core::ser::Serialize for magic_sync::status::Listed<T> where T: serde_core::ser::Serialize
pub fn magic_sync::status::Listed<T>::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl<T> core::marker::Freeze for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::marker::Freeze
impl<T> core::marker::Send for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::marker::Send
impl<T> core::marker::Sync for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::marker::Sync
impl<T> core::marker::Unpin for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for magic_sync::status::Listed<T> where alloc::vec::Vec<T>: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct magic_sync::status::Listing
pub magic_sync::status::Listing::contract: u32
pub magic_sync::status::Listing::now: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Listing::offset: u32
pub magic_sync::status::Listing::replicas: magic_sync::status::Listed<magic_sync::status::ReplicaOverview>
pub magic_sync::status::Listing::state: core::option::Option<magic_sync::status::ReplicaState>
impl core::clone::Clone for magic_sync::status::Listing
pub fn magic_sync::status::Listing::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Listing
pub fn magic_sync::status::Listing::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Listing
pub fn magic_sync::status::Listing::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Listing
impl core::marker::Send for magic_sync::status::Listing
impl core::marker::Sync for magic_sync::status::Listing
impl core::marker::Unpin for magic_sync::status::Listing
impl core::marker::UnsafeUnpin for magic_sync::status::Listing
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Listing
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Listing
#[non_exhaustive] pub struct magic_sync::status::Overview
pub magic_sync::status::Overview::contract: u32
pub magic_sync::status::Overview::health: magic_sync::status::Health
pub magic_sync::status::Overview::now: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Overview::replicas: magic_sync::status::Listed<magic_sync::status::ReplicaOverview>
pub magic_sync::status::Overview::states: magic_sync::status::ReplicaCounts
pub magic_sync::status::Overview::tables: alloc::vec::Vec<magic_sync::status::TableOverview>
impl core::clone::Clone for magic_sync::status::Overview
pub fn magic_sync::status::Overview::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Overview
pub fn magic_sync::status::Overview::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Overview
pub fn magic_sync::status::Overview::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Overview
impl core::marker::Send for magic_sync::status::Overview
impl core::marker::Sync for magic_sync::status::Overview
impl core::marker::Unpin for magic_sync::status::Overview
impl core::marker::UnsafeUnpin for magic_sync::status::Overview
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Overview
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Overview
#[non_exhaustive] pub struct magic_sync::status::Page
pub magic_sync::status::Page::limit: u32
pub magic_sync::status::Page::offset: u32
impl magic_sync::status::Page
pub const fn magic_sync::status::Page::new(u32, u32) -> Self
impl core::clone::Clone for magic_sync::status::Page
pub fn magic_sync::status::Page::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::Page
impl core::cmp::PartialEq for magic_sync::status::Page
pub fn magic_sync::status::Page::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::status::Page
pub fn magic_sync::status::Page::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::Page
impl core::marker::StructuralPartialEq for magic_sync::status::Page
impl core::marker::Freeze for magic_sync::status::Page
impl core::marker::Send for magic_sync::status::Page
impl core::marker::Sync for magic_sync::status::Page
impl core::marker::Unpin for magic_sync::status::Page
impl core::marker::UnsafeUnpin for magic_sync::status::Page
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Page
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Page
#[non_exhaustive] pub struct magic_sync::status::Parked
pub magic_sync::status::Parked::attempts: i32
pub magic_sync::status::Parked::id: i64
pub magic_sync::status::Parked::key: core::option::Option<alloc::string::String>
pub magic_sync::status::Parked::kind: magic_sync::status::NoteKind
pub magic_sync::status::Parked::last_error: core::option::Option<alloc::string::String>
pub magic_sync::status::Parked::parked_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::Parked::replica: core::option::Option<uuid::Uuid>
pub magic_sync::status::Parked::table: core::option::Option<alloc::string::String>
impl core::clone::Clone for magic_sync::status::Parked
pub fn magic_sync::status::Parked::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Parked
pub fn magic_sync::status::Parked::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Parked
pub fn magic_sync::status::Parked::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Parked
impl core::marker::Send for magic_sync::status::Parked
impl core::marker::Sync for magic_sync::status::Parked
impl core::marker::Unpin for magic_sync::status::Parked
impl core::marker::UnsafeUnpin for magic_sync::status::Parked
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Parked
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Parked
#[non_exhaustive] pub struct magic_sync::status::Progress
pub magic_sync::status::Progress::contract: u32
pub magic_sync::status::Progress::replicas: alloc::vec::Vec<magic_sync::status::ReplicaProgress>
impl core::clone::Clone for magic_sync::status::Progress
pub fn magic_sync::status::Progress::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Progress
pub fn magic_sync::status::Progress::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Progress
pub fn magic_sync::status::Progress::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Progress
impl core::marker::Send for magic_sync::status::Progress
impl core::marker::Sync for magic_sync::status::Progress
impl core::marker::Unpin for magic_sync::status::Progress
impl core::marker::UnsafeUnpin for magic_sync::status::Progress
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Progress
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Progress
#[non_exhaustive] pub struct magic_sync::status::Quarantined
pub magic_sync::status::Quarantined::attempts: i32
pub magic_sync::status::Quarantined::first_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Quarantined::key: alloc::string::String
pub magic_sync::status::Quarantined::last_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Quarantined::reason: alloc::string::String
pub magic_sync::status::Quarantined::replica: uuid::Uuid
pub magic_sync::status::Quarantined::table: alloc::string::String
impl core::clone::Clone for magic_sync::status::Quarantined
pub fn magic_sync::status::Quarantined::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Quarantined
pub fn magic_sync::status::Quarantined::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Quarantined
pub fn magic_sync::status::Quarantined::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Quarantined
impl core::marker::Send for magic_sync::status::Quarantined
impl core::marker::Sync for magic_sync::status::Quarantined
impl core::marker::Unpin for magic_sync::status::Quarantined
impl core::marker::UnsafeUnpin for magic_sync::status::Quarantined
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Quarantined
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Quarantined
#[non_exhaustive] pub struct magic_sync::status::ReplicaCounts
pub magic_sync::status::ReplicaCounts::awaiting_fix: i64
pub magic_sync::status::ReplicaCounts::catching_up: i64
pub magic_sync::status::ReplicaCounts::synced: i64
pub magic_sync::status::ReplicaCounts::unreachable: i64
impl core::clone::Clone for magic_sync::status::ReplicaCounts
pub fn magic_sync::status::ReplicaCounts::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::ReplicaCounts
impl core::cmp::PartialEq for magic_sync::status::ReplicaCounts
pub fn magic_sync::status::ReplicaCounts::eq(&self, &Self) -> bool
impl core::default::Default for magic_sync::status::ReplicaCounts
pub fn magic_sync::status::ReplicaCounts::default() -> Self
impl core::fmt::Debug for magic_sync::status::ReplicaCounts
pub fn magic_sync::status::ReplicaCounts::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::ReplicaCounts
impl core::marker::StructuralPartialEq for magic_sync::status::ReplicaCounts
impl serde_core::ser::Serialize for magic_sync::status::ReplicaCounts
pub fn magic_sync::status::ReplicaCounts::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::ReplicaCounts
impl core::marker::Send for magic_sync::status::ReplicaCounts
impl core::marker::Sync for magic_sync::status::ReplicaCounts
impl core::marker::Unpin for magic_sync::status::ReplicaCounts
impl core::marker::UnsafeUnpin for magic_sync::status::ReplicaCounts
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::ReplicaCounts
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::ReplicaCounts
#[non_exhaustive] pub struct magic_sync::status::ReplicaOverview
pub magic_sync::status::ReplicaOverview::applied_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::ReplicaOverview::backlog: core::option::Option<magic_sync::status::Backlog>
pub magic_sync::status::ReplicaOverview::failures: i32
pub magic_sync::status::ReplicaOverview::last_error: core::option::Option<alloc::string::String>
pub magic_sync::status::ReplicaOverview::owed: i64
pub magic_sync::status::ReplicaOverview::parked: i64
pub magic_sync::status::ReplicaOverview::pending: i64
pub magic_sync::status::ReplicaOverview::quarantined: i64
pub magic_sync::status::ReplicaOverview::replica: uuid::Uuid
pub magic_sync::status::ReplicaOverview::retry_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::ReplicaOverview::sent_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::ReplicaOverview::state: magic_sync::status::ReplicaState
pub magic_sync::status::ReplicaOverview::unconfirmed: bool
pub magic_sync::status::ReplicaOverview::unfiled: i64
pub magic_sync::status::ReplicaOverview::waiting_since: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::ReplicaOverview::wishes: magic_sync::status::WishCounts
impl core::clone::Clone for magic_sync::status::ReplicaOverview
pub fn magic_sync::status::ReplicaOverview::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::ReplicaOverview
pub fn magic_sync::status::ReplicaOverview::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::ReplicaOverview
pub fn magic_sync::status::ReplicaOverview::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::ReplicaOverview
impl core::marker::Send for magic_sync::status::ReplicaOverview
impl core::marker::Sync for magic_sync::status::ReplicaOverview
impl core::marker::Unpin for magic_sync::status::ReplicaOverview
impl core::marker::UnsafeUnpin for magic_sync::status::ReplicaOverview
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::ReplicaOverview
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::ReplicaOverview
#[non_exhaustive] pub struct magic_sync::status::ReplicaProgress
pub magic_sync::status::ReplicaProgress::replica: uuid::Uuid
pub magic_sync::status::ReplicaProgress::tables: alloc::vec::Vec<magic_sync::status::TableProgress>
impl core::clone::Clone for magic_sync::status::ReplicaProgress
pub fn magic_sync::status::ReplicaProgress::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::ReplicaProgress
pub fn magic_sync::status::ReplicaProgress::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::ReplicaProgress
pub fn magic_sync::status::ReplicaProgress::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::ReplicaProgress
impl core::marker::Send for magic_sync::status::ReplicaProgress
impl core::marker::Sync for magic_sync::status::ReplicaProgress
impl core::marker::Unpin for magic_sync::status::ReplicaProgress
impl core::marker::UnsafeUnpin for magic_sync::status::ReplicaProgress
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::ReplicaProgress
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::ReplicaProgress
#[non_exhaustive] pub struct magic_sync::status::RowPlace
pub magic_sync::status::RowPlace::replica: uuid::Uuid
pub magic_sync::status::RowPlace::state: magic_sync::status::RowState
impl core::clone::Clone for magic_sync::status::RowPlace
pub fn magic_sync::status::RowPlace::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::RowPlace
impl core::cmp::PartialEq for magic_sync::status::RowPlace
pub fn magic_sync::status::RowPlace::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::status::RowPlace
pub fn magic_sync::status::RowPlace::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::RowPlace
impl core::marker::StructuralPartialEq for magic_sync::status::RowPlace
impl serde_core::ser::Serialize for magic_sync::status::RowPlace
pub fn magic_sync::status::RowPlace::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::RowPlace
impl core::marker::Send for magic_sync::status::RowPlace
impl core::marker::Sync for magic_sync::status::RowPlace
impl core::marker::Unpin for magic_sync::status::RowPlace
impl core::marker::UnsafeUnpin for magic_sync::status::RowPlace
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::RowPlace
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::RowPlace
#[non_exhaustive] pub struct magic_sync::status::RowProgress
pub magic_sync::status::RowProgress::contract: u32
pub magic_sync::status::RowProgress::places: alloc::vec::Vec<magic_sync::status::RowPlace>
impl core::clone::Clone for magic_sync::status::RowProgress
pub fn magic_sync::status::RowProgress::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::RowProgress
pub fn magic_sync::status::RowProgress::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::RowProgress
pub fn magic_sync::status::RowProgress::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::RowProgress
impl core::marker::Send for magic_sync::status::RowProgress
impl core::marker::Sync for magic_sync::status::RowProgress
impl core::marker::Unpin for magic_sync::status::RowProgress
impl core::marker::UnsafeUnpin for magic_sync::status::RowProgress
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::RowProgress
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::RowProgress
#[non_exhaustive] pub struct magic_sync::status::TableOverview
pub magic_sync::status::TableOverview::in_flight: i64
pub magic_sync::status::TableOverview::parked: i64
pub magic_sync::status::TableOverview::pending: i64
pub magic_sync::status::TableOverview::quarantined: i64
pub magic_sync::status::TableOverview::replicas: i64
pub magic_sync::status::TableOverview::synced: bool
pub magic_sync::status::TableOverview::table: alloc::string::String
pub magic_sync::status::TableOverview::unfiled: i64
impl core::clone::Clone for magic_sync::status::TableOverview
pub fn magic_sync::status::TableOverview::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::TableOverview
impl core::cmp::PartialEq for magic_sync::status::TableOverview
pub fn magic_sync::status::TableOverview::eq(&self, &Self) -> bool
impl core::default::Default for magic_sync::status::TableOverview
pub fn magic_sync::status::TableOverview::default() -> Self
impl core::fmt::Debug for magic_sync::status::TableOverview
pub fn magic_sync::status::TableOverview::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for magic_sync::status::TableOverview
impl serde_core::ser::Serialize for magic_sync::status::TableOverview
pub fn magic_sync::status::TableOverview::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::TableOverview
impl core::marker::Send for magic_sync::status::TableOverview
impl core::marker::Sync for magic_sync::status::TableOverview
impl core::marker::Unpin for magic_sync::status::TableOverview
impl core::marker::UnsafeUnpin for magic_sync::status::TableOverview
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::TableOverview
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::TableOverview
#[non_exhaustive] pub struct magic_sync::status::TableProgress
pub magic_sync::status::TableProgress::holds: i64
pub magic_sync::status::TableProgress::in_flight: i64
pub magic_sync::status::TableProgress::outdated: i64
pub magic_sync::status::TableProgress::quarantined: i64
pub magic_sync::status::TableProgress::should: i64
pub magic_sync::status::TableProgress::table: alloc::string::String
pub magic_sync::status::TableProgress::to_remove: i64
impl magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::up_to_date(&self) -> i64
impl core::clone::Clone for magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::TableProgress
impl core::cmp::PartialEq for magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::eq(&self, &Self) -> bool
impl core::default::Default for magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::default() -> Self
impl core::fmt::Debug for magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for magic_sync::status::TableProgress
impl serde_core::ser::Serialize for magic_sync::status::TableProgress
pub fn magic_sync::status::TableProgress::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::TableProgress
impl core::marker::Send for magic_sync::status::TableProgress
impl core::marker::Sync for magic_sync::status::TableProgress
impl core::marker::Unpin for magic_sync::status::TableProgress
impl core::marker::UnsafeUnpin for magic_sync::status::TableProgress
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::TableProgress
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::TableProgress
#[non_exhaustive] pub struct magic_sync::status::Unfiled
pub magic_sync::status::Unfiled::attempts: i32
pub magic_sync::status::Unfiled::first_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Unfiled::id: i64
pub magic_sync::status::Unfiled::last_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::Unfiled::reason: alloc::string::String
pub magic_sync::status::Unfiled::replica: uuid::Uuid
pub magic_sync::status::Unfiled::table: alloc::string::String
impl core::clone::Clone for magic_sync::status::Unfiled
pub fn magic_sync::status::Unfiled::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::Unfiled
pub fn magic_sync::status::Unfiled::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::Unfiled
pub fn magic_sync::status::Unfiled::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::Unfiled
impl core::marker::Send for magic_sync::status::Unfiled
impl core::marker::Sync for magic_sync::status::Unfiled
impl core::marker::Unpin for magic_sync::status::Unfiled
impl core::marker::UnsafeUnpin for magic_sync::status::Unfiled
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::Unfiled
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::Unfiled
#[non_exhaustive] pub struct magic_sync::status::UpProgress
pub magic_sync::status::UpProgress::set_aside: i64
pub magic_sync::status::UpProgress::table: alloc::string::String
pub magic_sync::status::UpProgress::unfiled: i64
pub magic_sync::status::UpProgress::unsent: i64
impl core::clone::Clone for magic_sync::status::UpProgress
pub fn magic_sync::status::UpProgress::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::UpProgress
impl core::cmp::PartialEq for magic_sync::status::UpProgress
pub fn magic_sync::status::UpProgress::eq(&self, &Self) -> bool
impl core::fmt::Debug for magic_sync::status::UpProgress
pub fn magic_sync::status::UpProgress::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for magic_sync::status::UpProgress
impl serde_core::ser::Serialize for magic_sync::status::UpProgress
pub fn magic_sync::status::UpProgress::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl<'de> serde_core::de::Deserialize<'de> for magic_sync::status::UpProgress
pub fn magic_sync::status::UpProgress::deserialize<__D>(__D) -> core::result::Result<Self, <__D as serde_core::de::Deserializer>::Error> where __D: serde_core::de::Deserializer<'de>
impl core::marker::Freeze for magic_sync::status::UpProgress
impl core::marker::Send for magic_sync::status::UpProgress
impl core::marker::Sync for magic_sync::status::UpProgress
impl core::marker::Unpin for magic_sync::status::UpProgress
impl core::marker::UnsafeUnpin for magic_sync::status::UpProgress
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::UpProgress
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::UpProgress
#[non_exhaustive] pub struct magic_sync::status::WishCounts
pub magic_sync::status::WishCounts::pending: i64
pub magic_sync::status::WishCounts::refused: i64
pub magic_sync::status::WishCounts::superseded: i64
pub magic_sync::status::WishCounts::waiting: i64
impl core::clone::Clone for magic_sync::status::WishCounts
pub fn magic_sync::status::WishCounts::clone(&self) -> Self
impl core::cmp::Eq for magic_sync::status::WishCounts
impl core::cmp::PartialEq for magic_sync::status::WishCounts
pub fn magic_sync::status::WishCounts::eq(&self, &Self) -> bool
impl core::default::Default for magic_sync::status::WishCounts
pub fn magic_sync::status::WishCounts::default() -> Self
impl core::fmt::Debug for magic_sync::status::WishCounts
pub fn magic_sync::status::WishCounts::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for magic_sync::status::WishCounts
impl core::marker::StructuralPartialEq for magic_sync::status::WishCounts
impl serde_core::ser::Serialize for magic_sync::status::WishCounts
pub fn magic_sync::status::WishCounts::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::WishCounts
impl core::marker::Send for magic_sync::status::WishCounts
impl core::marker::Sync for magic_sync::status::WishCounts
impl core::marker::Unpin for magic_sync::status::WishCounts
impl core::marker::UnsafeUnpin for magic_sync::status::WishCounts
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::WishCounts
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::WishCounts
#[non_exhaustive] pub struct magic_sync::status::WishEntry
pub magic_sync::status::WishEntry::answered_at: core::option::Option<chrono::datetime::DateTime<chrono::offset::utc::Utc>>
pub magic_sync::status::WishEntry::key: alloc::string::String
pub magic_sync::status::WishEntry::note: core::option::Option<alloc::string::String>
pub magic_sync::status::WishEntry::reason: core::option::Option<alloc::string::String>
pub magic_sync::status::WishEntry::replica: uuid::Uuid
pub magic_sync::status::WishEntry::state: magic_sync::status::WishState
pub magic_sync::status::WishEntry::table: alloc::string::String
pub magic_sync::status::WishEntry::wished_at: chrono::datetime::DateTime<chrono::offset::utc::Utc>
impl core::clone::Clone for magic_sync::status::WishEntry
pub fn magic_sync::status::WishEntry::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::WishEntry
pub fn magic_sync::status::WishEntry::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::WishEntry
pub fn magic_sync::status::WishEntry::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::WishEntry
impl core::marker::Send for magic_sync::status::WishEntry
impl core::marker::Sync for magic_sync::status::WishEntry
impl core::marker::Unpin for magic_sync::status::WishEntry
impl core::marker::UnsafeUnpin for magic_sync::status::WishEntry
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::WishEntry
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::WishEntry
#[non_exhaustive] pub struct magic_sync::status::WishListing
pub magic_sync::status::WishListing::contract: u32
pub magic_sync::status::WishListing::now: chrono::datetime::DateTime<chrono::offset::utc::Utc>
pub magic_sync::status::WishListing::offset: u32
pub magic_sync::status::WishListing::state: core::option::Option<magic_sync::status::WishState>
pub magic_sync::status::WishListing::wishes: magic_sync::status::Listed<magic_sync::status::WishEntry>
impl core::clone::Clone for magic_sync::status::WishListing
pub fn magic_sync::status::WishListing::clone(&self) -> Self
impl core::fmt::Debug for magic_sync::status::WishListing
pub fn magic_sync::status::WishListing::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl serde_core::ser::Serialize for magic_sync::status::WishListing
pub fn magic_sync::status::WishListing::serialize<__S>(&self, __S) -> core::result::Result<<__S as serde_core::ser::Serializer>::Ok, <__S as serde_core::ser::Serializer>::Error> where __S: serde_core::ser::Serializer
impl core::marker::Freeze for magic_sync::status::WishListing
impl core::marker::Send for magic_sync::status::WishListing
impl core::marker::Sync for magic_sync::status::WishListing
impl core::marker::Unpin for magic_sync::status::WishListing
impl core::marker::UnsafeUnpin for magic_sync::status::WishListing
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::status::WishListing
impl core::panic::unwind_safe::UnwindSafe for magic_sync::status::WishListing
pub const magic_sync::status::CONTRACT: u32
pub mod magic_sync::wire
pub struct magic_sync::wire::Codec<P>
impl<P: core::marker::Sync + 'static> magic_sync::wire::Codec<P>
pub fn magic_sync::wire::Codec<P>::json<R>(core::option::Option<magic_sync::wire::Place<R, P>>) -> Self where R: magic_sync::row::Row + core::clone::Clone + core::marker::Send + core::marker::Sync + serde_core::ser::Serialize + serde_core::de::DeserializeOwned
pub fn magic_sync::wire::Codec<P>::new<R, M>(fn(R) -> core::result::Result<M, magic_sync::wire::MapError>, fn(M) -> core::result::Result<R, magic_sync::wire::MapError>, core::option::Option<magic_sync::wire::Place<R, P>>) -> Self where R: magic_sync::row::Row + core::clone::Clone + core::marker::Send + core::marker::Sync, M: prost::message::Message + core::default::Default + 'static
impl<P> core::fmt::Debug for magic_sync::wire::Codec<P>
pub fn magic_sync::wire::Codec<P>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<P> core::marker::Freeze for magic_sync::wire::Codec<P> where alloc::boxed::Box<dyn Ops<P>>: core::marker::Freeze
impl<P> core::marker::Send for magic_sync::wire::Codec<P> where alloc::boxed::Box<dyn Ops<P>>: core::marker::Send
impl<P> core::marker::Sync for magic_sync::wire::Codec<P> where alloc::boxed::Box<dyn Ops<P>>: core::marker::Sync
impl<P> core::marker::Unpin for magic_sync::wire::Codec<P> where alloc::boxed::Box<dyn Ops<P>>: core::marker::Unpin
impl<P> core::marker::UnsafeUnpin for magic_sync::wire::Codec<P> where alloc::boxed::Box<dyn Ops<P>>: core::marker::UnsafeUnpin
impl<P> !core::panic::unwind_safe::RefUnwindSafe for magic_sync::wire::Codec<P>
impl<P> !core::panic::unwind_safe::UnwindSafe for magic_sync::wire::Codec<P>
pub struct magic_sync::wire::MapError(_)
impl magic_sync::wire::MapError
pub fn magic_sync::wire::MapError::new(impl core::fmt::Display) -> Self
impl core::fmt::Debug for magic_sync::wire::MapError
pub fn magic_sync::wire::MapError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for magic_sync::wire::MapError
pub fn magic_sync::wire::MapError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E: core::error::Error> core::convert::From<E> for magic_sync::wire::MapError
pub fn magic_sync::wire::MapError::from(E) -> Self
impl core::marker::Freeze for magic_sync::wire::MapError
impl core::marker::Send for magic_sync::wire::MapError
impl core::marker::Sync for magic_sync::wire::MapError
impl core::marker::Unpin for magic_sync::wire::MapError
impl core::marker::UnsafeUnpin for magic_sync::wire::MapError
impl core::panic::unwind_safe::RefUnwindSafe for magic_sync::wire::MapError
impl core::panic::unwind_safe::UnwindSafe for magic_sync::wire::MapError
pub type magic_sync::wire::Place<R, P> = fn(&mut R, uuid::Uuid, &P)
#[non_exhaustive] pub enum magic_sync::Error
pub magic_sync::Error::Database(sqlx_core::error::Error)
#[non_exhaustive] pub magic_sync::Error::Host
pub magic_sync::Error::Host::reason: alloc::string::String
pub magic_sync::Error::Host::transient: bool
pub magic_sync::Error::Malformed
pub magic_sync::Error::Malformed::reason: alloc::string::String
pub magic_sync::Error::Malformed::table: alloc::string::String
pub magic_sync::Error::Misuse(alloc::string::String)
pub magic_sync::Error::Protocol
pub magic_sync::Error::Protocol::ours: u32
pub magic_sync::Error::Protocol::theirs: u32
#[non_exhaustive] pub magic_sync::Error::Transport
pub magic_sync::Error::Transport::reason: alloc::string::String
pub magic_sync::Error::Transport::transient: bool
impl magic_sync::Error
pub fn magic_sync::Error::host(bool, impl core::convert::Into<alloc::string::String>) -> Self
pub fn magic_sync::Error::is_transient(&self) -> bool
pub fn magic_sync::Error::transport(bool, impl core::convert::Into<alloc::string::String>) -> Self
impl core::convert::From<sqlx_core::error::Error> for magic_sync::Error
pub fn magic_sync::Error::from(sqlx_core::error::Error) -> Self
impl core::error::Error for magic_sync::Error
pub fn magic_sync::Error::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for magic_sync::Error
pub fn magic_sync::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for magic_sync::Error
pub fn magic_sync::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for magic_sync::Error
impl core::marker::Send for magic_sync::Error
impl core::marker::Sync for magic_sync::Error
impl core::marker::Unpin for magic_sync::Error
impl core::marker::UnsafeUnpin for magic_sync::Error
impl !core::panic::unwind_safe::RefUnwindSafe for magic_sync::Error
impl !core::panic::unwind_safe::UnwindSafe for magic_sync::Error
pub const magic_sync::SERVER_SCHEMA_VERSION: i32
pub trait magic_sync::Columns: crate::__private::Sealed
pub trait magic_sync::Row: magic_sync::row::Columns + for<'r> sqlx_core::from_row::FromRow<'r, <__private::Db as sqlx_core::database::Database>::Row> + core::marker::Send + core::marker::Unpin + 'static
pub const magic_sync::Row::KEY: &'static [&'static str]
pub const magic_sync::Row::MIRROR: magic_sync::row::Mirror
pub const magic_sync::Row::SCHEMA: &'static str
pub const magic_sync::Row::TABLE: &'static str
pub fn magic_sync::Row::key(&self) -> magic_sync::row::Key
pub fn magic_sync::Row::key_text(&self) -> alloc::string::String
pub type magic_sync::Conn = sqlx_postgres::connection::PgConnection