md_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <vector>
#include <functional>
#include <atomic>
#include "market/market_data.hpp"
#include "base/blockingconcurrentqueue.h"
 
namespace fix40 {
 
enum class MdAdapterState {
    DISCONNECTED,   
    CONNECTING,     
    CONNECTED,      
    LOGGING_IN,     
    READY,          
    ERROR           
};
 
using StateCallback = std::function<void(MdAdapterState state, const std::string& message)>;
 
class MdAdapter {
public:
    virtual ~MdAdapter() = default;
 
    // =========================================================================
    // 生命周期管理
    // =========================================================================
 
    virtual bool start() = 0;
 
    virtual void stop() = 0;
 
    virtual bool isRunning() const = 0;
 
    virtual MdAdapterState getState() const = 0;
 
    // =========================================================================
    // 订阅管理
    // =========================================================================
 
    virtual bool subscribe(const std::vector<std::string>& instruments) = 0;
 
    virtual bool unsubscribe(const std::vector<std::string>& instruments) = 0;
 
    // =========================================================================
    // 回调设置
    // =========================================================================
 
    virtual void setStateCallback(StateCallback callback) = 0;
 
    // =========================================================================
    // 信息查询
    // =========================================================================
 
    virtual std::string getName() const = 0;
 
    virtual std::string getTradingDay() const = 0;
 
protected:
    explicit MdAdapter(moodycamel::BlockingConcurrentQueue<MarketData>& queue)
        : marketDataQueue_(queue) {}
 
    void pushMarketData(const MarketData& data) {
        marketDataQueue_.enqueue(data);
    }
 
    void pushMarketData(MarketData&& data) {
        marketDataQueue_.enqueue(std::move(data));
    }
 
    moodycamel::BlockingConcurrentQueue<MarketData>& marketDataQueue_;
};
 
} // namespace fix40