logproto-client.h File Reference

#include "logproto.h"
#include "persist-state.h"

Include dependency graph for logproto-client.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	LogProtoClientOptions
union	LogProtoClientOptionsStorage
struct	LogProtoClientFlowControlFuncs
struct	LogProtoClient
struct	LogProtoClientFactory

Macros
#define	LOG_PROTO_CLIENT_OPTIONS_SIZE   128
#define	DEFINE_LOG_PROTO_CLIENT(prefix, options...)
#define	LOG_PROTO_CLIENT_PLUGIN(prefix, __name)
#define	LOG_PROTO_CLIENT_PLUGIN_WITH_GRAMMAR(__parser, __name)

Typedefs
typedef char	static_assert_size_check_LogProtoClientOptions[LOG_PROTO_CLIENT_OPTIONS_SIZE >=sizeof(LogProtoClientOptions) ? 1 :-1]
typedef void(*	LogProtoClientAckCallback) (gint num_msg_acked, gpointer user_data)
typedef void(*	LogProtoClientRewindCallback) (gpointer user_data)

Functions
void	log_proto_client_options_set_drop_input (LogProtoClientOptionsStorage *options, gboolean drop_input)
void	log_proto_client_options_set_timeout (LogProtoClientOptionsStorage *options, gint timeout)
gint	log_proto_client_options_get_timeout (LogProtoClientOptionsStorage *options)
void	log_proto_client_options_defaults (LogProtoClientOptionsStorage *options)
void	log_proto_client_options_init (LogProtoClientOptionsStorage *options, GlobalConfig *cfg)
void	log_proto_client_options_destroy (LogProtoClientOptionsStorage *options)
void	log_proto_client_init (LogProtoClient *s, LogTransport *transport, const LogProtoClientOptionsStorage *options)
void	log_proto_client_free (LogProtoClient *s)
void	log_proto_client_free_method (LogProtoClient *s)
LogProtoClientFactory *	log_proto_client_get_factory (PluginContext *context, const gchar *name)

Macro Definition Documentation

DEFINE_LOG_PROTO_CLIENT

#define DEFINE_LOG_PROTO_CLIENT	(		prefix,
			options...
	)

Value:

  static gpointer                                                       \
  prefix ## _client_plugin_construct(Plugin *self)            \
  {                                                                     \
    static LogProtoClientFactory proto = {                              \
      .construct = prefix ## _client_new,                               \
      .stateful  = FALSE,                                               \
      ##options \
    };                                                                  \
    return &proto;                                                      \
  }

LOG_PROTO_CLIENT_OPTIONS_SIZE

#define LOG_PROTO_CLIENT_OPTIONS_SIZE   128

LOG_PROTO_CLIENT_PLUGIN

#define LOG_PROTO_CLIENT_PLUGIN	(		prefix,
			__name
	)

Value:

  {             \
    .type = LL_CONTEXT_CLIENT_PROTO,            \
    .name = __name,         \
    .construct = prefix ## _client_plugin_construct,  \
  }

LOG_PROTO_CLIENT_PLUGIN_WITH_GRAMMAR

#define LOG_PROTO_CLIENT_PLUGIN_WITH_GRAMMAR	(		__parser,
			__name
	)

Value:

  {             \
    .type = LL_CONTEXT_CLIENT_PROTO,            \
    .name = __name,         \
    .parser = &__parser,  \
  }

Typedef Documentation

LogProtoClientAckCallback

typedef void(* LogProtoClientAckCallback) (gint num_msg_acked, gpointer user_data)

LogProtoClientRewindCallback

typedef void(* LogProtoClientRewindCallback) (gpointer user_data)

static_assert_size_check_LogProtoClientOptions

typedef char static_assert_size_check_LogProtoClientOptions[ LOG_PROTO_CLIENT_OPTIONS_SIZE >=sizeof(LogProtoClientOptions) ? 1 :-1]

Function Documentation

log_proto_client_free()

void log_proto_client_free

(

LogProtoClient *

s

)

log_proto_client_free_method()

void log_proto_client_free_method

(

LogProtoClient *

s

)

log_proto_client_get_factory()

LogProtoClientFactory* log_proto_client_get_factory	(	PluginContext *	context,
		const gchar *	name
	)

log_proto_client_init()

void log_proto_client_init	(	LogProtoClient *	s,
		LogTransport *	transport,
		const LogProtoClientOptionsStorage *	options
	)

log_proto_client_options_defaults()

void log_proto_client_options_defaults

(

LogProtoClientOptionsStorage *

options

)

log_proto_client_options_destroy()

void log_proto_client_options_destroy

(

LogProtoClientOptionsStorage *

options

)

log_proto_client_options_get_timeout()

gint log_proto_client_options_get_timeout

(

LogProtoClientOptionsStorage *

options

)

log_proto_client_options_init()

void log_proto_client_options_init	(	LogProtoClientOptionsStorage *	options,
		GlobalConfig *	cfg
	)

log_proto_client_options_set_drop_input()

void log_proto_client_options_set_drop_input	(	LogProtoClientOptionsStorage *	options,
		gboolean	drop_input
	)

log_proto_client_options_set_timeout()

void log_proto_client_options_set_timeout	(	LogProtoClientOptionsStorage *	options,
		gint	timeout
	)