Struct klickhouse::Client [−][src]
pub struct Client { /* fields omitted */ }
Expand description
Client handle for a Clickhouse connection, has internal reference to connection, and can be freely cloned and sent across threads.
Implementations
impl Client
[src]
impl Client
[src]pub fn connect_stream(
read: impl AsyncRead + Unpin + Send + Sync + 'static,
writer: impl AsyncWrite + Unpin + Send + Sync + 'static,
options: ClientOptions
) -> Self
[src]
pub fn connect_stream(
read: impl AsyncRead + Unpin + Send + Sync + 'static,
writer: impl AsyncWrite + Unpin + Send + Sync + 'static,
options: ClientOptions
) -> Self
[src]Consumes a reader and writer to connect to Klickhouse. To be used for exotic setups or TLS. Generally prefer Client::connect()
pub async fn connect<A: ToSocketAddrs>(
destination: A,
options: ClientOptions
) -> Result<Self>
[src]
pub async fn connect<A: ToSocketAddrs>(
destination: A,
options: ClientOptions
) -> Result<Self>
[src]Connects to a specific socket address over plaintext TCP for Clickhouse.
pub async fn query_raw(&self, query: &str) -> Result<impl Stream<Item = Block>>
[src]
pub async fn query_raw(&self, query: &str) -> Result<impl Stream<Item = Block>>
[src]Sends a query string and read column blocks over a stream.
You probably want Client::query()
pub async fn insert_native_raw(
&self,
query: &str,
blocks: impl Stream<Item = Block> + Send + Sync + Unpin + 'static
) -> Result<impl Stream<Item = Block>>
[src]
pub async fn insert_native_raw(
&self,
query: &str,
blocks: impl Stream<Item = Block> + Send + Sync + Unpin + 'static
) -> Result<impl Stream<Item = Block>>
[src]Sends a query string with streaming associated data (i.e. insert) over native protocol.
Once all outgoing blocks are written (EOF of blocks
stream), then any response blocks from Clickhouse are read.
You probably want Client::insert_native
.
pub async fn insert_native<T: Row + Send + Sync + 'static>(
&self,
query: &str,
blocks: impl Stream<Item = Vec<T>> + Send + Sync + Unpin + 'static
) -> Result<()>
[src]
pub async fn insert_native<T: Row + Send + Sync + 'static>(
&self,
query: &str,
blocks: impl Stream<Item = Vec<T>> + Send + Sync + Unpin + 'static
) -> Result<()>
[src]Sends a query string with streaming associated data (i.e. insert) over native protocol.
Once all outgoing blocks are written (EOF of blocks
stream), then any response blocks from Clickhouse are read and DISCARDED.
Make sure any query you send native data with has a format native
suffix.
pub async fn insert_native_block<T: Row + Send + Sync + 'static>(
&self,
query: &str,
blocks: Vec<T>
) -> Result<()>
[src]
pub async fn insert_native_block<T: Row + Send + Sync + 'static>(
&self,
query: &str,
blocks: Vec<T>
) -> Result<()>
[src]Wrapper over Client::insert_native
to send a single block.
Make sure any query you send native data with has a format native
suffix.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more