kafka-dest-worker.c File Reference

#include "kafka-dest-worker.h"
#include "kafka-internal.h"
#include "str-utils.h"
#include "timeutils/misc.h"
#include <zlib.h>

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

Functions
const gchar *	kafka_dest_worker_resolve_template_topic_name (KafkaDestWorker *self, LogMessage *msg)
rd_kafka_topic_t *	kafka_dest_worker_calculate_topic_from_template (KafkaDestWorker *self, LogMessage *msg)
rd_kafka_topic_t *	kafka_dest_worker_get_literal_topic (KafkaDestWorker *self)
rd_kafka_topic_t *	kafka_dest_worker_calculate_topic (KafkaDestWorker *self, LogMessage *msg)
LogThreadedDestWorker *	kafka_dest_worker_new (LogThreadedDestDriver *o, gint worker_index)

Function Documentation

kafka_dest_worker_calculate_topic()

rd_kafka_topic_t* kafka_dest_worker_calculate_topic	(	KafkaDestWorker *	self,
		LogMessage *	msg
	)

kafka_dest_worker_calculate_topic_from_template()

rd_kafka_topic_t* kafka_dest_worker_calculate_topic_from_template	(	KafkaDestWorker *	self,
		LogMessage *	msg
	)

kafka_dest_worker_get_literal_topic()

rd_kafka_topic_t* kafka_dest_worker_get_literal_topic

(

KafkaDestWorker *

self

)

kafka_dest_worker_new()

LogThreadedDestWorker* kafka_dest_worker_new	(	LogThreadedDestDriver *	o,
		gint	worker_index
	)

kafka_dest_worker_resolve_template_topic_name()

const gchar* kafka_dest_worker_resolve_template_topic_name	(	KafkaDestWorker *	self,
		LogMessage *	msg
	)