Go: Implement DBSize Server Management Cluster

go/api/glide_cluster_client.go

@@ -6,13 +6,18 @@ package api
 // #include "../lib.h"
 import "C"
 
+import (
+	"github.com/valkey-io/valkey-glide/go/glide/api/options"
+)
+
 // GlideClusterClient interface compliance check.
 var _ GlideClusterClientCommands = (*GlideClusterClient)(nil)
 
 // GlideClusterClientCommands is a client used for connection in cluster mode.
 type GlideClusterClientCommands interface {
 	BaseClient
 	GenericClusterCommands
+	ServerManagementClusterCommands
 }
 
 // GlideClusterClient implements cluster mode operations by extending baseClient functionality.
@@ -69,3 +74,28 @@ func (client *GlideClusterClient) CustomCommand(args []string) (ClusterValue[int
 	}
 	return CreateClusterValue(data), nil
 }
+
+// Returns the number of keys in the currently selected database.
+//
+// Return value:
+//
+//	The number of keys in the currently selected database.
+//
+// Example:
+//
+//	route := api.SimpleNodeRoute(api.RandomRoute)
+//	options := options.NewDBOptionsBuilder().SetRoute(route)
+//	result, err := client.DBSizeWithOption(route)
+//	if err != nil {
+//	  // handle error
+//	}
+//	fmt.Println(result) // Output: 1
+//
+// [valkey.io]: https://valkey.io/commands/dbsize/
+func (client *GlideClusterClient) DBSizeWithOptions(opts options.RouteOption) (int64, error) {
+	result, err := client.executeCommandWithRoute(C.DBSize, []string{}, opts.Route)
+	if err != nil {
+		return defaultIntResponse, err
+	}
+	return handleIntResponse(result)
+}

go/api/options/db_size_options.go

@@ -0,0 +1,16 @@
+package options
+
+import "github.com/valkey-io/valkey-glide/go/glide/api/config"
+
+type DBSizeOptions struct {
+	Route config.Route
+}
+
+func NewTimeOptionsBuilder() *DBSizeOptions {
+	return &DBSizeOptions{}
+}
+
+func (dbSizeOptions *DBSizeOptions) SetRoute(route config.Route) *DBSizeOptions {
+	dbSizeOptions.Route = route
+	return dbSizeOptions
+}

go/api/options/route_options.go

@@ -0,0 +1,9 @@
+// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+
+package options
+
+import "github.com/valkey-io/valkey-glide/go/glide/api/config"
+
+type RouteOption struct {
+	Route config.Route
+}

go/api/server_management_cluster_commands.go

@@ -0,0 +1,14 @@
+// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+
+package api
+
+import "github.com/valkey-io/valkey-glide/go/glide/api/options"
+
+// ServerManagementClusterCommands supports commands for the "Server Management Commands" group for cluster client.
+//
+// See [valkey.io] for details.
+//
+// [valkey.io]: https://valkey.io/commands/#server
+type ServerManagementClusterCommands interface {
+	DBSizeWithOptions(routeOption options.RouteOption) (int64, error)
+}

go/integTest/cluster_commands_test.go

@@ -6,6 +6,8 @@ import (
 	"strings"
 
 	"github.com/stretchr/testify/assert"
+	"github.com/valkey-io/valkey-glide/go/glide/api/config"
+	"github.com/valkey-io/valkey-glide/go/glide/api/options"
 )
 
 func (suite *GlideTestSuite) TestClusterCustomCommandInfo() {
@@ -27,3 +29,14 @@ func (suite *GlideTestSuite) TestClusterCustomCommandEcho() {
 	// ECHO is routed to a single random node
 	assert.Equal(suite.T(), "GO GLIDE GO", result.Value().(string))
 }
+
+func (suite *GlideTestSuite) TestDBSizeRandomRoute() {
+	client := suite.defaultClusterClient()
+	route := config.Route(config.RandomRoute)
+	options := options.RouteOption{Route: route}
+	result, err := client.DBSizeWithOptions(options)
+	assert.NoError(suite.T(), err)
+	assert.NotNil(suite.T(), result)
+	assert.NotEmpty(suite.T(), result)
+	assert.Greater(suite.T(), result, int64(0))
+}