Подключение к нешардированному кластеру Valkey™

# Собрать вручную утилиту redis-tools с поддержкой TLS.
RUN apt-get update && \
    apt-get install make gcc libssl-dev --yes && \
    wget https://download.redis.io/redis-stable.tar.gz && \
    tar -xzvf redis-stable.tar.gz && \
    cd redis-stable && \
    make BUILD_TLS=yes MALLOC=libc && \
    make install && \
    cp ./src/redis-cli /usr/bin/

sudo apt update && sudo apt install -y redis-tools

redis-cli \
    -h c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz \
    -a <пароль>

using System;
using System.Threading.Tasks;
using StackExchange.Redis;

namespace RedisClient
{
    class Program
    {
        // Configuration constants
        private const string TEST_KEY = "test-key";
        private const string TEST_VALUE = "test-value";
        private const string USERNAME = "default";
        private const string PASSWORD = "<пароль>";

        static async Task<int> Main(string[] args)
        {
            try
            {
                var sentinelOptions = new ConfigurationOptions
                {
                    EndPoints = {
                        "<FQDN_хоста_1_Valkey™>:26379",
                        ...
                        "<FQDN_хоста_N_Valkey™>:26379"
                    },
                    CommandMap = CommandMap.Sentinel
                };

                var sentinelConnection = await ConnectionMultiplexer.ConnectAsync(sentinelOptions);

                var endpoints = sentinelConnection.GetEndPoints();
                var sentinelServer = sentinelConnection.GetServer(endpoints[0]);
                var masterEndpoint = await sentinelServer.SentinelGetMasterAddressByNameAsync("mymaster");
                await sentinelConnection.CloseAsync();

                var masterOptions = new ConfigurationOptions
                {
                    EndPoints = { masterEndpoint },
                    User = USERNAME,
                    Password = PASSWORD,
                    Ssl = false
                };

                var connection = await ConnectionMultiplexer.ConnectAsync(masterOptions);

                var db = connection.GetDatabase();

                bool setResult = await db.StringSetAsync(TEST_KEY, TEST_VALUE);
                if (!setResult)
                {
                    Console.WriteLine($"SET failed for key {TEST_KEY}");
                    return 1;
                }
                Console.WriteLine($"Successfully set {TEST_KEY} = {TEST_VALUE}");

                var getResult = await db.StringGetAsync(TEST_KEY);
                if (!getResult.HasValue)
                {
                    Console.WriteLine($"GET failed: Key {TEST_KEY} not found");
                    return 1;
                }

                string retrievedValue = getResult.ToString();
                if (retrievedValue != TEST_VALUE)
                {
                    Console.WriteLine($"GET failed. Expected: '{TEST_VALUE}' Actual: '{retrievedValue}'");
                    return 1;
                }
                Console.WriteLine($"Successfully retrieved {TEST_KEY} = {retrievedValue}");

                return 0;
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Operation failed: {ex.Message}");
                return 1;
            }
        }
    }
}

using System;
using System.Threading.Tasks;
using StackExchange.Redis;

namespace RedisClient
{
    class Program
    {
        // Configuration constants
        private const string TEST_KEY = "test-key";
        private const string TEST_VALUE = "test-value";
        private const string USERNAME = "default";
        private const string PASSWORD = "<пароль>";

        static async Task<int> Main(string[] args)
        {
            try
            {
                var masterOptions = new ConfigurationOptions
                {
                    EndPoints = { "<FQDN_хоста-мастера_Valkey™>:6379" },
                    User = USERNAME,
                    Password = PASSWORD
                };

                var connection = await ConnectionMultiplexer.ConnectAsync(masterOptions);

                var db = connection.GetDatabase();

                bool setResult = await db.StringSetAsync(TEST_KEY, TEST_VALUE);
                if (!setResult)
                {
                    Console.WriteLine($"SET failed for key {TEST_KEY}");
                    return 1;
                }
                Console.WriteLine($"Successfully set {TEST_KEY} = {TEST_VALUE}");

                var getResult = await db.StringGetAsync(TEST_KEY);
                if (!getResult.HasValue)
                {
                    Console.WriteLine($"GET failed: Key {TEST_KEY} not found");
                    return 1;
                }

                string retrievedValue = getResult.ToString();
                if (retrievedValue != TEST_VALUE)
                {
                    Console.WriteLine($"GET failed. Expected: '{TEST_VALUE}' Actual: '{retrievedValue}'");
                    return 1;
                }
                Console.WriteLine($"Successfully retrieved {TEST_KEY} = {retrievedValue}");

                return 0;
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Operation failed: {ex.Message}");
                return 1;
            }
        }
    }
}

package main

import (
	"fmt"
	"github.com/go-redis/redis/v7"
)

func main() {
	conn := redis.NewUniversalClient(
		&redis.UniversalOptions{
			Addrs: []string{
				"<FQDN_хоста_1_Valkey™>:26379",
				...
				"<FQDN_хоста_N_Valkey™>:26379"},
			MasterName: "<имя_кластера_Valkey™>",
			Password:   "<пароль>",
			ReadOnly:   false,
		},
	)
	err := conn.Set("foo", "bar", 0).Err()
	if err != nil {
		panic(err)
	}

	result, err := conn.Get("foo").Result()
	if err != nil {
		panic(err)
	}
	fmt.Println(result)

	conn.Close()
}

