diff --git a/cluster_test.go b/cluster_test.go index 92471647..be249424 100644 --- a/cluster_test.go +++ b/cluster_test.go @@ -746,6 +746,12 @@ var _ = Describe("ClusterClient", func() { }) }) + It("should CLUSTER MYSHARDID", func() { + shardID, err := client.ClusterMyShardID(ctx).Result() + Expect(err).NotTo(HaveOccurred()) + Expect(shardID).ToNot(BeEmpty()) + }) + It("should CLUSTER NODES", func() { res, err := client.ClusterNodes(ctx).Result() Expect(err).NotTo(HaveOccurred()) diff --git a/commands.go b/commands.go index 588b3a4f..c9b2af29 100644 --- a/commands.go +++ b/commands.go @@ -460,6 +460,7 @@ type Cmdable interface { PubSubShardChannels(ctx context.Context, pattern string) *StringSliceCmd PubSubShardNumSub(ctx context.Context, channels ...string) *MapStringIntCmd + ClusterMyShardID(ctx context.Context) *StringCmd ClusterSlots(ctx context.Context) *ClusterSlotsCmd ClusterShards(ctx context.Context) *ClusterShardsCmd ClusterLinks(ctx context.Context) *ClusterLinksCmd @@ -3584,6 +3585,12 @@ func (c cmdable) PubSubNumPat(ctx context.Context) *IntCmd { //------------------------------------------------------------------------------ +func (c cmdable) ClusterMyShardID(ctx context.Context) *StringCmd { + cmd := NewStringCmd(ctx, "cluster", "myshardid") + _ = c(ctx, cmd) + return cmd +} + func (c cmdable) ClusterSlots(ctx context.Context) *ClusterSlotsCmd { cmd := NewClusterSlotsCmd(ctx, "cluster", "slots") _ = c(ctx, cmd)