def messagePartitionKey()

in src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala [198:209]

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

  def messagePartitionKey(persistenceId: String, sequenceNr: Long): String =
    messagePartitionKeyFromGroupNr(persistenceId, sequenceNr / PartitionSize)

  def messagePartitionKeyFromGroupNr(persistenceId: String, partitionGroupNr: Long): String =
    s"$JournalName-P-$persistenceId-$partitionGroupNr"

  def highSeqKey(persistenceId: String, shard: Long) = {
    val item: Item = new JHMap
    item.put(Key, S(s"$JournalName-SH-$persistenceId-$shard"))
    item.put(Sort, Naught)
    item
  }