grouping-parser.c File Reference

#include "grouping-parser.h"
#include "scratch-buffers.h"
#include "str-utils.h"

Include dependency graph for grouping-parser.c:

Functions
void	grouping_parser_set_key_template (LogParser *s, LogTemplate *key_template)
void	grouping_parser_set_sort_key_template (LogParser *s, LogTemplate *sort_key)
void	grouping_parser_set_scope (LogParser *s, CorrelationScope scope)
void	grouping_parser_set_timeout (LogParser *s, gint timeout)
void	grouping_parser_clone_settings (GroupingParser *self, GroupingParser *cloned)
void	_advance_time_based_on_message (GroupingParser *self, const UnixTime *ls, StatefulParserEmittedMessages *emitted_messages)
LogMessage *	grouping_parser_aggregate_context (GroupingParser *self, CorrelationContext *context)
CorrelationContext *	grouping_parser_lookup_or_create_context (GroupingParser *self, LogMessage *msg)
void	grouping_parser_perform_grouping (GroupingParser *self, LogMessage *msg, StatefulParserEmittedMessages *emitted_messages)
gboolean	grouping_parser_process_method (LogParser *s, LogMessage **pmsg, const LogPathOptions *path_options, const char *input, gsize input_len)
gboolean	grouping_parser_init_method (LogPipe *s)
gboolean	grouping_parser_deinit_method (LogPipe *s)
void	grouping_parser_free_method (LogPipe *s)
void	grouping_parser_init_instance (GroupingParser *self, GlobalConfig *cfg)
void	grouping_parser_global_init (void)

Function Documentation

_advance_time_based_on_message()

void _advance_time_based_on_message	(	GroupingParser *	self,
		const UnixTime *	ls,
		StatefulParserEmittedMessages *	emitted_messages
	)

grouping_parser_aggregate_context()

LogMessage* grouping_parser_aggregate_context	(	GroupingParser *	self,
		CorrelationContext *	context
	)

grouping_parser_clone_settings()

void grouping_parser_clone_settings	(	GroupingParser *	self,
		GroupingParser *	cloned
	)

grouping_parser_deinit_method()

gboolean grouping_parser_deinit_method

(

LogPipe *

s

)

grouping_parser_free_method()

void grouping_parser_free_method

(

LogPipe *

s

)

grouping_parser_global_init()

void grouping_parser_global_init

(

void

)

grouping_parser_init_instance()

void grouping_parser_init_instance	(	GroupingParser *	self,
		GlobalConfig *	cfg
	)

grouping_parser_init_method()

gboolean grouping_parser_init_method

(

LogPipe *

s

)

grouping_parser_lookup_or_create_context()

CorrelationContext* grouping_parser_lookup_or_create_context	(	GroupingParser *	self,
		LogMessage *	msg
	)

grouping_parser_perform_grouping()

void grouping_parser_perform_grouping	(	GroupingParser *	self,
		LogMessage *	msg,
		StatefulParserEmittedMessages *	emitted_messages
	)

grouping_parser_process_method()

gboolean grouping_parser_process_method	(	LogParser *	s,
		LogMessage **	pmsg,
		const LogPathOptions *	path_options,
		const char *	input,
		gsize	input_len
	)

grouping_parser_set_key_template()

void grouping_parser_set_key_template	(	LogParser *	s,
		LogTemplate *	key_template
	)

grouping_parser_set_scope()

void grouping_parser_set_scope	(	LogParser *	s,
		CorrelationScope	scope
	)

grouping_parser_set_sort_key_template()

void grouping_parser_set_sort_key_template	(	LogParser *	s,
		LogTemplate *	sort_key
	)

grouping_parser_set_timeout()

void grouping_parser_set_timeout	(	LogParser *	s,
		gint	timeout
	)