Provides filtering for the MADARA transport layer. More...

Classes
class	AESBufferFilter
	Encrypts a buffer with 256 bit AES via OpenSSL. More...

class	AggregateFilter
	Abstract base class for implementing aggregate record filters via a functor interface. More...

class	BufferFilter
	Abstract base class for implementing buffer filters via a functor interface. More...

class	BufferFilterHeader
	Defines a buffer filter header. More...

class	ClearRecords
	Filter for clearing records from a filter. More...

class	CounterFilter
	Filter for discovering neighboring peers. More...

class	DynamicPredicateFilter
	Filter for removing variables with any unwanted predicates. More...

class	DynamicPrefixFilter
	Filter for removing variables with any unwanted prefixes. More...

class	DynamicPrefixIntConvert
	Filter for integerizing variables (usually before sending) More...

class	DynamicPrefixPrint
	Filter for printing variables as they arrive and excluding prefixes that are unwanted via a user-specified MADARA StringVector container. More...

class	EndpointClear
	Filter for deleting endpoints, usually when new endpoints have been discovered. More...

class	EndpointDiscovery
	Filter for discovering remote hosts that have sent messages. More...

class	FragmentsToFilesFilter
	Receives fragments and saves them to files. More...

class	JavaBufferFilter
	Filters a buffer in Java. More...

class	LZ4BufferFilter
	Compresses with LZ4. More...

class	PeerDiscovery
	Filter for discovering neighboring peers. More...

class	PrefixIntConvert
	Filter for printing variables as they arrive and excluding prefixes that are unwanted via a user-specified MADARA StringVector container. More...

class	PrefixPrint
	Filter for printing variables as they arrive and excluding prefixes that are unwanted via a user-specified MADARA StringVector container. More...

class	RecordFilter
	Abstract base class for implementing individual record filters via a functor interface. More...

class	VariableMapFilter
	Filter for mapping variables in the KB into a filter's outgoing or incoming messages. More...

Typedefs
typedef std::list< BufferFilter * >	BufferFilters

Enumerations
enum	{ RECORD = 0 , RECORD_NAME = 1 , OPERATION_TYPE = 2 , SEND_BANDWIDTH = 3 , RECEIVED_BANDWIDTH = 4 , UPDATE_TIME = 5 , CURRENT_TIME = 6 , KNOWLEDGE_DOMAIN = 7 , ORIGINATOR = 8 , TOTAL_ARGUMENTS = 9 }

Functions
MADARA_EXPORT knowledge::KnowledgeRecord	discard (knowledge::FunctionArguments &args, knowledge::Variables &vars)
	Filter for discarding a record. More...

MADARA_EXPORT knowledge::KnowledgeRecord	discard_nonfiles (knowledge::FunctionArguments &args, knowledge::Variables &vars)
	Filter for discarding a non-file record. More...

MADARA_EXPORT knowledge::KnowledgeRecord	discard_nonprimitives (knowledge::FunctionArguments &args, knowledge::Variables &vars)
	Filter for discarding a non-primitive record. More...

MADARA_EXPORT void	log_aggregate (knowledge::KnowledgeMap &records, const transport::TransportContext &transport_context, knowledge::Variables &vars)
	Filter for logging aggregate update and context. More...

MADARA_EXPORT knowledge::KnowledgeRecord	log_args (knowledge::FunctionArguments &args, knowledge::Variables &vars)
	Filter for logging args. More...

Detailed Description

Provides filtering for the MADARA transport layer.

Typedef Documentation

◆ BufferFilters

typedef std::list<BufferFilter*> madara::filters::BufferFilters

Definition at line 65 of file BufferFilter.h.

Enumeration Type Documentation

◆ anonymous enum

anonymous enum

Enumerator
RECORD
RECORD_NAME
OPERATION_TYPE
SEND_BANDWIDTH
RECEIVED_BANDWIDTH
UPDATE_TIME
CURRENT_TIME
KNOWLEDGE_DOMAIN
ORIGINATOR
TOTAL_ARGUMENTS

Definition at line 16 of file Arguments.h.

Function Documentation

◆ discard()

madara::knowledge::KnowledgeRecord madara::filters::discard	(	knowledge::FunctionArguments &	args,
		knowledge::Variables &	vars
	)

Filter for discarding a record.

Resulting record will have a status of UNCREATED.

Parameters

args	arguments to the filter (unused)
vars	variable context (unused)

Returns: record with status set to UNCREATED

Definition at line 10 of file GenericFilters.cpp.

◆ discard_nonfiles()

madara::knowledge::KnowledgeRecord madara::filters::discard_nonfiles	(	knowledge::FunctionArguments &	args,
		knowledge::Variables &	vars
	)

Filter for discarding a non-file record.

Resulting record will have a status of UNCREATED. Files are IMAGE_JPEG, TEXT, XML, and UNKNOWN_FILE_TYPE.

Parameters

args	filter arguments (only first argument is used)
vars	variable context

Returns: record with status set to UNCREATED if arg is non-file

Alternatively, we could check type () for each defined type, but this will check that we are a file type

At the transport layer, we should check for stripped types and remove them from the list of knowledge records

Definition at line 42 of file GenericFilters.cpp.

◆ discard_nonprimitives()

madara::knowledge::KnowledgeRecord madara::filters::discard_nonprimitives	(	knowledge::FunctionArguments &	args,
		knowledge::Variables &	vars
	)

Filter for discarding a non-primitive record.

Resulting record will have a status of UNCREATED. Primitives are INTEGER, DOUBLE, STRING, INTEGER_ARRAY, and DOUBLE_ARRAY.

Parameters

args	filter arguments (only first argument is used)
vars	variable context (unused)

Returns: record with status set to UNCREATED if arg is non-primitive

Alternatively, we could check type () for each defined type, but this will check that we are not a file type

At the transport layer, we should check for stripped types and remove them from the list of knowledge records

Definition at line 17 of file GenericFilters.cpp.

◆ log_aggregate()

void madara::filters::log_aggregate	(	knowledge::KnowledgeMap &	records,
		const transport::TransportContext &	transport_context,
		knowledge::Variables &	vars
	)

Filter for logging aggregate update and context.

Parameters

records	aggregate update
transport_context	the transport context
vars	variable context

Definition at line 131 of file GenericFilters.cpp.

◆ log_args()

madara::knowledge::KnowledgeRecord madara::filters::log_args	(	knowledge::FunctionArguments &	args,
		knowledge::Variables &	vars
	)

Filter for logging args.

Parameters

args	filter arguments (only first argument is used)
vars	variable context

Returns: record with status set to UNCREATED if arg is non-file

Definition at line 67 of file GenericFilters.cpp.

Classes

Typedefs

Enumerations

Functions

Detailed Description

Typedef Documentation

◆ BufferFilters

Enumeration Type Documentation

◆ anonymous enum

Function Documentation

◆ discard()

◆ discard_nonfiles()

◆ discard_nonprimitives()

◆ log_aggregate()

◆ log_args()