worker_registry.h

#ifndef RECODEX_BROKER_ROUTER_H
#define RECODEX_BROKER_ROUTER_H

#include <map>
#include <memory>
#include <queue>
#include <vector>

#include "worker.h"

class worker_registry
{
public:
    typedef std::shared_ptr<worker> worker_ptr;

private:
    std::vector<worker_ptr> workers_;

public:
    worker_registry();
    virtual void add_worker(worker_ptr worker);
    virtual void remove_worker(worker_ptr worker);
    virtual worker_ptr find_worker(const request::headers_t &headers);
    virtual worker_ptr find_worker_by_identity(const std::string &identity);
    virtual void deprioritize_worker(worker_ptr worker);
    virtual const std::vector<worker_ptr> &get_workers() const;
};

#endif // RECODEX_BROKER_ROUTER_H