@@ -304,20 +304,20 @@ var _ = Describe("Redis Ring", func() {
304
304
ring = redis .NewRing (opt )
305
305
})
306
306
It ("supports Process hook" , func () {
307
- err := ring .Ping (ctx ).Err ()
307
+ err := ring .Set (ctx , "key" , "test" , 0 ).Err ()
308
308
Expect (err ).NotTo (HaveOccurred ())
309
309
310
310
var stack []string
311
311
312
312
ring .AddHook (& hook {
313
313
processHook : func (hook redis.ProcessHook ) redis.ProcessHook {
314
314
return func (ctx context.Context , cmd redis.Cmder ) error {
315
- Expect (cmd .String ()).To (Equal ("ping : " ))
315
+ Expect (cmd .String ()).To (Equal ("get key : " ))
316
316
stack = append (stack , "ring.BeforeProcess" )
317
317
318
318
err := hook (ctx , cmd )
319
319
320
- Expect (cmd .String ()).To (Equal ("ping: PONG " ))
320
+ Expect (cmd .String ()).To (Equal ("get key: test " ))
321
321
stack = append (stack , "ring.AfterProcess" )
322
322
323
323
return err
@@ -329,12 +329,12 @@ var _ = Describe("Redis Ring", func() {
329
329
shard .AddHook (& hook {
330
330
processHook : func (hook redis.ProcessHook ) redis.ProcessHook {
331
331
return func (ctx context.Context , cmd redis.Cmder ) error {
332
- Expect (cmd .String ()).To (Equal ("ping : " ))
332
+ Expect (cmd .String ()).To (Equal ("get key : " ))
333
333
stack = append (stack , "shard.BeforeProcess" )
334
334
335
335
err := hook (ctx , cmd )
336
336
337
- Expect (cmd .String ()).To (Equal ("ping: PONG " ))
337
+ Expect (cmd .String ()).To (Equal ("get key: test " ))
338
338
stack = append (stack , "shard.AfterProcess" )
339
339
340
340
return err
@@ -344,7 +344,7 @@ var _ = Describe("Redis Ring", func() {
344
344
return nil
345
345
})
346
346
347
- err = ring .Ping (ctx ).Err ()
347
+ err = ring .Get (ctx , "key" ).Err ()
348
348
Expect (err ).NotTo (HaveOccurred ())
349
349
Expect (stack ).To (Equal ([]string {
350
350
"ring.BeforeProcess" ,
0 commit comments