pipeline_factory.cc File Reference

#include "plugin/group_replication/include/pipeline_factory.h"
#include <stddef.h>
#include <mysql/components/services/log_builtins.h>
#include "my_dbug.h"
#include "plugin/group_replication/include/handlers/applier_handler.h"
#include "plugin/group_replication/include/handlers/certification_handler.h"
#include "plugin/group_replication/include/handlers/event_cataloger.h"

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...

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