feat: add vtadmin api command

Signed-off-by: Manan Gupta <[email protected]>

go/test/endtoend/transaction/twopc/main_test.go

@@ -108,6 +108,11 @@ func TestMain(m *testing.M) {
 		vtParams = clusterInstance.GetVTParams(keyspaceName)
 		vtgateGrpcAddress = fmt.Sprintf("%s:%d", clusterInstance.Hostname, clusterInstance.VtgateGrpcPort)
 
+		clusterInstance.NewVTAdminProcess()
+		if err := clusterInstance.VtadminProcess.Setup(); err != nil {
+			return 1
+		}
+
 		// create mysql instance and connection parameters
 		conn, closer, err := utils.NewMySQL(clusterInstance, keyspaceName, SchemaSQL)
 		if err != nil {

go/test/endtoend/transaction/twopc/twopc_test.go

@@ -22,6 +22,7 @@ import (
 	"fmt"
 	"reflect"
 	"sort"
+	"strconv"
 	"strings"
 	"sync"
 	"testing"
@@ -1428,6 +1429,12 @@ func TestReadTransactionStatus(t *testing.T) {
 	require.Contains(t, out, "insert into twopc_t1(id, col) values (9, 4)")
 	require.Contains(t, out, unresTransaction.Dtid)
 
+	// Read the data from vtadmin API, and verify that too has the same information.
+	apiRes := clusterInstance.VtadminProcess.MakeAPICallRetry(t, fmt.Sprintf("/api/transaction/local/%v/info", unresTransaction.Dtid))
+	require.Contains(t, apiRes, "insert into twopc_t1(id, col) values (9, 4)")
+	require.Contains(t, apiRes, unresTransaction.Dtid)
+	require.Contains(t, apiRes, strconv.FormatInt(res.TimeCreated, 10))
+
 	// Wait for the commit to have returned.
 	wg.Wait()
 }