()
| 423 | } |
| 424 | |
| 425 | func ExampleClient_Pipeline() { |
| 426 | pipe := rdb.Pipeline() |
| 427 | |
| 428 | incr := pipe.Incr(ctx, "pipeline_counter") |
| 429 | pipe.Expire(ctx, "pipeline_counter", time.Hour) |
| 430 | |
| 431 | // Execute |
| 432 | // |
| 433 | // INCR pipeline_counter |
| 434 | // EXPIRE pipeline_counts 3600 |
| 435 | // |
| 436 | // using one rdb-server roundtrip. |
| 437 | _, err := pipe.Exec(ctx) |
| 438 | fmt.Println(incr.Val(), err) |
| 439 | // Output: 1 <nil> |
| 440 | } |
| 441 | |
| 442 | func ExampleClient_TxPipelined() { |
| 443 | var incr *redis.IntCmd |