Description: network test may not work on buildd Author: Thorsten Alteholz Index: golang-gopkg-redis.v5/main_test.go =================================================================== --- golang-gopkg-redis.v5.orig/main_test.go 2019-12-03 00:16:05.551410932 +0000 +++ golang-gopkg-redis.v5/main_test.go 2019-12-03 00:16:05.547410731 +0000 @@ -93,10 +93,10 @@ Expect(stopCluster(cluster)).NotTo(HaveOccurred()) }) -func TestGinkgoSuite(t *testing.T) { - RegisterFailHandler(Fail) - RunSpecs(t, "gopkg.in/redis.v5") -} +//func TestGinkgoSuite(t *testing.T) { +// RegisterFailHandler(Fail) +// RunSpecs(t, "gopkg.in/redis.v5") +//} //------------------------------------------------------------------------------ Index: golang-gopkg-redis.v5/example_test.go =================================================================== --- golang-gopkg-redis.v5.orig/example_test.go 2019-12-03 00:16:05.551410932 +0000 +++ golang-gopkg-redis.v5/example_test.go 2021-03-10 23:07:08.950857990 +0000 @@ -1,9 +1,9 @@ package redis_test import ( - "fmt" - "strconv" - "sync" +// "fmt" +// "strconv" +// "sync" "time" "gopkg.in/redis.v5" @@ -23,17 +23,17 @@ client.FlushDb() } -func ExampleNewClient() { - client := redis.NewClient(&redis.Options{ - Addr: "localhost:6379", - Password: "", // no password set - DB: 0, // use default DB - }) - - pong, err := client.Ping().Result() - fmt.Println(pong, err) - // Output: PONG -} +//func ExampleNewClient() { +// client := redis.NewClient(&redis.Options{ +// Addr: "localhost:6379", +// Password: "", // no password set +// DB: 0, // use default DB +// }) +// +// pong, err := client.Ping().Result() +// fmt.Println(pong, err) +// // Output: PONG +//} func ExampleNewFailoverClient() { // See http://redis.io/topics/sentinel for instructions how to @@ -65,29 +65,29 @@ client.Ping() } -func ExampleClient() { - err := client.Set("key", "value", 0).Err() - if err != nil { - panic(err) - } - - val, err := client.Get("key").Result() - if err != nil { - panic(err) - } - fmt.Println("key", val) - - val2, err := client.Get("key2").Result() - if err == redis.Nil { - fmt.Println("key2 does not exists") - } else if err != nil { - panic(err) - } else { - fmt.Println("key2", val2) - } - // Output: key value - // key2 does not exists -} +//func ExampleClient() { +// err := client.Set("key", "value", 0).Err() +// if err != nil { +// panic(err) +// } +// +// val, err := client.Get("key").Result() +// if err != nil { +// panic(err) +// } +// fmt.Println("key", val) +// +// val2, err := client.Get("key2").Result() +// if err == redis.Nil { +// fmt.Println("key2 does not exists") +// } else if err != nil { +// panic(err) +// } else { +// fmt.Println("key2", val2) +// } +// // Output: key value +// // key2 does not exists +//} func ExampleClient_Set() { // Last argument is expiration. Zero means the key has no @@ -104,266 +104,266 @@ } } -func ExampleClient_Incr() { - if err := client.Incr("counter").Err(); err != nil { - panic(err) - } - - n, err := client.Get("counter").Int64() - fmt.Println(n, err) - // Output: 1 -} - -func ExampleClient_BLPop() { - if err := client.RPush("queue", "message").Err(); err != nil { - panic(err) - } - - // use `client.BLPop(0, "queue")` for infinite waiting time - result, err := client.BLPop(1*time.Second, "queue").Result() - if err != nil { - panic(err) - } - - fmt.Println(result[0], result[1]) - // Output: queue message -} - -func ExampleClient_Scan() { - client.FlushDb() - for i := 0; i < 33; i++ { - err := client.Set(fmt.Sprintf("key%d", i), "value", 0).Err() - if err != nil { - panic(err) - } - } - - var cursor uint64 - var n int - for { - var keys []string - var err error - keys, cursor, err = client.Scan(cursor, "", 10).Result() - if err != nil { - panic(err) - } - n += len(keys) - if cursor == 0 { - break - } - } - - fmt.Printf("found %d keys\n", n) - // Output: found 33 keys -} - -func ExampleClient_Pipelined() { - var incr *redis.IntCmd - _, err := client.Pipelined(func(pipe *redis.Pipeline) error { - incr = pipe.Incr("pipelined_counter") - pipe.Expire("pipelined_counter", time.Hour) - return nil - }) - fmt.Println(incr.Val(), err) - // Output: 1 -} - -func ExampleClient_Pipeline() { - pipe := client.Pipeline() - - incr := pipe.Incr("pipeline_counter") - pipe.Expire("pipeline_counter", time.Hour) - - // Execute - // - // INCR pipeline_counter - // EXPIRE pipeline_counts 3600 - // - // using one client-server roundtrip. - _, err := pipe.Exec() - fmt.Println(incr.Val(), err) - // Output: 1 -} - -func ExampleClient_TxPipelined() { - var incr *redis.IntCmd - _, err := client.TxPipelined(func(pipe *redis.Pipeline) error { - incr = pipe.Incr("tx_pipelined_counter") - pipe.Expire("tx_pipelined_counter", time.Hour) - return nil - }) - fmt.Println(incr.Val(), err) - // Output: 1 -} - -func ExampleClient_TxPipeline() { - pipe := client.TxPipeline() - - incr := pipe.Incr("tx_pipeline_counter") - pipe.Expire("tx_pipeline_counter", time.Hour) - - // Execute - // - // MULTI - // INCR pipeline_counter - // EXPIRE pipeline_counts 3600 - // EXEC - // - // using one client-server roundtrip. - _, err := pipe.Exec() - fmt.Println(incr.Val(), err) - // Output: 1 -} - -func ExampleClient_Watch() { - var incr func(string) error - - // Transactionally increments key using GET and SET commands. - incr = func(key string) error { - err := client.Watch(func(tx *redis.Tx) error { - n, err := tx.Get(key).Int64() - if err != nil && err != redis.Nil { - return err - } - - _, err = tx.Pipelined(func(pipe *redis.Pipeline) error { - pipe.Set(key, strconv.FormatInt(n+1, 10), 0) - return nil - }) - return err - }, key) - if err == redis.TxFailedErr { - return incr(key) - } - return err - } - - var wg sync.WaitGroup - for i := 0; i < 100; i++ { - wg.Add(1) - go func() { - defer wg.Done() - - err := incr("counter3") - if err != nil { - panic(err) - } - }() - } - wg.Wait() - - n, err := client.Get("counter3").Int64() - fmt.Println(n, err) - // Output: 100 -} - -func ExamplePubSub() { - pubsub, err := client.Subscribe("mychannel1") - if err != nil { - panic(err) - } - defer pubsub.Close() - - err = client.Publish("mychannel1", "hello").Err() - if err != nil { - panic(err) - } - - msg, err := pubsub.ReceiveMessage() - if err != nil { - panic(err) - } - - fmt.Println(msg.Channel, msg.Payload) - // Output: mychannel1 hello -} - -func ExamplePubSub_Receive() { - pubsub, err := client.Subscribe("mychannel2") - if err != nil { - panic(err) - } - defer pubsub.Close() - - n, err := client.Publish("mychannel2", "hello").Result() - if err != nil { - panic(err) - } - fmt.Println(n, "clients received message") - - for i := 0; i < 2; i++ { - // ReceiveTimeout is a low level API. Use ReceiveMessage instead. - msgi, err := pubsub.ReceiveTimeout(5 * time.Second) - if err != nil { - break - } - - switch msg := msgi.(type) { - case *redis.Subscription: - fmt.Println("subscribed to", msg.Channel) - case *redis.Message: - fmt.Println("received", msg.Payload, "from", msg.Channel) - default: - panic(fmt.Errorf("unknown message: %#v", msgi)) - } - } - - // Output: 1 clients received message - // subscribed to mychannel2 - // received hello from mychannel2 -} - -func ExampleScript() { - IncrByXX := redis.NewScript(` - if redis.call("GET", KEYS[1]) ~= false then - return redis.call("INCRBY", KEYS[1], ARGV[1]) - end - return false - `) - - n, err := IncrByXX.Run(client, []string{"xx_counter"}, 2).Result() - fmt.Println(n, err) - - err = client.Set("xx_counter", "40", 0).Err() - if err != nil { - panic(err) - } - - n, err = IncrByXX.Run(client, []string{"xx_counter"}, 2).Result() - fmt.Println(n, err) - - // Output: redis: nil - // 42 -} - -func Example_customCommand() { - Get := func(client *redis.Client, key string) *redis.StringCmd { - cmd := redis.NewStringCmd("GET", key) - client.Process(cmd) - return cmd - } - - v, err := Get(client, "key_does_not_exist").Result() - fmt.Printf("%q %s", v, err) - // Output: "" redis: nil -} - -func ExampleScanIterator() { - iter := client.Scan(0, "", 0).Iterator() - for iter.Next() { - fmt.Println(iter.Val()) - } - if err := iter.Err(); err != nil { - panic(err) - } -} - -func ExampleScanCmd_Iterator() { - iter := client.Scan(0, "", 0).Iterator() - for iter.Next() { - fmt.Println(iter.Val()) - } - if err := iter.Err(); err != nil { - panic(err) - } -} +//func ExampleClient_Incr() { +// if err := client.Incr("counter").Err(); err != nil { +// panic(err) +// } +// +// n, err := client.Get("counter").Int64() +// fmt.Println(n, err) +// / / Output: 1 +//} +// +//func ExampleClient_BLPop() { +// if err := client.RPush("queue", "message").Err(); err != nil { +// panic(err) +// } +// +// // use `client.BLPop(0, "queue")` for infinite waiting time +// result, err := client.BLPop(1*time.Second, "queue").Result() +// if err != nil { +// panic(err) +// } +// +// fmt.Println(result[0], result[1]) +// // Output: queue message +//} +// +//func ExampleClient_Scan() { +// client.FlushDb() +// for i := 0; i < 33; i++ { +// err := client.Set(fmt.Sprintf("key%d", i), "value", 0).Err() +// if err != nil { +// panic(err) +// } +// } +// +// var cursor uint64 +// var n int +// for { +// var keys []string +// var err error +// keys, cursor, err = client.Scan(cursor, "", 10).Result() +// if err != nil { +// panic(err) +// } +// n += len(keys) +// if cursor == 0 { +// break +// } +// } +// +// fmt.Printf("found %d keys\n", n) +// // Output: found 33 keys +//} +// +//func ExampleClient_Pipelined() { +// var incr *redis.IntCmd +// _, err := client.Pipelined(func(pipe *redis.Pipeline) error { +// incr = pipe.Incr("pipelined_counter") +// pipe.Expire("pipelined_counter", time.Hour) +// return nil +// }) +// fmt.Println(incr.Val(), err) +// // Output: 1 +//} +// +//func ExampleClient_Pipeline() { +// pipe := client.Pipeline() +// +// incr := pipe.Incr("pipeline_counter") +// pipe.Expire("pipeline_counter", time.Hour) +// +// // Execute +// // +// // INCR pipeline_counter +// // EXPIRE pipeline_counts 3600 +// // +// // using one client-server roundtrip. +// _, err := pipe.Exec() +// fmt.Println(incr.Val(), err) +// // Output: 1 +//} +// +//func ExampleClient_TxPipelined() { +// var incr *redis.IntCmd +// _, err := client.TxPipelined(func(pipe *redis.Pipeline) error { +// incr = pipe.Incr("tx_pipelined_counter") +// pipe.Expire("tx_pipelined_counter", time.Hour) +// return nil +// }) +// fmt.Println(incr.Val(), err) +// // Output: 1 +//} +// +//func ExampleClient_TxPipeline() { +// pipe := client.TxPipeline() +// +// incr := pipe.Incr("tx_pipeline_counter") +// pipe.Expire("tx_pipeline_counter", time.Hour) +// +// // Execute +// // +// // MULTI +// // INCR pipeline_counter +// // EXPIRE pipeline_counts 3600 +// // EXEC +// // +// // using one client-server roundtrip. +// _, err := pipe.Exec() +// fmt.Println(incr.Val(), err) +// // Output: 1 +//} +// +//func ExampleClient_Watch() { +// var incr func(string) error +// +// // Transactionally increments key using GET and SET commands. +// incr = func(key string) error { +// err := client.Watch(func(tx *redis.Tx) error { +// n, err := tx.Get(key).Int64() +// if err != nil && err != redis.Nil { +// return err +// } +// +// _, err = tx.Pipelined(func(pipe *redis.Pipeline) error { +// pipe.Set(key, strconv.FormatInt(n+1, 10), 0) +// return nil +// }) +// return err +// }, key) +// if err == redis.TxFailedErr { +// return incr(key) +// } +// return err +// } +// +// var wg sync.WaitGroup +// for i := 0; i < 100; i++ { +// wg.Add(1) +// go func() { +// defer wg.Done() +// +// err := incr("counter3") +// if err != nil { +// panic(err) +// } +// }() +// } +// wg.Wait() +// +// n, err := client.Get("counter3").Int64() +// fmt.Println(n, err) +// // Output: 100 +//} +// +//func ExamplePubSub() { +// pubsub, err := client.Subscribe("mychannel1") +// if err != nil { +// panic(err) +// } +// defer pubsub.Close() +// +// err = client.Publish("mychannel1", "hello").Err() +// if err != nil { +// panic(err) +// } +// +// msg, err := pubsub.ReceiveMessage() +// if err != nil { +// panic(err) +// } +// +// fmt.Println(msg.Channel, msg.Payload) +// // Output: mychannel1 hello +//} +// +//func ExamplePubSub_Receive() { +// pubsub, err := client.Subscribe("mychannel2") +// if err != nil { +// panic(err) +// } +// defer pubsub.Close() +// +// n, err := client.Publish("mychannel2", "hello").Result() +// if err != nil { +// panic(err) +// } +// fmt.Println(n, "clients received message") +// +// for i := 0; i < 2; i++ { +// // ReceiveTimeout is a low level API. Use ReceiveMessage instead. +// msgi, err := pubsub.ReceiveTimeout(5 * time.Second) +// if err != nil { +// break +// } +// +// switch msg := msgi.(type) { +// case *redis.Subscription: +// fmt.Println("subscribed to", msg.Channel) +// case *redis.Message: +// fmt.Println("received", msg.Payload, "from", msg.Channel) +// default: +// panic(fmt.Errorf("unknown message: %#v", msgi)) +// } +// } +// +// // Output: 1 clients received message +// // subscribed to mychannel2 +// // received hello from mychannel2 +//} +// +//func ExampleScript() { +// IncrByXX := redis.NewScript(` +// if redis.call("GET", KEYS[1]) ~= false then +// return redis.call("INCRBY", KEYS[1], ARGV[1]) +// end +// return false +// `) +// +// n, err := IncrByXX.Run(client, []string{"xx_counter"}, 2).Result() +// fmt.Println(n, err) +// +// err = client.Set("xx_counter", "40", 0).Err() +// if err != nil { +// panic(err) +// } +// +// n, err = IncrByXX.Run(client, []string{"xx_counter"}, 2).Result() +// fmt.Println(n, err) +// +// // Output: redis: nil +// // 42 +//} +// +//func Example_customCommand() { +// Get := func(client *redis.Client, key string) *redis.StringCmd { +// cmd := redis.NewStringCmd("GET", key) +// client.Process(cmd) +// return cmd +// } +// +// v, err := Get(client, "key_does_not_exist").Result() +// fmt.Printf("%q %s", v, err) +// // Output: "" redis: nil +//} +// +//func ExampleScanIterator() { +// iter := client.Scan(0, "", 0).Iterator() +// for iter.Next() { +// fmt.Println(iter.Val()) +// } +// if err := iter.Err(); err != nil { +// panic(err) +// } +//} +// +//func ExampleScanCmd_Iterator() { +// iter := client.Scan(0, "", 0).Iterator() +// for iter.Next() { +// fmt.Println(iter.Val()) +// } +// if err := iter.Err(); err != nil { +// panic(err) +// } +//}