Struct vector::sinks::splunk_hec::common::request::HecRequest

pub struct HecRequest {
    pub body: Bytes,
    pub metadata: RequestMetadata,
    pub finalizers: EventFinalizers,
    pub passthrough_token: Option<Arc<str>>,
    pub index: Option<String>,
    pub source: Option<String>,
    pub sourcetype: Option<String>,
    pub host: Option<String>,
}

Fields

body: Bytes

metadata: RequestMetadata

finalizers: EventFinalizers

passthrough_token: Option<Arc<str>>

index: Option<String>

source: Option<String>

sourcetype: Option<String>

host: Option<String>

Trait Implementations

impl ByteSizeOf for HecRequest

fn allocated_bytes(&self) -> usize

Returns the allocated bytes of this type

fn size_of(&self) -> usize

Returns the in-memory size of this type

impl Clone for HecRequest

fn clone(&self) -> HecRequest

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for HecRequest

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

Formats the value using the given formatter.

impl ElementCount for HecRequest

fn element_count(&self) -> usize

impl Finalizable for HecRequest

fn take_finalizers(&mut self) -> EventFinalizers

Consumes the finalizers of this object.

impl MetaDescriptive for HecRequest

fn get_metadata(&self) -> &RequestMetadata

Returns the RequestMetadata associated with this object.

fn metadata_mut(&mut self) -> &mut RequestMetadata

impl<S> Service<HecRequest> for HecService<S>

where S: Service<HecRequest> + Send + 'static, S::Future: Send + 'static, S::Response: Response + ResponseExt + Send + 'static, S::Error: Debug + Into<Error> + Send,

type Response = HecResponse

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<HecService<S> as Service<HecRequest>>::Response, <HecService<S> as Service<HecRequest>>::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: HecRequest) -> Self::Future

Process the request and return the response asynchronously.