cdrs-async 0.1.0-alpha.0

Asynchronous driver for Apache Cassandra
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
25
26
27

use {
  async_trait::async_trait,
  std::{io, marker::Unpin, net},
};

use async_std::io::{Read, Write};

/// Generic transport trait which is implemented by transports provided by CDRS.
///
/// It requires that implementor had following traits implementations: `Sized`,
/// `Send`, `Unpin`, async `Read` and `Write`.
#[async_trait]
pub trait CDRSTransport: Sized + Read + Write + Send + Sync + Unpin {
  // TODO: uncomment it
  // /// Creates a new independently owned handle to the underlying socket.
  // ///
  // /// The returned TcpStream is a reference to the same stream that this object references.
  // /// Both handles will read and write the same stream of data, and options set on one stream
  // /// will be propagated to the other stream.
  // async fn try_clone(&self) -> io::Result<Self>;

  /// Shuts down the read, write, or both halves of this connection.
  fn close(&mut self, close: net::Shutdown) -> io::Result<()>;

  /// Method that checks that transport is alive
  fn is_alive(&self) -> bool;
}