Apama
9.12.0.5
|
EngineStatus function API. More...
#include <engine_client_c.h>
Public Member Functions | |
AP_bool (AP_ENGINE_CLIENT_CALL *print)(AP_EngineStatus *status | |
Format the status into the given buffer. More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getUptime)(AP_EngineStatus *status) | |
Get the time in ms that the Engine has been running for. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumMonitors)(AP_EngineStatus *status) | |
Get the number of monitors defined in the Engine. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumProcesses)(AP_EngineStatus *status) | |
Get the number of monitor processes or active sub-monitors. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumListeners)(AP_EngineStatus *status) | |
Get the number of active listeners. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumEventTypes)(AP_EngineStatus *status) | |
Get the number of event types defined. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumQueuedFastTrack)(AP_EngineStatus *status) | |
Get the total number of events waiting on the route queues (value of 'rq' in the correlator status line). More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumQueuedInput)(AP_EngineStatus *status) | |
Get the total number of events waiting on the input queues (value of 'iq' in the correlator status line). More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getNumReceived)(AP_EngineStatus *status) | |
Get the number of events received since the Engine started (including those discarded because they were invalid). More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getNumFastTracked)(AP_EngineStatus *status) | |
Get the number of events received on the internal input queue since the Engine started. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumConsumers)(AP_EngineStatus *status) | |
Get the number of event consumers connected to the engine. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumOutputEventsQueued)(AP_EngineStatus *status) | |
Get the number of events waiting on the output queue. More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getNumOutputEventsCreated)(AP_EngineStatus *status) | |
Gets the number of output events which have been put onto the output queue. More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getNumOutputEventsSent)(AP_EngineStatus *status) | |
This is the number of output events sent out by the correlator process. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumJavaApplications)(AP_EngineStatus *status) | |
Get the number of java applications defined in the Engine. More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getNumProcessed)(AP_EngineStatus *status) | |
Get the number of events taken off the input queue and processed since the Engine started. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumSubListeners)(AP_EngineStatus *status) | |
Get the number of active listeners. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNumContexts)(AP_EngineStatus *status) | |
Get the number of active contexts. More... | |
const AP_char8 *AP_ENGINE_CLIENT_CALL * | getMostBackedUpInput (AP_EngineStatus *status) |
Get the name of the most backed up (slowest) context. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getMostBackedUpQueueSize)(AP_EngineStatus *status) | |
Get the queue size of the most backed up (slowest) context. More... | |
const AP_char8 *AP_ENGINE_CLIENT_CALL * | getSlowestReceiver (AP_EngineStatus *status) |
Get the name of the slowest receiver. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getSlowestReceiverQueueSize)(AP_EngineStatus *status) | |
Get the queue size of the slowest receiver. More... | |
AP_uint32 (AP_ENGINE_CLIENT_CALL *getNextStatusItem)(AP_EngineStatus *status | |
Sets arguments with the next status item name and value. More... | |
const AP_char8 *AP_ENGINE_CLIENT_CALL * | getStatusValue (AP_EngineStatus *status, const char *key) |
Get the status value with the specified key. More... | |
AP_uint64 (AP_ENGINE_CLIENT_CALL *getStatusIntValue)(AP_EngineStatus *status | |
Get the status value with the specified key, as an integer. More... | |
void (AP_ENGINE_CLIENT_CALL *deleteStatus)(AP_EngineStatus *status) | |
Delete the supplied AP_EngineStatus (returned from a previous call to AP_EngineManagement->getStatus()) More... | |
AP_EngineStatus *AP_ENGINE_CLIENT_CALL * | copyStatus (AP_EngineStatus *status) |
Copy the supplied AP_EngineStatus (returned from a previous call to AP_EngineManagement->getStatus()) More... | |
void *AP_ENGINE_CLIENT_CALL * | copyIterator (AP_EngineStatus *status, void *opaque_state) |
Copy an opaque_state as returned by getNextStatusItem. More... | |
void (AP_ENGINE_CLIENT_CALL *disposeIterator)(AP_EngineStatus *status | |
Delete the opaque_state as returned by getNextStatusItem. More... | |
AP_int64 (AP_ENGINE_CLIENT_CALL *getUserInt)(AP_EngineStatus *status | |
Get a user value of type AP_int64. More... | |
AP_int64 (AP_ENGINE_CLIENT_CALL *getUserIntOr)(AP_EngineStatus *status | |
Get a user value of type AP_int64 or the alt value if it cannot be found. More... | |
AP_float64 (AP_ENGINE_CLIENT_CALL *getUserFloat)(AP_EngineStatus *status | |
Get a user value of type AP_float64. More... | |
AP_float64 (AP_ENGINE_CLIENT_CALL *getUserFloatOr)(AP_EngineStatus *status | |
Get a user value of type AP_float64 or the alt value if it cannot be found. More... | |
AP_bool (AP_ENGINE_CLIENT_CALL *getUserBool)(AP_EngineStatus *status | |
Get a user value of type AP_bool. More... | |
AP_bool (AP_ENGINE_CLIENT_CALL *getUserBoolOr)(AP_EngineStatus *status | |
Get a user value of type AP_bool or the alt value if it cannot be found. More... | |
const AP_char8 *AP_ENGINE_CLIENT_CALL * | getUserString (AP_EngineStatus *status, const char *key) |
Get a user value of type AP_char8*. More... | |
const AP_char8 *AP_ENGINE_CLIENT_CALL * | getUserStringOr (AP_EngineStatus *status, const char *key, const AP_char8 *alt) |
Get a user value of type AP_char8* or the alt value if it cannot be found. More... | |
EngineStatus function API.
AP_EngineStatus_Functions::AP_bool | ( | AP_ENGINE_CLIENT_CALL * | ) |
Format the status into the given buffer.
AP_EngineStatus_Functions::AP_bool | ( | AP_ENGINE_CLIENT_CALL * | getUserBool | ) |
Get a user value of type AP_bool.
EngineException |
AP_EngineStatus_Functions::AP_bool | ( | AP_ENGINE_CLIENT_CALL * | getUserBoolOr | ) |
Get a user value of type AP_bool or the alt value if it cannot be found.
EngineException |
AP_EngineStatus_Functions::AP_float64 | ( | AP_ENGINE_CLIENT_CALL * | getUserFloat | ) |
Get a user value of type AP_float64.
EngineException |
AP_EngineStatus_Functions::AP_float64 | ( | AP_ENGINE_CLIENT_CALL * | getUserFloatOr | ) |
Get a user value of type AP_float64 or the alt value if it cannot be found.
EngineException |
AP_EngineStatus_Functions::AP_int64 | ( | AP_ENGINE_CLIENT_CALL * | getUserInt | ) |
Get a user value of type AP_int64.
EngineException |
AP_EngineStatus_Functions::AP_int64 | ( | AP_ENGINE_CLIENT_CALL * | getUserIntOr | ) |
Get a user value of type AP_int64 or the alt value if it cannot be found.
EngineException |
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumMonitors | ) |
Get the number of monitors defined in the Engine.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumProcesses | ) |
Get the number of monitor processes or active sub-monitors.
If a monitor spawns it creates a new process.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumListeners | ) |
Get the number of active listeners.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumEventTypes | ) |
Get the number of event types defined.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumQueuedFastTrack | ) |
Get the total number of events waiting on the route queues (value of 'rq' in the correlator status line).
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumQueuedInput | ) |
Get the total number of events waiting on the input queues (value of 'iq' in the correlator status line).
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumConsumers | ) |
Get the number of event consumers connected to the engine.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumOutputEventsQueued | ) |
Get the number of events waiting on the output queue.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumJavaApplications | ) |
Get the number of java applications defined in the Engine.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumSubListeners | ) |
Get the number of active listeners.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNumContexts | ) |
Get the number of active contexts.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getMostBackedUpQueueSize | ) |
Get the queue size of the most backed up (slowest) context.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getSlowestReceiverQueueSize | ) |
Get the queue size of the slowest receiver.
AP_EngineStatus_Functions::AP_uint32 | ( | AP_ENGINE_CLIENT_CALL * | getNextStatusItem | ) |
Sets arguments with the next status item name and value.
Sample usage: void *opaque_state = 0; const char *name; const char *value; while (status->getNextStatusItem(&name, &value, &opaque_state)) { //Do stuff with name,value } status->disposeIterator(opaque_state);
name | contains the name of the status item upon return of the function |
value | contains the value of the status item upon return of the function |
opaque_state | a state pointer which must be initiazed to null when the function is called the first time. This pointer must be free'd by calling disposeIterator. |
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getUptime | ) |
Get the time in ms that the Engine has been running for.
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getNumReceived | ) |
Get the number of events received since the Engine started (including those discarded because they were invalid).
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getNumFastTracked | ) |
Get the number of events received on the internal input queue since the Engine started.
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getNumOutputEventsCreated | ) |
Gets the number of output events which have been put onto the output queue.
This corresponds to the number of MonitorScript emit commands executed.
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getNumOutputEventsSent | ) |
This is the number of output events sent out by the correlator process.
This differs from getNumOutEventsCreated since events can be of interest to a varying number of consumers.
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getNumProcessed | ) |
Get the number of events taken off the input queue and processed since the Engine started.
AP_EngineStatus_Functions::AP_uint64 | ( | AP_ENGINE_CLIENT_CALL * | getStatusIntValue | ) |
Get the status value with the specified key, as an integer.
void* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::copyIterator | ( | AP_EngineStatus * | status, |
void * | opaque_state | ||
) |
Copy an opaque_state as returned by getNextStatusItem.
AP_EngineStatus* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::copyStatus | ( | AP_EngineStatus * | status | ) |
Copy the supplied AP_EngineStatus (returned from a previous call to AP_EngineManagement->getStatus())
const AP_char8* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::getMostBackedUpInput | ( | AP_EngineStatus * | status | ) |
Get the name of the most backed up (slowest) context.
const AP_char8* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::getSlowestReceiver | ( | AP_EngineStatus * | status | ) |
Get the name of the slowest receiver.
const AP_char8* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::getStatusValue | ( | AP_EngineStatus * | status, |
const char * | key | ||
) |
Get the status value with the specified key.
const AP_char8* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::getUserString | ( | AP_EngineStatus * | status, |
const char * | key | ||
) |
Get a user value of type AP_char8*.
EngineException |
const AP_char8* AP_ENGINE_CLIENT_CALL* AP_EngineStatus_Functions::getUserStringOr | ( | AP_EngineStatus * | status, |
const char * | key, | ||
const AP_char8 * | alt | ||
) |
Get a user value of type AP_char8* or the alt value if it cannot be found.
EngineException |
AP_EngineStatus_Functions::void | ( | AP_ENGINE_CLIENT_CALL * | deleteStatus | ) |
Delete the supplied AP_EngineStatus (returned from a previous call to AP_EngineManagement->getStatus())
AP_EngineStatus_Functions::void | ( | AP_ENGINE_CLIENT_CALL * | disposeIterator | ) |
Delete the opaque_state as returned by getNextStatusItem.