src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReaderConfig.scala

package com.gu.contentapi.firehose.kinesis

import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider

import scala.concurrent.duration._

case class KinesisStreamReaderConfig(
  streamName: String,
  app: String,
  stage: String,
  mode: String,
  suffix: Option[String],
  kinesisCredentialsProvider: AwsCredentialsProvider,
  dynamoCredentialsProvider: AwsCredentialsProvider,
  awsRegion: String,
  checkpointInterval: Duration = 30.second,
  maxCheckpointBatchSize: Int = 20,
  maxRecords: Int = 10000,
  idleTimeBetweenReadsInMillis: Long = 2000L) {

  lazy val applicationName: String = s"${streamName}_${app}-${mode}-${stage.toUpperCase}${suffix.getOrElse("")}"

}