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

Method getOldestRegisteredTimestamp

ring/model.go:530–547  ·  view source on GitHub ↗

getOldestRegisteredTimestamp returns unix timestamp of oldest "RegisteredTimestamp" value from all instances. If any instance has 0 value of RegisteredTimestamp, this function returns 0.

()

Source from the content-addressed store, hash-verified

528// getOldestRegisteredTimestamp returns unix timestamp of oldest "RegisteredTimestamp" value from all instances.
529// If any instance has 0 value of RegisteredTimestamp, this function returns 0.
530func (d *Desc) getOldestRegisteredTimestamp() int64 {
531 var result int64
532
533 for _, instance := range d.Ingesters {
534 switch {
535 case instance.RegisteredTimestamp == 0:
536 return 0
537
538 case result == 0:
539 result = instance.RegisteredTimestamp
540
541 case instance.RegisteredTimestamp < result:
542 result = instance.RegisteredTimestamp
543 }
544 }
545
546 return result
547}
548
549func (d *Desc) instancesWithTokensCount() int {
550 count := 0

Callers 2

buildRingForTheShardMethod · 0.95
setRingStateFromDescMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected