...

Source file src/cloud.google.com/go/bigquery/connection/apiv1beta1/connectionpb/connection.pb.go

Documentation: cloud.google.com/go/bigquery/connection/apiv1beta1/connectionpb

     1  // Copyright 2022 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/connection/v1beta1/connection.proto
    20  
    21  package connectionpb
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	iampb "cloud.google.com/go/iam/apiv1/iampb"
    29  	_ "google.golang.org/genproto/googleapis/api/annotations"
    30  	grpc "google.golang.org/grpc"
    31  	codes "google.golang.org/grpc/codes"
    32  	status "google.golang.org/grpc/status"
    33  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    34  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    35  	emptypb "google.golang.org/protobuf/types/known/emptypb"
    36  	fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb"
    37  	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
    38  )
    39  
    40  const (
    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  // Supported Cloud SQL database types.
    48  type CloudSqlProperties_DatabaseType int32
    49  
    50  const (
    51  	// Unspecified database type.
    52  	CloudSqlProperties_DATABASE_TYPE_UNSPECIFIED CloudSqlProperties_DatabaseType = 0
    53  	// Cloud SQL for PostgreSQL.
    54  	CloudSqlProperties_POSTGRES CloudSqlProperties_DatabaseType = 1
    55  	// Cloud SQL for MySQL.
    56  	CloudSqlProperties_MYSQL CloudSqlProperties_DatabaseType = 2
    57  )
    58  
    59  // Enum value maps for CloudSqlProperties_DatabaseType.
    60  var (
    61  	CloudSqlProperties_DatabaseType_name = map[int32]string{
    62  		0: "DATABASE_TYPE_UNSPECIFIED",
    63  		1: "POSTGRES",
    64  		2: "MYSQL",
    65  	}
    66  	CloudSqlProperties_DatabaseType_value = map[string]int32{
    67  		"DATABASE_TYPE_UNSPECIFIED": 0,
    68  		"POSTGRES":                  1,
    69  		"MYSQL":                     2,
    70  	}
    71  )
    72  
    73  func (x CloudSqlProperties_DatabaseType) Enum() *CloudSqlProperties_DatabaseType {
    74  	p := new(CloudSqlProperties_DatabaseType)
    75  	*p = x
    76  	return p
    77  }
    78  
    79  func (x CloudSqlProperties_DatabaseType) String() string {
    80  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    81  }
    82  
    83  func (CloudSqlProperties_DatabaseType) Descriptor() protoreflect.EnumDescriptor {
    84  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_enumTypes[0].Descriptor()
    85  }
    86  
    87  func (CloudSqlProperties_DatabaseType) Type() protoreflect.EnumType {
    88  	return &file_google_cloud_bigquery_connection_v1beta1_connection_proto_enumTypes[0]
    89  }
    90  
    91  func (x CloudSqlProperties_DatabaseType) Number() protoreflect.EnumNumber {
    92  	return protoreflect.EnumNumber(x)
    93  }
    94  
    95  // Deprecated: Use CloudSqlProperties_DatabaseType.Descriptor instead.
    96  func (CloudSqlProperties_DatabaseType) EnumDescriptor() ([]byte, []int) {
    97  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{9, 0}
    98  }
    99  
   100  // The request for
   101  // [ConnectionService.CreateConnection][google.cloud.bigquery.connection.v1beta1.ConnectionService.CreateConnection].
   102  type CreateConnectionRequest struct {
   103  	state         protoimpl.MessageState
   104  	sizeCache     protoimpl.SizeCache
   105  	unknownFields protoimpl.UnknownFields
   106  
   107  	// Required. Parent resource name.
   108  	// Must be in the format `projects/{project_id}/locations/{location_id}`
   109  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   110  	// Optional. Connection id that should be assigned to the created connection.
   111  	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
   112  	// Required. Connection to create.
   113  	Connection *Connection `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
   114  }
   115  
   116  func (x *CreateConnectionRequest) Reset() {
   117  	*x = CreateConnectionRequest{}
   118  	if protoimpl.UnsafeEnabled {
   119  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[0]
   120  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   121  		ms.StoreMessageInfo(mi)
   122  	}
   123  }
   124  
   125  func (x *CreateConnectionRequest) String() string {
   126  	return protoimpl.X.MessageStringOf(x)
   127  }
   128  
   129  func (*CreateConnectionRequest) ProtoMessage() {}
   130  
   131  func (x *CreateConnectionRequest) ProtoReflect() protoreflect.Message {
   132  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[0]
   133  	if protoimpl.UnsafeEnabled && x != nil {
   134  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   135  		if ms.LoadMessageInfo() == nil {
   136  			ms.StoreMessageInfo(mi)
   137  		}
   138  		return ms
   139  	}
   140  	return mi.MessageOf(x)
   141  }
   142  
   143  // Deprecated: Use CreateConnectionRequest.ProtoReflect.Descriptor instead.
   144  func (*CreateConnectionRequest) Descriptor() ([]byte, []int) {
   145  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{0}
   146  }
   147  
   148  func (x *CreateConnectionRequest) GetParent() string {
   149  	if x != nil {
   150  		return x.Parent
   151  	}
   152  	return ""
   153  }
   154  
   155  func (x *CreateConnectionRequest) GetConnectionId() string {
   156  	if x != nil {
   157  		return x.ConnectionId
   158  	}
   159  	return ""
   160  }
   161  
   162  func (x *CreateConnectionRequest) GetConnection() *Connection {
   163  	if x != nil {
   164  		return x.Connection
   165  	}
   166  	return nil
   167  }
   168  
   169  // The request for
   170  // [ConnectionService.GetConnection][google.cloud.bigquery.connection.v1beta1.ConnectionService.GetConnection].
   171  type GetConnectionRequest struct {
   172  	state         protoimpl.MessageState
   173  	sizeCache     protoimpl.SizeCache
   174  	unknownFields protoimpl.UnknownFields
   175  
   176  	// Required. Name of the requested connection, for example:
   177  	// `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
   178  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   179  }
   180  
   181  func (x *GetConnectionRequest) Reset() {
   182  	*x = GetConnectionRequest{}
   183  	if protoimpl.UnsafeEnabled {
   184  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[1]
   185  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   186  		ms.StoreMessageInfo(mi)
   187  	}
   188  }
   189  
   190  func (x *GetConnectionRequest) String() string {
   191  	return protoimpl.X.MessageStringOf(x)
   192  }
   193  
   194  func (*GetConnectionRequest) ProtoMessage() {}
   195  
   196  func (x *GetConnectionRequest) ProtoReflect() protoreflect.Message {
   197  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[1]
   198  	if protoimpl.UnsafeEnabled && x != nil {
   199  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   200  		if ms.LoadMessageInfo() == nil {
   201  			ms.StoreMessageInfo(mi)
   202  		}
   203  		return ms
   204  	}
   205  	return mi.MessageOf(x)
   206  }
   207  
   208  // Deprecated: Use GetConnectionRequest.ProtoReflect.Descriptor instead.
   209  func (*GetConnectionRequest) Descriptor() ([]byte, []int) {
   210  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{1}
   211  }
   212  
   213  func (x *GetConnectionRequest) GetName() string {
   214  	if x != nil {
   215  		return x.Name
   216  	}
   217  	return ""
   218  }
   219  
   220  // The request for
   221  // [ConnectionService.ListConnections][google.cloud.bigquery.connection.v1beta1.ConnectionService.ListConnections].
   222  type ListConnectionsRequest struct {
   223  	state         protoimpl.MessageState
   224  	sizeCache     protoimpl.SizeCache
   225  	unknownFields protoimpl.UnknownFields
   226  
   227  	// Required. Parent resource name.
   228  	// Must be in the form: `projects/{project_id}/locations/{location_id}`
   229  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   230  	// Required. Maximum number of results per page.
   231  	MaxResults *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
   232  	// Page token.
   233  	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
   234  }
   235  
   236  func (x *ListConnectionsRequest) Reset() {
   237  	*x = ListConnectionsRequest{}
   238  	if protoimpl.UnsafeEnabled {
   239  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[2]
   240  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   241  		ms.StoreMessageInfo(mi)
   242  	}
   243  }
   244  
   245  func (x *ListConnectionsRequest) String() string {
   246  	return protoimpl.X.MessageStringOf(x)
   247  }
   248  
   249  func (*ListConnectionsRequest) ProtoMessage() {}
   250  
   251  func (x *ListConnectionsRequest) ProtoReflect() protoreflect.Message {
   252  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[2]
   253  	if protoimpl.UnsafeEnabled && x != nil {
   254  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   255  		if ms.LoadMessageInfo() == nil {
   256  			ms.StoreMessageInfo(mi)
   257  		}
   258  		return ms
   259  	}
   260  	return mi.MessageOf(x)
   261  }
   262  
   263  // Deprecated: Use ListConnectionsRequest.ProtoReflect.Descriptor instead.
   264  func (*ListConnectionsRequest) Descriptor() ([]byte, []int) {
   265  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{2}
   266  }
   267  
   268  func (x *ListConnectionsRequest) GetParent() string {
   269  	if x != nil {
   270  		return x.Parent
   271  	}
   272  	return ""
   273  }
   274  
   275  func (x *ListConnectionsRequest) GetMaxResults() *wrapperspb.UInt32Value {
   276  	if x != nil {
   277  		return x.MaxResults
   278  	}
   279  	return nil
   280  }
   281  
   282  func (x *ListConnectionsRequest) GetPageToken() string {
   283  	if x != nil {
   284  		return x.PageToken
   285  	}
   286  	return ""
   287  }
   288  
   289  // The response for
   290  // [ConnectionService.ListConnections][google.cloud.bigquery.connection.v1beta1.ConnectionService.ListConnections].
   291  type ListConnectionsResponse struct {
   292  	state         protoimpl.MessageState
   293  	sizeCache     protoimpl.SizeCache
   294  	unknownFields protoimpl.UnknownFields
   295  
   296  	// Next page token.
   297  	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
   298  	// List of connections.
   299  	Connections []*Connection `protobuf:"bytes,2,rep,name=connections,proto3" json:"connections,omitempty"`
   300  }
   301  
   302  func (x *ListConnectionsResponse) Reset() {
   303  	*x = ListConnectionsResponse{}
   304  	if protoimpl.UnsafeEnabled {
   305  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[3]
   306  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   307  		ms.StoreMessageInfo(mi)
   308  	}
   309  }
   310  
   311  func (x *ListConnectionsResponse) String() string {
   312  	return protoimpl.X.MessageStringOf(x)
   313  }
   314  
   315  func (*ListConnectionsResponse) ProtoMessage() {}
   316  
   317  func (x *ListConnectionsResponse) ProtoReflect() protoreflect.Message {
   318  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[3]
   319  	if protoimpl.UnsafeEnabled && x != nil {
   320  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   321  		if ms.LoadMessageInfo() == nil {
   322  			ms.StoreMessageInfo(mi)
   323  		}
   324  		return ms
   325  	}
   326  	return mi.MessageOf(x)
   327  }
   328  
   329  // Deprecated: Use ListConnectionsResponse.ProtoReflect.Descriptor instead.
   330  func (*ListConnectionsResponse) Descriptor() ([]byte, []int) {
   331  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{3}
   332  }
   333  
   334  func (x *ListConnectionsResponse) GetNextPageToken() string {
   335  	if x != nil {
   336  		return x.NextPageToken
   337  	}
   338  	return ""
   339  }
   340  
   341  func (x *ListConnectionsResponse) GetConnections() []*Connection {
   342  	if x != nil {
   343  		return x.Connections
   344  	}
   345  	return nil
   346  }
   347  
   348  // The request for
   349  // [ConnectionService.UpdateConnection][google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnection].
   350  type UpdateConnectionRequest struct {
   351  	state         protoimpl.MessageState
   352  	sizeCache     protoimpl.SizeCache
   353  	unknownFields protoimpl.UnknownFields
   354  
   355  	// Required. Name of the connection to update, for example:
   356  	// `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
   357  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   358  	// Required. Connection containing the updated fields.
   359  	Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
   360  	// Required. Update mask for the connection fields to be updated.
   361  	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
   362  }
   363  
   364  func (x *UpdateConnectionRequest) Reset() {
   365  	*x = UpdateConnectionRequest{}
   366  	if protoimpl.UnsafeEnabled {
   367  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[4]
   368  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   369  		ms.StoreMessageInfo(mi)
   370  	}
   371  }
   372  
   373  func (x *UpdateConnectionRequest) String() string {
   374  	return protoimpl.X.MessageStringOf(x)
   375  }
   376  
   377  func (*UpdateConnectionRequest) ProtoMessage() {}
   378  
   379  func (x *UpdateConnectionRequest) ProtoReflect() protoreflect.Message {
   380  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[4]
   381  	if protoimpl.UnsafeEnabled && x != nil {
   382  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   383  		if ms.LoadMessageInfo() == nil {
   384  			ms.StoreMessageInfo(mi)
   385  		}
   386  		return ms
   387  	}
   388  	return mi.MessageOf(x)
   389  }
   390  
   391  // Deprecated: Use UpdateConnectionRequest.ProtoReflect.Descriptor instead.
   392  func (*UpdateConnectionRequest) Descriptor() ([]byte, []int) {
   393  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{4}
   394  }
   395  
   396  func (x *UpdateConnectionRequest) GetName() string {
   397  	if x != nil {
   398  		return x.Name
   399  	}
   400  	return ""
   401  }
   402  
   403  func (x *UpdateConnectionRequest) GetConnection() *Connection {
   404  	if x != nil {
   405  		return x.Connection
   406  	}
   407  	return nil
   408  }
   409  
   410  func (x *UpdateConnectionRequest) GetUpdateMask() *fieldmaskpb.FieldMask {
   411  	if x != nil {
   412  		return x.UpdateMask
   413  	}
   414  	return nil
   415  }
   416  
   417  // The request for
   418  // [ConnectionService.UpdateConnectionCredential][google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnectionCredential].
   419  type UpdateConnectionCredentialRequest struct {
   420  	state         protoimpl.MessageState
   421  	sizeCache     protoimpl.SizeCache
   422  	unknownFields protoimpl.UnknownFields
   423  
   424  	// Required. Name of the connection, for example:
   425  	// `projects/{project_id}/locations/{location_id}/connections/{connection_id}/credential`
   426  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   427  	// Required. Credential to use with the connection.
   428  	Credential *ConnectionCredential `protobuf:"bytes,2,opt,name=credential,proto3" json:"credential,omitempty"`
   429  }
   430  
   431  func (x *UpdateConnectionCredentialRequest) Reset() {
   432  	*x = UpdateConnectionCredentialRequest{}
   433  	if protoimpl.UnsafeEnabled {
   434  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[5]
   435  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   436  		ms.StoreMessageInfo(mi)
   437  	}
   438  }
   439  
   440  func (x *UpdateConnectionCredentialRequest) String() string {
   441  	return protoimpl.X.MessageStringOf(x)
   442  }
   443  
   444  func (*UpdateConnectionCredentialRequest) ProtoMessage() {}
   445  
   446  func (x *UpdateConnectionCredentialRequest) ProtoReflect() protoreflect.Message {
   447  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[5]
   448  	if protoimpl.UnsafeEnabled && x != nil {
   449  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   450  		if ms.LoadMessageInfo() == nil {
   451  			ms.StoreMessageInfo(mi)
   452  		}
   453  		return ms
   454  	}
   455  	return mi.MessageOf(x)
   456  }
   457  
   458  // Deprecated: Use UpdateConnectionCredentialRequest.ProtoReflect.Descriptor instead.
   459  func (*UpdateConnectionCredentialRequest) Descriptor() ([]byte, []int) {
   460  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{5}
   461  }
   462  
   463  func (x *UpdateConnectionCredentialRequest) GetName() string {
   464  	if x != nil {
   465  		return x.Name
   466  	}
   467  	return ""
   468  }
   469  
   470  func (x *UpdateConnectionCredentialRequest) GetCredential() *ConnectionCredential {
   471  	if x != nil {
   472  		return x.Credential
   473  	}
   474  	return nil
   475  }
   476  
   477  // The request for [ConnectionService.DeleteConnectionRequest][].
   478  type DeleteConnectionRequest struct {
   479  	state         protoimpl.MessageState
   480  	sizeCache     protoimpl.SizeCache
   481  	unknownFields protoimpl.UnknownFields
   482  
   483  	// Required. Name of the deleted connection, for example:
   484  	// `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
   485  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   486  }
   487  
   488  func (x *DeleteConnectionRequest) Reset() {
   489  	*x = DeleteConnectionRequest{}
   490  	if protoimpl.UnsafeEnabled {
   491  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[6]
   492  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   493  		ms.StoreMessageInfo(mi)
   494  	}
   495  }
   496  
   497  func (x *DeleteConnectionRequest) String() string {
   498  	return protoimpl.X.MessageStringOf(x)
   499  }
   500  
   501  func (*DeleteConnectionRequest) ProtoMessage() {}
   502  
   503  func (x *DeleteConnectionRequest) ProtoReflect() protoreflect.Message {
   504  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[6]
   505  	if protoimpl.UnsafeEnabled && x != nil {
   506  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   507  		if ms.LoadMessageInfo() == nil {
   508  			ms.StoreMessageInfo(mi)
   509  		}
   510  		return ms
   511  	}
   512  	return mi.MessageOf(x)
   513  }
   514  
   515  // Deprecated: Use DeleteConnectionRequest.ProtoReflect.Descriptor instead.
   516  func (*DeleteConnectionRequest) Descriptor() ([]byte, []int) {
   517  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{6}
   518  }
   519  
   520  func (x *DeleteConnectionRequest) GetName() string {
   521  	if x != nil {
   522  		return x.Name
   523  	}
   524  	return ""
   525  }
   526  
   527  // Configuration parameters to establish connection with an external data
   528  // source, except the credential attributes.
   529  type Connection struct {
   530  	state         protoimpl.MessageState
   531  	sizeCache     protoimpl.SizeCache
   532  	unknownFields protoimpl.UnknownFields
   533  
   534  	// The resource name of the connection in the form of:
   535  	// `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
   536  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   537  	// User provided display name for the connection.
   538  	FriendlyName string `protobuf:"bytes,2,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
   539  	// User provided description.
   540  	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
   541  	// Properties specific to the underlying data source.
   542  	//
   543  	// Types that are assignable to Properties:
   544  	//
   545  	//	*Connection_CloudSql
   546  	Properties isConnection_Properties `protobuf_oneof:"properties"`
   547  	// Output only. The creation timestamp of the connection.
   548  	CreationTime int64 `protobuf:"varint,5,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
   549  	// Output only. The last update timestamp of the connection.
   550  	LastModifiedTime int64 `protobuf:"varint,6,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
   551  	// Output only. True, if credential is configured for this connection.
   552  	HasCredential bool `protobuf:"varint,7,opt,name=has_credential,json=hasCredential,proto3" json:"has_credential,omitempty"`
   553  }
   554  
   555  func (x *Connection) Reset() {
   556  	*x = Connection{}
   557  	if protoimpl.UnsafeEnabled {
   558  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[7]
   559  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   560  		ms.StoreMessageInfo(mi)
   561  	}
   562  }
   563  
   564  func (x *Connection) String() string {
   565  	return protoimpl.X.MessageStringOf(x)
   566  }
   567  
   568  func (*Connection) ProtoMessage() {}
   569  
   570  func (x *Connection) ProtoReflect() protoreflect.Message {
   571  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[7]
   572  	if protoimpl.UnsafeEnabled && x != nil {
   573  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   574  		if ms.LoadMessageInfo() == nil {
   575  			ms.StoreMessageInfo(mi)
   576  		}
   577  		return ms
   578  	}
   579  	return mi.MessageOf(x)
   580  }
   581  
   582  // Deprecated: Use Connection.ProtoReflect.Descriptor instead.
   583  func (*Connection) Descriptor() ([]byte, []int) {
   584  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{7}
   585  }
   586  
   587  func (x *Connection) GetName() string {
   588  	if x != nil {
   589  		return x.Name
   590  	}
   591  	return ""
   592  }
   593  
   594  func (x *Connection) GetFriendlyName() string {
   595  	if x != nil {
   596  		return x.FriendlyName
   597  	}
   598  	return ""
   599  }
   600  
   601  func (x *Connection) GetDescription() string {
   602  	if x != nil {
   603  		return x.Description
   604  	}
   605  	return ""
   606  }
   607  
   608  func (m *Connection) GetProperties() isConnection_Properties {
   609  	if m != nil {
   610  		return m.Properties
   611  	}
   612  	return nil
   613  }
   614  
   615  func (x *Connection) GetCloudSql() *CloudSqlProperties {
   616  	if x, ok := x.GetProperties().(*Connection_CloudSql); ok {
   617  		return x.CloudSql
   618  	}
   619  	return nil
   620  }
   621  
   622  func (x *Connection) GetCreationTime() int64 {
   623  	if x != nil {
   624  		return x.CreationTime
   625  	}
   626  	return 0
   627  }
   628  
   629  func (x *Connection) GetLastModifiedTime() int64 {
   630  	if x != nil {
   631  		return x.LastModifiedTime
   632  	}
   633  	return 0
   634  }
   635  
   636  func (x *Connection) GetHasCredential() bool {
   637  	if x != nil {
   638  		return x.HasCredential
   639  	}
   640  	return false
   641  }
   642  
   643  type isConnection_Properties interface {
   644  	isConnection_Properties()
   645  }
   646  
   647  type Connection_CloudSql struct {
   648  	// Cloud SQL properties.
   649  	CloudSql *CloudSqlProperties `protobuf:"bytes,4,opt,name=cloud_sql,json=cloudSql,proto3,oneof"`
   650  }
   651  
   652  func (*Connection_CloudSql) isConnection_Properties() {}
   653  
   654  // Credential to use with a connection.
   655  type ConnectionCredential struct {
   656  	state         protoimpl.MessageState
   657  	sizeCache     protoimpl.SizeCache
   658  	unknownFields protoimpl.UnknownFields
   659  
   660  	// Credential specific to the underlying data source.
   661  	//
   662  	// Types that are assignable to Credential:
   663  	//
   664  	//	*ConnectionCredential_CloudSql
   665  	Credential isConnectionCredential_Credential `protobuf_oneof:"credential"`
   666  }
   667  
   668  func (x *ConnectionCredential) Reset() {
   669  	*x = ConnectionCredential{}
   670  	if protoimpl.UnsafeEnabled {
   671  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[8]
   672  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   673  		ms.StoreMessageInfo(mi)
   674  	}
   675  }
   676  
   677  func (x *ConnectionCredential) String() string {
   678  	return protoimpl.X.MessageStringOf(x)
   679  }
   680  
   681  func (*ConnectionCredential) ProtoMessage() {}
   682  
   683  func (x *ConnectionCredential) ProtoReflect() protoreflect.Message {
   684  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[8]
   685  	if protoimpl.UnsafeEnabled && x != nil {
   686  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   687  		if ms.LoadMessageInfo() == nil {
   688  			ms.StoreMessageInfo(mi)
   689  		}
   690  		return ms
   691  	}
   692  	return mi.MessageOf(x)
   693  }
   694  
   695  // Deprecated: Use ConnectionCredential.ProtoReflect.Descriptor instead.
   696  func (*ConnectionCredential) Descriptor() ([]byte, []int) {
   697  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{8}
   698  }
   699  
   700  func (m *ConnectionCredential) GetCredential() isConnectionCredential_Credential {
   701  	if m != nil {
   702  		return m.Credential
   703  	}
   704  	return nil
   705  }
   706  
   707  func (x *ConnectionCredential) GetCloudSql() *CloudSqlCredential {
   708  	if x, ok := x.GetCredential().(*ConnectionCredential_CloudSql); ok {
   709  		return x.CloudSql
   710  	}
   711  	return nil
   712  }
   713  
   714  type isConnectionCredential_Credential interface {
   715  	isConnectionCredential_Credential()
   716  }
   717  
   718  type ConnectionCredential_CloudSql struct {
   719  	// Credential for Cloud SQL database.
   720  	CloudSql *CloudSqlCredential `protobuf:"bytes,1,opt,name=cloud_sql,json=cloudSql,proto3,oneof"`
   721  }
   722  
   723  func (*ConnectionCredential_CloudSql) isConnectionCredential_Credential() {}
   724  
   725  // Connection properties specific to the Cloud SQL.
   726  type CloudSqlProperties struct {
   727  	state         protoimpl.MessageState
   728  	sizeCache     protoimpl.SizeCache
   729  	unknownFields protoimpl.UnknownFields
   730  
   731  	// Cloud SQL instance ID in the form `project:location:instance`.
   732  	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
   733  	// Database name.
   734  	Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
   735  	// Type of the Cloud SQL database.
   736  	Type CloudSqlProperties_DatabaseType `protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.bigquery.connection.v1beta1.CloudSqlProperties_DatabaseType" json:"type,omitempty"`
   737  	// Input only. Cloud SQL credential.
   738  	Credential *CloudSqlCredential `protobuf:"bytes,4,opt,name=credential,proto3" json:"credential,omitempty"`
   739  	// Output only. The account ID of the service used for the purpose of this
   740  	// connection.
   741  	//
   742  	// When the connection is used in the context of an operation in
   743  	// BigQuery, this service account will serve as the identity being used for
   744  	// connecting to the CloudSQL instance specified in this connection.
   745  	ServiceAccountId string `protobuf:"bytes,5,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
   746  }
   747  
   748  func (x *CloudSqlProperties) Reset() {
   749  	*x = CloudSqlProperties{}
   750  	if protoimpl.UnsafeEnabled {
   751  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[9]
   752  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   753  		ms.StoreMessageInfo(mi)
   754  	}
   755  }
   756  
   757  func (x *CloudSqlProperties) String() string {
   758  	return protoimpl.X.MessageStringOf(x)
   759  }
   760  
   761  func (*CloudSqlProperties) ProtoMessage() {}
   762  
   763  func (x *CloudSqlProperties) ProtoReflect() protoreflect.Message {
   764  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[9]
   765  	if protoimpl.UnsafeEnabled && x != nil {
   766  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   767  		if ms.LoadMessageInfo() == nil {
   768  			ms.StoreMessageInfo(mi)
   769  		}
   770  		return ms
   771  	}
   772  	return mi.MessageOf(x)
   773  }
   774  
   775  // Deprecated: Use CloudSqlProperties.ProtoReflect.Descriptor instead.
   776  func (*CloudSqlProperties) Descriptor() ([]byte, []int) {
   777  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{9}
   778  }
   779  
   780  func (x *CloudSqlProperties) GetInstanceId() string {
   781  	if x != nil {
   782  		return x.InstanceId
   783  	}
   784  	return ""
   785  }
   786  
   787  func (x *CloudSqlProperties) GetDatabase() string {
   788  	if x != nil {
   789  		return x.Database
   790  	}
   791  	return ""
   792  }
   793  
   794  func (x *CloudSqlProperties) GetType() CloudSqlProperties_DatabaseType {
   795  	if x != nil {
   796  		return x.Type
   797  	}
   798  	return CloudSqlProperties_DATABASE_TYPE_UNSPECIFIED
   799  }
   800  
   801  func (x *CloudSqlProperties) GetCredential() *CloudSqlCredential {
   802  	if x != nil {
   803  		return x.Credential
   804  	}
   805  	return nil
   806  }
   807  
   808  func (x *CloudSqlProperties) GetServiceAccountId() string {
   809  	if x != nil {
   810  		return x.ServiceAccountId
   811  	}
   812  	return ""
   813  }
   814  
   815  // Credential info for the Cloud SQL.
   816  type CloudSqlCredential struct {
   817  	state         protoimpl.MessageState
   818  	sizeCache     protoimpl.SizeCache
   819  	unknownFields protoimpl.UnknownFields
   820  
   821  	// The username for the credential.
   822  	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
   823  	// The password for the credential.
   824  	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
   825  }
   826  
   827  func (x *CloudSqlCredential) Reset() {
   828  	*x = CloudSqlCredential{}
   829  	if protoimpl.UnsafeEnabled {
   830  		mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[10]
   831  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   832  		ms.StoreMessageInfo(mi)
   833  	}
   834  }
   835  
   836  func (x *CloudSqlCredential) String() string {
   837  	return protoimpl.X.MessageStringOf(x)
   838  }
   839  
   840  func (*CloudSqlCredential) ProtoMessage() {}
   841  
   842  func (x *CloudSqlCredential) ProtoReflect() protoreflect.Message {
   843  	mi := &file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[10]
   844  	if protoimpl.UnsafeEnabled && x != nil {
   845  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   846  		if ms.LoadMessageInfo() == nil {
   847  			ms.StoreMessageInfo(mi)
   848  		}
   849  		return ms
   850  	}
   851  	return mi.MessageOf(x)
   852  }
   853  
   854  // Deprecated: Use CloudSqlCredential.ProtoReflect.Descriptor instead.
   855  func (*CloudSqlCredential) Descriptor() ([]byte, []int) {
   856  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP(), []int{10}
   857  }
   858  
   859  func (x *CloudSqlCredential) GetUsername() string {
   860  	if x != nil {
   861  		return x.Username
   862  	}
   863  	return ""
   864  }
   865  
   866  func (x *CloudSqlCredential) GetPassword() string {
   867  	if x != nil {
   868  		return x.Password
   869  	}
   870  	return ""
   871  }
   872  
   873  var File_google_cloud_bigquery_connection_v1beta1_connection_proto protoreflect.FileDescriptor
   874  
   875  var file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDesc = []byte{
   876  	0x0a, 0x39, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   877  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
   878  	0x6f, 0x6e, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
   879  	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x28, 0x67, 0x6f, 0x6f,
   880  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
   881  	0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31,
   882  	0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
   883  	0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72,
   884  	0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f,
   885  	0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f,
   886  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62,
   887  	0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67,
   888  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72,
   889  	0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   890  	0x2f, 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x69, 0x61, 0x6d, 0x5f, 0x70, 0x6f, 0x6c, 0x69,
   891  	0x63, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   892  	0x2f, 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x2e, 0x70,
   893  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f,
   894  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   895  	0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
   896  	0x75, 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72,
   897  	0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
   898  	0x6f, 0x62, 0x75, 0x66, 0x2f, 0x77, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x73, 0x2e, 0x70, 0x72,
   899  	0x6f, 0x74, 0x6f, 0x22, 0xe1, 0x01, 0x0a, 0x17, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6f,
   900  	0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
   901  	0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42,
   902  	0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f,
   903  	0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
   904  	0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65,
   905  	0x6e, 0x74, 0x12, 0x28, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
   906  	0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0c,
   907  	0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x59, 0x0a, 0x0a,
   908  	0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b,
   909  	0x32, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
   910  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
   911  	0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e,
   912  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0a, 0x63, 0x6f, 0x6e,
   913  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x60, 0x0a, 0x14, 0x47, 0x65, 0x74, 0x43, 0x6f,
   914  	0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
   915  	0x48, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x34, 0xe0,
   916  	0x41, 0x02, 0xfa, 0x41, 0x2e, 0x0a, 0x2c, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x63,
   917  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   918  	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
   919  	0x69, 0x6f, 0x6e, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xbe, 0x01, 0x0a, 0x16, 0x4c, 0x69,
   920  	0x73, 0x74, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71,
   921  	0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01,
   922  	0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f,
   923  	0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
   924  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52,
   925  	0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x42, 0x0a, 0x0b, 0x6d, 0x61, 0x78, 0x5f, 0x72,
   926  	0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67,
   927  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x55,
   928  	0x49, 0x6e, 0x74, 0x33, 0x32, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52,
   929  	0x0a, 0x6d, 0x61, 0x78, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x70,
   930  	0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
   931  	0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x99, 0x01, 0x0a, 0x17, 0x4c,
   932  	0x69, 0x73, 0x74, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65,
   933  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70,
   934  	0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
   935  	0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x56,
   936  	0x0a, 0x0b, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x02, 0x20,
   937  	0x03, 0x28, 0x0b, 0x32, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   938  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e,
   939  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43,
   940  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
   941  	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x80, 0x02, 0x0a, 0x17, 0x55, 0x70, 0x64, 0x61, 0x74,
   942  	0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65,
   943  	0x73, 0x74, 0x12, 0x48, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
   944  	0x42, 0x34, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2e, 0x0a, 0x2c, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
   945  	0x72, 0x79, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f,
   946  	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6f, 0x6e, 0x6e,
   947  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x59, 0x0a, 0x0a,
   948  	0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
   949  	0x32, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
   950  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
   951  	0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e,
   952  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0a, 0x63, 0x6f, 0x6e,
   953  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74,
   954  	0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67,
   955  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46,
   956  	0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0a, 0x75,
   957  	0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0xa1, 0x01, 0x0a, 0x21, 0x55, 0x70,
   958  	0x64, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x72,
   959  	0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
   960  	0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
   961  	0x41, 0x02, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x63, 0x0a, 0x0a, 0x63, 0x72, 0x65, 0x64,
   962  	0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3e, 0x2e, 0x67,
   963  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
   964  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e,
   965  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
   966  	0x6f, 0x6e, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x42, 0x03, 0xe0, 0x41,
   967  	0x02, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x22, 0x63, 0x0a,
   968  	0x17, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
   969  	0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x48, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
   970  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x34, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2e, 0x0a, 0x2c,
   971  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
   972  	0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
   973  	0x6d, 0x2f, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x04, 0x6e, 0x61,
   974  	0x6d, 0x65, 0x22, 0xd0, 0x03, 0x0a, 0x0a, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
   975  	0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
   976  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x66, 0x72, 0x69, 0x65, 0x6e, 0x64, 0x6c,
   977  	0x79, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x66, 0x72,
   978  	0x69, 0x65, 0x6e, 0x64, 0x6c, 0x79, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65,
   979  	0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
   980  	0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x5b, 0x0a, 0x09,
   981  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x5f, 0x73, 0x71, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32,
   982  	0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
   983  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
   984  	0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64,
   985  	0x53, 0x71, 0x6c, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x48, 0x00, 0x52,
   986  	0x08, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x53, 0x71, 0x6c, 0x12, 0x28, 0x0a, 0x0d, 0x63, 0x72, 0x65,
   987  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03,
   988  	0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0c, 0x63, 0x72, 0x65, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54,
   989  	0x69, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x12, 0x6c, 0x61, 0x73, 0x74, 0x5f, 0x6d, 0x6f, 0x64, 0x69,
   990  	0x66, 0x69, 0x65, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x42,
   991  	0x03, 0xe0, 0x41, 0x03, 0x52, 0x10, 0x6c, 0x61, 0x73, 0x74, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69,
   992  	0x65, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x2a, 0x0a, 0x0e, 0x68, 0x61, 0x73, 0x5f, 0x63, 0x72,
   993  	0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x08, 0x42, 0x03,
   994  	0xe0, 0x41, 0x03, 0x52, 0x0d, 0x68, 0x61, 0x73, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69,
   995  	0x61, 0x6c, 0x3a, 0x73, 0xea, 0x41, 0x70, 0x0a, 0x2c, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   996  	0x79, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   997  	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6f, 0x6e, 0x6e, 0x65,
   998  	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x40, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
   999  	0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69,
  1000  	0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x63,
  1001  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x63, 0x6f, 0x6e, 0x6e,
  1002  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x42, 0x0c, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x70, 0x65,
  1003  	0x72, 0x74, 0x69, 0x65, 0x73, 0x22, 0x81, 0x01, 0x0a, 0x14, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
  1004  	0x74, 0x69, 0x6f, 0x6e, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x12, 0x5b,
  1005  	0x0a, 0x09, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x5f, 0x73, 0x71, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28,
  1006  	0x0b, 0x32, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1007  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
  1008  	0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f,
  1009  	0x75, 0x64, 0x53, 0x71, 0x6c, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x48,
  1010  	0x00, 0x52, 0x08, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x53, 0x71, 0x6c, 0x42, 0x0c, 0x0a, 0x0a, 0x63,
  1011  	0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x22, 0x8e, 0x03, 0x0a, 0x12, 0x43, 0x6c,
  1012  	0x6f, 0x75, 0x64, 0x53, 0x71, 0x6c, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73,
  1013  	0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18,
  1014  	0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x49,
  1015  	0x64, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x18, 0x02, 0x20,
  1016  	0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x12, 0x5d, 0x0a,
  1017  	0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x49, 0x2e, 0x67, 0x6f,
  1018  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1019  	0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76,
  1020  	0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x53, 0x71, 0x6c, 0x50,
  1021  	0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61,
  1022  	0x73, 0x65, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x61, 0x0a, 0x0a,
  1023  	0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,
  1024  	0x32, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1025  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1026  	0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f, 0x75,
  1027  	0x64, 0x53, 0x71, 0x6c, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x42, 0x03,
  1028  	0xe0, 0x41, 0x04, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x12,
  1029  	0x31, 0x0a, 0x12, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x61, 0x63, 0x63, 0x6f, 0x75,
  1030  	0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03,
  1031  	0x52, 0x10, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
  1032  	0x49, 0x64, 0x22, 0x46, 0x0a, 0x0c, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x79,
  1033  	0x70, 0x65, 0x12, 0x1d, 0x0a, 0x19, 0x44, 0x41, 0x54, 0x41, 0x42, 0x41, 0x53, 0x45, 0x5f, 0x54,
  1034  	0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10,
  1035  	0x00, 0x12, 0x0c, 0x0a, 0x08, 0x50, 0x4f, 0x53, 0x54, 0x47, 0x52, 0x45, 0x53, 0x10, 0x01, 0x12,
  1036  	0x09, 0x0a, 0x05, 0x4d, 0x59, 0x53, 0x51, 0x4c, 0x10, 0x02, 0x22, 0x4c, 0x0a, 0x12, 0x43, 0x6c,
  1037  	0x6f, 0x75, 0x64, 0x53, 0x71, 0x6c, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c,
  1038  	0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
  1039  	0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08,
  1040  	0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
  1041  	0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x32, 0x98, 0x10, 0x0a, 0x11, 0x43, 0x6f, 0x6e,
  1042  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0xf7,
  1043  	0x01, 0x0a, 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1044  	0x69, 0x6f, 0x6e, 0x12, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1045  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e,
  1046  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43,
  1047  	0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52,
  1048  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1049  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63,
  1050  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1051  	0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x6a, 0xda, 0x41,
  1052  	0x1f, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
  1053  	0x6f, 0x6e, 0x2c, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64,
  1054  	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x42, 0x3a, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
  1055  	0x6f, 0x6e, 0x22, 0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61,
  1056  	0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
  1057  	0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x63, 0x6f, 0x6e,
  1058  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0xca, 0x01, 0x0a, 0x0d, 0x47, 0x65, 0x74,
  1059  	0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3e, 0x2e, 0x67, 0x6f, 0x6f,
  1060  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1061  	0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31,
  1062  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1063  	0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x67, 0x6f, 0x6f,
  1064  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1065  	0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31,
  1066  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
  1067  	0x22, 0x43, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x36, 0x12,
  1068  	0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
  1069  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74,
  1070  	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
  1071  	0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xe9, 0x01, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6f,
  1072  	0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x40, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1073  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1074  	0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62,
  1075  	0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1076  	0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x41, 0x2e, 0x67, 0x6f,
  1077  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1078  	0x65, 0x72, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76,
  1079  	0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6f, 0x6e, 0x6e, 0x65,
  1080  	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x51,
  1081  	0xda, 0x41, 0x12, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x6d, 0x61, 0x78, 0x5f, 0x72, 0x65,
  1082  	0x73, 0x75, 0x6c, 0x74, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x36, 0x12, 0x34, 0x2f, 0x76, 0x31,
  1083  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72,
  1084  	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f,
  1085  	0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
  1086  	0x73, 0x12, 0xf3, 0x01, 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e,
  1087  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1088  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63,
  1089  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1090  	0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
  1091  	0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1092  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1093  	0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62,
  1094  	0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22,
  1095  	0x66, 0xda, 0x41, 0x1b, 0x6e, 0x61, 0x6d, 0x65, 0x2c, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1096  	0x69, 0x6f, 0x6e, 0x2c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x82,
  1097  	0xd3, 0xe4, 0x93, 0x02, 0x42, 0x3a, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
  1098  	0x6e, 0x32, 0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
  1099  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
  1100  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1101  	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xe8, 0x01, 0x0a, 0x1a, 0x55, 0x70, 0x64, 0x61,
  1102  	0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x72, 0x65, 0x64,
  1103  	0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x12, 0x4b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1104  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x63,
  1105  	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1106  	0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
  1107  	0x6f, 0x6e, 0x43, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x52, 0x65, 0x71, 0x75,
  1108  	0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
  1109  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x65, 0xda, 0x41, 0x0f,
  1110  	0x6e, 0x61, 0x6d, 0x65, 0x2c, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61, 0x6c, 0x82,
  1111  	0xd3, 0xe4, 0x93, 0x02, 0x4d, 0x3a, 0x0a, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61,
  1112  	0x6c, 0x32, 0x3f, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
  1113  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
  1114  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1115  	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x61,
  1116  	0x6c, 0x7d, 0x12, 0xb2, 0x01, 0x0a, 0x10, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6f, 0x6e,
  1117  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1118  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1119  	0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1120  	0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1121  	0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f,
  1122  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70,
  1123  	0x74, 0x79, 0x22, 0x43, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02,
  1124  	0x36, 0x2a, 0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
  1125  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
  1126  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
  1127  	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xae, 0x01, 0x0a, 0x0c, 0x47, 0x65, 0x74, 0x49,
  1128  	0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1129  	0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50,
  1130  	0x6f, 0x6c, 0x69, 0x63, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x67,
  1131  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x6c,
  1132  	0x69, 0x63, 0x79, 0x22, 0x63, 0xda, 0x41, 0x10, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
  1133  	0x2c, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x4a, 0x3a, 0x01,
  1134  	0x2a, 0x22, 0x45, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x72, 0x65, 0x73,
  1135  	0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a,
  1136  	0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e,
  1137  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x67, 0x65, 0x74, 0x49,
  1138  	0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0xad, 0x01, 0x0a, 0x0c, 0x53, 0x65, 0x74,
  1139  	0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1140  	0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x49, 0x61, 0x6d,
  1141  	0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e,
  1142  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f,
  1143  	0x6c, 0x69, 0x63, 0x79, 0x22, 0x62, 0xda, 0x41, 0x0f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
  1144  	0x65, 0x2c, 0x70, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x4a, 0x3a, 0x01,
  1145  	0x2a, 0x22, 0x45, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x72, 0x65, 0x73,
  1146  	0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a,
  1147  	0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6f, 0x6e,
  1148  	0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x73, 0x65, 0x74, 0x49,
  1149  	0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0xd8, 0x01, 0x0a, 0x12, 0x54, 0x65, 0x73,
  1150  	0x74, 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12,
  1151  	0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e,
  1152  	0x54, 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f,
  1153  	0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1154  	0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x49, 0x61,
  1155  	0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70,
  1156  	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x6d, 0xda, 0x41, 0x14, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
  1157  	0x65, 0x2c, 0x70, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x82, 0xd3, 0xe4,
  1158  	0x93, 0x02, 0x50, 0x3a, 0x01, 0x2a, 0x22, 0x4b, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31,
  1159  	0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
  1160  	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
  1161  	0x2a, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d,
  1162  	0x3a, 0x74, 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69,
  1163  	0x6f, 0x6e, 0x73, 0x1a, 0x7e, 0xca, 0x41, 0x21, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1164  	0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1165  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x57, 0x68, 0x74, 0x74, 0x70,
  1166  	0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
  1167  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67, 0x71,
  1168  	0x75, 0x65, 0x72, 0x79, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77,
  1169  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
  1170  	0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66,
  1171  	0x6f, 0x72, 0x6d, 0x42, 0xe3, 0x01, 0x0a, 0x2c, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1172  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1173  	0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x62,
  1174  	0x65, 0x74, 0x61, 0x31, 0x42, 0x0f, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
  1175  	0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x4c, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f,
  1176  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75,
  1177  	0x65, 0x72, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x61,
  1178  	0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
  1179  	0x74, 0x69, 0x6f, 0x6e, 0x70, 0x62, 0x3b, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
  1180  	0x6e, 0x70, 0x62, 0xaa, 0x02, 0x28, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f,
  1181  	0x75, 0x64, 0x2e, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x43, 0x6f, 0x6e, 0x6e,
  1182  	0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x56, 0x31, 0x42, 0x65, 0x74, 0x61, 0x31, 0xca, 0x02,
  1183  	0x28, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x42, 0x69,
  1184  	0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x5c, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f,
  1185  	0x6e, 0x5c, 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1186  	0x33,
  1187  }
  1188  
  1189  var (
  1190  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescOnce sync.Once
  1191  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescData = file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDesc
  1192  )
  1193  
  1194  func file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescGZIP() []byte {
  1195  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescOnce.Do(func() {
  1196  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescData)
  1197  	})
  1198  	return file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDescData
  1199  }
  1200  
  1201  var file_google_cloud_bigquery_connection_v1beta1_connection_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
  1202  var file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
  1203  var file_google_cloud_bigquery_connection_v1beta1_connection_proto_goTypes = []interface{}{
  1204  	(CloudSqlProperties_DatabaseType)(0),      // 0: google.cloud.bigquery.connection.v1beta1.CloudSqlProperties.DatabaseType
  1205  	(*CreateConnectionRequest)(nil),           // 1: google.cloud.bigquery.connection.v1beta1.CreateConnectionRequest
  1206  	(*GetConnectionRequest)(nil),              // 2: google.cloud.bigquery.connection.v1beta1.GetConnectionRequest
  1207  	(*ListConnectionsRequest)(nil),            // 3: google.cloud.bigquery.connection.v1beta1.ListConnectionsRequest
  1208  	(*ListConnectionsResponse)(nil),           // 4: google.cloud.bigquery.connection.v1beta1.ListConnectionsResponse
  1209  	(*UpdateConnectionRequest)(nil),           // 5: google.cloud.bigquery.connection.v1beta1.UpdateConnectionRequest
  1210  	(*UpdateConnectionCredentialRequest)(nil), // 6: google.cloud.bigquery.connection.v1beta1.UpdateConnectionCredentialRequest
  1211  	(*DeleteConnectionRequest)(nil),           // 7: google.cloud.bigquery.connection.v1beta1.DeleteConnectionRequest
  1212  	(*Connection)(nil),                        // 8: google.cloud.bigquery.connection.v1beta1.Connection
  1213  	(*ConnectionCredential)(nil),              // 9: google.cloud.bigquery.connection.v1beta1.ConnectionCredential
  1214  	(*CloudSqlProperties)(nil),                // 10: google.cloud.bigquery.connection.v1beta1.CloudSqlProperties
  1215  	(*CloudSqlCredential)(nil),                // 11: google.cloud.bigquery.connection.v1beta1.CloudSqlCredential
  1216  	(*wrapperspb.UInt32Value)(nil),            // 12: google.protobuf.UInt32Value
  1217  	(*fieldmaskpb.FieldMask)(nil),             // 13: google.protobuf.FieldMask
  1218  	(*iampb.GetIamPolicyRequest)(nil),         // 14: google.iam.v1.GetIamPolicyRequest
  1219  	(*iampb.SetIamPolicyRequest)(nil),         // 15: google.iam.v1.SetIamPolicyRequest
  1220  	(*iampb.TestIamPermissionsRequest)(nil),   // 16: google.iam.v1.TestIamPermissionsRequest
  1221  	(*emptypb.Empty)(nil),                     // 17: google.protobuf.Empty
  1222  	(*iampb.Policy)(nil),                      // 18: google.iam.v1.Policy
  1223  	(*iampb.TestIamPermissionsResponse)(nil),  // 19: google.iam.v1.TestIamPermissionsResponse
  1224  }
  1225  var file_google_cloud_bigquery_connection_v1beta1_connection_proto_depIdxs = []int32{
  1226  	8,  // 0: google.cloud.bigquery.connection.v1beta1.CreateConnectionRequest.connection:type_name -> google.cloud.bigquery.connection.v1beta1.Connection
  1227  	12, // 1: google.cloud.bigquery.connection.v1beta1.ListConnectionsRequest.max_results:type_name -> google.protobuf.UInt32Value
  1228  	8,  // 2: google.cloud.bigquery.connection.v1beta1.ListConnectionsResponse.connections:type_name -> google.cloud.bigquery.connection.v1beta1.Connection
  1229  	8,  // 3: google.cloud.bigquery.connection.v1beta1.UpdateConnectionRequest.connection:type_name -> google.cloud.bigquery.connection.v1beta1.Connection
  1230  	13, // 4: google.cloud.bigquery.connection.v1beta1.UpdateConnectionRequest.update_mask:type_name -> google.protobuf.FieldMask
  1231  	9,  // 5: google.cloud.bigquery.connection.v1beta1.UpdateConnectionCredentialRequest.credential:type_name -> google.cloud.bigquery.connection.v1beta1.ConnectionCredential
  1232  	10, // 6: google.cloud.bigquery.connection.v1beta1.Connection.cloud_sql:type_name -> google.cloud.bigquery.connection.v1beta1.CloudSqlProperties
  1233  	11, // 7: google.cloud.bigquery.connection.v1beta1.ConnectionCredential.cloud_sql:type_name -> google.cloud.bigquery.connection.v1beta1.CloudSqlCredential
  1234  	0,  // 8: google.cloud.bigquery.connection.v1beta1.CloudSqlProperties.type:type_name -> google.cloud.bigquery.connection.v1beta1.CloudSqlProperties.DatabaseType
  1235  	11, // 9: google.cloud.bigquery.connection.v1beta1.CloudSqlProperties.credential:type_name -> google.cloud.bigquery.connection.v1beta1.CloudSqlCredential
  1236  	1,  // 10: google.cloud.bigquery.connection.v1beta1.ConnectionService.CreateConnection:input_type -> google.cloud.bigquery.connection.v1beta1.CreateConnectionRequest
  1237  	2,  // 11: google.cloud.bigquery.connection.v1beta1.ConnectionService.GetConnection:input_type -> google.cloud.bigquery.connection.v1beta1.GetConnectionRequest
  1238  	3,  // 12: google.cloud.bigquery.connection.v1beta1.ConnectionService.ListConnections:input_type -> google.cloud.bigquery.connection.v1beta1.ListConnectionsRequest
  1239  	5,  // 13: google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnection:input_type -> google.cloud.bigquery.connection.v1beta1.UpdateConnectionRequest
  1240  	6,  // 14: google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnectionCredential:input_type -> google.cloud.bigquery.connection.v1beta1.UpdateConnectionCredentialRequest
  1241  	7,  // 15: google.cloud.bigquery.connection.v1beta1.ConnectionService.DeleteConnection:input_type -> google.cloud.bigquery.connection.v1beta1.DeleteConnectionRequest
  1242  	14, // 16: google.cloud.bigquery.connection.v1beta1.ConnectionService.GetIamPolicy:input_type -> google.iam.v1.GetIamPolicyRequest
  1243  	15, // 17: google.cloud.bigquery.connection.v1beta1.ConnectionService.SetIamPolicy:input_type -> google.iam.v1.SetIamPolicyRequest
  1244  	16, // 18: google.cloud.bigquery.connection.v1beta1.ConnectionService.TestIamPermissions:input_type -> google.iam.v1.TestIamPermissionsRequest
  1245  	8,  // 19: google.cloud.bigquery.connection.v1beta1.ConnectionService.CreateConnection:output_type -> google.cloud.bigquery.connection.v1beta1.Connection
  1246  	8,  // 20: google.cloud.bigquery.connection.v1beta1.ConnectionService.GetConnection:output_type -> google.cloud.bigquery.connection.v1beta1.Connection
  1247  	4,  // 21: google.cloud.bigquery.connection.v1beta1.ConnectionService.ListConnections:output_type -> google.cloud.bigquery.connection.v1beta1.ListConnectionsResponse
  1248  	8,  // 22: google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnection:output_type -> google.cloud.bigquery.connection.v1beta1.Connection
  1249  	17, // 23: google.cloud.bigquery.connection.v1beta1.ConnectionService.UpdateConnectionCredential:output_type -> google.protobuf.Empty
  1250  	17, // 24: google.cloud.bigquery.connection.v1beta1.ConnectionService.DeleteConnection:output_type -> google.protobuf.Empty
  1251  	18, // 25: google.cloud.bigquery.connection.v1beta1.ConnectionService.GetIamPolicy:output_type -> google.iam.v1.Policy
  1252  	18, // 26: google.cloud.bigquery.connection.v1beta1.ConnectionService.SetIamPolicy:output_type -> google.iam.v1.Policy
  1253  	19, // 27: google.cloud.bigquery.connection.v1beta1.ConnectionService.TestIamPermissions:output_type -> google.iam.v1.TestIamPermissionsResponse
  1254  	19, // [19:28] is the sub-list for method output_type
  1255  	10, // [10:19] is the sub-list for method input_type
  1256  	10, // [10:10] is the sub-list for extension type_name
  1257  	10, // [10:10] is the sub-list for extension extendee
  1258  	0,  // [0:10] is the sub-list for field type_name
  1259  }
  1260  
  1261  func init() { file_google_cloud_bigquery_connection_v1beta1_connection_proto_init() }
  1262  func file_google_cloud_bigquery_connection_v1beta1_connection_proto_init() {
  1263  	if File_google_cloud_bigquery_connection_v1beta1_connection_proto != nil {
  1264  		return
  1265  	}
  1266  	if !protoimpl.UnsafeEnabled {
  1267  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1268  			switch v := v.(*CreateConnectionRequest); i {
  1269  			case 0:
  1270  				return &v.state
  1271  			case 1:
  1272  				return &v.sizeCache
  1273  			case 2:
  1274  				return &v.unknownFields
  1275  			default:
  1276  				return nil
  1277  			}
  1278  		}
  1279  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1280  			switch v := v.(*GetConnectionRequest); i {
  1281  			case 0:
  1282  				return &v.state
  1283  			case 1:
  1284  				return &v.sizeCache
  1285  			case 2:
  1286  				return &v.unknownFields
  1287  			default:
  1288  				return nil
  1289  			}
  1290  		}
  1291  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1292  			switch v := v.(*ListConnectionsRequest); i {
  1293  			case 0:
  1294  				return &v.state
  1295  			case 1:
  1296  				return &v.sizeCache
  1297  			case 2:
  1298  				return &v.unknownFields
  1299  			default:
  1300  				return nil
  1301  			}
  1302  		}
  1303  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1304  			switch v := v.(*ListConnectionsResponse); i {
  1305  			case 0:
  1306  				return &v.state
  1307  			case 1:
  1308  				return &v.sizeCache
  1309  			case 2:
  1310  				return &v.unknownFields
  1311  			default:
  1312  				return nil
  1313  			}
  1314  		}
  1315  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1316  			switch v := v.(*UpdateConnectionRequest); i {
  1317  			case 0:
  1318  				return &v.state
  1319  			case 1:
  1320  				return &v.sizeCache
  1321  			case 2:
  1322  				return &v.unknownFields
  1323  			default:
  1324  				return nil
  1325  			}
  1326  		}
  1327  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1328  			switch v := v.(*UpdateConnectionCredentialRequest); i {
  1329  			case 0:
  1330  				return &v.state
  1331  			case 1:
  1332  				return &v.sizeCache
  1333  			case 2:
  1334  				return &v.unknownFields
  1335  			default:
  1336  				return nil
  1337  			}
  1338  		}
  1339  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1340  			switch v := v.(*DeleteConnectionRequest); i {
  1341  			case 0:
  1342  				return &v.state
  1343  			case 1:
  1344  				return &v.sizeCache
  1345  			case 2:
  1346  				return &v.unknownFields
  1347  			default:
  1348  				return nil
  1349  			}
  1350  		}
  1351  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1352  			switch v := v.(*Connection); i {
  1353  			case 0:
  1354  				return &v.state
  1355  			case 1:
  1356  				return &v.sizeCache
  1357  			case 2:
  1358  				return &v.unknownFields
  1359  			default:
  1360  				return nil
  1361  			}
  1362  		}
  1363  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1364  			switch v := v.(*ConnectionCredential); i {
  1365  			case 0:
  1366  				return &v.state
  1367  			case 1:
  1368  				return &v.sizeCache
  1369  			case 2:
  1370  				return &v.unknownFields
  1371  			default:
  1372  				return nil
  1373  			}
  1374  		}
  1375  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1376  			switch v := v.(*CloudSqlProperties); i {
  1377  			case 0:
  1378  				return &v.state
  1379  			case 1:
  1380  				return &v.sizeCache
  1381  			case 2:
  1382  				return &v.unknownFields
  1383  			default:
  1384  				return nil
  1385  			}
  1386  		}
  1387  		file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1388  			switch v := v.(*CloudSqlCredential); i {
  1389  			case 0:
  1390  				return &v.state
  1391  			case 1:
  1392  				return &v.sizeCache
  1393  			case 2:
  1394  				return &v.unknownFields
  1395  			default:
  1396  				return nil
  1397  			}
  1398  		}
  1399  	}
  1400  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[7].OneofWrappers = []interface{}{
  1401  		(*Connection_CloudSql)(nil),
  1402  	}
  1403  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes[8].OneofWrappers = []interface{}{
  1404  		(*ConnectionCredential_CloudSql)(nil),
  1405  	}
  1406  	type x struct{}
  1407  	out := protoimpl.TypeBuilder{
  1408  		File: protoimpl.DescBuilder{
  1409  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1410  			RawDescriptor: file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDesc,
  1411  			NumEnums:      1,
  1412  			NumMessages:   11,
  1413  			NumExtensions: 0,
  1414  			NumServices:   1,
  1415  		},
  1416  		GoTypes:           file_google_cloud_bigquery_connection_v1beta1_connection_proto_goTypes,
  1417  		DependencyIndexes: file_google_cloud_bigquery_connection_v1beta1_connection_proto_depIdxs,
  1418  		EnumInfos:         file_google_cloud_bigquery_connection_v1beta1_connection_proto_enumTypes,
  1419  		MessageInfos:      file_google_cloud_bigquery_connection_v1beta1_connection_proto_msgTypes,
  1420  	}.Build()
  1421  	File_google_cloud_bigquery_connection_v1beta1_connection_proto = out.File
  1422  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_rawDesc = nil
  1423  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_goTypes = nil
  1424  	file_google_cloud_bigquery_connection_v1beta1_connection_proto_depIdxs = nil
  1425  }
  1426  
  1427  // Reference imports to suppress errors if they are not otherwise used.
  1428  var _ context.Context
  1429  var _ grpc.ClientConnInterface
  1430  
  1431  // This is a compile-time assertion to ensure that this generated file
  1432  // is compatible with the grpc package it is being compiled against.
  1433  const _ = grpc.SupportPackageIsVersion6
  1434  
  1435  // ConnectionServiceClient is the client API for ConnectionService service.
  1436  //
  1437  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1438  type ConnectionServiceClient interface {
  1439  	// Creates a new connection.
  1440  	CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
  1441  	// Returns specified connection.
  1442  	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
  1443  	// Returns a list of connections in the given project.
  1444  	ListConnections(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error)
  1445  	// Updates the specified connection. For security reasons, also resets
  1446  	// credential if connection properties are in the update field mask.
  1447  	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
  1448  	// Sets the credential for the specified connection.
  1449  	UpdateConnectionCredential(ctx context.Context, in *UpdateConnectionCredentialRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  1450  	// Deletes connection and associated credential.
  1451  	DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  1452  	// Gets the access control policy for a resource.
  1453  	// Returns an empty policy if the resource exists and does not have a policy
  1454  	// set.
  1455  	GetIamPolicy(ctx context.Context, in *iampb.GetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error)
  1456  	// Sets the access control policy on the specified resource. Replaces any
  1457  	// existing policy.
  1458  	//
  1459  	// Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
  1460  	SetIamPolicy(ctx context.Context, in *iampb.SetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error)
  1461  	// Returns permissions that a caller has on the specified resource.
  1462  	// If the resource does not exist, this will return an empty set of
  1463  	// permissions, not a `NOT_FOUND` error.
  1464  	//
  1465  	// Note: This operation is designed to be used for building permission-aware
  1466  	// UIs and command-line tools, not for authorization checking. This operation
  1467  	// may "fail open" without warning.
  1468  	TestIamPermissions(ctx context.Context, in *iampb.TestIamPermissionsRequest, opts ...grpc.CallOption) (*iampb.TestIamPermissionsResponse, error)
  1469  }
  1470  
  1471  type connectionServiceClient struct {
  1472  	cc grpc.ClientConnInterface
  1473  }
  1474  
  1475  func NewConnectionServiceClient(cc grpc.ClientConnInterface) ConnectionServiceClient {
  1476  	return &connectionServiceClient{cc}
  1477  }
  1478  
  1479  func (c *connectionServiceClient) CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*Connection, error) {
  1480  	out := new(Connection)
  1481  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/CreateConnection", in, out, opts...)
  1482  	if err != nil {
  1483  		return nil, err
  1484  	}
  1485  	return out, nil
  1486  }
  1487  
  1488  func (c *connectionServiceClient) GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*Connection, error) {
  1489  	out := new(Connection)
  1490  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/GetConnection", in, out, opts...)
  1491  	if err != nil {
  1492  		return nil, err
  1493  	}
  1494  	return out, nil
  1495  }
  1496  
  1497  func (c *connectionServiceClient) ListConnections(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error) {
  1498  	out := new(ListConnectionsResponse)
  1499  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/ListConnections", in, out, opts...)
  1500  	if err != nil {
  1501  		return nil, err
  1502  	}
  1503  	return out, nil
  1504  }
  1505  
  1506  func (c *connectionServiceClient) UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*Connection, error) {
  1507  	out := new(Connection)
  1508  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/UpdateConnection", in, out, opts...)
  1509  	if err != nil {
  1510  		return nil, err
  1511  	}
  1512  	return out, nil
  1513  }
  1514  
  1515  func (c *connectionServiceClient) UpdateConnectionCredential(ctx context.Context, in *UpdateConnectionCredentialRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  1516  	out := new(emptypb.Empty)
  1517  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/UpdateConnectionCredential", in, out, opts...)
  1518  	if err != nil {
  1519  		return nil, err
  1520  	}
  1521  	return out, nil
  1522  }
  1523  
  1524  func (c *connectionServiceClient) DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  1525  	out := new(emptypb.Empty)
  1526  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/DeleteConnection", in, out, opts...)
  1527  	if err != nil {
  1528  		return nil, err
  1529  	}
  1530  	return out, nil
  1531  }
  1532  
  1533  func (c *connectionServiceClient) GetIamPolicy(ctx context.Context, in *iampb.GetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error) {
  1534  	out := new(iampb.Policy)
  1535  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/GetIamPolicy", in, out, opts...)
  1536  	if err != nil {
  1537  		return nil, err
  1538  	}
  1539  	return out, nil
  1540  }
  1541  
  1542  func (c *connectionServiceClient) SetIamPolicy(ctx context.Context, in *iampb.SetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error) {
  1543  	out := new(iampb.Policy)
  1544  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/SetIamPolicy", in, out, opts...)
  1545  	if err != nil {
  1546  		return nil, err
  1547  	}
  1548  	return out, nil
  1549  }
  1550  
  1551  func (c *connectionServiceClient) TestIamPermissions(ctx context.Context, in *iampb.TestIamPermissionsRequest, opts ...grpc.CallOption) (*iampb.TestIamPermissionsResponse, error) {
  1552  	out := new(iampb.TestIamPermissionsResponse)
  1553  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.connection.v1beta1.ConnectionService/TestIamPermissions", in, out, opts...)
  1554  	if err != nil {
  1555  		return nil, err
  1556  	}
  1557  	return out, nil
  1558  }
  1559  
  1560  // ConnectionServiceServer is the server API for ConnectionService service.
  1561  type ConnectionServiceServer interface {
  1562  	// Creates a new connection.
  1563  	CreateConnection(context.Context, *CreateConnectionRequest) (*Connection, error)
  1564  	// Returns specified connection.
  1565  	GetConnection(context.Context, *GetConnectionRequest) (*Connection, error)
  1566  	// Returns a list of connections in the given project.
  1567  	ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)
  1568  	// Updates the specified connection. For security reasons, also resets
  1569  	// credential if connection properties are in the update field mask.
  1570  	UpdateConnection(context.Context, *UpdateConnectionRequest) (*Connection, error)
  1571  	// Sets the credential for the specified connection.
  1572  	UpdateConnectionCredential(context.Context, *UpdateConnectionCredentialRequest) (*emptypb.Empty, error)
  1573  	// Deletes connection and associated credential.
  1574  	DeleteConnection(context.Context, *DeleteConnectionRequest) (*emptypb.Empty, error)
  1575  	// Gets the access control policy for a resource.
  1576  	// Returns an empty policy if the resource exists and does not have a policy
  1577  	// set.
  1578  	GetIamPolicy(context.Context, *iampb.GetIamPolicyRequest) (*iampb.Policy, error)
  1579  	// Sets the access control policy on the specified resource. Replaces any
  1580  	// existing policy.
  1581  	//
  1582  	// Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
  1583  	SetIamPolicy(context.Context, *iampb.SetIamPolicyRequest) (*iampb.Policy, error)
  1584  	// Returns permissions that a caller has on the specified resource.
  1585  	// If the resource does not exist, this will return an empty set of
  1586  	// permissions, not a `NOT_FOUND` error.
  1587  	//
  1588  	// Note: This operation is designed to be used for building permission-aware
  1589  	// UIs and command-line tools, not for authorization checking. This operation
  1590  	// may "fail open" without warning.
  1591  	TestIamPermissions(context.Context, *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error)
  1592  }
  1593  
  1594  // UnimplementedConnectionServiceServer can be embedded to have forward compatible implementations.
  1595  type UnimplementedConnectionServiceServer struct {
  1596  }
  1597  
  1598  func (*UnimplementedConnectionServiceServer) CreateConnection(context.Context, *CreateConnectionRequest) (*Connection, error) {
  1599  	return nil, status.Errorf(codes.Unimplemented, "method CreateConnection not implemented")
  1600  }
  1601  func (*UnimplementedConnectionServiceServer) GetConnection(context.Context, *GetConnectionRequest) (*Connection, error) {
  1602  	return nil, status.Errorf(codes.Unimplemented, "method GetConnection not implemented")
  1603  }
  1604  func (*UnimplementedConnectionServiceServer) ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error) {
  1605  	return nil, status.Errorf(codes.Unimplemented, "method ListConnections not implemented")
  1606  }
  1607  func (*UnimplementedConnectionServiceServer) UpdateConnection(context.Context, *UpdateConnectionRequest) (*Connection, error) {
  1608  	return nil, status.Errorf(codes.Unimplemented, "method UpdateConnection not implemented")
  1609  }
  1610  func (*UnimplementedConnectionServiceServer) UpdateConnectionCredential(context.Context, *UpdateConnectionCredentialRequest) (*emptypb.Empty, error) {
  1611  	return nil, status.Errorf(codes.Unimplemented, "method UpdateConnectionCredential not implemented")
  1612  }
  1613  func (*UnimplementedConnectionServiceServer) DeleteConnection(context.Context, *DeleteConnectionRequest) (*emptypb.Empty, error) {
  1614  	return nil, status.Errorf(codes.Unimplemented, "method DeleteConnection not implemented")
  1615  }
  1616  func (*UnimplementedConnectionServiceServer) GetIamPolicy(context.Context, *iampb.GetIamPolicyRequest) (*iampb.Policy, error) {
  1617  	return nil, status.Errorf(codes.Unimplemented, "method GetIamPolicy not implemented")
  1618  }
  1619  func (*UnimplementedConnectionServiceServer) SetIamPolicy(context.Context, *iampb.SetIamPolicyRequest) (*iampb.Policy, error) {
  1620  	return nil, status.Errorf(codes.Unimplemented, "method SetIamPolicy not implemented")
  1621  }
  1622  func (*UnimplementedConnectionServiceServer) TestIamPermissions(context.Context, *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error) {
  1623  	return nil, status.Errorf(codes.Unimplemented, "method TestIamPermissions not implemented")
  1624  }
  1625  
  1626  func RegisterConnectionServiceServer(s *grpc.Server, srv ConnectionServiceServer) {
  1627  	s.RegisterService(&_ConnectionService_serviceDesc, srv)
  1628  }
  1629  
  1630  func _ConnectionService_CreateConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1631  	in := new(CreateConnectionRequest)
  1632  	if err := dec(in); err != nil {
  1633  		return nil, err
  1634  	}
  1635  	if interceptor == nil {
  1636  		return srv.(ConnectionServiceServer).CreateConnection(ctx, in)
  1637  	}
  1638  	info := &grpc.UnaryServerInfo{
  1639  		Server:     srv,
  1640  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/CreateConnection",
  1641  	}
  1642  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1643  		return srv.(ConnectionServiceServer).CreateConnection(ctx, req.(*CreateConnectionRequest))
  1644  	}
  1645  	return interceptor(ctx, in, info, handler)
  1646  }
  1647  
  1648  func _ConnectionService_GetConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1649  	in := new(GetConnectionRequest)
  1650  	if err := dec(in); err != nil {
  1651  		return nil, err
  1652  	}
  1653  	if interceptor == nil {
  1654  		return srv.(ConnectionServiceServer).GetConnection(ctx, in)
  1655  	}
  1656  	info := &grpc.UnaryServerInfo{
  1657  		Server:     srv,
  1658  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/GetConnection",
  1659  	}
  1660  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1661  		return srv.(ConnectionServiceServer).GetConnection(ctx, req.(*GetConnectionRequest))
  1662  	}
  1663  	return interceptor(ctx, in, info, handler)
  1664  }
  1665  
  1666  func _ConnectionService_ListConnections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1667  	in := new(ListConnectionsRequest)
  1668  	if err := dec(in); err != nil {
  1669  		return nil, err
  1670  	}
  1671  	if interceptor == nil {
  1672  		return srv.(ConnectionServiceServer).ListConnections(ctx, in)
  1673  	}
  1674  	info := &grpc.UnaryServerInfo{
  1675  		Server:     srv,
  1676  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/ListConnections",
  1677  	}
  1678  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1679  		return srv.(ConnectionServiceServer).ListConnections(ctx, req.(*ListConnectionsRequest))
  1680  	}
  1681  	return interceptor(ctx, in, info, handler)
  1682  }
  1683  
  1684  func _ConnectionService_UpdateConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1685  	in := new(UpdateConnectionRequest)
  1686  	if err := dec(in); err != nil {
  1687  		return nil, err
  1688  	}
  1689  	if interceptor == nil {
  1690  		return srv.(ConnectionServiceServer).UpdateConnection(ctx, in)
  1691  	}
  1692  	info := &grpc.UnaryServerInfo{
  1693  		Server:     srv,
  1694  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/UpdateConnection",
  1695  	}
  1696  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1697  		return srv.(ConnectionServiceServer).UpdateConnection(ctx, req.(*UpdateConnectionRequest))
  1698  	}
  1699  	return interceptor(ctx, in, info, handler)
  1700  }
  1701  
  1702  func _ConnectionService_UpdateConnectionCredential_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1703  	in := new(UpdateConnectionCredentialRequest)
  1704  	if err := dec(in); err != nil {
  1705  		return nil, err
  1706  	}
  1707  	if interceptor == nil {
  1708  		return srv.(ConnectionServiceServer).UpdateConnectionCredential(ctx, in)
  1709  	}
  1710  	info := &grpc.UnaryServerInfo{
  1711  		Server:     srv,
  1712  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/UpdateConnectionCredential",
  1713  	}
  1714  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1715  		return srv.(ConnectionServiceServer).UpdateConnectionCredential(ctx, req.(*UpdateConnectionCredentialRequest))
  1716  	}
  1717  	return interceptor(ctx, in, info, handler)
  1718  }
  1719  
  1720  func _ConnectionService_DeleteConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1721  	in := new(DeleteConnectionRequest)
  1722  	if err := dec(in); err != nil {
  1723  		return nil, err
  1724  	}
  1725  	if interceptor == nil {
  1726  		return srv.(ConnectionServiceServer).DeleteConnection(ctx, in)
  1727  	}
  1728  	info := &grpc.UnaryServerInfo{
  1729  		Server:     srv,
  1730  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/DeleteConnection",
  1731  	}
  1732  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1733  		return srv.(ConnectionServiceServer).DeleteConnection(ctx, req.(*DeleteConnectionRequest))
  1734  	}
  1735  	return interceptor(ctx, in, info, handler)
  1736  }
  1737  
  1738  func _ConnectionService_GetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1739  	in := new(iampb.GetIamPolicyRequest)
  1740  	if err := dec(in); err != nil {
  1741  		return nil, err
  1742  	}
  1743  	if interceptor == nil {
  1744  		return srv.(ConnectionServiceServer).GetIamPolicy(ctx, in)
  1745  	}
  1746  	info := &grpc.UnaryServerInfo{
  1747  		Server:     srv,
  1748  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/GetIamPolicy",
  1749  	}
  1750  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1751  		return srv.(ConnectionServiceServer).GetIamPolicy(ctx, req.(*iampb.GetIamPolicyRequest))
  1752  	}
  1753  	return interceptor(ctx, in, info, handler)
  1754  }
  1755  
  1756  func _ConnectionService_SetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1757  	in := new(iampb.SetIamPolicyRequest)
  1758  	if err := dec(in); err != nil {
  1759  		return nil, err
  1760  	}
  1761  	if interceptor == nil {
  1762  		return srv.(ConnectionServiceServer).SetIamPolicy(ctx, in)
  1763  	}
  1764  	info := &grpc.UnaryServerInfo{
  1765  		Server:     srv,
  1766  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/SetIamPolicy",
  1767  	}
  1768  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1769  		return srv.(ConnectionServiceServer).SetIamPolicy(ctx, req.(*iampb.SetIamPolicyRequest))
  1770  	}
  1771  	return interceptor(ctx, in, info, handler)
  1772  }
  1773  
  1774  func _ConnectionService_TestIamPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1775  	in := new(iampb.TestIamPermissionsRequest)
  1776  	if err := dec(in); err != nil {
  1777  		return nil, err
  1778  	}
  1779  	if interceptor == nil {
  1780  		return srv.(ConnectionServiceServer).TestIamPermissions(ctx, in)
  1781  	}
  1782  	info := &grpc.UnaryServerInfo{
  1783  		Server:     srv,
  1784  		FullMethod: "/google.cloud.bigquery.connection.v1beta1.ConnectionService/TestIamPermissions",
  1785  	}
  1786  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1787  		return srv.(ConnectionServiceServer).TestIamPermissions(ctx, req.(*iampb.TestIamPermissionsRequest))
  1788  	}
  1789  	return interceptor(ctx, in, info, handler)
  1790  }
  1791  
  1792  var _ConnectionService_serviceDesc = grpc.ServiceDesc{
  1793  	ServiceName: "google.cloud.bigquery.connection.v1beta1.ConnectionService",
  1794  	HandlerType: (*ConnectionServiceServer)(nil),
  1795  	Methods: []grpc.MethodDesc{
  1796  		{
  1797  			MethodName: "CreateConnection",
  1798  			Handler:    _ConnectionService_CreateConnection_Handler,
  1799  		},
  1800  		{
  1801  			MethodName: "GetConnection",
  1802  			Handler:    _ConnectionService_GetConnection_Handler,
  1803  		},
  1804  		{
  1805  			MethodName: "ListConnections",
  1806  			Handler:    _ConnectionService_ListConnections_Handler,
  1807  		},
  1808  		{
  1809  			MethodName: "UpdateConnection",
  1810  			Handler:    _ConnectionService_UpdateConnection_Handler,
  1811  		},
  1812  		{
  1813  			MethodName: "UpdateConnectionCredential",
  1814  			Handler:    _ConnectionService_UpdateConnectionCredential_Handler,
  1815  		},
  1816  		{
  1817  			MethodName: "DeleteConnection",
  1818  			Handler:    _ConnectionService_DeleteConnection_Handler,
  1819  		},
  1820  		{
  1821  			MethodName: "GetIamPolicy",
  1822  			Handler:    _ConnectionService_GetIamPolicy_Handler,
  1823  		},
  1824  		{
  1825  			MethodName: "SetIamPolicy",
  1826  			Handler:    _ConnectionService_SetIamPolicy_Handler,
  1827  		},
  1828  		{
  1829  			MethodName: "TestIamPermissions",
  1830  			Handler:    _ConnectionService_TestIamPermissions_Handler,
  1831  		},
  1832  	},
  1833  	Streams:  []grpc.StreamDesc{},
  1834  	Metadata: "google/cloud/bigquery/connection/v1beta1/connection.proto",
  1835  }
  1836  

View as plain text