def checkpointAcked()

in src/main/scala/com/gu/kinesis/ConsumerStats.scala [12:30]

• 14 lines of code
• 1 McCabe index (conditional complexity)

  def checkpointAcked(shardConsumerId: ShardConsumerId): Unit
  def checkpointShardEndAcked(shardConsumerId: ShardConsumerId): Unit
  def checkpointDelayed(shardConsumerId: ShardConsumerId, e: Throwable): Unit
  def checkpointFailed(shardConsumerId: ShardConsumerId, e: Throwable): Unit

  def trackRecord(shardConsumerId: ShardConsumerId, record: KinesisRecord): Unit

  def trackBatchEnqueue(shardConsumerId: ShardConsumerId, batchSize: Int)(
      closure: => Future[QueueOfferResult]
  ): Future[QueueOfferResult]

  def recordNrOfInFlightRecords(shardConsumerId: ShardConsumerId, totalCount: Int): Unit
  def recordNrOfProcessedUncheckpointedRecords(shardConsumerId: ShardConsumerId, totalCount: Int): Unit

  def reportInitialization(shardConsumerId: ShardConsumerId): Unit
  def reportShutdown(shardConsumerId: ShardConsumerId, reason: ShutdownReason): Unit
}

object ConsumerStats {