CatapultServer  v0.5.0.1 (Elephant)
MongoTransactionStatusStorage.h
Go to the documentation of this file.
1 
21 #pragma once
22 #include "MongoStorageContext.h"
23 #include "catapult/subscribers/TransactionStatusSubscriber.h"
24 #include <memory>
25 
26 namespace catapult { namespace mongo {
27 
29  std::unique_ptr<subscribers::TransactionStatusSubscriber> CreateMongoTransactionStatusStorage(MongoStorageContext& context);
30 }}
MapperUtils.h
m_context
MongoStorageContext & m_context
Definition: MongoTransactionStatusStorage.cpp:83
SpinLock.h
catapult::mongo::CreateMongoTransactionStatusStorage
std::unique_ptr< subscribers::TransactionStatusSubscriber > CreateMongoTransactionStatusStorage(MongoStorageContext &context)
Creates a mongodb transaction status storage around context.
Definition: MongoTransactionStatusStorage.cpp:91
catapult::Hash256
utils::ByteArray< Hash256_Size, Hash256_tag > Hash256
Definition: src/catapult/types.h:47
MongoStorageContext.h
Collection_Name
static constexpr auto Collection_Name
Definition: MongoHashLockInfoCacheStorage.cpp:30
m_database
MongoDatabase m_database
Definition: MongoTransactionStatusStorage.cpp:84
m_lock
utils::SpinLock m_lock
Definition: MongoTransactionStatusStorage.cpp:87
TransactionStatusSubscriber.h
TransactionStatus.h
MongoBulkWriter.h
catapult::mongo::plugins::ToDbModel
bsoncxx::document::value ToDbModel(const state::HashLockInfo &hashLockInfo, const Address &accountAddress)
Maps a hashLockInfo and accountAddress to the corresponding db model value.
Definition: HashLockInfoMapper.cpp:40
MongoTransactionStatusStorage.h
catapult
Definition: AddressExtractionExtension.cpp:28
catapult::mongo::MongoStorageContext
Context for creating a mongo storage.
Definition: MongoStorageContext.h:30
TransactionStatusMapper.h
catapult::mongo::mappers::ToBinary
bsoncxx::types::b_binary ToBinary(const uint8_t *pData, size_t size)
Converts raw array (pData) of size elements into bson binary type.
Definition: MapperUtils.cpp:30
m_errorPolicy
MongoErrorPolicy m_errorPolicy
Definition: MongoTransactionStatusStorage.cpp:85
m_transactionStatuses
std::vector< model::TransactionStatus > m_transactionStatuses
Definition: MongoTransactionStatusStorage.cpp:86
catapult::thread::get_all
std::vector< T > get_all(std::vector< future< T >> &&futures)
Definition: FutureUtils.h:141
catapult::utils::SpinLockGuard
std::lock_guard< SpinLock > SpinLockGuard
A spin lock guard.
Definition: SpinLock.h:60