id: 1 unit: override def processRecords() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 35 end line: 60 size: 22 LOC McCabe index: 4 number of parameters: 1 id: 2 unit: override protected def processEvent() file: src/main/scala/com/gu/contentapi/firehose/ContentApiFirehoseConsumer.scala start line: 32 end line: 54 size: 18 LOC McCabe index: 11 number of parameters: 1 id: 3 unit: constructor() file: cdk/lib/content-api-firehose-client-testing.ts start line: 8 end line: 24 size: 17 LOC McCabe index: 1 number of parameters: 3 id: 4 unit: protected def processEvents() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 62 end line: 76 size: 9 LOC McCabe index: 2 number of parameters: 1 id: 5 unit: def kinesisClientFor() file: src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReader.scala start line: 20 end line: 32 size: 8 LOC McCabe index: 1 number of parameters: 2 id: 6 unit: def shutdownRequested() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 88 end line: 92 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 7 unit: def start() file: src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReader.scala start line: 75 end line: 79 size: 5 LOC McCabe index: 1 number of parameters: 0 id: 8 unit: override def initialize() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 30 end line: 33 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 9 unit: def leaseLost() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 78 end line: 81 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 10 unit: def shardEnded() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 83 end line: 86 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 11 unit: def shutdown() file: src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReader.scala start line: 81 end line: 84 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 12 unit: override def shutdown() file: src/main/scala/com/gu/contentapi/firehose/ContentApiFirehoseConsumer.scala start line: 56 end line: 58 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 13 unit: def shutdown() file: src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala start line: 98 end line: 98 size: 1 LOC McCabe index: 1 number of parameters: 1