doc_test.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. package test
  2. import (
  3. "app.yhyue.com/moapp/jy_docs/rpc/stdlib/stdlib"
  4. "app.yhyue.com/moapp/jy_docs/rpc/stdlib/stdlibclient"
  5. "context"
  6. "github.com/tal-tech/go-zero/core/discov"
  7. "github.com/tal-tech/go-zero/zrpc"
  8. "log"
  9. "testing"
  10. "time"
  11. )
  12. func Test_DocOn(t *testing.T) {
  13. ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
  14. std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
  15. req := &stdlib.DocChangeReq{Id: "123", Reason: 1}
  16. res, err := std.DocOn(ctx, req)
  17. log.Println("err ", err)
  18. if res.State == true {
  19. log.Println("req true")
  20. } else {
  21. log.Println("req false", res)
  22. }
  23. }
  24. func Test_DocOff(t *testing.T) {
  25. ctx, _ := context.WithTimeout(context.Background(), 120*time.Second)
  26. std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
  27. req := &stdlib.DocChangeReq{Id: "123", Reason: 10}
  28. res, err := std.DocOff(ctx, req)
  29. log.Println("err ", err)
  30. if res.State == true {
  31. log.Println("req true")
  32. } else {
  33. log.Println("req false", res)
  34. }
  35. //log.Println("err ", err)
  36. //log.Println("req ", res)
  37. }