func insertOnUpdateData()

in at/rollback/client/insert_on_update.go [32:53]

19 lines of code
3 McCabe index (conditional complexity)


func insertOnUpdateData(ctx context.Context) (re error) {
	request := gorequest.New()
	log.Infof("branch transaction begin")

	// global transaction will roll back,because insertOnUpdateDataFail
	request.Post(serverIpPort+"/insertOnUpdateDataSuccess").
		Set(constant.XidKey, tm.GetXID(ctx)).
		End(func(response gorequest.Response, body string, errs []error) {
			if response.StatusCode != http.StatusOK {
				re = fmt.Errorf("insert on update data success")
			}
		})

	request.Post(serverIpPort2+"/insertOnUpdateDataFail").
		Set(constant.XidKey, tm.GetXID(ctx)).
		End(func(response gorequest.Response, body string, errs []error) {
			if response.StatusCode != http.StatusOK {
				re = fmt.Errorf("insert on update data fail")
			}
		})
	return
}