kafka-source-persist.h File Reference

#include "syslog-ng.h"
#include "persist-state.h"
#include "kafka-source-driver.h"
#include <librdkafka/rdkafka.h>

Include dependency graph for kafka-source-persist.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
KafkaSourcePersist *	kafka_source_persist_new (KafkaSourceDriver *owner)
void	kafka_source_persist_ref (KafkaSourcePersist *self)
void	kafka_source_persist_unref (KafkaSourcePersist *self)
gboolean	kafka_source_persist_init (KafkaSourcePersist *self, PersistState *state, const gchar *topic, int32_t partition, int64_t override_position, gboolean use_offset_tracker)
void	kafka_source_persist_invalidate (KafkaSourcePersist *self)
gboolean	kafka_source_persist_is_ready (KafkaSourcePersist *self)
gboolean	kafka_source_persist_matching (KafkaSourcePersist *self, const gchar *topic, int32_t partition)
gboolean	kafka_source_persist_remote_is_valid (KafkaSourcePersist *self)
int32_t	kafka_source_persist_get_partition (KafkaSourcePersist *self)
const gchar *	kafka_source_persist_get_topic (KafkaSourcePersist *self)
void	kafka_source_persist_fill_bookmark (KafkaSourcePersist *self, Bookmark *bookmark, int64_t offset)
void	kafka_source_persist_load_position (KafkaSourcePersist *self, int64_t *offset)

Function Documentation

kafka_source_persist_fill_bookmark()

void kafka_source_persist_fill_bookmark	(	KafkaSourcePersist *	self,
		Bookmark *	bookmark,
		int64_t	offset
	)

kafka_source_persist_get_partition()

int32_t kafka_source_persist_get_partition

(

KafkaSourcePersist *

self

)

kafka_source_persist_get_topic()

const gchar* kafka_source_persist_get_topic

(

KafkaSourcePersist *

self

)

kafka_source_persist_init()

gboolean kafka_source_persist_init	(	KafkaSourcePersist *	self,
		PersistState *	state,
		const gchar *	topic,
		int32_t	partition,
		int64_t	override_position,
		gboolean	use_offset_tracker
	)

kafka_source_persist_invalidate()

void kafka_source_persist_invalidate

(

KafkaSourcePersist *

self

)

kafka_source_persist_is_ready()

gboolean kafka_source_persist_is_ready ( KafkaSourcePersist *  self )

inline

kafka_source_persist_load_position()

void kafka_source_persist_load_position	(	KafkaSourcePersist *	self,
		int64_t *	offset
	)

kafka_source_persist_matching()

gboolean kafka_source_persist_matching ( KafkaSourcePersist *  self, const gchar *  topic, int32_t  partition  )

inline

kafka_source_persist_new()

KafkaSourcePersist* kafka_source_persist_new

(

KafkaSourceDriver *

owner

)

kafka_source_persist_ref()

void kafka_source_persist_ref ( KafkaSourcePersist *  self )

inline

kafka_source_persist_remote_is_valid()

gboolean kafka_source_persist_remote_is_valid

(

KafkaSourcePersist *

self

)

kafka_source_persist_unref()

void kafka_source_persist_unref ( KafkaSourcePersist *  self )

inline