- Generated by
1.9.5
|
Streaming C++ API
|
This is the complete list of members for sb::StreamBaseClient, including all inherited members.
| ALL_CONTAINERS enum value | sb::StreamBaseClient | |
| canDequeue() | sb::StreamBaseClient | |
| close() | sb::StreamBaseClient | |
| DEFAULT_FLUSH_INTERVAL (defined in sb::StreamBaseClient) | sb::StreamBaseClient | static |
| 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 value | sb::StreamBaseClient | |
| getBufferSize() const | sb::StreamBaseClient | |
| getConnectionID() const | sb::StreamBaseClient | |
| getConnectionIdAsHexString() const | sb::StreamBaseClient | |
| getDequeueResultsInterceptor() | sb::StreamBaseClient | |
| getDynamicVariables(const std::string &modulePath) | sb::StreamBaseClient | |
| getIsBuffering() const | sb::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::StreamBaseClient | inline |
| getStreamProperties(const std::string &entity, StreamProperties::CaptureTransformStrategy strategy=StreamProperties::FLATTEN) | sb::StreamBaseClient | |
| getStreamPropertiesByHash(const std::string &hex) | sb::StreamBaseClient | |
| getTupleDequeueCount() const | sb::StreamBaseClient | |
| getTupleEnqueueCount() const | sb::StreamBaseClient | |
| getURI() const | sb::StreamBaseClient | |
| getURIs() const (defined in sb::StreamBaseClient) | sb::StreamBaseClient | |
| getVersion() | sb::StreamBaseClient | inline |
| INCLUDE_MODULES enum value | sb::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 name | sb::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 |
1.9.5