[−][src]Struct st2_logformat::LogRecord
A LogRecord
constitutes the unified struct
representation of
log messages from various stream processors.
It is the underlying structure from which the PAG construction starts.
If necessary, it can also be serialized e.g. into a msgpack
representation.
Fields
seq_no: u64
worker-unique identifier of a message, given in order the events are logged in the computation.
epoch: u64
epoch of the computation this record belongs to
timestamp: Timestamp
Event time in nanoseconds since the Epoch (midnight, January 1, 1970 UTC).
local_worker: Worker
Context this event occured in; denotes which of the parallel timelines it belongs to.
activity_type: ActivityType
Describes the instrumentation point which triggered this event.
event_type: EventType
Identifies which end of an edge this program event belongs to.
remote_worker: Option<Worker>
Similar to local_worker
but specifies the worker ID for the other end of a sent/received message.
operator_id: Option<OperatorId>
Unique id for the operator in the dataflow. This only applies for some event types, e.g. scheduling or processing.
channel_id: Option<ChannelId>
Unique id for the channel in the dataflow. This only applies for some event types, e.g. data / control messages.
correlator_id: Option<u64>
correlates remote events belonging together
length: Option<usize>
Number of records to detect skew
Trait Implementations
impl Clone for LogRecord
[src]
fn clone(&self) -> LogRecord
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
impl Ord for LogRecord
[src]
fn cmp(&self, other: &LogRecord) -> Ordering
[src]
fn max(self, other: Self) -> Self
1.21.0[src]
Compares and returns the maximum of two values. Read more
fn min(self, other: Self) -> Self
1.21.0[src]
Compares and returns the minimum of two values. Read more
fn clamp(self, min: Self, max: Self) -> Self
[src]
clamp
)Restrict a value to a certain interval. Read more
impl PartialOrd<LogRecord> for LogRecord
[src]
fn partial_cmp(&self, other: &LogRecord) -> Option<Ordering>
[src]
#[must_use]
fn lt(&self, other: &Rhs) -> bool
1.0.0[src]
This method tests less than (for self
and other
) and is used by the <
operator. Read more
#[must_use]
fn le(&self, other: &Rhs) -> bool
1.0.0[src]
This method tests less than or equal to (for self
and other
) and is used by the <=
operator. Read more
#[must_use]
fn gt(&self, other: &Rhs) -> bool
1.0.0[src]
This method tests greater than (for self
and other
) and is used by the >
operator. Read more
#[must_use]
fn ge(&self, other: &Rhs) -> bool
1.0.0[src]
This method tests greater than or equal to (for self
and other
) and is used by the >=
operator. Read more
impl PartialEq<LogRecord> for LogRecord
[src]
impl Eq for LogRecord
[src]
impl Debug for LogRecord
[src]
impl Hash for LogRecord
[src]
fn hash<__H: Hasher>(&self, state: &mut __H)
[src]
fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher,
1.3.0[src]
H: Hasher,
Feeds a slice of this type into the given [Hasher
]. Read more
impl Abomonation for LogRecord
[src]
Auto Trait Implementations
impl Sync for LogRecord
impl Send for LogRecord
impl Unpin for LogRecord
impl RefUnwindSafe for LogRecord
impl UnwindSafe for LogRecord
Blanket Implementations
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Data for T where
T: Ord + Debug + Data,
[src]
T: Ord + Debug + Data,
impl<T> ExchangeData for T where
T: Ord + Debug + ExchangeData,
[src]
T: Ord + Debug + ExchangeData,
impl<T> Hashable for T where
T: Hash,
[src]
T: Hash,
impl<T> Data for T where
T: 'static + Clone,
[src]
T: 'static + Clone,
impl<T> Data for T where
T: 'static + Send + Sync + Any + Abomonation,
T: 'static + Send + Sync + Any + Abomonation,
impl<T> ExchangeData for T where
T: Data + Data,
[src]
T: Data + Data,