Struct ServiceManager 

pub struct ServiceManager {
    pub naming_service: Arc<NamingService>,
    pub service_instance: ServiceInstance,
    pub service_name: String,
}

Fields

naming_service: Arc<NamingService>

service_instance: ServiceInstance

service_name: String

Implementations

impl ServiceManager

pub fn new(opt: ServeOptions) -> Result<Self, EzError>

Examples found in repository

examples/grpc_service.rs (line 10)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // TODO Start gRPC or HTTP service.

    let manager = ServiceManager::new(ServeOptions::default())?;
    if let Err(e) = manager.online() {
        println!("online fail, caused by: {}", e);
        std::process::exit(1);
    };

    std::thread::sleep(std::time::Duration::from_secs(30));
    // TODO block Listen signal...

    // Go offline before the gRPC or HTTP service shuts down
    manager.offline()?;

    // TODO Close gRPC or HTTP service.
    Ok(())
}

pub fn online(&self) -> Result<(), EzError>

Examples found in repository

examples/grpc_service.rs (line 11)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // TODO Start gRPC or HTTP service.

    let manager = ServiceManager::new(ServeOptions::default())?;
    if let Err(e) = manager.online() {
        println!("online fail, caused by: {}", e);
        std::process::exit(1);
    };

    std::thread::sleep(std::time::Duration::from_secs(30));
    // TODO block Listen signal...

    // Go offline before the gRPC or HTTP service shuts down
    manager.offline()?;

    // TODO Close gRPC or HTTP service.
    Ok(())
}

pub fn offline(&self) -> Result<(), EzError>

Examples found in repository

examples/grpc_service.rs (line 20)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // TODO Start gRPC or HTTP service.

    let manager = ServiceManager::new(ServeOptions::default())?;
    if let Err(e) = manager.online() {
        println!("online fail, caused by: {}", e);
        std::process::exit(1);
    };

    std::thread::sleep(std::time::Duration::from_secs(30));
    // TODO block Listen signal...

    // Go offline before the gRPC or HTTP service shuts down
    manager.offline()?;

    // TODO Close gRPC or HTTP service.
    Ok(())
}

Trait Implementations

impl Clone for ServiceManager

fn clone(&self) -> ServiceManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServiceManager

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

Formats the value using the given formatter.