pipeline_factory.h File Reference

#include "plugin/group_replication/include/pipeline_interfaces.h"

Go to the source code of this file.

Enumerations
enum	Handler_id { CERTIFICATION_HANDLER , SQL_THREAD_APPLICATION_HANDLER , CATALOGING_HANDLER }
	Enumeration type for the different types of handlers. More...
enum	Handler_pipeline_type { STANDARD_GROUP_REPLICATION_PIPELINE = 0 }

Functions
int	get_pipeline (Handler_pipeline_type pipeline_type, Event_handler **pipeline)
	This method joins the two above method, assembling a pipeline accordingly with the given configuration. More...
int	get_pipeline_configuration (Handler_pipeline_type pipeline_type, Handler_id **pipeline_conf)
	This method returns the configured handlers for the received pipeline. More...
int	configure_pipeline (Event_handler **pipeline, Handler_id handler_list[], int num_handlers)
	This method configures the pipeline accordingly to the received handlers. More...

Enumeration Type Documentation

Handler_id

enum Handler_id

Enumeration type for the different types of handlers.

Enumerator
CERTIFICATION_HANDLER
SQL_THREAD_APPLICATION_HANDLER
CATALOGING_HANDLER

Handler_pipeline_type

enum Handler_pipeline_type

Enumerator
STANDARD_GROUP_REPLICATION_PIPELINE

Function Documentation

configure_pipeline()

int configure_pipeline	(	Event_handler **	pipeline,
		Handler_id	handler_list[],
		int	num_handlers
	)

This method configures the pipeline accordingly to the received handlers.

Taking the received handlers, this method initializes each one of them, appending them to the pipeline. It also checks the handler role, checking for duplicated handlers that were marked as being unique.

Parameters

[out]	pipeline	the pipeline to configure
[in]	handler_list	the list of handler ids
[in]	num_handlers	the number of handlers to configure

Returns

the end status

Return values

0	OK
!=0	Error returned on the execution

get_pipeline()

int get_pipeline	(	Handler_pipeline_type	pipeline_type,
		Event_handler **	pipeline
	)

This method joins the two above method, assembling a pipeline accordingly with the given configuration.

Parameters

[in]	pipeline_type	the selected pipeline
[out]	pipeline	the assembled pipeline

Returns

the end status

Return values

0	OK
!=0	Error returned on the execution

get_pipeline_configuration()

int get_pipeline_configuration	(	Handler_pipeline_type	pipeline_type,
		Handler_id **	pipeline_conf
	)

This method returns the configured handlers for the received pipeline.

Parameters

[in]	pipeline_type	the selected pipeline
[out]	pipeline_conf	the returned list of handler ids

Returns

the number of handlers in the pipeline