def apply()

in src/main/scala/com/gu/kinesis/ConsumerConfig.scala [32:59]

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

  def apply(
      streamName: String,
      appName: String,
      workerId: String = ConsumerConfig.generateWorkerId,
      initialPositionInStreamExtended: InitialPositionInStreamExtended = defaultInitialPosition,
      coordinatorConfig: Option[CoordinatorConfig] = None,
      leaseManagementConfig: Option[LeaseManagementConfig] = None,
      metricsConfig: Option[MetricsConfig] = None,
      retrievalConfig: Option[RetrievalConfig] = None
  )(implicit
      kinesisClient: KinesisAsyncClient = defaultKinesisClient,
      dynamoClient: DynamoDbAsyncClient = defaultDynamoClient,
      cloudwatchClient: CloudWatchAsyncClient = defaultCloudwatchClient
  ): ConsumerConfig = {
    ConsumerConfig(
      streamName,
      appName,
      workerId,
      kinesisClient,
      dynamoClient,
      cloudwatchClient,
      initialPositionInStreamExtended,
      coordinatorConfig,
      leaseManagementConfig,
      metricsConfig,
      retrievalConfig
    )
  }