Streaming C++ API
sb::StreamBaseClient Member List

This is the complete list of members for sb::StreamBaseClient, including all inherited members.

ALL_CONTAINERS enum valuesb::StreamBaseClient
canDequeue()sb::StreamBaseClient
close()sb::StreamBaseClient
DEFAULT_FLUSH_INTERVAL (defined in sb::StreamBaseClient)sb::StreamBaseClientstatic
dequeue(StreamProperties &streamProperties)sb::StreamBaseClient
dequeue(std::string &stream_name)sb::StreamBaseClient
dequeue()sb::StreamBaseClient
dequeue(int timeout_ms)sb::StreamBaseClient
describe(const std::string &entity)sb::StreamBaseClient
enableBuffering(int buffer_size, int flush_interval=DEFAULT_FLUSH_INTERVAL)sb::StreamBaseClient
enableHeartbeating()sb::StreamBaseClient
enqueue(const std::string &stream_name, Tuple &tuple)sb::StreamBaseClient
enqueue(const StreamProperties &props, Tuple &tuple)sb::StreamBaseClient
enqueue(const std::string &stream_name, TupleList &tuples)sb::StreamBaseClient
enqueue(const StreamProperties &props, TupleList &tuples)sb::StreamBaseClient
flushAllBuffers()sb::StreamBaseClient
flushBuffer(const StreamProperties &props)sb::StreamBaseClient
flushBuffer(const std::string &stream_name)sb::StreamBaseClient
FULLY_QUALIFIED_NAMES enum valuesb::StreamBaseClient
getBufferSize() constsb::StreamBaseClient
getConnectionID() constsb::StreamBaseClient
getConnectionIdAsHexString() constsb::StreamBaseClient
getDequeueResultsInterceptor()sb::StreamBaseClient
getDynamicVariables(const std::string &modulePath)sb::StreamBaseClient
getIsBuffering() constsb::StreamBaseClient
getSchemaByHash(const std::string &hash)sb::StreamBaseClient
getSchemaByName(const std::string &name)sb::StreamBaseClient
getSchemaForStream(const std::string &entity, StreamProperties::CaptureTransformStrategy strategy=StreamProperties::FLATTEN)sb::StreamBaseClient
getSettings()sb::StreamBaseClientinline
getStreamProperties(const std::string &entity, StreamProperties::CaptureTransformStrategy strategy=StreamProperties::FLATTEN)sb::StreamBaseClient
getStreamPropertiesByHash(const std::string &hex)sb::StreamBaseClient
getTupleDequeueCount() constsb::StreamBaseClient
getTupleEnqueueCount() constsb::StreamBaseClient
getURI() constsb::StreamBaseClient
getURIs() const (defined in sb::StreamBaseClient)sb::StreamBaseClient
getVersion()sb::StreamBaseClientinline
INCLUDE_MODULES enum valuesb::StreamBaseClient
isClosed()sb::StreamBaseClient
isConnected()sb::StreamBaseClient
isStreamSubscribed(const std::string &entity)sb::StreamBaseClient
listEntities(const std::string &type, int flags, std::vector< std::string > &names)sb::StreamBaseClient
listEntities(StreamBaseEntityType::Type type, int flags, std::vector< std::string > &names)sb::StreamBaseClient
listEntities(StreamBaseEntityType::Type type, std::vector< std::string > &names)sb::StreamBaseClient
ListEntitiesFlags enum namesb::StreamBaseClient
operatorStatus(const std::string &containerName, std::vector< std::string > &aStatus)sb::StreamBaseClient
readTable(const std::string &tablePath, int limit, const std::string &predicate="")sb::StreamBaseClient
resubscribe(const std::string &stream_name, const std::string &logical_stream, const std::string &predicate)sb::StreamBaseClient
resubscribe(const StreamProperties &props, const std::string &logical_stream, const std::string &predicate)sb::StreamBaseClient
setDequeueResultInterceptor(DequeueResult::Interceptor *dri)sb::StreamBaseClient
setDynamicVariable(const std::string &dynamicVariablePath, const std::string &value)sb::StreamBaseClient
setQuiescentLimit(int timeoutMS)sb::StreamBaseClient
status(std::vector< std::string > &aStatus, bool verbose=false)sb::StreamBaseClient
StreamBaseClient(const StreamBaseURI &uri=StreamBaseURI::fromEnvironment(), int buffer_size=0, int flush_interval=DEFAULT_FLUSH_INTERVAL)sb::StreamBaseClient
StreamBaseClient(const std::string &uris, int buffer_size=0, int flush_interval=DEFAULT_FLUSH_INTERVAL) (defined in sb::StreamBaseClient)sb::StreamBaseClient
StreamBaseClient(const std::vector< StreamBaseURI > &uris, int buffer_size=0, int flush_interval=DEFAULT_FLUSH_INTERVAL) (defined in sb::StreamBaseClient)sb::StreamBaseClient
StreamBaseClient(const std::vector< StreamBaseURI > &uris, sb::ClientSettings &settings, int buffer_size=0, int flush_interval=DEFAULT_FLUSH_INTERVAL) (defined in sb::StreamBaseClient)sb::StreamBaseClient
subscribe(const std::string &stream_name)sb::StreamBaseClient
subscribe(const StreamProperties &props)sb::StreamBaseClient
subscribe(const std::string &stream_name, const std::string &logical_stream, const std::string &predicate)sb::StreamBaseClient
subscribe(const StreamProperties &props, const std::string &logical_stream, const std::string &predicate)sb::StreamBaseClient
typecheck(const std::string &sbapp, std::map< std::string, Schema > &streams, bool full=false)sb::StreamBaseClient
unsubscribe(const std::string &stream_name)sb::StreamBaseClient
unsubscribe(const StreamProperties &props)sb::StreamBaseClient
~StreamBaseClient()sb::StreamBaseClient