Struct wireman_core::descriptor::ProtoDescriptor

source ·

pub struct ProtoDescriptor { /* private fields */ }

Implementations§

source §

impl ProtoDescriptor

source

pub fn new( includes: impl IntoIterator<Item = impl AsRef<Path>>, files: impl IntoIterator<Item = impl AsRef<Path>>, ) -> Result<Self>

Instantiate DescriptorPool from proto files and include paths

§Errors

Failed to compile proto ProtoxCompileError
Failed to generate descriptor DescriptorError

Examples found in repository ?

examples/metadata.rs (lines 11-14)

fn main() -> Result<()> {
    let desc = ProtoDescriptor::new(
        vec!["/Users/philippreiter/Rust/wireman/example"],
        vec!["grpc_simple/debugger.proto"],
    )?;
    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[1];
    println!("Service: {:}", service.full_name());
    println!("Method:  {:}", method.full_name());

    let mut req = desc.get_request(&method);
    req.set_address("http://localhost:50051");

    let resp = do_request(&req)?;
    println!("\nResponse:\n{:}", resp.message.to_json()?);

    Ok(())
}

source

pub fn get_service_by_name(&self, name: &str) -> Option<ServiceDescriptor>

Returns a Service by its name

source

pub fn get_message_by_name(&self, name: &str) -> Option<MessageDescriptor>

Returns a Message by its name

source

pub fn get_method_by_name( &self, service_name: &str, method_name: &str, ) -> Option<MethodDescriptor>

Returns a Method of a service by its name

source

pub fn get_services(&self) -> Vec<ServiceDescriptor>

Returns all Services from the descriptor pool

Examples found in repository ?

examples/metadata.rs (line 15)

fn main() -> Result<()> {
    let desc = ProtoDescriptor::new(
        vec!["/Users/philippreiter/Rust/wireman/example"],
        vec!["grpc_simple/debugger.proto"],
    )?;
    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[1];
    println!("Service: {:}", service.full_name());
    println!("Method:  {:}", method.full_name());

    let mut req = desc.get_request(&method);
    req.set_address("http://localhost:50051");

    let resp = do_request(&req)?;
    println!("\nResponse:\n{:}", resp.message.to_json()?);

    Ok(())
}

source

pub fn get_methods(&self, service: &ServiceDescriptor) -> Vec<MethodDescriptor>

Examples found in repository ?

examples/metadata.rs (line 16)

fn main() -> Result<()> {
    let desc = ProtoDescriptor::new(
        vec!["/Users/philippreiter/Rust/wireman/example"],
        vec!["grpc_simple/debugger.proto"],
    )?;
    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[1];
    println!("Service: {:}", service.full_name());
    println!("Method:  {:}", method.full_name());

    let mut req = desc.get_request(&method);
    req.set_address("http://localhost:50051");

    let resp = do_request(&req)?;
    println!("\nResponse:\n{:}", resp.message.to_json()?);

    Ok(())
}

source

pub fn get_request_descriptor( &self, method: &MethodDescriptor, ) -> MessageDescriptor

source

pub fn get_response_descriptor( &self, method: &MethodDescriptor, ) -> MessageDescriptor

source

pub fn get_request(&self, method: &MethodDescriptor) -> RequestMessage

Examples found in repository ?

examples/metadata.rs (line 20)

fn main() -> Result<()> {
    let desc = ProtoDescriptor::new(
        vec!["/Users/philippreiter/Rust/wireman/example"],
        vec!["grpc_simple/debugger.proto"],
    )?;
    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[1];
    println!("Service: {:}", service.full_name());
    println!("Method:  {:}", method.full_name());

    let mut req = desc.get_request(&method);
    req.set_address("http://localhost:50051");

    let resp = do_request(&req)?;
    println!("\nResponse:\n{:}", resp.message.to_json()?);

    Ok(())
}