private def _changesByTag()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala [114:124]

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

  private def _changesByTag(
      tag: Rep[String],
      offset: ConstColumn[Long],
      maxOffset: ConstColumn[Long],
      max: ConstColumn[Long]) = {
    durableStateTable
      .filter(_.tag === tag)
      .sortBy(_.globalOffset.asc)
      .filter(row => row.globalOffset > offset && row.globalOffset <= maxOffset)
      .take(max)
  }