ah_md_spi_inl.h

/*************************************************************************
  > File Name: ah_md_spi_inl.h
  > Author: leaker
  > Mail: xiao13149920@foxmail.com
  > Created Time: Mon 21 Dec 2020 09:49:35 AM CST
 ************************************************************************/

#ifndef __AH_MD_SPI_INL_H__
#define __AH_MD_SPI_INL_H__

#include <memory>
#include <string>

#include "annhoo_md_sdk/ah_md_common.h"
#include "annhoo_md_sdk/ah_md_spi.h"

// #ifdef TEST_VEAHION
#define SECONDS 1
#define USECONDS 100
#define BULKSIZE 100
// #endif

namespace annhoo {
class AHMdSpiInl : public IAHMdSpi {
public:
    AHMdSpiInl(const std::string& index_filename,
               // const std::string& entrust,
               // const std::string& trade,
               const std::string& tick_filename, const std::string& snap_shot_filename, const char* delimiter = ", ",
               const char* suffix = "\n");
    virtual ~AHMdSpiInl();

    AHMdSpiInl(const AHMdSpiInl& r) = delete;
    AHMdSpiInl(AHMdSpiInl&& r) = delete;
    AHMdSpiInl& operator=(const AHMdSpiInl& r) = delete;
    AHMdSpiInl& operator=(AHMdSpiInl&& r) = delete;

public:
    virtual void OnIndexCB(AHIndex* index) override;
    virtual void OnTickCB(AHTick* tick, uint16_t type) override;
    virtual void OnSnapshotCB(AHSnapshot* snap_shot) override;

private:
    int         index_fd;
    int         snapshot_fd;
    std::string delimiter;
    std::string suffix;
};
} // namespace annhoo

#endif