mirror of
https://github.com/hanzokv/go.git
synced 2026-09-24 00:31:51 +00:00
zeekay
6994cf05aa
We do not use Redis. The client was a go-redis fork and still said so
everywhere: `package redis`, `redis.NewClient`, `redis://`, `extra/redisotel`.
Consumers wrote `redis.Client` against a Valkey-backed store called KV.
package redis -> package kv (93 decls)
redis.X -> kv.X (2,794 call sites)
"redis: …" errors -> "kv: …" (206)
extra/redis{otel,cmd,prometheus,census} -> extra/kv{otel,cmd,prometheus,census}
redis:// , rediss:// -> kv:// , kvs:// (ParseURL)
Redis*/*Redis* idents -> KV*/*KV*
REDIS_VERSION, REDIS_ENDPOINTS_CONFIG_PATH -> KV_*
I previously argued this rename was unsafe because much of it was "wire
contract". That was wrong, and the categorisation shows why: RESP command names
are GET/SET/HSET — they never contain the word. Of 5,771 occurrences only two
kinds were server-visible at all: the ParseURL scheme (we choose what we pass;
our configs already use kv://) and the CLIENT SETINFO lib-name label, which the
server merely records. Nothing here changes a byte of protocol.
Two things deliberately keep the old spelling:
RediSearch — names a specific external module the FT.* commands map to.
StoreDist — contains the letters by accident (sto-reDis-t), not the word.
Breaking for consumers by design: every import site must move redis.X -> kv.X.
Minor bump, never a major — this module stays v9 forever.
43 lines
894 B
Go
43 lines
894 B
Go
package e2e
|
|
|
|
import (
|
|
"log"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hanzokv/go/v9"
|
|
"github.com/hanzokv/go/v9/logging"
|
|
)
|
|
|
|
// Global log collector
|
|
var logCollector *TestLogCollector
|
|
|
|
const defaultTestTimeout = 30 * time.Minute
|
|
|
|
// Global fault injector client
|
|
var faultInjector *FaultInjectorClient
|
|
|
|
func TestMain(m *testing.M) {
|
|
var err error
|
|
if os.Getenv("E2E_SCENARIO_TESTS") != "true" {
|
|
log.Println("Skipping scenario tests, E2E_SCENARIO_TESTS is not set")
|
|
return
|
|
}
|
|
|
|
faultInjector, err = CreateTestFaultInjector()
|
|
if err != nil {
|
|
panic("Failed to create fault injector: " + err.Error())
|
|
}
|
|
// use log collector to capture logs from kv clients
|
|
logCollector = NewTestLogCollector()
|
|
kv.SetLogger(logCollector)
|
|
kv.SetLogLevel(logging.LogLevelDebug)
|
|
|
|
logCollector.Clear()
|
|
defer logCollector.Clear()
|
|
log.Println("Running scenario tests...")
|
|
status := m.Run()
|
|
os.Exit(status)
|
|
}
|