Go: Implement Random Key

CHANGELOG.md

@@ -20,6 +20,7 @@
 * Go: Add `FLUSHALL` ([#3117](https://github.com/valkey-io/valkey-glide/pull/3117))
 * Go: Add `FLUSHDB` ([#3117](https://github.com/valkey-io/valkey-glide/pull/3117))
 * Go: Add password update api ([#3346](https://github.com/valkey-io/valkey-glide/pull/3346))
+* Go: Add `Random Key` ([#3358](https://github.com/valkey-io/valkey-glide/pull/3358))
 
 #### Breaking Changes
 

go/api/generic_cluster_commands.go

@@ -23,4 +23,8 @@ type GenericClusterCommands interface {
 		cursor options.ClusterScanCursor,
 		opts options.ClusterScanOptions,
 	) (options.ClusterScanCursor, []string, error)
+
+	RandomKey() (string, error)
+
+	RandomKeyWithRoute(opts options.RouteOption) (string, error)
 }

go/api/generic_cluster_commands_test.go

@@ -5,6 +5,7 @@ package api
 import (
 	"fmt"
 
+	"github.com/google/uuid"
 	"github.com/valkey-io/valkey-glide/go/api/config"
 	"github.com/valkey-io/valkey-glide/go/api/options"
 )
@@ -212,3 +213,32 @@ func ExampleGlideClusterClient_ScanWithOptions_type() {
 
 	// Output: [someKey]
 }
+
+func ExampleGlideClusterClient_RandomKey() {
+	var client *GlideClusterClient = getExampleGlideClusterClient() // example helper function
+	key := uuid.New().String()
+	client.Set(key, "Hello")
+	result, err := client.RandomKey()
+	if err != nil {
+		fmt.Println("Glide example failed with an error: ", err)
+	}
+
+	fmt.Println(len(result) > 0)
+
+	// Output: true
+}
+
+func ExampleGlideClusterClient_RandomKeyWithRoute() {
+	var client *GlideClusterClient = getExampleGlideClusterClient() // example helper function
+	options := options.RouteOption{Route: nil}
+	key := uuid.New().String()
+	client.Set(key, "Hello")
+	result, err := client.RandomKeyWithRoute(options)
+	if err != nil {
+		fmt.Println("Glide example failed with an error: ", err)
+	}
+
+	fmt.Println(len(result) > 0)
+
+	// Output: true
+}

go/api/generic_commands.go

@@ -9,4 +9,6 @@ package api
 // [valkey.io]: https://valkey.io/commands/#generic
 type GenericCommands interface {
 	CustomCommand(args []string) (interface{}, error)
+
+	RandomKey() (string, error)
 }

go/api/generic_commands_test.go

@@ -4,6 +4,8 @@ package api
 
 import (
 	"fmt"
+
+	"github.com/google/uuid"
 )
 
 func ExampleGlideClient_CustomCommand() {
@@ -16,3 +18,16 @@ func ExampleGlideClient_CustomCommand() {
 
 	// Output: PONG
 }
+
+func ExampleGlideClient_RandomKey() {
+	var client *GlideClient = getExampleGlideClient() // example helper function
+	key := uuid.New().String()
+	client.Set(key, "Hello")
+	result, err := client.RandomKey()
+	if err != nil {
+		fmt.Println("Glide example failed with an error: ", err)
+	}
+	fmt.Println(len(result) > 0)
+
+	// Output: true
+}

go/api/glide_client.go

@@ -314,3 +314,18 @@ func (client *GlideClient) FlushDBWithOptions(mode options.FlushMode) (string, e
 	}
 	return handleStringResponse(result)
 }
+
+// Returns a random existing key name from the currently selected database.
+//
+// Return value:
+//
+//	A random existing key name from the currently selected database.
+//
+// [valkey.io]: https://valkey.io/commands/randomkey/
+func (client *GlideClient) RandomKey() (string, error) {
+	result, err := client.executeCommand(C.RandomKey, []string{})
+	if err != nil {
+		return DefaultStringResponse, err
+	}
+	return handleStringResponse(result)
+}

go/api/glide_cluster_client.go

@@ -544,3 +544,40 @@ func (client *GlideClusterClient) ScanWithOptions(
 	nextCursor, keys, err := handleScanResponse(response)
 	return *options.NewClusterScanCursorWithId(nextCursor), keys, err
 }
+
+// Returns a random key.
+//
+// Return value:
+//
+//	A random key from the database.
+//
+// [valkey.io]: https://valkey.io/commands/randomkey/
+func (client *GlideClusterClient) RandomKey() (string, error) {
+	result, err := client.executeCommand(C.RandomKey, []string{})
+	if err != nil {
+		return DefaultStringResponse, err
+	}
+	return handleStringResponse(result)
+}
+
+// Returns a random key.
+//
+// Parameters:
+//
+// opts - specifies the routing configuration for the command.
+//
+//	The client will route the command to the nodes defined by route,
+//	and will return the first successful result.
+//
+// Return value:
+//
+//	A random key from the database.
+//
+// [valkey.io]: https://valkey.io/commands/randomkey/
+func (client *GlideClusterClient) RandomKeyWithRoute(opts options.RouteOption) (string, error) {
+	result, err := client.executeCommandWithRoute(C.RandomKey, []string{}, opts.Route)
+	if err != nil {
+		return DefaultStringResponse, err
+	}
+	return handleStringResponse(result)
+}

go/integTest/cluster_commands_test.go

@@ -1099,3 +1099,14 @@ func (suite *GlideTestSuite) TestUpdateConnectionPasswordCluster_ImmediateAuthWr
 	_, err = adminClient.CustomCommand([]string{"CONFIG", "SET", "requirepass", ""})
 	assert.NoError(suite.T(), err)
 }
+
+func (suite *GlideTestSuite) TestRandomKeyWithRoute() {
+	client := suite.defaultClusterClient()
+	// Test 1: Check if Echo command return the message
+	t := suite.T()
+	route := config.Route(config.RandomRoute)
+	options := options.RouteOption{Route: route}
+	result, err := client.RandomKeyWithRoute(options)
+	assert.NoError(t, err)
+	assert.NotNil(t, result)
+}

go/integTest/standalone_commands_test.go

@@ -789,3 +789,12 @@ func (suite *GlideTestSuite) TestUpdateConnectionPassword_ImmediateAuthWrongPass
 	_, err = adminClient.ConfigSet(map[string]string{"requirepass": ""})
 	assert.NoError(suite.T(), err)
 }
+
+func (suite *GlideTestSuite) TestRandomKey() {
+	client := suite.defaultClient()
+	// Test 1: Check if Echo command return the message
+	t := suite.T()
+	result, err := client.RandomKey()
+	assert.Nil(t, err)
+	assert.NotNil(t, result)
+}