Struct Connection 

pub struct Connection { /* private fields */ }

Async connection wrapper for TCP/TLS socket This is the async I/O boundary - all socket operations are async

Implementations

impl Connection

pub fn new(stream: TcpStream) -> Self

Create a new connection from a TCP stream

pub async fn connect(host: &str, port: u16) -> Result<Self>

Connect to a ClickHouse server with default options

pub async fn connect_with_options( host: &str, port: u16, options: &ConnectionOptions, ) -> Result<Self>

Connect to a ClickHouse server with custom options

pub async fn read_varint(&mut self) -> Result<u64>

Read a varint-encoded u64

pub async fn write_varint(&mut self, value: u64) -> Result<()>

Write a varint-encoded u64

pub async fn read_u8(&mut self) -> Result<u8>

Read a fixed-size value

pub async fn read_u16(&mut self) -> Result<u16>

Read a little-endian u16

pub async fn read_u32(&mut self) -> Result<u32>

Read a little-endian u32

pub async fn read_u64(&mut self) -> Result<u64>

Read a little-endian u64

pub async fn read_i8(&mut self) -> Result<i8>

Read a signed i8

pub async fn read_i16(&mut self) -> Result<i16>

Read a little-endian i16

pub async fn read_i32(&mut self) -> Result<i32>

Read a little-endian i32

pub async fn read_i64(&mut self) -> Result<i64>

Read a little-endian i64

pub async fn write_u8(&mut self, value: u8) -> Result<()>

Write fixed-size values

pub async fn write_u16(&mut self, value: u16) -> Result<()>

Write a little-endian u16

pub async fn write_u32(&mut self, value: u32) -> Result<()>

Write a little-endian u32

pub async fn write_u64(&mut self, value: u64) -> Result<()>

Write a little-endian u64

pub async fn write_u128(&mut self, value: u128) -> Result<()>

Write a little-endian u128

pub async fn write_i8(&mut self, value: i8) -> Result<()>

Write a signed i8

pub async fn write_i16(&mut self, value: i16) -> Result<()>

Write a little-endian i16

pub async fn write_i32(&mut self, value: i32) -> Result<()>

Write a little-endian i32

pub async fn write_i64(&mut self, value: i64) -> Result<()>

Write a little-endian i64

pub async fn read_string(&mut self) -> Result<String>

Read a length-prefixed string

pub async fn write_string(&mut self, s: &str) -> Result<()>

Write a length-prefixed string

pub async fn write_quoted_string(&mut self, s: &str) -> Result<()>

Write a quoted string for query parameters

pub async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

Read exact number of bytes into a buffer

pub async fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>

Read bytes into an existing buffer

pub async fn write_bytes(&mut self, data: &[u8]) -> Result<()>

Write bytes

pub async fn flush(&mut self) -> Result<()>

Flush the write buffer

pub async fn read_packet(&mut self) -> Result<Bytes>

Read a complete packet (length-prefixed data) Returns the packet data without the length prefix

pub async fn write_packet(&mut self, data: &[u8]) -> Result<()>

Write a packet with length prefix