diff options
Diffstat (limited to 'client/go/internal/vespa/document/circuit_breaker.go')
| -rw-r--r-- | client/go/internal/vespa/document/circuit_breaker.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/client/go/internal/vespa/document/circuit_breaker.go b/client/go/internal/vespa/document/circuit_breaker.go index f7f0f4360df..9bcf2e3f619 100644 --- a/client/go/internal/vespa/document/circuit_breaker.go +++ b/client/go/internal/vespa/document/circuit_breaker.go @@ -19,7 +19,7 @@ const ( type CircuitBreaker interface { Success() - Error(error) + Failure() State() CircuitState } @@ -28,7 +28,6 @@ type timeCircuitBreaker struct { doomDuration time.Duration failingSinceMillis atomic.Int64 - lastError atomic.Value halfOpen atomic.Bool open atomic.Bool @@ -42,10 +41,8 @@ func (b *timeCircuitBreaker) Success() { } } -func (b *timeCircuitBreaker) Error(err error) { - if b.failingSinceMillis.CompareAndSwap(math.MaxInt64, b.now().UnixMilli()) { - b.lastError.Store(err) - } +func (b *timeCircuitBreaker) Failure() { + b.failingSinceMillis.CompareAndSwap(math.MaxInt64, b.now().UnixMilli()) } func (b *timeCircuitBreaker) State() CircuitState { |