abortIntern(string meth, string fmt) | OMQ::AbstractParallelReceiveStream | private |
abortInternMethod(string meth) | OMQ::AbstractParallelReceiveStream | private |
abortIo(string reason) | OMQ::AbstractParallelStream | private:internal |
abortIoWait(string reason) | OMQ::AbstractParallelStream | private:internal |
beginTransaction(OMQ::DbStreamConfig m_config) | OMQ::AbstractParallelStream | private:internal |
beginTransaction(QorusSystemRestHelper remote, string datasource, *timeout timeout_ms, *reference info) | OMQ::AbstractParallelStream | private:internalstatic |
checkComplete(string meth) | OMQ::DbRemoteReceive | private |
checkError(string cmd) | OMQ::AbstractParallelStream | private:internal |
checkStream(QorusSystemRestHelper helper, string op) | OMQ::AbstractParallelStream | private:internalstatic |
cleanup() | OMQ::AbstractParallelReceiveStream | virtual |
cleanupBase() | OMQ::AbstractParallelStream | private:internal |
cnt() | OMQ::AbstractParallelStream | private:internal |
commit() | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::commit(OMQ::DbStreamConfig m_config) | OMQ::AbstractParallelStream | private |
complete | OMQ::DbRemoteReceive | private |
config() | OMQ::DbRemoteReceive | virtual |
constructor(*hash< auto > options, DbRemoteBase remote, string sql, *list< auto > args) | OMQ::DbRemoteReceive | private |
constructor(*hash< auto > options, string remote, string datasource, string sql, *list< auto > args) | OMQ::DbRemoteReceive | private |
constructor(*hash< auto > options, QorusSystemRestHelper remote, string datasource, string sql, *list< auto > args) | OMQ::DbRemoteReceive | private |
constructor(DbRemoteBase remote, string stream, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
constructor(DbRemoteBase remote, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
constructor(string remote, string datasource, string stream, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
constructor(string remote, string datasource, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
constructor(QorusSystemRestHelper remote, string datasource, string stream, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
constructor(QorusSystemRestHelper remote, string datasource, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::constructor() | Qore::Thread::AbstractThreadResource | |
dataq | OMQ::AbstractParallelStream | private:internal |
destructor() | OMQ::AbstractParallelReceiveStream | |
disconnect() | OMQ::DbRemoteReceive | |
DO_DISCONNECT | OMQ::AbstractParallelStream | private:internal |
DONT_DISCONNECT | OMQ::AbstractParallelStream | private:internal |
getAllData(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getAllDataRows(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getData(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getDataRows(*timeout timeout_ms) | OMQ::DbRemoteReceive | |
getInfo() | OMQ::AbstractParallelStream | private:internal |
inTransaction() | OMQ::AbstractParallelStream | private:internal |
m_config | OMQ::DbRemoteReceive | private |
m_info() | OMQ::AbstractParallelStream | private:internal |
markIoComplete() | OMQ::AbstractParallelStream | private:internal |
markIoInProgress() | OMQ::AbstractParallelStream | private:internal |
objid | OMQ::AbstractParallelStream | private:internal |
openStream(string stream, string table_name, *hash< auto > options) | OMQ::DbRemoteReceive | |
recvData(auto data) | DataStreamClient::DataStreamRecvMessage | |
recvDataDone(*string err) | DataStreamClient::DataStreamRecvMessage | |
recvDataDoneImpl(*string err) | OMQ::DbRemoteReceive | private |
recvDataImpl(auto rdata) | OMQ::DbRemoteReceive | privatevirtual |
rollback(bool action=DO_DISCONNECT) | OMQ::DbRemoteReceive | |
OMQ::AbstractParallelReceiveStream::rollback(OMQ::DbStreamConfig m_config) | OMQ::AbstractParallelStream | private |
socketThread(*ThreadLocalData my_tld) | OMQ::AbstractParallelStream | private:internal |
socketThreadImpl() | OMQ::DbRemoteReceive | privatevirtual |
startStream() | OMQ::AbstractParallelStream | private:internal |
startStreamImpl() | OMQ::DbRemoteReceive | privatevirtual |
staticCleanup() | OMQ::AbstractParallelStream | private:internalstatic |
StreamTerminatedError | OMQ::AbstractParallelStream | private:internal |
thread_ex | OMQ::AbstractParallelStream | private:internal |
ThreadKey | OMQ::AbstractParallelStream | private:internal |
throwAbortedExceptionImpl(string meth) | OMQ::DbRemoteReceive | privatevirtual |
waitIoComplete() | OMQ::AbstractParallelStream | private:internal |