MCPcopy
hub / github.com/redis/go-redis / Add

Method Add

internal/routing/aggregator.go:25–25  ·  view source on GitHub ↗

Add processes a single shard response.

(result interface{}, err error)

Source from the content-addressed store, hash-verified

23type ResponseAggregator interface {
24 // Add processes a single shard response.
25 Add(result interface{}, err error) error
26
27 // AddWithKey processes a single shard response for a specific key (used by keyed aggregators).
28 AddWithKey(key string, result interface{}, err error) error

Callers 15

TestAggLogicalAndAggregatorFunction · 0.95
TestAggLogicalOrAggregatorFunction · 0.95
TestEventDrivenHandoffIntegrationFunction · 0.65
pubsub_test.goFile · 0.65
TestOptionsCloneMaintNotificationsRaceFunction · 0.65
ForEachShardMethod · 0.65
generalProcessPipelineMethod · 0.65
sentinel_test.goFile · 0.65
ring_test.goFile · 0.65
TestClusterMaintNotifications_ConcurrentCallbacksFunction · 0.65
generateUniqueIDFunction · 0.65
BenchmarkPubSubConcurrentCreationFunction · 0.65

Implementers 10

AllSucceededAggregatorinternal/routing/aggregator.go
OneSucceededAggregatorinternal/routing/aggregator.go
AggSumAggregatorinternal/routing/aggregator.go
AggMinAggregatorinternal/routing/aggregator.go
AggMaxAggregatorinternal/routing/aggregator.go
AggLogicalAndAggregatorinternal/routing/aggregator.go
AggLogicalOrAggregatorinternal/routing/aggregator.go
DefaultKeylessAggregatorinternal/routing/aggregator.go
DefaultKeyedAggregatorinternal/routing/aggregator.go
SpecialAggregatorinternal/routing/aggregator.go

Calls

no outgoing calls

Tested by 15

TestAggLogicalAndAggregatorFunction · 0.76
TestAggLogicalOrAggregatorFunction · 0.76
TestEventDrivenHandoffIntegrationFunction · 0.52
TestOptionsCloneMaintNotificationsRaceFunction · 0.52
TestClusterMaintNotifications_ConcurrentCallbacksFunction · 0.52
BenchmarkPubSubConcurrentCreationFunction · 0.52
BenchmarkSetGoroutinesFunction · 0.52
WaitForIndexingFunction · 0.52
ExampleClient_WatchFunction · 0.52
benchmarkHSETOperationsConcurrentFunction · 0.52
TestClusterMaintNotifications_SMIGRATEDFunction · 0.52
TestClusterMaintNotifications_DeduplicationFunction · 0.52