public:

static Sink& GetInstance();

/**

bool setPathPrefix(const std::string &path_prefix);

//! 设置是否开启实时落盘

void setFileSyncEnable(bool is_enable);

bool isFileSyncEnabled() const { return is_file_sync_enabled_; }

//! 获取目录路径

std::string getDirPath() const { return dir_path_; }

//! 获取当前记录文件名

std::string getCurrRecordFilename() const { return curr_record_filename_; }

//! 设置记录文件的大小的上限

void setRecordFileMaxSize(size_t max_size) { record_file_max_size_ = max_size; }

size_t getRecordFileMaxSize() const { return record_file_max_size_; }

bool enable(); //! 使能

void disable(); //! 停止

bool isEnabled() const { return is_enabled_; }

//! 过滤策略

enum class FilterStrategy {

kPermit, //! 允许

kReject, //! 拒绝

};

using ExemptSet = std::set<std::string>;

//! 设置与获取过滤策略，默认允许或是拒绝

void setFilterStrategy(FilterStrategy strategy) { filter_strategy_ = strategy; }

FilterStrategy getFilterStrategy() const { return filter_strategy_; }

//! 设置与获取豁免集合

void setFilterExemptSet(const ExemptSet &exempt_set);

ExemptSet getFilterExemptSet() const;

/**

void commitRecord(const char *name, const char *module, uint32_t line, uint64_t end_timepoint_us, uint64_t duration_us);

protected:

~Sink();

struct RecordHeader {

long thread_id;

uint64_t end_ts_us;

uint64_t duration_us;

uint32_t line;

size_t name_size;

size_t module_size;

};

using Index = uint64_t;

void onBackendRecvData(const void *data, size_t size);

void onBackendRecvRecord(const RecordHeader &record, const char *name, const char *module,

std::vector<uint8_t> &write_cache);

bool checkAndWriteNames();

bool checkAndWriteModules();

bool checkAndWriteThreads();

bool checkAndCreateRecordFile();

bool isFilterPassed(const std::string &module) const;

Index allocNameIndex(const std::string &name, uint32_t line);

Index allocModuleIndex(const std::string &module);

Index allocThreadIndex(long thread_id);

private:

std::string dir_path_;

size_t record_file_max_size_ = std::numeric_limits<size_t>::max();

std::string name_list_filename_;

std::string module_list_filename_;

std::string thread_list_filename_;

bool is_file_sync_enabled_ = false;

std::atomic_bool is_enabled_{false};

util::AsyncPipe async_pipe_;

//! 下面的成员变量，由后端线程读写

util::Buffer buffer_;

std::string curr_record_filename_; //! 当前记录文件的全名

int curr_record_fd_ = -1; //! 当前记录文件描述符

size_t total_write_size_ = 0; //! 当前记录文件已写入数据量

uint64_t last_timepoint_us_ = 0; //! 当前记录文件的上一条记录的时间戳(us)

//! 名称编码

std::map<std::string, Index> name_to_index_map_;

uint32_t next_name_index_ = 0;

//! 模块编码

std::map<std::string, Index> module_to_index_map_;

uint32_t next_module_index_ = 0;

//! 线程号编码

std::map<long, Index> thread_to_index_map_;

int next_thread_index_ = 0;

//! 过滤相关变量

mutable std::mutex lock_;

FilterStrategy filter_strategy_ = FilterStrategy::kPermit; //! 默认允许

ExemptSet filter_exempt_set_;