()
| 50 | } |
| 51 | |
| 52 | func (cfg *Config) ToRingConfig() ring.Config { |
| 53 | rc := ring.Config{} |
| 54 | flagext.DefaultValues(&rc) |
| 55 | |
| 56 | rc.KVStore = cfg.KVStore |
| 57 | rc.HeartbeatTimeout = cfg.HeartbeatTimeout |
| 58 | rc.ReplicationFactor = 1 |
| 59 | rc.SubringCacheDisabled = true |
| 60 | |
| 61 | return rc |
| 62 | } |
| 63 | |
| 64 | func (cfg *Config) ToLifecyclerConfig(numTokens int) (ring.BasicLifecyclerConfig, error) { |
| 65 | instanceAddr, err := ring.GetInstanceAddr(cfg.InstanceAddr, cfg.InstanceInterfaceNames, log.Logger, cfg.EnableInet6) |