Struct ReflectionService 

pub struct ReflectionService { /* private fields */ }

gRPC-compatible server reflection service backed by a Reflector.

Implements both the grpc.reflection.v1 and grpc.reflection.v1alpha flavors of the protocol (the messages are structurally identical; older clients — and some current ones, e.g. grpcurl fallback paths — still speak v1alpha). Register both with install, or register a single version through the generated extension traits.

use connectrpc::Router;
use connectrpc_reflection::{Reflector, install};

// In real code: include_bytes!(concat!(env!("OUT_DIR"), "/app.fds.bin"))
let reflector = Reflector::from_descriptor_set_bytes(descriptor_set_bytes()).unwrap();
let router = install(Router::new(), reflector);

Implementations

impl ReflectionService

pub fn new(reflector: Reflector) -> Self

Wrap a reflector by value; it is moved into a fresh Arc.

pub fn from_arc(reflector: Arc<Reflector>) -> Self

Wrap a reflector that is already inside an Arc.

Trait Implementations

impl Clone for ReflectionService

fn clone(&self) -> ReflectionService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerReflection for ReflectionService

async fn server_reflection_info( &self, _ctx: RequestContext, requests: ServiceStream<StreamMessage<ServerReflectionRequest>>, ) -> ServiceResult<ServiceStream<ServerReflectionResponse>>

The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.

impl ServerReflection for ReflectionService

async fn server_reflection_info( &self, _ctx: RequestContext, requests: ServiceStream<StreamMessage<ServerReflectionRequest>>, ) -> ServiceResult<ServiceStream<ServerReflectionResponse>>

The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.