| 1 | import * as Duration from "../../Duration.ts" |
| 2 | import type { ShardingConfig } from "../ShardingConfig.ts" |
| 3 | |
| 4 | /** |
| 5 | * @internal |
| 6 | */ |
| 7 | export const effectiveInterval = (config: ShardingConfig["Service"]): Duration.Duration => |
| 8 | Duration.min( |
| 9 | Duration.fromInputUnsafe(config.shardLockRefreshInterval), |
| 10 | Duration.divideUnsafe(Duration.fromInputUnsafe(config.shardLockExpiration), 3) |
| 11 | ) |