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

Method getRegisteredAt

ring/lifecycler.go:402–406  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

400}
401
402func (i *Lifecycler) getRegisteredAt() time.Time {
403 i.stateMtx.RLock()
404 defer i.stateMtx.RUnlock()
405 return i.registeredAt
406}
407
408func (i *Lifecycler) setRegisteredAt(registeredAt time.Time) {
409 i.stateMtx.Lock()

Callers 7

initRingMethod · 0.95
verifyTokensMethod · 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