public void loadMaxCapacity()

in src/main/java/com/amazonaws/services/kinesis/scaling/auto/StreamMetricManager.java [107:123]

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

	public void loadMaxCapacity() throws Exception {
		LOG.info(String.format("Refreshing Stream %s Throughput Information", this.streamName));
		Integer openShards = StreamScalingUtils.getOpenShardCount(this.kinesisClient, this.streamName);

		for (KinesisOperationType op : this.trackedOperations) {
			int maxBytes = openShards.intValue() * op.getMaxCapacity().get(StreamMetric.Bytes);
			int maxRecords = openShards.intValue() * op.getMaxCapacity().get(StreamMetric.Records);
			StreamMetrics maxCapacity = new StreamMetrics(op);
			maxCapacity.put(StreamMetric.Bytes, maxBytes);
			maxCapacity.put(StreamMetric.Records, maxRecords);

			streamMaxCapacity.put(op, maxCapacity);

			LOG.info(String.format("Stream Capacity for %s: %s Open Shards, %,d Bytes/Second, %d Records/Second",
					op.toString(), openShards, maxBytes, maxRecords));
		}
	}