volo_boot 0.1.2

volo_boot
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use aok::{OK, Void};
use volo::Service;
use volo_grpc::{
  RecvEntryMessage, Request, Response, SendEntryMessage, Status,
  codec::compression::{CompressionEncoding::Zstd, ZstdConfig},
  context::ServerContext,
  server::{NamedService, Server, ServiceBuilder},
};

use crate::env_addr;

pub async fn grpc<S, T, U>(api_server: S, init: impl Fn(Server) -> Server) -> Void
where
  S: 'static
    + Service<ServerContext, Request<T>, Response = Response<U>>
    + Sync
    + Send
    + NamedService
    + Clone,
  S::Error: Into<Status>,
  T: RecvEntryMessage + 'static,
  U: SendEntryMessage + 'static,
{
  let addr: volo::net::Address = env_addr("GRPC", 3333).into();

  let compression_config = vec![Zstd(Some(ZstdConfig::default()))];
  let srv = ServiceBuilder::new(api_server)
    .send_compressions(compression_config.clone())
    .accept_compressions(compression_config)
    .build();

  xerr::log!(
    init(Server::new())
      .add_service(srv)
      // .layer_front(volo_layer::Log)
      .run(addr)
      .await
  );
  OK
}