kafka-internal.c File Reference

#include "kafka-internal.h"
#include "kafka-props.h"

Include dependency graph for kafka-internal.c:

Functions
GQuark	topic_name_error_quark (void)
gboolean	kafka_validate_topic_pattern (const char *topic, GError **error)
gboolean	kafka_validate_topic_name (const gchar *name, GError **error)
void	kafka_log_callback (const rd_kafka_t *rkt, int level, const char *fac, const char *msg)
gboolean	kafka_conf_get_prop (const rd_kafka_conf_t *conf, const gchar *name, gchar *dest, size_t *dest_size)
gboolean	kafka_conf_set_prop (rd_kafka_conf_t *conf, const gchar *name, const gchar *value)
gboolean	kafka_apply_config_props (rd_kafka_conf_t *conf, GList *props, gchar **protected_properties, gsize protected_properties_num)
gchar *	kafka_format_partition_key (const gchar *topic, int32_t partition, gchar *key, gsize key_size)
gboolean	kafka_seek_partition (KafkaSourceDriver *self, rd_kafka_topic_partition_t *partition, int64_t offset, int timeout_ms)
gboolean	kafka_seek_partitions (KafkaSourceDriver *self, rd_kafka_topic_partition_list_t *partitions, int timeout_ms)
void	kafka_log_partition_list (KafkaSourceDriver *self, const rd_kafka_topic_partition_list_t *partitions)
void	kafka_register_counters (KafkaSourceDriver *self, GHashTable *stats_table, const gchar *label, const gchar *label_value, const gchar **counter_names, gint level)
void	kafka_unregister_counters (KafkaSourceDriver *self, const gchar *label, const gchar *label_value, StatsCounterItem *counter, const gchar **counter_names)
void	kafka_options_defaults (KafkaOptions *self)
void	kafka_options_destroy (KafkaOptions *self)
void	kafka_options_merge_config (KafkaOptions *self, GList *props)
KafkaLogging	kafka_string_to_logging (const gchar *logging)
gboolean	kafka_options_set_logging (KafkaOptions *self, const gchar *logging)
void	kafka_options_set_bootstrap_servers (KafkaOptions *self, const gchar *bootstrap_servers)
void	kafka_options_set_poll_timeout (KafkaOptions *self, gint poll_timeout)
void	kafka_options_set_state_update_timeout (KafkaOptions *self, gint state_update_timeout)
void	kafka_opaque_init (KafkaOpaque *self, LogDriver *driver, KafkaOptions *options)
void	kafka_opaque_deinit (KafkaOpaque *self)
LogDriver *	kafka_opaque_driver (KafkaOpaque *self)
void	kafka_opaque_state_lock (KafkaOpaque *self)
void	kafka_opaque_state_unlock (KafkaOpaque *self)
KafkaConnectedState	kafka_opaque_state_get (KafkaOpaque *self)
void	kafka_opaque_state_set (KafkaOpaque *self, KafkaConnectedState state)
gint	kafka_opaque_state_get_last_error (KafkaOpaque *self)
void	kafka_opaque_state_set_last_error (KafkaOpaque *self, gint error)

Function Documentation

kafka_apply_config_props()

gboolean kafka_apply_config_props	(	rd_kafka_conf_t *	conf,
		GList *	props,
		gchar **	protected_properties,
		gsize	protected_properties_num
	)

kafka_conf_get_prop()

gboolean kafka_conf_get_prop	(	const rd_kafka_conf_t *	conf,
		const gchar *	name,
		gchar *	dest,
		size_t *	dest_size
	)

kafka_conf_set_prop()

gboolean kafka_conf_set_prop	(	rd_kafka_conf_t *	conf,
		const gchar *	name,
		const gchar *	value
	)

kafka_format_partition_key()

gchar* kafka_format_partition_key ( const gchar *  topic, int32_t  partition, gchar *  key, gsize  key_size  )

inline

kafka_log_callback()

void kafka_log_callback	(	const rd_kafka_t *	rkt,
		int	level,
		const char *	fac,
		const char *	msg
	)

kafka_log_partition_list()

void kafka_log_partition_list	(	KafkaSourceDriver *	self,
		const rd_kafka_topic_partition_list_t *	partitions
	)

kafka_opaque_deinit()

void kafka_opaque_deinit

(

KafkaOpaque *

self

)

kafka_opaque_driver()

LogDriver* kafka_opaque_driver ( KafkaOpaque *  self )

inline

kafka_opaque_init()

void kafka_opaque_init	(	KafkaOpaque *	self,
		LogDriver *	driver,
		KafkaOptions *	options
	)

kafka_opaque_state_get()

KafkaConnectedState kafka_opaque_state_get ( KafkaOpaque *  self )

inline

kafka_opaque_state_get_last_error()

gint kafka_opaque_state_get_last_error ( KafkaOpaque *  self )

inline

kafka_opaque_state_lock()

void kafka_opaque_state_lock ( KafkaOpaque *  self )

inline

kafka_opaque_state_set()

void kafka_opaque_state_set ( KafkaOpaque *  self, KafkaConnectedState  state  )

inline

kafka_opaque_state_set_last_error()

void kafka_opaque_state_set_last_error ( KafkaOpaque *  self, gint  error  )

inline

kafka_opaque_state_unlock()

void kafka_opaque_state_unlock ( KafkaOpaque *  self )

inline

kafka_options_defaults()

void kafka_options_defaults

(

KafkaOptions *

self

)

kafka_options_destroy()

void kafka_options_destroy

(

KafkaOptions *

self

)

kafka_options_merge_config()

void kafka_options_merge_config ( KafkaOptions *  self, GList *  props  )

inline

kafka_options_set_bootstrap_servers()

void kafka_options_set_bootstrap_servers	(	KafkaOptions *	self,
		const gchar *	bootstrap_servers
	)

kafka_options_set_logging()

gboolean kafka_options_set_logging	(	KafkaOptions *	self,
		const gchar *	logging
	)

kafka_options_set_poll_timeout()

void kafka_options_set_poll_timeout ( KafkaOptions *  self, gint  poll_timeout  )

inline

kafka_options_set_state_update_timeout()

void kafka_options_set_state_update_timeout ( KafkaOptions *  self, gint  state_update_timeout  )

inline

kafka_register_counters()

void kafka_register_counters	(	KafkaSourceDriver *	self,
		GHashTable *	stats_table,
		const gchar *	label,
		const gchar *	label_value,
		const gchar **	counter_names,
		gint	level
	)

kafka_seek_partition()

gboolean kafka_seek_partition	(	KafkaSourceDriver *	self,
		rd_kafka_topic_partition_t *	partition,
		int64_t	offset,
		int	timeout_ms
	)

kafka_seek_partitions()

gboolean kafka_seek_partitions	(	KafkaSourceDriver *	self,
		rd_kafka_topic_partition_list_t *	partitions,
		int	timeout_ms
	)

kafka_string_to_logging()

KafkaLogging kafka_string_to_logging

(

const gchar *

logging

)

kafka_unregister_counters()

void kafka_unregister_counters	(	KafkaSourceDriver *	self,
		const gchar *	label,
		const gchar *	label_value,
		StatsCounterItem *	counter,
		const gchar **	counter_names
	)

kafka_validate_topic_name()

gboolean kafka_validate_topic_name	(	const gchar *	name,
		GError **	error
	)

kafka_validate_topic_pattern()

gboolean kafka_validate_topic_pattern	(	const char *	topic,
		GError **	error
	)

topic_name_error_quark()

GQuark topic_name_error_quark

(

void

)