|
@@ -30,13 +30,15 @@ func main() {
|
|
|
})
|
|
|
client.Ping(ctx)
|
|
|
for i := 0; i < *messageCount; i++ {
|
|
|
+ start := time.Now()
|
|
|
misses := client.PoolStats().Misses
|
|
|
_, err := client.Set(ctx, "DTM", "DTM", 0).Result()
|
|
|
+ elapsed := time.Since(start)
|
|
|
if err != nil {
|
|
|
fmt.Println(err)
|
|
|
}
|
|
|
if client.PoolStats().Misses > misses {
|
|
|
- fmt.Println("Failover")
|
|
|
+ fmt.Printf("Failover: Client took %d ms to complete operation %+v\n", elapsed.Milliseconds(), client.PoolStats())
|
|
|
}
|
|
|
|
|
|
}
|