kafka-source-driver.h File Reference

#include "syslog-ng.h"
#include "driver.h"
#include "logsource.h"

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

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

Go to the source code of this file.

Functions
void	kafka_sd_merge_config (LogDriver *d, GList *props)
gboolean	kafka_sd_set_logging (LogDriver *d, const gchar *logging)
gboolean	kafka_sd_set_topics (LogDriver *d, GList *topics)
gboolean	kafka_sd_set_strategy_hint (LogDriver *d, const gchar *strategy_hint)
gboolean	kafka_sd_set_persis_store (LogDriver *d, const gchar *strategy_hint)
void	kafka_sd_set_bootstrap_servers (LogDriver *d, const gchar *bootstrap_servers)
void	kafka_sd_set_log_fetch_delay (LogDriver *s, guint new_value)
void	kafka_sd_set_log_fetch_retry_delay (LogDriver *s, guint new_value)
void	kafka_sd_set_log_fetch_limit (LogDriver *s, guint new_value)
void	kafka_sd_set_log_fetch_queue_full_delay (LogDriver *s, guint new_value)
void	kafka_sd_set_poll_timeout (LogDriver *d, gint poll_timeout)
void	kafka_sd_set_state_update_timeout (LogDriver *d, gint state_update_timeout)
void	kafka_sd_set_time_reopen (LogDriver *d, gint time_reopen)
void	kafka_sd_set_ignore_saved_bookmarks (LogDriver *s, gboolean new_value)
void	kafka_sd_set_disable_bookmarks (LogDriver *s, gboolean new_value)
void	kafka_sd_set_separate_worker_queues (LogDriver *s, gboolean new_value)
void	kafka_sd_set_store_kafka_metadata (LogDriver *s, gboolean new_value)
LogDriver *	kafka_sd_new (GlobalConfig *cfg)

Function Documentation

kafka_sd_merge_config()

void kafka_sd_merge_config	(	LogDriver *	d,
		GList *	props
	)

kafka_sd_new()

LogDriver* kafka_sd_new

(

GlobalConfig *

cfg

)

kafka_sd_set_bootstrap_servers()

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

kafka_sd_set_disable_bookmarks()

void kafka_sd_set_disable_bookmarks	(	LogDriver *	s,
		gboolean	new_value
	)

kafka_sd_set_ignore_saved_bookmarks()

void kafka_sd_set_ignore_saved_bookmarks	(	LogDriver *	s,
		gboolean	new_value
	)

kafka_sd_set_log_fetch_delay()

void kafka_sd_set_log_fetch_delay	(	LogDriver *	s,
		guint	new_value
	)

kafka_sd_set_log_fetch_limit()

void kafka_sd_set_log_fetch_limit	(	LogDriver *	s,
		guint	new_value
	)

kafka_sd_set_log_fetch_queue_full_delay()

void kafka_sd_set_log_fetch_queue_full_delay	(	LogDriver *	s,
		guint	new_value
	)

kafka_sd_set_log_fetch_retry_delay()

void kafka_sd_set_log_fetch_retry_delay	(	LogDriver *	s,
		guint	new_value
	)

kafka_sd_set_logging()

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

kafka_sd_set_persis_store()

gboolean kafka_sd_set_persis_store	(	LogDriver *	d,
		const gchar *	strategy_hint
	)

kafka_sd_set_poll_timeout()

void kafka_sd_set_poll_timeout	(	LogDriver *	d,
		gint	poll_timeout
	)

kafka_sd_set_separate_worker_queues()

void kafka_sd_set_separate_worker_queues	(	LogDriver *	s,
		gboolean	new_value
	)

kafka_sd_set_state_update_timeout()

void kafka_sd_set_state_update_timeout	(	LogDriver *	d,
		gint	state_update_timeout
	)

kafka_sd_set_store_kafka_metadata()

void kafka_sd_set_store_kafka_metadata	(	LogDriver *	s,
		gboolean	new_value
	)

kafka_sd_set_strategy_hint()

gboolean kafka_sd_set_strategy_hint	(	LogDriver *	d,
		const gchar *	strategy_hint
	)

kafka_sd_set_time_reopen()

void kafka_sd_set_time_reopen	(	LogDriver *	d,
		gint	time_reopen
	)

kafka_sd_set_topics()

gboolean kafka_sd_set_topics	(	LogDriver *	d,
		GList *	topics
	)