Interface ReadRequestsLogger

All Known Subinterfaces:
RWLogger
All Known Implementing Classes:
AbstractRWLogger, CSVLogger, GrpcLogger, PrometheusLogger, Sl4jLogger, SystemLogger
public interface ReadRequestsLogger
Read-side request logging hooks used by SBK loggers. Implementations can optionally aggregate per-reader metrics (counts, bytes, timeouts) to be emitted periodically or exported to external systems.

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getMaxReaderIDs()
    Maximum number of reader IDs the logger expects to track.
    void
    recordReadRequests(int readerId, long startTime, long bytes, long events)
    Record one or more read requests attributed to a reader.
    void
    recordReadTimeoutEvents(int readerId, long startTime, long timeoutEvents)
    Record read timeout events for a reader.

  • Method Details

    • recordReadRequests

      void recordReadRequests(int readerId, long startTime, long bytes, long events)
      Record one or more read requests attributed to a reader.
      Parameters:
      readerId - logical reader identifier (0..N-1)
      startTime - read start time in the active TimeUnit
      bytes - bytes read for these events
      events - number of read events

    • recordReadTimeoutEvents

      void recordReadTimeoutEvents(int readerId, long startTime, long timeoutEvents)
      Record read timeout events for a reader.
      Parameters:
      readerId - logical reader identifier (0..N-1)
      startTime - time when timeouts were observed
      timeoutEvents - number of timeout events

    • getMaxReaderIDs

      int getMaxReaderIDs()
      Maximum number of reader IDs the logger expects to track. Returning 0 disables per-reader request logging.
      Returns:
      max reader IDs