func WriteBinlog(bin *binlog.Binlog, clusterID uint64) error {
	commitData, _ := bin.Marshal()
	req := &binlog.WriteBinlogReq{ClusterID: clusterID, Payload: commitData}
	resp, err := PumpClient.WriteBinlog(goctx.Background(), req)
	if err == nil && resp.Errmsg != "" {
		err = errors.New(resp.Errmsg)
	}
	return errors.Trace(err)
}
// WriteBinlog writes a binlog to Pump.
WriteBinlog writes a binlog to Pump.
// WriteBinlog writes a binlog to Pump .
func WriteBinlog(bin *binlog.Binlog, clusterID uint64) error {
	commitData, _ := bin.Marshal()
	req := &binlog.WriteBinlogReq{ClusterID: clusterID, Payload: commitData}
	resp, err := PumpClient.WriteBinlog(goctx.Background(), req)
	if err == nil && resp.Errmsg != "" {
		err = errors.New(resp.Errmsg)
	}
	return errors.Trace(err)
}
func WriteBinlog ( bin * binlog . Binlog , clusterID uint64 ) error { commitData , _ := bin . Marshal ( ) req := & binlog . WriteBinlogReq { ClusterID : clusterID , Payload : commitData } resp , err := PumpClient . WriteBinlog ( goctx . Background ( ) , req ) if err == nil && resp . Errmsg != " " { err = errors . New ( resp . Errmsg ) } return errors . Trace ( err ) }
WriteBinlog writes a binlog to Pump.
WriteBinlog writes a binlog to Pump .