Meters
Overview
Various monitoring meters are automatically created for each Joule component. They cover the actual stream, processors, transports and connected stores.
Stream
The stream monitor provides the observability in to the number of events processed within the processing pipeline as a whole. This is a useful monitor to observe to ensure events are passing through the pipeline successfully and quickly enough.
Type | Description |
---|---|
Queued | Number of events queued for processing |
Processed | Number of events successfully processed |
Failed | Number of failed events not processed by the consuming / publishing transport |
Processor
Every processor has a set of metrics turned on by default.
Type | Description |
---|---|
Received | Number of events received by the processor before being queued |
Queued | Number of events queued ready for processing |
Processed | Number of events successfully processed |
Discarded | Number of events discarded, dropped, from the processor which is removed from the processing pipeline |
Ignored | Number of events ignored but not dropped from the processing pipeline |
Failed | Number of failed events due to a processing failure |
If a processor has been provided with a symbolic name within the DSL configuration a bean will be created using this name.
Transport
Every transport has these metrics turned on by default.
Type | Description |
---|---|
Queued | Number of events queued ready for processing |
Processed | Number of events successfully processed |
Failed | Number of failed events not processed by the consuming / publishing transport |
If a transport has been provided with a symbolic name within the DSL configuration a bean will be created using this name.
Storage
This is a useful set of metrics to understand the I/O load of a connected store.
Type | Description |
---|---|
Reads | Number of reads performed on the store |
Writes | Number of writes performed against the store |
If a store has been provided with a symbolic name within the DSL configuration a bean will be created using this name.
Last updated