Method GetShardClientForKey

ring.go:951–957

GetShardClientForKey returns the shard client that would handle the given key. This can be used to determine which shard a particular key/channel would be routed to.

(key string)

// GetShardClientForKey returns the shard client that would handle the given key.
// This can be used to determine which shard a particular key/channel would be routed to.
func (c *Ring) GetShardClientForKey(key string) (*Client, error) {
	shard, err := c.sharding.GetByKey(key)
	if err != nil {
		return nil, err
	}
	return shard.Client, nil
}