Struct PreparedRequest

Source

pub struct PreparedRequest<'request> { /* private fields */ }

Expand description

Complete request, endpoint, operation metadata, and response policy.

Implementations§

Source §

impl<'request> PreparedRequest<'request>

Source

pub const fn new( request: TransportRequest<'request>, service: ProviderService<'request>, metadata: OperationMetadata, response_policy: ResponsePolicy, ) -> Self

Creates a complete prepared request without policy defaults.

Examples found in repository ?

examples/prepared_request.rs (lines 75-80)

46    fn prepare<'storage>(
47        &self,
48        storage: PreparationStorage<'storage>,
49    ) -> Result<PreparedRequest<'storage>, Self::Error> {
50        let (target_storage, _body_storage) = storage.into_parts();
51        let target = target_storage
52            .get_mut(..17)
53            .ok_or(PrepareError::TargetBuffer)?;
54        target.copy_from_slice(b"/resources?page=1");
55        let target = core::str::from_utf8(target).map_err(|_| PrepareError::InvalidTarget)?;
56        let target = RequestTarget::new(target).map_err(|_| PrepareError::InvalidTarget)?;
57        let request = TransportRequest::new(Method::Get, target);
58        let metadata = OperationMetadata::new(
59            OperationImpact::ReadOnly,
60            RequestSemantics::Safe,
61            RetryEligibility::ExplicitPolicy,
62            CostIntent::NoKnownCost,
63        )
64        .map_err(|_| PrepareError::InvalidMetadata)?;
65        let response_policy = ResponsePolicy::new(
66            &OK_STATUS,
67            ContentTypePolicy::Required(&JSON_MEDIA),
68            ResponseBodyPolicy::Required,
69            65_536,
70        )
71        .map_err(|_| PrepareError::InvalidResponsePolicy)?;
72        let endpoint =
73            EndpointIdentity::new(EndpointScheme::Https, "api.example.invalid", 443, "/v1")
74                .map_err(|_| PrepareError::InvalidEndpoint)?;
75        Ok(PreparedRequest::new(
76            request,
77            ProviderService::from_marker::<ComputeService>(EndpointPolicy::fixed(endpoint)),
78            metadata,
79            response_policy,
80        ))
81    }

Source

pub const fn with_operation_id(self, operation_id: OperationId) -> Self

Binds a validated provider operation identifier to this request.

Source

pub const fn transport_request(self) -> TransportRequest<'request>

Returns the validated transport request.

Examples found in repository ?

examples/prepared_request.rs (line 90)

84fn main() {
85    let mut target = [0_u8; MAX_REQUEST_TARGET_BYTES];
86    let mut body = [0_u8; 1];
87    let prepared = ListResources.prepare(PreparationStorage::new(&mut target, &mut body));
88    let Ok(prepared) = prepared else { return };
89
90    assert_eq!(prepared.transport_request().method(), Method::Get);
91    assert_eq!(prepared.metadata().impact(), OperationImpact::ReadOnly);
92    assert_eq!(prepared.response_policy().max_body_bytes(), 65_536);
93}

Source

pub const fn service(self) -> ProviderService<'request>

Returns the bound provider service.

Source

pub const fn metadata(self) -> OperationMetadata

Returns complete safety and retry metadata.

Examples found in repository ?

examples/prepared_request.rs (line 91)

84fn main() {
85    let mut target = [0_u8; MAX_REQUEST_TARGET_BYTES];
86    let mut body = [0_u8; 1];
87    let prepared = ListResources.prepare(PreparationStorage::new(&mut target, &mut body));
88    let Ok(prepared) = prepared else { return };
89
90    assert_eq!(prepared.transport_request().method(), Method::Get);
91    assert_eq!(prepared.metadata().impact(), OperationImpact::ReadOnly);
92    assert_eq!(prepared.response_policy().max_body_bytes(), 65_536);
93}

Source

pub const fn response_policy(self) -> ResponsePolicy

Returns complete checked-response policy.

Examples found in repository ?

examples/prepared_request.rs (line 92)

84fn main() {
85    let mut target = [0_u8; MAX_REQUEST_TARGET_BYTES];
86    let mut body = [0_u8; 1];
87    let prepared = ListResources.prepare(PreparationStorage::new(&mut target, &mut body));
88    let Ok(prepared) = prepared else { return };
89
90    assert_eq!(prepared.transport_request().method(), Method::Get);
91    assert_eq!(prepared.metadata().impact(), OperationImpact::ReadOnly);
92    assert_eq!(prepared.response_policy().max_body_bytes(), 65_536);
93}