A pipeline element that writes to a storage service or buffer. More...

Inheritance diagram for PipelineWriter:

Collaboration diagram for PipelineWriter:

[legend]

Public Member Functions
	PipelineWriter ()
	Constructor for the pipeline writer, the element that sits at the end of every pipeline and branch.

std::string	getName ()

void	ingest (READINGSET *readingSet)
	Ingest into a pipeline writer.

bool	setup (ManagementClient mgmt, void ingest, std::map< std::string, PipelineElement * > &categories)
	Setup the pipeline writer.

bool	init (OUTPUT_HANDLE *outHandle, OUTPUT_STREAM output)
	Initialise the pipeline writer.

void	shutdown (ServiceHandler serviceHandler, ConfigHandler configHandler)
	Shutdown the pipeline writer.

bool	isReady ()
	Return if the pipeline writer is ready to receive data.

Public Member Functions inherited from PipelineElement
void	setNext (PipelineElement *next)

PipelineElement *	getNext ()

void	setService (const std::string &serviceName)

void	setStorage (StorageClient *storage)

bool	attachDebugger ()
	Attach a debugger class to the pipeline. More...

void	detachDebugger ()
	Detach a pipeline debugger from the pipeline element.

void	setDebuggerBuffer (unsigned int size)
	Setup the size of the debug buffer. More...

std::vector< std::shared_ptr< Reading > >	getDebuggerBuffer ()
	Fetch the content of the debugger buffer. More...

virtual bool	setupConfiguration (ManagementClient *, std::vector< std::string > &)

virtual bool	isFilter ()

virtual bool	isBranch ()

virtual void	reconfigure (const std::string &)

Additional Inherited Members
Static Public Member Functions inherited from PipelineElement
static void	ingest (void handle, READINGSET readings)

Protected Attributes inherited from PipelineElement
std::string	m_serviceName

PipelineElement *	m_next

StorageClient *	m_storage

PipelineDebugger *	m_debugger

Detailed Description

A pipeline element that writes to a storage service or buffer.

The documentation for this class was generated from the following files:

Public Member Functions