MCPcopy
hub / github.com/grafana/dskit / getTokens

Method getTokens

ring/lifecycler.go:384–388  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

382}
383
384func (i *Lifecycler) getTokens() Tokens {
385 i.stateMtx.RLock()
386 defer i.stateMtx.RUnlock()
387 return i.tokens
388}
389
390func (i *Lifecycler) setTokens(tokens Tokens) {
391 i.stateMtx.Lock()

Callers 7

checkRingHealthForReadinessMethod · 0.95
compareTokensMethod · 0.95
autoJoinMethod · 0.95
updateConsulMethod · 0.95
TestLifecycler_ShouldHandleInstanceAbruptlyRestartedFunction · 0.95
TestLifecycler_HeartbeatAfterBackendResetFunction · 0.95
TestRestartIngester_NoUnregister_LongHeartbeatFunction · 0.95

Calls

no outgoing calls

Tested by 3

TestLifecycler_ShouldHandleInstanceAbruptlyRestartedFunction · 0.76
TestLifecycler_HeartbeatAfterBackendResetFunction · 0.76
TestRestartIngester_NoUnregister_LongHeartbeatFunction · 0.76