Struct MethodDescriptor 

pub struct MethodDescriptor { /* private fields */ }

A method definition for a ServiceDescriptor.

Implementations

impl MethodDescriptor

pub fn new(service: ServiceDescriptor, index: usize) -> MethodDescriptor

Create a new MethodDescriptor referencing the method at index within the ServiceDescriptor.

Panics

Panics if index is out-of-bounds.

pub fn index(&self) -> usize

Gets the index of the method within the parent ServiceDescriptor.

pub fn parent_service(&self) -> &ServiceDescriptor

Gets a reference to the ServiceDescriptor this method is defined in.

pub fn parent_pool(&self) -> &DescriptorPool

Gets a reference to the DescriptorPool this method is defined in.

pub fn parent_file(&self) -> FileDescriptor

Gets the FileDescriptor this method is defined in.

pub fn name(&self) -> &str

Gets the short name of the method, e.g. method.

pub fn full_name(&self) -> &str

Gets the full name of the method, e.g. my.package.MyService.my_method.

Examples found in repository

examples/reflection.rs (line 18)

async fn main() -> Result<()> {
    let request = ReflectionRequest::new("http://localhost:50051");
    let desc = ProtoDescriptor::from_reflection(request).await?;
    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[0];
    println!("Service: {:}", service.full_name());
    println!("Method:  {:}", method.full_name());
    //
    let mut req = desc.get_request(&method);
    req.set_address("http://localhost:50051");

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

    Ok(())
}

examples/metadata.rs (line 19)

async 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).await?;
    println!("\nResponse:\n{:}", resp.message.to_json()?);

    Ok(())
}

pub fn path(&self) -> &[i32]

Gets the path where this method is defined within the FileDescriptorProto, e.g. [6, 0, 2, 0].

See path for more details on the structure of the path.

pub fn method_descriptor_proto(&self) -> &MethodDescriptorProto

Gets a reference to the raw MethodDescriptorProto wrapped by this MethodDescriptor.

pub fn options(&self) -> DynamicMessage

Decodes the options defined for this MethodDescriptorProto, including any extension options.

pub fn input(&self) -> MessageDescriptor

Gets the MessageDescriptor for the input type of this method.

pub fn output(&self) -> MessageDescriptor

Gets the MessageDescriptor for the output type of this method.

pub fn is_client_streaming(&self) -> bool

Returns true if the client streams multiple messages.

pub fn is_server_streaming(&self) -> bool

Returns true if the server streams multiple messages.

Examples found in repository

examples/streaming.rs (line 18)

async fn main() -> Result<()> {
    let desc = ProtoDescriptor::new(
        vec!["/Users/philippreiter/Rust/wireman/example/server/streaming"],
        vec!["streaming.proto"],
    )?;

    let service = &desc.get_services()[0];
    let method = &desc.get_methods(service)[0];

    if !method.is_server_streaming() {
        println!("Method must be server streaming");
    }

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

    let response = call_server_streaming(&request, None).await?;

    let mut pinned = std::pin::pin!(response);
    let stream = pinned.as_mut().get_mut();

    while let Some(message) = stream.next().await {
        let message = message?;
        println!("message: {:?}", message.message);
        println!();
    }

    Ok(())
}

Trait Implementations

impl Clone for MethodDescriptor

fn clone(&self) -> MethodDescriptor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MethodDescriptor

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

Formats the value using the given formatter.

impl Eq for MethodDescriptor

impl PartialEq for MethodDescriptor

fn eq(&self, other: &MethodDescriptor) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for MethodDescriptor