({ clusterID: '', keyspace: '' });
+
+ const selectedKeyspace = keyspaces.find(
+ (ks) => ks.keyspace?.name === params.keyspace && ks.cluster?.id === params.clusterID
+ );
+
+ const transactionsQuery = useTransactions(params, {
+ enabled: !!params.keyspace,
+ });
+
+ const transactions =
+ (transactionsQuery.data && orderBy(transactionsQuery.data.transactions, ['time_created'], 'asc')) || [];
+
+ const renderRows = (rows: query.ITransactionMetadata[]) => {
+ return rows.map((row) => {
+ return (
+
+
+ {row.dtid}
+
+
+ {formatTransactionState(row)}
+
+
+ {row.participants?.map((participant) => {
+ const shard = `${participant.keyspace}/${participant.shard}`;
+ return (
+
+ {shard}
+
+ );
+ })}
+
+
+ {formatDateTime(row.time_created)}
+
+ {formatRelativeTimeInSeconds(row.time_created)}
+
+
+
+ );
+ });
+ };
+
+ return (
+
+
+ In Flight Distributed Transactions
+
+
+
+
+
+ );
+};
diff --git a/web/vtadmin/src/hooks/api.ts b/web/vtadmin/src/hooks/api.ts
index f3772ed4ab0..c60888ef154 100644
--- a/web/vtadmin/src/hooks/api.ts
+++ b/web/vtadmin/src/hooks/api.ts
@@ -81,6 +81,8 @@ import {
ValidateVersionShardParams,
startWorkflow,
stopWorkflow,
+ FetchTransactionsParams,
+ fetchTransactions,
} from '../api/http';
import { vtadmin as pb, vtctldata } from '../proto/vtadmin';
import { formatAlias } from '../util/tablets';
@@ -405,6 +407,16 @@ export const useVSchema = (params: FetchVSchemaParams, options?: UseQueryOptions
return useQuery(['vschema', params], () => fetchVSchema(params));
};
+/**
+ * useTransactions is a query hook that fetches unresolved transactions for the given keyspace.
+ */
+export const useTransactions = (
+ params: FetchTransactionsParams,
+ options?: UseQueryOptions | undefined
+) => {
+ return useQuery(['transactions', params], () => fetchTransactions(params), { ...options });
+};
+
export const useVTExplain = (
params: Parameters[0],
options?: UseQueryOptions | undefined
diff --git a/web/vtadmin/src/proto/vtadmin.d.ts b/web/vtadmin/src/proto/vtadmin.d.ts
index f621e6b0996..f4a9e104daf 100644
--- a/web/vtadmin/src/proto/vtadmin.d.ts
+++ b/web/vtadmin/src/proto/vtadmin.d.ts
@@ -443,6 +443,20 @@ export namespace vtadmin {
*/
public getTopologyPath(request: vtadmin.IGetTopologyPathRequest): Promise;
+ /**
+ * Calls GetUnresolvedTransactions.
+ * @param request GetUnresolvedTransactionsRequest message or plain object
+ * @param callback Node-style callback called with the error, if any, and GetUnresolvedTransactionsResponse
+ */
+ public getUnresolvedTransactions(request: vtadmin.IGetUnresolvedTransactionsRequest, callback: vtadmin.VTAdmin.GetUnresolvedTransactionsCallback): void;
+
+ /**
+ * Calls GetUnresolvedTransactions.
+ * @param request GetUnresolvedTransactionsRequest message or plain object
+ * @returns Promise
+ */
+ public getUnresolvedTransactions(request: vtadmin.IGetUnresolvedTransactionsRequest): Promise;
+
/**
* Calls GetVSchema.
* @param request GetVSchemaRequest message or plain object
@@ -1090,6 +1104,13 @@ export namespace vtadmin {
*/
type GetTopologyPathCallback = (error: (Error|null), response?: vtctldata.GetTopologyPathResponse) => void;
+ /**
+ * Callback as used by {@link vtadmin.VTAdmin#getUnresolvedTransactions}.
+ * @param error Error, if any
+ * @param [response] GetUnresolvedTransactionsResponse
+ */
+ type GetUnresolvedTransactionsCallback = (error: (Error|null), response?: vtctldata.GetUnresolvedTransactionsResponse) => void;
+
/**
* Callback as used by {@link vtadmin.VTAdmin#getVSchema}.
* @param error Error, if any
@@ -8073,6 +8094,109 @@ export namespace vtadmin {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a GetUnresolvedTransactionsRequest. */
+ interface IGetUnresolvedTransactionsRequest {
+
+ /** GetUnresolvedTransactionsRequest cluster_id */
+ cluster_id?: (string|null);
+
+ /** GetUnresolvedTransactionsRequest keyspace */
+ keyspace?: (string|null);
+ }
+
+ /** Represents a GetUnresolvedTransactionsRequest. */
+ class GetUnresolvedTransactionsRequest implements IGetUnresolvedTransactionsRequest {
+
+ /**
+ * Constructs a new GetUnresolvedTransactionsRequest.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtadmin.IGetUnresolvedTransactionsRequest);
+
+ /** GetUnresolvedTransactionsRequest cluster_id. */
+ public cluster_id: string;
+
+ /** GetUnresolvedTransactionsRequest keyspace. */
+ public keyspace: string;
+
+ /**
+ * Creates a new GetUnresolvedTransactionsRequest instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns GetUnresolvedTransactionsRequest instance
+ */
+ public static create(properties?: vtadmin.IGetUnresolvedTransactionsRequest): vtadmin.GetUnresolvedTransactionsRequest;
+
+ /**
+ * Encodes the specified GetUnresolvedTransactionsRequest message. Does not implicitly {@link vtadmin.GetUnresolvedTransactionsRequest.verify|verify} messages.
+ * @param message GetUnresolvedTransactionsRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtadmin.IGetUnresolvedTransactionsRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified GetUnresolvedTransactionsRequest message, length delimited. Does not implicitly {@link vtadmin.GetUnresolvedTransactionsRequest.verify|verify} messages.
+ * @param message GetUnresolvedTransactionsRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtadmin.IGetUnresolvedTransactionsRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a GetUnresolvedTransactionsRequest message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns GetUnresolvedTransactionsRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtadmin.GetUnresolvedTransactionsRequest;
+
+ /**
+ * Decodes a GetUnresolvedTransactionsRequest message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns GetUnresolvedTransactionsRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtadmin.GetUnresolvedTransactionsRequest;
+
+ /**
+ * Verifies a GetUnresolvedTransactionsRequest message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a GetUnresolvedTransactionsRequest message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns GetUnresolvedTransactionsRequest
+ */
+ public static fromObject(object: { [k: string]: any }): vtadmin.GetUnresolvedTransactionsRequest;
+
+ /**
+ * Creates a plain object from a GetUnresolvedTransactionsRequest message. Also converts values to other types if specified.
+ * @param message GetUnresolvedTransactionsRequest
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtadmin.GetUnresolvedTransactionsRequest, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this GetUnresolvedTransactionsRequest to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for GetUnresolvedTransactionsRequest
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of a GetVSchemaRequest. */
interface IGetVSchemaRequest {
diff --git a/web/vtadmin/src/proto/vtadmin.js b/web/vtadmin/src/proto/vtadmin.js
index 1d789b297c7..f2ecaae8334 100644
--- a/web/vtadmin/src/proto/vtadmin.js
+++ b/web/vtadmin/src/proto/vtadmin.js
@@ -1038,6 +1038,39 @@ export const vtadmin = $root.vtadmin = (() => {
* @variation 2
*/
+ /**
+ * Callback as used by {@link vtadmin.VTAdmin#getUnresolvedTransactions}.
+ * @memberof vtadmin.VTAdmin
+ * @typedef GetUnresolvedTransactionsCallback
+ * @type {function}
+ * @param {Error|null} error Error, if any
+ * @param {vtctldata.GetUnresolvedTransactionsResponse} [response] GetUnresolvedTransactionsResponse
+ */
+
+ /**
+ * Calls GetUnresolvedTransactions.
+ * @function getUnresolvedTransactions
+ * @memberof vtadmin.VTAdmin
+ * @instance
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest} request GetUnresolvedTransactionsRequest message or plain object
+ * @param {vtadmin.VTAdmin.GetUnresolvedTransactionsCallback} callback Node-style callback called with the error, if any, and GetUnresolvedTransactionsResponse
+ * @returns {undefined}
+ * @variation 1
+ */
+ Object.defineProperty(VTAdmin.prototype.getUnresolvedTransactions = function getUnresolvedTransactions(request, callback) {
+ return this.rpcCall(getUnresolvedTransactions, $root.vtadmin.GetUnresolvedTransactionsRequest, $root.vtctldata.GetUnresolvedTransactionsResponse, request, callback);
+ }, "name", { value: "GetUnresolvedTransactions" });
+
+ /**
+ * Calls GetUnresolvedTransactions.
+ * @function getUnresolvedTransactions
+ * @memberof vtadmin.VTAdmin
+ * @instance
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest} request GetUnresolvedTransactionsRequest message or plain object
+ * @returns {Promise} Promise
+ * @variation 2
+ */
+
/**
* Callback as used by {@link vtadmin.VTAdmin#getVSchema}.
* @memberof vtadmin.VTAdmin
@@ -18227,6 +18260,233 @@ export const vtadmin = $root.vtadmin = (() => {
return GetTopologyPathRequest;
})();
+ vtadmin.GetUnresolvedTransactionsRequest = (function() {
+
+ /**
+ * Properties of a GetUnresolvedTransactionsRequest.
+ * @memberof vtadmin
+ * @interface IGetUnresolvedTransactionsRequest
+ * @property {string|null} [cluster_id] GetUnresolvedTransactionsRequest cluster_id
+ * @property {string|null} [keyspace] GetUnresolvedTransactionsRequest keyspace
+ */
+
+ /**
+ * Constructs a new GetUnresolvedTransactionsRequest.
+ * @memberof vtadmin
+ * @classdesc Represents a GetUnresolvedTransactionsRequest.
+ * @implements IGetUnresolvedTransactionsRequest
+ * @constructor
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest=} [properties] Properties to set
+ */
+ function GetUnresolvedTransactionsRequest(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * GetUnresolvedTransactionsRequest cluster_id.
+ * @member {string} cluster_id
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @instance
+ */
+ GetUnresolvedTransactionsRequest.prototype.cluster_id = "";
+
+ /**
+ * GetUnresolvedTransactionsRequest keyspace.
+ * @member {string} keyspace
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @instance
+ */
+ GetUnresolvedTransactionsRequest.prototype.keyspace = "";
+
+ /**
+ * Creates a new GetUnresolvedTransactionsRequest instance using the specified properties.
+ * @function create
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest=} [properties] Properties to set
+ * @returns {vtadmin.GetUnresolvedTransactionsRequest} GetUnresolvedTransactionsRequest instance
+ */
+ GetUnresolvedTransactionsRequest.create = function create(properties) {
+ return new GetUnresolvedTransactionsRequest(properties);
+ };
+
+ /**
+ * Encodes the specified GetUnresolvedTransactionsRequest message. Does not implicitly {@link vtadmin.GetUnresolvedTransactionsRequest.verify|verify} messages.
+ * @function encode
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest} message GetUnresolvedTransactionsRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ GetUnresolvedTransactionsRequest.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.cluster_id != null && Object.hasOwnProperty.call(message, "cluster_id"))
+ writer.uint32(/* id 1, wireType 2 =*/10).string(message.cluster_id);
+ if (message.keyspace != null && Object.hasOwnProperty.call(message, "keyspace"))
+ writer.uint32(/* id 2, wireType 2 =*/18).string(message.keyspace);
+ return writer;
+ };
+
+ /**
+ * Encodes the specified GetUnresolvedTransactionsRequest message, length delimited. Does not implicitly {@link vtadmin.GetUnresolvedTransactionsRequest.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {vtadmin.IGetUnresolvedTransactionsRequest} message GetUnresolvedTransactionsRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ GetUnresolvedTransactionsRequest.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a GetUnresolvedTransactionsRequest message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtadmin.GetUnresolvedTransactionsRequest} GetUnresolvedTransactionsRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ GetUnresolvedTransactionsRequest.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtadmin.GetUnresolvedTransactionsRequest();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.cluster_id = reader.string();
+ break;
+ }
+ case 2: {
+ message.keyspace = reader.string();
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a GetUnresolvedTransactionsRequest message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtadmin.GetUnresolvedTransactionsRequest} GetUnresolvedTransactionsRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ GetUnresolvedTransactionsRequest.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a GetUnresolvedTransactionsRequest message.
+ * @function verify
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ GetUnresolvedTransactionsRequest.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ if (message.cluster_id != null && message.hasOwnProperty("cluster_id"))
+ if (!$util.isString(message.cluster_id))
+ return "cluster_id: string expected";
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ if (!$util.isString(message.keyspace))
+ return "keyspace: string expected";
+ return null;
+ };
+
+ /**
+ * Creates a GetUnresolvedTransactionsRequest message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtadmin.GetUnresolvedTransactionsRequest} GetUnresolvedTransactionsRequest
+ */
+ GetUnresolvedTransactionsRequest.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtadmin.GetUnresolvedTransactionsRequest)
+ return object;
+ let message = new $root.vtadmin.GetUnresolvedTransactionsRequest();
+ if (object.cluster_id != null)
+ message.cluster_id = String(object.cluster_id);
+ if (object.keyspace != null)
+ message.keyspace = String(object.keyspace);
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a GetUnresolvedTransactionsRequest message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {vtadmin.GetUnresolvedTransactionsRequest} message GetUnresolvedTransactionsRequest
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ GetUnresolvedTransactionsRequest.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.defaults) {
+ object.cluster_id = "";
+ object.keyspace = "";
+ }
+ if (message.cluster_id != null && message.hasOwnProperty("cluster_id"))
+ object.cluster_id = message.cluster_id;
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ object.keyspace = message.keyspace;
+ return object;
+ };
+
+ /**
+ * Converts this GetUnresolvedTransactionsRequest to JSON.
+ * @function toJSON
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ GetUnresolvedTransactionsRequest.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for GetUnresolvedTransactionsRequest
+ * @function getTypeUrl
+ * @memberof vtadmin.GetUnresolvedTransactionsRequest
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ GetUnresolvedTransactionsRequest.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtadmin.GetUnresolvedTransactionsRequest";
+ };
+
+ return GetUnresolvedTransactionsRequest;
+ })();
+
vtadmin.GetVSchemaRequest = (function() {
/**
diff --git a/web/vtadmin/src/util/time.ts b/web/vtadmin/src/util/time.ts
index c9f0017d011..82703d60281 100644
--- a/web/vtadmin/src/util/time.ts
+++ b/web/vtadmin/src/util/time.ts
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-import * as dayjs from 'dayjs';
+import dayjs from 'dayjs';
import localizedFormat from 'dayjs/plugin/localizedFormat';
import relativeTime from 'dayjs/plugin/relativeTime';
@@ -44,3 +44,11 @@ export const formatRelativeTime = (timestamp: number | Long | null | undefined):
export const formatDateTimeShort = (timestamp: number | Long | null | undefined): string | null => {
return format(timestamp, 'MM/DD/YY HH:mm:ss Z');
};
+
+export const formatRelativeTimeInSeconds = (timestamp: number | Long | null | undefined): string | null => {
+ const u = parse(timestamp);
+ if (!u) return null;
+ const currentTime = dayjs();
+ const secondsElapsed = currentTime.diff(u, 'second');
+ return `${secondsElapsed} seconds ago`;
+};
diff --git a/web/vtadmin/src/util/transactions.ts b/web/vtadmin/src/util/transactions.ts
new file mode 100644
index 00000000000..10d18cb6173
--- /dev/null
+++ b/web/vtadmin/src/util/transactions.ts
@@ -0,0 +1,28 @@
+/**
+ * Copyright 2024 The Vitess Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import { invertBy } from 'lodash-es';
+import { query } from '../proto/vtadmin';
+
+/**
+ * TRANSACTION_STATES maps numeric transaction state back to human readable strings.
+ */
+export const TRANSACTION_STATES = Object.entries(invertBy(query.TransactionState)).reduce((acc, [k, vs]) => {
+ acc[k] = vs[0];
+ return acc;
+}, {} as { [k: string]: string });
+
+export const formatTransactionState = (transaction: query.ITransactionMetadata) =>
+ transaction.state && TRANSACTION_STATES[transaction.state];