Code

Implement CLUSTER PUBSUB#866

Code

Open

vazois wants to merge 28 commits intomicrosoft:mainmicrosoft/garnet:mainfrom vazois:vazois/cluster-pubsubvazois/garnet:vazois/cluster-pubsubCopy head branch name to clipboard

+881-237

Commits

Commits on Jan 23, 2025

• skip Interlocked.Exchange and FlushConfig when no update detected on merge

  vazois

  committed
  d995b11

  Copy full SHA for d995b11

• special case of zero epoch necessitates tracking of explicit slot update

  vazois

  committed
  4afc0db

  Copy full SHA for 4afc0db

• move key spec extraction to clusterProvider

  vazois

  committed
  86cf1d4

  Copy full SHA for 86cf1d4

• implement CLUSTER PUBLISH api

  vazois

  committed
  957f03c

  Copy full SHA for 957f03c

• implement SSUBSCRIBE api

  vazois

  committed
  82951d8

  Copy full SHA for 82951d8

• implement SPUBLISH api

  vazois

  committed
  e80c3f9

  Copy full SHA for e80c3f9

• implement separate code path for CLUSTER SPUBLISH

  vazois

  committed
  fae3ce4

  Copy full SHA for fae3ce4

• expose max number of outstanding pubsub forwarding tasks parameter

  vazois

  committed
  54ae893

  Copy full SHA for 54ae893

• add API to forward published messages using GarnetClient

  vazois

  committed
  0830b59

  Copy full SHA for 0830b59

• add methods to extract nodeIds of all nodes in cluster and all nodes in a shard

  vazois

  committed
  824f614

  Copy full SHA for 824f614

• hook up published message forwarding

  vazois

  committed
  bd744bf

  Copy full SHA for bd744bf

• PUBLISH and SPUBLISH benchmark addition

  vazois

  committed
  c7208bc

  Copy full SHA for c7208bc

• fix check for getting most recent config instance

  vazois

  committed
  9db32e7

  Copy full SHA for 9db32e7

• optimization 1: calculate candidates for published message forwarding only when config gets updated

  vazois

  committed
  c9345aa

  Copy full SHA for c9345aa

• optimization2: ignore response from cluster publish

  vazois

  committed
  412ae03

  Copy full SHA for 412ae03

• add publish BDN

  vazois

  committed
  95db9b0

  Copy full SHA for 95db9b0

• minimize task creation

  vazois

  committed
  7816c5e

  Copy full SHA for 7816c5e

• load no response task

  vazois

  committed
  5ef16a3

  Copy full SHA for 5ef16a3

• change to pinned array

  vazois

  committed
  8fc56d1

  Copy full SHA for 8fc56d1

• simplify config update for publish forward

  vazois

  committed
  bd1e3c8

  Copy full SHA for bd1e3c8

• wip; wait for response vs fire and forget

  vazois

  committed
  120edee

  Copy full SHA for 120edee

• add protected connection initialization for gossip-publish

  vazois

  committed
  5788de0

  Copy full SHA for 5788de0

• remove BDN because not useful

  vazois

  committed
  f42a1f4

  Copy full SHA for f42a1f4

• remove unused NoResponse flag

  vazois

  committed
  e5b48b6

  Copy full SHA for e5b48b6

• remove option for tasks

  vazois

  committed
  eecb867

  Copy full SHA for eecb867

• ensure noResponse for slot verification of cluster commands

  vazois

  committed
  8026a30

  Copy full SHA for 8026a30

• add SPUBLISH and PUBLISH docs

  vazois

  committed
  8c17dd9

  Copy full SHA for 8c17dd9

• correct typo

  vazois

  committed
  4fa2ddd

  Copy full SHA for 4fa2ddd