()
| 486 | } |
| 487 | |
| 488 | func (c *ringSharding) Random() (*ringShard, error) { |
| 489 | return c.GetByKey(strconv.Itoa(rand.Int())) |
| 490 | } |
| 491 | |
| 492 | // Heartbeat monitors state of each shard in the ring. |
| 493 | func (c *ringSharding) Heartbeat(ctx context.Context, frequency time.Duration) { |