Struct Schema 

pub struct Schema { /* private fields */ }

Resolves a Transcoder for a gRPC method path according to a SchemaSource. Cheap to clone; the reflection snapshot is shared.

Implementations

impl Schema

pub fn from_transcoder(transcoder: Option<Arc<Transcoder>>) -> Self

Build a schema from an already-constructed transcoder — the in-process case, where the descriptors live in memory and there is no upstream to reflect against. None means no +json transcoder is configured.

pub fn build( source: SchemaSource, channel: Channel, ttl: Duration, ) -> Result<Self, TranscodeError>

Build a resolver. The Bundled set is parsed eagerly so a bad descriptor set fails at startup; channel is the upstream connection reused for reflection, and ttl is the reflection refresh interval. Call Schema::start afterwards to kick off the reflection loader.

pub fn start(&self)

Start the background reflection loader (eager initial load + TTL refresh). A no-op unless the source involves reflection. Must be called from within a Tokio runtime.

pub async fn reload(&self) -> Result<(), Status>

Force an immediate reflection reload, returning its result. The management hook behind ProxyConfig::admin_reload_path.

pub fn enabled(&self) -> bool

Whether this proxy can transcode +json at all.

pub async fn transcoder_any(&self) -> Result<Arc<Transcoder>, Status>

The transcoder for this source, without validating any specific method — for REST annotation matching, where the target method isn’t known until the URL is matched against the router.

pub async fn transcoder( &self, method_path: &str, ) -> Result<Arc<Transcoder>, Status>

Resolve the transcoder for method_path (/pkg.Service/Method). An unknown method yields Unimplemented (uniformly across sources), distinct from a transcode failure.

Trait Implementations

impl Clone for Schema

fn clone(&self) -> Schema

Returns a duplicate of the value.

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

Performs copy-assignment from source.