Struct CmsValidatorClient 

pub struct CmsValidatorClient {
    http: Client,
    cms_internal_url: Url,
    secret: SecretString,
    max_request_bytes: AtomicUsize,
}

HTTP client for the validator routes under the CMS’s /api/agent/.

Fields

http: Client

cms_internal_url: Url

secret: SecretString

max_request_bytes: AtomicUsize

BlockSchemas::max_request_bytes of the latest schemas fetched; 0 before the first.

Implementations

impl CmsValidatorClient

pub fn new(cms_internal_url: Url, secret: SecretString) -> Result<Self, Error>

cms_internal_url is the CMS base as a Url::join base, e.g. http://cms:3000/cms/.

fn route(&self, name: &str) -> Result<Url, ValidatorError>

The URL of the validator route name.

async fn send<T: for<'de> Deserialize<'de>>( &self, request: RequestBuilder, ) -> Result<T, ValidatorError>

Trait Implementations

impl BlockValidator for CmsValidatorClient

fn validate_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: &'life1 ValidationRequest<'life2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ValidationOutcome>, ValidatorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

The outcome of each page, in request order.

fn block_schemas<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BlockSchemas, ValidatorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The current block registrations; crate::state::McpState::block_schemas caches them.