afamqp.c File Reference

#include "afamqp.h"
#include "syslog-ng.h"
#include "messages.h"
#include "stats/stats-registry.h"
#include "logmsg/nvtable.h"
#include "logqueue.h"
#include "scratch-buffers.h"
#include "logthrdest/logthrdestdrv.h"
#include "timeutils/misc.h"
#include "compat/amqp-compat.h"
#include <amqp.h>
#include <amqp_framing.h>
#include <amqp_tcp_socket.h>
#include <amqp_ssl_socket.h>

Include dependency graph for afamqp.c:

Classes
struct	AMQPDestDriver

Functions
gboolean	afamqp_dd_set_auth_method (LogDriver *d, const gchar *auth_method)
void	afamqp_dd_set_user (LogDriver *d, const gchar *user)
void	afamqp_dd_set_password (LogDriver *d, const gchar *password)
void	afamqp_dd_set_vhost (LogDriver *d, const gchar *vhost)
void	afamqp_dd_set_host (LogDriver *d, const gchar *host)
void	afamqp_dd_set_port (LogDriver *d, gint port)
void	afamqp_dd_set_exchange (LogDriver *d, const gchar *exchange)
void	afamqp_dd_set_exchange_declare (LogDriver *d, gboolean declare)
void	afamqp_dd_set_exchange_type (LogDriver *d, const gchar *exchange_type)
void	afamqp_dd_set_routing_key (LogDriver *d, LogTemplate *routing_key_template)
void	afamqp_dd_set_body (LogDriver *d, LogTemplate *body_template)
void	afamqp_dd_set_persistent (LogDriver *s, gboolean persistent)
void	afamqp_dd_set_value_pairs (LogDriver *d, ValuePairs *vp)
LogTemplateOptions *	afamqp_dd_get_template_options (LogDriver *s)
void	afamqp_dd_set_ca_file (LogDriver *d, const gchar *cacrt)
void	afamqp_dd_set_key_file (LogDriver *d, const gchar *key)
void	afamqp_dd_set_cert_file (LogDriver *d, const gchar *usercrt)
void	afamqp_dd_set_peer_verify (LogDriver *d, gboolean verify)
void	afamqp_dd_set_max_channel (LogDriver *d, gint max_channel)
void	afamqp_dd_set_frame_size (LogDriver *d, gint frame_size)
void	afamqp_dd_set_offered_heartbeat (LogDriver *d, gint offered_heartbeat)
LogDriver *	afamqp_dd_new (GlobalConfig *cfg)

Function Documentation

afamqp_dd_get_template_options()

LogTemplateOptions* afamqp_dd_get_template_options

(

LogDriver *

s

)

afamqp_dd_new()

LogDriver* afamqp_dd_new

(

GlobalConfig *

cfg

)

afamqp_dd_set_auth_method()

gboolean afamqp_dd_set_auth_method	(	LogDriver *	d,
		const gchar *	auth_method
	)

afamqp_dd_set_body()

void afamqp_dd_set_body	(	LogDriver *	d,
		LogTemplate *	body_template
	)

afamqp_dd_set_ca_file()

void afamqp_dd_set_ca_file	(	LogDriver *	d,
		const gchar *	cacrt
	)

afamqp_dd_set_cert_file()

void afamqp_dd_set_cert_file	(	LogDriver *	d,
		const gchar *	usercrt
	)

afamqp_dd_set_exchange()

void afamqp_dd_set_exchange	(	LogDriver *	d,
		const gchar *	exchange
	)

afamqp_dd_set_exchange_declare()

void afamqp_dd_set_exchange_declare	(	LogDriver *	d,
		gboolean	declare
	)

afamqp_dd_set_exchange_type()

void afamqp_dd_set_exchange_type	(	LogDriver *	d,
		const gchar *	exchange_type
	)

afamqp_dd_set_frame_size()

void afamqp_dd_set_frame_size	(	LogDriver *	d,
		gint	frame_size
	)

afamqp_dd_set_host()

void afamqp_dd_set_host	(	LogDriver *	d,
		const gchar *	host
	)

afamqp_dd_set_key_file()

void afamqp_dd_set_key_file	(	LogDriver *	d,
		const gchar *	key
	)

afamqp_dd_set_max_channel()

void afamqp_dd_set_max_channel	(	LogDriver *	d,
		gint	max_channel
	)

afamqp_dd_set_offered_heartbeat()

void afamqp_dd_set_offered_heartbeat	(	LogDriver *	d,
		gint	offered_heartbeat
	)

afamqp_dd_set_password()

void afamqp_dd_set_password	(	LogDriver *	d,
		const gchar *	password
	)

afamqp_dd_set_peer_verify()

void afamqp_dd_set_peer_verify	(	LogDriver *	d,
		gboolean	verify
	)

afamqp_dd_set_persistent()

void afamqp_dd_set_persistent	(	LogDriver *	s,
		gboolean	persistent
	)

afamqp_dd_set_port()

void afamqp_dd_set_port	(	LogDriver *	d,
		gint	port
	)

afamqp_dd_set_routing_key()

void afamqp_dd_set_routing_key	(	LogDriver *	d,
		LogTemplate *	routing_key_template
	)

afamqp_dd_set_user()

void afamqp_dd_set_user	(	LogDriver *	d,
		const gchar *	user
	)

afamqp_dd_set_value_pairs()

void afamqp_dd_set_value_pairs	(	LogDriver *	d,
		ValuePairs *	vp
	)

afamqp_dd_set_vhost()

void afamqp_dd_set_vhost	(	LogDriver *	d,
		const gchar *	vhost
	)