#include "logproto-server.h"
#include "messages.h"
#include "cfg.h"
#include "plugin.h"
#include "plugin-types.h"
#include "ack-tracker/ack_tracker_factory.h"

Include dependency graph for logproto-server.c:

Functions
const guchar *	find_eom (const guchar *s, gsize n)

AckTrackerFactory *	log_proto_server_get_ack_tracker_factory (LogProtoServer *s)

gboolean	log_proto_server_is_position_tracked (LogProtoServer *s)

gboolean	log_proto_server_validate_options_method (LogProtoServer *self)

void	log_proto_server_free_method (LogProtoServer *self)

void	log_proto_server_free (LogProtoServer *self)

void	log_proto_server_init (LogProtoServer self, LogTransport transport, const LogProtoServerOptionsStorage *options)

gboolean	log_proto_server_options_set_encoding (LogProtoServerOptionsStorage self, const gchar encoding)

void	log_proto_server_options_set_ack_tracker_factory (LogProtoServerOptionsStorage self, AckTrackerFactory factory)

void	log_proto_server_options_defaults (LogProtoServerOptionsStorage *options)

void	log_proto_server_options_init (LogProtoServerOptionsStorage options, GlobalConfig cfg)

gboolean	log_proto_server_options_validate (LogProtoServerOptionsStorage *options)

void	log_proto_server_options_destroy (LogProtoServerOptionsStorage *options)

LogProtoServerFactory *	log_proto_server_get_factory (PluginContext context, const gchar name)

Function Documentation

◆ find_eom()

const guchar* find_eom	(	const guchar *	s,
		gsize	n
	)

Find the character terminating the buffer.

NOTE: when looking for the end-of-message here, it either needs to be terminated via NUL or via NL, when terminating via NL we have to make sure that there's no NUL left in the message. This function iterates over the input data and returns a pointer to the first occurrence of NL or NUL.

It uses an algorithm similar to what there's in libc memchr/strchr.

NOTE: find_eom is not static as it is used by a unit test program.

◆ log_proto_server_free()

void log_proto_server_free ( LogProtoServer * self )

◆ log_proto_server_free_method()

void log_proto_server_free_method ( LogProtoServer * self )

◆ log_proto_server_get_ack_tracker_factory()

AckTrackerFactory* log_proto_server_get_ack_tracker_factory ( LogProtoServer * s )

◆ log_proto_server_get_factory()

LogProtoServerFactory* log_proto_server_get_factory	(	PluginContext *	context,
		const gchar *	name
	)

◆ log_proto_server_init()

void log_proto_server_init	(	LogProtoServer *	self,
		LogTransport *	transport,
		const LogProtoServerOptionsStorage *	options
	)

◆ log_proto_server_is_position_tracked()

gboolean log_proto_server_is_position_tracked ( LogProtoServer * s )

◆ log_proto_server_options_defaults()

void log_proto_server_options_defaults ( LogProtoServerOptionsStorage * options )

◆ log_proto_server_options_destroy()

void log_proto_server_options_destroy ( LogProtoServerOptionsStorage * options )

◆ log_proto_server_options_init()

void log_proto_server_options_init	(	LogProtoServerOptionsStorage *	options,
		GlobalConfig *	cfg
	)

◆ log_proto_server_options_set_ack_tracker_factory()

void log_proto_server_options_set_ack_tracker_factory	(	LogProtoServerOptionsStorage *	self,
		AckTrackerFactory *	factory
	)

◆ log_proto_server_options_set_encoding()

gboolean log_proto_server_options_set_encoding	(	LogProtoServerOptionsStorage *	self,
		const gchar *	encoding
	)

◆ log_proto_server_options_validate()

gboolean log_proto_server_options_validate ( LogProtoServerOptionsStorage * options )

◆ log_proto_server_validate_options_method()

gboolean log_proto_server_validate_options_method ( LogProtoServer * self )

Functions