grpc_service/
grpc_service.rs

1use ez_rust_discovery::{ServeOptions, ServiceManager};
2
3/// [NACOS_ADDR] Nacos server address
4/// [NACOS_NAMESPACE] Service namespace
5/// [SERVICE_ADDR] Worker service address
6/// [SERVICE_NAME] Worker service name
7fn main() -> Result<(), Box<dyn std::error::Error>> {
8    // TODO Start gRPC or HTTP service.
9
10    let manager = ServiceManager::new(ServeOptions::default())?;
11    if let Err(e) = manager.online() {
12        println!("online fail, caused by: {}", e);
13        std::process::exit(1);
14    };
15
16    std::thread::sleep(std::time::Duration::from_secs(30));
17    // TODO block Listen signal...
18
19    // Go offline before the gRPC or HTTP service shuts down
20    manager.offline()?;
21
22    // TODO Close gRPC or HTTP service.
23    Ok(())
24}
grpc_service/grpc_service.rs

grpc_service/
grpc_service.rs
