Struct MadeServiceServer 

pub struct MadeServiceServer<T> { /* private fields */ }

Implementation status (server side) at v0.1:

Every RPC is backed by a use case in made-app/src/usecases/ (or services/auto_dispatch.rs for ProcessTriggerEvent; StatisticsPort::snapshot for GetStatus / GetMetrics; AgentFactoryPort + AgentRegistryPort for RegisterAgent / UnregisterAgent; DeliberationObserverPort bridged to an mpsc channel for StreamDeliberation).

Caveats the project’s honesty principles require to surface:

RegisterAgent accepts kind == "noop" unconditionally. Provider- backed kinds (vLLM, Anthropic, OpenAI, …) are accepted when the binary was compiled with the matching feature and booted with the required provider configuration.

StreamDeliberation emits one DeliberationUpdate per phase transition (Proposing → Revising → Validating → Scoring → Completed) and a final frame carrying the winner DeliberationResult. It does not yet emit per-proposal / per-critique / per-revision frames.

Implementations

impl<T> MadeServiceServer<T>

pub fn new(inner: T) -> MadeServiceServer<T>

pub fn from_arc(inner: Arc<T>) -> MadeServiceServer<T>

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> InterceptedService<MadeServiceServer<T>, F>

where F: Interceptor,

pub fn accept_compressed( self, encoding: CompressionEncoding, ) -> MadeServiceServer<T>

Enable decompressing requests with the given encoding.

pub fn send_compressed( self, encoding: CompressionEncoding, ) -> MadeServiceServer<T>

Compress responses with the given encoding, if the client supports it.

pub fn max_decoding_message_size(self, limit: usize) -> MadeServiceServer<T>

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> MadeServiceServer<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations

impl<T> Clone for MadeServiceServer<T>

fn clone(&self) -> MadeServiceServer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MadeServiceServer<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> NamedService for MadeServiceServer<T>

const NAME: &'static str = SERVICE_NAME

The Service-Name as described here.

impl<T, B> Service<Request<B>> for MadeServiceServer<T>

where T: MadeService, B: Body + Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send + 'static,

type Response = Response<UnsyncBoxBody<Bytes, Status>>

Responses given by the service.

type Error = !

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<MadeServiceServer<T> as Service<Request<B>>>::Response, <MadeServiceServer<T> as Service<Request<B>>>::Error>> + Send>>

The future response value.

fn poll_ready( &mut self, _cx: &mut Context<'_>, ) -> Poll<Result<(), <MadeServiceServer<T> as Service<Request<B>>>::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call( &mut self, req: Request<B>, ) -> <MadeServiceServer<T> as Service<Request<B>>>::Future

Process the request and return the response asynchronously.