override def setStringKey()

in distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatedDataSerializer.scala [233:341]
100 lines of code
1 McCabe index (conditional complexity)

    override def setStringKey(
        builder: rd.ORMapDeltaGroup.MapEntry.Builder,
        key: String,
        value: dm.OtherMessage): rd.ORMapDeltaGroup.MapEntry =
      builder.setStringKey(key).setValue(value).build()
    override def setLongKey(
        builder: rd.ORMapDeltaGroup.MapEntry.Builder,
        key: Long,
        value: dm.OtherMessage): rd.ORMapDeltaGroup.MapEntry =
      builder.setLongKey(key).setValue(value).build()
    override def setIntKey(
        builder: rd.ORMapDeltaGroup.MapEntry.Builder,
        key: Int,
        value: dm.OtherMessage): rd.ORMapDeltaGroup.MapEntry =
      builder.setIntKey(key).setValue(value).build()
    override def setOtherKey(
        builder: rd.ORMapDeltaGroup.MapEntry.Builder,
        key: dm.OtherMessage,
        value: dm.OtherMessage): rd.ORMapDeltaGroup.MapEntry =
      builder.setOtherKey(key).setValue(value).build()
    override def hasStringKey(entry: rd.ORMapDeltaGroup.MapEntry): Boolean = entry.hasStringKey
    override def getStringKey(entry: rd.ORMapDeltaGroup.MapEntry): String = entry.getStringKey
    override def hasIntKey(entry: rd.ORMapDeltaGroup.MapEntry): Boolean = entry.hasIntKey
    override def getIntKey(entry: rd.ORMapDeltaGroup.MapEntry): Int = entry.getIntKey
    override def hasLongKey(entry: rd.ORMapDeltaGroup.MapEntry): Boolean = entry.hasLongKey
    override def getLongKey(entry: rd.ORMapDeltaGroup.MapEntry): Long = entry.getLongKey
    override def hasOtherKey(entry: rd.ORMapDeltaGroup.MapEntry): Boolean = entry.hasOtherKey
    override def getOtherKey(entry: rd.ORMapDeltaGroup.MapEntry): OtherMessage = entry.getOtherKey
    override def getValue(entry: rd.ORMapDeltaGroup.MapEntry): dm.OtherMessage = entry.getValue
  }

}

/**
 * Protobuf serializer of ReplicatedData.
 */
class ReplicatedDataSerializer(val system: ExtendedActorSystem)
    extends SerializerWithStringManifest
    with SerializationSupport
    with BaseSerializer {

  import ReplicatedDataSerializer._

  private val DeletedDataManifest = "A"
  private val GSetManifest = "B"
  private val GSetKeyManifest = "b"
  private val ORSetManifest = "C"
  private val ORSetKeyManifest = "c"
  private val ORSetAddManifest = "Ca"
  private val ORSetRemoveManifest = "Cr"
  private val ORSetFullManifest = "Cf"
  private val ORSetDeltaGroupManifest = "Cg"
  private val FlagManifest = "D"
  private val FlagKeyManifest = "d"
  private val LWWRegisterManifest = "E"
  private val LWWRegisterKeyManifest = "e"
  private val GCounterManifest = "F"
  private val GCounterKeyManifest = "f"
  private val PNCounterManifest = "G"
  private val PNCounterKeyManifest = "g"
  private val ORMapManifest = "H"
  private val ORMapKeyManifest = "h"
  private val ORMapPutManifest = "Ha"
  private val ORMapRemoveManifest = "Hr"
  private val ORMapRemoveKeyManifest = "Hk"
  private val ORMapUpdateManifest = "Hu"
  private val ORMapDeltaGroupManifest = "Hg"
  private val LWWMapManifest = "I"
  private val LWWMapKeyManifest = "i"
  private val PNCounterMapManifest = "J"
  private val PNCounterMapKeyManifest = "j"
  private val ORMultiMapManifest = "K"
  private val ORMultiMapKeyManifest = "k"
  private val VersionVectorManifest = "L"

  private val fromBinaryMap = collection.immutable.HashMap[String, Array[Byte] => AnyRef](
    GSetManifest -> gsetFromBinary,
    ORSetManifest -> orsetFromBinary,
    ORSetAddManifest -> orsetAddFromBinary,
    ORSetRemoveManifest -> orsetRemoveFromBinary,
    ORSetFullManifest -> orsetFullFromBinary,
    ORSetDeltaGroupManifest -> orsetDeltaGroupFromBinary,
    FlagManifest -> flagFromBinary,
    LWWRegisterManifest -> lwwRegisterFromBinary,
    GCounterManifest -> gcounterFromBinary,
    PNCounterManifest -> pncounterFromBinary,
    ORMapManifest -> ormapFromBinary,
    ORMapPutManifest -> ormapPutFromBinary,
    ORMapRemoveManifest -> ormapRemoveFromBinary,
    ORMapRemoveKeyManifest -> ormapRemoveKeyFromBinary,
    ORMapUpdateManifest -> ormapUpdateFromBinary,
    ORMapDeltaGroupManifest -> ormapDeltaGroupFromBinary,
    LWWMapManifest -> lwwmapFromBinary,
    PNCounterMapManifest -> pncountermapFromBinary,
    ORMultiMapManifest -> multimapFromBinary,
    DeletedDataManifest -> (_ => DeletedData),
    VersionVectorManifest -> versionVectorFromBinary,
    GSetKeyManifest -> (bytes => GSetKey(keyIdFromBinary(bytes))),
    ORSetKeyManifest -> (bytes => ORSetKey(keyIdFromBinary(bytes))),
    FlagKeyManifest -> (bytes => FlagKey(keyIdFromBinary(bytes))),
    LWWRegisterKeyManifest -> (bytes => LWWRegisterKey(keyIdFromBinary(bytes))),
    GCounterKeyManifest -> (bytes => GCounterKey(keyIdFromBinary(bytes))),
    PNCounterKeyManifest -> (bytes => PNCounterKey(keyIdFromBinary(bytes))),
    ORMapKeyManifest -> (bytes => ORMapKey(keyIdFromBinary(bytes))),
    LWWMapKeyManifest -> (bytes => LWWMapKey(keyIdFromBinary(bytes))),
    PNCounterMapKeyManifest -> (bytes => PNCounterMapKey(keyIdFromBinary(bytes))),
    ORMultiMapKeyManifest -> (bytes => ORMultiMapKey(keyIdFromBinary(bytes))))

  override def manifest(obj: AnyRef): String = obj match {