sqlx-core 0.2.6

Core of SQLx, the rust SQL toolkit. Not intended to be used directly.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use super::Encode;
use crate::io::BufMut;
use byteorder::NetworkEndian;

/// Sent instead of [`StartupMessage`] with a new connection to cancel a running query on an existing
/// connection.
///
/// https://www.postgresql.org/docs/devel/protocol-flow.html#id-1.10.5.7.9
pub struct CancelRequest {
    /// The process ID of the target database.
    pub process_id: i32,

    /// The secret key for the target database.
    pub secret_key: i32,
}

impl Encode for CancelRequest {
    fn encode(&self, buf: &mut Vec<u8>) {
        buf.put_i32::<NetworkEndian>(16); // message length
        buf.put_i32::<NetworkEndian>(8087_7102); // constant for cancel request
        buf.put_i32::<NetworkEndian>(self.process_id);
        buf.put_i32::<NetworkEndian>(self.secret_key);
    }
}