ofekshenawa 48d65e5641 Metadata driven cluster routing (#4093) ...

* feat(command): add metadata-driven routing

* fix(cluster): preserve routing compatibility

* fix spellcheck ci

* fix(cluster): harden metadata routing

- Preserve legacy routing, hook order and typed results.
- Handle topology health and invalid metadata safely.
- Reject fan-out from ordered async pipelines before dispatch.
- Reduce allocations and duplicate routing work.
- Add regression coverage and document remaining limitations.

* fix(cluster): correct routing and cursor ownership

- Handle unavailable nodes and malformed topology replies
- Bound metadata verification and retry refreshes in the background
- Bind client-local cursor tokens to their originating nodes
- Validate routing policies and refresh topology after redirects
- Reduce routing allocations and extend tests and documentation

* fix spellcheck ci

* fix ci

* fix ci

* refactor(cluster): split cursor ownership

* fix cursor bug

* fix ci

2026-10-21 17:34:41 +03:00

..

auth/streaming

feat(autopipeline): full duplex flusher (#4002)

2026-09-11 17:54:03 +03:00

cmdmetagen

feat(csc): derive command eligibility (#3960)

2026-10-20 16:33:57 +03:00

customvet

chore: bump version of deps reported by govulncheck (#4060)

2026-10-02 13:38:14 +03:00

hashtag

test: migrate hashtag tests to standard testing (#4085)

2026-10-20 12:21:46 +03:00

hscan

fix(hscan): copy the value before handing it to an unmarshaler (#4078)

2026-10-20 12:33:49 +03:00

interfaces

feat(sch): MaintNotifications for ClusterClient (#3643)

2026-02-13 13:25:07 +02:00

maintnotifications/logs

fix(maintnotifications): fix "proccessing" typo in log message (#4044)

2026-09-29 14:05:40 +03:00

otel

fix(otel): count connections that predate Init (#4089)

2026-10-19 13:57:17 +03:00

pool

test(pool): assert PoolSize soft cap in limit spec (#4180)

2026-10-20 16:33:45 +03:00

proto

feat(csc): derive command eligibility (#3960)

2026-10-20 16:33:57 +03:00

routing

Metadata driven cluster routing (#4093)

2026-10-21 17:34:41 +03:00

util

refactor(math): use Go1.21's built-in min/max function (#3656)

2026-01-08 17:46:13 +02:00

arg.go

chore: update import path

2023-01-23 08:48:54 +02:00

internal_test.go

chore: fewer test dependencies

2023-01-27 15:01:50 +00:00

internal.go

chore(rand) replace internal/rand with stdlib math/rand (#3823)

2026-05-22 15:54:30 +03:00

log.go

fix(log): guard global Logger and LogLevel with atomics (#3988)

2026-09-03 09:49:28 +03:00

once.go

chore(golang): use type-safe sync/atomic value types (#3860)

2026-06-24 08:43:48 +03:00

redis.go

feat(e2e-testing): maintnotifications e2e and refactor (#3526)

2025-09-26 19:17:09 +03:00

semaphore_test.go

feat(autopipeline): automatic command pipelining (#3942)

2026-08-03 19:59:50 +03:00

semaphore.go

perf(autopipeline): better pool utilization on stranglers - *Client (#3962)

2026-08-24 14:42:14 +03:00

util_test.go

feat(search): parser resp3 responses for search (#3741)

2026-05-21 14:18:35 +03:00

util.go

feat(search): parser resp3 responses for search (#3741)

2026-05-21 14:18:35 +03:00