mqtt-destination.c File Reference

#include "mqtt-destination.h"
#include "mqtt-worker.h"
#include "plugin.h"
#include "messages.h"
#include "misc.h"
#include "stats/stats-registry.h"
#include "logqueue.h"
#include "driver.h"
#include "plugin-types.h"
#include "logthrdest/logthrdestdrv.h"
#include <MQTTClient.h>
#include <strings.h>

Include dependency graph for mqtt-destination.c:

Macros
#define	DEFAULT_MESSAGE_TEMPLATE   "$ISODATE $HOST $MSGHDR$MSG"

Functions
void	mqtt_dd_set_topic_template (LogDriver *d, LogTemplate *topic)
void	mqtt_dd_set_fallback_topic (LogDriver *d, const gchar *fallback_topic)
void	mqtt_dd_set_message_template_ref (LogDriver *d, LogTemplate *message)
LogDriver *	mqtt_dd_new (GlobalConfig *cfg)
LogTemplateOptions *	mqtt_dd_get_template_options (LogDriver *s)
gboolean	mqtt_dd_validate_topic_name (const gchar *name, GError **error)
GQuark	mqtt_topic_name_error_quark (void)
MQTTClientOptions *	mqtt_dd_get_options (LogDriver *s)

Macro Definition Documentation

DEFAULT_MESSAGE_TEMPLATE

#define DEFAULT_MESSAGE_TEMPLATE   "$ISODATE $HOST $MSGHDR$MSG"

Function Documentation

mqtt_dd_get_options()

MQTTClientOptions* mqtt_dd_get_options

(

LogDriver *

s

)

mqtt_dd_get_template_options()

LogTemplateOptions* mqtt_dd_get_template_options

(

LogDriver *

s

)

mqtt_dd_new()

LogDriver* mqtt_dd_new

(

GlobalConfig *

cfg

)

mqtt_dd_set_fallback_topic()

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

mqtt_dd_set_message_template_ref()

void mqtt_dd_set_message_template_ref	(	LogDriver *	d,
		LogTemplate *	message
	)

mqtt_dd_set_topic_template()

void mqtt_dd_set_topic_template	(	LogDriver *	d,
		LogTemplate *	topic
	)

mqtt_dd_validate_topic_name()

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

mqtt_topic_name_error_quark()

GQuark mqtt_topic_name_error_quark

(

void

)