Enum vector_core::event::Event

pub enum Event {
    Log(LogEvent),
    Metric(Metric),
    Trace(TraceEvent),
}

Variants

Log(LogEvent)

Metric(Metric)

Trace(TraceEvent)

Implementations

impl Event

pub fn as_log(&self) -> &LogEvent

Return self as a LogEvent

Panics

This function panics if self is anything other than an Event::Log.

pub fn as_mut_log(&mut self) -> &mut LogEvent

Return self as a mutable LogEvent

Panics

This function panics if self is anything other than an Event::Log.

pub fn into_log(self) -> LogEvent

Coerces self into a LogEvent

Panics

This function panics if self is anything other than an Event::Log.

pub fn try_into_log(self) -> Option<LogEvent>

Fallibly coerces self into a LogEvent

If the event is a LogEvent, then Some(log_event) is returned, otherwise None.

pub fn maybe_as_log(&self) -> Option<&LogEvent>

Return self as a LogEvent if possible

If the event is a LogEvent, then Some(&log_event) is returned, otherwise None.

pub fn as_metric(&self) -> &Metric

Return self as a Metric

Panics

This function panics if self is anything other than an Event::Metric.

pub fn as_mut_metric(&mut self) -> &mut Metric

Return self as a mutable Metric

Panics

This function panics if self is anything other than an Event::Metric.

pub fn into_metric(self) -> Metric

Coerces self into Metric

Panics

This function panics if self is anything other than an Event::Metric.

pub fn try_into_metric(self) -> Option<Metric>

Fallibly coerces self into a Metric

If the event is a Metric, then Some(metric) is returned, otherwise None.

pub fn as_trace(&self) -> &TraceEvent

Return self as a TraceEvent

Panics

This function panics if self is anything other than an Event::Trace.

pub fn as_mut_trace(&mut self) -> &mut TraceEvent

Return self as a mutable TraceEvent

Panics

This function panics if self is anything other than an Event::Trace.

pub fn into_trace(self) -> TraceEvent

Coerces self into a TraceEvent

Panics

This function panics if self is anything other than an Event::Trace.

pub fn try_into_trace(self) -> Option<TraceEvent>

Fallibly coerces self into a TraceEvent

If the event is a TraceEvent, then Some(trace) is returned, otherwise None.

pub fn metadata(&self) -> &EventMetadata

pub fn metadata_mut(&mut self) -> &mut EventMetadata

pub fn into_metadata(self) -> EventMetadata

Destroy the event and return the metadata.

pub fn with_batch_notifier(self, batch: &BatchNotifier) -> Self

pub fn with_batch_notifier_option(self, batch: &Option<BatchNotifier>) -> Self

pub fn source_id(&self) -> Option<&Arc<ComponentKey>>

Returns a reference to the event metadata source.

pub fn set_source_id(&mut self, source_id: Arc<ComponentKey>)

Sets the source_id in the event metadata to the provided value.

pub fn set_upstream_id(&mut self, upstream_id: Arc<OutputId>)

Sets the upstream_id in the event metadata to the provided value.

pub fn set_source_type(&mut self, source_type: &'static str)

Sets the source_type in the event metadata to the provided value.

pub fn with_source_id(self, source_id: Arc<ComponentKey>) -> Self

Sets the source_id in the event metadata to the provided value.

pub fn with_source_type(self, source_type: &'static str) -> Self

Sets the source_type in the event metadata to the provided value.

pub fn with_upstream_id(self, upstream_id: Arc<OutputId>) -> Self

Sets the upstream_id in the event metadata to the provided value.

pub fn from_json_value( value: Value, log_namespace: LogNamespace, ) -> Result<Self>

Creates an Event from a JSON value.

Errors

If a non-object JSON value is passed in with the Legacy namespace, this will return an error.

Trait Implementations

impl AddBatchNotifier for Event

fn add_batch_notifier(&mut self, batch: BatchNotifier)

Adds a single shared batch notifier to this type.

impl ByteSizeOf for Event

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 Event

fn clone(&self) -> Event

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EstimatedJsonEncodedSizeOf for Event

fn estimated_json_encoded_size_of(&self) -> JsonSize

impl EventContainer for Event

type IntoIter = Once<Event>

The type of Iterator used to turn this container into events.

fn len(&self) -> usize

The number of events in this container.

fn is_empty(&self) -> bool

Is this container empty?

fn into_events(self) -> Self::IntoIter

Turn this container into an iterator over Event.

impl EventCount for Event

fn event_count(&self) -> usize

impl<'a> EventDataEq<Event> for EventRef<'a>

fn event_data_eq(&self, that: &Event) -> bool

impl EventDataEq for Event

fn event_data_eq(&self, other: &Self) -> bool

impl Finalizable for Event

fn take_finalizers(&mut self) -> EventFinalizers

Consumes the finalizers of this object.

impl<'a> From<&'a Event> for EventRef<'a>

fn from(event: &'a Event) -> Self

Converts to this type from the input type.

impl<'a> From<&'a mut Event> for EventMutRef<'a>

fn from(event: &'a mut Event) -> Self

Converts to this type from the input type.

impl From<Event> for Event

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<Event> for EventArray

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<Event> for EventWrapper

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<Event> for WithMetadata<Event>

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<Event> for WithMetadata<EventWrapper>

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<EventWrapper> for Event

fn from(proto: EventWrapper) -> Self

Converts to this type from the input type.

impl From<LogEvent> for Event

fn from(log: LogEvent) -> Self

Converts to this type from the input type.

impl From<Metric> for Event

fn from(metric: Metric) -> Self

Converts to this type from the input type.

impl From<TraceEvent> for Event

fn from(trace: TraceEvent) -> Self

Converts to this type from the input type.

impl FromLua for Event

fn from_lua(value: LuaValue, lua: &Lua) -> LuaResult<Self>

Performs the conversion.

impl GetEventCountTags for Event

fn get_tags(&self) -> TaggedEventsSent

impl MaybeAsLogMut for Event

fn maybe_as_log_mut(&mut self) -> Option<&mut LogEvent>

impl PartialEq for Event

fn eq(&self, other: &Event) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Event

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> TaskTransform<Event> for T

where T: RuntimeTransform + Send + 'static,

fn transform( self: Box<Self>, input_rx: Pin<Box<dyn Stream<Item = Event> + Send>>, ) -> Pin<Box<dyn Stream<Item = Event> + Send>>

where Self: 'static,

fn transform_events( self: Box<Self>, task: Pin<Box<dyn Stream<Item = Event> + Send>>, ) -> Pin<Box<dyn Stream<Item = Event> + Send>>

where T: From<Event>, T::IntoIter: Send,

Wrap the transform task to process and emit individual events. This is used to simplify testing task transforms.

impl TryInto<Value> for Event

type Error = Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<Value, Self::Error>

Performs the conversion.

impl StructuralPartialEq for Event