#include "logthrdest/logthrdestdrv.h"

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

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

Functions
void	kafka_dd_merge_config (LogDriver d, GList props)

void	kafka_dd_set_topic (LogDriver d, LogTemplate topic)

void	kafka_dd_set_fallback_topic (LogDriver d, const gchar fallback_topic)

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_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 shutdown_timeout)

void	kafka_dd_set_flush_timeout_on_reload (LogDriver *d, gint reload_timeout)

void	kafka_dd_set_poll_timeout (LogDriver *d, gint poll_timeout)

void	kafka_dd_set_transaction_commit (LogDriver *d, gboolean transaction_commit)

gboolean	kafka_dd_is_topic_name_a_template (KafkaDestDriver *self)

LogTemplateOptions *	kafka_dd_get_template_options (LogDriver *d)

gboolean	kafka_dd_reopen (LogDriver *d)

void	kafka_dd_shutdown (LogThreadedDestDriver *s)

LogDriver *	kafka_dd_new (GlobalConfig *cfg)

Function Documentation

◆ kafka_dd_get_template_options()

LogTemplateOptions* kafka_dd_get_template_options ( LogDriver * d )

◆ 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_reopen()

gboolean kafka_dd_reopen ( LogDriver * d )

◆ 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	reload_timeout
	)

◆ kafka_dd_set_flush_timeout_on_shutdown()

void kafka_dd_set_flush_timeout_on_shutdown	(	LogDriver *	d,
		gint	shutdown_timeout
	)

◆ 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 )

Functions