Source file src/google.golang.org/genproto/googleapis/partner/aistreams/v1alpha1/aistreams.pb.go

Documentation: google.golang.org/genproto/googleapis/partner/aistreams/v1alpha1

     1  // Copyright 2024 Google LLC
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.26.0
    18  // 	protoc        v4.24.4
    19  // source: google/partner/aistreams/v1alpha1/aistreams.proto
    20  
    21  package aistreams
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
    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  	fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb"
    36  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    37  )
    38  
    39  const (
    40  	// Verify that this generated code is sufficiently up-to-date.
    41  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    42  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    43  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    44  )
    45  
    46  // Cluster resource.
    47  type Cluster struct {
    48  	state         protoimpl.MessageState
    49  	sizeCache     protoimpl.SizeCache
    50  	unknownFields protoimpl.UnknownFields
    51  
    52  	// The name of the cluster. The format of cluster is:
    53  	// projects/<projectid>/locations/<locationid>/clusters/<clusterid>.
    54  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    55  	// Output only. The time at which this cluster was created.
    56  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
    57  	// Output only. The time at which this cluster was updated.
    58  	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
    59  	// Labels with user-defined metadata.
    60  	Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    61  	// Output only. The certificate for creating the secure connection between the
    62  	// client and the AI Streams data plane.
    63  	Certificate string `protobuf:"bytes,5,opt,name=certificate,proto3" json:"certificate,omitempty"`
    64  	// Output only. The endpoint of the data plane cluster.
    65  	ServiceEndpoint string `protobuf:"bytes,6,opt,name=service_endpoint,json=serviceEndpoint,proto3" json:"service_endpoint,omitempty"`
    66  }
    67  
    68  func (x *Cluster) Reset() {
    69  	*x = Cluster{}
    70  	if protoimpl.UnsafeEnabled {
    71  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[0]
    72  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    73  		ms.StoreMessageInfo(mi)
    74  	}
    75  }
    76  
    77  func (x *Cluster) String() string {
    78  	return protoimpl.X.MessageStringOf(x)
    79  }
    80  
    81  func (*Cluster) ProtoMessage() {}
    82  
    83  func (x *Cluster) ProtoReflect() protoreflect.Message {
    84  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[0]
    85  	if protoimpl.UnsafeEnabled && x != nil {
    86  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    87  		if ms.LoadMessageInfo() == nil {
    88  			ms.StoreMessageInfo(mi)
    89  		}
    90  		return ms
    91  	}
    92  	return mi.MessageOf(x)
    93  }
    94  
    95  // Deprecated: Use Cluster.ProtoReflect.Descriptor instead.
    96  func (*Cluster) Descriptor() ([]byte, []int) {
    97  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{0}
    98  }
    99  
   100  func (x *Cluster) GetName() string {
   101  	if x != nil {
   102  		return x.Name
   103  	}
   104  	return ""
   105  }
   106  
   107  func (x *Cluster) GetCreateTime() *timestamppb.Timestamp {
   108  	if x != nil {
   109  		return x.CreateTime
   110  	}
   111  	return nil
   112  }
   113  
   114  func (x *Cluster) GetUpdateTime() *timestamppb.Timestamp {
   115  	if x != nil {
   116  		return x.UpdateTime
   117  	}
   118  	return nil
   119  }
   120  
   121  func (x *Cluster) GetLabels() map[string]string {
   122  	if x != nil {
   123  		return x.Labels
   124  	}
   125  	return nil
   126  }
   127  
   128  func (x *Cluster) GetCertificate() string {
   129  	if x != nil {
   130  		return x.Certificate
   131  	}
   132  	return ""
   133  }
   134  
   135  func (x *Cluster) GetServiceEndpoint() string {
   136  	if x != nil {
   137  		return x.ServiceEndpoint
   138  	}
   139  	return ""
   140  }
   141  
   142  // Request message for 'ListClusters'.
   143  type ListClustersRequest struct {
   144  	state         protoimpl.MessageState
   145  	sizeCache     protoimpl.SizeCache
   146  	unknownFields protoimpl.UnknownFields
   147  
   148  	// Required. The parent that owns the collection of Clusters.
   149  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   150  	// Maximum number of Clusters to return.
   151  	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
   152  	// Page token received from a previous `ListClusters` call. Provide this to
   153  	// retrieve the subsequent page. When paginating, all other parameters
   154  	// provided to `ListClusters` must match the call that provided the page
   155  	// token.
   156  	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
   157  	// Filter request.
   158  	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
   159  	// Order by fields for the result.
   160  	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
   161  }
   162  
   163  func (x *ListClustersRequest) Reset() {
   164  	*x = ListClustersRequest{}
   165  	if protoimpl.UnsafeEnabled {
   166  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[1]
   167  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   168  		ms.StoreMessageInfo(mi)
   169  	}
   170  }
   171  
   172  func (x *ListClustersRequest) String() string {
   173  	return protoimpl.X.MessageStringOf(x)
   174  }
   175  
   176  func (*ListClustersRequest) ProtoMessage() {}
   177  
   178  func (x *ListClustersRequest) ProtoReflect() protoreflect.Message {
   179  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[1]
   180  	if protoimpl.UnsafeEnabled && x != nil {
   181  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   182  		if ms.LoadMessageInfo() == nil {
   183  			ms.StoreMessageInfo(mi)
   184  		}
   185  		return ms
   186  	}
   187  	return mi.MessageOf(x)
   188  }
   189  
   190  // Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
   191  func (*ListClustersRequest) Descriptor() ([]byte, []int) {
   192  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{1}
   193  }
   194  
   195  func (x *ListClustersRequest) GetParent() string {
   196  	if x != nil {
   197  		return x.Parent
   198  	}
   199  	return ""
   200  }
   201  
   202  func (x *ListClustersRequest) GetPageSize() int32 {
   203  	if x != nil {
   204  		return x.PageSize
   205  	}
   206  	return 0
   207  }
   208  
   209  func (x *ListClustersRequest) GetPageToken() string {
   210  	if x != nil {
   211  		return x.PageToken
   212  	}
   213  	return ""
   214  }
   215  
   216  func (x *ListClustersRequest) GetFilter() string {
   217  	if x != nil {
   218  		return x.Filter
   219  	}
   220  	return ""
   221  }
   222  
   223  func (x *ListClustersRequest) GetOrderBy() string {
   224  	if x != nil {
   225  		return x.OrderBy
   226  	}
   227  	return ""
   228  }
   229  
   230  // Response message from 'ListClusters'.
   231  type ListClustersResponse struct {
   232  	state         protoimpl.MessageState
   233  	sizeCache     protoimpl.SizeCache
   234  	unknownFields protoimpl.UnknownFields
   235  
   236  	// List of clusters.
   237  	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
   238  	// A token, which can be sent as `page_token` to retrieve the next page.
   239  	// If this field is omitted, there are no subsequent pages.
   240  	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
   241  	// Locations that could not be reached.
   242  	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
   243  }
   244  
   245  func (x *ListClustersResponse) Reset() {
   246  	*x = ListClustersResponse{}
   247  	if protoimpl.UnsafeEnabled {
   248  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[2]
   249  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   250  		ms.StoreMessageInfo(mi)
   251  	}
   252  }
   253  
   254  func (x *ListClustersResponse) String() string {
   255  	return protoimpl.X.MessageStringOf(x)
   256  }
   257  
   258  func (*ListClustersResponse) ProtoMessage() {}
   259  
   260  func (x *ListClustersResponse) ProtoReflect() protoreflect.Message {
   261  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[2]
   262  	if protoimpl.UnsafeEnabled && x != nil {
   263  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   264  		if ms.LoadMessageInfo() == nil {
   265  			ms.StoreMessageInfo(mi)
   266  		}
   267  		return ms
   268  	}
   269  	return mi.MessageOf(x)
   270  }
   271  
   272  // Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
   273  func (*ListClustersResponse) Descriptor() ([]byte, []int) {
   274  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{2}
   275  }
   276  
   277  func (x *ListClustersResponse) GetClusters() []*Cluster {
   278  	if x != nil {
   279  		return x.Clusters
   280  	}
   281  	return nil
   282  }
   283  
   284  func (x *ListClustersResponse) GetNextPageToken() string {
   285  	if x != nil {
   286  		return x.NextPageToken
   287  	}
   288  	return ""
   289  }
   290  
   291  func (x *ListClustersResponse) GetUnreachable() []string {
   292  	if x != nil {
   293  		return x.Unreachable
   294  	}
   295  	return nil
   296  }
   297  
   298  // Request message for 'GetCluster'.
   299  type GetClusterRequest struct {
   300  	state         protoimpl.MessageState
   301  	sizeCache     protoimpl.SizeCache
   302  	unknownFields protoimpl.UnknownFields
   303  
   304  	// Required. The name of the Cluster resource to get.
   305  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   306  }
   307  
   308  func (x *GetClusterRequest) Reset() {
   309  	*x = GetClusterRequest{}
   310  	if protoimpl.UnsafeEnabled {
   311  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[3]
   312  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   313  		ms.StoreMessageInfo(mi)
   314  	}
   315  }
   316  
   317  func (x *GetClusterRequest) String() string {
   318  	return protoimpl.X.MessageStringOf(x)
   319  }
   320  
   321  func (*GetClusterRequest) ProtoMessage() {}
   322  
   323  func (x *GetClusterRequest) ProtoReflect() protoreflect.Message {
   324  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[3]
   325  	if protoimpl.UnsafeEnabled && x != nil {
   326  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   327  		if ms.LoadMessageInfo() == nil {
   328  			ms.StoreMessageInfo(mi)
   329  		}
   330  		return ms
   331  	}
   332  	return mi.MessageOf(x)
   333  }
   334  
   335  // Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.
   336  func (*GetClusterRequest) Descriptor() ([]byte, []int) {
   337  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{3}
   338  }
   339  
   340  func (x *GetClusterRequest) GetName() string {
   341  	if x != nil {
   342  		return x.Name
   343  	}
   344  	return ""
   345  }
   346  
   347  // Request message for 'CreateCluster'.
   348  type CreateClusterRequest struct {
   349  	state         protoimpl.MessageState
   350  	sizeCache     protoimpl.SizeCache
   351  	unknownFields protoimpl.UnknownFields
   352  
   353  	// Required. The parent that owns the collection of Clusters.
   354  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   355  	// Required. The cluster identifier.
   356  	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
   357  	// Required. The cluster resource to create.
   358  	Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
   359  	// Optional. An optional request ID to identify requests. Specify a unique
   360  	// request ID so that if you must retry your request, the server will know to
   361  	// ignore the request if it has already been completed. The server will
   362  	// guarantee that for at least 60 minutes since the first request.
   363  	//
   364  	// For example, consider a situation where you make an initial request and the
   365  	// request times out. If you make the request again with the same request ID,
   366  	// the server can check if original operation with the same request ID was
   367  	// received, and if so, will ignore the second request. This prevents clients
   368  	// from accidentally creating duplicate commitments.
   369  	//
   370  	// The request ID must be a valid UUID with the exception that zero UUID is
   371  	// not supported (00000000-0000-0000-0000-000000000000).
   372  	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
   373  }
   374  
   375  func (x *CreateClusterRequest) Reset() {
   376  	*x = CreateClusterRequest{}
   377  	if protoimpl.UnsafeEnabled {
   378  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[4]
   379  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   380  		ms.StoreMessageInfo(mi)
   381  	}
   382  }
   383  
   384  func (x *CreateClusterRequest) String() string {
   385  	return protoimpl.X.MessageStringOf(x)
   386  }
   387  
   388  func (*CreateClusterRequest) ProtoMessage() {}
   389  
   390  func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message {
   391  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[4]
   392  	if protoimpl.UnsafeEnabled && x != nil {
   393  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   394  		if ms.LoadMessageInfo() == nil {
   395  			ms.StoreMessageInfo(mi)
   396  		}
   397  		return ms
   398  	}
   399  	return mi.MessageOf(x)
   400  }
   401  
   402  // Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.
   403  func (*CreateClusterRequest) Descriptor() ([]byte, []int) {
   404  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{4}
   405  }
   406  
   407  func (x *CreateClusterRequest) GetParent() string {
   408  	if x != nil {
   409  		return x.Parent
   410  	}
   411  	return ""
   412  }
   413  
   414  func (x *CreateClusterRequest) GetClusterId() string {
   415  	if x != nil {
   416  		return x.ClusterId
   417  	}
   418  	return ""
   419  }
   420  
   421  func (x *CreateClusterRequest) GetCluster() *Cluster {
   422  	if x != nil {
   423  		return x.Cluster
   424  	}
   425  	return nil
   426  }
   427  
   428  func (x *CreateClusterRequest) GetRequestId() string {
   429  	if x != nil {
   430  		return x.RequestId
   431  	}
   432  	return ""
   433  }
   434  
   435  // Request message for 'UpdateCluster'.
   436  type UpdateClusterRequest struct {
   437  	state         protoimpl.MessageState
   438  	sizeCache     protoimpl.SizeCache
   439  	unknownFields protoimpl.UnknownFields
   440  
   441  	// Required. Field mask is used to specify the fields to be overwritten in the
   442  	// Cluster resource by the update.
   443  	// The fields specified in the update_mask are relative to the resource, not
   444  	// the full request. A field will be overwritten if it is in the mask. If the
   445  	// user does not provide a mask then all fields will be overwritten.
   446  	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
   447  	// Required. The Cluster resource to update.
   448  	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
   449  	// Optional. An optional request ID to identify requests. Specify a unique
   450  	// request ID so that if you must retry your request, the server will know to
   451  	// ignore the request if it has already been completed. The server will
   452  	// guarantee that for at least 60 minutes since the first request.
   453  	//
   454  	// For example, consider a situation where you make an initial request and the
   455  	// request times out. If you make the request again with the same request ID,
   456  	// the server can check if original operation with the same request ID was
   457  	// received, and if so, will ignore the second request. This prevents clients
   458  	// from accidentally creating duplicate commitments.
   459  	//
   460  	// The request ID must be a valid UUID with the exception that zero UUID is
   461  	// not supported (00000000-0000-0000-0000-000000000000).
   462  	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
   463  }
   464  
   465  func (x *UpdateClusterRequest) Reset() {
   466  	*x = UpdateClusterRequest{}
   467  	if protoimpl.UnsafeEnabled {
   468  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[5]
   469  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   470  		ms.StoreMessageInfo(mi)
   471  	}
   472  }
   473  
   474  func (x *UpdateClusterRequest) String() string {
   475  	return protoimpl.X.MessageStringOf(x)
   476  }
   477  
   478  func (*UpdateClusterRequest) ProtoMessage() {}
   479  
   480  func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message {
   481  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[5]
   482  	if protoimpl.UnsafeEnabled && x != nil {
   483  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   484  		if ms.LoadMessageInfo() == nil {
   485  			ms.StoreMessageInfo(mi)
   486  		}
   487  		return ms
   488  	}
   489  	return mi.MessageOf(x)
   490  }
   491  
   492  // Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.
   493  func (*UpdateClusterRequest) Descriptor() ([]byte, []int) {
   494  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{5}
   495  }
   496  
   497  func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask {
   498  	if x != nil {
   499  		return x.UpdateMask
   500  	}
   501  	return nil
   502  }
   503  
   504  func (x *UpdateClusterRequest) GetCluster() *Cluster {
   505  	if x != nil {
   506  		return x.Cluster
   507  	}
   508  	return nil
   509  }
   510  
   511  func (x *UpdateClusterRequest) GetRequestId() string {
   512  	if x != nil {
   513  		return x.RequestId
   514  	}
   515  	return ""
   516  }
   517  
   518  // Request message for 'DeleteCluster'.
   519  type DeleteClusterRequest struct {
   520  	state         protoimpl.MessageState
   521  	sizeCache     protoimpl.SizeCache
   522  	unknownFields protoimpl.UnknownFields
   523  
   524  	// Required. The name of cluster to delete.
   525  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   526  	// Optional. An optional request ID to identify requests. Specify a unique
   527  	// request ID so that if you must retry your request, the server will know to
   528  	// ignore the request if it has already been completed. The server will
   529  	// guarantee that for at least 60 minutes after the first request.
   530  	//
   531  	// For example, consider a situation where you make an initial request and the
   532  	// request times out. If you make the request again with the same request ID,
   533  	// the server can check if original operation with the same request ID was
   534  	// received, and if so, will ignore the second request. This prevents clients
   535  	// from accidentally creating duplicate commitments.
   536  	//
   537  	// The request ID must be a valid UUID with the exception that zero UUID is
   538  	// not supported (00000000-0000-0000-0000-000000000000).
   539  	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
   540  }
   541  
   542  func (x *DeleteClusterRequest) Reset() {
   543  	*x = DeleteClusterRequest{}
   544  	if protoimpl.UnsafeEnabled {
   545  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[6]
   546  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   547  		ms.StoreMessageInfo(mi)
   548  	}
   549  }
   550  
   551  func (x *DeleteClusterRequest) String() string {
   552  	return protoimpl.X.MessageStringOf(x)
   553  }
   554  
   555  func (*DeleteClusterRequest) ProtoMessage() {}
   556  
   557  func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message {
   558  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[6]
   559  	if protoimpl.UnsafeEnabled && x != nil {
   560  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   561  		if ms.LoadMessageInfo() == nil {
   562  			ms.StoreMessageInfo(mi)
   563  		}
   564  		return ms
   565  	}
   566  	return mi.MessageOf(x)
   567  }
   568  
   569  // Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
   570  func (*DeleteClusterRequest) Descriptor() ([]byte, []int) {
   571  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{6}
   572  }
   573  
   574  func (x *DeleteClusterRequest) GetName() string {
   575  	if x != nil {
   576  		return x.Name
   577  	}
   578  	return ""
   579  }
   580  
   581  func (x *DeleteClusterRequest) GetRequestId() string {
   582  	if x != nil {
   583  		return x.RequestId
   584  	}
   585  	return ""
   586  }
   587  
   588  // Stream resource.
   589  type Stream struct {
   590  	state         protoimpl.MessageState
   591  	sizeCache     protoimpl.SizeCache
   592  	unknownFields protoimpl.UnknownFields
   593  
   594  	// The name of the stream. The format for the full name is:
   595  	// projects/<projectid>/location/<locationid>/clusters/<clusterid>/streams/<streamid>.
   596  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   597  	// Output only. The time at which this Stream was created.
   598  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
   599  	// Output only. The time at which this Stream was updated.
   600  	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
   601  	// The labels of the stream.
   602  	Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
   603  }
   604  
   605  func (x *Stream) Reset() {
   606  	*x = Stream{}
   607  	if protoimpl.UnsafeEnabled {
   608  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[7]
   609  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   610  		ms.StoreMessageInfo(mi)
   611  	}
   612  }
   613  
   614  func (x *Stream) String() string {
   615  	return protoimpl.X.MessageStringOf(x)
   616  }
   617  
   618  func (*Stream) ProtoMessage() {}
   619  
   620  func (x *Stream) ProtoReflect() protoreflect.Message {
   621  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[7]
   622  	if protoimpl.UnsafeEnabled && x != nil {
   623  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   624  		if ms.LoadMessageInfo() == nil {
   625  			ms.StoreMessageInfo(mi)
   626  		}
   627  		return ms
   628  	}
   629  	return mi.MessageOf(x)
   630  }
   631  
   632  // Deprecated: Use Stream.ProtoReflect.Descriptor instead.
   633  func (*Stream) Descriptor() ([]byte, []int) {
   634  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{7}
   635  }
   636  
   637  func (x *Stream) GetName() string {
   638  	if x != nil {
   639  		return x.Name
   640  	}
   641  	return ""
   642  }
   643  
   644  func (x *Stream) GetCreateTime() *timestamppb.Timestamp {
   645  	if x != nil {
   646  		return x.CreateTime
   647  	}
   648  	return nil
   649  }
   650  
   651  func (x *Stream) GetUpdateTime() *timestamppb.Timestamp {
   652  	if x != nil {
   653  		return x.UpdateTime
   654  	}
   655  	return nil
   656  }
   657  
   658  func (x *Stream) GetLabels() map[string]string {
   659  	if x != nil {
   660  		return x.Labels
   661  	}
   662  	return nil
   663  }
   664  
   665  // Request message for 'ListStreams'.
   666  type ListStreamsRequest struct {
   667  	state         protoimpl.MessageState
   668  	sizeCache     protoimpl.SizeCache
   669  	unknownFields protoimpl.UnknownFields
   670  
   671  	// Required. The parent that owns the collection of the Streams.
   672  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   673  	// Maximum number of Streams to return.
   674  	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
   675  	// Page token received from a previous `ListStreams` call. Provide this to
   676  	// retrieve the subsequent page. When paginating, all other parameters
   677  	// provided to `ListClusters` must match the call that provided the page
   678  	// token.
   679  	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
   680  	// Filter request.
   681  	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
   682  	// Order by fields for the result.
   683  	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
   684  }
   685  
   686  func (x *ListStreamsRequest) Reset() {
   687  	*x = ListStreamsRequest{}
   688  	if protoimpl.UnsafeEnabled {
   689  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[8]
   690  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   691  		ms.StoreMessageInfo(mi)
   692  	}
   693  }
   694  
   695  func (x *ListStreamsRequest) String() string {
   696  	return protoimpl.X.MessageStringOf(x)
   697  }
   698  
   699  func (*ListStreamsRequest) ProtoMessage() {}
   700  
   701  func (x *ListStreamsRequest) ProtoReflect() protoreflect.Message {
   702  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[8]
   703  	if protoimpl.UnsafeEnabled && x != nil {
   704  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   705  		if ms.LoadMessageInfo() == nil {
   706  			ms.StoreMessageInfo(mi)
   707  		}
   708  		return ms
   709  	}
   710  	return mi.MessageOf(x)
   711  }
   712  
   713  // Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.
   714  func (*ListStreamsRequest) Descriptor() ([]byte, []int) {
   715  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{8}
   716  }
   717  
   718  func (x *ListStreamsRequest) GetParent() string {
   719  	if x != nil {
   720  		return x.Parent
   721  	}
   722  	return ""
   723  }
   724  
   725  func (x *ListStreamsRequest) GetPageSize() int32 {
   726  	if x != nil {
   727  		return x.PageSize
   728  	}
   729  	return 0
   730  }
   731  
   732  func (x *ListStreamsRequest) GetPageToken() string {
   733  	if x != nil {
   734  		return x.PageToken
   735  	}
   736  	return ""
   737  }
   738  
   739  func (x *ListStreamsRequest) GetFilter() string {
   740  	if x != nil {
   741  		return x.Filter
   742  	}
   743  	return ""
   744  }
   745  
   746  func (x *ListStreamsRequest) GetOrderBy() string {
   747  	if x != nil {
   748  		return x.OrderBy
   749  	}
   750  	return ""
   751  }
   752  
   753  // Response message from 'ListStreams'.
   754  type ListStreamsResponse struct {
   755  	state         protoimpl.MessageState
   756  	sizeCache     protoimpl.SizeCache
   757  	unknownFields protoimpl.UnknownFields
   758  
   759  	// List of the streams.
   760  	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
   761  	// A token, which can be sent as `page_token` to retrieve the next page.
   762  	// If this field is omitted, there are no subsequent pages.
   763  	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
   764  	// Locations that could not be reached.
   765  	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
   766  }
   767  
   768  func (x *ListStreamsResponse) Reset() {
   769  	*x = ListStreamsResponse{}
   770  	if protoimpl.UnsafeEnabled {
   771  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[9]
   772  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   773  		ms.StoreMessageInfo(mi)
   774  	}
   775  }
   776  
   777  func (x *ListStreamsResponse) String() string {
   778  	return protoimpl.X.MessageStringOf(x)
   779  }
   780  
   781  func (*ListStreamsResponse) ProtoMessage() {}
   782  
   783  func (x *ListStreamsResponse) ProtoReflect() protoreflect.Message {
   784  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[9]
   785  	if protoimpl.UnsafeEnabled && x != nil {
   786  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   787  		if ms.LoadMessageInfo() == nil {
   788  			ms.StoreMessageInfo(mi)
   789  		}
   790  		return ms
   791  	}
   792  	return mi.MessageOf(x)
   793  }
   794  
   795  // Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.
   796  func (*ListStreamsResponse) Descriptor() ([]byte, []int) {
   797  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{9}
   798  }
   799  
   800  func (x *ListStreamsResponse) GetStreams() []*Stream {
   801  	if x != nil {
   802  		return x.Streams
   803  	}
   804  	return nil
   805  }
   806  
   807  func (x *ListStreamsResponse) GetNextPageToken() string {
   808  	if x != nil {
   809  		return x.NextPageToken
   810  	}
   811  	return ""
   812  }
   813  
   814  func (x *ListStreamsResponse) GetUnreachable() []string {
   815  	if x != nil {
   816  		return x.Unreachable
   817  	}
   818  	return nil
   819  }
   820  
   821  // Request message for 'GetStream'.
   822  type GetStreamRequest struct {
   823  	state         protoimpl.MessageState
   824  	sizeCache     protoimpl.SizeCache
   825  	unknownFields protoimpl.UnknownFields
   826  
   827  	// Required. The name of the stream.
   828  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   829  }
   830  
   831  func (x *GetStreamRequest) Reset() {
   832  	*x = GetStreamRequest{}
   833  	if protoimpl.UnsafeEnabled {
   834  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[10]
   835  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   836  		ms.StoreMessageInfo(mi)
   837  	}
   838  }
   839  
   840  func (x *GetStreamRequest) String() string {
   841  	return protoimpl.X.MessageStringOf(x)
   842  }
   843  
   844  func (*GetStreamRequest) ProtoMessage() {}
   845  
   846  func (x *GetStreamRequest) ProtoReflect() protoreflect.Message {
   847  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[10]
   848  	if protoimpl.UnsafeEnabled && x != nil {
   849  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   850  		if ms.LoadMessageInfo() == nil {
   851  			ms.StoreMessageInfo(mi)
   852  		}
   853  		return ms
   854  	}
   855  	return mi.MessageOf(x)
   856  }
   857  
   858  // Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.
   859  func (*GetStreamRequest) Descriptor() ([]byte, []int) {
   860  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{10}
   861  }
   862  
   863  func (x *GetStreamRequest) GetName() string {
   864  	if x != nil {
   865  		return x.Name
   866  	}
   867  	return ""
   868  }
   869  
   870  // Request message for 'CreateStream'.
   871  type CreateStreamRequest struct {
   872  	state         protoimpl.MessageState
   873  	sizeCache     protoimpl.SizeCache
   874  	unknownFields protoimpl.UnknownFields
   875  
   876  	// Required. The parent that owns the collection of streams.
   877  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   878  	// Required. The stream identifier.
   879  	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
   880  	// Required. The stream to create.
   881  	Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
   882  	// Optional. An optional request ID to identify requests. Specify a unique
   883  	// request ID so that if you must retry your request, the server will know to
   884  	// ignore the request if it has already been completed. The server will
   885  	// guarantee that for at least 60 minutes since the first request.
   886  	//
   887  	// For example, consider a situation where you make an initial request and t
   888  	// he request times out. If you make the request again with the same request
   889  	// ID, the server can check if original operation with the same request ID
   890  	// was received, and if so, will ignore the second request. This prevents
   891  	// clients from accidentally creating duplicate commitments.
   892  	//
   893  	// The request ID must be a valid UUID with the exception that zero UUID is
   894  	// not supported (00000000-0000-0000-0000-000000000000).
   895  	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
   896  }
   897  
   898  func (x *CreateStreamRequest) Reset() {
   899  	*x = CreateStreamRequest{}
   900  	if protoimpl.UnsafeEnabled {
   901  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[11]
   902  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   903  		ms.StoreMessageInfo(mi)
   904  	}
   905  }
   906  
   907  func (x *CreateStreamRequest) String() string {
   908  	return protoimpl.X.MessageStringOf(x)
   909  }
   910  
   911  func (*CreateStreamRequest) ProtoMessage() {}
   912  
   913  func (x *CreateStreamRequest) ProtoReflect() protoreflect.Message {
   914  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[11]
   915  	if protoimpl.UnsafeEnabled && x != nil {
   916  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   917  		if ms.LoadMessageInfo() == nil {
   918  			ms.StoreMessageInfo(mi)
   919  		}
   920  		return ms
   921  	}
   922  	return mi.MessageOf(x)
   923  }
   924  
   925  // Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.
   926  func (*CreateStreamRequest) Descriptor() ([]byte, []int) {
   927  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{11}
   928  }
   929  
   930  func (x *CreateStreamRequest) GetParent() string {
   931  	if x != nil {
   932  		return x.Parent
   933  	}
   934  	return ""
   935  }
   936  
   937  func (x *CreateStreamRequest) GetStreamId() string {
   938  	if x != nil {
   939  		return x.StreamId
   940  	}
   941  	return ""
   942  }
   943  
   944  func (x *CreateStreamRequest) GetStream() *Stream {
   945  	if x != nil {
   946  		return x.Stream
   947  	}
   948  	return nil
   949  }
   950  
   951  func (x *CreateStreamRequest) GetRequestId() string {
   952  	if x != nil {
   953  		return x.RequestId
   954  	}
   955  	return ""
   956  }
   957  
   958  // Request message for 'UpdateStream'.
   959  type UpdateStreamRequest struct {
   960  	state         protoimpl.MessageState
   961  	sizeCache     protoimpl.SizeCache
   962  	unknownFields protoimpl.UnknownFields
   963  
   964  	// Required. Field mask is used to specify the fields to be overwritten in the
   965  	// Stream resource by the update.
   966  	// The fields specified in the update_mask are relative to the resource, not
   967  	// the full request. A field will be overwritten if it is in the mask. If the
   968  	// user does not provide a mask then all fields will be overwritten.
   969  	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
   970  	// Required. The stream resource to update.
   971  	Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
   972  	// Optional. An optional request ID to identify requests. Specify a unique
   973  	// request ID so that if you must retry your request, the server will know to
   974  	// ignore the request if it has already been completed. The server will
   975  	// guarantee that for at least 60 minutes since the first request.
   976  	//
   977  	// For example, consider a situation where you make an initial request and t
   978  	// he request times out. If you make the request again with the same request
   979  	// ID, the server can check if original operation with the same request ID
   980  	// was received, and if so, will ignore the second request. This prevents
   981  	// clients from accidentally creating duplicate commitments.
   982  	//
   983  	// The request ID must be a valid UUID with the exception that zero UUID is
   984  	// not supported (00000000-0000-0000-0000-000000000000).
   985  	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
   986  }
   987  
   988  func (x *UpdateStreamRequest) Reset() {
   989  	*x = UpdateStreamRequest{}
   990  	if protoimpl.UnsafeEnabled {
   991  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[12]
   992  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   993  		ms.StoreMessageInfo(mi)
   994  	}
   995  }
   996  
   997  func (x *UpdateStreamRequest) String() string {
   998  	return protoimpl.X.MessageStringOf(x)
   999  }
  1000  
  1001  func (*UpdateStreamRequest) ProtoMessage() {}
  1002  
  1003  func (x *UpdateStreamRequest) ProtoReflect() protoreflect.Message {
  1004  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[12]
  1005  	if protoimpl.UnsafeEnabled && x != nil {
  1006  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1007  		if ms.LoadMessageInfo() == nil {
  1008  			ms.StoreMessageInfo(mi)
  1009  		}
  1010  		return ms
  1011  	}
  1012  	return mi.MessageOf(x)
  1013  }
  1014  
  1015  // Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.
  1016  func (*UpdateStreamRequest) Descriptor() ([]byte, []int) {
  1017  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{12}
  1018  }
  1019  
  1020  func (x *UpdateStreamRequest) GetUpdateMask() *fieldmaskpb.FieldMask {
  1021  	if x != nil {
  1022  		return x.UpdateMask
  1023  	}
  1024  	return nil
  1025  }
  1026  
  1027  func (x *UpdateStreamRequest) GetStream() *Stream {
  1028  	if x != nil {
  1029  		return x.Stream
  1030  	}
  1031  	return nil
  1032  }
  1033  
  1034  func (x *UpdateStreamRequest) GetRequestId() string {
  1035  	if x != nil {
  1036  		return x.RequestId
  1037  	}
  1038  	return ""
  1039  }
  1040  
  1041  // Request message for 'DeleteStream'.
  1042  type DeleteStreamRequest struct {
  1043  	state         protoimpl.MessageState
  1044  	sizeCache     protoimpl.SizeCache
  1045  	unknownFields protoimpl.UnknownFields
  1046  
  1047  	// Required. The name of the stream.
  1048  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  1049  	// Optional. An optional request ID to identify requests. Specify a unique
  1050  	// request ID so that if you must retry your request, the server will know to
  1051  	// ignore the request if it has already been completed. The server will
  1052  	// guarantee that for at least 60 minutes after the first request.
  1053  	//
  1054  	// For example, consider a situation where you make an initial request and t
  1055  	// he request times out. If you make the request again with the same request
  1056  	// ID, the server can check if original operation with the same request ID
  1057  	// was received, and if so, will ignore the second request. This prevents
  1058  	// clients from accidentally creating duplicate commitments.
  1059  	//
  1060  	// The request ID must be a valid UUID with the exception that zero UUID is
  1061  	// not supported (00000000-0000-0000-0000-000000000000).
  1062  	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
  1063  }
  1064  
  1065  func (x *DeleteStreamRequest) Reset() {
  1066  	*x = DeleteStreamRequest{}
  1067  	if protoimpl.UnsafeEnabled {
  1068  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[13]
  1069  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1070  		ms.StoreMessageInfo(mi)
  1071  	}
  1072  }
  1073  
  1074  func (x *DeleteStreamRequest) String() string {
  1075  	return protoimpl.X.MessageStringOf(x)
  1076  }
  1077  
  1078  func (*DeleteStreamRequest) ProtoMessage() {}
  1079  
  1080  func (x *DeleteStreamRequest) ProtoReflect() protoreflect.Message {
  1081  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[13]
  1082  	if protoimpl.UnsafeEnabled && x != nil {
  1083  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1084  		if ms.LoadMessageInfo() == nil {
  1085  			ms.StoreMessageInfo(mi)
  1086  		}
  1087  		return ms
  1088  	}
  1089  	return mi.MessageOf(x)
  1090  }
  1091  
  1092  // Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.
  1093  func (*DeleteStreamRequest) Descriptor() ([]byte, []int) {
  1094  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{13}
  1095  }
  1096  
  1097  func (x *DeleteStreamRequest) GetName() string {
  1098  	if x != nil {
  1099  		return x.Name
  1100  	}
  1101  	return ""
  1102  }
  1103  
  1104  func (x *DeleteStreamRequest) GetRequestId() string {
  1105  	if x != nil {
  1106  		return x.RequestId
  1107  	}
  1108  	return ""
  1109  }
  1110  
  1111  // Represents the metadata of the long-running operation.
  1112  type OperationMetadata struct {
  1113  	state         protoimpl.MessageState
  1114  	sizeCache     protoimpl.SizeCache
  1115  	unknownFields protoimpl.UnknownFields
  1116  
  1117  	// Output only. The time the operation was created.
  1118  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
  1119  	// Output only. The time the operation finished running.
  1120  	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
  1121  	// Output only. Server-defined resource path for the target of the operation.
  1122  	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
  1123  	// Output only. Name of the verb executed by the operation.
  1124  	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
  1125  	// Output only. Human-readable status of the operation, if any.
  1126  	StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
  1127  	// Output only. Identifies whether the user has requested cancellation
  1128  	// of the operation. Operations that have successfully been cancelled
  1129  	// have [Operation.error][] value with a
  1130  	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
  1131  	// `Code.CANCELLED`.
  1132  	RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
  1133  	// Output only. API version used to start the operation.
  1134  	ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
  1135  }
  1136  
  1137  func (x *OperationMetadata) Reset() {
  1138  	*x = OperationMetadata{}
  1139  	if protoimpl.UnsafeEnabled {
  1140  		mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[14]
  1141  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1142  		ms.StoreMessageInfo(mi)
  1143  	}
  1144  }
  1145  
  1146  func (x *OperationMetadata) String() string {
  1147  	return protoimpl.X.MessageStringOf(x)
  1148  }
  1149  
  1150  func (*OperationMetadata) ProtoMessage() {}
  1151  
  1152  func (x *OperationMetadata) ProtoReflect() protoreflect.Message {
  1153  	mi := &file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[14]
  1154  	if protoimpl.UnsafeEnabled && x != nil {
  1155  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1156  		if ms.LoadMessageInfo() == nil {
  1157  			ms.StoreMessageInfo(mi)
  1158  		}
  1159  		return ms
  1160  	}
  1161  	return mi.MessageOf(x)
  1162  }
  1163  
  1164  // Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
  1165  func (*OperationMetadata) Descriptor() ([]byte, []int) {
  1166  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP(), []int{14}
  1167  }
  1168  
  1169  func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp {
  1170  	if x != nil {
  1171  		return x.CreateTime
  1172  	}
  1173  	return nil
  1174  }
  1175  
  1176  func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp {
  1177  	if x != nil {
  1178  		return x.EndTime
  1179  	}
  1180  	return nil
  1181  }
  1182  
  1183  func (x *OperationMetadata) GetTarget() string {
  1184  	if x != nil {
  1185  		return x.Target
  1186  	}
  1187  	return ""
  1188  }
  1189  
  1190  func (x *OperationMetadata) GetVerb() string {
  1191  	if x != nil {
  1192  		return x.Verb
  1193  	}
  1194  	return ""
  1195  }
  1196  
  1197  func (x *OperationMetadata) GetStatusMessage() string {
  1198  	if x != nil {
  1199  		return x.StatusMessage
  1200  	}
  1201  	return ""
  1202  }
  1203  
  1204  func (x *OperationMetadata) GetRequestedCancellation() bool {
  1205  	if x != nil {
  1206  		return x.RequestedCancellation
  1207  	}
  1208  	return false
  1209  }
  1210  
  1211  func (x *OperationMetadata) GetApiVersion() string {
  1212  	if x != nil {
  1213  		return x.ApiVersion
  1214  	}
  1215  	return ""
  1216  }
  1217  
  1218  var File_google_partner_aistreams_v1alpha1_aistreams_proto protoreflect.FileDescriptor
  1219  
  1220  var file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDesc = []byte{
  1221  	0x0a, 0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72,
  1222  	0x2f, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1223  	0x68, 0x61, 0x31, 0x2f, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x70, 0x72,
  1224  	0x6f, 0x74, 0x6f, 0x12, 0x21, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74,
  1225  	0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31,
  1226  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61,
  1227  	0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70,
  1228  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
  1229  	0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
  1230  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f,
  1231  	0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19,
  1232  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75,
  1233  	0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1234  	0x65, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70,
  1235  	0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20,
  1236  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f,
  1237  	0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1238  	0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
  1239  	0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1240  	0x6f, 0x22, 0xe6, 0x03, 0x0a, 0x07, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x12, 0x0a,
  1241  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d,
  1242  	0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65,
  1243  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1244  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
  1245  	0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54,
  1246  	0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69,
  1247  	0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1248  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
  1249  	0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74,
  1250  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x4e, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18,
  1251  	0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1252  	0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1253  	0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
  1254  	0x72, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c,
  1255  	0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x25, 0x0a, 0x0b, 0x63, 0x65, 0x72, 0x74, 0x69, 0x66, 0x69,
  1256  	0x63, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
  1257  	0x0b, 0x63, 0x65, 0x72, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x65, 0x12, 0x2e, 0x0a, 0x10,
  1258  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74,
  1259  	0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0f, 0x73, 0x65, 0x72,
  1260  	0x76, 0x69, 0x63, 0x65, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x1a, 0x39, 0x0a, 0x0b,
  1261  	0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
  1262  	0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
  1263  	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61,
  1264  	0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x3a, 0x61, 0xea, 0x41, 0x5e, 0x0a, 0x20, 0x61, 0x69,
  1265  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
  1266  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x3a,
  1267  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1268  	0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f,
  1269  	0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73,
  1270  	0x2f, 0x7b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x7d, 0x22, 0xc7, 0x01, 0x0a, 0x13, 0x4c,
  1271  	0x69, 0x73, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
  1272  	0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
  1273  	0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61,
  1274  	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
  1275  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70,
  1276  	0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69,
  1277  	0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69,
  1278  	0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e,
  1279  	0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65,
  1280  	0x6e, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28,
  1281  	0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x19, 0x0a, 0x08, 0x6f, 0x72, 0x64,
  1282  	0x65, 0x72, 0x5f, 0x62, 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6f, 0x72, 0x64,
  1283  	0x65, 0x72, 0x42, 0x79, 0x22, 0xa8, 0x01, 0x0a, 0x14, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6c, 0x75,
  1284  	0x73, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x46, 0x0a,
  1285  	0x08, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
  1286  	0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72,
  1287  	0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1288  	0x68, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x08, 0x63, 0x6c, 0x75,
  1289  	0x73, 0x74, 0x65, 0x72, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61,
  1290  	0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d,
  1291  	0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x20, 0x0a,
  1292  	0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x03,
  1293  	0x28, 0x09, 0x52, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68, 0x61, 0x62, 0x6c, 0x65, 0x22,
  1294  	0x51, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71,
  1295  	0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
  1296  	0x28, 0x09, 0x42, 0x28, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x22, 0x0a, 0x20, 0x61, 0x69, 0x73, 0x74,
  1297  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
  1298  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x04, 0x6e, 0x61,
  1299  	0x6d, 0x65, 0x22, 0xec, 0x01, 0x0a, 0x14, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75,
  1300  	0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x41, 0x0a, 0x06, 0x70,
  1301  	0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xe0, 0x41, 0x02,
  1302  	0xfa, 0x41, 0x23, 0x0a, 0x21, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x67,
  1303  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4c, 0x6f,
  1304  	0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x22,
  1305  	0x0a, 0x0a, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
  1306  	0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x09, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
  1307  	0x49, 0x64, 0x12, 0x49, 0x0a, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x18, 0x03, 0x20,
  1308  	0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72,
  1309  	0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76,
  1310  	0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x42,
  1311  	0x03, 0xe0, 0x41, 0x02, 0x52, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x22, 0x0a,
  1312  	0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28,
  1313  	0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49,
  1314  	0x64, 0x22, 0xc7, 0x01, 0x0a, 0x14, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73,
  1315  	0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70,
  1316  	0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1317  	0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
  1318  	0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x02,
  1319  	0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x12, 0x49, 0x0a, 0x07,
  1320  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e,
  1321  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61,
  1322  	0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
  1323  	0x31, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x07,
  1324  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x22, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65,
  1325  	0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01,
  1326  	0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x78, 0x0a, 0x14, 0x44,
  1327  	0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75,
  1328  	0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
  1329  	0x09, 0x42, 0x28, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x22, 0x0a, 0x20, 0x61, 0x69, 0x73, 0x74, 0x72,
  1330  	0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
  1331  	0x63, 0x6f, 0x6d, 0x2f, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x04, 0x6e, 0x61, 0x6d,
  1332  	0x65, 0x12, 0x22, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18,
  1333  	0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75,
  1334  	0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x9d, 0x03, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1335  	0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
  1336  	0x6e, 0x61, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74,
  1337  	0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1338  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65,
  1339  	0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61,
  1340  	0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65,
  1341  	0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f,
  1342  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69,
  1343  	0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x75, 0x70,
  1344  	0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x4d, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65,
  1345  	0x6c, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1346  	0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65,
  1347  	0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72,
  1348  	0x65, 0x61, 0x6d, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52,
  1349  	0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c,
  1350  	0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20,
  1351  	0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75,
  1352  	0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02,
  1353  	0x38, 0x01, 0x3a, 0x71, 0xea, 0x41, 0x6e, 0x0a, 0x1f, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1354  	0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
  1355  	0x6d, 0x2f, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x4b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1356  	0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63,
  1357  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1358  	0x7d, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x7b, 0x63, 0x6c, 0x75, 0x73,
  1359  	0x74, 0x65, 0x72, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74,
  1360  	0x72, 0x65, 0x61, 0x6d, 0x7d, 0x22, 0xc5, 0x01, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x74,
  1361  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a, 0x06,
  1362  	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x28, 0xe0, 0x41,
  1363  	0x02, 0xfa, 0x41, 0x22, 0x0a, 0x20, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e,
  1364  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x43,
  1365  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1b,
  1366  	0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
  1367  	0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70,
  1368  	0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
  1369  	0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69,
  1370  	0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74,
  1371  	0x65, 0x72, 0x12, 0x19, 0x0a, 0x08, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x5f, 0x62, 0x79, 0x18, 0x05,
  1372  	0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x42, 0x79, 0x22, 0xa4, 0x01,
  1373  	0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x73,
  1374  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x43, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1375  	0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1376  	0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1377  	0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
  1378  	0x6d, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65,
  1379  	0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20,
  1380  	0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b,
  1381  	0x65, 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68, 0x61, 0x62, 0x6c,
  1382  	0x65, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68,
  1383  	0x61, 0x62, 0x6c, 0x65, 0x22, 0x4f, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61,
  1384  	0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1385  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f,
  1386  	0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1387  	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1388  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xe5, 0x01, 0x0a, 0x13, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
  1389  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a,
  1390  	0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x28, 0xe0,
  1391  	0x41, 0x02, 0xfa, 0x41, 0x22, 0x0a, 0x20, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1392  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
  1393  	0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12,
  1394  	0x20, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
  1395  	0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x08, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49,
  1396  	0x64, 0x12, 0x46, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28,
  1397  	0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e,
  1398  	0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61,
  1399  	0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41,
  1400  	0x02, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x22, 0x0a, 0x0a, 0x72, 0x65, 0x71,
  1401  	0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
  1402  	0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0xc3, 0x01,
  1403  	0x0a, 0x13, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,
  1404  	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f,
  1405  	0x6d, 0x61, 0x73, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f,
  1406  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65,
  1407  	0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0a, 0x75, 0x70, 0x64,
  1408  	0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x12, 0x46, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61,
  1409  	0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1410  	0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1411  	0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65,
  1412  	0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12,
  1413  	0x22, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20,
  1414  	0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73,
  1415  	0x74, 0x49, 0x64, 0x22, 0x76, 0x0a, 0x13, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x74, 0x72,
  1416  	0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61,
  1417  	0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21,
  1418  	0x0a, 0x1f, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1419  	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x74, 0x72, 0x65, 0x61,
  1420  	0x6d, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x22, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65,
  1421  	0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01,
  1422  	0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0xd5, 0x02, 0x0a, 0x11,
  1423  	0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74,
  1424  	0x61, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65,
  1425  	0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1426  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
  1427  	0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54,
  1428  	0x69, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18,
  1429  	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1430  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
  1431  	0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12,
  1432  	0x1b, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42,
  1433  	0x03, 0xe0, 0x41, 0x03, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x17, 0x0a, 0x04,
  1434  	0x76, 0x65, 0x72, 0x62, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
  1435  	0x04, 0x76, 0x65, 0x72, 0x62, 0x12, 0x2a, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f,
  1436  	0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
  1437  	0x41, 0x03, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1438  	0x65, 0x12, 0x3a, 0x0a, 0x16, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x5f, 0x63,
  1439  	0x61, 0x6e, 0x63, 0x65, 0x6c, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28,
  1440  	0x08, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x15, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65,
  1441  	0x64, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x24, 0x0a,
  1442  	0x0b, 0x61, 0x70, 0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x07, 0x20, 0x01,
  1443  	0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x61, 0x70, 0x69, 0x56, 0x65, 0x72, 0x73,
  1444  	0x69, 0x6f, 0x6e, 0x32, 0xd0, 0x11, 0x0a, 0x09, 0x41, 0x49, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1445  	0x73, 0x12, 0xc4, 0x01, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
  1446  	0x72, 0x73, 0x12, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74,
  1447  	0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31,
  1448  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74,
  1449  	0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x37, 0x2e, 0x67, 0x6f, 0x6f,
  1450  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74,
  1451  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c,
  1452  	0x69, 0x73, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
  1453  	0x6e, 0x73, 0x65, 0x22, 0x43, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x82, 0xd3,
  1454  	0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f,
  1455  	0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73,
  1456  	0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f,
  1457  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x12, 0xb1, 0x01, 0x0a, 0x0a, 0x47, 0x65, 0x74,
  1458  	0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1459  	0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1460  	0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x43,
  1461  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2a, 0x2e,
  1462  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61,
  1463  	0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
  1464  	0x31, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x22, 0x41, 0xda, 0x41, 0x04, 0x6e, 0x61,
  1465  	0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x12, 0x32, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1466  	0x68, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1467  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a,
  1468  	0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xe7, 0x01, 0x0a,
  1469  	0x0d, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x37,
  1470  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e,
  1471  	0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
  1472  	0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
  1473  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1474  	0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65,
  1475  	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x7e, 0xca, 0x41, 0x1c, 0x0a, 0x07, 0x43, 0x6c, 0x75,
  1476  	0x73, 0x74, 0x65, 0x72, 0x12, 0x11, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d,
  1477  	0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xda, 0x41, 0x19, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74,
  1478  	0x2c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x2c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
  1479  	0x5f, 0x69, 0x64, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3d, 0x22, 0x32, 0x2f, 0x76, 0x31, 0x61, 0x6c,
  1480  	0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f,
  1481  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1482  	0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x3a, 0x07, 0x63,
  1483  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0xea, 0x01, 0x0a, 0x0d, 0x55, 0x70, 0x64, 0x61, 0x74,
  1484  	0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1485  	0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65,
  1486  	0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x55, 0x70, 0x64,
  1487  	0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  1488  	0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72,
  1489  	0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1490  	0x22, 0x80, 0x01, 0xca, 0x41, 0x1c, 0x0a, 0x07, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12,
  1491  	0x11, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
  1492  	0x74, 0x61, 0xda, 0x41, 0x13, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x2c, 0x75, 0x70, 0x64,
  1493  	0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x32, 0x3a,
  1494  	0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x63, 0x6c, 0x75, 0x73, 0x74,
  1495  	0x65, 0x72, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73,
  1496  	0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63,
  1497  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x07, 0x63, 0x6c, 0x75, 0x73,
  1498  	0x74, 0x65, 0x72, 0x12, 0xd7, 0x01, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c,
  1499  	0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1500  	0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1501  	0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65,
  1502  	0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d,
  1503  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e,
  1504  	0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x6e, 0xca,
  1505  	0x41, 0x2a, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1506  	0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x11, 0x4f, 0x70, 0x65, 0x72, 0x61,
  1507  	0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xda, 0x41, 0x04, 0x6e,
  1508  	0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x34, 0x2a, 0x32, 0x2f, 0x76, 0x31, 0x61, 0x6c,
  1509  	0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
  1510  	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
  1511  	0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xcb, 0x01,
  1512  	0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0x35, 0x2e,
  1513  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61,
  1514  	0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
  1515  	0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71,
  1516  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61,
  1517  	0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e,
  1518  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x74, 0x72,
  1519  	0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4d, 0xda, 0x41,
  1520  	0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e, 0x12, 0x3c, 0x2f,
  1521  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74,
  1522  	0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61,
  1523  	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73,
  1524  	0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0xb8, 0x01, 0x0a, 0x09,
  1525  	0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1526  	0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72,
  1527  	0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x47, 0x65,
  1528  	0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29,
  1529  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e,
  1530  	0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
  1531  	0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x4b, 0xda, 0x41, 0x04, 0x6e, 0x61,
  1532  	0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e, 0x12, 0x3c, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
  1533  	0x68, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1534  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a,
  1535  	0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65,
  1536  	0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xec, 0x01, 0x0a, 0x0c, 0x43, 0x72, 0x65, 0x61, 0x74,
  1537  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1538  	0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1539  	0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61,
  1540  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
  1541  	0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e,
  1542  	0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x84,
  1543  	0x01, 0xca, 0x41, 0x1b, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x11, 0x4f, 0x70,
  1544  	0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xda,
  1545  	0x41, 0x17, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2c,
  1546  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22,
  1547  	0x3c, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65,
  1548  	0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f,
  1549  	0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65,
  1550  	0x72, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x3a, 0x06, 0x73,
  1551  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0xee, 0x01, 0x0a, 0x0c, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65,
  1552  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1553  	0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1554  	0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74,
  1555  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d,
  1556  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e,
  1557  	0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x86, 0x01,
  1558  	0xca, 0x41, 0x1b, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x11, 0x4f, 0x70, 0x65,
  1559  	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xda, 0x41,
  1560  	0x12, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d,
  1561  	0x61, 0x73, 0x6b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x4d, 0x32, 0x43, 0x2f, 0x76, 0x31, 0x61, 0x6c,
  1562  	0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x6e, 0x61, 0x6d,
  1563  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
  1564  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
  1565  	0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x06,
  1566  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0xdf, 0x01, 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x65, 0x74,
  1567  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1568  	0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1569  	0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65,
  1570  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
  1571  	0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e,
  1572  	0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x78,
  1573  	0xca, 0x41, 0x2a, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1574  	0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x11, 0x4f, 0x70, 0x65, 0x72,
  1575  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xda, 0x41, 0x04,
  1576  	0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e, 0x2a, 0x3c, 0x2f, 0x76, 0x31, 0x61,
  1577  	0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
  1578  	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
  1579  	0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74,
  1580  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x1a, 0x4c, 0xca, 0x41, 0x18, 0x61, 0x69, 0x73,
  1581  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  1582  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f,
  1583  	0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63,
  1584  	0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c,
  1585  	0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0xb2, 0x01, 0x0a, 0x25, 0x63, 0x6f, 0x6d, 0x2e, 0x67,
  1586  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x2e, 0x61, 0x69,
  1587  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
  1588  	0x42, 0x0e, 0x41, 0x49, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f,
  1589  	0x50, 0x01, 0x5a, 0x4a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e,
  1590  	0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67,
  1591  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x61, 0x72, 0x74, 0x6e, 0x65,
  1592  	0x72, 0x2f, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x76, 0x31, 0x61, 0x6c,
  1593  	0x70, 0x68, 0x61, 0x31, 0x3b, 0x61, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0xf8, 0x01,
  1594  	0x01, 0xca, 0x02, 0x27, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64,
  1595  	0x5c, 0x50, 0x61, 0x72, 0x74, 0x6e, 0x65, 0x72, 0x5c, 0x41, 0x69, 0x73, 0x74, 0x72, 0x65, 0x61,
  1596  	0x6d, 0x73, 0x5c, 0x56, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f,
  1597  	0x74, 0x6f, 0x33,
  1598  }
  1599  
  1600  var (
  1601  	file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescOnce sync.Once
  1602  	file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescData = file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDesc
  1603  )
  1604  
  1605  func file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescGZIP() []byte {
  1606  	file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescOnce.Do(func() {
  1607  		file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescData)
  1608  	})
  1609  	return file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDescData
  1610  }
  1611  
  1612  var file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes = make([]protoimpl.MessageInfo, 17)
  1613  var file_google_partner_aistreams_v1alpha1_aistreams_proto_goTypes = []interface{}{
  1614  	(*Cluster)(nil),                 // 0: google.partner.aistreams.v1alpha1.Cluster
  1615  	(*ListClustersRequest)(nil),     // 1: google.partner.aistreams.v1alpha1.ListClustersRequest
  1616  	(*ListClustersResponse)(nil),    // 2: google.partner.aistreams.v1alpha1.ListClustersResponse
  1617  	(*GetClusterRequest)(nil),       // 3: google.partner.aistreams.v1alpha1.GetClusterRequest
  1618  	(*CreateClusterRequest)(nil),    // 4: google.partner.aistreams.v1alpha1.CreateClusterRequest
  1619  	(*UpdateClusterRequest)(nil),    // 5: google.partner.aistreams.v1alpha1.UpdateClusterRequest
  1620  	(*DeleteClusterRequest)(nil),    // 6: google.partner.aistreams.v1alpha1.DeleteClusterRequest
  1621  	(*Stream)(nil),                  // 7: google.partner.aistreams.v1alpha1.Stream
  1622  	(*ListStreamsRequest)(nil),      // 8: google.partner.aistreams.v1alpha1.ListStreamsRequest
  1623  	(*ListStreamsResponse)(nil),     // 9: google.partner.aistreams.v1alpha1.ListStreamsResponse
  1624  	(*GetStreamRequest)(nil),        // 10: google.partner.aistreams.v1alpha1.GetStreamRequest
  1625  	(*CreateStreamRequest)(nil),     // 11: google.partner.aistreams.v1alpha1.CreateStreamRequest
  1626  	(*UpdateStreamRequest)(nil),     // 12: google.partner.aistreams.v1alpha1.UpdateStreamRequest
  1627  	(*DeleteStreamRequest)(nil),     // 13: google.partner.aistreams.v1alpha1.DeleteStreamRequest
  1628  	(*OperationMetadata)(nil),       // 14: google.partner.aistreams.v1alpha1.OperationMetadata
  1629  	nil,                             // 15: google.partner.aistreams.v1alpha1.Cluster.LabelsEntry
  1630  	nil,                             // 16: google.partner.aistreams.v1alpha1.Stream.LabelsEntry
  1631  	(*timestamppb.Timestamp)(nil),   // 17: google.protobuf.Timestamp
  1632  	(*fieldmaskpb.FieldMask)(nil),   // 18: google.protobuf.FieldMask
  1633  	(*longrunningpb.Operation)(nil), // 19: google.longrunning.Operation
  1634  }
  1635  var file_google_partner_aistreams_v1alpha1_aistreams_proto_depIdxs = []int32{
  1636  	17, // 0: google.partner.aistreams.v1alpha1.Cluster.create_time:type_name -> google.protobuf.Timestamp
  1637  	17, // 1: google.partner.aistreams.v1alpha1.Cluster.update_time:type_name -> google.protobuf.Timestamp
  1638  	15, // 2: google.partner.aistreams.v1alpha1.Cluster.labels:type_name -> google.partner.aistreams.v1alpha1.Cluster.LabelsEntry
  1639  	0,  // 3: google.partner.aistreams.v1alpha1.ListClustersResponse.clusters:type_name -> google.partner.aistreams.v1alpha1.Cluster
  1640  	0,  // 4: google.partner.aistreams.v1alpha1.CreateClusterRequest.cluster:type_name -> google.partner.aistreams.v1alpha1.Cluster
  1641  	18, // 5: google.partner.aistreams.v1alpha1.UpdateClusterRequest.update_mask:type_name -> google.protobuf.FieldMask
  1642  	0,  // 6: google.partner.aistreams.v1alpha1.UpdateClusterRequest.cluster:type_name -> google.partner.aistreams.v1alpha1.Cluster
  1643  	17, // 7: google.partner.aistreams.v1alpha1.Stream.create_time:type_name -> google.protobuf.Timestamp
  1644  	17, // 8: google.partner.aistreams.v1alpha1.Stream.update_time:type_name -> google.protobuf.Timestamp
  1645  	16, // 9: google.partner.aistreams.v1alpha1.Stream.labels:type_name -> google.partner.aistreams.v1alpha1.Stream.LabelsEntry
  1646  	7,  // 10: google.partner.aistreams.v1alpha1.ListStreamsResponse.streams:type_name -> google.partner.aistreams.v1alpha1.Stream
  1647  	7,  // 11: google.partner.aistreams.v1alpha1.CreateStreamRequest.stream:type_name -> google.partner.aistreams.v1alpha1.Stream
  1648  	18, // 12: google.partner.aistreams.v1alpha1.UpdateStreamRequest.update_mask:type_name -> google.protobuf.FieldMask
  1649  	7,  // 13: google.partner.aistreams.v1alpha1.UpdateStreamRequest.stream:type_name -> google.partner.aistreams.v1alpha1.Stream
  1650  	17, // 14: google.partner.aistreams.v1alpha1.OperationMetadata.create_time:type_name -> google.protobuf.Timestamp
  1651  	17, // 15: google.partner.aistreams.v1alpha1.OperationMetadata.end_time:type_name -> google.protobuf.Timestamp
  1652  	1,  // 16: google.partner.aistreams.v1alpha1.AIStreams.ListClusters:input_type -> google.partner.aistreams.v1alpha1.ListClustersRequest
  1653  	3,  // 17: google.partner.aistreams.v1alpha1.AIStreams.GetCluster:input_type -> google.partner.aistreams.v1alpha1.GetClusterRequest
  1654  	4,  // 18: google.partner.aistreams.v1alpha1.AIStreams.CreateCluster:input_type -> google.partner.aistreams.v1alpha1.CreateClusterRequest
  1655  	5,  // 19: google.partner.aistreams.v1alpha1.AIStreams.UpdateCluster:input_type -> google.partner.aistreams.v1alpha1.UpdateClusterRequest
  1656  	6,  // 20: google.partner.aistreams.v1alpha1.AIStreams.DeleteCluster:input_type -> google.partner.aistreams.v1alpha1.DeleteClusterRequest
  1657  	8,  // 21: google.partner.aistreams.v1alpha1.AIStreams.ListStreams:input_type -> google.partner.aistreams.v1alpha1.ListStreamsRequest
  1658  	10, // 22: google.partner.aistreams.v1alpha1.AIStreams.GetStream:input_type -> google.partner.aistreams.v1alpha1.GetStreamRequest
  1659  	11, // 23: google.partner.aistreams.v1alpha1.AIStreams.CreateStream:input_type -> google.partner.aistreams.v1alpha1.CreateStreamRequest
  1660  	12, // 24: google.partner.aistreams.v1alpha1.AIStreams.UpdateStream:input_type -> google.partner.aistreams.v1alpha1.UpdateStreamRequest
  1661  	13, // 25: google.partner.aistreams.v1alpha1.AIStreams.DeleteStream:input_type -> google.partner.aistreams.v1alpha1.DeleteStreamRequest
  1662  	2,  // 26: google.partner.aistreams.v1alpha1.AIStreams.ListClusters:output_type -> google.partner.aistreams.v1alpha1.ListClustersResponse
  1663  	0,  // 27: google.partner.aistreams.v1alpha1.AIStreams.GetCluster:output_type -> google.partner.aistreams.v1alpha1.Cluster
  1664  	19, // 28: google.partner.aistreams.v1alpha1.AIStreams.CreateCluster:output_type -> google.longrunning.Operation
  1665  	19, // 29: google.partner.aistreams.v1alpha1.AIStreams.UpdateCluster:output_type -> google.longrunning.Operation
  1666  	19, // 30: google.partner.aistreams.v1alpha1.AIStreams.DeleteCluster:output_type -> google.longrunning.Operation
  1667  	9,  // 31: google.partner.aistreams.v1alpha1.AIStreams.ListStreams:output_type -> google.partner.aistreams.v1alpha1.ListStreamsResponse
  1668  	7,  // 32: google.partner.aistreams.v1alpha1.AIStreams.GetStream:output_type -> google.partner.aistreams.v1alpha1.Stream
  1669  	19, // 33: google.partner.aistreams.v1alpha1.AIStreams.CreateStream:output_type -> google.longrunning.Operation
  1670  	19, // 34: google.partner.aistreams.v1alpha1.AIStreams.UpdateStream:output_type -> google.longrunning.Operation
  1671  	19, // 35: google.partner.aistreams.v1alpha1.AIStreams.DeleteStream:output_type -> google.longrunning.Operation
  1672  	26, // [26:36] is the sub-list for method output_type
  1673  	16, // [16:26] is the sub-list for method input_type
  1674  	16, // [16:16] is the sub-list for extension type_name
  1675  	16, // [16:16] is the sub-list for extension extendee
  1676  	0,  // [0:16] is the sub-list for field type_name
  1677  }
  1678  
  1679  func init() { file_google_partner_aistreams_v1alpha1_aistreams_proto_init() }
  1680  func file_google_partner_aistreams_v1alpha1_aistreams_proto_init() {
  1681  	if File_google_partner_aistreams_v1alpha1_aistreams_proto != nil {
  1682  		return
  1683  	}
  1684  	if !protoimpl.UnsafeEnabled {
  1685  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1686  			switch v := v.(*Cluster); i {
  1687  			case 0:
  1688  				return &v.state
  1689  			case 1:
  1690  				return &v.sizeCache
  1691  			case 2:
  1692  				return &v.unknownFields
  1693  			default:
  1694  				return nil
  1695  			}
  1696  		}
  1697  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1698  			switch v := v.(*ListClustersRequest); i {
  1699  			case 0:
  1700  				return &v.state
  1701  			case 1:
  1702  				return &v.sizeCache
  1703  			case 2:
  1704  				return &v.unknownFields
  1705  			default:
  1706  				return nil
  1707  			}
  1708  		}
  1709  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1710  			switch v := v.(*ListClustersResponse); i {
  1711  			case 0:
  1712  				return &v.state
  1713  			case 1:
  1714  				return &v.sizeCache
  1715  			case 2:
  1716  				return &v.unknownFields
  1717  			default:
  1718  				return nil
  1719  			}
  1720  		}
  1721  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1722  			switch v := v.(*GetClusterRequest); i {
  1723  			case 0:
  1724  				return &v.state
  1725  			case 1:
  1726  				return &v.sizeCache
  1727  			case 2:
  1728  				return &v.unknownFields
  1729  			default:
  1730  				return nil
  1731  			}
  1732  		}
  1733  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1734  			switch v := v.(*CreateClusterRequest); i {
  1735  			case 0:
  1736  				return &v.state
  1737  			case 1:
  1738  				return &v.sizeCache
  1739  			case 2:
  1740  				return &v.unknownFields
  1741  			default:
  1742  				return nil
  1743  			}
  1744  		}
  1745  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1746  			switch v := v.(*UpdateClusterRequest); i {
  1747  			case 0:
  1748  				return &v.state
  1749  			case 1:
  1750  				return &v.sizeCache
  1751  			case 2:
  1752  				return &v.unknownFields
  1753  			default:
  1754  				return nil
  1755  			}
  1756  		}
  1757  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1758  			switch v := v.(*DeleteClusterRequest); i {
  1759  			case 0:
  1760  				return &v.state
  1761  			case 1:
  1762  				return &v.sizeCache
  1763  			case 2:
  1764  				return &v.unknownFields
  1765  			default:
  1766  				return nil
  1767  			}
  1768  		}
  1769  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1770  			switch v := v.(*Stream); i {
  1771  			case 0:
  1772  				return &v.state
  1773  			case 1:
  1774  				return &v.sizeCache
  1775  			case 2:
  1776  				return &v.unknownFields
  1777  			default:
  1778  				return nil
  1779  			}
  1780  		}
  1781  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1782  			switch v := v.(*ListStreamsRequest); i {
  1783  			case 0:
  1784  				return &v.state
  1785  			case 1:
  1786  				return &v.sizeCache
  1787  			case 2:
  1788  				return &v.unknownFields
  1789  			default:
  1790  				return nil
  1791  			}
  1792  		}
  1793  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1794  			switch v := v.(*ListStreamsResponse); i {
  1795  			case 0:
  1796  				return &v.state
  1797  			case 1:
  1798  				return &v.sizeCache
  1799  			case 2:
  1800  				return &v.unknownFields
  1801  			default:
  1802  				return nil
  1803  			}
  1804  		}
  1805  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1806  			switch v := v.(*GetStreamRequest); i {
  1807  			case 0:
  1808  				return &v.state
  1809  			case 1:
  1810  				return &v.sizeCache
  1811  			case 2:
  1812  				return &v.unknownFields
  1813  			default:
  1814  				return nil
  1815  			}
  1816  		}
  1817  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1818  			switch v := v.(*CreateStreamRequest); i {
  1819  			case 0:
  1820  				return &v.state
  1821  			case 1:
  1822  				return &v.sizeCache
  1823  			case 2:
  1824  				return &v.unknownFields
  1825  			default:
  1826  				return nil
  1827  			}
  1828  		}
  1829  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1830  			switch v := v.(*UpdateStreamRequest); i {
  1831  			case 0:
  1832  				return &v.state
  1833  			case 1:
  1834  				return &v.sizeCache
  1835  			case 2:
  1836  				return &v.unknownFields
  1837  			default:
  1838  				return nil
  1839  			}
  1840  		}
  1841  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1842  			switch v := v.(*DeleteStreamRequest); i {
  1843  			case 0:
  1844  				return &v.state
  1845  			case 1:
  1846  				return &v.sizeCache
  1847  			case 2:
  1848  				return &v.unknownFields
  1849  			default:
  1850  				return nil
  1851  			}
  1852  		}
  1853  		file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  1854  			switch v := v.(*OperationMetadata); i {
  1855  			case 0:
  1856  				return &v.state
  1857  			case 1:
  1858  				return &v.sizeCache
  1859  			case 2:
  1860  				return &v.unknownFields
  1861  			default:
  1862  				return nil
  1863  			}
  1864  		}
  1865  	}
  1866  	type x struct{}
  1867  	out := protoimpl.TypeBuilder{
  1868  		File: protoimpl.DescBuilder{
  1869  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1870  			RawDescriptor: file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDesc,
  1871  			NumEnums:      0,
  1872  			NumMessages:   17,
  1873  			NumExtensions: 0,
  1874  			NumServices:   1,
  1875  		},
  1876  		GoTypes:           file_google_partner_aistreams_v1alpha1_aistreams_proto_goTypes,
  1877  		DependencyIndexes: file_google_partner_aistreams_v1alpha1_aistreams_proto_depIdxs,
  1878  		MessageInfos:      file_google_partner_aistreams_v1alpha1_aistreams_proto_msgTypes,
  1879  	}.Build()
  1880  	File_google_partner_aistreams_v1alpha1_aistreams_proto = out.File
  1881  	file_google_partner_aistreams_v1alpha1_aistreams_proto_rawDesc = nil
  1882  	file_google_partner_aistreams_v1alpha1_aistreams_proto_goTypes = nil
  1883  	file_google_partner_aistreams_v1alpha1_aistreams_proto_depIdxs = nil
  1884  }
  1885  
  1886  // Reference imports to suppress errors if they are not otherwise used.
  1887  var _ context.Context
  1888  var _ grpc.ClientConnInterface
  1889  
  1890  // This is a compile-time assertion to ensure that this generated file
  1891  // is compatible with the grpc package it is being compiled against.
  1892  const _ = grpc.SupportPackageIsVersion6
  1893  
  1894  // AIStreamsClient is the client API for AIStreams service.
  1895  //
  1896  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1897  type AIStreamsClient interface {
  1898  	// Lists Clusters in a given project and location.
  1899  	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
  1900  	// Gets details of a single Cluster.
  1901  	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
  1902  	// Creates a new Cluster in a given project and location.
  1903  	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1904  	// Updates the parameters of a single Cluster.
  1905  	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1906  	// Deletes a single Cluster.
  1907  	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1908  	// Lists Streams in a given project, location and cluster.
  1909  	ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
  1910  	// Gets details of a single Stream.
  1911  	GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error)
  1912  	// Creates a new Stream in a given project and location.
  1913  	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1914  	// Updates the parameters of a single Stream.
  1915  	UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1916  	// Deletes a single Stream.
  1917  	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
  1918  }
  1919  
  1920  type aIStreamsClient struct {
  1921  	cc grpc.ClientConnInterface
  1922  }
  1923  
  1924  func NewAIStreamsClient(cc grpc.ClientConnInterface) AIStreamsClient {
  1925  	return &aIStreamsClient{cc}
  1926  }
  1927  
  1928  func (c *aIStreamsClient) ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) {
  1929  	out := new(ListClustersResponse)
  1930  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/ListClusters", in, out, opts...)
  1931  	if err != nil {
  1932  		return nil, err
  1933  	}
  1934  	return out, nil
  1935  }
  1936  
  1937  func (c *aIStreamsClient) GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) {
  1938  	out := new(Cluster)
  1939  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/GetCluster", in, out, opts...)
  1940  	if err != nil {
  1941  		return nil, err
  1942  	}
  1943  	return out, nil
  1944  }
  1945  
  1946  func (c *aIStreamsClient) CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  1947  	out := new(longrunningpb.Operation)
  1948  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/CreateCluster", in, out, opts...)
  1949  	if err != nil {
  1950  		return nil, err
  1951  	}
  1952  	return out, nil
  1953  }
  1954  
  1955  func (c *aIStreamsClient) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  1956  	out := new(longrunningpb.Operation)
  1957  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/UpdateCluster", in, out, opts...)
  1958  	if err != nil {
  1959  		return nil, err
  1960  	}
  1961  	return out, nil
  1962  }
  1963  
  1964  func (c *aIStreamsClient) DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  1965  	out := new(longrunningpb.Operation)
  1966  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/DeleteCluster", in, out, opts...)
  1967  	if err != nil {
  1968  		return nil, err
  1969  	}
  1970  	return out, nil
  1971  }
  1972  
  1973  func (c *aIStreamsClient) ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error) {
  1974  	out := new(ListStreamsResponse)
  1975  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/ListStreams", in, out, opts...)
  1976  	if err != nil {
  1977  		return nil, err
  1978  	}
  1979  	return out, nil
  1980  }
  1981  
  1982  func (c *aIStreamsClient) GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error) {
  1983  	out := new(Stream)
  1984  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/GetStream", in, out, opts...)
  1985  	if err != nil {
  1986  		return nil, err
  1987  	}
  1988  	return out, nil
  1989  }
  1990  
  1991  func (c *aIStreamsClient) CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  1992  	out := new(longrunningpb.Operation)
  1993  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/CreateStream", in, out, opts...)
  1994  	if err != nil {
  1995  		return nil, err
  1996  	}
  1997  	return out, nil
  1998  }
  1999  
  2000  func (c *aIStreamsClient) UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  2001  	out := new(longrunningpb.Operation)
  2002  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/UpdateStream", in, out, opts...)
  2003  	if err != nil {
  2004  		return nil, err
  2005  	}
  2006  	return out, nil
  2007  }
  2008  
  2009  func (c *aIStreamsClient) DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
  2010  	out := new(longrunningpb.Operation)
  2011  	err := c.cc.Invoke(ctx, "/google.partner.aistreams.v1alpha1.AIStreams/DeleteStream", in, out, opts...)
  2012  	if err != nil {
  2013  		return nil, err
  2014  	}
  2015  	return out, nil
  2016  }
  2017  
  2018  // AIStreamsServer is the server API for AIStreams service.
  2019  type AIStreamsServer interface {
  2020  	// Lists Clusters in a given project and location.
  2021  	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
  2022  	// Gets details of a single Cluster.
  2023  	GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
  2024  	// Creates a new Cluster in a given project and location.
  2025  	CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
  2026  	// Updates the parameters of a single Cluster.
  2027  	UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
  2028  	// Deletes a single Cluster.
  2029  	DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
  2030  	// Lists Streams in a given project, location and cluster.
  2031  	ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
  2032  	// Gets details of a single Stream.
  2033  	GetStream(context.Context, *GetStreamRequest) (*Stream, error)
  2034  	// Creates a new Stream in a given project and location.
  2035  	CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)
  2036  	// Updates the parameters of a single Stream.
  2037  	UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)
  2038  	// Deletes a single Stream.
  2039  	DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)
  2040  }
  2041  
  2042  // UnimplementedAIStreamsServer can be embedded to have forward compatible implementations.
  2043  type UnimplementedAIStreamsServer struct {
  2044  }
  2045  
  2046  func (*UnimplementedAIStreamsServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error) {
  2047  	return nil, status.Errorf(codes.Unimplemented, "method ListClusters not implemented")
  2048  }
  2049  func (*UnimplementedAIStreamsServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error) {
  2050  	return nil, status.Errorf(codes.Unimplemented, "method GetCluster not implemented")
  2051  }
  2052  func (*UnimplementedAIStreamsServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error) {
  2053  	return nil, status.Errorf(codes.Unimplemented, "method CreateCluster not implemented")
  2054  }
  2055  func (*UnimplementedAIStreamsServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error) {
  2056  	return nil, status.Errorf(codes.Unimplemented, "method UpdateCluster not implemented")
  2057  }
  2058  func (*UnimplementedAIStreamsServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error) {
  2059  	return nil, status.Errorf(codes.Unimplemented, "method DeleteCluster not implemented")
  2060  }
  2061  func (*UnimplementedAIStreamsServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error) {
  2062  	return nil, status.Errorf(codes.Unimplemented, "method ListStreams not implemented")
  2063  }
  2064  func (*UnimplementedAIStreamsServer) GetStream(context.Context, *GetStreamRequest) (*Stream, error) {
  2065  	return nil, status.Errorf(codes.Unimplemented, "method GetStream not implemented")
  2066  }
  2067  func (*UnimplementedAIStreamsServer) CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error) {
  2068  	return nil, status.Errorf(codes.Unimplemented, "method CreateStream not implemented")
  2069  }
  2070  func (*UnimplementedAIStreamsServer) UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error) {
  2071  	return nil, status.Errorf(codes.Unimplemented, "method UpdateStream not implemented")
  2072  }
  2073  func (*UnimplementedAIStreamsServer) DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error) {
  2074  	return nil, status.Errorf(codes.Unimplemented, "method DeleteStream not implemented")
  2075  }
  2076  
  2077  func RegisterAIStreamsServer(s *grpc.Server, srv AIStreamsServer) {
  2078  	s.RegisterService(&_AIStreams_serviceDesc, srv)
  2079  }
  2080  
  2081  func _AIStreams_ListClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2082  	in := new(ListClustersRequest)
  2083  	if err := dec(in); err != nil {
  2084  		return nil, err
  2085  	}
  2086  	if interceptor == nil {
  2087  		return srv.(AIStreamsServer).ListClusters(ctx, in)
  2088  	}
  2089  	info := &grpc.UnaryServerInfo{
  2090  		Server:     srv,
  2091  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/ListClusters",
  2092  	}
  2093  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2094  		return srv.(AIStreamsServer).ListClusters(ctx, req.(*ListClustersRequest))
  2095  	}
  2096  	return interceptor(ctx, in, info, handler)
  2097  }
  2098  
  2099  func _AIStreams_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2100  	in := new(GetClusterRequest)
  2101  	if err := dec(in); err != nil {
  2102  		return nil, err
  2103  	}
  2104  	if interceptor == nil {
  2105  		return srv.(AIStreamsServer).GetCluster(ctx, in)
  2106  	}
  2107  	info := &grpc.UnaryServerInfo{
  2108  		Server:     srv,
  2109  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/GetCluster",
  2110  	}
  2111  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2112  		return srv.(AIStreamsServer).GetCluster(ctx, req.(*GetClusterRequest))
  2113  	}
  2114  	return interceptor(ctx, in, info, handler)
  2115  }
  2116  
  2117  func _AIStreams_CreateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2118  	in := new(CreateClusterRequest)
  2119  	if err := dec(in); err != nil {
  2120  		return nil, err
  2121  	}
  2122  	if interceptor == nil {
  2123  		return srv.(AIStreamsServer).CreateCluster(ctx, in)
  2124  	}
  2125  	info := &grpc.UnaryServerInfo{
  2126  		Server:     srv,
  2127  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/CreateCluster",
  2128  	}
  2129  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2130  		return srv.(AIStreamsServer).CreateCluster(ctx, req.(*CreateClusterRequest))
  2131  	}
  2132  	return interceptor(ctx, in, info, handler)
  2133  }
  2134  
  2135  func _AIStreams_UpdateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2136  	in := new(UpdateClusterRequest)
  2137  	if err := dec(in); err != nil {
  2138  		return nil, err
  2139  	}
  2140  	if interceptor == nil {
  2141  		return srv.(AIStreamsServer).UpdateCluster(ctx, in)
  2142  	}
  2143  	info := &grpc.UnaryServerInfo{
  2144  		Server:     srv,
  2145  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/UpdateCluster",
  2146  	}
  2147  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2148  		return srv.(AIStreamsServer).UpdateCluster(ctx, req.(*UpdateClusterRequest))
  2149  	}
  2150  	return interceptor(ctx, in, info, handler)
  2151  }
  2152  
  2153  func _AIStreams_DeleteCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2154  	in := new(DeleteClusterRequest)
  2155  	if err := dec(in); err != nil {
  2156  		return nil, err
  2157  	}
  2158  	if interceptor == nil {
  2159  		return srv.(AIStreamsServer).DeleteCluster(ctx, in)
  2160  	}
  2161  	info := &grpc.UnaryServerInfo{
  2162  		Server:     srv,
  2163  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/DeleteCluster",
  2164  	}
  2165  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2166  		return srv.(AIStreamsServer).DeleteCluster(ctx, req.(*DeleteClusterRequest))
  2167  	}
  2168  	return interceptor(ctx, in, info, handler)
  2169  }
  2170  
  2171  func _AIStreams_ListStreams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2172  	in := new(ListStreamsRequest)
  2173  	if err := dec(in); err != nil {
  2174  		return nil, err
  2175  	}
  2176  	if interceptor == nil {
  2177  		return srv.(AIStreamsServer).ListStreams(ctx, in)
  2178  	}
  2179  	info := &grpc.UnaryServerInfo{
  2180  		Server:     srv,
  2181  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/ListStreams",
  2182  	}
  2183  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2184  		return srv.(AIStreamsServer).ListStreams(ctx, req.(*ListStreamsRequest))
  2185  	}
  2186  	return interceptor(ctx, in, info, handler)
  2187  }
  2188  
  2189  func _AIStreams_GetStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2190  	in := new(GetStreamRequest)
  2191  	if err := dec(in); err != nil {
  2192  		return nil, err
  2193  	}
  2194  	if interceptor == nil {
  2195  		return srv.(AIStreamsServer).GetStream(ctx, in)
  2196  	}
  2197  	info := &grpc.UnaryServerInfo{
  2198  		Server:     srv,
  2199  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/GetStream",
  2200  	}
  2201  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2202  		return srv.(AIStreamsServer).GetStream(ctx, req.(*GetStreamRequest))
  2203  	}
  2204  	return interceptor(ctx, in, info, handler)
  2205  }
  2206  
  2207  func _AIStreams_CreateStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2208  	in := new(CreateStreamRequest)
  2209  	if err := dec(in); err != nil {
  2210  		return nil, err
  2211  	}
  2212  	if interceptor == nil {
  2213  		return srv.(AIStreamsServer).CreateStream(ctx, in)
  2214  	}
  2215  	info := &grpc.UnaryServerInfo{
  2216  		Server:     srv,
  2217  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/CreateStream",
  2218  	}
  2219  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2220  		return srv.(AIStreamsServer).CreateStream(ctx, req.(*CreateStreamRequest))
  2221  	}
  2222  	return interceptor(ctx, in, info, handler)
  2223  }
  2224  
  2225  func _AIStreams_UpdateStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2226  	in := new(UpdateStreamRequest)
  2227  	if err := dec(in); err != nil {
  2228  		return nil, err
  2229  	}
  2230  	if interceptor == nil {
  2231  		return srv.(AIStreamsServer).UpdateStream(ctx, in)
  2232  	}
  2233  	info := &grpc.UnaryServerInfo{
  2234  		Server:     srv,
  2235  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/UpdateStream",
  2236  	}
  2237  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2238  		return srv.(AIStreamsServer).UpdateStream(ctx, req.(*UpdateStreamRequest))
  2239  	}
  2240  	return interceptor(ctx, in, info, handler)
  2241  }
  2242  
  2243  func _AIStreams_DeleteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2244  	in := new(DeleteStreamRequest)
  2245  	if err := dec(in); err != nil {
  2246  		return nil, err
  2247  	}
  2248  	if interceptor == nil {
  2249  		return srv.(AIStreamsServer).DeleteStream(ctx, in)
  2250  	}
  2251  	info := &grpc.UnaryServerInfo{
  2252  		Server:     srv,
  2253  		FullMethod: "/google.partner.aistreams.v1alpha1.AIStreams/DeleteStream",
  2254  	}
  2255  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2256  		return srv.(AIStreamsServer).DeleteStream(ctx, req.(*DeleteStreamRequest))
  2257  	}
  2258  	return interceptor(ctx, in, info, handler)
  2259  }
  2260  
  2261  var _AIStreams_serviceDesc = grpc.ServiceDesc{
  2262  	ServiceName: "google.partner.aistreams.v1alpha1.AIStreams",
  2263  	HandlerType: (*AIStreamsServer)(nil),
  2264  	Methods: []grpc.MethodDesc{
  2265  		{
  2266  			MethodName: "ListClusters",
  2267  			Handler:    _AIStreams_ListClusters_Handler,
  2268  		},
  2269  		{
  2270  			MethodName: "GetCluster",
  2271  			Handler:    _AIStreams_GetCluster_Handler,
  2272  		},
  2273  		{
  2274  			MethodName: "CreateCluster",
  2275  			Handler:    _AIStreams_CreateCluster_Handler,
  2276  		},
  2277  		{
  2278  			MethodName: "UpdateCluster",
  2279  			Handler:    _AIStreams_UpdateCluster_Handler,
  2280  		},
  2281  		{
  2282  			MethodName: "DeleteCluster",
  2283  			Handler:    _AIStreams_DeleteCluster_Handler,
  2284  		},
  2285  		{
  2286  			MethodName: "ListStreams",
  2287  			Handler:    _AIStreams_ListStreams_Handler,
  2288  		},
  2289  		{
  2290  			MethodName: "GetStream",
  2291  			Handler:    _AIStreams_GetStream_Handler,
  2292  		},
  2293  		{
  2294  			MethodName: "CreateStream",
  2295  			Handler:    _AIStreams_CreateStream_Handler,
  2296  		},
  2297  		{
  2298  			MethodName: "UpdateStream",
  2299  			Handler:    _AIStreams_UpdateStream_Handler,
  2300  		},
  2301  		{
  2302  			MethodName: "DeleteStream",
  2303  			Handler:    _AIStreams_DeleteStream_Handler,
  2304  		},
  2305  	},
  2306  	Streams:  []grpc.StreamDesc{},
  2307  	Metadata: "google/partner/aistreams/v1alpha1/aistreams.proto",
  2308  }
  2309  

View as plain text