logqueue-disk.h File Reference

#include "logmsg/logmsg.h"
#include "logqueue.h"
#include "qdisk.h"
#include "logmsg/logmsg-serialize.h"

Include dependency graph for logqueue-disk.h:

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

Go to the source code of this file.

Classes
struct	LogQueueDisk

Functions
const gchar *	log_queue_disk_get_filename (LogQueue *self)
gboolean	log_queue_disk_stop (LogQueue *self, gboolean *persistent)
gboolean	log_queue_disk_start (LogQueue *self)
void	log_queue_disk_init_instance (LogQueueDisk *self, DiskQueueOptions *options, const gchar *qdisk_file_id, const gchar *filename, const gchar *persist_name, gint stats_level, StatsClusterKeyBuilder *driver_sck_builder, StatsClusterKeyBuilder *queue_sck_builder)
void	log_queue_disk_restart_corrupted (LogQueueDisk *self)
void	log_queue_disk_free_method (LogQueueDisk *self)
void	log_queue_disk_update_disk_related_counters (LogQueueDisk *self)
LogMessage *	log_queue_disk_read_message (LogQueueDisk *self, LogPathOptions *path_options)
LogMessage *	log_queue_disk_peek_message (LogQueueDisk *self)
void	log_queue_disk_drop_message (LogQueueDisk *self, LogMessage *msg, const LogPathOptions *path_options)
gboolean	log_queue_disk_serialize_msg (LogQueueDisk *self, LogMessage *msg, GString *serialized)
gboolean	log_queue_disk_deserialize_msg (LogQueueDisk *self, GString *serialized, LogMessage **msg)

Variables
QueueType	log_queue_disk_type

Function Documentation

log_queue_disk_deserialize_msg()

gboolean log_queue_disk_deserialize_msg	(	LogQueueDisk *	self,
		GString *	serialized,
		LogMessage **	msg
	)

log_queue_disk_drop_message()

void log_queue_disk_drop_message	(	LogQueueDisk *	self,
		LogMessage *	msg,
		const LogPathOptions *	path_options
	)

log_queue_disk_free_method()

void log_queue_disk_free_method

(

LogQueueDisk *

self

)

log_queue_disk_get_filename()

const gchar* log_queue_disk_get_filename

(

LogQueue *

self

)

log_queue_disk_init_instance()

void log_queue_disk_init_instance	(	LogQueueDisk *	self,
		DiskQueueOptions *	options,
		const gchar *	qdisk_file_id,
		const gchar *	filename,
		const gchar *	persist_name,
		gint	stats_level,
		StatsClusterKeyBuilder *	driver_sck_builder,
		StatsClusterKeyBuilder *	queue_sck_builder
	)

log_queue_disk_peek_message()

LogMessage* log_queue_disk_peek_message

(

LogQueueDisk *

self

)

log_queue_disk_read_message()

LogMessage* log_queue_disk_read_message	(	LogQueueDisk *	self,
		LogPathOptions *	path_options
	)

log_queue_disk_restart_corrupted()

void log_queue_disk_restart_corrupted

(

LogQueueDisk *

self

)

log_queue_disk_serialize_msg()

gboolean log_queue_disk_serialize_msg	(	LogQueueDisk *	self,
		LogMessage *	msg,
		GString *	serialized
	)

log_queue_disk_start()

gboolean log_queue_disk_start

(

LogQueue *

self

)

log_queue_disk_stop()

gboolean log_queue_disk_stop	(	LogQueue *	self,
		gboolean *	persistent
	)

log_queue_disk_update_disk_related_counters()

void log_queue_disk_update_disk_related_counters

(

LogQueueDisk *

self

)

Variable Documentation

log_queue_disk_type

QueueType log_queue_disk_type

extern