Struct TtheaderCoreService

pub struct TtheaderCoreService<H> { /* private fields */ }

Core Thrift service handler supporting the THeader protocol.

TtheaderCoreService is responsible for accepting Thrift connections, decoding requests, routing them through a handler chain, and encoding responses. It supports the THeader protocol for efficient message framing and metadata handling. For implementation details and example usage, see the module level documentation.

Implementations

impl<H> TtheaderCoreService<H>

pub fn new(handler_chain: H, thrift_timeout: ThriftServerTimeout) -> Self

impl<F> TtheaderCoreService<F>

pub fn layer<C>() -> impl FactoryLayer<C, F, Factory = Self>

where C: Param<ThriftServerTimeout>,

Trait Implementations

impl<F: AsyncMakeService> AsyncMakeService for TtheaderCoreService<F>

type Service = TtheaderCoreService<<F as AsyncMakeService>::Service>

The type of service this factory creates.

type Error = <F as AsyncMakeService>::Error

The type of error that can occur during service creation.

async fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Asynchronously creates a new service, optionally using an existing service as a reference.

fn make(&self) -> impl Future<Output = Result<Self::Service, Self::Error>>

Asynchronously creates a new service without referencing an existing one.

impl<H: Clone> Clone for TtheaderCoreService<H>

fn clone(&self) -> TtheaderCoreService<H>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F> MakeService for TtheaderCoreService<F>

where F: MakeService,

type Service = TtheaderCoreService<<F as MakeService>::Service>

The type of service this factory creates.

type Error = <F as MakeService>::Error

The type of error that can occur during service creation.

fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Creates a new service, optionally using an existing service as a reference.

fn make(&self) -> Result<Self::Service, Self::Error>

Creates a new service without referencing an existing one.

impl<H, Stream, CXIn, CXStore, CXState, ERR> Service<(Stream, CXIn)> for TtheaderCoreService<H>

where CXIn: ParamRef<PeerAddr> + Fork<Store = CXStore, State = CXState>, CXStore: 'static, for<'a> CXState: Attach<CXStore>, for<'a> H: ThriftHandler<<CXState as Attach<CXStore>>::Hdr<'a>, Error = ERR>, ERR: Into<AnyError> + Debug, Stream: AsyncReadRent + AsyncWriteRent + Unpin + 'static,

type Response = ()

The type of response returned by this service.

type Error = Infallible

The type of error that this service can produce.

async fn call( &self, __arg1: (Stream, CXIn), ) -> Result<Self::Response, Self::Error>

Asynchronously process the request and return the response.