private def itemSize()

in src/main/scala/org/apache/pekko/persistence/dynamodb/snapshot/DynamoDBSnapshotRequests.scala [37:47]

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

  private def itemSize(partitionKey: String, serializedSnapshot: Array[Byte]) =
    DynamoFixedByteSize + partitionKey.length + serializedSnapshot.size

  def delete(metadata: SnapshotMetadata): Future[Unit] = {
    val request = new DeleteItemRequest()
      .withTableName(Table)
      .addKeyEntry(Key, S(messagePartitionKey(metadata.persistenceId)))
      .addKeyEntry(SequenceNr, N(metadata.sequenceNr))

    dynamo.deleteItem(request).map(toUnit)
  }