def apply()

in src/main/scala/com/gu/kinesis/ShardCheckpointConfig.scala [14:22]

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

  def apply(config: Config): ShardCheckpointConfig = {
    val localConfig = config.getConfig("com.gu.kinesis.consumer.shard-checkpoint-config")
    ShardCheckpointConfig(
      checkpointPeriod = localConfig.getDuration("checkpoint-period").toMillis.millis,
      checkpointAfterProcessingNrOfRecords = localConfig.getInt("checkpoint-after-processing-nr-of-records"),
      maxWaitForCompletionOnStreamShutdown =
        localConfig.getDuration("max-wait-for-completion-on-stream-shutdown").toMillis.millis
    )
  }