kcenon::logger::async::batch_processor::processing_stats Struct Reference

Processing statistics. More...

#include <batch_processor.h>

Collaboration diagram for kcenon::logger::async::batch_processor::processing_stats:

Public Member Functions
void	reset ()

Public Attributes
std::atomic< uint64_t >	total_batches {0}
std::atomic< uint64_t >	total_entries {0}
std::atomic< uint64_t >	dropped_entries {0}
std::atomic< uint64_t >	back_pressure_events {0}
std::atomic< uint64_t >	dynamic_size_adjustments {0}
std::atomic< uint64_t >	flush_by_size {0}
std::atomic< uint64_t >	flush_by_time {0}
std::atomic< uint64_t >	flush_by_manual {0}
std::atomic< double >	average_batch_size {0.0}
std::atomic< double >	average_processing_time_ms {0.0}

Detailed Description

Processing statistics.

Definition at line 91 of file batch_processor.h.

Member Function Documentation

reset()

void kcenon::logger::async::batch_processor::processing_stats::reset ( )

inline

Definition at line 105 of file batch_processor.h.

                     {
            total_batches = 0;
            total_entries = 0;
            dropped_entries = 0;
            back_pressure_events = 0;
            dynamic_size_adjustments = 0;
            flush_by_size = 0;
            flush_by_time = 0;
            flush_by_manual = 0;
            average_batch_size = 0.0;
            average_processing_time_ms = 0.0;
        }

References average_batch_size, average_processing_time_ms, back_pressure_events, dropped_entries, dynamic_size_adjustments, flush_by_manual, flush_by_size, flush_by_time, total_batches, and total_entries.

Referenced by kcenon::logger::async::batch_processor::reset_stats().

Here is the caller graph for this function:

Member Data Documentation

average_batch_size

std::atomic<double> kcenon::logger::async::batch_processor::processing_stats::average_batch_size {0.0}

Definition at line 102 of file batch_processor.h.

{0.0};

Referenced by reset(), and kcenon::logger::async::batch_processor::update_stats().

average_processing_time_ms

std::atomic<double> kcenon::logger::async::batch_processor::processing_stats::average_processing_time_ms {0.0}

Definition at line 103 of file batch_processor.h.

{0.0};

Referenced by reset(), and kcenon::logger::async::batch_processor::update_stats().

back_pressure_events

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::back_pressure_events {0}

Definition at line 95 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::handle_back_pressure(), and reset().

dropped_entries

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::dropped_entries {0}

Definition at line 94 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::add_entry(), and reset().

dynamic_size_adjustments

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::dynamic_size_adjustments {0}

Definition at line 96 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::adjust_batch_size(), and reset().

flush_by_manual

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::flush_by_manual {0}

Definition at line 100 of file batch_processor.h.

{0};

Referenced by reset().

flush_by_size

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::flush_by_size {0}

Definition at line 98 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::process_loop_iteration(), and reset().

flush_by_time

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::flush_by_time {0}

Definition at line 99 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::process_loop_iteration(), and reset().

total_batches

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::total_batches {0}

Definition at line 92 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::process_batch(), reset(), and kcenon::logger::async::batch_processor::update_stats().

total_entries

std::atomic<uint64_t> kcenon::logger::async::batch_processor::processing_stats::total_entries {0}

Definition at line 93 of file batch_processor.h.

{0};

Referenced by kcenon::logger::async::batch_processor::process_batch(), reset(), and kcenon::logger::async::batch_processor::update_stats().

---

The documentation for this struct was generated from the following file:

• src/impl/async/batch_processor.h