kafka-source-persist.c File Reference

#include "kafka-source-persist.h"
#include "kafka-internal.h"
#include "messages.h"
#include "persistable-state-header.h"
#include "ack-tracker/ack_tracker.h"

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

Classes
struct	OffsetTracker
struct	KafkaSourcePersistData
struct	KafkaSourcePersist
struct	KafkaSourceBookmark

Macros
#define	KAFKA_SOURCE_PERSIST_VERSION_1   1
#define	MIN_WINDOW_SIZE   2048

Functions
void	kafka_source_persist_fill_bookmark (KafkaSourcePersist *self, Bookmark *bookmark, int64_t offset)
void	kafka_source_persist_load_position (KafkaSourcePersist *self, int64_t *offset)
gboolean	kafka_source_persist_init (KafkaSourcePersist *self, PersistState *persist_state, const gchar *topic, int32_t partition, int64_t override_position, gboolean use_offset_tracker)
int32_t	kafka_source_persist_get_partition (KafkaSourcePersist *self)
const gchar *	kafka_source_persist_get_topic (KafkaSourcePersist *self)
gboolean	kafka_source_persist_remote_is_valid (KafkaSourcePersist *self)
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)
KafkaSourcePersist *	kafka_source_persist_new (KafkaSourceDriver *owner)
void	kafka_source_persist_ref (KafkaSourcePersist *self)
void	kafka_source_persist_unref (KafkaSourcePersist *self)

Macro Definition Documentation

KAFKA_SOURCE_PERSIST_VERSION_1

#define KAFKA_SOURCE_PERSIST_VERSION_1   1

MIN_WINDOW_SIZE

#define MIN_WINDOW_SIZE   2048

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 *	persist_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