|
| constructor (string stream, string remote, string datasource, string tablename, *hash< auto > options) |
| creates the object and assigns config info
|
|
| constructor (string stream, QorusSystemRestHelper remote, string datasource, string tablename, *hash< auto > options) |
| creates the object and assigns config info
|
|
*string | getRawSql () |
| returns any raw SQL set
|
|
*list< auto > | getRawSqlArgs () |
| returns any raw SQL bind args set
|
|
*hash< auto > | selectOptions () |
| returns any select hash<auto> options
|
|
bool | transaction () |
| returns the transaction flag
|
|
| update (string stream, string tablename, *hash< auto > options) |
| updates the configuration for a new stream
|
|
| logStreamConfigImpl (string what, string url) |
| logs the stream configuration when created
|
|
| constructor (string stream, string remote, string datasource, *string tablename, *hash< auto > options) |
| creates the object and assigns config info
|
|
| constructor (string stream, QorusSystemRestHelper remote, string datasource, *string tablename, *hash< auto > options) |
| creates the object and assigns config info
|
|
string | streamDesc () |
| returns a description of the stream for error reporting
|
|
| logStreamConfigImpl (string what, string url) |
| logs the stream configuration when created
|
|
| constructor (string stream, string remote, *hash< auto > options) |
| constructor taking a string giving the name of the remote connection for the remote server More...
|
|
| constructor (string stream, QorusSystemRestHelper remote, *hash< auto > options) |
| constructor taking an OMQ::QorusSystemRestHelper object for the remote connection More...
|
|
| logStreamConfig (string what) |
| logs the stream configuration when created
|
|
| logStreamConfigImpl (string what, string url) |
| logs the stream configuration when created
|
|
string | stream () |
| returns the stream name
|
|
string | streamDesc () |
| returns a description of the stream for error reporting
|
|
QorusSystemRestHelper | remote () |
| returns the remote connection object (see OMQ::QorusSystemRestHelper)
|
|
timeout | timeout () |
| returns the timeout value in milliseconds
|
|
int | block () |
| returns the block size
|
|
bool | suppressRemoteTimeout () |
| returns True if no "timeout" option should be sent to the remote
|
|
| update (string stream, *hash< auto > options) |
| updates the configuration for a new stream
|
|
| constructor (string datasource, *string tablename) |
| creates the object and assigns config info More...
|
|
string | datasource () |
| returns the the datasource connection name in the remote server
|
|
*string | tableName () |
| returns the table name
|
|
| update (string tablename) |
| updates the configuration for a new stream
|
|
| constructor (*hash< auto > options) |
| creates the object and assigns config info
|
|
*int | queueBlockSize () |
| returns the queue block size
|
|
int | queueTimeout () |
| returns the queue timeout in milliseconds
|
|
| update (*hash< auto > options) |
| updates options
|
|
|
bool | m_transaction = False |
| flag to start a remote transaction
|
|
*string | sql |
| raw select SQL for non-table-based selects
|
|
*list< auto > | args |
| bind args for non-table-based selects
|
|
string | m_stream |
| no public members More...
|
|
QorusSystemRestHelper | m_remote |
| real remote rest helper
|
|
timeout | m_timeout = 5m |
| timeout for rest connections
|
|
bool | m_no_remote_timeout = False |
| flag to suppress sending the timeout option to the remote
|
|
int | m_logLevel = LoggerLevel::INFO |
| default log level; default LoggerLevel::INFO
|
|
softint | m_block |
| block size
|
|
bool | clear_persistent |
| clear the persistent flag on exit
|
|
*softint | m_queue_block_size = 2 |
| data queue block size; the number of blocks to queue for sending before the main data thread will block; default: 2
|
|
timeout | m_queue_timeout = 5m |
| queue timeout; maximum amount of time a message can wait for the queue to become free; default: 5m
|
|
const | MinQueueBlockSize = 2 |
| minimum queue block size
|
|
config class for DB select streams