Help dynamically adding services to a server #744

itmecho · 2021-08-14T22:31:46Z

itmecho
Aug 14, 2021

I'm trying to write a reusable wrapper to use across some microservices but I can't figure out how to add an unknown amount of services to a Server. This is a rough idea of the wrapper:

use std::{collections::HashMap, error::Error, net::SocketAddr};

use http::{Request, Response};
use tonic::{
    body::BoxBody,
    transport::{Body, NamedService},
};

pub struct Service<S> {
    servers: HashMap<SocketAddr, Vec<S>>,
}

impl<S> Service<S>
where
    S: tower::Service<Request<Body>, Response = Response<BoxBody>>
        + NamedService
        + Clone
        + Send
        + 'static,
    S::Future: Send + 'static,
    S::Error: Into<Box<dyn Error + Send + Sync>> + Send,
{
    pub fn builder() -> Self {
        Self {
            servers: HashMap::new(),
        }
    }

    pub fn with_server(mut self, addr: SocketAddr, server: S) -> Self {
        self.servers.entry(addr).or_default().push(server);
        self
    }

    pub fn run(self) -> Result<(), Box<dyn Error>> {
        let mut x = vec![];
        for (addr, services) in self.servers {
            let server = tonic::transport::Server::builder(); // <- Server
            for svc in services {
                server = server.add_service(svc); // Error here as add_service returns a Router, not a Server
            }
            x.push(server.serve(addr)); // Error again as you can't call serve on a Server
        }

        tokio::try_join!(futures::future::join_all(x))?; // Error due to the errors above
        Ok(())
    }
}

I've been reading through the docs and examples but I can't see any way of doing this? Maybe I'm going about it the wrong way

visortelle · 2021-11-16T14:08:01Z

visortelle
Nov 16, 2021

@itmecho did you solve the issue? If yes, then can you please share how? :)

4 replies

itmecho Nov 16, 2021
Author

I didn't I'm afraid, I never managed to figure out the types as as soon as you add a service, it changes =\

visortelle Nov 16, 2021

Having the same problem. 😕

davidpdrsn Nov 16, 2021
Maintainer

This isn't very straight forward but it can be done. You can use BoxService to erase the type and Buffer to make the service Clone.

visortelle Nov 16, 2021

@davidpdrsn thank you.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Help dynamically adding services to a server #744

Uh oh!

{{title}}

Uh oh!

Replies: 1 comment 4 replies

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Select a reply

Uh oh!

Help dynamically adding services to a server #744

Uh oh!

itmecho Aug 14, 2021

Replies: 1 comment · 4 replies

Uh oh!

visortelle Nov 16, 2021

Uh oh!

itmecho Nov 16, 2021 Author

Uh oh!

visortelle Nov 16, 2021

Uh oh!

davidpdrsn Nov 16, 2021 Maintainer

Uh oh!

visortelle Nov 16, 2021

itmecho
Aug 14, 2021

Replies: 1 comment 4 replies

visortelle
Nov 16, 2021

itmecho Nov 16, 2021
Author

davidpdrsn Nov 16, 2021
Maintainer