Struct opensrv_mysql::AsyncMysqlIntermediary

pub struct AsyncMysqlIntermediary<B, S: AsyncRead + Unpin, W> { /* private fields */ }

A server that speaks the MySQL/MariaDB protocol, and can delegate client commands to a backend that implements AsyncMysqlShim.

Implementations

impl<B, R, W> AsyncMysqlIntermediary<B, R, W>where
    W: AsyncWrite + Send + Unpin,
    B: AsyncMysqlShim<W> + Send + Sync,
    R: AsyncRead + Send + Unpin,

pub async fn run_on(shim: B, stream: R, output_stream: W) -> Result<(), B::Error>

Create a new server over two one-way channels and process client commands until the client disconnects or an error occurs.

pub async fn run_with_options(
    shim: B,
    input_stream: R,
    output_stream: W,
    opts: &IntermediaryOptions
) -> Result<(), B::Error>

Create a new server over two one-way channels and process client commands until the client disconnects or an error occurs, with config options.

pub async fn init_before_ssl(
    shim: &mut B,
    input_stream: R,
    output_stream: &mut W,
    tls_conf: &Option<Arc<ServerConfig>>
) -> Result<(bool, (ClientHandshake, u8, CapabilityFlags, PacketReader<R>)), B::Error>

pub async fn init_after_ssl(
    &mut self,
    handshake: ClientHandshake,
    seq: u8
) -> Result<(), B::Error>