SimpleRing returns an instance of `ring.Ring` as a service. Starting and stopping the service is up to the caller.
(store kv.Client)
| 193 | |
| 194 | // SimpleRing returns an instance of `ring.Ring` as a service. Starting and stopping the service is up to the caller. |
| 195 | func SimpleRing(store kv.Client) (*ring.Ring, error) { |
| 196 | var config ring.Config |
| 197 | flagext.DefaultValues(&config) |
| 198 | |
| 199 | return ring.NewWithStoreClientAndStrategy( |
| 200 | config, |
| 201 | "local", // ring name |
| 202 | "collectors/ring", // prefix key where peers are stored |
| 203 | store, |
| 204 | ring.NewDefaultReplicationStrategy(), |
| 205 | prometheus.NewPedanticRegistry(), |
| 206 | log.With(logger, "component", "ring"), |
| 207 | ) |
| 208 | } |
| 209 | |
| 210 | // SimpleRingLifecycler returns an instance lifecycler for the given `kv.Client`. |
| 211 | // Usually lifecycler will be part of the server side that act as a single peer. |
no test coverage detected