kafka-dest-driver.c File Reference

#include "kafka-dest-driver.h"
#include "kafka-internal.h"
#include "kafka-props.h"
#include <stdlib.h>

Include dependency graph for kafka-dest-driver.c:

Functions
void	kafka_dd_set_topic (LogDriver *d, LogTemplate *topic)
void	kafka_dd_set_fallback_topic (LogDriver *d, const gchar *fallback_topic)
void	kafka_dd_merge_config (LogDriver *d, GList *props)
gboolean	kafka_dd_set_logging (LogDriver *d, const gchar *logging)
void	kafka_dd_set_bootstrap_servers (LogDriver *d, const gchar *bootstrap_servers)
void	kafka_dd_set_poll_timeout (LogDriver *d, gint poll_timeout)
void	kafka_dd_set_key_ref (LogDriver *d, LogTemplate *key)
void	kafka_dd_set_message_ref (LogDriver *d, LogTemplate *message)
void	kafka_dd_set_flush_timeout_on_shutdown (LogDriver *d, gint flush_timeout_on_shutdown)
void	kafka_dd_set_flush_timeout_on_reload (LogDriver *d, gint flush_timeout_on_reload)
void	kafka_dd_set_transaction_commit (LogDriver *d, gboolean transaction_commit)
LogTemplateOptions *	kafka_dd_get_template_options (LogDriver *d)
gboolean	kafka_dd_is_topic_name_a_template (KafkaDestDriver *self)
rd_kafka_topic_t *	_construct_topic (KafkaDestDriver *self, const gchar *name)
rd_kafka_topic_t *	kafka_dd_query_insert_topic (KafkaDestDriver *self, const gchar *name)
gboolean	kafka_dd_reopen (LogDriver *s)
gboolean	kafka_dd_init (LogPipe *s)
void	kafka_dd_shutdown (LogThreadedDestDriver *s)
LogDriver *	kafka_dd_new (GlobalConfig *cfg)

Function Documentation

_construct_topic()

rd_kafka_topic_t* _construct_topic	(	KafkaDestDriver *	self,
		const gchar *	name
	)

kafka_dd_get_template_options()

LogTemplateOptions* kafka_dd_get_template_options

(

LogDriver *

d

)

kafka_dd_init()

gboolean kafka_dd_init

(

LogPipe *

s

)

kafka_dd_is_topic_name_a_template()

gboolean kafka_dd_is_topic_name_a_template

(

KafkaDestDriver *

self

)

kafka_dd_merge_config()

void kafka_dd_merge_config	(	LogDriver *	d,
		GList *	props
	)

kafka_dd_new()

LogDriver* kafka_dd_new

(

GlobalConfig *

cfg

)

kafka_dd_query_insert_topic()

rd_kafka_topic_t* kafka_dd_query_insert_topic	(	KafkaDestDriver *	self,
		const gchar *	name
	)

kafka_dd_reopen()

gboolean kafka_dd_reopen

(

LogDriver *

s

)

kafka_dd_set_bootstrap_servers()

void kafka_dd_set_bootstrap_servers	(	LogDriver *	d,
		const gchar *	bootstrap_servers
	)

kafka_dd_set_fallback_topic()

void kafka_dd_set_fallback_topic	(	LogDriver *	d,
		const gchar *	fallback_topic
	)

kafka_dd_set_flush_timeout_on_reload()

void kafka_dd_set_flush_timeout_on_reload	(	LogDriver *	d,
		gint	flush_timeout_on_reload
	)

kafka_dd_set_flush_timeout_on_shutdown()

void kafka_dd_set_flush_timeout_on_shutdown	(	LogDriver *	d,
		gint	flush_timeout_on_shutdown
	)

kafka_dd_set_key_ref()

void kafka_dd_set_key_ref	(	LogDriver *	d,
		LogTemplate *	key
	)

kafka_dd_set_logging()

gboolean kafka_dd_set_logging	(	LogDriver *	d,
		const gchar *	logging
	)

kafka_dd_set_message_ref()

void kafka_dd_set_message_ref	(	LogDriver *	d,
		LogTemplate *	message
	)

kafka_dd_set_poll_timeout()

void kafka_dd_set_poll_timeout	(	LogDriver *	d,
		gint	poll_timeout
	)

kafka_dd_set_topic()

void kafka_dd_set_topic	(	LogDriver *	d,
		LogTemplate *	topic
	)

kafka_dd_set_transaction_commit()

void kafka_dd_set_transaction_commit	(	LogDriver *	d,
		gboolean	transaction_commit
	)

kafka_dd_shutdown()

void kafka_dd_shutdown

(

LogThreadedDestDriver *

s

)