Package io.sbk.api

Interface RateController

All Known Implementing Classes:
SbkRateController
public interface RateController
Interface for Rate or Throughput Controller.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    control(long records, double elapsedSec)
    Blocks for small amounts of time to achieve target Throughput/events per sec.
    void
    start(int recordsPerSec)
    Start the Rate Controller.

  • Method Details

    • start

      void start(int recordsPerSec)
      Start the Rate Controller.
      Parameters:
      recordsPerSec - Records Per Second.

    • control

      void control(long records, double elapsedSec)
      Blocks for small amounts of time to achieve target Throughput/events per sec.
      Parameters:
      records - current cumulative records
      elapsedSec - Elapsed Seconds