Struct MakeThriftConnectionFromAddrs 

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

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

The connection is created in accordance with the thrift rust tutorial:

• Open a TTcpChannel and split it
• Use the created [ReadHalf] and [WriteHalf] to create TReadTransport and TWriteTransport
• Use those to create TInputProtocol and TOutputProtocol
• Create a new client with i_prot and o_prot – It needs to implement FromProtocol

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 duplicate 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