1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/datastore/admin/v1/migration.proto 20 21package admin 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 28 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 29) 30 31const ( 32 // Verify that this generated code is sufficiently up-to-date. 33 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 34 // Verify that runtime/protoimpl is sufficiently up-to-date. 35 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 36) 37 38// States for a migration. 39type MigrationState int32 40 41const ( 42 // Unspecified. 43 MigrationState_MIGRATION_STATE_UNSPECIFIED MigrationState = 0 44 // The migration is running. 45 MigrationState_RUNNING MigrationState = 1 46 // The migration is paused. 47 MigrationState_PAUSED MigrationState = 2 48 // The migration is complete. 49 MigrationState_COMPLETE MigrationState = 3 50) 51 52// Enum value maps for MigrationState. 53var ( 54 MigrationState_name = map[int32]string{ 55 0: "MIGRATION_STATE_UNSPECIFIED", 56 1: "RUNNING", 57 2: "PAUSED", 58 3: "COMPLETE", 59 } 60 MigrationState_value = map[string]int32{ 61 "MIGRATION_STATE_UNSPECIFIED": 0, 62 "RUNNING": 1, 63 "PAUSED": 2, 64 "COMPLETE": 3, 65 } 66) 67 68func (x MigrationState) Enum() *MigrationState { 69 p := new(MigrationState) 70 *p = x 71 return p 72} 73 74func (x MigrationState) String() string { 75 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 76} 77 78func (MigrationState) Descriptor() protoreflect.EnumDescriptor { 79 return file_google_datastore_admin_v1_migration_proto_enumTypes[0].Descriptor() 80} 81 82func (MigrationState) Type() protoreflect.EnumType { 83 return &file_google_datastore_admin_v1_migration_proto_enumTypes[0] 84} 85 86func (x MigrationState) Number() protoreflect.EnumNumber { 87 return protoreflect.EnumNumber(x) 88} 89 90// Deprecated: Use MigrationState.Descriptor instead. 91func (MigrationState) EnumDescriptor() ([]byte, []int) { 92 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{0} 93} 94 95// Steps in a migration. 96type MigrationStep int32 97 98const ( 99 // Unspecified. 100 MigrationStep_MIGRATION_STEP_UNSPECIFIED MigrationStep = 0 101 // Pre-migration: the database is prepared for migration. 102 MigrationStep_PREPARE MigrationStep = 6 103 // Start of migration. 104 MigrationStep_START MigrationStep = 1 105 // Writes are applied synchronously to at least one replica. 106 MigrationStep_APPLY_WRITES_SYNCHRONOUSLY MigrationStep = 7 107 // Data is copied to Cloud Firestore and then verified to match the data in 108 // Cloud Datastore. 109 MigrationStep_COPY_AND_VERIFY MigrationStep = 2 110 // Eventually-consistent reads are redirected to Cloud Firestore. 111 MigrationStep_REDIRECT_EVENTUALLY_CONSISTENT_READS MigrationStep = 3 112 // Strongly-consistent reads are redirected to Cloud Firestore. 113 MigrationStep_REDIRECT_STRONGLY_CONSISTENT_READS MigrationStep = 4 114 // Writes are redirected to Cloud Firestore. 115 MigrationStep_REDIRECT_WRITES MigrationStep = 5 116) 117 118// Enum value maps for MigrationStep. 119var ( 120 MigrationStep_name = map[int32]string{ 121 0: "MIGRATION_STEP_UNSPECIFIED", 122 6: "PREPARE", 123 1: "START", 124 7: "APPLY_WRITES_SYNCHRONOUSLY", 125 2: "COPY_AND_VERIFY", 126 3: "REDIRECT_EVENTUALLY_CONSISTENT_READS", 127 4: "REDIRECT_STRONGLY_CONSISTENT_READS", 128 5: "REDIRECT_WRITES", 129 } 130 MigrationStep_value = map[string]int32{ 131 "MIGRATION_STEP_UNSPECIFIED": 0, 132 "PREPARE": 6, 133 "START": 1, 134 "APPLY_WRITES_SYNCHRONOUSLY": 7, 135 "COPY_AND_VERIFY": 2, 136 "REDIRECT_EVENTUALLY_CONSISTENT_READS": 3, 137 "REDIRECT_STRONGLY_CONSISTENT_READS": 4, 138 "REDIRECT_WRITES": 5, 139 } 140) 141 142func (x MigrationStep) Enum() *MigrationStep { 143 p := new(MigrationStep) 144 *p = x 145 return p 146} 147 148func (x MigrationStep) String() string { 149 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 150} 151 152func (MigrationStep) Descriptor() protoreflect.EnumDescriptor { 153 return file_google_datastore_admin_v1_migration_proto_enumTypes[1].Descriptor() 154} 155 156func (MigrationStep) Type() protoreflect.EnumType { 157 return &file_google_datastore_admin_v1_migration_proto_enumTypes[1] 158} 159 160func (x MigrationStep) Number() protoreflect.EnumNumber { 161 return protoreflect.EnumNumber(x) 162} 163 164// Deprecated: Use MigrationStep.Descriptor instead. 165func (MigrationStep) EnumDescriptor() ([]byte, []int) { 166 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{1} 167} 168 169// Concurrency modes for transactions in Cloud Firestore. 170type MigrationProgressEvent_ConcurrencyMode int32 171 172const ( 173 // Unspecified. 174 MigrationProgressEvent_CONCURRENCY_MODE_UNSPECIFIED MigrationProgressEvent_ConcurrencyMode = 0 175 // Pessimistic concurrency. 176 MigrationProgressEvent_PESSIMISTIC MigrationProgressEvent_ConcurrencyMode = 1 177 // Optimistic concurrency. 178 MigrationProgressEvent_OPTIMISTIC MigrationProgressEvent_ConcurrencyMode = 2 179) 180 181// Enum value maps for MigrationProgressEvent_ConcurrencyMode. 182var ( 183 MigrationProgressEvent_ConcurrencyMode_name = map[int32]string{ 184 0: "CONCURRENCY_MODE_UNSPECIFIED", 185 1: "PESSIMISTIC", 186 2: "OPTIMISTIC", 187 } 188 MigrationProgressEvent_ConcurrencyMode_value = map[string]int32{ 189 "CONCURRENCY_MODE_UNSPECIFIED": 0, 190 "PESSIMISTIC": 1, 191 "OPTIMISTIC": 2, 192 } 193) 194 195func (x MigrationProgressEvent_ConcurrencyMode) Enum() *MigrationProgressEvent_ConcurrencyMode { 196 p := new(MigrationProgressEvent_ConcurrencyMode) 197 *p = x 198 return p 199} 200 201func (x MigrationProgressEvent_ConcurrencyMode) String() string { 202 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 203} 204 205func (MigrationProgressEvent_ConcurrencyMode) Descriptor() protoreflect.EnumDescriptor { 206 return file_google_datastore_admin_v1_migration_proto_enumTypes[2].Descriptor() 207} 208 209func (MigrationProgressEvent_ConcurrencyMode) Type() protoreflect.EnumType { 210 return &file_google_datastore_admin_v1_migration_proto_enumTypes[2] 211} 212 213func (x MigrationProgressEvent_ConcurrencyMode) Number() protoreflect.EnumNumber { 214 return protoreflect.EnumNumber(x) 215} 216 217// Deprecated: Use MigrationProgressEvent_ConcurrencyMode.Descriptor instead. 218func (MigrationProgressEvent_ConcurrencyMode) EnumDescriptor() ([]byte, []int) { 219 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{1, 0} 220} 221 222// An event signifying a change in state of a [migration from Cloud Datastore to 223// Cloud Firestore in Datastore 224// mode](https://cloud.google.com/datastore/docs/upgrade-to-firestore). 225type MigrationStateEvent struct { 226 state protoimpl.MessageState 227 sizeCache protoimpl.SizeCache 228 unknownFields protoimpl.UnknownFields 229 230 // The new state of the migration. 231 State MigrationState `protobuf:"varint,1,opt,name=state,proto3,enum=google.datastore.admin.v1.MigrationState" json:"state,omitempty"` 232} 233 234func (x *MigrationStateEvent) Reset() { 235 *x = MigrationStateEvent{} 236 if protoimpl.UnsafeEnabled { 237 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[0] 238 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 239 ms.StoreMessageInfo(mi) 240 } 241} 242 243func (x *MigrationStateEvent) String() string { 244 return protoimpl.X.MessageStringOf(x) 245} 246 247func (*MigrationStateEvent) ProtoMessage() {} 248 249func (x *MigrationStateEvent) ProtoReflect() protoreflect.Message { 250 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[0] 251 if protoimpl.UnsafeEnabled && x != nil { 252 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 253 if ms.LoadMessageInfo() == nil { 254 ms.StoreMessageInfo(mi) 255 } 256 return ms 257 } 258 return mi.MessageOf(x) 259} 260 261// Deprecated: Use MigrationStateEvent.ProtoReflect.Descriptor instead. 262func (*MigrationStateEvent) Descriptor() ([]byte, []int) { 263 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{0} 264} 265 266func (x *MigrationStateEvent) GetState() MigrationState { 267 if x != nil { 268 return x.State 269 } 270 return MigrationState_MIGRATION_STATE_UNSPECIFIED 271} 272 273// An event signifying the start of a new step in a [migration from Cloud 274// Datastore to Cloud Firestore in Datastore 275// mode](https://cloud.google.com/datastore/docs/upgrade-to-firestore). 276type MigrationProgressEvent struct { 277 state protoimpl.MessageState 278 sizeCache protoimpl.SizeCache 279 unknownFields protoimpl.UnknownFields 280 281 // The step that is starting. 282 // 283 // An event with step set to `START` indicates that the migration 284 // has been reverted back to the initial pre-migration state. 285 Step MigrationStep `protobuf:"varint,1,opt,name=step,proto3,enum=google.datastore.admin.v1.MigrationStep" json:"step,omitempty"` 286 // Details about this step. 287 // 288 // Types that are assignable to StepDetails: 289 // *MigrationProgressEvent_PrepareStepDetails_ 290 // *MigrationProgressEvent_RedirectWritesStepDetails_ 291 StepDetails isMigrationProgressEvent_StepDetails `protobuf_oneof:"step_details"` 292} 293 294func (x *MigrationProgressEvent) Reset() { 295 *x = MigrationProgressEvent{} 296 if protoimpl.UnsafeEnabled { 297 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[1] 298 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 299 ms.StoreMessageInfo(mi) 300 } 301} 302 303func (x *MigrationProgressEvent) String() string { 304 return protoimpl.X.MessageStringOf(x) 305} 306 307func (*MigrationProgressEvent) ProtoMessage() {} 308 309func (x *MigrationProgressEvent) ProtoReflect() protoreflect.Message { 310 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[1] 311 if protoimpl.UnsafeEnabled && x != nil { 312 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 313 if ms.LoadMessageInfo() == nil { 314 ms.StoreMessageInfo(mi) 315 } 316 return ms 317 } 318 return mi.MessageOf(x) 319} 320 321// Deprecated: Use MigrationProgressEvent.ProtoReflect.Descriptor instead. 322func (*MigrationProgressEvent) Descriptor() ([]byte, []int) { 323 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{1} 324} 325 326func (x *MigrationProgressEvent) GetStep() MigrationStep { 327 if x != nil { 328 return x.Step 329 } 330 return MigrationStep_MIGRATION_STEP_UNSPECIFIED 331} 332 333func (m *MigrationProgressEvent) GetStepDetails() isMigrationProgressEvent_StepDetails { 334 if m != nil { 335 return m.StepDetails 336 } 337 return nil 338} 339 340func (x *MigrationProgressEvent) GetPrepareStepDetails() *MigrationProgressEvent_PrepareStepDetails { 341 if x, ok := x.GetStepDetails().(*MigrationProgressEvent_PrepareStepDetails_); ok { 342 return x.PrepareStepDetails 343 } 344 return nil 345} 346 347func (x *MigrationProgressEvent) GetRedirectWritesStepDetails() *MigrationProgressEvent_RedirectWritesStepDetails { 348 if x, ok := x.GetStepDetails().(*MigrationProgressEvent_RedirectWritesStepDetails_); ok { 349 return x.RedirectWritesStepDetails 350 } 351 return nil 352} 353 354type isMigrationProgressEvent_StepDetails interface { 355 isMigrationProgressEvent_StepDetails() 356} 357 358type MigrationProgressEvent_PrepareStepDetails_ struct { 359 // Details for the `PREPARE` step. 360 PrepareStepDetails *MigrationProgressEvent_PrepareStepDetails `protobuf:"bytes,2,opt,name=prepare_step_details,json=prepareStepDetails,proto3,oneof"` 361} 362 363type MigrationProgressEvent_RedirectWritesStepDetails_ struct { 364 // Details for the `REDIRECT_WRITES` step. 365 RedirectWritesStepDetails *MigrationProgressEvent_RedirectWritesStepDetails `protobuf:"bytes,3,opt,name=redirect_writes_step_details,json=redirectWritesStepDetails,proto3,oneof"` 366} 367 368func (*MigrationProgressEvent_PrepareStepDetails_) isMigrationProgressEvent_StepDetails() {} 369 370func (*MigrationProgressEvent_RedirectWritesStepDetails_) isMigrationProgressEvent_StepDetails() {} 371 372// Details for the `PREPARE` step. 373type MigrationProgressEvent_PrepareStepDetails struct { 374 state protoimpl.MessageState 375 sizeCache protoimpl.SizeCache 376 unknownFields protoimpl.UnknownFields 377 378 // The concurrency mode this database will use when it reaches the 379 // `REDIRECT_WRITES` step. 380 ConcurrencyMode MigrationProgressEvent_ConcurrencyMode `protobuf:"varint,1,opt,name=concurrency_mode,json=concurrencyMode,proto3,enum=google.datastore.admin.v1.MigrationProgressEvent_ConcurrencyMode" json:"concurrency_mode,omitempty"` 381} 382 383func (x *MigrationProgressEvent_PrepareStepDetails) Reset() { 384 *x = MigrationProgressEvent_PrepareStepDetails{} 385 if protoimpl.UnsafeEnabled { 386 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[2] 387 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 388 ms.StoreMessageInfo(mi) 389 } 390} 391 392func (x *MigrationProgressEvent_PrepareStepDetails) String() string { 393 return protoimpl.X.MessageStringOf(x) 394} 395 396func (*MigrationProgressEvent_PrepareStepDetails) ProtoMessage() {} 397 398func (x *MigrationProgressEvent_PrepareStepDetails) ProtoReflect() protoreflect.Message { 399 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[2] 400 if protoimpl.UnsafeEnabled && x != nil { 401 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 402 if ms.LoadMessageInfo() == nil { 403 ms.StoreMessageInfo(mi) 404 } 405 return ms 406 } 407 return mi.MessageOf(x) 408} 409 410// Deprecated: Use MigrationProgressEvent_PrepareStepDetails.ProtoReflect.Descriptor instead. 411func (*MigrationProgressEvent_PrepareStepDetails) Descriptor() ([]byte, []int) { 412 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{1, 0} 413} 414 415func (x *MigrationProgressEvent_PrepareStepDetails) GetConcurrencyMode() MigrationProgressEvent_ConcurrencyMode { 416 if x != nil { 417 return x.ConcurrencyMode 418 } 419 return MigrationProgressEvent_CONCURRENCY_MODE_UNSPECIFIED 420} 421 422// Details for the `REDIRECT_WRITES` step. 423type MigrationProgressEvent_RedirectWritesStepDetails struct { 424 state protoimpl.MessageState 425 sizeCache protoimpl.SizeCache 426 unknownFields protoimpl.UnknownFields 427 428 // Ths concurrency mode for this database. 429 ConcurrencyMode MigrationProgressEvent_ConcurrencyMode `protobuf:"varint,1,opt,name=concurrency_mode,json=concurrencyMode,proto3,enum=google.datastore.admin.v1.MigrationProgressEvent_ConcurrencyMode" json:"concurrency_mode,omitempty"` 430} 431 432func (x *MigrationProgressEvent_RedirectWritesStepDetails) Reset() { 433 *x = MigrationProgressEvent_RedirectWritesStepDetails{} 434 if protoimpl.UnsafeEnabled { 435 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[3] 436 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 437 ms.StoreMessageInfo(mi) 438 } 439} 440 441func (x *MigrationProgressEvent_RedirectWritesStepDetails) String() string { 442 return protoimpl.X.MessageStringOf(x) 443} 444 445func (*MigrationProgressEvent_RedirectWritesStepDetails) ProtoMessage() {} 446 447func (x *MigrationProgressEvent_RedirectWritesStepDetails) ProtoReflect() protoreflect.Message { 448 mi := &file_google_datastore_admin_v1_migration_proto_msgTypes[3] 449 if protoimpl.UnsafeEnabled && x != nil { 450 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 451 if ms.LoadMessageInfo() == nil { 452 ms.StoreMessageInfo(mi) 453 } 454 return ms 455 } 456 return mi.MessageOf(x) 457} 458 459// Deprecated: Use MigrationProgressEvent_RedirectWritesStepDetails.ProtoReflect.Descriptor instead. 460func (*MigrationProgressEvent_RedirectWritesStepDetails) Descriptor() ([]byte, []int) { 461 return file_google_datastore_admin_v1_migration_proto_rawDescGZIP(), []int{1, 1} 462} 463 464func (x *MigrationProgressEvent_RedirectWritesStepDetails) GetConcurrencyMode() MigrationProgressEvent_ConcurrencyMode { 465 if x != nil { 466 return x.ConcurrencyMode 467 } 468 return MigrationProgressEvent_CONCURRENCY_MODE_UNSPECIFIED 469} 470 471var File_google_datastore_admin_v1_migration_proto protoreflect.FileDescriptor 472 473var file_google_datastore_admin_v1_migration_proto_rawDesc = []byte{ 474 0x0a, 0x29, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 475 0x72, 0x65, 0x2f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x69, 0x67, 0x72, 476 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x19, 0x67, 0x6f, 0x6f, 477 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 478 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x22, 0x56, 0x0a, 0x13, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 479 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x3f, 0x0a, 480 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e, 0x67, 481 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 482 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 483 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x22, 0xd8, 484 0x05, 0x0a, 0x16, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x67, 485 0x72, 0x65, 0x73, 0x73, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x3c, 0x0a, 0x04, 0x73, 0x74, 0x65, 486 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 487 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 488 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x65, 489 0x70, 0x52, 0x04, 0x73, 0x74, 0x65, 0x70, 0x12, 0x78, 0x0a, 0x14, 0x70, 0x72, 0x65, 0x70, 0x61, 490 0x72, 0x65, 0x5f, 0x73, 0x74, 0x65, 0x70, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x18, 491 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x44, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 492 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 493 0x31, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x67, 0x72, 494 0x65, 0x73, 0x73, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 495 0x53, 0x74, 0x65, 0x70, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x48, 0x00, 0x52, 0x12, 0x70, 496 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x53, 0x74, 0x65, 0x70, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 497 0x73, 0x12, 0x8e, 0x01, 0x0a, 0x1c, 0x72, 0x65, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x5f, 0x77, 498 0x72, 0x69, 0x74, 0x65, 0x73, 0x5f, 0x73, 0x74, 0x65, 0x70, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 499 0x6c, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x4b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 500 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 501 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 502 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x65, 0x64, 0x69, 503 0x72, 0x65, 0x63, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x73, 0x53, 0x74, 0x65, 0x70, 0x44, 0x65, 504 0x74, 0x61, 0x69, 0x6c, 0x73, 0x48, 0x00, 0x52, 0x19, 0x72, 0x65, 0x64, 0x69, 0x72, 0x65, 0x63, 505 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x73, 0x53, 0x74, 0x65, 0x70, 0x44, 0x65, 0x74, 0x61, 0x69, 506 0x6c, 0x73, 0x1a, 0x82, 0x01, 0x0a, 0x12, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x53, 0x74, 507 0x65, 0x70, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x12, 0x6c, 0x0a, 0x10, 0x63, 0x6f, 0x6e, 508 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 509 0x01, 0x28, 0x0e, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 510 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 511 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 512 0x73, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 513 0x63, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x52, 0x0f, 0x63, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 514 0x6e, 0x63, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x1a, 0x89, 0x01, 0x0a, 0x19, 0x52, 0x65, 0x64, 0x69, 515 0x72, 0x65, 0x63, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x73, 0x53, 0x74, 0x65, 0x70, 0x44, 0x65, 516 0x74, 0x61, 0x69, 0x6c, 0x73, 0x12, 0x6c, 0x0a, 0x10, 0x63, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 517 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 518 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 519 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x69, 0x67, 0x72, 520 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x45, 0x76, 0x65, 521 0x6e, 0x74, 0x2e, 0x43, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x63, 0x79, 0x4d, 0x6f, 522 0x64, 0x65, 0x52, 0x0f, 0x63, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x63, 0x79, 0x4d, 523 0x6f, 0x64, 0x65, 0x22, 0x54, 0x0a, 0x0f, 0x43, 0x6f, 0x6e, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 524 0x63, 0x79, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x20, 0x0a, 0x1c, 0x43, 0x4f, 0x4e, 0x43, 0x55, 0x52, 525 0x52, 0x45, 0x4e, 0x43, 0x59, 0x5f, 0x4d, 0x4f, 0x44, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 526 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0f, 0x0a, 0x0b, 0x50, 0x45, 0x53, 0x53, 527 0x49, 0x4d, 0x49, 0x53, 0x54, 0x49, 0x43, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x4f, 0x50, 0x54, 528 0x49, 0x4d, 0x49, 0x53, 0x54, 0x49, 0x43, 0x10, 0x02, 0x42, 0x0e, 0x0a, 0x0c, 0x73, 0x74, 0x65, 529 0x70, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x2a, 0x58, 0x0a, 0x0e, 0x4d, 0x69, 0x67, 530 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1f, 0x0a, 0x1b, 0x4d, 531 0x49, 0x47, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x55, 532 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 533 0x52, 0x55, 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x01, 0x12, 0x0a, 0x0a, 0x06, 0x50, 0x41, 0x55, 534 0x53, 0x45, 0x44, 0x10, 0x02, 0x12, 0x0c, 0x0a, 0x08, 0x43, 0x4f, 0x4d, 0x50, 0x4c, 0x45, 0x54, 535 0x45, 0x10, 0x03, 0x2a, 0xe3, 0x01, 0x0a, 0x0d, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 536 0x6e, 0x53, 0x74, 0x65, 0x70, 0x12, 0x1e, 0x0a, 0x1a, 0x4d, 0x49, 0x47, 0x52, 0x41, 0x54, 0x49, 537 0x4f, 0x4e, 0x5f, 0x53, 0x54, 0x45, 0x50, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 538 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x52, 0x45, 0x50, 0x41, 0x52, 0x45, 539 0x10, 0x06, 0x12, 0x09, 0x0a, 0x05, 0x53, 0x54, 0x41, 0x52, 0x54, 0x10, 0x01, 0x12, 0x1e, 0x0a, 540 0x1a, 0x41, 0x50, 0x50, 0x4c, 0x59, 0x5f, 0x57, 0x52, 0x49, 0x54, 0x45, 0x53, 0x5f, 0x53, 0x59, 541 0x4e, 0x43, 0x48, 0x52, 0x4f, 0x4e, 0x4f, 0x55, 0x53, 0x4c, 0x59, 0x10, 0x07, 0x12, 0x13, 0x0a, 542 0x0f, 0x43, 0x4f, 0x50, 0x59, 0x5f, 0x41, 0x4e, 0x44, 0x5f, 0x56, 0x45, 0x52, 0x49, 0x46, 0x59, 543 0x10, 0x02, 0x12, 0x28, 0x0a, 0x24, 0x52, 0x45, 0x44, 0x49, 0x52, 0x45, 0x43, 0x54, 0x5f, 0x45, 544 0x56, 0x45, 0x4e, 0x54, 0x55, 0x41, 0x4c, 0x4c, 0x59, 0x5f, 0x43, 0x4f, 0x4e, 0x53, 0x49, 0x53, 545 0x54, 0x45, 0x4e, 0x54, 0x5f, 0x52, 0x45, 0x41, 0x44, 0x53, 0x10, 0x03, 0x12, 0x26, 0x0a, 0x22, 546 0x52, 0x45, 0x44, 0x49, 0x52, 0x45, 0x43, 0x54, 0x5f, 0x53, 0x54, 0x52, 0x4f, 0x4e, 0x47, 0x4c, 547 0x59, 0x5f, 0x43, 0x4f, 0x4e, 0x53, 0x49, 0x53, 0x54, 0x45, 0x4e, 0x54, 0x5f, 0x52, 0x45, 0x41, 548 0x44, 0x53, 0x10, 0x04, 0x12, 0x13, 0x0a, 0x0f, 0x52, 0x45, 0x44, 0x49, 0x52, 0x45, 0x43, 0x54, 549 0x5f, 0x57, 0x52, 0x49, 0x54, 0x45, 0x53, 0x10, 0x05, 0x42, 0xdb, 0x01, 0x0a, 0x1d, 0x63, 0x6f, 550 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 551 0x72, 0x65, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x31, 0x42, 0x0e, 0x4d, 0x69, 0x67, 552 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x67, 553 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 554 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 555 0x61, 0x70, 0x69, 0x73, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x61, 556 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x31, 0x3b, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0xaa, 0x02, 0x1f, 557 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x44, 0x61, 0x74, 558 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x56, 0x31, 0xca, 559 0x02, 0x1f, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x44, 560 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x5c, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x5c, 0x56, 561 0x31, 0xea, 0x02, 0x23, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 562 0x64, 0x3a, 0x3a, 0x44, 0x61, 0x74, 0x61, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x3a, 0x3a, 0x41, 0x64, 563 0x6d, 0x69, 0x6e, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 564} 565 566var ( 567 file_google_datastore_admin_v1_migration_proto_rawDescOnce sync.Once 568 file_google_datastore_admin_v1_migration_proto_rawDescData = file_google_datastore_admin_v1_migration_proto_rawDesc 569) 570 571func file_google_datastore_admin_v1_migration_proto_rawDescGZIP() []byte { 572 file_google_datastore_admin_v1_migration_proto_rawDescOnce.Do(func() { 573 file_google_datastore_admin_v1_migration_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_datastore_admin_v1_migration_proto_rawDescData) 574 }) 575 return file_google_datastore_admin_v1_migration_proto_rawDescData 576} 577 578var file_google_datastore_admin_v1_migration_proto_enumTypes = make([]protoimpl.EnumInfo, 3) 579var file_google_datastore_admin_v1_migration_proto_msgTypes = make([]protoimpl.MessageInfo, 4) 580var file_google_datastore_admin_v1_migration_proto_goTypes = []interface{}{ 581 (MigrationState)(0), // 0: google.datastore.admin.v1.MigrationState 582 (MigrationStep)(0), // 1: google.datastore.admin.v1.MigrationStep 583 (MigrationProgressEvent_ConcurrencyMode)(0), // 2: google.datastore.admin.v1.MigrationProgressEvent.ConcurrencyMode 584 (*MigrationStateEvent)(nil), // 3: google.datastore.admin.v1.MigrationStateEvent 585 (*MigrationProgressEvent)(nil), // 4: google.datastore.admin.v1.MigrationProgressEvent 586 (*MigrationProgressEvent_PrepareStepDetails)(nil), // 5: google.datastore.admin.v1.MigrationProgressEvent.PrepareStepDetails 587 (*MigrationProgressEvent_RedirectWritesStepDetails)(nil), // 6: google.datastore.admin.v1.MigrationProgressEvent.RedirectWritesStepDetails 588} 589var file_google_datastore_admin_v1_migration_proto_depIdxs = []int32{ 590 0, // 0: google.datastore.admin.v1.MigrationStateEvent.state:type_name -> google.datastore.admin.v1.MigrationState 591 1, // 1: google.datastore.admin.v1.MigrationProgressEvent.step:type_name -> google.datastore.admin.v1.MigrationStep 592 5, // 2: google.datastore.admin.v1.MigrationProgressEvent.prepare_step_details:type_name -> google.datastore.admin.v1.MigrationProgressEvent.PrepareStepDetails 593 6, // 3: google.datastore.admin.v1.MigrationProgressEvent.redirect_writes_step_details:type_name -> google.datastore.admin.v1.MigrationProgressEvent.RedirectWritesStepDetails 594 2, // 4: google.datastore.admin.v1.MigrationProgressEvent.PrepareStepDetails.concurrency_mode:type_name -> google.datastore.admin.v1.MigrationProgressEvent.ConcurrencyMode 595 2, // 5: google.datastore.admin.v1.MigrationProgressEvent.RedirectWritesStepDetails.concurrency_mode:type_name -> google.datastore.admin.v1.MigrationProgressEvent.ConcurrencyMode 596 6, // [6:6] is the sub-list for method output_type 597 6, // [6:6] is the sub-list for method input_type 598 6, // [6:6] is the sub-list for extension type_name 599 6, // [6:6] is the sub-list for extension extendee 600 0, // [0:6] is the sub-list for field type_name 601} 602 603func init() { file_google_datastore_admin_v1_migration_proto_init() } 604func file_google_datastore_admin_v1_migration_proto_init() { 605 if File_google_datastore_admin_v1_migration_proto != nil { 606 return 607 } 608 if !protoimpl.UnsafeEnabled { 609 file_google_datastore_admin_v1_migration_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 610 switch v := v.(*MigrationStateEvent); i { 611 case 0: 612 return &v.state 613 case 1: 614 return &v.sizeCache 615 case 2: 616 return &v.unknownFields 617 default: 618 return nil 619 } 620 } 621 file_google_datastore_admin_v1_migration_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 622 switch v := v.(*MigrationProgressEvent); i { 623 case 0: 624 return &v.state 625 case 1: 626 return &v.sizeCache 627 case 2: 628 return &v.unknownFields 629 default: 630 return nil 631 } 632 } 633 file_google_datastore_admin_v1_migration_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 634 switch v := v.(*MigrationProgressEvent_PrepareStepDetails); i { 635 case 0: 636 return &v.state 637 case 1: 638 return &v.sizeCache 639 case 2: 640 return &v.unknownFields 641 default: 642 return nil 643 } 644 } 645 file_google_datastore_admin_v1_migration_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 646 switch v := v.(*MigrationProgressEvent_RedirectWritesStepDetails); i { 647 case 0: 648 return &v.state 649 case 1: 650 return &v.sizeCache 651 case 2: 652 return &v.unknownFields 653 default: 654 return nil 655 } 656 } 657 } 658 file_google_datastore_admin_v1_migration_proto_msgTypes[1].OneofWrappers = []interface{}{ 659 (*MigrationProgressEvent_PrepareStepDetails_)(nil), 660 (*MigrationProgressEvent_RedirectWritesStepDetails_)(nil), 661 } 662 type x struct{} 663 out := protoimpl.TypeBuilder{ 664 File: protoimpl.DescBuilder{ 665 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 666 RawDescriptor: file_google_datastore_admin_v1_migration_proto_rawDesc, 667 NumEnums: 3, 668 NumMessages: 4, 669 NumExtensions: 0, 670 NumServices: 0, 671 }, 672 GoTypes: file_google_datastore_admin_v1_migration_proto_goTypes, 673 DependencyIndexes: file_google_datastore_admin_v1_migration_proto_depIdxs, 674 EnumInfos: file_google_datastore_admin_v1_migration_proto_enumTypes, 675 MessageInfos: file_google_datastore_admin_v1_migration_proto_msgTypes, 676 }.Build() 677 File_google_datastore_admin_v1_migration_proto = out.File 678 file_google_datastore_admin_v1_migration_proto_rawDesc = nil 679 file_google_datastore_admin_v1_migration_proto_goTypes = nil 680 file_google_datastore_admin_v1_migration_proto_depIdxs = nil 681} 682