NCBI C++ ToolKit
Functions | Variables
blob_storage.cpp File Reference
#include <ncbi_pch.hpp>
#include <connect/ncbi_core_cxx.hpp>
#include <connect/ncbi_socket.hpp>
#include <objtools/pubseq_gateway/impl/cassandra/blob_storage.hpp>
#include <objtools/pubseq_gateway/impl/cassandra/lbsm_resolver.hpp>
#include <objtools/pubseq_gateway/impl/cassandra/cass_factory.hpp>
+ Include dependency graph for blob_storage.cpp:

Go to the source code of this file.

Go to the SVN repository for this file.

Functions

bool CanRetry (CCassandraException const &e, int retries)
 
vector< SSatInfoEntryReadCassandraSatInfo (string const &keyspace, string const &domain, shared_ptr< CCassConnection > connection, optional< chrono::milliseconds > timeout)
 
shared_ptr< CPSGMessagesReadCassandraMessages (string const &keyspace, string const &domain, shared_ptr< CCassConnection > connection, optional< chrono::milliseconds > timeout)
 
set< stringReadSecureSatUsers (string const &keyspace, int32_t sat, shared_ptr< CCassConnection > connection, optional< chrono::milliseconds > timeout)
 
string GetAddressString (string const &host, bool is_host)
 
template<class T >
void hash_combine (size_t &seed, const T &v)
 
size_t HashSatInfoData (vector< SSatInfoEntry > const &rows, string const &secure_registry_section, map< int32_t, set< string >> secure_users)
 
shared_ptr< CCassConnectionMakeCassConnection (shared_ptr< IRegistry const > const &registry, string const &section, string const &service, bool reset_namespace)
 
string GetServiceKey (string const &service, string const &registry_section)
 
string GetConnectionPointKey (string const &peer, int16_t port, string const &registry_section)
 

Variables

constexpr TCassConsistency kSatInfoReadConsistency {CCassConsistency::kLocalQuorum}
 
constexpr int kSatInfoReadRetry {5}
 

Function Documentation

◆ CanRetry()

bool CanRetry ( CCassandraException const e,
int  retries 
)

◆ GetAddressString()

string GetAddressString ( string const host,
bool  is_host 
)

◆ GetConnectionPointKey()

string GetConnectionPointKey ( string const peer,
int16_t  port,
string const registry_section 
)
inline

◆ GetServiceKey()

string GetServiceKey ( string const service,
string const registry_section 
)
inline

◆ hash_combine()

template<class T >
void hash_combine ( size_t &  seed,
const T v 
)
inline

Definition at line 197 of file blob_storage.cpp.

References seed.

Referenced by HashSatInfoData().

◆ HashSatInfoData()

size_t HashSatInfoData ( vector< SSatInfoEntry > const rows,
string const secure_registry_section,
map< int32_t, set< string >>  secure_users 
)

Definition at line 203 of file blob_storage.cpp.

References hash_combine(), result, and row.

Referenced by CSatInfoSchemaProvider::RefreshSchema().

◆ MakeCassConnection()

shared_ptr<CCassConnection> MakeCassConnection ( shared_ptr< IRegistry const > const registry,
string const section,
string const service,
bool  reset_namespace 
)

◆ ReadCassandraMessages()

shared_ptr<CPSGMessages> ReadCassandraMessages ( string const keyspace,
string const domain,
shared_ptr< CCassConnection connection,
optional< chrono::milliseconds >  timeout 
)

◆ ReadCassandraSatInfo()

vector<SSatInfoEntry> ReadCassandraSatInfo ( string const keyspace,
string const domain,
shared_ptr< CCassConnection connection,
optional< chrono::milliseconds >  timeout 
)

◆ ReadSecureSatUsers()

set<string> ReadSecureSatUsers ( string const keyspace,
int32_t  sat,
shared_ptr< CCassConnection connection,
optional< chrono::milliseconds >  timeout 
)

Variable Documentation

◆ kSatInfoReadConsistency

constexpr TCassConsistency kSatInfoReadConsistency {CCassConsistency::kLocalQuorum}
constexpr

◆ kSatInfoReadRetry

constexpr int kSatInfoReadRetry {5}
constexpr
Modified on Mon Jun 17 05:06:50 2024 by modify_doxy.py rev. 669887