Struct mz_adapter::coord::ConnMeta

pub struct ConnMeta {
    secret_key: u32,
    connected_at: EpochMillis,
    user: User,
    application_name: String,
    uuid: Uuid,
    conn_id: ConnectionId,
    client_ip: Option<IpAddr>,
    drop_sinks: BTreeSet<GlobalId>,
    deferred_lock: Option<OwnedMutexGuard<()>>,
    pending_cluster_alters: BTreeSet<ClusterId>,
    notice_tx: UnboundedSender<AdapterNotice>,
    authenticated_role: RoleId,
}

Metadata about an active connection.

Fields

secret_key: u32

Pgwire specifies that every connection have a 32-bit secret associated with it, that is known to both the client and the server. Cancellation requests are required to authenticate with the secret of the connection that they are targeting.

connected_at: EpochMillis

The time when the session’s connection was initiated.

user: User

application_name: String

uuid: Uuid

conn_id: ConnectionId

client_ip: Option<IpAddr>

drop_sinks: BTreeSet<GlobalId>

Sinks that will need to be dropped when the current transaction, if any, is cleared.

deferred_lock: Option<OwnedMutexGuard<()>>

Lock for the Coordinator’s deferred statements that is dropped on transaction clear.

pending_cluster_alters: BTreeSet<ClusterId>

Cluster reconfigurations that will need to be cleaned up when the current transaction is cleared

notice_tx: UnboundedSender<AdapterNotice>

Channel on which to send notices to a session.

authenticated_role: RoleId

The role that initiated the database context. Fixed for the duration of the connection. WARNING: This role reference is not updated when the role is dropped. Consumers should not assume that this role exist.

Implementations

impl ConnMeta

pub fn conn_id(&self) -> &ConnectionId

pub fn user(&self) -> &User

pub fn application_name(&self) -> &str

pub fn authenticated_role_id(&self) -> &RoleId

pub fn uuid(&self) -> Uuid

pub fn client_ip(&self) -> Option<IpAddr>

pub fn connected_at(&self) -> EpochMillis

Trait Implementations

impl Debug for ConnMeta

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

Formats the value using the given formatter.

impl Serialize for ConnMeta

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

where __S: Serializer,

Serialize this value into the given Serde serializer.