syslog-ng source
LogWriter Struct Reference
Collaboration diagram for LogWriter:

Public Attributes

LogPipe super
 
LogQueue * queue
 
guint32 flags: 31
 
gint32 seq_num
 
gboolean handshake_in_progress
 
gboolean partial_write
 
struct {
   StatsClusterKeyBuilder *   stats_kb
 
   StatsClusterKey *   output_events_key
 
   StatsCounterItem *   dropped_messages
 
   StatsCounterItem *   suppressed_messages
 
   StatsCounterItem *   processed_messages
 
   StatsCounterItem *   written_messages
 
   StatsClusterKey *   written_bytes_key
 
   StatsByteCounter   written_bytes
 
   StatsAggregator *   max_message_size
 
   StatsAggregator *   average_messages_size
 
   StatsAggregator *   CPS
 
   StatsClusterKey *   message_delay_key
 
   StatsCounterItem *   message_delay
 
   StatsClusterKey *   message_delay_sample_age_key
 
   StatsCounterItem *   message_delay_sample_age
 
   struct {
      StatsCounterItem *   count
 
      StatsCounterItem *   bytes
 
   }   truncated
 
metrics
 
LogPipe * control
 
LogWriterOptionsoptions
 
LogMessage * last_msg
 
guint32 last_msg_count
 
time_t last_delay_update
 
GString * line_buffer
 
gchar * stats_id
 
struct iv_fd fd_watch
 
struct iv_timer suspend_timer
 
struct iv_task immed_io_task
 
struct iv_event queue_filled
 
MainLoopIOWorkerJob io_job
 
GMutex suppress_lock
 
MlBatchedTimer suppress_timer
 
MlBatchedTimer mark_timer
 
struct iv_timer reopen_timer
 
struct iv_timer idle_timer
 
LogProtoStatus work_result
 
gint pollable_state
 
LogProtoClient * proto
 
LogProtoClient * pending_proto
 
guint watches_running: 1
 
guint suspended: 1
 
guint waiting_for_throttle: 1
 
gboolean pending_proto_present
 
GCond pending_proto_cond
 
GMutex pending_proto_lock
 

Member Data Documentation

◆ average_messages_size

StatsAggregator* LogWriter::average_messages_size

◆ bytes

StatsCounterItem* LogWriter::bytes

◆ control

LogPipe* LogWriter::control

◆ count

StatsCounterItem* LogWriter::count

◆ CPS

StatsAggregator* LogWriter::CPS

◆ dropped_messages

StatsCounterItem* LogWriter::dropped_messages

◆ fd_watch

struct iv_fd LogWriter::fd_watch

◆ flags

guint32 LogWriter::flags

◆ handshake_in_progress

gboolean LogWriter::handshake_in_progress

◆ idle_timer

struct iv_timer LogWriter::idle_timer

◆ immed_io_task

struct iv_task LogWriter::immed_io_task

◆ io_job

MainLoopIOWorkerJob LogWriter::io_job

◆ last_delay_update

time_t LogWriter::last_delay_update

◆ last_msg

LogMessage* LogWriter::last_msg

◆ last_msg_count

guint32 LogWriter::last_msg_count

◆ line_buffer

GString* LogWriter::line_buffer

◆ mark_timer

MlBatchedTimer LogWriter::mark_timer

◆ max_message_size

StatsAggregator* LogWriter::max_message_size

◆ message_delay

StatsCounterItem* LogWriter::message_delay

◆ message_delay_key

StatsClusterKey* LogWriter::message_delay_key

◆ message_delay_sample_age

StatsCounterItem* LogWriter::message_delay_sample_age

◆ message_delay_sample_age_key

StatsClusterKey* LogWriter::message_delay_sample_age_key

◆ 

struct { ... } LogWriter::metrics

◆ options

LogWriterOptions* LogWriter::options

◆ output_events_key

StatsClusterKey* LogWriter::output_events_key

◆ partial_write

gboolean LogWriter::partial_write

◆ pending_proto

LogProtoClient * LogWriter::pending_proto

◆ pending_proto_cond

GCond LogWriter::pending_proto_cond

◆ pending_proto_lock

GMutex LogWriter::pending_proto_lock

◆ pending_proto_present

gboolean LogWriter::pending_proto_present

◆ pollable_state

gint LogWriter::pollable_state

◆ processed_messages

StatsCounterItem* LogWriter::processed_messages

◆ proto

LogProtoClient* LogWriter::proto

◆ queue

LogQueue* LogWriter::queue

◆ queue_filled

struct iv_event LogWriter::queue_filled

◆ reopen_timer

struct iv_timer LogWriter::reopen_timer

◆ seq_num

gint32 LogWriter::seq_num

◆ stats_id

gchar* LogWriter::stats_id

◆ stats_kb

StatsClusterKeyBuilder* LogWriter::stats_kb

◆ super

LogPipe LogWriter::super

◆ suppress_lock

GMutex LogWriter::suppress_lock

◆ suppress_timer

MlBatchedTimer LogWriter::suppress_timer

◆ suppressed_messages

StatsCounterItem* LogWriter::suppressed_messages

◆ suspend_timer

struct iv_timer LogWriter::suspend_timer

◆ suspended

guint LogWriter::suspended

◆ 

struct { ... } LogWriter::truncated

◆ waiting_for_throttle

guint LogWriter::waiting_for_throttle

◆ watches_running

guint LogWriter::watches_running

◆ work_result

LogProtoStatus LogWriter::work_result

◆ written_bytes

StatsByteCounter LogWriter::written_bytes

◆ written_bytes_key

StatsClusterKey* LogWriter::written_bytes_key

◆ written_messages

StatsCounterItem* LogWriter::written_messages

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