Struct KernelRequest 

pub struct KernelRequest {
    pub call: ToolCallRequest,
    pub tenant_id: TenantId,
}

Request accepted by KernelService.

Fields

call: ToolCallRequest

Tool-call request evaluated by the kernel.

tenant_id: TenantId

Tenant partition key for tower middleware. Capability semantics stay inside chio-kernel.

Implementations

impl KernelRequest

pub fn new(call: ToolCallRequest, tenant_id: impl Into<TenantId>) -> Self

Create a new kernel service request.

Trait Implementations

impl Service<KernelRequest> for KernelService

type Response = ToolCallResponse

Responses given by the service.

type Error = KernelServiceError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<KernelService as Service<KernelRequest>>::Response, <KernelService as Service<KernelRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

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

fn call(&mut self, req: KernelRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S> Service<KernelRequest> for KernelTraceService<S>

where S: Service<KernelRequest, Response = KernelResponse, Error = KernelServiceError> + Send + 'static, S::Future: Send + 'static,

type Response = ToolCallResponse

Responses given by the service.

type Error = KernelServiceError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<KernelTraceService<S> as Service<KernelRequest>>::Response, <KernelTraceService<S> as Service<KernelRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

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

fn call(&mut self, req: KernelRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S> Service<KernelRequest> for TenantConcurrencyLimitService<S>

where S: Service<KernelRequest, Error = KernelServiceError> + Clone + Send + 'static, S::Future: Send + 'static, S::Response: Send + 'static,

type Response = <S as Service<KernelRequest>>::Response

Responses given by the service.

type Error = KernelServiceError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<TenantConcurrencyLimitService<S> as Service<KernelRequest>>::Response, <TenantConcurrencyLimitService<S> as Service<KernelRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

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

fn call(&mut self, req: KernelRequest) -> Self::Future

Process the request and return the response asynchronously.