Struct ObservabilityIngestRequestV1

Source

pub struct ObservabilityIngestRequestV1 {
    pub endpoint: ObservabilityIngestEndpointV1,
    pub operation_id: String,
    pub request_digest: [u8; 32],
    pub protocol: ObservabilityIngestProtocolV1,
    pub mode: ObservabilityIngestModeV1,
    pub expected_index_id: String,
    pub index_name: String,
    pub content_encoding: ObservabilityContentEncodingV1,
    pub exact_encoded_message: Vec<u8>,
    pub timeout: Duration,
}

Fields§

§endpoint: ObservabilityIngestEndpointV1§operation_id: String§request_digest: [u8; 32]§protocol: ObservabilityIngestProtocolV1§mode: ObservabilityIngestModeV1§expected_index_id: String§index_name: String§content_encoding: ObservabilityContentEncodingV1§exact_encoded_message: Vec<u8>§timeout: Duration

Auto Trait Implementations§

§

ObservabilityIngestRequestV1

Struct ObservabilityIngestRequestV1 Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for ObservabilityIngestRequestV1

impl RefUnwindSafe for ObservabilityIngestRequestV1

impl Send for ObservabilityIngestRequestV1

impl Sync for ObservabilityIngestRequestV1

impl Unpin for ObservabilityIngestRequestV1

impl UnsafeUnpin for ObservabilityIngestRequestV1

impl UnwindSafe for ObservabilityIngestRequestV1

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct ObservabilityIngestRequestV1

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,