set status by lag for all upstreams (#291)
This commit is contained in:
@@ -89,11 +89,6 @@ abstract class DefaultUpstream(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun statusByLag(lag: Long?, proposed: UpstreamAvailability): UpstreamAvailability {
|
private fun statusByLag(lag: Long?, proposed: UpstreamAvailability): UpstreamAvailability {
|
||||||
if (options.disableValidation) {
|
|
||||||
// if we specifically told that this upstream should be _always valid_ then skip
|
|
||||||
// the status calculation and trust the proposed value as is
|
|
||||||
return proposed
|
|
||||||
}
|
|
||||||
if (lag == null) {
|
if (lag == null) {
|
||||||
return UpstreamAvailability.UNAVAILABLE
|
return UpstreamAvailability.UNAVAILABLE
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user