Skip to main content

Datastore

qlog_dancer::datastore

Struct Datastore 

Source 
pub struct Datastore {
Show 74 fields
    pub vantage_point: VantagePoint,
    pub application_proto: ApplicationProto,
    pub session_id: Option<i64>,
    pub host: Option<String>,
    pub h2_client_settings: Http2Settings,
    pub h2_server_settings: Http2Settings,
    pub client_quic_tps: TransportParameters,
    pub last_event_time: f64,
    pub packet_sent: HashMap<PacketType, BTreeMap<u64, PacketInfoStub>>,
    pub packet_received: HashMap<PacketType, BTreeMap<u64, PacketInfoStub>>,
    pub netlog_ack_sent_missing_packet: BTreeMap<PacketType, BTreeSet<u64>>,
    pub netlog_ack_received_missing_packet: BTreeMap<PacketType, BTreeSet<u64>>,
    pub packet_acked: Vec<QlogPointu64>,
    pub local_cwnd: Vec<QlogPointu64>,
    pub local_bytes_in_flight: Vec<QlogPointu64>,
    pub local_ssthresh: Vec<QlogPointu64>,
    pub local_pacing_rate: Vec<QlogPointu64>,
    pub local_delivery_rate: Vec<QlogPointu64>,
    pub local_send_rate: Vec<QlogPointu64>,
    pub local_ack_rate: Vec<QlogPointu64>,
    pub local_min_rtt: Vec<QlogPointRtt>,
    pub local_latest_rtt: Vec<QlogPointRtt>,
    pub local_smoothed_rtt: Vec<QlogPointRtt>,
    pub congestion_state_updates: Vec<(f64, u64, String)>,
    pub received_max_data: Vec<QlogPointu64>,
    pub received_stream_max_data_tracker: StreamMaxTracker,
    pub sent_max_data: Vec<QlogPointu64>,
    pub sent_stream_max_data_tracker: StreamMaxTracker,
    pub stream_buffer_reads_tracker: StreamBufferTracker,
    pub stream_buffer_writes_tracker: StreamBufferTracker,
    pub stream_buffer_dropped_tracker: StreamBufferTracker,
    pub received_reset_stream: BTreeMap<u64, Vec<QuicFrame>>,
    pub sent_reset_stream: BTreeMap<u64, Vec<QuicFrame>>,
    pub received_stream_frames: BTreeMap<u64, Vec<(f64, StreamDatapoint)>>,
    pub received_stream_frames_count_based: BTreeMap<u64, Vec<(u64, StreamDatapoint)>>,
    pub total_received_stream_frame_count: u64,
    pub sent_stream_frames: BTreeMap<u64, Vec<(f64, QuicFrame)>>,
    pub sent_stream_frames_count_based: BTreeMap<u64, Vec<(u64, QuicFrame)>>,
    pub total_sent_stream_frame_count: u64,
    pub received_data_frames: BTreeMap<u64, Vec<(f64, u64)>>,
    pub received_data_frames_count_based: BTreeMap<u64, Vec<(u64, u64)>>,
    pub total_received_data_frame_count: u64,
    pub received_data_cumulative: BTreeMap<u64, Vec<(f64, u64)>>,
    pub received_data_cumulative_max: BTreeMap<u64, u64>,
    pub sent_data_frames: BTreeMap<u64, Vec<(f64, u64)>>,
    pub sent_data_frames_count_based: BTreeMap<u64, Vec<(u64, u64)>>,
    pub total_sent_data_frame_count: u64,
    pub sent_data_cumulative: BTreeMap<u64, Vec<(f64, u64)>>,
    pub sent_data_cumulative_max: BTreeMap<u64, u64>,
    pub http_requests: BTreeMap<u64, HttpRequestStub>,
    pub largest_data_frame_rx_length_global: u64,
    pub largest_data_frame_tx_length_global: u64,
    pub local_init_max_stream_data_bidi_local: u64,
    pub local_init_max_stream_data_uni: u64,
    pub peer_init_max_stream_data_bidi_local: u64,
    pub peer_init_max_stream_data_bidi_remote: u64,
    pub peer_init_max_stream_data_uni: u64,
    pub h2_recv_window_updates: BTreeMap<u32, Vec<(f64, i32)>>,
    pub h2_send_window_updates_balanced: BTreeMap<u32, Vec<(f64, i32)>>,
    pub h2_send_window_updates_absolute: BTreeMap<u32, Vec<(f64, u64)>>,
    pub netlog_quic_server_window_blocked: BTreeMap<i64, Vec<f64>>,
    pub netlog_quic_client_side_window_updates: BTreeMap<i64, Vec<(f64, u64)>>,
    pub netlog_h2_stream_received_connection_cumulative: Vec<QlogPointu64>,
    pub netlog_quic_stream_received_connection_cumulative: Vec<QlogPointu64>,
    pub received_packets_netlog: Vec<(f64, PacketInfoStub)>,
    pub discontinuous_packet_number_count: u64,
    pub netlog_ack_sent_missing_packets_raw: Vec<(f64, Vec<u64>)>,
    pub total_tx_ack: usize,
    pub max_ack_sent_missing_packets_size: usize,
    pub total_rx_ack: usize,
    pub max_ack_received_missing_packets_size: usize,
    pub quic_session_close: Option<QuicSessionClose>,
    pub h2_session_close: Option<H2SessionClose>,
    pub h2_concurrent_requests: u64,

}

Fields§

