syslog-ng source
Public Attributes | List of all members
LogThreadedDestDriver Struct Reference

#include <logthrdestdrv.h>

Collaboration diagram for LogThreadedDestDriver:
Collaboration graph
[legend]

Public Attributes

LogDestDriver super
 
struct {
   StatsClusterKey *   output_events_sc_key
 
   StatsClusterKey *   processed_sc_key
 
   StatsClusterKey *   output_event_retries_sc_key
 
   StatsCounterItem *   dropped_messages
 
   StatsCounterItem *   processed_messages
 
   StatsCounterItem *   written_messages
 
   StatsCounterItem *   output_event_retries
 
   StatsAggregator *   max_message_size
 
   StatsAggregator *   average_messages_size
 
   StatsAggregator *   max_batch_size
 
   StatsAggregator *   average_batch_size
 
   StatsAggregator *   CPS
 
} metrics
 
gint batch_lines
 
gint batch_timeout
 
gboolean under_termination
 
time_t time_reopen
 
gint retries_on_error_max
 
guint retries_max
 
struct {
   LogThreadedDestWorker *(*   construct )(LogThreadedDestDriver *s,
      gint worker_index)
 
   LogThreadedDestWorker   instance
 
   void(*   thread_init )(LogThreadedDestDriver *s)
 
   void(*   thread_deinit )(LogThreadedDestDriver *s)
 
   gboolean(*   connect )(LogThreadedDestDriver *s)
 
   void(*   disconnect )(LogThreadedDestDriver *s)
 
   LogThreadedResult(*   insert )(LogThreadedDestDriver *s,
      LogMessage *msg)
 
   LogThreadedResult(*   flush )(LogThreadedDestDriver *s)
 
} worker
 
LogThreadedDestWorker ** workers
 
gint num_workers
 
gint created_workers
 
guint last_worker
 
gboolean flush_on_key_change
 
LogTemplate * worker_partition_key
 
gint stats_source
 
gint32 shared_seq_num
 
guint32 flags
 
const gchar *(* format_stats_key )(LogThreadedDestDriver *s, StatsClusterKeyBuilder *kb)
 

Member Data Documentation

◆ average_batch_size

StatsAggregator* LogThreadedDestDriver::average_batch_size

◆ average_messages_size

StatsAggregator* LogThreadedDestDriver::average_messages_size

◆ batch_lines

gint LogThreadedDestDriver::batch_lines

◆ batch_timeout

gint LogThreadedDestDriver::batch_timeout

◆ connect

gboolean(* LogThreadedDestDriver::connect) (LogThreadedDestDriver *s)

◆ construct

LogThreadedDestWorker*(* LogThreadedDestDriver::construct) (LogThreadedDestDriver *s, gint worker_index)

◆ CPS

StatsAggregator* LogThreadedDestDriver::CPS

◆ created_workers

gint LogThreadedDestDriver::created_workers

◆ disconnect

void(* LogThreadedDestDriver::disconnect) (LogThreadedDestDriver *s)

◆ dropped_messages

StatsCounterItem* LogThreadedDestDriver::dropped_messages

◆ flags

guint32 LogThreadedDestDriver::flags

◆ flush

LogThreadedResult(* LogThreadedDestDriver::flush) (LogThreadedDestDriver *s)

◆ flush_on_key_change

gboolean LogThreadedDestDriver::flush_on_key_change

◆ format_stats_key

const gchar*(* LogThreadedDestDriver::format_stats_key) (LogThreadedDestDriver *s, StatsClusterKeyBuilder *kb)

◆ insert

LogThreadedResult(* LogThreadedDestDriver::insert) (LogThreadedDestDriver *s, LogMessage *msg)

◆ instance

LogThreadedDestWorker LogThreadedDestDriver::instance

◆ last_worker

guint LogThreadedDestDriver::last_worker

◆ max_batch_size

StatsAggregator* LogThreadedDestDriver::max_batch_size

◆ max_message_size

StatsAggregator* LogThreadedDestDriver::max_message_size

◆ 

struct { ... } LogThreadedDestDriver::metrics

◆ num_workers

gint LogThreadedDestDriver::num_workers

◆ output_event_retries

StatsCounterItem* LogThreadedDestDriver::output_event_retries

◆ output_event_retries_sc_key

StatsClusterKey* LogThreadedDestDriver::output_event_retries_sc_key

◆ output_events_sc_key

StatsClusterKey* LogThreadedDestDriver::output_events_sc_key

◆ processed_messages

StatsCounterItem* LogThreadedDestDriver::processed_messages

◆ processed_sc_key

StatsClusterKey* LogThreadedDestDriver::processed_sc_key

◆ retries_max

guint LogThreadedDestDriver::retries_max

◆ retries_on_error_max

gint LogThreadedDestDriver::retries_on_error_max

◆ shared_seq_num

gint32 LogThreadedDestDriver::shared_seq_num

◆ stats_source

gint LogThreadedDestDriver::stats_source

◆ super

LogDestDriver LogThreadedDestDriver::super

◆ thread_deinit

void(* LogThreadedDestDriver::thread_deinit) (LogThreadedDestDriver *s)

◆ thread_init

void(* LogThreadedDestDriver::thread_init) (LogThreadedDestDriver *s)

◆ time_reopen

time_t LogThreadedDestDriver::time_reopen

◆ under_termination

gboolean LogThreadedDestDriver::under_termination

◆ 

struct { ... } LogThreadedDestDriver::worker

◆ worker_partition_key

LogTemplate* LogThreadedDestDriver::worker_partition_key

◆ workers

LogThreadedDestWorker** LogThreadedDestDriver::workers

◆ written_messages

StatsCounterItem* LogThreadedDestDriver::written_messages
The documentation for this struct was generated from the following file: