syslog-ng source
Public Attributes | List of all members
KafkaSourcePersist Struct Reference
Collaboration diagram for KafkaSourcePersist:
Collaboration graph
[legend]

Public Attributes

PersistState * persist_state
 
PersistEntryHandle handle
 
gboolean use_offset_tracker
 
OffsetTracker * tracker
 
KafkaSourceDriver * owner
 
gchar topic [MAX_KAFKA_TOPIC_NAME_LEN+1]
 
int32_t partition
 
int64_t last_confirmed_offset
 
GMutex mutex
 
gboolean valid
 
guint used_count
 

Member Data Documentation

◆ handle

PersistEntryHandle KafkaSourcePersist::handle

◆ last_confirmed_offset

int64_t KafkaSourcePersist::last_confirmed_offset

◆ mutex

GMutex KafkaSourcePersist::mutex

◆ owner

KafkaSourceDriver* KafkaSourcePersist::owner

◆ partition

int32_t KafkaSourcePersist::partition

◆ persist_state

PersistState* KafkaSourcePersist::persist_state

◆ topic

gchar KafkaSourcePersist::topic[MAX_KAFKA_TOPIC_NAME_LEN+1]

◆ tracker

OffsetTracker* KafkaSourcePersist::tracker

◆ use_offset_tracker

gboolean KafkaSourcePersist::use_offset_tracker

◆ used_count

guint KafkaSourcePersist::used_count

◆ valid

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