Source file src/cloud.google.com/go/bigquery/migration/apiv2/migrationpb/migration_service.pb.go

Documentation: cloud.google.com/go/bigquery/migration/apiv2/migrationpb

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

View as plain text