We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4993855 commit 1cd9496Copy full SHA for 1cd9496
pkg/kv/kvserver/replica.go
@@ -221,14 +221,19 @@ func newLeaderlessWatcher(r *Replica) *leaderlessWatcher {
221
}
222
223
224
+// Err implements the signaller interface.
225
func (lw *leaderlessWatcher) Err() error {
226
return lw.err
227
228
229
+// C implements the signaller interface.
230
func (lw *leaderlessWatcher) C() <-chan struct{} {
231
return lw.closedChannel
232
233
234
+// IsUnavailable returns true if the replica is considered unavailable.
235
+// Unavailability is defined as being leaderless for a long time, where long is
236
+// defined by the ReplicaUnavailableThreshold.
237
func (lw *leaderlessWatcher) IsUnavailable() bool {
238
lw.mu.RLock()
239
defer lw.mu.RUnlock()
0 commit comments