afmongodb.c File Reference

#include "afmongodb.h"
#include "afmongodb-parser.h"
#include "afmongodb-worker.h"
#include "apphook.h"
#include "messages.h"
#include "stats/stats-registry.h"
#include "plugin.h"
#include "plugin-types.h"
#include "syslog-ng.h"
#include <time.h>
#include "afmongodb-private.h"

Include dependency graph for afmongodb.c:

Macros
#define	DEFAULT_URI
#define	DEFAULT_SERVER_SELECTION_TIMEOUT   3000

Functions
LogTemplateOptions *	afmongodb_dd_get_template_options (LogDriver *s)
void	afmongodb_dd_set_uri (LogDriver *d, const gchar *uri)
void	afmongodb_dd_set_collection (LogDriver *d, LogTemplate *collection_template)
void	afmongodb_dd_set_value_pairs (LogDriver *d, ValuePairs *vp)
void	afmongodb_dd_set_bulk (LogDriver *d, gboolean bulk)
void	afmongodb_dd_set_bulk_unordered (LogDriver *d, gboolean unordered)
void	afmongodb_dd_set_bulk_bypass_validation (LogDriver *d, gboolean bypass_validation)
void	afmongodb_dd_set_write_concern (LogDriver *d, int32_t write_concern_level)
gboolean	afmongodb_dd_private_uri_init (LogDriver *d)
gboolean	afmongodb_dd_client_pool_init (MongoDBDestDriver *self)
LogDriver *	afmongodb_dd_new (GlobalConfig *cfg)
gboolean	afmongodb_module_init (PluginContext *context, CfgArgs *args)

Variables
CfgParser	afmongodb_dd_parser
const ModuleInfo	module_info

Macro Definition Documentation

DEFAULT_SERVER_SELECTION_TIMEOUT

#define DEFAULT_SERVER_SELECTION_TIMEOUT   3000

DEFAULT_URI

#define DEFAULT_URI

Value:

      "mongodb://127.0.0.1:27017/syslog"\
      "?wtimeoutMS=60000&socketTimeoutMS=60000&connectTimeoutMS=60000"

Function Documentation

afmongodb_dd_client_pool_init()

gboolean afmongodb_dd_client_pool_init

(

MongoDBDestDriver *

self

)

afmongodb_dd_get_template_options()

LogTemplateOptions* afmongodb_dd_get_template_options

(

LogDriver *

s

)

afmongodb_dd_new()

LogDriver* afmongodb_dd_new

(

GlobalConfig *

cfg

)

afmongodb_dd_private_uri_init()

gboolean afmongodb_dd_private_uri_init

(

LogDriver *

d

)

afmongodb_dd_set_bulk()

void afmongodb_dd_set_bulk	(	LogDriver *	d,
		gboolean	bulk
	)

afmongodb_dd_set_bulk_bypass_validation()

void afmongodb_dd_set_bulk_bypass_validation	(	LogDriver *	d,
		gboolean	bypass_validation
	)

afmongodb_dd_set_bulk_unordered()

void afmongodb_dd_set_bulk_unordered	(	LogDriver *	d,
		gboolean	unordered
	)

afmongodb_dd_set_collection()

void afmongodb_dd_set_collection	(	LogDriver *	d,
		LogTemplate *	collection_template
	)

afmongodb_dd_set_uri()

void afmongodb_dd_set_uri	(	LogDriver *	d,
		const gchar *	uri
	)

afmongodb_dd_set_value_pairs()

void afmongodb_dd_set_value_pairs	(	LogDriver *	d,
		ValuePairs *	vp
	)

afmongodb_dd_set_write_concern()

void afmongodb_dd_set_write_concern	(	LogDriver *	d,
		int32_t	write_concern_level
	)

afmongodb_module_init()

gboolean afmongodb_module_init	(	PluginContext *	context,
		CfgArgs *	args
	)

Variable Documentation

afmongodb_dd_parser

CfgParser afmongodb_dd_parser

extern

module_info

const ModuleInfo module_info

Initial value:

=
{
  .canonical_name = "afmongodb",
  .version = SYSLOG_NG_VERSION,
  .description = "The afmongodb module provides MongoDB destination support for syslog-ng.",
  .core_revision = SYSLOG_NG_SOURCE_REVISION,
  .plugins = &afmongodb_plugin,
  .plugins_len = 1,
}