(context.Context)
| 153 | AddState(string, cluster.State, prometheus.Registerer) cluster.ClusterChannel |
| 154 | Position() int |
| 155 | WaitReady(context.Context) error |
| 156 | } |
| 157 | |
| 158 | // Replicator is used to exchange state with peers via the ring when sharding is enabled. |
no outgoing calls