in tcc/gin/client/main.go [33:57]
func main() {
flag.Parse()
client.InitPath("../../../conf/seatago.yml")
bgCtx, cancel := context.WithTimeout(context.Background(), time.Minute*10)
defer cancel()
serverIpPort := "http://127.0.0.1:8080"
tm.WithGlobalTx(
bgCtx,
&tm.GtxConfig{
Name: "TccSampleLocalGlobalTx",
},
func(ctx context.Context) (re error) {
request := gorequest.New()
log.Infof("branch transaction begin")
request.Post(serverIpPort+"/prepare").
Set(constant.XidKey, tm.GetXID(ctx)).
End(func(response gorequest.Response, body string, errs []error) {
if len(errs) != 0 {
re = errs[0]
}
})
return
})
}