Add BridgeGRpcClient (#19546)

Author: mregrock

.github/last_commit.txt

@@ -1 +1 @@
-693a9330006deec1f2ced3ef39abf3db14e13fc4
+032168beb3fb711566abaf1469b1d154c87edb14

src/api/grpc/draft/ydb_bridge_v1.proto

@@ -0,0 +1,22 @@
+syntax = "proto3";
+
+package Ydb.Bridge.V1;
+
+option java_package = "com.yandex.ydb.bridge.v1";
+option java_outer_classname = "BridgeGrpc";
+option java_multiple_files = true;
+
+import "src/api/protos/draft/ydb_bridge.proto";
+
+// Service for managing cluster in bridge mode
+service BridgeService {
+
+    // Get current cluster state
+    // Useful for monitoring and decision-making before state changes
+    rpc GetClusterState(Ydb.Bridge.GetClusterStateRequest) returns (Ydb.Bridge.GetClusterStateResponse);
+
+    // Update cluster state by providing a list of desired pile states
+    // This is the main operation for failover and promotion scenarios
+    rpc UpdateClusterState(Ydb.Bridge.UpdateClusterStateRequest) returns (Ydb.Bridge.UpdateClusterStateResponse);
+
+}

src/api/protos/draft/ydb_bridge.proto

@@ -0,0 +1,51 @@
+syntax = "proto3";
+option cc_enable_arenas = true;
+
+package Ydb.Bridge;
+
+option java_package = "com.yandex.ydb.bridge.proto";
+option java_outer_classname = "BridgeProtos";
+option java_multiple_files = true;
+
+import "src/api/protos/ydb_operation.proto";
+
+// State of a pile in relation to primary
+enum PileState {
+    DISCONNECTED = 0; // disconnected from the cluster (no connectivity to other piles)
+    NOT_SYNCHRONIZED = 1; // not synchronized with primary, cannot be promoted
+    SYNCHRONIZED = 2; // fully synchronized with primary, may be promoted
+    PROMOTE = 3; // pile is being promoted to primary
+    PRIMARY = 4; // pile is primary
+}
+
+// Pair of pile id and pile state
+message PileStateUpdate {
+    uint32 pile_id = 1;
+    PileState state = 2;
+}
+
+message GetClusterStateRequest {
+    Ydb.Operations.OperationParams operation_params = 1;
+}
+
+message GetClusterStateResponse {
+    Ydb.Operations.Operation operation = 1;
+}
+
+message GetClusterStateResult {
+    // Current cluster state
+    repeated PileStateUpdate per_pile_state = 1;
+}
+
+message UpdateClusterStateRequest {
+    Ydb.Operations.OperationParams operation_params = 1;
+    // List of desired pile states to update
+    repeated PileStateUpdate updates = 2;
+}
+
+message UpdateClusterStateResponse {
+    Ydb.Operations.Operation operation = 1;
+}
+
+message UpdateClusterStateResult {
+}