def updateDynamoDbTableWithRate()

in src/it/scala/com/gu/kinesis/KinesisResourceManager.scala [111:129]

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

  def updateDynamoDbTableWithRate(tableName: String, requestPerSecond: Long): Unit = {
    withDynamoDbClient { dynamoDb =>
      waitForTableToBecomeAvailable(tableName, dynamoDb)
      dynamoDb.updateTable(
        UpdateTableRequest
          .builder()
          .tableName(tableName)
          .provisionedThroughput(
            ProvisionedThroughput
              .builder()
              .readCapacityUnits(requestPerSecond)
              .writeCapacityUnits(requestPerSecond)
              .build()
          )
          .build()
      )
      waitForTableToBecomeAvailable(tableName, dynamoDb)
    }
  }