usbharu
/
owl
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: RetryPolicyをcommonパッケージのものに統一

This commit is contained in:
usbharu 2024-03-05 12:14:49 +09:00
parent 8c7133f233
commit 8f5c1715c3
4 changed files with 18 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
broker/src/main/kotlin/dev/usbharu/owl/broker/service/RetryPolicy.kt
View File

@ -1,31 +0,0 @@
/*
* Copyright (C) 2024 usbharu
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package dev.usbharu.owl.broker.service
import java.time.Instant
import kotlin.math.pow
import kotlin.math.roundToLong
interface RetryPolicy {
fun nextRetry(now: Instant, attempt: Int): Instant
}
class ExponentialRetryPolicy(private val firstRetrySeconds: Int = 30) : RetryPolicy {
override fun nextRetry(now: Instant, attempt: Int): Instant =
now.plusSeconds(firstRetrySeconds.toDouble().pow(attempt + 1.0).roundToLong())
}

3
broker/src/main/kotlin/dev/usbharu/owl/broker/service/RetryPolicyFactory.kt
View File

@ -16,6 +16,9 @@
package dev.usbharu.owl.broker.service
import dev.usbharu.owl.common.retry.ExponentialRetryPolicy
import dev.usbharu.owl.common.retry.RetryPolicy
interface RetryPolicyFactory {
fun factory(name: String): RetryPolicy
}

11
common/src/main/kotlin/dev/usbharu/owl/common/retry/ExponentialRetryPolicy.kt Normal file
View File

@ -0,0 +1,11 @@
package dev.usbharu.owl.common.retry
import java.time.Instant
import kotlin.math.pow
import kotlin.math.roundToLong
class ExponentialRetryPolicy(private val firstRetrySeconds: Int = 30) : RetryPolicy {
override fun nextRetry(now: Instant, attempt: Int): Instant =
now.plusSeconds(firstRetrySeconds.toDouble().pow(attempt + 1.0).roundToLong())
}

3
common/src/main/kotlin/dev/usbharu/owl/common/retry/RetryPolicy.kt
View File

@ -16,5 +16,8 @@
package dev.usbharu.owl.common.retry
import java.time.Instant
interface RetryPolicy {
fun nextRetry(now: Instant, attempt: Int): Instant
}