Qore DataProvider Module Reference 2.7.5
|
A factory class for creating DataProviderPipeline objects. More...
#include <DataProviderPipelineFactory.qc.dox.h>
Public Member Methods | |
append (AbstractDataProcessor processor) | |
Appends a data processor to the default pipeline. More... | |
append (int id, AbstractDataProcessor processor) | |
Appends a data processor to a pipeline. More... | |
int | appendQueue (int id) |
Appends a new queue to an existing pipeline and returns the new queue ID. More... | |
constructor (*hash< PipelineOptionInfo > opts) | |
Creates the object with the given options. More... | |
DataProviderPipeline | create (*hash< PipelineOptionInfo > opts) |
Creates a new DataProviderPipeline object. More... | |
hash< PipelineFactoryInfo > | getInfo () |
Returns pipeline factory info. More... | |
Private Member Methods | |
checkUpdateQueue (softstring id) | |
Checks if the given queue exists. | |
processQueue (DataProviderPipeline pipe, int id, hash< PipelineQueueInfo > queue) | |
Creates a queue in a pipeline. | |
Private Attributes | |
bool | do_bulk = True |
Bulk flag. | |
*hash< PipelineOptionInfo > | opts |
Options for the pipelines. | |
hash< string, hash< PipelineQueueInfo > > | pmap |
Hash of queues keyed by queue ID. | |
A factory class for creating DataProviderPipeline objects.
DataProvider::DataProviderPipelineFactory::append | ( | AbstractDataProcessor | processor | ) |
Appends a data processor to the default pipeline.
DataProvider::DataProviderPipelineFactory::append | ( | int | id, |
AbstractDataProcessor | processor | ||
) |
Appends a data processor to a pipeline.
id | the queue ID as returned from appendQueue() |
processor | the data processor to append to the pipeline |
PIPELINE-ERROR | invalid queue ID or the queue already terminates in additional queues |
int DataProvider::DataProviderPipelineFactory::appendQueue | ( | int | id | ) |
Appends a new queue to an existing pipeline and returns the new queue ID.
id | the queue to which the new pipeline will be appended |
PIPELINE-ERROR | the pipeline is locked, or the given queue does not exist |
DataProvider::DataProviderPipelineFactory::constructor | ( | *hash< PipelineOptionInfo > | opts | ) |
Creates the object with the given options.
opts | any options for the pipeline; see PipelineOptionInfo for more information |
DataProviderPipeline DataProvider::DataProviderPipelineFactory::create | ( | *hash< PipelineOptionInfo > | opts | ) |
Creates a new DataProviderPipeline object.
opts | override any options given in the constructor |
hash< PipelineFactoryInfo > DataProvider::DataProviderPipelineFactory::getInfo | ( | ) |
Returns pipeline factory info.