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

#include <logthrdestdrv.h>

Collaboration diagram for LogThreadedDestWorker:
Collaboration graph
[legend]

Public Attributes

MainLoopThreadedWorker thread
 
LogQueue * queue
 
struct iv_task do_work
 
struct iv_event wake_up_event
 
struct iv_event shutdown_event
 
struct iv_timer timer_reopen
 
struct iv_timer timer_throttle
 
struct iv_timer timer_flush
 
LogThreadedDestDriver * owner
 
gint worker_index
 
gboolean connected
 
gint batch_size
 
gint rewound_batch_size
 
gint retries_on_error_counter
 
guint retries_counter
 
gint32 seq_num
 
struct timespec last_flush_time
 
gboolean enable_batching
 
gboolean suspended
 
time_t time_reopen
 
struct {
   GString *   last_key
 
} partitioning
 
struct {
   StatsClusterKey *   output_event_bytes_sc_key
 
   StatsClusterKey *   output_unreachable_key
 
   StatsClusterKey *   message_delay_sample_key
 
   StatsClusterKey *   message_delay_sample_age_key
 
   StatsByteCounter   written_bytes
 
   StatsCounterItem *   output_unreachable
 
   StatsCounterItem *   message_delay_sample
 
   StatsCounterItem *   message_delay_sample_age
 
   gint64   last_delay_update
 
} metrics
 
gboolean(* init )(LogThreadedDestWorker *s)
 
void(* deinit )(LogThreadedDestWorker *s)
 
gboolean(* connect )(LogThreadedDestWorker *s)
 
void(* disconnect )(LogThreadedDestWorker *s)
 
LogThreadedResult(* insert )(LogThreadedDestWorker *s, LogMessage *msg)
 
LogThreadedResult(* flush )(LogThreadedDestWorker *s, LogThreadedFlushMode mode)
 
void(* free_fn )(LogThreadedDestWorker *s)
 

Member Data Documentation

◆ batch_size

gint LogThreadedDestWorker::batch_size

◆ connect

gboolean(* LogThreadedDestWorker::connect) (LogThreadedDestWorker *s)

◆ connected

gboolean LogThreadedDestWorker::connected

◆ deinit

void(* LogThreadedDestWorker::deinit) (LogThreadedDestWorker *s)

◆ disconnect

void(* LogThreadedDestWorker::disconnect) (LogThreadedDestWorker *s)

◆ do_work

struct iv_task LogThreadedDestWorker::do_work

◆ enable_batching

gboolean LogThreadedDestWorker::enable_batching

◆ flush

LogThreadedResult(* LogThreadedDestWorker::flush) (LogThreadedDestWorker *s, LogThreadedFlushMode mode)

◆ free_fn

void(* LogThreadedDestWorker::free_fn) (LogThreadedDestWorker *s)

◆ init

gboolean(* LogThreadedDestWorker::init) (LogThreadedDestWorker *s)

◆ insert

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

◆ last_delay_update

gint64 LogThreadedDestWorker::last_delay_update

◆ last_flush_time

struct timespec LogThreadedDestWorker::last_flush_time

◆ last_key

GString* LogThreadedDestWorker::last_key

◆ message_delay_sample

StatsCounterItem* LogThreadedDestWorker::message_delay_sample

◆ message_delay_sample_age

StatsCounterItem* LogThreadedDestWorker::message_delay_sample_age

◆ message_delay_sample_age_key

StatsClusterKey* LogThreadedDestWorker::message_delay_sample_age_key

◆ message_delay_sample_key

StatsClusterKey* LogThreadedDestWorker::message_delay_sample_key

◆ 

struct { ... } LogThreadedDestWorker::metrics

◆ output_event_bytes_sc_key

StatsClusterKey* LogThreadedDestWorker::output_event_bytes_sc_key

◆ output_unreachable

StatsCounterItem* LogThreadedDestWorker::output_unreachable

◆ output_unreachable_key

StatsClusterKey* LogThreadedDestWorker::output_unreachable_key

◆ owner

LogThreadedDestDriver* LogThreadedDestWorker::owner

◆ 

struct { ... } LogThreadedDestWorker::partitioning

◆ queue

LogQueue* LogThreadedDestWorker::queue

◆ retries_counter

guint LogThreadedDestWorker::retries_counter

◆ retries_on_error_counter

gint LogThreadedDestWorker::retries_on_error_counter

◆ rewound_batch_size

gint LogThreadedDestWorker::rewound_batch_size

◆ seq_num

gint32 LogThreadedDestWorker::seq_num

◆ shutdown_event

struct iv_event LogThreadedDestWorker::shutdown_event

◆ suspended

gboolean LogThreadedDestWorker::suspended

◆ thread

MainLoopThreadedWorker LogThreadedDestWorker::thread

◆ time_reopen

time_t LogThreadedDestWorker::time_reopen

◆ timer_flush

struct iv_timer LogThreadedDestWorker::timer_flush

◆ timer_reopen

struct iv_timer LogThreadedDestWorker::timer_reopen

◆ timer_throttle

struct iv_timer LogThreadedDestWorker::timer_throttle

◆ wake_up_event

struct iv_event LogThreadedDestWorker::wake_up_event

◆ worker_index

gint LogThreadedDestWorker::worker_index

◆ written_bytes

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