Fledge
An open source edge computing platform for industrial users
Connection Member List

This is the complete list of members for Connection, including all inherited members.

aggregateQuery(const rapidjson::Value &payload, std::string &resultSet) (defined in Connection)Connection
aggregateQuery(const rapidjson::Value &payload, std::string &resultSet) (defined in Connection)Connection
aggregateQuery(const rapidjson::Value &payload, std::string &resultSet) (defined in Connection)Connection
appendReadings(const char *readings)Connection
appendReadings(const char *readings) (defined in Connection)Connection
appendReadings(const char *readings) (defined in Connection)Connection
Connection()Connection
Connection(ConnectionManager *manager)Connection
Connection() (defined in Connection)Connection
create_schema(const std::string &payload)Connection
create_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
create_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
create_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
createSchema(const std::string &schema)Connection
createSchema(const std::string &schema) (defined in Connection)Connection
delete_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
delete_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
delete_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
deleteRows(const std::string &table, const std::string &condition) (defined in Connection)Connection
deleteRows(const std::string &schema, const std::string &table, const std::string &condition) (defined in Connection)Connection
deleteRows(const std::string &schema, const std::string &table, const std::string &condition) (defined in Connection)Connection
fetchReadings(unsigned long id, unsigned int blksize, std::string &resultSet)Connection
fetchReadings(unsigned long id, unsigned int blksize, std::string &resultSet) (defined in Connection)Connection
fetchReadings(unsigned long id, unsigned int blksize, std::string &resultSet) (defined in Connection)Connection
findSchemaFromDB(const std::string &service, const std::string &name, std::string &resultSet)Connection
formatDate(char *formatted_date, size_t formatted_date_size, const char *date)Connectionstatic
formatDate(char *formatted_date, size_t formatted_date_size, const char *date) (defined in Connection)Connection
formatDate(char *formatted_date, size_t formatted_date_size, const char *date) (defined in Connection)Connection
get_table_snapshots(const std::string &table, std::string &resultSet) (defined in Connection)Connection
get_table_snapshots(const std::string &table, std::string &resultSet) (defined in Connection)Connection
get_table_snapshots(const std::string &table, std::string &resultSet) (defined in Connection)Connection
getDbHandle() (defined in Connection)Connectioninline
getNow(std::string &Now) (defined in Connection)Connection
getNow(std::string &Now) (defined in Connection)Connection
insert(const std::string &table, const std::string &data)Connection
insert(const std::string &schema, const std::string &table, const std::string &data)Connection
insert(const std::string &schema, const std::string &table, const std::string &data) (defined in Connection)Connection
load_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
load_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
load_table_snapshot(const std::string &table, const std::string &id) (defined in Connection)Connection
parseDatabaseStorageSchema(int &version, const std::string &res, std::unordered_map< std::string, std::unordered_set< columnRec, columnRecHasher, columnRecComparator > > &tableColumnMap, std::unordered_map< std::string, std::vector< std::string > > &tableIndexMap, bool &schemaCreationRequest)Connection
purgeOperation(const char *sql, const char *logSection, const char *phase, bool retrieve)Connection
purgeReadings(unsigned long age, unsigned int flags, unsigned long sent, std::string &results)Connection
purgeReadings(unsigned long age, unsigned int flags, unsigned long sent, std::string &results) (defined in Connection)Connection
purgeReadings(unsigned long age, unsigned int flags, unsigned long sent, std::string &results) (defined in Connection)Connection
purgeReadingsAsset(const std::string &asset) (defined in Connection)Connection
purgeReadingsAsset(const std::string &asset) (defined in Connection)Connection
purgeReadingsAsset(const std::string &asset) (defined in Connection)Connection
purgeReadingsByRows(unsigned long rowcount, unsigned int flags, unsigned long sent, std::string &results)Connection
purgeReadingsByRows(unsigned long rowcount, unsigned int flags, unsigned long sent, std::string &results) (defined in Connection)Connection
purgeReadingsByRows(unsigned long rowcount, unsigned int flags, unsigned long sent, std::string &results) (defined in Connection)Connection
readingStream(ReadingStream **readings, bool commit)Connection
readingStream(ReadingStream **readings, bool commit) (defined in Connection)Connection
retrieve(const std::string &schema, const std::string &table, const std::string &condition, std::string &resultSet) (defined in Connection)Connection
retrieve(const std::string &schema, const std::string &table, const std::string &condition, std::string &resultSet) (defined in Connection)Connection
retrieve(const std::string &schema, const std::string &table, const std::string &condition, std::string &resultSet) (defined in Connection)Connection
retrieveReadings(const std::string &condition, std::string &resultSet) (defined in Connection)Connection
retrieveReadings(const std::string &condition, std::string &resultSet) (defined in Connection)Connection
retrieveReadings(const std::string &condition, std::string &resultSet) (defined in Connection)Connection
setMaxReadingRows(long rows) (defined in Connection)Connectioninline
setPurgeBlockSize(unsigned long purgeBlockSize) (defined in Connection)Connectioninline
setTrace(bool flag)Connectioninline
setTrace(bool) (defined in Connection)Connection
setTrace(bool) (defined in Connection)Connection
setUsedDbId(int dbId)Connection
shutdownAppendReadings()Connection
supportsReadings() (defined in Connection)Connectioninline
tableSize(const std::string &table) (defined in Connection)Connection
tableSize(const std::string &table) (defined in Connection)Connection
tableSize(const std::string &table) (defined in Connection)Connection
update(const std::string &table, const std::string &data) (defined in Connection)Connection
update(const std::string &schema, const std::string &table, const std::string &data) (defined in Connection)Connection
update(const std::string &schema, const std::string &table, const std::string &data) (defined in Connection)Connection
vacuum()Connection
vacuum() (defined in Connection)Connection
~Connection()Connection
~Connection() (defined in Connection)Connection
~Connection() (defined in Connection)Connection