package main

import (
	"fmt"
	"github.com/go-redis/redis/v7"
)

func main() {
	conn := redis.NewUniversalClient(
		&redis.UniversalOptions{
			Addrs:    []string{"c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz:6379"},
			Password: "<пароль>",
			ReadOnly: false,
		},
	)
	err := conn.Set("foo", "bar", 0).Err()
	if err != nil {
		panic(err)
	}

	result, err := conn.Get("foo").Result()
	if err != nil {
		panic(err)
	}
	fmt.Println(result)

	conn.Close()
}

package com.example;

import java.util.HashSet;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisSentinelPool;

public class App {
  public static void main(String[] args) {
    String redisName = "<имя_кластера_Valkey™>";
    String redisPass = "<пароль>";

    HashSet sentinels = new HashSet();
    sentinels.add("<FQDN_хоста_1_Valkey™>:26379");
    ...
    sentinels.add("<FQDN_хоста_N_Valkey™>:26379");

    try {
      JedisSentinelPool pool = new JedisSentinelPool(redisName, sentinels);
      Jedis conn = pool.getResource();

      conn.auth(redisPass);
      conn.set("foo", "bar");
      System.out.println(conn.get("foo"));

      pool.close();
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }
}

package com.example;

import redis.clients.jedis.Jedis;

public class App {
  public static void main(String[] args) {
    String redisHost = "c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz";
    String redisPass = "<пароль>";

    try {
      Jedis conn = new Jedis(redisHost);

      conn.auth(redisPass);
      conn.set("foo", "bar");
      System.out.println(conn.get("foo"));

      conn.close();
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }
}

"use strict";
const Redis = require("ioredis");

const conn = new Redis({
    sentinels: [
        { host: "<FQDN_хоста_1_Valkey™>", port: 26379 },
        ...
        { host: "<FQDN_хоста_N_Valkey™>", port: 26379 },
    ],
    name: "<имя_кластера_Valkey™>",
    password: "<пароль>"
});

conn.set("foo", "bar", function (err) {
    if (err) {
        console.error(err);
        conn.disconnect();
    }
});

conn.get("foo", function (err, result) {
    if (err) {
        console.error(err);
    } else {
        console.log(result);
    }

    conn.disconnect();
});

"use strict";

const Redis = require("ioredis");

const conn = new Redis({
    host: "c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz",
    port: 6379,
    password: "<пароль>"
});

conn.set("foo", "bar", function (err) {
    if (err) {
        console.error(err);
        conn.disconnect();
    }
});

conn.get("foo", function (err, result) {
    if (err) {
        console.error(err);
    } else {
        console.log(result);
    }

    conn.disconnect();
});

<?php
require "Predis/Autoloader.php";
Predis\Autoloader::register();

$sentinels = [
    "<FQDN_хоста_1_Valkey™>:26379",
    ...
    "<FQDN_хоста_N_Valkey™>:26379",
];
$options = [
    "replication" => "sentinel",
    "service" => "<имя_кластера_Valkey™>",
    "parameters" => [
        "password" => "<пароль>",
    ],
];

$conn = new Predis\Client($sentinels, $options);

$conn->set("foo", "bar");
var_dump($conn->get("foo"));

$conn->disconnect();
?>

<?php
require "Predis/Autoloader.php";
Predis\Autoloader::register();

$host = ["c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz:6379"];
$options = [
    "parameters" => [
        "password" => "<пароль>",
    ],
];

$conn = new Predis\Client($host, $options);

$conn->set("foo", "bar");
var_dump($conn->get("foo"));

$conn->disconnect();
?>

from redis.sentinel import Sentinel

sentinels = [
    "<FQDN_хоста_1_Valkey™>",
    ...
    "<FQDN_хоста_N_Valkey™>"
]
name = "<имя_кластера_Valkey™>"
pwd = "<пароль>"

sentinel = Sentinel([(h, 26379) for h in sentinels], socket_timeout=0.1)
master = sentinel.master_for(name, password=pwd)
slave = sentinel.slave_for(name, password=pwd)

master.set("foo", "bar")
print(slave.get("foo"))

import redis

r = redis.StrictRedis(
    host="c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz",
    port=6379,
    password="<пароль>",
)

r.set("foo", "bar")
print(r.get("foo"))

# coding: utf-8

require 'redis'

SENTINELS = [
  { host: '<FQDN_хоста_1_Valkey™>', port: 26379 },
  ...
  { host: '<FQDN_хоста_N_Valkey™>', port: 26379 }
]

conn = Redis.new(
  host: '<имя_кластера_Valkey™>',
  sentinels: SENTINELS,
  role: 'master',
  password: '<пароль>'
)

conn.set('foo', 'bar')
puts conn.get('foo')

conn.close

# coding: utf-8

require 'redis'

conn = Redis.new(
  host: 'c-<идентификатор_кластера>.rw.mdb.yandexcloud.kz',
  port: 6379,
  password: '<пароль>'
)

conn.set('foo', 'bar')
puts conn.get('foo')

conn.close