Struct FrameRouteService 

pub struct FrameRouteService<State = (), E = Error> { /* private fields */ }

Route Frame to a Service via API key

A simple example that routes MetadataRequest and CreateTopicsRequest. ApiVersionsRequest is created by the builder including both of the implemented services using the version ranges from RootMessageMeta.

let router = FrameRouteService::<(), Error>::builder()
    .with_service(
        RequestLayer::<MetadataRequest>::new().into_layer(ResponseService::new(|_, _| {
            Ok(MetadataResponse::default()
                .brokers(Some([].into()))
                .topics(Some([].into()))
                .cluster_id(Some("tansu".into()))
                .controller_id(Some(111))
                .throttle_time_ms(Some(0))
                .cluster_authorized_operations(Some(-1)))
        })),
    )
    .and_then(|builder| {
        builder.with_service(RequestLayer::<CreateTopicsRequest>::new().into_layer(
            ResponseService::new(|_, _| {
                Ok(CreateTopicsResponse::default()
                    .throttle_time_ms(Some(0))
                    .topics(Some([].into())))
            }),
        ))
    })
    .and_then(|builder| builder.build())?;

Implementations

impl<State, E> FrameRouteService<State, E>

where State: Clone + Send + Sync + 'static, E: Error + From<Error> + From<Error> + Send + Sync + 'static,

pub fn new( routes: Arc<BTreeMap<i16, BoxService<State, Frame, Frame, E>>>, ) -> Self

pub fn builder() -> FrameRouteBuilder<State, E>

Trait Implementations

impl<State: Clone, E: Clone> Clone for FrameRouteService<State, E>

fn clone(&self) -> FrameRouteService<State, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<State: Debug, E: Debug> Debug for FrameRouteService<State, E>

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

Formats the value using the given formatter.

impl<State: Default, E: Default> Default for FrameRouteService<State, E>

fn default() -> FrameRouteService<State, E>

Returns the “default value” for a type.

impl<State, E> Service<State, Frame> for FrameRouteService<State, E>

where State: Clone + Send + Sync + 'static, E: Error + From<Error> + From<Error> + Send + Sync + 'static,

type Response = Frame

The type of response returned by the service.

type Error = E

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Frame, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.