DataProviderPipelineFactory.qc.dox.h

// -*- mode: c++; indent-tabs-mode: nil -*-
 
// assume local scope for variables, do not use "$" signs
// require type definitions everywhere
// enable all warnings
// allow weak references
 
namespace DataProvider {
public hashdecl PipelineFactoryInfo {
    *hash<auto> opts;
 
    int num_queues;
 
    bool bulk;
};
 
hashdecl PipelineQueueInfo {
    int id;
 
    #! Queue elements; either AbstractDataProcessor objects or a list of PipelineQueueInfo hashes
    list<auto> elems();
 
    #! Maximum queue size
    int size;
};
 
 
class DataProviderPipelineFactory {
 
public:
    
 
protected:
        *hash<PipelineOptionInfo> opts;
 
        hash<string, hash<PipelineQueueInfo>> pmap;
 
        bool do_bulk = True;
 
public:
 
 
    constructor(*hash<PipelineOptionInfo> opts);
 
 
 
    hash<PipelineFactoryInfo> getInfo();
 
 
 
    DataProviderPipeline create(*hash<PipelineOptionInfo> opts);
 
 
 
    append(AbstractDataProcessor processor);
 
 
 
    append(int id, AbstractDataProcessor processor);
 
 
 
    int appendQueue(int id);
 
 
protected:
     checkUpdateQueue(softstring id);
public:
 
 
protected:
     processQueue(DataProviderPipeline pipe, int id, hash<PipelineQueueInfo> queue);
public:
 
};
};