mirror of
https://github.com/injoyai/tdx.git
synced 2025-11-26 21:25:35 +08:00
增加DialWith的示例
This commit is contained in:
@@ -6,14 +6,22 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func Test(f func(c *tdx.Client)) {
|
func Test(f func(c *tdx.Client)) {
|
||||||
for _, v := range tdx.Hosts {
|
|
||||||
c, err := tdx.Dial(v, tdx.WithDebug())
|
//重连方式1,优点,同一个客户端指针
|
||||||
if err != nil {
|
c, err := tdx.DialWith(tdx.NewHostDial(tdx.Hosts, 0), tdx.WithDebug())
|
||||||
logs.PrintErr(err)
|
logs.PanicErr(err)
|
||||||
continue
|
f(c)
|
||||||
}
|
<-c.Done()
|
||||||
f(c)
|
|
||||||
<-c.Done()
|
//重连方式2
|
||||||
break
|
//for _, v := range tdx.Hosts {
|
||||||
}
|
// c, err := tdx.DialWith(v, tdx.WithDebug())
|
||||||
|
// if err != nil {
|
||||||
|
// logs.PrintErr(err)
|
||||||
|
// continue
|
||||||
|
// }
|
||||||
|
// f(c)
|
||||||
|
// <-c.Done()
|
||||||
|
// break
|
||||||
|
//}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user