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

#include <kafka-internal.h>

Collaboration diagram for KafkaSourceDriver:
Collaboration graph
[legend]

Public Attributes

LogThreadedSourceDriver super
 
KafkaSourceOptions options
 
KafkaOpaque opaque
 
rd_kafka_t * kafka
 
rd_kafka_queue_t * consumer_kafka_queue
 
rd_kafka_queue_t * main_kafka_queue
 
rd_kafka_topic_partition_list_t * assigned_partitions
 
gchar * group_id
 
GList * requested_topics
 
KafkaSrcConsumerStrategy strategy
 
GAsyncQueue ** msg_queues
 
GCond * queue_conds
 
GMutex * queue_cond_mutexes
 
guint allocated_queue_num
 
gchar single_queue_name [64]
 
GMutex partition_assignement_mutex
 
gboolean reassign_signaled
 
gboolean assignement_invalidated_signaled
 
GAtomicCounter running_thread_num
 
GAtomicCounter sleeping_thread_num
 
GHashTable * persists
 
gboolean all_persists_ready
 
const gchar * persist_name
 
const gchar * stat_persist_name
 
GHashTable * stats_topics
 
GHashTable * stats_workers
 
StatsAggregator * max_message_size
 
StatsAggregator * average_messages_size
 
StatsAggregator * CPS
 

Member Data Documentation

◆ all_persists_ready

gboolean KafkaSourceDriver::all_persists_ready

◆ allocated_queue_num

guint KafkaSourceDriver::allocated_queue_num

◆ assigned_partitions

rd_kafka_topic_partition_list_t* KafkaSourceDriver::assigned_partitions

◆ assignement_invalidated_signaled

gboolean KafkaSourceDriver::assignement_invalidated_signaled

◆ average_messages_size

StatsAggregator* KafkaSourceDriver::average_messages_size

◆ consumer_kafka_queue

rd_kafka_queue_t* KafkaSourceDriver::consumer_kafka_queue

◆ CPS

StatsAggregator* KafkaSourceDriver::CPS

◆ group_id

gchar* KafkaSourceDriver::group_id

◆ kafka

rd_kafka_t* KafkaSourceDriver::kafka

◆ main_kafka_queue

rd_kafka_queue_t* KafkaSourceDriver::main_kafka_queue

◆ max_message_size

StatsAggregator* KafkaSourceDriver::max_message_size

◆ msg_queues

GAsyncQueue** KafkaSourceDriver::msg_queues

◆ opaque

KafkaOpaque KafkaSourceDriver::opaque

◆ options

KafkaSourceOptions KafkaSourceDriver::options

◆ partition_assignement_mutex

GMutex KafkaSourceDriver::partition_assignement_mutex

◆ persist_name

const gchar* KafkaSourceDriver::persist_name

◆ persists

GHashTable* KafkaSourceDriver::persists

◆ queue_cond_mutexes

GMutex* KafkaSourceDriver::queue_cond_mutexes

◆ queue_conds

GCond* KafkaSourceDriver::queue_conds

◆ reassign_signaled

gboolean KafkaSourceDriver::reassign_signaled

◆ requested_topics

GList* KafkaSourceDriver::requested_topics

◆ running_thread_num

GAtomicCounter KafkaSourceDriver::running_thread_num

◆ single_queue_name

gchar KafkaSourceDriver::single_queue_name[64]

◆ sleeping_thread_num

GAtomicCounter KafkaSourceDriver::sleeping_thread_num

◆ stat_persist_name

const gchar* KafkaSourceDriver::stat_persist_name

◆ stats_topics

GHashTable* KafkaSourceDriver::stats_topics

◆ stats_workers

GHashTable* KafkaSourceDriver::stats_workers

◆ strategy

KafkaSrcConsumerStrategy KafkaSourceDriver::strategy

◆ super

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