logqueue.h File Reference

#include "logmsg/logmsg.h"
#include "stats/stats-registry.h"
#include "stats/stats-cluster-key-builder.h"

Include dependency graph for logqueue.h:

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

Go to the source code of this file.

Classes
struct	LogQueueMetrics
struct	LogQueue

Typedefs
typedef void(*	LogQueuePushNotifyFunc) (gpointer user_data)
typedef const char *	QueueType

Functions
void	log_queue_memory_usage_add (LogQueue *self, gsize value)
void	log_queue_memory_usage_sub (LogQueue *self, gsize value)
void	log_queue_queued_messages_add (LogQueue *self, gsize value)
void	log_queue_queued_messages_sub (LogQueue *self, gsize value)
void	log_queue_queued_messages_inc (LogQueue *self)
void	log_queue_queued_messages_dec (LogQueue *self)
void	log_queue_queued_messages_reset (LogQueue *self)
void	log_queue_dropped_messages_inc (LogQueue *self)
void	log_queue_push_notify (LogQueue *self)
void	log_queue_reset_parallel_push (LogQueue *self)
void	log_queue_set_parallel_push (LogQueue *self, LogQueuePushNotifyFunc parallel_push_notify, gpointer user_data, GDestroyNotify user_data_destroy)
gboolean	log_queue_check_items (LogQueue *self, gint *timeout, LogQueuePushNotifyFunc parallel_push_notify, gpointer user_data, GDestroyNotify user_data_destroy)
void	log_queue_mark_as_abandoned (LogQueue *self)
void	log_queue_init_instance (LogQueue *self, const gchar *persist_name, gint stats_level, StatsClusterKeyBuilder *driver_sck_builder, StatsClusterKeyBuilder *queue_sck_builder)
void	log_queue_free_method (LogQueue *self)

Typedef Documentation

LogQueuePushNotifyFunc

typedef void(* LogQueuePushNotifyFunc) (gpointer user_data)

QueueType

typedef const char* QueueType

Function Documentation

log_queue_check_items()

gboolean log_queue_check_items	(	LogQueue *	self,
		gint *	timeout,
		LogQueuePushNotifyFunc	parallel_push_notify,
		gpointer	user_data,
		GDestroyNotify	user_data_destroy
	)

log_queue_dropped_messages_inc()

void log_queue_dropped_messages_inc

(

LogQueue *

self

)

log_queue_free_method()

void log_queue_free_method

(

LogQueue *

self

)

log_queue_init_instance()

void log_queue_init_instance	(	LogQueue *	self,
		const gchar *	persist_name,
		gint	stats_level,
		StatsClusterKeyBuilder *	driver_sck_builder,
		StatsClusterKeyBuilder *	queue_sck_builder
	)

log_queue_mark_as_abandoned()

void log_queue_mark_as_abandoned ( LogQueue *  self )

inline

log_queue_memory_usage_add()

void log_queue_memory_usage_add	(	LogQueue *	self,
		gsize	value
	)

log_queue_memory_usage_sub()

void log_queue_memory_usage_sub	(	LogQueue *	self,
		gsize	value
	)

log_queue_push_notify()

void log_queue_push_notify

(

LogQueue *

self

)

log_queue_queued_messages_add()

void log_queue_queued_messages_add	(	LogQueue *	self,
		gsize	value
	)

log_queue_queued_messages_dec()

void log_queue_queued_messages_dec

(

LogQueue *

self

)

log_queue_queued_messages_inc()

void log_queue_queued_messages_inc

(

LogQueue *

self

)

log_queue_queued_messages_reset()

void log_queue_queued_messages_reset

(

LogQueue *

self

)

log_queue_queued_messages_sub()

void log_queue_queued_messages_sub	(	LogQueue *	self,
		gsize	value
	)

log_queue_reset_parallel_push()

void log_queue_reset_parallel_push

(

LogQueue *

self

)

log_queue_set_parallel_push()

void log_queue_set_parallel_push	(	LogQueue *	self,
		LogQueuePushNotifyFunc	parallel_push_notify,
		gpointer	user_data,
		GDestroyNotify	user_data_destroy
	)