Package | Description |
---|---|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
com.streambase.sb.monitor |
Provides classes and interfaces to monitor the behavior of a running StreamBase server.
|
Modifier and Type | Class and Description |
---|---|
class |
DeMUXStreamBaseClient
This is a StreamBaseClient that is intended for use by several independent queries.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionStatusCallback.stateChanged(ConnectionStatus state,
StreamBaseClient streamBaseClient,
String additionalInfo)
Called when the connection state changes
|
Constructor and Description |
---|
TupleConnections(StreamBaseClient client,
boolean haModeOn) |
Modifier and Type | Method and Description |
---|---|
StreamBaseClient |
StreamBaseMonitor.getClient()
Get the
StreamBaseClient that this monitor is using |
Modifier and Type | Method and Description |
---|---|
protected String |
Snapshot.getOperatorType(StreamBaseClient sbClient,
String name) |
(package private) Snapshot.Status |
Snapshot.readNextMonitorSnap(StreamBaseClient sbClient,
Snapshot.Source source)
Read the next monitor snapshot, return Status if we are done or not
|
Constructor and Description |
---|
StreamBaseMonitor(StreamBaseClient client)
Create a monitoring object, which will connect to a server with the given
StreamBaseClient object.
|
StreamBaseMonitor(StreamBaseClient sbClient,
String streamName) |
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.