func GetCurrentGTID(addr *Addr) (string, error) {
	var d *sql.DB
	var gtid string
	var err error
	if d, err = Open(addr); err == nil {
		err = d.QueryRow("SELECT @@global.gtid_executed").Scan(&gtid)
		log.E(d.Close())
	}
	return gtid, err
}
GetCurrentGTID returns current gtid set for the specified db address (host,port,user,password)
package db
import (
	"database/sql"
	"github.com/pkg/errors"
	"github.com/uber/storagetapper/log"
)