AuroraNode(ptr< ConfFile > conf=ptr< ConfFile >()) | AuroraNode | |
BOX enum value | AuroraNode | |
checkpoint(vector< long long > &measurements) | AuroraNode | |
chokeBoxes(vector< string > names) | AuroraNode | |
create_cpview(CPViewDescription view_desc, StreamDef streamdef) | AuroraNode | |
createStream(string name, TupleDescription desc) | AuroraNode | |
describe(string entity) | AuroraNode | |
drain() | AuroraNode | |
enqueue(const char *stream_name, const void *data, size_t tuple_length, size_t num_tuples, const void *schema_uuid=0) | AuroraNode | |
EntityType enum name | AuroraNode | |
getBox(string name) const | AuroraNode | |
getBoxes() const | AuroraNode | |
getCpuStats() const | AuroraNode | |
getDequeueHandle() | AuroraNode | |
getLockSet(string name) | AuroraNode | |
getNetworkAsDot() const | AuroraNode | |
getNetworkAsDotStatements(string prefix) const | AuroraNode | |
getNetworkAsDotSubgraph(string prefix, string attrs) const | AuroraNode | |
getPagePool() | AuroraNode | |
getProperties() const | AuroraNode | |
getStatsObject() | AuroraNode | |
getStatsObject() const | AuroraNode | |
getStream(string name) const | AuroraNode | |
getStreamProperties(string entity) | AuroraNode | |
getTupleDescription(string name) const | AuroraNode | |
getTupleDescriptionByHash(string hash) const | AuroraNode | |
INPUT_STREAMS enum value | AuroraNode | |
listEntities(EntityType type, vector< string > &names) | AuroraNode | |
load_box(string file_path) | AuroraNode | |
modifyNetwork(string data, BoxPackage &boxes) | AuroraNode | |
OUTPUT_STREAMS enum value | AuroraNode | |
packBoxes(string data, BoxPackage &boxes) | AuroraNode | |
recover() | AuroraNode | |
repr() const | AuroraNode | |
resumeBoxes(vector< string > names) | AuroraNode | |
schedule_checkpoint_task(ptr< GenericCheckpointTask > task) | AuroraNode | |
SCHEMA enum value | AuroraNode | |
selval | AuroraNode | |
shutdown() | AuroraNode | |
sm | AuroraNode | |
start() | AuroraNode | |
STREAM enum value | AuroraNode | |
StreamProperties typedef | AuroraNode | |
suspendBoxes(vector< string > names) | AuroraNode | |
typecheck(string data, map< string, TupleDescription > &streams) | AuroraNode | |
typecheck(string data, vector< StreamProperties > &streams) | AuroraNode | |
validate(string data) | AuroraNode | |
xGetInputQueueLengthSum() const | AuroraNode | |
~AuroraNode() | AuroraNode | |