diff --git a/docker-compose.yml b/docker-compose.yml index 4438aae..96b6d78 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -5,8 +5,8 @@ services: environment: IS_DOCKER: '1' ports: - - '8080:8080' - - '58080:58080' + - '36789:36789' + - '36790:36790' volumes: - .:/app/work - /etc/localtime:/etc/localtime:ro diff --git a/dtmsvr/dtmsvr.go b/dtmsvr/dtmsvr.go index 206bbb8..be0eac2 100644 --- a/dtmsvr/dtmsvr.go +++ b/dtmsvr/dtmsvr.go @@ -22,8 +22,8 @@ import ( "github.com/yedf/dtm/examples" ) -var dtmsvrPort = 8080 -var dtmsvrGrpcPort = 58080 +var dtmsvrPort = 36789 +var dtmsvrGrpcPort = 36790 var metricsPort = 8889 // StartSvr StartSvr @@ -84,7 +84,7 @@ func updateBranchAsync() { for len(updates) > 0 { dbr := dbGet().Clauses(clause.OnConflict{ OnConstraint: "trans_branch_op_pkey", - DoUpdates: clause.AssignmentColumns([]string{"status", "finish_time","update_time"}), + DoUpdates: clause.AssignmentColumns([]string{"status", "finish_time", "update_time"}), }).Create(updates) dtmimp.Logf("flushed %d branch status to db. affected: %d", len(updates), dbr.RowsAffected) if dbr.Error != nil {