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.25.0-devel 18// protoc v3.12.2 19// source: google/cloud/bigquery/migration/v2alpha/migration_service.proto 20 21package migration 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 proto "github.com/golang/protobuf/proto" 29 _ "google.golang.org/genproto/googleapis/api/annotations" 30 _ "google.golang.org/genproto/googleapis/rpc/errdetails" 31 grpc "google.golang.org/grpc" 32 codes "google.golang.org/grpc/codes" 33 status "google.golang.org/grpc/status" 34 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 35 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 36 emptypb "google.golang.org/protobuf/types/known/emptypb" 37 fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb" 38) 39 40const ( 41 // Verify that this generated code is sufficiently up-to-date. 42 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 43 // Verify that runtime/protoimpl is sufficiently up-to-date. 44 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 45) 46 47// This is a compile-time assertion that a sufficiently up-to-date version 48// of the legacy proto package is being used. 49const _ = proto.ProtoPackageIsVersion4 50 51// Request to create a migration workflow resource. 52type CreateMigrationWorkflowRequest struct { 53 state protoimpl.MessageState 54 sizeCache protoimpl.SizeCache 55 unknownFields protoimpl.UnknownFields 56 57 // Required. The name of the project to which this migration workflow belongs. 58 // Example: `projects/foo/locations/bar` 59 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 60 // Required. The migration workflow to create. 61 MigrationWorkflow *MigrationWorkflow `protobuf:"bytes,2,opt,name=migration_workflow,json=migrationWorkflow,proto3" json:"migration_workflow,omitempty"` 62} 63 64func (x *CreateMigrationWorkflowRequest) Reset() { 65 *x = CreateMigrationWorkflowRequest{} 66 if protoimpl.UnsafeEnabled { 67 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0] 68 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 69 ms.StoreMessageInfo(mi) 70 } 71} 72 73func (x *CreateMigrationWorkflowRequest) String() string { 74 return protoimpl.X.MessageStringOf(x) 75} 76 77func (*CreateMigrationWorkflowRequest) ProtoMessage() {} 78 79func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 80 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0] 81 if protoimpl.UnsafeEnabled && x != nil { 82 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 83 if ms.LoadMessageInfo() == nil { 84 ms.StoreMessageInfo(mi) 85 } 86 return ms 87 } 88 return mi.MessageOf(x) 89} 90 91// Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 92func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 93 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{0} 94} 95 96func (x *CreateMigrationWorkflowRequest) GetParent() string { 97 if x != nil { 98 return x.Parent 99 } 100 return "" 101} 102 103func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow { 104 if x != nil { 105 return x.MigrationWorkflow 106 } 107 return nil 108} 109 110// A request to get a previously created migration workflow. 111type GetMigrationWorkflowRequest struct { 112 state protoimpl.MessageState 113 sizeCache protoimpl.SizeCache 114 unknownFields protoimpl.UnknownFields 115 116 // Required. The unique identifier for the migration workflow. 117 // Example: `projects/123/locations/us/workflows/1234` 118 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 119 // The list of fields to be retrieved. 120 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 121} 122 123func (x *GetMigrationWorkflowRequest) Reset() { 124 *x = GetMigrationWorkflowRequest{} 125 if protoimpl.UnsafeEnabled { 126 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1] 127 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 128 ms.StoreMessageInfo(mi) 129 } 130} 131 132func (x *GetMigrationWorkflowRequest) String() string { 133 return protoimpl.X.MessageStringOf(x) 134} 135 136func (*GetMigrationWorkflowRequest) ProtoMessage() {} 137 138func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 139 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1] 140 if protoimpl.UnsafeEnabled && x != nil { 141 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 142 if ms.LoadMessageInfo() == nil { 143 ms.StoreMessageInfo(mi) 144 } 145 return ms 146 } 147 return mi.MessageOf(x) 148} 149 150// Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 151func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 152 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{1} 153} 154 155func (x *GetMigrationWorkflowRequest) GetName() string { 156 if x != nil { 157 return x.Name 158 } 159 return "" 160} 161 162func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask { 163 if x != nil { 164 return x.ReadMask 165 } 166 return nil 167} 168 169// A request to list previously created migration workflows. 170type ListMigrationWorkflowsRequest struct { 171 state protoimpl.MessageState 172 sizeCache protoimpl.SizeCache 173 unknownFields protoimpl.UnknownFields 174 175 // Required. The project and location of the migration workflows to list. 176 // Example: `projects/123/locations/us` 177 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 178 // The list of fields to be retrieved. 179 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 180 // The maximum number of migration workflows to return. The service may return 181 // fewer than this number. 182 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 183 // A page token, received from previous `ListMigrationWorkflows` call. 184 // Provide this to retrieve the subsequent page. 185 // 186 // When paginating, all other parameters provided to `ListMigrationWorkflows` 187 // must match the call that provided the page token. 188 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 189} 190 191func (x *ListMigrationWorkflowsRequest) Reset() { 192 *x = ListMigrationWorkflowsRequest{} 193 if protoimpl.UnsafeEnabled { 194 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2] 195 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 196 ms.StoreMessageInfo(mi) 197 } 198} 199 200func (x *ListMigrationWorkflowsRequest) String() string { 201 return protoimpl.X.MessageStringOf(x) 202} 203 204func (*ListMigrationWorkflowsRequest) ProtoMessage() {} 205 206func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message { 207 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2] 208 if protoimpl.UnsafeEnabled && x != nil { 209 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 210 if ms.LoadMessageInfo() == nil { 211 ms.StoreMessageInfo(mi) 212 } 213 return ms 214 } 215 return mi.MessageOf(x) 216} 217 218// Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead. 219func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int) { 220 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{2} 221} 222 223func (x *ListMigrationWorkflowsRequest) GetParent() string { 224 if x != nil { 225 return x.Parent 226 } 227 return "" 228} 229 230func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask { 231 if x != nil { 232 return x.ReadMask 233 } 234 return nil 235} 236 237func (x *ListMigrationWorkflowsRequest) GetPageSize() int32 { 238 if x != nil { 239 return x.PageSize 240 } 241 return 0 242} 243 244func (x *ListMigrationWorkflowsRequest) GetPageToken() string { 245 if x != nil { 246 return x.PageToken 247 } 248 return "" 249} 250 251// Response object for a `ListMigrationWorkflows` call. 252type ListMigrationWorkflowsResponse struct { 253 state protoimpl.MessageState 254 sizeCache protoimpl.SizeCache 255 unknownFields protoimpl.UnknownFields 256 257 // The migration workflows for the specified project / location. 258 MigrationWorkflows []*MigrationWorkflow `protobuf:"bytes,1,rep,name=migration_workflows,json=migrationWorkflows,proto3" json:"migration_workflows,omitempty"` 259 // A token, which can be sent as `page_token` to retrieve the next page. 260 // If this field is omitted, there are no subsequent pages. 261 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 262} 263 264func (x *ListMigrationWorkflowsResponse) Reset() { 265 *x = ListMigrationWorkflowsResponse{} 266 if protoimpl.UnsafeEnabled { 267 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3] 268 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 269 ms.StoreMessageInfo(mi) 270 } 271} 272 273func (x *ListMigrationWorkflowsResponse) String() string { 274 return protoimpl.X.MessageStringOf(x) 275} 276 277func (*ListMigrationWorkflowsResponse) ProtoMessage() {} 278 279func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message { 280 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3] 281 if protoimpl.UnsafeEnabled && x != nil { 282 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 283 if ms.LoadMessageInfo() == nil { 284 ms.StoreMessageInfo(mi) 285 } 286 return ms 287 } 288 return mi.MessageOf(x) 289} 290 291// Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead. 292func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int) { 293 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{3} 294} 295 296func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow { 297 if x != nil { 298 return x.MigrationWorkflows 299 } 300 return nil 301} 302 303func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string { 304 if x != nil { 305 return x.NextPageToken 306 } 307 return "" 308} 309 310// A request to delete a previously created migration workflow. 311type DeleteMigrationWorkflowRequest struct { 312 state protoimpl.MessageState 313 sizeCache protoimpl.SizeCache 314 unknownFields protoimpl.UnknownFields 315 316 // Required. The unique identifier for the migration workflow. 317 // Example: `projects/123/locations/us/workflows/1234` 318 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 319} 320 321func (x *DeleteMigrationWorkflowRequest) Reset() { 322 *x = DeleteMigrationWorkflowRequest{} 323 if protoimpl.UnsafeEnabled { 324 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4] 325 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 326 ms.StoreMessageInfo(mi) 327 } 328} 329 330func (x *DeleteMigrationWorkflowRequest) String() string { 331 return protoimpl.X.MessageStringOf(x) 332} 333 334func (*DeleteMigrationWorkflowRequest) ProtoMessage() {} 335 336func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 337 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4] 338 if protoimpl.UnsafeEnabled && x != nil { 339 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 340 if ms.LoadMessageInfo() == nil { 341 ms.StoreMessageInfo(mi) 342 } 343 return ms 344 } 345 return mi.MessageOf(x) 346} 347 348// Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 349func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 350 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{4} 351} 352 353func (x *DeleteMigrationWorkflowRequest) GetName() string { 354 if x != nil { 355 return x.Name 356 } 357 return "" 358} 359 360// A request to start a previously created migration workflow. 361type StartMigrationWorkflowRequest struct { 362 state protoimpl.MessageState 363 sizeCache protoimpl.SizeCache 364 unknownFields protoimpl.UnknownFields 365 366 // Required. The unique identifier for the migration workflow. 367 // Example: `projects/123/locations/us/workflows/1234` 368 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 369} 370 371func (x *StartMigrationWorkflowRequest) Reset() { 372 *x = StartMigrationWorkflowRequest{} 373 if protoimpl.UnsafeEnabled { 374 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5] 375 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 376 ms.StoreMessageInfo(mi) 377 } 378} 379 380func (x *StartMigrationWorkflowRequest) String() string { 381 return protoimpl.X.MessageStringOf(x) 382} 383 384func (*StartMigrationWorkflowRequest) ProtoMessage() {} 385 386func (x *StartMigrationWorkflowRequest) ProtoReflect() protoreflect.Message { 387 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5] 388 if protoimpl.UnsafeEnabled && x != nil { 389 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 390 if ms.LoadMessageInfo() == nil { 391 ms.StoreMessageInfo(mi) 392 } 393 return ms 394 } 395 return mi.MessageOf(x) 396} 397 398// Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead. 399func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int) { 400 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{5} 401} 402 403func (x *StartMigrationWorkflowRequest) GetName() string { 404 if x != nil { 405 return x.Name 406 } 407 return "" 408} 409 410// A request to get a previously created migration subtasks. 411type GetMigrationSubtaskRequest struct { 412 state protoimpl.MessageState 413 sizeCache protoimpl.SizeCache 414 unknownFields protoimpl.UnknownFields 415 416 // Required. The unique identifier for the migration subtask. 417 // Example: `projects/123/locations/us/workflows/1234/subtasks/543` 418 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 419 // Optional. The list of fields to be retrieved. 420 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 421} 422 423func (x *GetMigrationSubtaskRequest) Reset() { 424 *x = GetMigrationSubtaskRequest{} 425 if protoimpl.UnsafeEnabled { 426 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6] 427 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 428 ms.StoreMessageInfo(mi) 429 } 430} 431 432func (x *GetMigrationSubtaskRequest) String() string { 433 return protoimpl.X.MessageStringOf(x) 434} 435 436func (*GetMigrationSubtaskRequest) ProtoMessage() {} 437 438func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message { 439 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6] 440 if protoimpl.UnsafeEnabled && x != nil { 441 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 442 if ms.LoadMessageInfo() == nil { 443 ms.StoreMessageInfo(mi) 444 } 445 return ms 446 } 447 return mi.MessageOf(x) 448} 449 450// Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead. 451func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int) { 452 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{6} 453} 454 455func (x *GetMigrationSubtaskRequest) GetName() string { 456 if x != nil { 457 return x.Name 458 } 459 return "" 460} 461 462func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask { 463 if x != nil { 464 return x.ReadMask 465 } 466 return nil 467} 468 469// A request to list previously created migration subtasks. 470type ListMigrationSubtasksRequest struct { 471 state protoimpl.MessageState 472 sizeCache protoimpl.SizeCache 473 unknownFields protoimpl.UnknownFields 474 475 // Required. The migration task of the subtasks to list. 476 // Example: `projects/123/locations/us/workflows/1234` 477 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 478 // Optional. The list of fields to be retrieved. 479 ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"` 480 // Optional. The maximum number of migration tasks to return. The service may return 481 // fewer than this number. 482 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 483 // Optional. A page token, received from previous `ListMigrationSubtasks` call. 484 // Provide this to retrieve the subsequent page. 485 // 486 // When paginating, all other parameters provided to `ListMigrationSubtasks` 487 // must match the call that provided the page token. 488 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 489 // Optional. The filter to apply. This can be used to get the subtasks of a specific 490 // tasks in a workflow, e.g. `migration_task = "ab012"` where `"ab012"` is the 491 // task ID (not the name in the named map). 492 Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"` 493} 494 495func (x *ListMigrationSubtasksRequest) Reset() { 496 *x = ListMigrationSubtasksRequest{} 497 if protoimpl.UnsafeEnabled { 498 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7] 499 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 500 ms.StoreMessageInfo(mi) 501 } 502} 503 504func (x *ListMigrationSubtasksRequest) String() string { 505 return protoimpl.X.MessageStringOf(x) 506} 507 508func (*ListMigrationSubtasksRequest) ProtoMessage() {} 509 510func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message { 511 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7] 512 if protoimpl.UnsafeEnabled && x != nil { 513 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 514 if ms.LoadMessageInfo() == nil { 515 ms.StoreMessageInfo(mi) 516 } 517 return ms 518 } 519 return mi.MessageOf(x) 520} 521 522// Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead. 523func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int) { 524 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{7} 525} 526 527func (x *ListMigrationSubtasksRequest) GetParent() string { 528 if x != nil { 529 return x.Parent 530 } 531 return "" 532} 533 534func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask { 535 if x != nil { 536 return x.ReadMask 537 } 538 return nil 539} 540 541func (x *ListMigrationSubtasksRequest) GetPageSize() int32 { 542 if x != nil { 543 return x.PageSize 544 } 545 return 0 546} 547 548func (x *ListMigrationSubtasksRequest) GetPageToken() string { 549 if x != nil { 550 return x.PageToken 551 } 552 return "" 553} 554 555func (x *ListMigrationSubtasksRequest) GetFilter() string { 556 if x != nil { 557 return x.Filter 558 } 559 return "" 560} 561 562// Response object for a `ListMigrationSubtasks` call. 563type ListMigrationSubtasksResponse struct { 564 state protoimpl.MessageState 565 sizeCache protoimpl.SizeCache 566 unknownFields protoimpl.UnknownFields 567 568 // The migration subtasks for the specified task. 569 MigrationSubtasks []*MigrationSubtask `protobuf:"bytes,1,rep,name=migration_subtasks,json=migrationSubtasks,proto3" json:"migration_subtasks,omitempty"` 570 // A token, which can be sent as `page_token` to retrieve the next page. 571 // If this field is omitted, there are no subsequent pages. 572 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 573} 574 575func (x *ListMigrationSubtasksResponse) Reset() { 576 *x = ListMigrationSubtasksResponse{} 577 if protoimpl.UnsafeEnabled { 578 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8] 579 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 580 ms.StoreMessageInfo(mi) 581 } 582} 583 584func (x *ListMigrationSubtasksResponse) String() string { 585 return protoimpl.X.MessageStringOf(x) 586} 587 588func (*ListMigrationSubtasksResponse) ProtoMessage() {} 589 590func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message { 591 mi := &file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8] 592 if protoimpl.UnsafeEnabled && x != nil { 593 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 594 if ms.LoadMessageInfo() == nil { 595 ms.StoreMessageInfo(mi) 596 } 597 return ms 598 } 599 return mi.MessageOf(x) 600} 601 602// Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead. 603func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int) { 604 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP(), []int{8} 605} 606 607func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask { 608 if x != nil { 609 return x.MigrationSubtasks 610 } 611 return nil 612} 613 614func (x *ListMigrationSubtasksResponse) GetNextPageToken() string { 615 if x != nil { 616 return x.NextPageToken 617 } 618 return "" 619} 620 621var File_google_cloud_bigquery_migration_v2alpha_migration_service_proto protoreflect.FileDescriptor 622 623var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc = []byte{ 624 0x0a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 625 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 626 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 627 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 628 0x6f, 0x12, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 629 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 630 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 631 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 632 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 633 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 634 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 635 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 636 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 637 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x40, 0x67, 638 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 639 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 640 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 641 0x5f, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 642 0x45, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 643 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 644 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 645 0x6f, 0x6e, 0x5f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 646 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 647 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 648 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 649 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 650 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 651 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 652 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 653 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 654 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 655 0x70, 0x63, 0x2f, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 656 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd3, 0x01, 0x0a, 0x1e, 0x43, 0x72, 0x65, 0x61, 0x74, 657 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 658 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 659 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 660 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 661 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 662 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x6e, 0x0a, 0x12, 663 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 664 0x6f, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 665 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 666 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 667 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 668 0x66, 0x6c, 0x6f, 0x77, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x11, 0x6d, 0x69, 0x67, 0x72, 0x61, 669 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0xa6, 0x01, 0x0a, 670 0x1b, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 671 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 672 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 673 0x41, 0x34, 0x0a, 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 674 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 675 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 676 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x37, 0x0a, 0x09, 677 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 678 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 679 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x52, 0x08, 0x72, 0x65, 0x61, 680 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0xd7, 0x01, 0x0a, 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 681 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 682 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 683 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 684 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 685 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 686 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x37, 0x0a, 0x09, 0x72, 0x65, 687 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 688 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 689 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x52, 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 690 0x61, 0x73, 0x6b, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 691 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 692 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 693 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 694 0xb5, 0x01, 0x0a, 0x1e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 695 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 696 0x73, 0x65, 0x12, 0x6b, 0x0a, 0x13, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 697 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 698 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 699 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 700 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 701 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x12, 0x6d, 0x69, 0x67, 702 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x12, 703 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 704 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 705 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x70, 0x0a, 0x1e, 0x44, 0x65, 0x6c, 0x65, 0x74, 706 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 707 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 708 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 0x0a, 709 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 710 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 711 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 712 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x6f, 0x0a, 0x1d, 0x53, 0x74, 0x61, 713 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 714 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4e, 0x0a, 0x04, 0x6e, 0x61, 715 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 716 0x0a, 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 717 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 718 0x6f, 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 719 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xa9, 0x01, 0x0a, 0x1a, 0x47, 720 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 721 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 722 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x39, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x33, 0x0a, 723 0x31, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 724 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 725 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 726 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3c, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 727 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 728 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 729 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x08, 0x72, 0x65, 730 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x93, 0x02, 0x0a, 0x1c, 0x4c, 0x69, 0x73, 0x74, 0x4d, 731 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 732 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x52, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 733 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x3a, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x34, 0x0a, 734 0x32, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 735 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 736 0x6d, 0x2f, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 737 0x6c, 0x6f, 0x77, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x3c, 0x0a, 0x09, 0x72, 738 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 739 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 740 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 741 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x12, 0x20, 0x0a, 0x09, 0x70, 0x61, 0x67, 742 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x42, 0x03, 0xe0, 0x41, 743 0x01, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x22, 0x0a, 0x0a, 0x70, 744 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 745 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 746 0x1b, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x42, 747 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x22, 0xb1, 0x01, 0x0a, 748 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 749 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x68, 750 0x0a, 0x12, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x75, 0x62, 0x74, 751 0x61, 0x73, 0x6b, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 752 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 753 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 754 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 755 0x62, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x11, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 756 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 757 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 758 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 759 0x32, 0xaa, 0x0d, 0x0a, 0x10, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 760 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x8a, 0x02, 0x0a, 0x17, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 761 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 762 0x77, 0x12, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 763 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 764 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 765 0x74, 0x65, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 766 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 767 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 768 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 769 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 770 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0x6a, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x48, 0x22, 0x32, 771 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 772 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 773 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 774 0x77, 0x73, 0x3a, 0x12, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 775 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0xda, 0x41, 0x19, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 776 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 777 0x6f, 0x77, 0x12, 0xdb, 0x01, 0x0a, 0x14, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 778 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x44, 0x2e, 0x67, 0x6f, 779 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 780 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 781 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x47, 0x65, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 782 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 783 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 784 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 785 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 786 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x22, 0x41, 0x82, 787 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 788 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 789 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 790 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 791 0x12, 0xee, 0x01, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 792 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x12, 0x46, 0x2e, 0x67, 0x6f, 793 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 794 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 795 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 796 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 797 0x65, 0x73, 0x74, 0x1a, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 798 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 799 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 800 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 801 0x6c, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x43, 0x82, 0xd3, 802 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 803 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 804 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 805 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 806 0x74, 0x12, 0xbd, 0x01, 0x0a, 0x17, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x69, 0x67, 0x72, 807 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x47, 0x2e, 808 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 809 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 810 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x69, 811 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 812 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 813 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x41, 814 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x2a, 0x32, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 815 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 816 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 817 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 818 0x65, 0x12, 0xc4, 0x01, 0x0a, 0x16, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 819 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x12, 0x46, 0x2e, 0x67, 820 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 821 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 822 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4d, 0x69, 0x67, 0x72, 823 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x52, 0x65, 0x71, 824 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 825 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x4a, 0x82, 0xd3, 826 0xe4, 0x93, 0x02, 0x3d, 0x22, 0x38, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 827 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 828 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 829 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x3a, 0x01, 830 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xe3, 0x01, 0x0a, 0x13, 0x47, 0x65, 0x74, 831 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 832 0x12, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 833 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 834 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x47, 0x65, 0x74, 0x4d, 0x69, 835 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x52, 0x65, 836 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 837 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 838 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 839 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 840 0x22, 0x4c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3f, 0x12, 0x3d, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 841 0x68, 0x61, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 842 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 843 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x75, 0x62, 0x74, 844 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xf6, 845 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 846 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x45, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 847 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 848 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 849 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 850 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 851 0x46, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 852 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 853 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x69, 854 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x52, 855 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3f, 0x12, 856 0x3d, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 857 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 858 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 859 0x77, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x75, 0x62, 0x74, 0x61, 0x73, 0x6b, 0x73, 0xda, 0x41, 860 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x1a, 0x54, 0xca, 0x41, 0x20, 0x62, 0x69, 0x67, 0x71, 861 0x75, 0x65, 0x72, 0x79, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 862 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 863 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 864 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 865 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x98, 0x01, 866 0x0a, 0x2b, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 867 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x6d, 0x69, 0x67, 0x72, 868 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42, 0x15, 0x4d, 869 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 870 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x50, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 871 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 872 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 873 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x6d, 0x69, 0x67, 874 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x3b, 0x6d, 875 0x69, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 876} 877 878var ( 879 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce sync.Once 880 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc 881) 882 883func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescGZIP() []byte { 884 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescOnce.Do(func() { 885 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData) 886 }) 887 return file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDescData 888} 889 890var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes = make([]protoimpl.MessageInfo, 9) 891var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = []interface{}{ 892 (*CreateMigrationWorkflowRequest)(nil), // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 893 (*GetMigrationWorkflowRequest)(nil), // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 894 (*ListMigrationWorkflowsRequest)(nil), // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 895 (*ListMigrationWorkflowsResponse)(nil), // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 896 (*DeleteMigrationWorkflowRequest)(nil), // 4: google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 897 (*StartMigrationWorkflowRequest)(nil), // 5: google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 898 (*GetMigrationSubtaskRequest)(nil), // 6: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 899 (*ListMigrationSubtasksRequest)(nil), // 7: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 900 (*ListMigrationSubtasksResponse)(nil), // 8: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 901 (*MigrationWorkflow)(nil), // 9: google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 902 (*fieldmaskpb.FieldMask)(nil), // 10: google.protobuf.FieldMask 903 (*MigrationSubtask)(nil), // 11: google.cloud.bigquery.migration.v2alpha.MigrationSubtask 904 (*emptypb.Empty)(nil), // 12: google.protobuf.Empty 905} 906var file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = []int32{ 907 9, // 0: google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest.migration_workflow:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 908 10, // 1: google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest.read_mask:type_name -> google.protobuf.FieldMask 909 10, // 2: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest.read_mask:type_name -> google.protobuf.FieldMask 910 9, // 3: google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse.migration_workflows:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 911 10, // 4: google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest.read_mask:type_name -> google.protobuf.FieldMask 912 10, // 5: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest.read_mask:type_name -> google.protobuf.FieldMask 913 11, // 6: google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse.migration_subtasks:type_name -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 914 0, // 7: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.CreateMigrationWorkflowRequest 915 1, // 8: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationWorkflowRequest 916 2, // 9: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsRequest 917 4, // 10: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.DeleteMigrationWorkflowRequest 918 5, // 11: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:input_type -> google.cloud.bigquery.migration.v2alpha.StartMigrationWorkflowRequest 919 6, // 12: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:input_type -> google.cloud.bigquery.migration.v2alpha.GetMigrationSubtaskRequest 920 7, // 13: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:input_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksRequest 921 9, // 14: google.cloud.bigquery.migration.v2alpha.MigrationService.CreateMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 922 9, // 15: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationWorkflow:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationWorkflow 923 3, // 16: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationWorkflows:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationWorkflowsResponse 924 12, // 17: google.cloud.bigquery.migration.v2alpha.MigrationService.DeleteMigrationWorkflow:output_type -> google.protobuf.Empty 925 12, // 18: google.cloud.bigquery.migration.v2alpha.MigrationService.StartMigrationWorkflow:output_type -> google.protobuf.Empty 926 11, // 19: google.cloud.bigquery.migration.v2alpha.MigrationService.GetMigrationSubtask:output_type -> google.cloud.bigquery.migration.v2alpha.MigrationSubtask 927 8, // 20: google.cloud.bigquery.migration.v2alpha.MigrationService.ListMigrationSubtasks:output_type -> google.cloud.bigquery.migration.v2alpha.ListMigrationSubtasksResponse 928 14, // [14:21] is the sub-list for method output_type 929 7, // [7:14] is the sub-list for method input_type 930 7, // [7:7] is the sub-list for extension type_name 931 7, // [7:7] is the sub-list for extension extendee 932 0, // [0:7] is the sub-list for field type_name 933} 934 935func init() { file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() } 936func file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_init() { 937 if File_google_cloud_bigquery_migration_v2alpha_migration_service_proto != nil { 938 return 939 } 940 file_google_cloud_bigquery_migration_v2alpha_migration_entities_proto_init() 941 file_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto_init() 942 file_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto_init() 943 if !protoimpl.UnsafeEnabled { 944 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 945 switch v := v.(*CreateMigrationWorkflowRequest); i { 946 case 0: 947 return &v.state 948 case 1: 949 return &v.sizeCache 950 case 2: 951 return &v.unknownFields 952 default: 953 return nil 954 } 955 } 956 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 957 switch v := v.(*GetMigrationWorkflowRequest); i { 958 case 0: 959 return &v.state 960 case 1: 961 return &v.sizeCache 962 case 2: 963 return &v.unknownFields 964 default: 965 return nil 966 } 967 } 968 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 969 switch v := v.(*ListMigrationWorkflowsRequest); i { 970 case 0: 971 return &v.state 972 case 1: 973 return &v.sizeCache 974 case 2: 975 return &v.unknownFields 976 default: 977 return nil 978 } 979 } 980 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 981 switch v := v.(*ListMigrationWorkflowsResponse); i { 982 case 0: 983 return &v.state 984 case 1: 985 return &v.sizeCache 986 case 2: 987 return &v.unknownFields 988 default: 989 return nil 990 } 991 } 992 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 993 switch v := v.(*DeleteMigrationWorkflowRequest); i { 994 case 0: 995 return &v.state 996 case 1: 997 return &v.sizeCache 998 case 2: 999 return &v.unknownFields 1000 default: 1001 return nil 1002 } 1003 } 1004 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1005 switch v := v.(*StartMigrationWorkflowRequest); i { 1006 case 0: 1007 return &v.state 1008 case 1: 1009 return &v.sizeCache 1010 case 2: 1011 return &v.unknownFields 1012 default: 1013 return nil 1014 } 1015 } 1016 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1017 switch v := v.(*GetMigrationSubtaskRequest); i { 1018 case 0: 1019 return &v.state 1020 case 1: 1021 return &v.sizeCache 1022 case 2: 1023 return &v.unknownFields 1024 default: 1025 return nil 1026 } 1027 } 1028 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1029 switch v := v.(*ListMigrationSubtasksRequest); i { 1030 case 0: 1031 return &v.state 1032 case 1: 1033 return &v.sizeCache 1034 case 2: 1035 return &v.unknownFields 1036 default: 1037 return nil 1038 } 1039 } 1040 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1041 switch v := v.(*ListMigrationSubtasksResponse); i { 1042 case 0: 1043 return &v.state 1044 case 1: 1045 return &v.sizeCache 1046 case 2: 1047 return &v.unknownFields 1048 default: 1049 return nil 1050 } 1051 } 1052 } 1053 type x struct{} 1054 out := protoimpl.TypeBuilder{ 1055 File: protoimpl.DescBuilder{ 1056 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1057 RawDescriptor: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc, 1058 NumEnums: 0, 1059 NumMessages: 9, 1060 NumExtensions: 0, 1061 NumServices: 1, 1062 }, 1063 GoTypes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes, 1064 DependencyIndexes: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs, 1065 MessageInfos: file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_msgTypes, 1066 }.Build() 1067 File_google_cloud_bigquery_migration_v2alpha_migration_service_proto = out.File 1068 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_rawDesc = nil 1069 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_goTypes = nil 1070 file_google_cloud_bigquery_migration_v2alpha_migration_service_proto_depIdxs = nil 1071} 1072 1073// Reference imports to suppress errors if they are not otherwise used. 1074var _ context.Context 1075var _ grpc.ClientConnInterface 1076 1077// This is a compile-time assertion to ensure that this generated file 1078// is compatible with the grpc package it is being compiled against. 1079const _ = grpc.SupportPackageIsVersion6 1080 1081// MigrationServiceClient is the client API for MigrationService service. 1082// 1083// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1084type MigrationServiceClient interface { 1085 // Creates a migration workflow. 1086 CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1087 // Gets a previously created migration workflow. 1088 GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) 1089 // Lists previously created migration workflow. 1090 ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) 1091 // Deletes a migration workflow by name. 1092 DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1093 // Starts a previously created migration workflow. I.e., the state transitions 1094 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1095 // An error will be signaled if the state is anything other than DRAFT or 1096 // RUNNING. 1097 StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 1098 // Gets a previously created migration subtask. 1099 GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) 1100 // Lists previously created migration subtasks. 1101 ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) 1102} 1103 1104type migrationServiceClient struct { 1105 cc grpc.ClientConnInterface 1106} 1107 1108func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient { 1109 return &migrationServiceClient{cc} 1110} 1111 1112func (c *migrationServiceClient) CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1113 out := new(MigrationWorkflow) 1114 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", in, out, opts...) 1115 if err != nil { 1116 return nil, err 1117 } 1118 return out, nil 1119} 1120 1121func (c *migrationServiceClient) GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error) { 1122 out := new(MigrationWorkflow) 1123 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", in, out, opts...) 1124 if err != nil { 1125 return nil, err 1126 } 1127 return out, nil 1128} 1129 1130func (c *migrationServiceClient) ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error) { 1131 out := new(ListMigrationWorkflowsResponse) 1132 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", in, out, opts...) 1133 if err != nil { 1134 return nil, err 1135 } 1136 return out, nil 1137} 1138 1139func (c *migrationServiceClient) DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1140 out := new(emptypb.Empty) 1141 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", in, out, opts...) 1142 if err != nil { 1143 return nil, err 1144 } 1145 return out, nil 1146} 1147 1148func (c *migrationServiceClient) StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 1149 out := new(emptypb.Empty) 1150 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", in, out, opts...) 1151 if err != nil { 1152 return nil, err 1153 } 1154 return out, nil 1155} 1156 1157func (c *migrationServiceClient) GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error) { 1158 out := new(MigrationSubtask) 1159 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", in, out, opts...) 1160 if err != nil { 1161 return nil, err 1162 } 1163 return out, nil 1164} 1165 1166func (c *migrationServiceClient) ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error) { 1167 out := new(ListMigrationSubtasksResponse) 1168 err := c.cc.Invoke(ctx, "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", in, out, opts...) 1169 if err != nil { 1170 return nil, err 1171 } 1172 return out, nil 1173} 1174 1175// MigrationServiceServer is the server API for MigrationService service. 1176type MigrationServiceServer interface { 1177 // Creates a migration workflow. 1178 CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) 1179 // Gets a previously created migration workflow. 1180 GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) 1181 // Lists previously created migration workflow. 1182 ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) 1183 // Deletes a migration workflow by name. 1184 DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) 1185 // Starts a previously created migration workflow. I.e., the state transitions 1186 // from DRAFT to RUNNING. This is a no-op if the state is already RUNNING. 1187 // An error will be signaled if the state is anything other than DRAFT or 1188 // RUNNING. 1189 StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) 1190 // Gets a previously created migration subtask. 1191 GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) 1192 // Lists previously created migration subtasks. 1193 ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) 1194} 1195 1196// UnimplementedMigrationServiceServer can be embedded to have forward compatible implementations. 1197type UnimplementedMigrationServiceServer struct { 1198} 1199 1200func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1201 return nil, status.Errorf(codes.Unimplemented, "method CreateMigrationWorkflow not implemented") 1202} 1203func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error) { 1204 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationWorkflow not implemented") 1205} 1206func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error) { 1207 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationWorkflows not implemented") 1208} 1209func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error) { 1210 return nil, status.Errorf(codes.Unimplemented, "method DeleteMigrationWorkflow not implemented") 1211} 1212func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error) { 1213 return nil, status.Errorf(codes.Unimplemented, "method StartMigrationWorkflow not implemented") 1214} 1215func (*UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error) { 1216 return nil, status.Errorf(codes.Unimplemented, "method GetMigrationSubtask not implemented") 1217} 1218func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error) { 1219 return nil, status.Errorf(codes.Unimplemented, "method ListMigrationSubtasks not implemented") 1220} 1221 1222func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer) { 1223 s.RegisterService(&_MigrationService_serviceDesc, srv) 1224} 1225 1226func _MigrationService_CreateMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1227 in := new(CreateMigrationWorkflowRequest) 1228 if err := dec(in); err != nil { 1229 return nil, err 1230 } 1231 if interceptor == nil { 1232 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, in) 1233 } 1234 info := &grpc.UnaryServerInfo{ 1235 Server: srv, 1236 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/CreateMigrationWorkflow", 1237 } 1238 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1239 return srv.(MigrationServiceServer).CreateMigrationWorkflow(ctx, req.(*CreateMigrationWorkflowRequest)) 1240 } 1241 return interceptor(ctx, in, info, handler) 1242} 1243 1244func _MigrationService_GetMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1245 in := new(GetMigrationWorkflowRequest) 1246 if err := dec(in); err != nil { 1247 return nil, err 1248 } 1249 if interceptor == nil { 1250 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, in) 1251 } 1252 info := &grpc.UnaryServerInfo{ 1253 Server: srv, 1254 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationWorkflow", 1255 } 1256 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1257 return srv.(MigrationServiceServer).GetMigrationWorkflow(ctx, req.(*GetMigrationWorkflowRequest)) 1258 } 1259 return interceptor(ctx, in, info, handler) 1260} 1261 1262func _MigrationService_ListMigrationWorkflows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1263 in := new(ListMigrationWorkflowsRequest) 1264 if err := dec(in); err != nil { 1265 return nil, err 1266 } 1267 if interceptor == nil { 1268 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, in) 1269 } 1270 info := &grpc.UnaryServerInfo{ 1271 Server: srv, 1272 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationWorkflows", 1273 } 1274 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1275 return srv.(MigrationServiceServer).ListMigrationWorkflows(ctx, req.(*ListMigrationWorkflowsRequest)) 1276 } 1277 return interceptor(ctx, in, info, handler) 1278} 1279 1280func _MigrationService_DeleteMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1281 in := new(DeleteMigrationWorkflowRequest) 1282 if err := dec(in); err != nil { 1283 return nil, err 1284 } 1285 if interceptor == nil { 1286 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, in) 1287 } 1288 info := &grpc.UnaryServerInfo{ 1289 Server: srv, 1290 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/DeleteMigrationWorkflow", 1291 } 1292 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1293 return srv.(MigrationServiceServer).DeleteMigrationWorkflow(ctx, req.(*DeleteMigrationWorkflowRequest)) 1294 } 1295 return interceptor(ctx, in, info, handler) 1296} 1297 1298func _MigrationService_StartMigrationWorkflow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1299 in := new(StartMigrationWorkflowRequest) 1300 if err := dec(in); err != nil { 1301 return nil, err 1302 } 1303 if interceptor == nil { 1304 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, in) 1305 } 1306 info := &grpc.UnaryServerInfo{ 1307 Server: srv, 1308 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/StartMigrationWorkflow", 1309 } 1310 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1311 return srv.(MigrationServiceServer).StartMigrationWorkflow(ctx, req.(*StartMigrationWorkflowRequest)) 1312 } 1313 return interceptor(ctx, in, info, handler) 1314} 1315 1316func _MigrationService_GetMigrationSubtask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1317 in := new(GetMigrationSubtaskRequest) 1318 if err := dec(in); err != nil { 1319 return nil, err 1320 } 1321 if interceptor == nil { 1322 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, in) 1323 } 1324 info := &grpc.UnaryServerInfo{ 1325 Server: srv, 1326 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/GetMigrationSubtask", 1327 } 1328 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1329 return srv.(MigrationServiceServer).GetMigrationSubtask(ctx, req.(*GetMigrationSubtaskRequest)) 1330 } 1331 return interceptor(ctx, in, info, handler) 1332} 1333 1334func _MigrationService_ListMigrationSubtasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1335 in := new(ListMigrationSubtasksRequest) 1336 if err := dec(in); err != nil { 1337 return nil, err 1338 } 1339 if interceptor == nil { 1340 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, in) 1341 } 1342 info := &grpc.UnaryServerInfo{ 1343 Server: srv, 1344 FullMethod: "/google.cloud.bigquery.migration.v2alpha.MigrationService/ListMigrationSubtasks", 1345 } 1346 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1347 return srv.(MigrationServiceServer).ListMigrationSubtasks(ctx, req.(*ListMigrationSubtasksRequest)) 1348 } 1349 return interceptor(ctx, in, info, handler) 1350} 1351 1352var _MigrationService_serviceDesc = grpc.ServiceDesc{ 1353 ServiceName: "google.cloud.bigquery.migration.v2alpha.MigrationService", 1354 HandlerType: (*MigrationServiceServer)(nil), 1355 Methods: []grpc.MethodDesc{ 1356 { 1357 MethodName: "CreateMigrationWorkflow", 1358 Handler: _MigrationService_CreateMigrationWorkflow_Handler, 1359 }, 1360 { 1361 MethodName: "GetMigrationWorkflow", 1362 Handler: _MigrationService_GetMigrationWorkflow_Handler, 1363 }, 1364 { 1365 MethodName: "ListMigrationWorkflows", 1366 Handler: _MigrationService_ListMigrationWorkflows_Handler, 1367 }, 1368 { 1369 MethodName: "DeleteMigrationWorkflow", 1370 Handler: _MigrationService_DeleteMigrationWorkflow_Handler, 1371 }, 1372 { 1373 MethodName: "StartMigrationWorkflow", 1374 Handler: _MigrationService_StartMigrationWorkflow_Handler, 1375 }, 1376 { 1377 MethodName: "GetMigrationSubtask", 1378 Handler: _MigrationService_GetMigrationSubtask_Handler, 1379 }, 1380 { 1381 MethodName: "ListMigrationSubtasks", 1382 Handler: _MigrationService_ListMigrationSubtasks_Handler, 1383 }, 1384 }, 1385 Streams: []grpc.StreamDesc{}, 1386 Metadata: "google/cloud/bigquery/migration/v2alpha/migration_service.proto", 1387} 1388