§vantage_point: VantagePoint§application_proto: ApplicationProto§session_id: Option<i64>§host: Option<String>§h2_client_settings: Http2Settings§h2_server_settings: Http2Settings§client_quic_tps: TransportParameters§last_event_time: f64§packet_sent: HashMap<PacketType, BTreeMap<u64, PacketInfoStub>>§packet_received: HashMap<PacketType, BTreeMap<u64, PacketInfoStub>>§netlog_ack_sent_missing_packet: BTreeMap<PacketType, BTreeSet<u64>>§netlog_ack_received_missing_packet: BTreeMap<PacketType, BTreeSet<u64>>§packet_acked: Vec<QlogPointu64>§local_cwnd: Vec<QlogPointu64>§local_bytes_in_flight: Vec<QlogPointu64>§local_ssthresh: Vec<QlogPointu64>§local_pacing_rate: Vec<QlogPointu64>§local_delivery_rate: Vec<QlogPointu64>§local_send_rate: Vec<QlogPointu64>§local_ack_rate: Vec<QlogPointu64>§local_min_rtt: Vec<QlogPointRtt>§local_latest_rtt: Vec<QlogPointRtt>§local_smoothed_rtt: Vec<QlogPointRtt>§congestion_state_updates: Vec<(f64, u64, String)>§received_max_data: Vec<QlogPointu64>§received_stream_max_data_tracker: StreamMaxTracker

Tracks per-stream max data: full history, current max, and cumulative sum.

§sent_max_data: Vec<QlogPointu64>§sent_stream_max_data_tracker: StreamMaxTracker

Tracks per-stream max data: full history, current max, and cumulative sum.

§stream_buffer_reads_tracker: StreamBufferTracker

Tracks stream buffer reads: per-stream history, current max, and running sum.

§stream_buffer_writes_tracker: StreamBufferTracker

Tracks stream buffer writes: per-stream history, current max, and running sum.

§stream_buffer_dropped_tracker: StreamBufferTracker

Tracks stream buffer dropped: per-stream history, current max, and running sum.

§received_reset_stream: BTreeMap<u64, Vec<QuicFrame>>§sent_reset_stream: BTreeMap<u64, Vec<QuicFrame>>§received_stream_frames: BTreeMap<u64, Vec<(f64, StreamDatapoint)>>§received_stream_frames_count_based: BTreeMap<u64, Vec<(u64, StreamDatapoint)>>§total_received_stream_frame_count: u64§sent_stream_frames: BTreeMap<u64, Vec<(f64, QuicFrame)>>§sent_stream_frames_count_based: BTreeMap<u64, Vec<(u64, QuicFrame)>>§total_sent_stream_frame_count: u64§received_data_frames: BTreeMap<u64, Vec<(f64, u64)>>§received_data_frames_count_based: BTreeMap<u64, Vec<(u64, u64)>>§total_received_data_frame_count: u64§received_data_cumulative: BTreeMap<u64, Vec<(f64, u64)>>§received_data_cumulative_max: BTreeMap<u64, u64>§sent_data_frames: BTreeMap<u64, Vec<(f64, u64)>>§sent_data_frames_count_based: BTreeMap<u64, Vec<(u64, u64)>>§total_sent_data_frame_count: u64§sent_data_cumulative: BTreeMap<u64, Vec<(f64, u64)>>§sent_data_cumulative_max: BTreeMap<u64, u64>§http_requests: BTreeMap<u64, HttpRequestStub>§largest_data_frame_rx_length_global: u64§largest_data_frame_tx_length_global: u64§local_init_max_stream_data_bidi_local: u64§local_init_max_stream_data_uni: u64§peer_init_max_stream_data_bidi_local: u64§peer_init_max_stream_data_bidi_remote: u64§peer_init_max_stream_data_uni: u64§h2_recv_window_updates: BTreeMap<u32, Vec<(f64, i32)>>§h2_send_window_updates_balanced: BTreeMap<u32, Vec<(f64, i32)>>§h2_send_window_updates_absolute: BTreeMap<u32, Vec<(f64, u64)>>§netlog_quic_server_window_blocked: BTreeMap<i64, Vec<f64>>§netlog_quic_client_side_window_updates: BTreeMap<i64, Vec<(f64, u64)>>§netlog_h2_stream_received_connection_cumulative: Vec<QlogPointu64>§netlog_quic_stream_received_connection_cumulative: Vec<QlogPointu64>§received_packets_netlog: Vec<(f64, PacketInfoStub)>§discontinuous_packet_number_count: u64§netlog_ack_sent_missing_packets_raw: Vec<(f64, Vec<u64>)>§total_tx_ack: usize§max_ack_sent_missing_packets_size: usize§total_rx_ack: usize§max_ack_received_missing_packets_size: usize§quic_session_close: Option<QuicSessionClose>§h2_session_close: Option<H2SessionClose>§h2_concurrent_requests: u64

Implementations§

Source§

impl Datastore

Source

pub fn consume_netlog_event( &mut self, session_start_time: u64, ev_hdr: &EventHeader, event: &Event, constants: &Constants, stream_bind: &StreamBindingMap, h3_session_requests: Option<&Vec<ReqOverH3>>, )

Source

pub fn consume_qlog_event(&mut self, event: &Event, process_acks: bool)

Source

pub fn with_qlog_events( events: &[Event], vantage_point: &VantagePointType, process_acks: bool, ) -> Self

Source

pub fn finalize(&mut self)

Source

pub fn hydrate_http_requests(&mut self)

Source

pub fn with_sqlog_reader_events( events: &[Event], vantage_point: &VantagePointType, process_acks: bool, ) -> Self

Trait Implementations§

Source§

impl Debug for Datastore

Source§

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

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

impl Default for Datastore

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

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
§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

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.

§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

§

impl<T> SendSyncUnwindSafe for T
where T: Send + Sync + UnwindSafe + ?Sized,

Source§

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

Source§

type Error = !

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

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

Performs the conversion.
Source§

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

Source§

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.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V