testutil

func CloseConnectors ¶

func CloseConnectors(t *testing.T, connectors []model.Connector)

func IsClusterMode ¶ added in v1.4.0

func IsClusterMode() bool

IsClusterMode reports whether the temporal tests are running against a Redis Cluster (TEST_ENABLE_CLUSTER=true) rather than a single node.

It exists so tests can account for cluster-only semantics. Notably, PUBLISH's reply counts only subscribers connected to the same node as the publisher; go-redis v9.11+ treats PUBLISH as keyless and routes it to a random node (while subscribers bind to the channel's slot node), so with subscribers present that count is non-deterministic even though delivery is unaffected.

func TestConnectors ¶

func TestConnectors(t *testing.T) []model.Connector

Connectors returns a list of connectors to be used in tests. If you are adding a new supported driver, add it here and it will be tested on all the tcs automatically.