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

Method Wait

commands.go:292–297  ·  view source on GitHub ↗
(ctx context.Context, numSlaves int, timeout time.Duration)

Source from the content-addressed store, hash-verified

290}
291
292func (c cmdable) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd {
293 cmd := NewIntCmd(ctx, "wait", numSlaves, int(timeout/time.Millisecond))
294 cmd.setReadTimeout(timeout)
295 _ = c(ctx, cmd)
296 return cmd
297}
298
299func (c cmdable) WaitAOF(ctx context.Context, numLocal, numSlaves int, timeout time.Duration) *IntCmd {
300 cmd := NewIntCmd(ctx, "waitAOF", numLocal, numSlaves, int(timeout/time.Millisecond))

Callers 15

pubsub_test.goFile · 0.80
ForEachShardMethod · 0.80
ring_test.goFile · 0.80
ForEachMasterMethod · 0.80
ForEachSlaveMethod · 0.80
ForEachShardMethod · 0.80
processPipelineMethod · 0.80
processTxPipelineMethod · 0.80

Calls 2

NewIntCmdFunction · 0.85
setReadTimeoutMethod · 0.80