Add clientName field

go/api/config.go

@@ -76,6 +76,7 @@ type baseClientConfiguration struct {
 	credentials    *RedisCredentials
 	readFrom       ReadFrom
 	requestTimeout int
+	clientName     string
 }
 
 func (config *baseClientConfiguration) toProtobuf() *protobuf.ConnectionRequest {
@@ -99,6 +100,10 @@ func (config *baseClientConfiguration) toProtobuf() *protobuf.ConnectionRequest
 		request.RequestTimeout = uint32(config.requestTimeout)
 	}
 
+	if config.clientName != "" {
+		request.ClientName = config.clientName
+	}
+
 	return &request
 }
 
@@ -208,6 +213,13 @@ func (config *RedisClientConfiguration) WithRequestTimeout(requestTimeout int) *
 	return config
 }
 
+// WithClientName sets the client name to be used for the client. Will be used with CLIENT SETNAME command during connection
+// establishment.
+func (config *RedisClientConfiguration) WithClientName(clientName string) *RedisClientConfiguration {
+	config.clientName = clientName
+	return config
+}
+
 // WithReconnectStrategy sets the [BackoffStrategy] used to determine how and when to reconnect, in case of connection
 // failures. If not set, a default backoff strategy will be used.
 func (config *RedisClientConfiguration) WithReconnectStrategy(strategy *BackoffStrategy) *RedisClientConfiguration {
@@ -288,3 +300,10 @@ func (config *RedisClusterClientConfiguration) WithRequestTimeout(requestTimeout
 	config.requestTimeout = requestTimeout
 	return config
 }
+
+// WithClientName sets the client name to be used for the client. Will be used with CLIENT SETNAME command during connection
+// establishment.
+func (config *RedisClusterClientConfiguration) WithClientName(clientName string) *RedisClusterClientConfiguration {
+	config.clientName = clientName
+	return config
+}

go/api/config_test.go

@@ -42,6 +42,7 @@ func TestConfig_allFieldsSet(t *testing.T) {
 	username := "username"
 	password := "password"
 	timeout := 3
+	clientName := "client name"
 	retries, factor, base := 5, 10, 50
 	databaseId := 1
 
@@ -50,6 +51,7 @@ func TestConfig_allFieldsSet(t *testing.T) {
 		WithReadFrom(PreferReplica).
 		WithCredentials(NewRedisCredentials(username, password)).
 		WithRequestTimeout(timeout).
+		WithClientName(clientName).
 		WithReconnectStrategy(NewBackoffStrategy(retries, factor, base)).
 		WithDatabaseId(databaseId)
 
@@ -59,6 +61,7 @@ func TestConfig_allFieldsSet(t *testing.T) {
 		ClusterModeEnabled: false,
 		AuthenticationInfo: &protobuf.AuthenticationInfo{Username: username, Password: password},
 		RequestTimeout:     uint32(timeout),
+		ClientName:         clientName,
 		ConnectionRetryStrategy: &protobuf.ConnectionRetryStrategy{
 			NumberOfRetries: uint32(retries),
 			Factor:          uint32(factor),