Struct thrift_pool::MakeThriftConnectionFromAddrs

pub struct MakeThriftConnectionFromAddrs<T, S> { /* fields omitted */ }

A MakeThriftConnection that attempts to create new connections from a ToSocketAddrs and a FromProtocol

The connection is accordance with the thrift rust tutorial:

• Open a TTcpChannel
• Split it
• Create TReadTransport and TWriteTransport
• Create TInputProtocol and TOutputProtocol
• Create a client with i_prot and o_prot

For that to happen, T needs to be able to create the Read/Write Transports and Input/Output Protocols from the ReadHalf and WriteHalf of the TTcpChannel. Those contraints should be fairly easily satisfied by implementing the relevant traits in the library

use thrift_pool::{MakeThriftConnectionFromAddrs, FromProtocol};

use thrift::{
    protocol::{TCompactInputProtocol, TCompactOutputProtocol, TInputProtocol, TOutputProtocol},
    transport::{
        ReadHalf, TFramedReadTransport, TFramedWriteTransport, TIoChannel, TReadTransport,
        TTcpChannel, TWriteTransport, WriteHalf,
    },
};

// A typical generated client looks like this
struct MyThriftClient<Ip: TInputProtocol, Op: TOutputProtocol> {
    i_prot: Ip,
    o_prot: Op,
}
impl<Ip: TInputProtocol, Op: TOutputProtocol> FromProtocol for MyThriftClient<Ip, Op> {
    type InputProtocol = Ip;

    type OutputProtocol = Op;

    fn from_protocol(
        input_protocol: Self::InputProtocol,
        output_protocol: Self::OutputProtocol,
    ) -> Self {
        MyThriftClient {
            i_prot: input_protocol,
            o_prot: output_protocol,
        }
    }
}
type Client = MyThriftClient<
    TCompactInputProtocol<TFramedReadTransport<ReadHalf<TTcpChannel>>>,
    TCompactOutputProtocol<TFramedWriteTransport<WriteHalf<TTcpChannel>>>,
>;

// The Protocols/Transports used in this client implement the necessary traits so we can do this
let manager =
    MakeThriftConnectionFromAddrs::<Client, _>::new("localhost:9090").into_connection_manager();

Implementations

impl<T, S> MakeThriftConnectionFromAddrs<T, S>

pub fn new(addrs: S) -> Self

impl<S: ToSocketAddrs + Clone, Rt: FromRead<Read = ReadHalf<TTcpChannel>>, Ip: FromReadTransport<ReadTransport = Rt>, Wt: FromWrite<Write = WriteHalf<TTcpChannel>>, Op: FromWriteTransport<WriteTransport = Wt>, T: FromProtocol<InputProtocol = Ip, OutputProtocol = Op>> MakeThriftConnectionFromAddrs<T, S>

pub fn into_connection_manager(self) -> ThriftConnectionManager<Self>

Trait Implementations

impl<T, S: Clone> Clone for MakeThriftConnectionFromAddrs<T, S>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, S: Debug> Debug for MakeThriftConnectionFromAddrs<T, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: ToSocketAddrs + Clone, Rt: FromRead<Read = ReadHalf<TTcpChannel>>, Ip: FromReadTransport<ReadTransport = Rt>, Wt: FromWrite<Write = WriteHalf<TTcpChannel>>, Op: FromWriteTransport<WriteTransport = Wt>, T: FromProtocol<InputProtocol = Ip, OutputProtocol = Op>> MakeThriftConnection for MakeThriftConnectionFromAddrs<T, S>

type Error = Error

The error type returned when a connection creation fails

type Output = T

The connection type the we are trying to create

fn make_thrift_connection(&self) -> Result<Self::Output, Self::Error>

Attempt to create a new connection