()
| 409 | } |
| 410 | |
| 411 | func (i *Lifecycler) loadTokenFile() (*TokenFile, error) { |
| 412 | |
| 413 | t, err := LoadTokenFile(i.cfg.TokensFilePath) |
| 414 | if err != nil { |
| 415 | return nil, err |
| 416 | } |
| 417 | |
| 418 | i.stateMtx.Lock() |
| 419 | defer i.stateMtx.Unlock() |
| 420 | |
| 421 | i.tokenFile = t |
| 422 | level.Info(i.logger).Log("msg", "loaded token file", "state", i.tokenFile.PreviousState, "num_tokens", len(i.tokenFile.Tokens), "path", i.cfg.TokensFilePath) |
| 423 | return i.tokenFile, nil |
| 424 | } |
| 425 | |
| 426 | func (i *Lifecycler) getRegisteredAt() time.Time { |
| 427 | i.stateMtx.RLock() |
no test coverage detected