(fn func(rdb *Client))
| 715 | } |
| 716 | |
| 717 | func (c *Ring) OnNewNode(fn func(rdb *Client)) { |
| 718 | c.sharding.OnNewNode(fn) |
| 719 | } |
| 720 | |
| 721 | // ForEachShard concurrently calls the fn on each live shard in the ring. |
| 722 | // It returns the first error if any. |
no outgoing calls