Enum PGMessage

pub enum PGMessage {
    Notify(PGNotifyMessage),
    Raise(PGRaiseMessage),
    Reconnect {
        timestamp: Timestamp,
        attempts: u32,
        max_attempts: u32,
    },
    Timeout {
        timestamp: Timestamp,
        duration: Duration,
    },
    Cancelled {
        timestamp: Timestamp,
        success: bool,
    },
    FailedToReconnect {
        timestamp: Timestamp,
        attempts: u32,
    },
}

Type used to represent any of the messages that can be received by the client callback.

Variants

Notify(PGNotifyMessage)

Raise(PGRaiseMessage)

Reconnect

Fields

timestamp: Timestamp

attempts: u32

max_attempts: u32

Timeout

Fields

timestamp: Timestamp

duration: Duration

Cancelled

Fields

timestamp: Timestamp

success: bool

FailedToReconnect

Fields

timestamp: Timestamp

attempts: u32

Implementations

impl PGMessage

pub fn reconnect(attempts: u32, max_attempts: u32) -> Self

pub fn timeout(duration: Duration) -> Self

pub fn cancelled(success: bool) -> Self

pub fn failed_to_reconnect(attempts: u32) -> Self

Trait Implementations

impl Clone for PGMessage

fn clone(&self) -> PGMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PGMessage

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

Formats the value using the given formatter.

impl Display for PGMessage

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

Formats the value using the given formatter.

impl From<DbError> for PGMessage

fn from(raise: DbError) -> Self

Converts to this type from the input type.

impl From<Notification> for PGMessage

fn from(note: Notification) -> Self

Converts to this type from the input type.

impl Serialize for PGMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.