Hi All, We have added a couple of MBeans for DAS to expose some debug level information. These Mbeans will list under org.wso2.carbon.analytics subdomain.
EVENT_COUNTER [int getCurrentCount()]- This will count all the events that received to DAS regardless of steam or tenant. We want to add this per tenant per stream. But in order to do that we need to add a Map to event persistence path and that might add extra delay to the event saving critical path. Because of that we thought of adding only a counter ( AtomicLong). RECEIVER_REMAINING_QUEUE_BUFFER_SIZE_IN_BYTES [ long getRemainingBufferCapacityInBytes(int tenantId), int getCurrentQueueSize(int tenantId)] - You can use this Mbean to get remaining buffer size in disruptor and current queue size. LAST_PROCESSED_TIMESTAMP[long getLastProcessedTimestamp(int tenantId, String id, boolean primary)] - This will return last saved incremental processed timestamp for given spark table. ANALYTICS_SCRIPT_LAST_EXECUTION_START_TIME[long getScriptLastExecutionStartTime(int tenantId, String scriptName)] - This will return latest execution start time of the given Spark script. Please let me know any other information that you think better expose through Mbeans. Regards, Gihan -- W.G. Gihan Anuruddha Senior Software Engineer | WSO2, Inc. M: +94772272595
_______________________________________________ Architecture mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
