def apply()

in projection/src/main/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSettings.scala [53:94]

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

  def apply(system: ActorSystem[_]): R2dbcProjectionSettings =
    apply(system.settings.config.getConfig(DefaultConfigPath))

  def apply(
      schema: Option[String],
      offsetTable: String,
      timestampOffsetTable: String,
      managementTable: String,
      useConnectionFactory: String,
      timeWindow: JDuration,
      keepNumberOfEntries: Int,
      evictInterval: JDuration,
      deleteInterval: JDuration,
      logDbCallsExceeding: FiniteDuration
  ): R2dbcProjectionSettings = new R2dbcProjectionSettings(
    Dialect.Postgres,
    schema,
    offsetTable,
    timestampOffsetTable,
    managementTable,
    useConnectionFactory,
    timeWindow,
    keepNumberOfEntries,
    evictInterval,
    deleteInterval,
    logDbCallsExceeding
  )
}

final class R2dbcProjectionSettings private (
    val dialect: Dialect,
    val schema: Option[String],
    val offsetTable: String,
    val timestampOffsetTable: String,
    val managementTable: String,
    val useConnectionFactory: String,
    val timeWindow: JDuration,
    val keepNumberOfEntries: Int,
    val evictInterval: JDuration,
    val deleteInterval: JDuration,
    val logDbCallsExceeding: FiniteDuration
) extends Serializable {