Struct retina_datatypes::connection::ConnRecord

source ·
pub struct ConnRecord {
    pub five_tuple: FiveTuple,
    pub first_seen_ts: Instant,
    pub second_seen_ts: Instant,
    pub last_seen_ts: Instant,
    pub max_inactivity: Duration,
    pub history: Vec<u8>,
    pub orig: Flow,
    pub resp: Flow,
}
Expand description

Tracks a connection record throughout its lifetime.

§Note

Internal connection state is an associated type of a pub trait, and therefore must also be public. Documentation is hidden by default to avoid confusing users.

Fields§

§five_tuple: FiveTuple

The connection 5-tuple.

§first_seen_ts: Instant

Timestamp of the first packet.

§Remarks

This represents the time Retina observed the first packet in the connection, and does not reflect timestamps read from a packet capture in offline analysis.

§second_seen_ts: Instant

Timestamp of the second packet (approximate).

§last_seen_ts: Instant

Timestamp of the last packet (approximate).

§max_inactivity: Duration

Maximum duration of inactivity (the maximum time between observed segments).

§history: Vec<u8>

This represents a summary of the connection history in the order the packets were observed, with letters encoded as a vector of bytes. This is a simplified version of state history in Zeek, and the meanings of each letter are similar: If the event comes from the originator, the letter is uppercase; if the event comes from the responder, the letter is lowercase.

  • S: a pure SYN with only the SYN bit set (may have payload)
  • H: a pure SYNACK with only the SYN and ACK bits set (may have payload)
  • A: a pure ACK with only the ACK bit set and no payload
  • D: segment contains non-zero payload length
  • F: the segment has the FIN bit set (may have other flags and/or payload)
  • R: segment has the RST bit set (may have other flags and/or payload)

Each letter is recorded a maximum of once in either direction.

§orig: Flow

Originator flow.

§resp: Flow

Responder flow.

Implementations§

source§

impl ConnRecord

source

pub fn client(&self) -> SocketAddr

Returns the client (originator) socket address.

source

pub fn server(&self) -> SocketAddr

Returns the server (responder) socket address.

source

pub fn total_pkts(&self) -> u64

Returns the total number of packets observed in the connection.

source

pub fn total_bytes(&self) -> u64

Returns the total number of payload bytes observed, excluding those from malformed packets.

source

pub fn history(&self) -> String

Returns the connection history.

source

pub fn duration(&self) -> Duration

Returns te duration of the connection.

§Remarks

This does not represent the actual duration of the connection in offline analysis. It approximates the elapsed time between observation of the first and last observed packet in the connection.

source

pub fn time_to_second_packet(&self) -> Duration

The duration (approximate) between the first and second packets.

Trait Implementations§

source§

impl Debug for ConnRecord

source§

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

Formats the value using the given formatter. Read more
source§

impl Display for ConnRecord

source§

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

Formats the value using the given formatter. Read more
source§

impl Serialize for ConnRecord

source§

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

Serialize this value into the given Serde serializer. Read more
source§

impl Tracked for ConnRecord

source§

fn new(first_pkt: &L4Pdu) -> Self

Initialize internal data; called once per connection. Note first_pkt will also be delivered to update.
source§

fn clear(&mut self)

Clear internal data; called if connection no longer matches filter that requires the Tracked type.
source§

fn update(&mut self, pdu: &L4Pdu, reassembled: bool)

New packet in connection received (or reassembled, if reassembled=true) Note this may be invoked both pre- and post-reassembly; types should check reassembled to avoid double-counting.
source§

fn stream_protocols() -> Vec<&'static str>

The stream protocols (lower-case) required for this datatype. See IMPLEMENTED_PROTOCOLS in retina_core for list of supported protocols.

Auto Trait Implementations§

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

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

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToString for T
where T: Display + ?Sized,

source§

default fn to_string(&self) -> String

Converts the given value to a String. Read more
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

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

§

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

The type returned in the event of a conversion error.
source§

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

Performs the conversion.