mirrors/spdlog
1
0
Fork 0
mirror of https://github.com/gabime/spdlog.git synced 2025-01-24 06:32:06 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

clang-format mongo_sink.h

Browse Source
This commit is contained in:
Sandor Magyar 2022-10-19 10:08:54 -04:00
parent 0674e79066
commit b5d361fc21
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
include/spdlog/sinks/mongo_sink.h
View File

@ -31,15 +31,15 @@ class mongo_sink : public base_sink<Mutex>
{ {
public: public:
mongo_sink(const std::string &db_name, const std::string &collection_name, const std::string &uri = "mongodb://localhost:27017") mongo_sink(const std::string &db_name, const std::string &collection_name, const std::string &uri = "mongodb://localhost:27017")
try try : mongo_sink(std::make_shared<mongocxx::instance>(), db_name, collection_name, uri)
: mongo_sink(std::make_shared<mongocxx::instance>(), db_name, collection_name, uri)
{} {}
catch (const mongocxx::exception &e) catch (const mongocxx::exception &e)
{ {
throw_spdlog_ex(fmt_lib::format("Error opening database: {}", e.what())); throw_spdlog_ex(fmt_lib::format("Error opening database: {}", e.what()));
} }
mongo_sink(std::shared_ptr<mongocxx::instance> instance, const std::string &db_name, const std::string &collection_name, const std::string &uri = "mongodb://localhost:27017") mongo_sink(std::shared_ptr<mongocxx::instance> instance, const std::string &db_name, const std::string &collection_name,
const std::string &uri = "mongodb://localhost:27017")
: instance_(std::move(instance)) : instance_(std::move(instance))
, db_name_(db_name) , db_name_(db_name)
, coll_name_(collection_name) , coll_name_(collection_name)
@ -67,10 +67,9 @@ protected:
if (client_ != nullptr) if (client_ != nullptr)
{ {
auto doc = document{} << "timestamp" << bsoncxx::types::b_date(msg.time) auto doc = document{} << "timestamp" << bsoncxx::types::b_date(msg.time) << "level" << level::to_string_view(msg.level).data()
<< "level" << level::to_string_view(msg.level).data() << "level_num" << msg.level << "level_num" << msg.level << "message" << std::string(msg.payload.begin(), msg.payload.end())
<< "message" << std::string(msg.payload.begin(), msg.payload.end()) << "logger_name" << "logger_name" << std::string(msg.logger_name.begin(), msg.logger_name.end()) << "thread_id"
<< std::string(msg.logger_name.begin(), msg.logger_name.end()) << "thread_id"
<< static_cast<int>(msg.thread_id) << finalize; << static_cast<int>(msg.thread_id) << finalize;
client_->database(db_name_).collection(coll_name_).insert_one(doc.view()); client_->database(db_name_).collection(coll_name_).insert_one(doc.view());
} }