reddb::wire_proto::replication::basebackup

Struct BaseBackupChunk

pub struct BaseBackupChunk {Show 26 fields
    pub snapshot_available: bool,
    pub replica_id: String,
    pub slot_restart_lsn: u64,
    pub snapshot_lsn: Option<u64>,
    pub snapshot_token: Option<String>,
    pub snapshot_total_bytes: Option<u64>,
    pub snapshot_offset: u64,
    pub next_snapshot_offset: Option<u64>,
    pub snapshot_complete: bool,
    pub snapshot_path: Option<String>,
    pub snapshot_chunk: Option<Vec<u8>>,
    pub snapshot_hex: Option<Vec<u8>>,
    pub metadata_binary: Option<Vec<u8>>,
    pub metadata_json: Option<Vec<u8>>,
    pub header_shadow: Option<Vec<u8>>,
    pub metadata_shadow: Option<Vec<u8>>,
    pub basebackup_available: bool,
    pub basebackup_timeline: Option<u64>,
    pub basebackup_start_lsn: Option<u64>,
    pub basebackup_checkpoint_lsn: Option<u64>,
    pub basebackup_snapshot_bytes: Option<u64>,
    pub basebackup_snapshot_checksum: Option<u64>,
    pub basebackup_manifest: Option<Vec<u8>>,
    pub basebackup_chunks: Vec<BaseBackupManifestChunk>,
    pub basebackup_chunk_ordinal: Option<u32>,
    pub basebackup_chunk: Option<Vec<u8>>,
}

Fields§

§snapshot_available: bool§replica_id: String§slot_restart_lsn: u64§snapshot_lsn: Option<u64>§snapshot_token: Option<String>§snapshot_total_bytes: Option<u64>§snapshot_offset: u64§next_snapshot_offset: Option<u64>§snapshot_complete: bool§snapshot_path: Option<String>§snapshot_chunk: Option<Vec<u8>>§snapshot_hex: Option<Vec<u8>>§metadata_binary: Option<Vec<u8>>§metadata_json: Option<Vec<u8>>§header_shadow: Option<Vec<u8>>§metadata_shadow: Option<Vec<u8>>§basebackup_available: bool§basebackup_timeline: Option<u64>§basebackup_start_lsn: Option<u64>§basebackup_checkpoint_lsn: Option<u64>§basebackup_snapshot_bytes: Option<u64>§basebackup_snapshot_checksum: Option<u64>§basebackup_manifest: Option<Vec<u8>>§basebackup_chunks: Vec<BaseBackupManifestChunk>§basebackup_chunk_ordinal: Option<u32>§basebackup_chunk: Option<Vec<u8>>

Struct BaseBackupChunk Copy item path

Fields§

Implementations§

impl BaseBackupChunk

pub fn new( replica_id: impl Into<String>, slot_restart_lsn: u64, ) -> BaseBackupChunk

pub fn encode_json(&self) -> Vec<u8> ⓘ

pub fn decode_json( bytes: &[u8], ) -> Result<BaseBackupChunk, ReplicationPayloadError>

pub fn required_basebackup_manifest( &self, ) -> Result<Option<&[u8]>, ReplicationPayloadError>

pub fn basebackup_chunk_part( &self, ) -> Result<Option<BaseBackupChunkPart<'_>>, ReplicationPayloadError>

Trait Implementations§

impl Clone for BaseBackupChunk

fn clone(&self) -> BaseBackupChunk

fn clone_from(&mut self, source: &Self)

impl Debug for BaseBackupChunk

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

impl Eq for BaseBackupChunk

impl PartialEq for BaseBackupChunk

fn eq(&self, other: &BaseBackupChunk) -> bool

fn ne(&self, other: &Rhs) -> bool

impl StructuralPartialEq for BaseBackupChunk

Auto Trait Implementations§

impl Freeze for BaseBackupChunk

impl RefUnwindSafe for BaseBackupChunk

impl Send for BaseBackupChunk

impl Sync for BaseBackupChunk

impl Unpin for BaseBackupChunk

impl UnsafeUnpin for BaseBackupChunk

impl UnwindSafe for BaseBackupChunk

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

Struct BaseBackupChunk

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,