Source file src/cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb/storage.pb.go

Documentation: cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb

     1  // Copyright 2023 Google LLC
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.32.0
    18  // 	protoc        v4.25.2
    19  // source: google/cloud/bigquery/storage/v1beta2/storage.proto
    20  
    21  package storagepb
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	_ "google.golang.org/genproto/googleapis/api/annotations"
    29  	status "google.golang.org/genproto/googleapis/rpc/status"
    30  	grpc "google.golang.org/grpc"
    31  	codes "google.golang.org/grpc/codes"
    32  	status1 "google.golang.org/grpc/status"
    33  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    34  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    35  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    36  	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
    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  // Error code for `StorageError`.
    47  type StorageError_StorageErrorCode int32
    48  
    49  const (
    50  	// Default error.
    51  	StorageError_STORAGE_ERROR_CODE_UNSPECIFIED StorageError_StorageErrorCode = 0
    52  	// Table is not found in the system.
    53  	StorageError_TABLE_NOT_FOUND StorageError_StorageErrorCode = 1
    54  	// Stream is already committed.
    55  	StorageError_STREAM_ALREADY_COMMITTED StorageError_StorageErrorCode = 2
    56  	// Stream is not found.
    57  	StorageError_STREAM_NOT_FOUND StorageError_StorageErrorCode = 3
    58  	// Invalid Stream type.
    59  	// For example, you try to commit a stream that is not pending.
    60  	StorageError_INVALID_STREAM_TYPE StorageError_StorageErrorCode = 4
    61  	// Invalid Stream state.
    62  	// For example, you try to commit a stream that is not finalized or is
    63  	// garbaged.
    64  	StorageError_INVALID_STREAM_STATE StorageError_StorageErrorCode = 5
    65  	// Stream is finalized.
    66  	StorageError_STREAM_FINALIZED StorageError_StorageErrorCode = 6
    67  )
    68  
    69  // Enum value maps for StorageError_StorageErrorCode.
    70  var (
    71  	StorageError_StorageErrorCode_name = map[int32]string{
    72  		0: "STORAGE_ERROR_CODE_UNSPECIFIED",
    73  		1: "TABLE_NOT_FOUND",
    74  		2: "STREAM_ALREADY_COMMITTED",
    75  		3: "STREAM_NOT_FOUND",
    76  		4: "INVALID_STREAM_TYPE",
    77  		5: "INVALID_STREAM_STATE",
    78  		6: "STREAM_FINALIZED",
    79  	}
    80  	StorageError_StorageErrorCode_value = map[string]int32{
    81  		"STORAGE_ERROR_CODE_UNSPECIFIED": 0,
    82  		"TABLE_NOT_FOUND":                1,
    83  		"STREAM_ALREADY_COMMITTED":       2,
    84  		"STREAM_NOT_FOUND":               3,
    85  		"INVALID_STREAM_TYPE":            4,
    86  		"INVALID_STREAM_STATE":           5,
    87  		"STREAM_FINALIZED":               6,
    88  	}
    89  )
    90  
    91  func (x StorageError_StorageErrorCode) Enum() *StorageError_StorageErrorCode {
    92  	p := new(StorageError_StorageErrorCode)
    93  	*p = x
    94  	return p
    95  }
    96  
    97  func (x StorageError_StorageErrorCode) String() string {
    98  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    99  }
   100  
   101  func (StorageError_StorageErrorCode) Descriptor() protoreflect.EnumDescriptor {
   102  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes[0].Descriptor()
   103  }
   104  
   105  func (StorageError_StorageErrorCode) Type() protoreflect.EnumType {
   106  	return &file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes[0]
   107  }
   108  
   109  func (x StorageError_StorageErrorCode) Number() protoreflect.EnumNumber {
   110  	return protoreflect.EnumNumber(x)
   111  }
   112  
   113  // Deprecated: Use StorageError_StorageErrorCode.Descriptor instead.
   114  func (StorageError_StorageErrorCode) EnumDescriptor() ([]byte, []int) {
   115  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{17, 0}
   116  }
   117  
   118  // Request message for `CreateReadSession`.
   119  type CreateReadSessionRequest struct {
   120  	state         protoimpl.MessageState
   121  	sizeCache     protoimpl.SizeCache
   122  	unknownFields protoimpl.UnknownFields
   123  
   124  	// Required. The request project that owns the session, in the form of
   125  	// `projects/{project_id}`.
   126  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   127  	// Required. Session to be created.
   128  	ReadSession *ReadSession `protobuf:"bytes,2,opt,name=read_session,json=readSession,proto3" json:"read_session,omitempty"`
   129  	// Max initial number of streams. If unset or zero, the server will
   130  	// provide a value of streams so as to produce reasonable throughput. Must be
   131  	// non-negative. The number of streams may be lower than the requested number,
   132  	// depending on the amount parallelism that is reasonable for the table. Error
   133  	// will be returned if the max count is greater than the current system
   134  	// max limit of 1,000.
   135  	//
   136  	// Streams must be read starting from offset 0.
   137  	MaxStreamCount int32 `protobuf:"varint,3,opt,name=max_stream_count,json=maxStreamCount,proto3" json:"max_stream_count,omitempty"`
   138  }
   139  
   140  func (x *CreateReadSessionRequest) Reset() {
   141  	*x = CreateReadSessionRequest{}
   142  	if protoimpl.UnsafeEnabled {
   143  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[0]
   144  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   145  		ms.StoreMessageInfo(mi)
   146  	}
   147  }
   148  
   149  func (x *CreateReadSessionRequest) String() string {
   150  	return protoimpl.X.MessageStringOf(x)
   151  }
   152  
   153  func (*CreateReadSessionRequest) ProtoMessage() {}
   154  
   155  func (x *CreateReadSessionRequest) ProtoReflect() protoreflect.Message {
   156  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[0]
   157  	if protoimpl.UnsafeEnabled && x != nil {
   158  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   159  		if ms.LoadMessageInfo() == nil {
   160  			ms.StoreMessageInfo(mi)
   161  		}
   162  		return ms
   163  	}
   164  	return mi.MessageOf(x)
   165  }
   166  
   167  // Deprecated: Use CreateReadSessionRequest.ProtoReflect.Descriptor instead.
   168  func (*CreateReadSessionRequest) Descriptor() ([]byte, []int) {
   169  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{0}
   170  }
   171  
   172  func (x *CreateReadSessionRequest) GetParent() string {
   173  	if x != nil {
   174  		return x.Parent
   175  	}
   176  	return ""
   177  }
   178  
   179  func (x *CreateReadSessionRequest) GetReadSession() *ReadSession {
   180  	if x != nil {
   181  		return x.ReadSession
   182  	}
   183  	return nil
   184  }
   185  
   186  func (x *CreateReadSessionRequest) GetMaxStreamCount() int32 {
   187  	if x != nil {
   188  		return x.MaxStreamCount
   189  	}
   190  	return 0
   191  }
   192  
   193  // Request message for `ReadRows`.
   194  type ReadRowsRequest struct {
   195  	state         protoimpl.MessageState
   196  	sizeCache     protoimpl.SizeCache
   197  	unknownFields protoimpl.UnknownFields
   198  
   199  	// Required. Stream to read rows from.
   200  	ReadStream string `protobuf:"bytes,1,opt,name=read_stream,json=readStream,proto3" json:"read_stream,omitempty"`
   201  	// The offset requested must be less than the last row read from Read.
   202  	// Requesting a larger offset is undefined. If not specified, start reading
   203  	// from offset zero.
   204  	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
   205  }
   206  
   207  func (x *ReadRowsRequest) Reset() {
   208  	*x = ReadRowsRequest{}
   209  	if protoimpl.UnsafeEnabled {
   210  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[1]
   211  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   212  		ms.StoreMessageInfo(mi)
   213  	}
   214  }
   215  
   216  func (x *ReadRowsRequest) String() string {
   217  	return protoimpl.X.MessageStringOf(x)
   218  }
   219  
   220  func (*ReadRowsRequest) ProtoMessage() {}
   221  
   222  func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message {
   223  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[1]
   224  	if protoimpl.UnsafeEnabled && x != nil {
   225  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   226  		if ms.LoadMessageInfo() == nil {
   227  			ms.StoreMessageInfo(mi)
   228  		}
   229  		return ms
   230  	}
   231  	return mi.MessageOf(x)
   232  }
   233  
   234  // Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.
   235  func (*ReadRowsRequest) Descriptor() ([]byte, []int) {
   236  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{1}
   237  }
   238  
   239  func (x *ReadRowsRequest) GetReadStream() string {
   240  	if x != nil {
   241  		return x.ReadStream
   242  	}
   243  	return ""
   244  }
   245  
   246  func (x *ReadRowsRequest) GetOffset() int64 {
   247  	if x != nil {
   248  		return x.Offset
   249  	}
   250  	return 0
   251  }
   252  
   253  // Information on if the current connection is being throttled.
   254  type ThrottleState struct {
   255  	state         protoimpl.MessageState
   256  	sizeCache     protoimpl.SizeCache
   257  	unknownFields protoimpl.UnknownFields
   258  
   259  	// How much this connection is being throttled. Zero means no throttling,
   260  	// 100 means fully throttled.
   261  	ThrottlePercent int32 `protobuf:"varint,1,opt,name=throttle_percent,json=throttlePercent,proto3" json:"throttle_percent,omitempty"`
   262  }
   263  
   264  func (x *ThrottleState) Reset() {
   265  	*x = ThrottleState{}
   266  	if protoimpl.UnsafeEnabled {
   267  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[2]
   268  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   269  		ms.StoreMessageInfo(mi)
   270  	}
   271  }
   272  
   273  func (x *ThrottleState) String() string {
   274  	return protoimpl.X.MessageStringOf(x)
   275  }
   276  
   277  func (*ThrottleState) ProtoMessage() {}
   278  
   279  func (x *ThrottleState) ProtoReflect() protoreflect.Message {
   280  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[2]
   281  	if protoimpl.UnsafeEnabled && x != nil {
   282  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   283  		if ms.LoadMessageInfo() == nil {
   284  			ms.StoreMessageInfo(mi)
   285  		}
   286  		return ms
   287  	}
   288  	return mi.MessageOf(x)
   289  }
   290  
   291  // Deprecated: Use ThrottleState.ProtoReflect.Descriptor instead.
   292  func (*ThrottleState) Descriptor() ([]byte, []int) {
   293  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{2}
   294  }
   295  
   296  func (x *ThrottleState) GetThrottlePercent() int32 {
   297  	if x != nil {
   298  		return x.ThrottlePercent
   299  	}
   300  	return 0
   301  }
   302  
   303  // Estimated stream statistics for a given Stream.
   304  type StreamStats struct {
   305  	state         protoimpl.MessageState
   306  	sizeCache     protoimpl.SizeCache
   307  	unknownFields protoimpl.UnknownFields
   308  
   309  	// Represents the progress of the current stream.
   310  	Progress *StreamStats_Progress `protobuf:"bytes,2,opt,name=progress,proto3" json:"progress,omitempty"`
   311  }
   312  
   313  func (x *StreamStats) Reset() {
   314  	*x = StreamStats{}
   315  	if protoimpl.UnsafeEnabled {
   316  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[3]
   317  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   318  		ms.StoreMessageInfo(mi)
   319  	}
   320  }
   321  
   322  func (x *StreamStats) String() string {
   323  	return protoimpl.X.MessageStringOf(x)
   324  }
   325  
   326  func (*StreamStats) ProtoMessage() {}
   327  
   328  func (x *StreamStats) ProtoReflect() protoreflect.Message {
   329  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[3]
   330  	if protoimpl.UnsafeEnabled && x != nil {
   331  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   332  		if ms.LoadMessageInfo() == nil {
   333  			ms.StoreMessageInfo(mi)
   334  		}
   335  		return ms
   336  	}
   337  	return mi.MessageOf(x)
   338  }
   339  
   340  // Deprecated: Use StreamStats.ProtoReflect.Descriptor instead.
   341  func (*StreamStats) Descriptor() ([]byte, []int) {
   342  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{3}
   343  }
   344  
   345  func (x *StreamStats) GetProgress() *StreamStats_Progress {
   346  	if x != nil {
   347  		return x.Progress
   348  	}
   349  	return nil
   350  }
   351  
   352  // Response from calling `ReadRows` may include row data, progress and
   353  // throttling information.
   354  type ReadRowsResponse struct {
   355  	state         protoimpl.MessageState
   356  	sizeCache     protoimpl.SizeCache
   357  	unknownFields protoimpl.UnknownFields
   358  
   359  	// Row data is returned in format specified during session creation.
   360  	//
   361  	// Types that are assignable to Rows:
   362  	//
   363  	//	*ReadRowsResponse_AvroRows
   364  	//	*ReadRowsResponse_ArrowRecordBatch
   365  	Rows isReadRowsResponse_Rows `protobuf_oneof:"rows"`
   366  	// Number of serialized rows in the rows block.
   367  	RowCount int64 `protobuf:"varint,6,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
   368  	// Statistics for the stream.
   369  	Stats *StreamStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
   370  	// Throttling state. If unset, the latest response still describes
   371  	// the current throttling status.
   372  	ThrottleState *ThrottleState `protobuf:"bytes,5,opt,name=throttle_state,json=throttleState,proto3" json:"throttle_state,omitempty"`
   373  	// The schema for the read. If read_options.selected_fields is set, the
   374  	// schema may be different from the table schema as it will only contain
   375  	// the selected fields. This schema is equivalent to the one returned by
   376  	// CreateSession. This field is only populated in the first ReadRowsResponse
   377  	// RPC.
   378  	//
   379  	// Types that are assignable to Schema:
   380  	//
   381  	//	*ReadRowsResponse_AvroSchema
   382  	//	*ReadRowsResponse_ArrowSchema
   383  	Schema isReadRowsResponse_Schema `protobuf_oneof:"schema"`
   384  }
   385  
   386  func (x *ReadRowsResponse) Reset() {
   387  	*x = ReadRowsResponse{}
   388  	if protoimpl.UnsafeEnabled {
   389  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4]
   390  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   391  		ms.StoreMessageInfo(mi)
   392  	}
   393  }
   394  
   395  func (x *ReadRowsResponse) String() string {
   396  	return protoimpl.X.MessageStringOf(x)
   397  }
   398  
   399  func (*ReadRowsResponse) ProtoMessage() {}
   400  
   401  func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message {
   402  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4]
   403  	if protoimpl.UnsafeEnabled && x != nil {
   404  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   405  		if ms.LoadMessageInfo() == nil {
   406  			ms.StoreMessageInfo(mi)
   407  		}
   408  		return ms
   409  	}
   410  	return mi.MessageOf(x)
   411  }
   412  
   413  // Deprecated: Use ReadRowsResponse.ProtoReflect.Descriptor instead.
   414  func (*ReadRowsResponse) Descriptor() ([]byte, []int) {
   415  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{4}
   416  }
   417  
   418  func (m *ReadRowsResponse) GetRows() isReadRowsResponse_Rows {
   419  	if m != nil {
   420  		return m.Rows
   421  	}
   422  	return nil
   423  }
   424  
   425  func (x *ReadRowsResponse) GetAvroRows() *AvroRows {
   426  	if x, ok := x.GetRows().(*ReadRowsResponse_AvroRows); ok {
   427  		return x.AvroRows
   428  	}
   429  	return nil
   430  }
   431  
   432  func (x *ReadRowsResponse) GetArrowRecordBatch() *ArrowRecordBatch {
   433  	if x, ok := x.GetRows().(*ReadRowsResponse_ArrowRecordBatch); ok {
   434  		return x.ArrowRecordBatch
   435  	}
   436  	return nil
   437  }
   438  
   439  func (x *ReadRowsResponse) GetRowCount() int64 {
   440  	if x != nil {
   441  		return x.RowCount
   442  	}
   443  	return 0
   444  }
   445  
   446  func (x *ReadRowsResponse) GetStats() *StreamStats {
   447  	if x != nil {
   448  		return x.Stats
   449  	}
   450  	return nil
   451  }
   452  
   453  func (x *ReadRowsResponse) GetThrottleState() *ThrottleState {
   454  	if x != nil {
   455  		return x.ThrottleState
   456  	}
   457  	return nil
   458  }
   459  
   460  func (m *ReadRowsResponse) GetSchema() isReadRowsResponse_Schema {
   461  	if m != nil {
   462  		return m.Schema
   463  	}
   464  	return nil
   465  }
   466  
   467  func (x *ReadRowsResponse) GetAvroSchema() *AvroSchema {
   468  	if x, ok := x.GetSchema().(*ReadRowsResponse_AvroSchema); ok {
   469  		return x.AvroSchema
   470  	}
   471  	return nil
   472  }
   473  
   474  func (x *ReadRowsResponse) GetArrowSchema() *ArrowSchema {
   475  	if x, ok := x.GetSchema().(*ReadRowsResponse_ArrowSchema); ok {
   476  		return x.ArrowSchema
   477  	}
   478  	return nil
   479  }
   480  
   481  type isReadRowsResponse_Rows interface {
   482  	isReadRowsResponse_Rows()
   483  }
   484  
   485  type ReadRowsResponse_AvroRows struct {
   486  	// Serialized row data in AVRO format.
   487  	AvroRows *AvroRows `protobuf:"bytes,3,opt,name=avro_rows,json=avroRows,proto3,oneof"`
   488  }
   489  
   490  type ReadRowsResponse_ArrowRecordBatch struct {
   491  	// Serialized row data in Arrow RecordBatch format.
   492  	ArrowRecordBatch *ArrowRecordBatch `protobuf:"bytes,4,opt,name=arrow_record_batch,json=arrowRecordBatch,proto3,oneof"`
   493  }
   494  
   495  func (*ReadRowsResponse_AvroRows) isReadRowsResponse_Rows() {}
   496  
   497  func (*ReadRowsResponse_ArrowRecordBatch) isReadRowsResponse_Rows() {}
   498  
   499  type isReadRowsResponse_Schema interface {
   500  	isReadRowsResponse_Schema()
   501  }
   502  
   503  type ReadRowsResponse_AvroSchema struct {
   504  	// Output only. Avro schema.
   505  	AvroSchema *AvroSchema `protobuf:"bytes,7,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
   506  }
   507  
   508  type ReadRowsResponse_ArrowSchema struct {
   509  	// Output only. Arrow schema.
   510  	ArrowSchema *ArrowSchema `protobuf:"bytes,8,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
   511  }
   512  
   513  func (*ReadRowsResponse_AvroSchema) isReadRowsResponse_Schema() {}
   514  
   515  func (*ReadRowsResponse_ArrowSchema) isReadRowsResponse_Schema() {}
   516  
   517  // Request message for `SplitReadStream`.
   518  type SplitReadStreamRequest struct {
   519  	state         protoimpl.MessageState
   520  	sizeCache     protoimpl.SizeCache
   521  	unknownFields protoimpl.UnknownFields
   522  
   523  	// Required. Name of the stream to split.
   524  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   525  	// A value in the range (0.0, 1.0) that specifies the fractional point at
   526  	// which the original stream should be split. The actual split point is
   527  	// evaluated on pre-filtered rows, so if a filter is provided, then there is
   528  	// no guarantee that the division of the rows between the new child streams
   529  	// will be proportional to this fractional value. Additionally, because the
   530  	// server-side unit for assigning data is collections of rows, this fraction
   531  	// will always map to a data storage boundary on the server side.
   532  	Fraction float64 `protobuf:"fixed64,2,opt,name=fraction,proto3" json:"fraction,omitempty"`
   533  }
   534  
   535  func (x *SplitReadStreamRequest) Reset() {
   536  	*x = SplitReadStreamRequest{}
   537  	if protoimpl.UnsafeEnabled {
   538  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[5]
   539  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   540  		ms.StoreMessageInfo(mi)
   541  	}
   542  }
   543  
   544  func (x *SplitReadStreamRequest) String() string {
   545  	return protoimpl.X.MessageStringOf(x)
   546  }
   547  
   548  func (*SplitReadStreamRequest) ProtoMessage() {}
   549  
   550  func (x *SplitReadStreamRequest) ProtoReflect() protoreflect.Message {
   551  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[5]
   552  	if protoimpl.UnsafeEnabled && x != nil {
   553  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   554  		if ms.LoadMessageInfo() == nil {
   555  			ms.StoreMessageInfo(mi)
   556  		}
   557  		return ms
   558  	}
   559  	return mi.MessageOf(x)
   560  }
   561  
   562  // Deprecated: Use SplitReadStreamRequest.ProtoReflect.Descriptor instead.
   563  func (*SplitReadStreamRequest) Descriptor() ([]byte, []int) {
   564  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{5}
   565  }
   566  
   567  func (x *SplitReadStreamRequest) GetName() string {
   568  	if x != nil {
   569  		return x.Name
   570  	}
   571  	return ""
   572  }
   573  
   574  func (x *SplitReadStreamRequest) GetFraction() float64 {
   575  	if x != nil {
   576  		return x.Fraction
   577  	}
   578  	return 0
   579  }
   580  
   581  type SplitReadStreamResponse struct {
   582  	state         protoimpl.MessageState
   583  	sizeCache     protoimpl.SizeCache
   584  	unknownFields protoimpl.UnknownFields
   585  
   586  	// Primary stream, which contains the beginning portion of
   587  	// |original_stream|. An empty value indicates that the original stream can no
   588  	// longer be split.
   589  	PrimaryStream *ReadStream `protobuf:"bytes,1,opt,name=primary_stream,json=primaryStream,proto3" json:"primary_stream,omitempty"`
   590  	// Remainder stream, which contains the tail of |original_stream|. An empty
   591  	// value indicates that the original stream can no longer be split.
   592  	RemainderStream *ReadStream `protobuf:"bytes,2,opt,name=remainder_stream,json=remainderStream,proto3" json:"remainder_stream,omitempty"`
   593  }
   594  
   595  func (x *SplitReadStreamResponse) Reset() {
   596  	*x = SplitReadStreamResponse{}
   597  	if protoimpl.UnsafeEnabled {
   598  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[6]
   599  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   600  		ms.StoreMessageInfo(mi)
   601  	}
   602  }
   603  
   604  func (x *SplitReadStreamResponse) String() string {
   605  	return protoimpl.X.MessageStringOf(x)
   606  }
   607  
   608  func (*SplitReadStreamResponse) ProtoMessage() {}
   609  
   610  func (x *SplitReadStreamResponse) ProtoReflect() protoreflect.Message {
   611  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[6]
   612  	if protoimpl.UnsafeEnabled && x != nil {
   613  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   614  		if ms.LoadMessageInfo() == nil {
   615  			ms.StoreMessageInfo(mi)
   616  		}
   617  		return ms
   618  	}
   619  	return mi.MessageOf(x)
   620  }
   621  
   622  // Deprecated: Use SplitReadStreamResponse.ProtoReflect.Descriptor instead.
   623  func (*SplitReadStreamResponse) Descriptor() ([]byte, []int) {
   624  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{6}
   625  }
   626  
   627  func (x *SplitReadStreamResponse) GetPrimaryStream() *ReadStream {
   628  	if x != nil {
   629  		return x.PrimaryStream
   630  	}
   631  	return nil
   632  }
   633  
   634  func (x *SplitReadStreamResponse) GetRemainderStream() *ReadStream {
   635  	if x != nil {
   636  		return x.RemainderStream
   637  	}
   638  	return nil
   639  }
   640  
   641  // Request message for `CreateWriteStream`.
   642  type CreateWriteStreamRequest struct {
   643  	state         protoimpl.MessageState
   644  	sizeCache     protoimpl.SizeCache
   645  	unknownFields protoimpl.UnknownFields
   646  
   647  	// Required. Reference to the table to which the stream belongs, in the format
   648  	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
   649  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   650  	// Required. Stream to be created.
   651  	WriteStream *WriteStream `protobuf:"bytes,2,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
   652  }
   653  
   654  func (x *CreateWriteStreamRequest) Reset() {
   655  	*x = CreateWriteStreamRequest{}
   656  	if protoimpl.UnsafeEnabled {
   657  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[7]
   658  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   659  		ms.StoreMessageInfo(mi)
   660  	}
   661  }
   662  
   663  func (x *CreateWriteStreamRequest) String() string {
   664  	return protoimpl.X.MessageStringOf(x)
   665  }
   666  
   667  func (*CreateWriteStreamRequest) ProtoMessage() {}
   668  
   669  func (x *CreateWriteStreamRequest) ProtoReflect() protoreflect.Message {
   670  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[7]
   671  	if protoimpl.UnsafeEnabled && x != nil {
   672  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   673  		if ms.LoadMessageInfo() == nil {
   674  			ms.StoreMessageInfo(mi)
   675  		}
   676  		return ms
   677  	}
   678  	return mi.MessageOf(x)
   679  }
   680  
   681  // Deprecated: Use CreateWriteStreamRequest.ProtoReflect.Descriptor instead.
   682  func (*CreateWriteStreamRequest) Descriptor() ([]byte, []int) {
   683  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{7}
   684  }
   685  
   686  func (x *CreateWriteStreamRequest) GetParent() string {
   687  	if x != nil {
   688  		return x.Parent
   689  	}
   690  	return ""
   691  }
   692  
   693  func (x *CreateWriteStreamRequest) GetWriteStream() *WriteStream {
   694  	if x != nil {
   695  		return x.WriteStream
   696  	}
   697  	return nil
   698  }
   699  
   700  // Request message for `AppendRows`.
   701  type AppendRowsRequest struct {
   702  	state         protoimpl.MessageState
   703  	sizeCache     protoimpl.SizeCache
   704  	unknownFields protoimpl.UnknownFields
   705  
   706  	// Required. The stream that is the target of the append operation. This value
   707  	// must be specified for the initial request. If subsequent requests specify
   708  	// the stream name, it must equal to the value provided in the first request.
   709  	// To write to the _default stream, populate this field with a string in the
   710  	// format `projects/{project}/datasets/{dataset}/tables/{table}/_default`.
   711  	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
   712  	// If present, the write is only performed if the next append offset is same
   713  	// as the provided value. If not present, the write is performed at the
   714  	// current end of stream. Specifying a value for this field is not allowed
   715  	// when calling AppendRows for the '_default' stream.
   716  	Offset *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
   717  	// Input rows. The `writer_schema` field must be specified at the initial
   718  	// request and currently, it will be ignored if specified in following
   719  	// requests. Following requests must have data in the same format as the
   720  	// initial request.
   721  	//
   722  	// Types that are assignable to Rows:
   723  	//
   724  	//	*AppendRowsRequest_ProtoRows
   725  	Rows isAppendRowsRequest_Rows `protobuf_oneof:"rows"`
   726  	// Id set by client to annotate its identity. Only initial request setting is
   727  	// respected.
   728  	TraceId string `protobuf:"bytes,6,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
   729  }
   730  
   731  func (x *AppendRowsRequest) Reset() {
   732  	*x = AppendRowsRequest{}
   733  	if protoimpl.UnsafeEnabled {
   734  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8]
   735  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   736  		ms.StoreMessageInfo(mi)
   737  	}
   738  }
   739  
   740  func (x *AppendRowsRequest) String() string {
   741  	return protoimpl.X.MessageStringOf(x)
   742  }
   743  
   744  func (*AppendRowsRequest) ProtoMessage() {}
   745  
   746  func (x *AppendRowsRequest) ProtoReflect() protoreflect.Message {
   747  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8]
   748  	if protoimpl.UnsafeEnabled && x != nil {
   749  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   750  		if ms.LoadMessageInfo() == nil {
   751  			ms.StoreMessageInfo(mi)
   752  		}
   753  		return ms
   754  	}
   755  	return mi.MessageOf(x)
   756  }
   757  
   758  // Deprecated: Use AppendRowsRequest.ProtoReflect.Descriptor instead.
   759  func (*AppendRowsRequest) Descriptor() ([]byte, []int) {
   760  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{8}
   761  }
   762  
   763  func (x *AppendRowsRequest) GetWriteStream() string {
   764  	if x != nil {
   765  		return x.WriteStream
   766  	}
   767  	return ""
   768  }
   769  
   770  func (x *AppendRowsRequest) GetOffset() *wrapperspb.Int64Value {
   771  	if x != nil {
   772  		return x.Offset
   773  	}
   774  	return nil
   775  }
   776  
   777  func (m *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows {
   778  	if m != nil {
   779  		return m.Rows
   780  	}
   781  	return nil
   782  }
   783  
   784  func (x *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData {
   785  	if x, ok := x.GetRows().(*AppendRowsRequest_ProtoRows); ok {
   786  		return x.ProtoRows
   787  	}
   788  	return nil
   789  }
   790  
   791  func (x *AppendRowsRequest) GetTraceId() string {
   792  	if x != nil {
   793  		return x.TraceId
   794  	}
   795  	return ""
   796  }
   797  
   798  type isAppendRowsRequest_Rows interface {
   799  	isAppendRowsRequest_Rows()
   800  }
   801  
   802  type AppendRowsRequest_ProtoRows struct {
   803  	// Rows in proto format.
   804  	ProtoRows *AppendRowsRequest_ProtoData `protobuf:"bytes,4,opt,name=proto_rows,json=protoRows,proto3,oneof"`
   805  }
   806  
   807  func (*AppendRowsRequest_ProtoRows) isAppendRowsRequest_Rows() {}
   808  
   809  // Response message for `AppendRows`.
   810  type AppendRowsResponse struct {
   811  	state         protoimpl.MessageState
   812  	sizeCache     protoimpl.SizeCache
   813  	unknownFields protoimpl.UnknownFields
   814  
   815  	// Types that are assignable to Response:
   816  	//
   817  	//	*AppendRowsResponse_AppendResult_
   818  	//	*AppendRowsResponse_Error
   819  	Response isAppendRowsResponse_Response `protobuf_oneof:"response"`
   820  	// If backend detects a schema update, pass it to user so that user can
   821  	// use it to input new type of message. It will be empty when no schema
   822  	// updates have occurred.
   823  	UpdatedSchema *TableSchema `protobuf:"bytes,3,opt,name=updated_schema,json=updatedSchema,proto3" json:"updated_schema,omitempty"`
   824  }
   825  
   826  func (x *AppendRowsResponse) Reset() {
   827  	*x = AppendRowsResponse{}
   828  	if protoimpl.UnsafeEnabled {
   829  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9]
   830  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   831  		ms.StoreMessageInfo(mi)
   832  	}
   833  }
   834  
   835  func (x *AppendRowsResponse) String() string {
   836  	return protoimpl.X.MessageStringOf(x)
   837  }
   838  
   839  func (*AppendRowsResponse) ProtoMessage() {}
   840  
   841  func (x *AppendRowsResponse) ProtoReflect() protoreflect.Message {
   842  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9]
   843  	if protoimpl.UnsafeEnabled && x != nil {
   844  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   845  		if ms.LoadMessageInfo() == nil {
   846  			ms.StoreMessageInfo(mi)
   847  		}
   848  		return ms
   849  	}
   850  	return mi.MessageOf(x)
   851  }
   852  
   853  // Deprecated: Use AppendRowsResponse.ProtoReflect.Descriptor instead.
   854  func (*AppendRowsResponse) Descriptor() ([]byte, []int) {
   855  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{9}
   856  }
   857  
   858  func (m *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response {
   859  	if m != nil {
   860  		return m.Response
   861  	}
   862  	return nil
   863  }
   864  
   865  func (x *AppendRowsResponse) GetAppendResult() *AppendRowsResponse_AppendResult {
   866  	if x, ok := x.GetResponse().(*AppendRowsResponse_AppendResult_); ok {
   867  		return x.AppendResult
   868  	}
   869  	return nil
   870  }
   871  
   872  func (x *AppendRowsResponse) GetError() *status.Status {
   873  	if x, ok := x.GetResponse().(*AppendRowsResponse_Error); ok {
   874  		return x.Error
   875  	}
   876  	return nil
   877  }
   878  
   879  func (x *AppendRowsResponse) GetUpdatedSchema() *TableSchema {
   880  	if x != nil {
   881  		return x.UpdatedSchema
   882  	}
   883  	return nil
   884  }
   885  
   886  type isAppendRowsResponse_Response interface {
   887  	isAppendRowsResponse_Response()
   888  }
   889  
   890  type AppendRowsResponse_AppendResult_ struct {
   891  	// Result if the append is successful.
   892  	AppendResult *AppendRowsResponse_AppendResult `protobuf:"bytes,1,opt,name=append_result,json=appendResult,proto3,oneof"`
   893  }
   894  
   895  type AppendRowsResponse_Error struct {
   896  	// Error returned when problems were encountered.  If present,
   897  	// it indicates rows were not accepted into the system.
   898  	// Users can retry or continue with other append requests within the
   899  	// same connection.
   900  	//
   901  	// Additional information about error signalling:
   902  	//
   903  	// ALREADY_EXISTS: Happens when an append specified an offset, and the
   904  	// backend already has received data at this offset.  Typically encountered
   905  	// in retry scenarios, and can be ignored.
   906  	//
   907  	// OUT_OF_RANGE: Returned when the specified offset in the stream is beyond
   908  	// the current end of the stream.
   909  	//
   910  	// INVALID_ARGUMENT: Indicates a malformed request or data.
   911  	//
   912  	// ABORTED: Request processing is aborted because of prior failures.  The
   913  	// request can be retried if previous failure is addressed.
   914  	//
   915  	// INTERNAL: Indicates server side error(s) that can be retried.
   916  	Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
   917  }
   918  
   919  func (*AppendRowsResponse_AppendResult_) isAppendRowsResponse_Response() {}
   920  
   921  func (*AppendRowsResponse_Error) isAppendRowsResponse_Response() {}
   922  
   923  // Request message for `GetWriteStreamRequest`.
   924  type GetWriteStreamRequest struct {
   925  	state         protoimpl.MessageState
   926  	sizeCache     protoimpl.SizeCache
   927  	unknownFields protoimpl.UnknownFields
   928  
   929  	// Required. Name of the stream to get, in the form of
   930  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   931  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   932  }
   933  
   934  func (x *GetWriteStreamRequest) Reset() {
   935  	*x = GetWriteStreamRequest{}
   936  	if protoimpl.UnsafeEnabled {
   937  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[10]
   938  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   939  		ms.StoreMessageInfo(mi)
   940  	}
   941  }
   942  
   943  func (x *GetWriteStreamRequest) String() string {
   944  	return protoimpl.X.MessageStringOf(x)
   945  }
   946  
   947  func (*GetWriteStreamRequest) ProtoMessage() {}
   948  
   949  func (x *GetWriteStreamRequest) ProtoReflect() protoreflect.Message {
   950  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[10]
   951  	if protoimpl.UnsafeEnabled && x != nil {
   952  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   953  		if ms.LoadMessageInfo() == nil {
   954  			ms.StoreMessageInfo(mi)
   955  		}
   956  		return ms
   957  	}
   958  	return mi.MessageOf(x)
   959  }
   960  
   961  // Deprecated: Use GetWriteStreamRequest.ProtoReflect.Descriptor instead.
   962  func (*GetWriteStreamRequest) Descriptor() ([]byte, []int) {
   963  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{10}
   964  }
   965  
   966  func (x *GetWriteStreamRequest) GetName() string {
   967  	if x != nil {
   968  		return x.Name
   969  	}
   970  	return ""
   971  }
   972  
   973  // Request message for `BatchCommitWriteStreams`.
   974  type BatchCommitWriteStreamsRequest struct {
   975  	state         protoimpl.MessageState
   976  	sizeCache     protoimpl.SizeCache
   977  	unknownFields protoimpl.UnknownFields
   978  
   979  	// Required. Parent table that all the streams should belong to, in the form
   980  	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
   981  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   982  	// Required. The group of streams that will be committed atomically.
   983  	WriteStreams []string `protobuf:"bytes,2,rep,name=write_streams,json=writeStreams,proto3" json:"write_streams,omitempty"`
   984  }
   985  
   986  func (x *BatchCommitWriteStreamsRequest) Reset() {
   987  	*x = BatchCommitWriteStreamsRequest{}
   988  	if protoimpl.UnsafeEnabled {
   989  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[11]
   990  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   991  		ms.StoreMessageInfo(mi)
   992  	}
   993  }
   994  
   995  func (x *BatchCommitWriteStreamsRequest) String() string {
   996  	return protoimpl.X.MessageStringOf(x)
   997  }
   998  
   999  func (*BatchCommitWriteStreamsRequest) ProtoMessage() {}
  1000  
  1001  func (x *BatchCommitWriteStreamsRequest) ProtoReflect() protoreflect.Message {
  1002  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[11]
  1003  	if protoimpl.UnsafeEnabled && x != nil {
  1004  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1005  		if ms.LoadMessageInfo() == nil {
  1006  			ms.StoreMessageInfo(mi)
  1007  		}
  1008  		return ms
  1009  	}
  1010  	return mi.MessageOf(x)
  1011  }
  1012  
  1013  // Deprecated: Use BatchCommitWriteStreamsRequest.ProtoReflect.Descriptor instead.
  1014  func (*BatchCommitWriteStreamsRequest) Descriptor() ([]byte, []int) {
  1015  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{11}
  1016  }
  1017  
  1018  func (x *BatchCommitWriteStreamsRequest) GetParent() string {
  1019  	if x != nil {
  1020  		return x.Parent
  1021  	}
  1022  	return ""
  1023  }
  1024  
  1025  func (x *BatchCommitWriteStreamsRequest) GetWriteStreams() []string {
  1026  	if x != nil {
  1027  		return x.WriteStreams
  1028  	}
  1029  	return nil
  1030  }
  1031  
  1032  // Response message for `BatchCommitWriteStreams`.
  1033  type BatchCommitWriteStreamsResponse struct {
  1034  	state         protoimpl.MessageState
  1035  	sizeCache     protoimpl.SizeCache
  1036  	unknownFields protoimpl.UnknownFields
  1037  
  1038  	// The time at which streams were committed in microseconds granularity.
  1039  	// This field will only exist when there are no stream errors.
  1040  	// **Note** if this field is not set, it means the commit was not successful.
  1041  	CommitTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
  1042  	// Stream level error if commit failed. Only streams with error will be in
  1043  	// the list.
  1044  	// If empty, there is no error and all streams are committed successfully.
  1045  	// If non empty, certain streams have errors and ZERO stream is committed due
  1046  	// to atomicity guarantee.
  1047  	StreamErrors []*StorageError `protobuf:"bytes,2,rep,name=stream_errors,json=streamErrors,proto3" json:"stream_errors,omitempty"`
  1048  }
  1049  
  1050  func (x *BatchCommitWriteStreamsResponse) Reset() {
  1051  	*x = BatchCommitWriteStreamsResponse{}
  1052  	if protoimpl.UnsafeEnabled {
  1053  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[12]
  1054  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1055  		ms.StoreMessageInfo(mi)
  1056  	}
  1057  }
  1058  
  1059  func (x *BatchCommitWriteStreamsResponse) String() string {
  1060  	return protoimpl.X.MessageStringOf(x)
  1061  }
  1062  
  1063  func (*BatchCommitWriteStreamsResponse) ProtoMessage() {}
  1064  
  1065  func (x *BatchCommitWriteStreamsResponse) ProtoReflect() protoreflect.Message {
  1066  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[12]
  1067  	if protoimpl.UnsafeEnabled && x != nil {
  1068  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1069  		if ms.LoadMessageInfo() == nil {
  1070  			ms.StoreMessageInfo(mi)
  1071  		}
  1072  		return ms
  1073  	}
  1074  	return mi.MessageOf(x)
  1075  }
  1076  
  1077  // Deprecated: Use BatchCommitWriteStreamsResponse.ProtoReflect.Descriptor instead.
  1078  func (*BatchCommitWriteStreamsResponse) Descriptor() ([]byte, []int) {
  1079  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{12}
  1080  }
  1081  
  1082  func (x *BatchCommitWriteStreamsResponse) GetCommitTime() *timestamppb.Timestamp {
  1083  	if x != nil {
  1084  		return x.CommitTime
  1085  	}
  1086  	return nil
  1087  }
  1088  
  1089  func (x *BatchCommitWriteStreamsResponse) GetStreamErrors() []*StorageError {
  1090  	if x != nil {
  1091  		return x.StreamErrors
  1092  	}
  1093  	return nil
  1094  }
  1095  
  1096  // Request message for invoking `FinalizeWriteStream`.
  1097  type FinalizeWriteStreamRequest struct {
  1098  	state         protoimpl.MessageState
  1099  	sizeCache     protoimpl.SizeCache
  1100  	unknownFields protoimpl.UnknownFields
  1101  
  1102  	// Required. Name of the stream to finalize, in the form of
  1103  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
  1104  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  1105  }
  1106  
  1107  func (x *FinalizeWriteStreamRequest) Reset() {
  1108  	*x = FinalizeWriteStreamRequest{}
  1109  	if protoimpl.UnsafeEnabled {
  1110  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[13]
  1111  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1112  		ms.StoreMessageInfo(mi)
  1113  	}
  1114  }
  1115  
  1116  func (x *FinalizeWriteStreamRequest) String() string {
  1117  	return protoimpl.X.MessageStringOf(x)
  1118  }
  1119  
  1120  func (*FinalizeWriteStreamRequest) ProtoMessage() {}
  1121  
  1122  func (x *FinalizeWriteStreamRequest) ProtoReflect() protoreflect.Message {
  1123  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[13]
  1124  	if protoimpl.UnsafeEnabled && x != nil {
  1125  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1126  		if ms.LoadMessageInfo() == nil {
  1127  			ms.StoreMessageInfo(mi)
  1128  		}
  1129  		return ms
  1130  	}
  1131  	return mi.MessageOf(x)
  1132  }
  1133  
  1134  // Deprecated: Use FinalizeWriteStreamRequest.ProtoReflect.Descriptor instead.
  1135  func (*FinalizeWriteStreamRequest) Descriptor() ([]byte, []int) {
  1136  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{13}
  1137  }
  1138  
  1139  func (x *FinalizeWriteStreamRequest) GetName() string {
  1140  	if x != nil {
  1141  		return x.Name
  1142  	}
  1143  	return ""
  1144  }
  1145  
  1146  // Response message for `FinalizeWriteStream`.
  1147  type FinalizeWriteStreamResponse struct {
  1148  	state         protoimpl.MessageState
  1149  	sizeCache     protoimpl.SizeCache
  1150  	unknownFields protoimpl.UnknownFields
  1151  
  1152  	// Number of rows in the finalized stream.
  1153  	RowCount int64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
  1154  }
  1155  
  1156  func (x *FinalizeWriteStreamResponse) Reset() {
  1157  	*x = FinalizeWriteStreamResponse{}
  1158  	if protoimpl.UnsafeEnabled {
  1159  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[14]
  1160  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1161  		ms.StoreMessageInfo(mi)
  1162  	}
  1163  }
  1164  
  1165  func (x *FinalizeWriteStreamResponse) String() string {
  1166  	return protoimpl.X.MessageStringOf(x)
  1167  }
  1168  
  1169  func (*FinalizeWriteStreamResponse) ProtoMessage() {}
  1170  
  1171  func (x *FinalizeWriteStreamResponse) ProtoReflect() protoreflect.Message {
  1172  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[14]
  1173  	if protoimpl.UnsafeEnabled && x != nil {
  1174  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1175  		if ms.LoadMessageInfo() == nil {
  1176  			ms.StoreMessageInfo(mi)
  1177  		}
  1178  		return ms
  1179  	}
  1180  	return mi.MessageOf(x)
  1181  }
  1182  
  1183  // Deprecated: Use FinalizeWriteStreamResponse.ProtoReflect.Descriptor instead.
  1184  func (*FinalizeWriteStreamResponse) Descriptor() ([]byte, []int) {
  1185  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{14}
  1186  }
  1187  
  1188  func (x *FinalizeWriteStreamResponse) GetRowCount() int64 {
  1189  	if x != nil {
  1190  		return x.RowCount
  1191  	}
  1192  	return 0
  1193  }
  1194  
  1195  // Request message for `FlushRows`.
  1196  type FlushRowsRequest struct {
  1197  	state         protoimpl.MessageState
  1198  	sizeCache     protoimpl.SizeCache
  1199  	unknownFields protoimpl.UnknownFields
  1200  
  1201  	// Required. The stream that is the target of the flush operation.
  1202  	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
  1203  	// Ending offset of the flush operation. Rows before this offset(including
  1204  	// this offset) will be flushed.
  1205  	Offset *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
  1206  }
  1207  
  1208  func (x *FlushRowsRequest) Reset() {
  1209  	*x = FlushRowsRequest{}
  1210  	if protoimpl.UnsafeEnabled {
  1211  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[15]
  1212  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1213  		ms.StoreMessageInfo(mi)
  1214  	}
  1215  }
  1216  
  1217  func (x *FlushRowsRequest) String() string {
  1218  	return protoimpl.X.MessageStringOf(x)
  1219  }
  1220  
  1221  func (*FlushRowsRequest) ProtoMessage() {}
  1222  
  1223  func (x *FlushRowsRequest) ProtoReflect() protoreflect.Message {
  1224  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[15]
  1225  	if protoimpl.UnsafeEnabled && x != nil {
  1226  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1227  		if ms.LoadMessageInfo() == nil {
  1228  			ms.StoreMessageInfo(mi)
  1229  		}
  1230  		return ms
  1231  	}
  1232  	return mi.MessageOf(x)
  1233  }
  1234  
  1235  // Deprecated: Use FlushRowsRequest.ProtoReflect.Descriptor instead.
  1236  func (*FlushRowsRequest) Descriptor() ([]byte, []int) {
  1237  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{15}
  1238  }
  1239  
  1240  func (x *FlushRowsRequest) GetWriteStream() string {
  1241  	if x != nil {
  1242  		return x.WriteStream
  1243  	}
  1244  	return ""
  1245  }
  1246  
  1247  func (x *FlushRowsRequest) GetOffset() *wrapperspb.Int64Value {
  1248  	if x != nil {
  1249  		return x.Offset
  1250  	}
  1251  	return nil
  1252  }
  1253  
  1254  // Respond message for `FlushRows`.
  1255  type FlushRowsResponse struct {
  1256  	state         protoimpl.MessageState
  1257  	sizeCache     protoimpl.SizeCache
  1258  	unknownFields protoimpl.UnknownFields
  1259  
  1260  	// The rows before this offset (including this offset) are flushed.
  1261  	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
  1262  }
  1263  
  1264  func (x *FlushRowsResponse) Reset() {
  1265  	*x = FlushRowsResponse{}
  1266  	if protoimpl.UnsafeEnabled {
  1267  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[16]
  1268  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1269  		ms.StoreMessageInfo(mi)
  1270  	}
  1271  }
  1272  
  1273  func (x *FlushRowsResponse) String() string {
  1274  	return protoimpl.X.MessageStringOf(x)
  1275  }
  1276  
  1277  func (*FlushRowsResponse) ProtoMessage() {}
  1278  
  1279  func (x *FlushRowsResponse) ProtoReflect() protoreflect.Message {
  1280  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[16]
  1281  	if protoimpl.UnsafeEnabled && x != nil {
  1282  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1283  		if ms.LoadMessageInfo() == nil {
  1284  			ms.StoreMessageInfo(mi)
  1285  		}
  1286  		return ms
  1287  	}
  1288  	return mi.MessageOf(x)
  1289  }
  1290  
  1291  // Deprecated: Use FlushRowsResponse.ProtoReflect.Descriptor instead.
  1292  func (*FlushRowsResponse) Descriptor() ([]byte, []int) {
  1293  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{16}
  1294  }
  1295  
  1296  func (x *FlushRowsResponse) GetOffset() int64 {
  1297  	if x != nil {
  1298  		return x.Offset
  1299  	}
  1300  	return 0
  1301  }
  1302  
  1303  // Structured custom BigQuery Storage error message. The error can be attached
  1304  // as error details in the returned rpc Status. In particular, the use of error
  1305  // codes allows more structured error handling, and reduces the need to evaluate
  1306  // unstructured error text strings.
  1307  type StorageError struct {
  1308  	state         protoimpl.MessageState
  1309  	sizeCache     protoimpl.SizeCache
  1310  	unknownFields protoimpl.UnknownFields
  1311  
  1312  	// BigQuery Storage specific error code.
  1313  	Code StorageError_StorageErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=google.cloud.bigquery.storage.v1beta2.StorageError_StorageErrorCode" json:"code,omitempty"`
  1314  	// Name of the failed entity.
  1315  	Entity string `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
  1316  	// Message that describes the error.
  1317  	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
  1318  }
  1319  
  1320  func (x *StorageError) Reset() {
  1321  	*x = StorageError{}
  1322  	if protoimpl.UnsafeEnabled {
  1323  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[17]
  1324  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1325  		ms.StoreMessageInfo(mi)
  1326  	}
  1327  }
  1328  
  1329  func (x *StorageError) String() string {
  1330  	return protoimpl.X.MessageStringOf(x)
  1331  }
  1332  
  1333  func (*StorageError) ProtoMessage() {}
  1334  
  1335  func (x *StorageError) ProtoReflect() protoreflect.Message {
  1336  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[17]
  1337  	if protoimpl.UnsafeEnabled && x != nil {
  1338  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1339  		if ms.LoadMessageInfo() == nil {
  1340  			ms.StoreMessageInfo(mi)
  1341  		}
  1342  		return ms
  1343  	}
  1344  	return mi.MessageOf(x)
  1345  }
  1346  
  1347  // Deprecated: Use StorageError.ProtoReflect.Descriptor instead.
  1348  func (*StorageError) Descriptor() ([]byte, []int) {
  1349  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{17}
  1350  }
  1351  
  1352  func (x *StorageError) GetCode() StorageError_StorageErrorCode {
  1353  	if x != nil {
  1354  		return x.Code
  1355  	}
  1356  	return StorageError_STORAGE_ERROR_CODE_UNSPECIFIED
  1357  }
  1358  
  1359  func (x *StorageError) GetEntity() string {
  1360  	if x != nil {
  1361  		return x.Entity
  1362  	}
  1363  	return ""
  1364  }
  1365  
  1366  func (x *StorageError) GetErrorMessage() string {
  1367  	if x != nil {
  1368  		return x.ErrorMessage
  1369  	}
  1370  	return ""
  1371  }
  1372  
  1373  type StreamStats_Progress struct {
  1374  	state         protoimpl.MessageState
  1375  	sizeCache     protoimpl.SizeCache
  1376  	unknownFields protoimpl.UnknownFields
  1377  
  1378  	// The fraction of rows assigned to the stream that have been processed by
  1379  	// the server so far, not including the rows in the current response
  1380  	// message.
  1381  	//
  1382  	// This value, along with `at_response_end`, can be used to interpolate
  1383  	// the progress made as the rows in the message are being processed using
  1384  	// the following formula: `at_response_start + (at_response_end -
  1385  	// at_response_start) * rows_processed_from_response / rows_in_response`.
  1386  	//
  1387  	// Note that if a filter is provided, the `at_response_end` value of the
  1388  	// previous response may not necessarily be equal to the
  1389  	// `at_response_start` value of the current response.
  1390  	AtResponseStart float64 `protobuf:"fixed64,1,opt,name=at_response_start,json=atResponseStart,proto3" json:"at_response_start,omitempty"`
  1391  	// Similar to `at_response_start`, except that this value includes the
  1392  	// rows in the current response.
  1393  	AtResponseEnd float64 `protobuf:"fixed64,2,opt,name=at_response_end,json=atResponseEnd,proto3" json:"at_response_end,omitempty"`
  1394  }
  1395  
  1396  func (x *StreamStats_Progress) Reset() {
  1397  	*x = StreamStats_Progress{}
  1398  	if protoimpl.UnsafeEnabled {
  1399  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[18]
  1400  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1401  		ms.StoreMessageInfo(mi)
  1402  	}
  1403  }
  1404  
  1405  func (x *StreamStats_Progress) String() string {
  1406  	return protoimpl.X.MessageStringOf(x)
  1407  }
  1408  
  1409  func (*StreamStats_Progress) ProtoMessage() {}
  1410  
  1411  func (x *StreamStats_Progress) ProtoReflect() protoreflect.Message {
  1412  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[18]
  1413  	if protoimpl.UnsafeEnabled && x != nil {
  1414  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1415  		if ms.LoadMessageInfo() == nil {
  1416  			ms.StoreMessageInfo(mi)
  1417  		}
  1418  		return ms
  1419  	}
  1420  	return mi.MessageOf(x)
  1421  }
  1422  
  1423  // Deprecated: Use StreamStats_Progress.ProtoReflect.Descriptor instead.
  1424  func (*StreamStats_Progress) Descriptor() ([]byte, []int) {
  1425  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{3, 0}
  1426  }
  1427  
  1428  func (x *StreamStats_Progress) GetAtResponseStart() float64 {
  1429  	if x != nil {
  1430  		return x.AtResponseStart
  1431  	}
  1432  	return 0
  1433  }
  1434  
  1435  func (x *StreamStats_Progress) GetAtResponseEnd() float64 {
  1436  	if x != nil {
  1437  		return x.AtResponseEnd
  1438  	}
  1439  	return 0
  1440  }
  1441  
  1442  // Proto schema and data.
  1443  type AppendRowsRequest_ProtoData struct {
  1444  	state         protoimpl.MessageState
  1445  	sizeCache     protoimpl.SizeCache
  1446  	unknownFields protoimpl.UnknownFields
  1447  
  1448  	// Proto schema used to serialize the data.
  1449  	WriterSchema *ProtoSchema `protobuf:"bytes,1,opt,name=writer_schema,json=writerSchema,proto3" json:"writer_schema,omitempty"`
  1450  	// Serialized row data in protobuf message format.
  1451  	Rows *ProtoRows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
  1452  }
  1453  
  1454  func (x *AppendRowsRequest_ProtoData) Reset() {
  1455  	*x = AppendRowsRequest_ProtoData{}
  1456  	if protoimpl.UnsafeEnabled {
  1457  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[19]
  1458  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1459  		ms.StoreMessageInfo(mi)
  1460  	}
  1461  }
  1462  
  1463  func (x *AppendRowsRequest_ProtoData) String() string {
  1464  	return protoimpl.X.MessageStringOf(x)
  1465  }
  1466  
  1467  func (*AppendRowsRequest_ProtoData) ProtoMessage() {}
  1468  
  1469  func (x *AppendRowsRequest_ProtoData) ProtoReflect() protoreflect.Message {
  1470  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[19]
  1471  	if protoimpl.UnsafeEnabled && x != nil {
  1472  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1473  		if ms.LoadMessageInfo() == nil {
  1474  			ms.StoreMessageInfo(mi)
  1475  		}
  1476  		return ms
  1477  	}
  1478  	return mi.MessageOf(x)
  1479  }
  1480  
  1481  // Deprecated: Use AppendRowsRequest_ProtoData.ProtoReflect.Descriptor instead.
  1482  func (*AppendRowsRequest_ProtoData) Descriptor() ([]byte, []int) {
  1483  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{8, 0}
  1484  }
  1485  
  1486  func (x *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema {
  1487  	if x != nil {
  1488  		return x.WriterSchema
  1489  	}
  1490  	return nil
  1491  }
  1492  
  1493  func (x *AppendRowsRequest_ProtoData) GetRows() *ProtoRows {
  1494  	if x != nil {
  1495  		return x.Rows
  1496  	}
  1497  	return nil
  1498  }
  1499  
  1500  // AppendResult is returned for successful append requests.
  1501  type AppendRowsResponse_AppendResult struct {
  1502  	state         protoimpl.MessageState
  1503  	sizeCache     protoimpl.SizeCache
  1504  	unknownFields protoimpl.UnknownFields
  1505  
  1506  	// The row offset at which the last append occurred. The offset will not be
  1507  	// set if appending using default streams.
  1508  	Offset *wrapperspb.Int64Value `protobuf:"bytes,1,opt,name=offset,proto3" json:"offset,omitempty"`
  1509  }
  1510  
  1511  func (x *AppendRowsResponse_AppendResult) Reset() {
  1512  	*x = AppendRowsResponse_AppendResult{}
  1513  	if protoimpl.UnsafeEnabled {
  1514  		mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[20]
  1515  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1516  		ms.StoreMessageInfo(mi)
  1517  	}
  1518  }
  1519  
  1520  func (x *AppendRowsResponse_AppendResult) String() string {
  1521  	return protoimpl.X.MessageStringOf(x)
  1522  }
  1523  
  1524  func (*AppendRowsResponse_AppendResult) ProtoMessage() {}
  1525  
  1526  func (x *AppendRowsResponse_AppendResult) ProtoReflect() protoreflect.Message {
  1527  	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[20]
  1528  	if protoimpl.UnsafeEnabled && x != nil {
  1529  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1530  		if ms.LoadMessageInfo() == nil {
  1531  			ms.StoreMessageInfo(mi)
  1532  		}
  1533  		return ms
  1534  	}
  1535  	return mi.MessageOf(x)
  1536  }
  1537  
  1538  // Deprecated: Use AppendRowsResponse_AppendResult.ProtoReflect.Descriptor instead.
  1539  func (*AppendRowsResponse_AppendResult) Descriptor() ([]byte, []int) {
  1540  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{9, 0}
  1541  }
  1542  
  1543  func (x *AppendRowsResponse_AppendResult) GetOffset() *wrapperspb.Int64Value {
  1544  	if x != nil {
  1545  		return x.Offset
  1546  	}
  1547  	return nil
  1548  }
  1549  
  1550  var File_google_cloud_bigquery_storage_v1beta2_storage_proto protoreflect.FileDescriptor
  1551  
  1552  var file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc = []byte{
  1553  	0x0a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
  1554  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
  1555  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
  1556  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1557  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
  1558  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x1a, 0x1c, 0x67, 0x6f,
  1559  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74,
  1560  	0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67,
  1561  	0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72,
  1562  	0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f,
  1563  	0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70,
  1564  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
  1565  	0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
  1566  	0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69,
  1567  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76,
  1568  	0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f,
  1569  	0x74, 0x6f, 0x1a, 0x30, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1570  	0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1571  	0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70,
  1572  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x34, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f,
  1573  	0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72,
  1574  	0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x70, 0x72, 0x6f, 0x74,
  1575  	0x6f, 0x62, 0x75, 0x66, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67, 0x6f, 0x6f, 0x67,
  1576  	0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1577  	0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1578  	0x32, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x31,
  1579  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67,
  1580  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31,
  1581  	0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1582  	0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1583  	0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f,
  1584  	0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1585  	0x62, 0x75, 0x66, 0x2f, 0x77, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x73, 0x2e, 0x70, 0x72, 0x6f,
  1586  	0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x73,
  1587  	0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xed, 0x01, 0x0a, 0x18,
  1588  	0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f,
  1589  	0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65,
  1590  	0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d,
  1591  	0x0a, 0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d,
  1592  	0x61, 0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  1593  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06, 0x70,
  1594  	0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x5a, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73, 0x65,
  1595  	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f,
  1596  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1597  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1598  	0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x42,
  1599  	0x03, 0xe0, 0x41, 0x02, 0x52, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f,
  1600  	0x6e, 0x12, 0x28, 0x0a, 0x10, 0x6d, 0x61, 0x78, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f,
  1601  	0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x6d, 0x61, 0x78,
  1602  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x7d, 0x0a, 0x0f, 0x52,
  1603  	0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x52,
  1604  	0x0a, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20,
  1605  	0x01, 0x28, 0x09, 0x42, 0x31, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2b, 0x0a, 0x29, 0x62, 0x69, 0x67,
  1606  	0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f,
  1607  	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64,
  1608  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0a, 0x72, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65,
  1609  	0x61, 0x6d, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01,
  1610  	0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x3a, 0x0a, 0x0d, 0x54, 0x68,
  1611  	0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x74,
  1612  	0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x18,
  1613  	0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x50,
  1614  	0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x22, 0xc6, 0x01, 0x0a, 0x0b, 0x53, 0x74, 0x72, 0x65, 0x61,
  1615  	0x6d, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x57, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65,
  1616  	0x73, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1617  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1618  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
  1619  	0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x53, 0x74, 0x61, 0x74, 0x73, 0x2e, 0x50, 0x72, 0x6f,
  1620  	0x67, 0x72, 0x65, 0x73, 0x73, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x1a,
  1621  	0x5e, 0x0a, 0x08, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x12, 0x2a, 0x0a, 0x11, 0x61,
  1622  	0x74, 0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74,
  1623  	0x18, 0x01, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0f, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1624  	0x73, 0x65, 0x53, 0x74, 0x61, 0x72, 0x74, 0x12, 0x26, 0x0a, 0x0f, 0x61, 0x74, 0x5f, 0x72, 0x65,
  1625  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x65, 0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x01,
  1626  	0x52, 0x0d, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x45, 0x6e, 0x64, 0x22,
  1627  	0xda, 0x04, 0x0a, 0x10, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70,
  1628  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4e, 0x0a, 0x09, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x72, 0x6f, 0x77,
  1629  	0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1630  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1631  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e,
  1632  	0x41, 0x76, 0x72, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x48, 0x00, 0x52, 0x08, 0x61, 0x76, 0x72, 0x6f,
  1633  	0x52, 0x6f, 0x77, 0x73, 0x12, 0x67, 0x0a, 0x12, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x72, 0x65,
  1634  	0x63, 0x6f, 0x72, 0x64, 0x5f, 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,
  1635  	0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1636  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1637  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x52, 0x65,
  1638  	0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x48, 0x00, 0x52, 0x10, 0x61, 0x72, 0x72,
  1639  	0x6f, 0x77, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x1b, 0x0a,
  1640  	0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03,
  1641  	0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x48, 0x0a, 0x05, 0x73, 0x74,
  1642  	0x61, 0x74, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1643  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1644  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1645  	0x32, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x05, 0x73,
  1646  	0x74, 0x61, 0x74, 0x73, 0x12, 0x5b, 0x0a, 0x0e, 0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65,
  1647  	0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x34, 0x2e, 0x67,
  1648  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1649  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1650  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x54, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x53, 0x74, 0x61,
  1651  	0x74, 0x65, 0x52, 0x0d, 0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x53, 0x74, 0x61, 0x74,
  1652  	0x65, 0x12, 0x59, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1653  	0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1654  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73,
  1655  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41,
  1656  	0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x01,
  1657  	0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x5c, 0x0a, 0x0c,
  1658  	0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x08, 0x20, 0x01,
  1659  	0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1660  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
  1661  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77,
  1662  	0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x01, 0x52, 0x0b, 0x61,
  1663  	0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x06, 0x0a, 0x04, 0x72, 0x6f,
  1664  	0x77, 0x73, 0x42, 0x08, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x7b, 0x0a, 0x16,
  1665  	0x53, 0x70, 0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1666  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x45, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01,
  1667  	0x20, 0x01, 0x28, 0x09, 0x42, 0x31, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2b, 0x0a, 0x29, 0x62, 0x69,
  1668  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f,
  1669  	0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61,
  1670  	0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a,
  1671  	0x08, 0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x01, 0x52,
  1672  	0x08, 0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xd1, 0x01, 0x0a, 0x17, 0x53, 0x70,
  1673  	0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73,
  1674  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x58, 0x0a, 0x0e, 0x70, 0x72, 0x69, 0x6d, 0x61, 0x72, 0x79,
  1675  	0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e,
  1676  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
  1677  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
  1678  	0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1679  	0x52, 0x0d, 0x70, 0x72, 0x69, 0x6d, 0x61, 0x72, 0x79, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12,
  1680  	0x5c, 0x0a, 0x10, 0x72, 0x65, 0x6d, 0x61, 0x69, 0x6e, 0x64, 0x65, 0x72, 0x5f, 0x73, 0x74, 0x72,
  1681  	0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1682  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1683  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1684  	0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0f, 0x72, 0x65,
  1685  	0x6d, 0x61, 0x69, 0x6e, 0x64, 0x65, 0x72, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0xb5, 0x01,
  1686  	0x0a, 0x18, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
  1687  	0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x06, 0x70, 0x61,
  1688  	0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x25, 0xe0, 0x41, 0x02, 0xfa,
  1689  	0x41, 0x1f, 0x0a, 0x1d, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67, 0x6f, 0x6f,
  1690  	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c,
  1691  	0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x5a, 0x0a, 0x0c, 0x77, 0x72, 0x69,
  1692  	0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1693  	0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
  1694  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
  1695  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
  1696  	0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x53,
  1697  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0xd4, 0x03, 0x0a, 0x11, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64,
  1698  	0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x55, 0x0a, 0x0c, 0x77,
  1699  	0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28,
  1700  	0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75,
  1701  	0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1702  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53,
  1703  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65,
  1704  	0x61, 0x6d, 0x12, 0x33, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01,
  1705  	0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  1706  	0x6f, 0x62, 0x75, 0x66, 0x2e, 0x49, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52,
  1707  	0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x63, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  1708  	0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x42, 0x2e, 0x67, 0x6f,
  1709  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1710  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1711  	0x74, 0x61, 0x32, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65,
  1712  	0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x44, 0x61, 0x74, 0x61, 0x48,
  1713  	0x00, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x19, 0x0a, 0x08,
  1714  	0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
  1715  	0x74, 0x72, 0x61, 0x63, 0x65, 0x49, 0x64, 0x1a, 0xaa, 0x01, 0x0a, 0x09, 0x50, 0x72, 0x6f, 0x74,
  1716  	0x6f, 0x44, 0x61, 0x74, 0x61, 0x12, 0x57, 0x0a, 0x0d, 0x77, 0x72, 0x69, 0x74, 0x65, 0x72, 0x5f,
  1717  	0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67,
  1718  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1719  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1720  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1721  	0x52, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x72, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x44,
  1722  	0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x67,
  1723  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1724  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1725  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x04,
  1726  	0x72, 0x6f, 0x77, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x22, 0xdb, 0x02, 0x0a,
  1727  	0x12, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
  1728  	0x6e, 0x73, 0x65, 0x12, 0x6d, 0x0a, 0x0d, 0x61, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x5f, 0x72, 0x65,
  1729  	0x73, 0x75, 0x6c, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x46, 0x2e, 0x67, 0x6f, 0x6f,
  1730  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1731  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1732  	0x61, 0x32, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73,
  1733  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75,
  1734  	0x6c, 0x74, 0x48, 0x00, 0x52, 0x0c, 0x61, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75,
  1735  	0x6c, 0x74, 0x12, 0x2a, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28,
  1736  	0x0b, 0x32, 0x12, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53,
  1737  	0x74, 0x61, 0x74, 0x75, 0x73, 0x48, 0x00, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x59,
  1738  	0x0a, 0x0e, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1739  	0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1740  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73,
  1741  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x54,
  1742  	0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x0d, 0x75, 0x70, 0x64, 0x61,
  1743  	0x74, 0x65, 0x64, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x1a, 0x43, 0x0a, 0x0c, 0x41, 0x70, 0x70,
  1744  	0x65, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x33, 0x0a, 0x06, 0x6f, 0x66, 0x66,
  1745  	0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1746  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x49, 0x6e, 0x74, 0x36,
  1747  	0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x42, 0x0a,
  1748  	0x0a, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5f, 0x0a, 0x15, 0x47, 0x65,
  1749  	0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75,
  1750  	0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
  1751  	0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75,
  1752  	0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1753  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53,
  1754  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x67, 0x0a, 0x1e, 0x42,
  1755  	0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53,
  1756  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a,
  1757  	0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
  1758  	0x41, 0x02, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x28, 0x0a, 0x0d, 0x77, 0x72,
  1759  	0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28,
  1760  	0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
  1761  	0x65, 0x61, 0x6d, 0x73, 0x22, 0xb8, 0x01, 0x0a, 0x1f, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f,
  1762  	0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1763  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3b, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x6d,
  1764  	0x69, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e,
  1765  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1766  	0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x69,
  1767  	0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x58, 0x0a, 0x0d, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f,
  1768  	0x65, 0x72, 0x72, 0x6f, 0x72, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67,
  1769  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1770  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1771  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x45, 0x72, 0x72, 0x6f,
  1772  	0x72, 0x52, 0x0c, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x73, 0x22,
  1773  	0x64, 0x0a, 0x1a, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65,
  1774  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a,
  1775  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02,
  1776  	0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f,
  1777  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
  1778  	0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1779  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x3a, 0x0a, 0x1b, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a,
  1780  	0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70,
  1781  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e,
  1782  	0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e,
  1783  	0x74, 0x22, 0x9e, 0x01, 0x0a, 0x10, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52,
  1784  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x55, 0x0a, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f,
  1785  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41,
  1786  	0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74,
  1787  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
  1788  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1789  	0x52, 0x0b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x33, 0x0a,
  1790  	0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e,
  1791  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
  1792  	0x49, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73,
  1793  	0x65, 0x74, 0x22, 0x2b, 0x0a, 0x11, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52,
  1794  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
  1795  	0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22,
  1796  	0xf0, 0x02, 0x0a, 0x0c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x45, 0x72, 0x72, 0x6f, 0x72,
  1797  	0x12, 0x58, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x44,
  1798  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69,
  1799  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76,
  1800  	0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x45, 0x72,
  1801  	0x72, 0x6f, 0x72, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x45, 0x72, 0x72, 0x6f, 0x72,
  1802  	0x43, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x6e,
  1803  	0x74, 0x69, 0x74, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x65, 0x6e, 0x74, 0x69,
  1804  	0x74, 0x79, 0x12, 0x23, 0x0a, 0x0d, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x6d, 0x65, 0x73, 0x73,
  1805  	0x61, 0x67, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x65, 0x72, 0x72, 0x6f, 0x72,
  1806  	0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0xc8, 0x01, 0x0a, 0x10, 0x53, 0x74, 0x6f, 0x72,
  1807  	0x61, 0x67, 0x65, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a, 0x1e,
  1808  	0x53, 0x54, 0x4f, 0x52, 0x41, 0x47, 0x45, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x5f, 0x43, 0x4f,
  1809  	0x44, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00,
  1810  	0x12, 0x13, 0x0a, 0x0f, 0x54, 0x41, 0x42, 0x4c, 0x45, 0x5f, 0x4e, 0x4f, 0x54, 0x5f, 0x46, 0x4f,
  1811  	0x55, 0x4e, 0x44, 0x10, 0x01, 0x12, 0x1c, 0x0a, 0x18, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x5f,
  1812  	0x41, 0x4c, 0x52, 0x45, 0x41, 0x44, 0x59, 0x5f, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x54, 0x45,
  1813  	0x44, 0x10, 0x02, 0x12, 0x14, 0x0a, 0x10, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x5f, 0x4e, 0x4f,
  1814  	0x54, 0x5f, 0x46, 0x4f, 0x55, 0x4e, 0x44, 0x10, 0x03, 0x12, 0x17, 0x0a, 0x13, 0x49, 0x4e, 0x56,
  1815  	0x41, 0x4c, 0x49, 0x44, 0x5f, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x5f, 0x54, 0x59, 0x50, 0x45,
  1816  	0x10, 0x04, 0x12, 0x18, 0x0a, 0x14, 0x49, 0x4e, 0x56, 0x41, 0x4c, 0x49, 0x44, 0x5f, 0x53, 0x54,
  1817  	0x52, 0x45, 0x41, 0x4d, 0x5f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x10, 0x05, 0x12, 0x14, 0x0a, 0x10,
  1818  	0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x5f, 0x46, 0x49, 0x4e, 0x41, 0x4c, 0x49, 0x5a, 0x45, 0x44,
  1819  	0x10, 0x06, 0x32, 0xbf, 0x06, 0x0a, 0x0c, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52,
  1820  	0x65, 0x61, 0x64, 0x12, 0xf8, 0x01, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65,
  1821  	0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3f, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1822  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1823  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1824  	0x32, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73,
  1825  	0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x67, 0x6f, 0x6f,
  1826  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1827  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1828  	0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x6e,
  1829  	0xda, 0x41, 0x24, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73,
  1830  	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2c, 0x6d, 0x61, 0x78, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61,
  1831  	0x6d, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x41, 0x3a, 0x01, 0x2a,
  1832  	0x22, 0x3c, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x72, 0x65, 0x61, 0x64,
  1833  	0x5f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x3d, 0x70,
  1834  	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65,
  1835  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xde,
  1836  	0x01, 0x0a, 0x08, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x36, 0x2e, 0x67, 0x6f,
  1837  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1838  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1839  	0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75,
  1840  	0x65, 0x73, 0x74, 0x1a, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1841  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1842  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64,
  1843  	0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5f, 0xda, 0x41,
  1844  	0x12, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2c, 0x6f, 0x66, 0x66,
  1845  	0x73, 0x65, 0x74, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x44, 0x12, 0x42, 0x2f, 0x76, 0x31, 0x62, 0x65,
  1846  	0x74, 0x61, 0x32, 0x2f, 0x7b, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1847  	0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61,
  1848  	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73,
  1849  	0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x30, 0x01, 0x12,
  1850  	0xd5, 0x01, 0x0a, 0x0f, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72,
  1851  	0x65, 0x61, 0x6d, 0x12, 0x3d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1852  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1853  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x70, 0x6c, 0x69,
  1854  	0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65,
  1855  	0x73, 0x74, 0x1a, 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1856  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
  1857  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x70, 0x6c, 0x69, 0x74,
  1858  	0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1859  	0x73, 0x65, 0x22, 0x43, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3d, 0x12, 0x3b, 0x2f, 0x76, 0x31, 0x62,
  1860  	0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
  1861  	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
  1862  	0x2a, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72,
  1863  	0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x1a, 0x7b, 0xca, 0x41, 0x1e, 0x62, 0x69, 0x67, 0x71,
  1864  	0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1865  	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x57, 0x68, 0x74, 0x74,
  1866  	0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
  1867  	0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67,
  1868  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77,
  1869  	0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
  1870  	0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74,
  1871  	0x66, 0x6f, 0x72, 0x6d, 0x32, 0xab, 0x0c, 0x0a, 0x0d, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72,
  1872  	0x79, 0x57, 0x72, 0x69, 0x74, 0x65, 0x12, 0xe9, 0x01, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 0x74,
  1873  	0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x3f, 0x2e, 0x67,
  1874  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1875  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1876  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65,
  1877  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e,
  1878  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
  1879  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
  1880  	0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61,
  1881  	0x6d, 0x22, 0x5f, 0xda, 0x41, 0x13, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x77, 0x72, 0x69,
  1882  	0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x40, 0x3a,
  1883  	0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x30, 0x2f,
  1884  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d,
  1885  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73,
  1886  	0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x88,
  1887  	0x02, 0x01, 0x12, 0xe4, 0x01, 0x0a, 0x0a, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77,
  1888  	0x73, 0x12, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1889  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1890  	0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64,
  1891  	0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x39, 0x2e, 0x67, 0x6f,
  1892  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1893  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1894  	0x74, 0x61, 0x32, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65,
  1895  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5d, 0xda, 0x41, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65,
  1896  	0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x3a, 0x01, 0x2a,
  1897  	0x22, 0x40, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x77, 0x72, 0x69, 0x74,
  1898  	0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
  1899  	0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74,
  1900  	0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f,
  1901  	0x2a, 0x7d, 0x88, 0x02, 0x01, 0x28, 0x01, 0x30, 0x01, 0x12, 0xd1, 0x01, 0x0a, 0x0e, 0x47, 0x65,
  1902  	0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x3c, 0x2e, 0x67,
  1903  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1904  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1905  	0x65, 0x74, 0x61, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
  1906  	0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x67, 0x6f, 0x6f,
  1907  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1908  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1909  	0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x4d,
  1910  	0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3d, 0x3a, 0x01, 0x2a,
  1911  	0x22, 0x38, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65,
  1912  	0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61,
  1913  	0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f,
  1914  	0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x88, 0x02, 0x01, 0x12, 0xeb, 0x01,
  1915  	0x0a, 0x13, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53,
  1916  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1917  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
  1918  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x46, 0x69,
  1919  	0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61,
  1920  	0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x42, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1921  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1922  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
  1923  	0x2e, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74,
  1924  	0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4d, 0xda, 0x41,
  1925  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3d, 0x3a, 0x01, 0x2a, 0x22, 0x38,
  1926  	0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70,
  1927  	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65,
  1928  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74,
  1929  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x88, 0x02, 0x01, 0x12, 0xee, 0x01, 0x0a, 0x17,
  1930  	0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65,
  1931  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0x45, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1932  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1933  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e,
  1934  	0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65,
  1935  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x46,
  1936  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69,
  1937  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76,
  1938  	0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d,
  1939  	0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65,
  1940  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x44, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e,
  1941  	0x74, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x32, 0x12, 0x30, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1942  	0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1943  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
  1944  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x88, 0x02, 0x01, 0x12, 0xdd, 0x01, 0x0a,
  1945  	0x09, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x37, 0x2e, 0x67, 0x6f, 0x6f,
  1946  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1947  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1948  	0x61, 0x32, 0x2e, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75,
  1949  	0x65, 0x73, 0x74, 0x1a, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1950  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1951  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x46, 0x6c, 0x75, 0x73,
  1952  	0x68, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5d, 0xda,
  1953  	0x41, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x82, 0xd3,
  1954  	0xe4, 0x93, 0x02, 0x45, 0x3a, 0x01, 0x2a, 0x22, 0x40, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1955  	0x32, 0x2f, 0x7b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x3d,
  1956  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73,
  1957  	0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x73,
  1958  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x88, 0x02, 0x01, 0x1a, 0xb3, 0x01, 0xca,
  1959  	0x41, 0x1e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1960  	0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
  1961  	0xd2, 0x41, 0x8b, 0x01, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e,
  1962  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61,
  1963  	0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2c, 0x68, 0x74, 0x74,
  1964  	0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
  1965  	0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67,
  1966  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x64, 0x61, 0x74, 0x61,
  1967  	0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f,
  1968  	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68,
  1969  	0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x88,
  1970  	0x02, 0x01, 0x42, 0x80, 0x01, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1971  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1972  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
  1973  	0x42, 0x0c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01,
  1974  	0x5a, 0x43, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1975  	0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73,
  1976  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
  1977  	0x32, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72,
  1978  	0x61, 0x67, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  1979  }
  1980  
  1981  var (
  1982  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescOnce sync.Once
  1983  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc
  1984  )
  1985  
  1986  func file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP() []byte {
  1987  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescOnce.Do(func() {
  1988  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData)
  1989  	})
  1990  	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData
  1991  }
  1992  
  1993  var file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
  1994  var file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes = make([]protoimpl.MessageInfo, 21)
  1995  var file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes = []interface{}{
  1996  	(StorageError_StorageErrorCode)(0),      // 0: google.cloud.bigquery.storage.v1beta2.StorageError.StorageErrorCode
  1997  	(*CreateReadSessionRequest)(nil),        // 1: google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest
  1998  	(*ReadRowsRequest)(nil),                 // 2: google.cloud.bigquery.storage.v1beta2.ReadRowsRequest
  1999  	(*ThrottleState)(nil),                   // 3: google.cloud.bigquery.storage.v1beta2.ThrottleState
  2000  	(*StreamStats)(nil),                     // 4: google.cloud.bigquery.storage.v1beta2.StreamStats
  2001  	(*ReadRowsResponse)(nil),                // 5: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse
  2002  	(*SplitReadStreamRequest)(nil),          // 6: google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest
  2003  	(*SplitReadStreamResponse)(nil),         // 7: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse
  2004  	(*CreateWriteStreamRequest)(nil),        // 8: google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest
  2005  	(*AppendRowsRequest)(nil),               // 9: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest
  2006  	(*AppendRowsResponse)(nil),              // 10: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse
  2007  	(*GetWriteStreamRequest)(nil),           // 11: google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest
  2008  	(*BatchCommitWriteStreamsRequest)(nil),  // 12: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest
  2009  	(*BatchCommitWriteStreamsResponse)(nil), // 13: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse
  2010  	(*FinalizeWriteStreamRequest)(nil),      // 14: google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest
  2011  	(*FinalizeWriteStreamResponse)(nil),     // 15: google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse
  2012  	(*FlushRowsRequest)(nil),                // 16: google.cloud.bigquery.storage.v1beta2.FlushRowsRequest
  2013  	(*FlushRowsResponse)(nil),               // 17: google.cloud.bigquery.storage.v1beta2.FlushRowsResponse
  2014  	(*StorageError)(nil),                    // 18: google.cloud.bigquery.storage.v1beta2.StorageError
  2015  	(*StreamStats_Progress)(nil),            // 19: google.cloud.bigquery.storage.v1beta2.StreamStats.Progress
  2016  	(*AppendRowsRequest_ProtoData)(nil),     // 20: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData
  2017  	(*AppendRowsResponse_AppendResult)(nil), // 21: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult
  2018  	(*ReadSession)(nil),                     // 22: google.cloud.bigquery.storage.v1beta2.ReadSession
  2019  	(*AvroRows)(nil),                        // 23: google.cloud.bigquery.storage.v1beta2.AvroRows
  2020  	(*ArrowRecordBatch)(nil),                // 24: google.cloud.bigquery.storage.v1beta2.ArrowRecordBatch
  2021  	(*AvroSchema)(nil),                      // 25: google.cloud.bigquery.storage.v1beta2.AvroSchema
  2022  	(*ArrowSchema)(nil),                     // 26: google.cloud.bigquery.storage.v1beta2.ArrowSchema
  2023  	(*ReadStream)(nil),                      // 27: google.cloud.bigquery.storage.v1beta2.ReadStream
  2024  	(*WriteStream)(nil),                     // 28: google.cloud.bigquery.storage.v1beta2.WriteStream
  2025  	(*wrapperspb.Int64Value)(nil),           // 29: google.protobuf.Int64Value
  2026  	(*status.Status)(nil),                   // 30: google.rpc.Status
  2027  	(*TableSchema)(nil),                     // 31: google.cloud.bigquery.storage.v1beta2.TableSchema
  2028  	(*timestamppb.Timestamp)(nil),           // 32: google.protobuf.Timestamp
  2029  	(*ProtoSchema)(nil),                     // 33: google.cloud.bigquery.storage.v1beta2.ProtoSchema
  2030  	(*ProtoRows)(nil),                       // 34: google.cloud.bigquery.storage.v1beta2.ProtoRows
  2031  }
  2032  var file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs = []int32{
  2033  	22, // 0: google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest.read_session:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession
  2034  	19, // 1: google.cloud.bigquery.storage.v1beta2.StreamStats.progress:type_name -> google.cloud.bigquery.storage.v1beta2.StreamStats.Progress
  2035  	23, // 2: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.avro_rows:type_name -> google.cloud.bigquery.storage.v1beta2.AvroRows
  2036  	24, // 3: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.arrow_record_batch:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowRecordBatch
  2037  	4,  // 4: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.stats:type_name -> google.cloud.bigquery.storage.v1beta2.StreamStats
  2038  	3,  // 5: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.throttle_state:type_name -> google.cloud.bigquery.storage.v1beta2.ThrottleState
  2039  	25, // 6: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta2.AvroSchema
  2040  	26, // 7: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSchema
  2041  	27, // 8: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse.primary_stream:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream
  2042  	27, // 9: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse.remainder_stream:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream
  2043  	28, // 10: google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest.write_stream:type_name -> google.cloud.bigquery.storage.v1beta2.WriteStream
  2044  	29, // 11: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.offset:type_name -> google.protobuf.Int64Value
  2045  	20, // 12: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.proto_rows:type_name -> google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData
  2046  	21, // 13: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.append_result:type_name -> google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult
  2047  	30, // 14: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.error:type_name -> google.rpc.Status
  2048  	31, // 15: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.updated_schema:type_name -> google.cloud.bigquery.storage.v1beta2.TableSchema
  2049  	32, // 16: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse.commit_time:type_name -> google.protobuf.Timestamp
  2050  	18, // 17: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse.stream_errors:type_name -> google.cloud.bigquery.storage.v1beta2.StorageError
  2051  	29, // 18: google.cloud.bigquery.storage.v1beta2.FlushRowsRequest.offset:type_name -> google.protobuf.Int64Value
  2052  	0,  // 19: google.cloud.bigquery.storage.v1beta2.StorageError.code:type_name -> google.cloud.bigquery.storage.v1beta2.StorageError.StorageErrorCode
  2053  	33, // 20: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData.writer_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ProtoSchema
  2054  	34, // 21: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData.rows:type_name -> google.cloud.bigquery.storage.v1beta2.ProtoRows
  2055  	29, // 22: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult.offset:type_name -> google.protobuf.Int64Value
  2056  	1,  // 23: google.cloud.bigquery.storage.v1beta2.BigQueryRead.CreateReadSession:input_type -> google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest
  2057  	2,  // 24: google.cloud.bigquery.storage.v1beta2.BigQueryRead.ReadRows:input_type -> google.cloud.bigquery.storage.v1beta2.ReadRowsRequest
  2058  	6,  // 25: google.cloud.bigquery.storage.v1beta2.BigQueryRead.SplitReadStream:input_type -> google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest
  2059  	8,  // 26: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.CreateWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest
  2060  	9,  // 27: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.AppendRows:input_type -> google.cloud.bigquery.storage.v1beta2.AppendRowsRequest
  2061  	11, // 28: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.GetWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest
  2062  	14, // 29: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FinalizeWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest
  2063  	12, // 30: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.BatchCommitWriteStreams:input_type -> google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest
  2064  	16, // 31: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FlushRows:input_type -> google.cloud.bigquery.storage.v1beta2.FlushRowsRequest
  2065  	22, // 32: google.cloud.bigquery.storage.v1beta2.BigQueryRead.CreateReadSession:output_type -> google.cloud.bigquery.storage.v1beta2.ReadSession
  2066  	5,  // 33: google.cloud.bigquery.storage.v1beta2.BigQueryRead.ReadRows:output_type -> google.cloud.bigquery.storage.v1beta2.ReadRowsResponse
  2067  	7,  // 34: google.cloud.bigquery.storage.v1beta2.BigQueryRead.SplitReadStream:output_type -> google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse
  2068  	28, // 35: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.CreateWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.WriteStream
  2069  	10, // 36: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.AppendRows:output_type -> google.cloud.bigquery.storage.v1beta2.AppendRowsResponse
  2070  	28, // 37: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.GetWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.WriteStream
  2071  	15, // 38: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FinalizeWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse
  2072  	13, // 39: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.BatchCommitWriteStreams:output_type -> google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse
  2073  	17, // 40: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FlushRows:output_type -> google.cloud.bigquery.storage.v1beta2.FlushRowsResponse
  2074  	32, // [32:41] is the sub-list for method output_type
  2075  	23, // [23:32] is the sub-list for method input_type
  2076  	23, // [23:23] is the sub-list for extension type_name
  2077  	23, // [23:23] is the sub-list for extension extendee
  2078  	0,  // [0:23] is the sub-list for field type_name
  2079  }
  2080  
  2081  func init() { file_google_cloud_bigquery_storage_v1beta2_storage_proto_init() }
  2082  func file_google_cloud_bigquery_storage_v1beta2_storage_proto_init() {
  2083  	if File_google_cloud_bigquery_storage_v1beta2_storage_proto != nil {
  2084  		return
  2085  	}
  2086  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init()
  2087  	file_google_cloud_bigquery_storage_v1beta2_avro_proto_init()
  2088  	file_google_cloud_bigquery_storage_v1beta2_protobuf_proto_init()
  2089  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_init()
  2090  	file_google_cloud_bigquery_storage_v1beta2_table_proto_init()
  2091  	if !protoimpl.UnsafeEnabled {
  2092  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  2093  			switch v := v.(*CreateReadSessionRequest); i {
  2094  			case 0:
  2095  				return &v.state
  2096  			case 1:
  2097  				return &v.sizeCache
  2098  			case 2:
  2099  				return &v.unknownFields
  2100  			default:
  2101  				return nil
  2102  			}
  2103  		}
  2104  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  2105  			switch v := v.(*ReadRowsRequest); i {
  2106  			case 0:
  2107  				return &v.state
  2108  			case 1:
  2109  				return &v.sizeCache
  2110  			case 2:
  2111  				return &v.unknownFields
  2112  			default:
  2113  				return nil
  2114  			}
  2115  		}
  2116  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  2117  			switch v := v.(*ThrottleState); i {
  2118  			case 0:
  2119  				return &v.state
  2120  			case 1:
  2121  				return &v.sizeCache
  2122  			case 2:
  2123  				return &v.unknownFields
  2124  			default:
  2125  				return nil
  2126  			}
  2127  		}
  2128  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  2129  			switch v := v.(*StreamStats); i {
  2130  			case 0:
  2131  				return &v.state
  2132  			case 1:
  2133  				return &v.sizeCache
  2134  			case 2:
  2135  				return &v.unknownFields
  2136  			default:
  2137  				return nil
  2138  			}
  2139  		}
  2140  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  2141  			switch v := v.(*ReadRowsResponse); i {
  2142  			case 0:
  2143  				return &v.state
  2144  			case 1:
  2145  				return &v.sizeCache
  2146  			case 2:
  2147  				return &v.unknownFields
  2148  			default:
  2149  				return nil
  2150  			}
  2151  		}
  2152  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  2153  			switch v := v.(*SplitReadStreamRequest); i {
  2154  			case 0:
  2155  				return &v.state
  2156  			case 1:
  2157  				return &v.sizeCache
  2158  			case 2:
  2159  				return &v.unknownFields
  2160  			default:
  2161  				return nil
  2162  			}
  2163  		}
  2164  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  2165  			switch v := v.(*SplitReadStreamResponse); i {
  2166  			case 0:
  2167  				return &v.state
  2168  			case 1:
  2169  				return &v.sizeCache
  2170  			case 2:
  2171  				return &v.unknownFields
  2172  			default:
  2173  				return nil
  2174  			}
  2175  		}
  2176  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  2177  			switch v := v.(*CreateWriteStreamRequest); i {
  2178  			case 0:
  2179  				return &v.state
  2180  			case 1:
  2181  				return &v.sizeCache
  2182  			case 2:
  2183  				return &v.unknownFields
  2184  			default:
  2185  				return nil
  2186  			}
  2187  		}
  2188  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  2189  			switch v := v.(*AppendRowsRequest); i {
  2190  			case 0:
  2191  				return &v.state
  2192  			case 1:
  2193  				return &v.sizeCache
  2194  			case 2:
  2195  				return &v.unknownFields
  2196  			default:
  2197  				return nil
  2198  			}
  2199  		}
  2200  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  2201  			switch v := v.(*AppendRowsResponse); i {
  2202  			case 0:
  2203  				return &v.state
  2204  			case 1:
  2205  				return &v.sizeCache
  2206  			case 2:
  2207  				return &v.unknownFields
  2208  			default:
  2209  				return nil
  2210  			}
  2211  		}
  2212  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  2213  			switch v := v.(*GetWriteStreamRequest); i {
  2214  			case 0:
  2215  				return &v.state
  2216  			case 1:
  2217  				return &v.sizeCache
  2218  			case 2:
  2219  				return &v.unknownFields
  2220  			default:
  2221  				return nil
  2222  			}
  2223  		}
  2224  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  2225  			switch v := v.(*BatchCommitWriteStreamsRequest); i {
  2226  			case 0:
  2227  				return &v.state
  2228  			case 1:
  2229  				return &v.sizeCache
  2230  			case 2:
  2231  				return &v.unknownFields
  2232  			default:
  2233  				return nil
  2234  			}
  2235  		}
  2236  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  2237  			switch v := v.(*BatchCommitWriteStreamsResponse); i {
  2238  			case 0:
  2239  				return &v.state
  2240  			case 1:
  2241  				return &v.sizeCache
  2242  			case 2:
  2243  				return &v.unknownFields
  2244  			default:
  2245  				return nil
  2246  			}
  2247  		}
  2248  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  2249  			switch v := v.(*FinalizeWriteStreamRequest); i {
  2250  			case 0:
  2251  				return &v.state
  2252  			case 1:
  2253  				return &v.sizeCache
  2254  			case 2:
  2255  				return &v.unknownFields
  2256  			default:
  2257  				return nil
  2258  			}
  2259  		}
  2260  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  2261  			switch v := v.(*FinalizeWriteStreamResponse); i {
  2262  			case 0:
  2263  				return &v.state
  2264  			case 1:
  2265  				return &v.sizeCache
  2266  			case 2:
  2267  				return &v.unknownFields
  2268  			default:
  2269  				return nil
  2270  			}
  2271  		}
  2272  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  2273  			switch v := v.(*FlushRowsRequest); i {
  2274  			case 0:
  2275  				return &v.state
  2276  			case 1:
  2277  				return &v.sizeCache
  2278  			case 2:
  2279  				return &v.unknownFields
  2280  			default:
  2281  				return nil
  2282  			}
  2283  		}
  2284  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
  2285  			switch v := v.(*FlushRowsResponse); i {
  2286  			case 0:
  2287  				return &v.state
  2288  			case 1:
  2289  				return &v.sizeCache
  2290  			case 2:
  2291  				return &v.unknownFields
  2292  			default:
  2293  				return nil
  2294  			}
  2295  		}
  2296  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
  2297  			switch v := v.(*StorageError); i {
  2298  			case 0:
  2299  				return &v.state
  2300  			case 1:
  2301  				return &v.sizeCache
  2302  			case 2:
  2303  				return &v.unknownFields
  2304  			default:
  2305  				return nil
  2306  			}
  2307  		}
  2308  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
  2309  			switch v := v.(*StreamStats_Progress); i {
  2310  			case 0:
  2311  				return &v.state
  2312  			case 1:
  2313  				return &v.sizeCache
  2314  			case 2:
  2315  				return &v.unknownFields
  2316  			default:
  2317  				return nil
  2318  			}
  2319  		}
  2320  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
  2321  			switch v := v.(*AppendRowsRequest_ProtoData); i {
  2322  			case 0:
  2323  				return &v.state
  2324  			case 1:
  2325  				return &v.sizeCache
  2326  			case 2:
  2327  				return &v.unknownFields
  2328  			default:
  2329  				return nil
  2330  			}
  2331  		}
  2332  		file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
  2333  			switch v := v.(*AppendRowsResponse_AppendResult); i {
  2334  			case 0:
  2335  				return &v.state
  2336  			case 1:
  2337  				return &v.sizeCache
  2338  			case 2:
  2339  				return &v.unknownFields
  2340  			default:
  2341  				return nil
  2342  			}
  2343  		}
  2344  	}
  2345  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4].OneofWrappers = []interface{}{
  2346  		(*ReadRowsResponse_AvroRows)(nil),
  2347  		(*ReadRowsResponse_ArrowRecordBatch)(nil),
  2348  		(*ReadRowsResponse_AvroSchema)(nil),
  2349  		(*ReadRowsResponse_ArrowSchema)(nil),
  2350  	}
  2351  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8].OneofWrappers = []interface{}{
  2352  		(*AppendRowsRequest_ProtoRows)(nil),
  2353  	}
  2354  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9].OneofWrappers = []interface{}{
  2355  		(*AppendRowsResponse_AppendResult_)(nil),
  2356  		(*AppendRowsResponse_Error)(nil),
  2357  	}
  2358  	type x struct{}
  2359  	out := protoimpl.TypeBuilder{
  2360  		File: protoimpl.DescBuilder{
  2361  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  2362  			RawDescriptor: file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc,
  2363  			NumEnums:      1,
  2364  			NumMessages:   21,
  2365  			NumExtensions: 0,
  2366  			NumServices:   2,
  2367  		},
  2368  		GoTypes:           file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes,
  2369  		DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs,
  2370  		EnumInfos:         file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes,
  2371  		MessageInfos:      file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes,
  2372  	}.Build()
  2373  	File_google_cloud_bigquery_storage_v1beta2_storage_proto = out.File
  2374  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc = nil
  2375  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes = nil
  2376  	file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs = nil
  2377  }
  2378  
  2379  // Reference imports to suppress errors if they are not otherwise used.
  2380  var _ context.Context
  2381  var _ grpc.ClientConnInterface
  2382  
  2383  // This is a compile-time assertion to ensure that this generated file
  2384  // is compatible with the grpc package it is being compiled against.
  2385  const _ = grpc.SupportPackageIsVersion6
  2386  
  2387  // BigQueryReadClient is the client API for BigQueryRead service.
  2388  //
  2389  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  2390  type BigQueryReadClient interface {
  2391  	// Creates a new read session. A read session divides the contents of a
  2392  	// BigQuery table into one or more streams, which can then be used to read
  2393  	// data from the table. The read session also specifies properties of the
  2394  	// data to be read, such as a list of columns or a push-down filter describing
  2395  	// the rows to be returned.
  2396  	//
  2397  	// A particular row can be read by at most one stream. When the caller has
  2398  	// reached the end of each stream in the session, then all the data in the
  2399  	// table has been read.
  2400  	//
  2401  	// Data is assigned to each stream such that roughly the same number of
  2402  	// rows can be read from each stream. Because the server-side unit for
  2403  	// assigning data is collections of rows, the API does not guarantee that
  2404  	// each stream will return the same number or rows. Additionally, the
  2405  	// limits are enforced based on the number of pre-filtered rows, so some
  2406  	// filters can lead to lopsided assignments.
  2407  	//
  2408  	// Read sessions automatically expire 6 hours after they are created and do
  2409  	// not require manual clean-up by the caller.
  2410  	CreateReadSession(ctx context.Context, in *CreateReadSessionRequest, opts ...grpc.CallOption) (*ReadSession, error)
  2411  	// Reads rows from the stream in the format prescribed by the ReadSession.
  2412  	// Each response contains one or more table rows, up to a maximum of 100 MiB
  2413  	// per response; read requests which attempt to read individual rows larger
  2414  	// than 100 MiB will fail.
  2415  	//
  2416  	// Each request also returns a set of stream statistics reflecting the current
  2417  	// state of the stream.
  2418  	ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigQueryRead_ReadRowsClient, error)
  2419  	// Splits a given `ReadStream` into two `ReadStream` objects. These
  2420  	// `ReadStream` objects are referred to as the primary and the residual
  2421  	// streams of the split. The original `ReadStream` can still be read from in
  2422  	// the same manner as before. Both of the returned `ReadStream` objects can
  2423  	// also be read from, and the rows returned by both child streams will be
  2424  	// the same as the rows read from the original stream.
  2425  	//
  2426  	// Moreover, the two child streams will be allocated back-to-back in the
  2427  	// original `ReadStream`. Concretely, it is guaranteed that for streams
  2428  	// original, primary, and residual, that original[0-j] = primary[0-j] and
  2429  	// original[j-n] = residual[0-m] once the streams have been read to
  2430  	// completion.
  2431  	SplitReadStream(ctx context.Context, in *SplitReadStreamRequest, opts ...grpc.CallOption) (*SplitReadStreamResponse, error)
  2432  }
  2433  
  2434  type bigQueryReadClient struct {
  2435  	cc grpc.ClientConnInterface
  2436  }
  2437  
  2438  func NewBigQueryReadClient(cc grpc.ClientConnInterface) BigQueryReadClient {
  2439  	return &bigQueryReadClient{cc}
  2440  }
  2441  
  2442  func (c *bigQueryReadClient) CreateReadSession(ctx context.Context, in *CreateReadSessionRequest, opts ...grpc.CallOption) (*ReadSession, error) {
  2443  	out := new(ReadSession)
  2444  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryRead/CreateReadSession", in, out, opts...)
  2445  	if err != nil {
  2446  		return nil, err
  2447  	}
  2448  	return out, nil
  2449  }
  2450  
  2451  func (c *bigQueryReadClient) ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigQueryRead_ReadRowsClient, error) {
  2452  	stream, err := c.cc.NewStream(ctx, &_BigQueryRead_serviceDesc.Streams[0], "/google.cloud.bigquery.storage.v1beta2.BigQueryRead/ReadRows", opts...)
  2453  	if err != nil {
  2454  		return nil, err
  2455  	}
  2456  	x := &bigQueryReadReadRowsClient{stream}
  2457  	if err := x.ClientStream.SendMsg(in); err != nil {
  2458  		return nil, err
  2459  	}
  2460  	if err := x.ClientStream.CloseSend(); err != nil {
  2461  		return nil, err
  2462  	}
  2463  	return x, nil
  2464  }
  2465  
  2466  type BigQueryRead_ReadRowsClient interface {
  2467  	Recv() (*ReadRowsResponse, error)
  2468  	grpc.ClientStream
  2469  }
  2470  
  2471  type bigQueryReadReadRowsClient struct {
  2472  	grpc.ClientStream
  2473  }
  2474  
  2475  func (x *bigQueryReadReadRowsClient) Recv() (*ReadRowsResponse, error) {
  2476  	m := new(ReadRowsResponse)
  2477  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2478  		return nil, err
  2479  	}
  2480  	return m, nil
  2481  }
  2482  
  2483  func (c *bigQueryReadClient) SplitReadStream(ctx context.Context, in *SplitReadStreamRequest, opts ...grpc.CallOption) (*SplitReadStreamResponse, error) {
  2484  	out := new(SplitReadStreamResponse)
  2485  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryRead/SplitReadStream", in, out, opts...)
  2486  	if err != nil {
  2487  		return nil, err
  2488  	}
  2489  	return out, nil
  2490  }
  2491  
  2492  // BigQueryReadServer is the server API for BigQueryRead service.
  2493  type BigQueryReadServer interface {
  2494  	// Creates a new read session. A read session divides the contents of a
  2495  	// BigQuery table into one or more streams, which can then be used to read
  2496  	// data from the table. The read session also specifies properties of the
  2497  	// data to be read, such as a list of columns or a push-down filter describing
  2498  	// the rows to be returned.
  2499  	//
  2500  	// A particular row can be read by at most one stream. When the caller has
  2501  	// reached the end of each stream in the session, then all the data in the
  2502  	// table has been read.
  2503  	//
  2504  	// Data is assigned to each stream such that roughly the same number of
  2505  	// rows can be read from each stream. Because the server-side unit for
  2506  	// assigning data is collections of rows, the API does not guarantee that
  2507  	// each stream will return the same number or rows. Additionally, the
  2508  	// limits are enforced based on the number of pre-filtered rows, so some
  2509  	// filters can lead to lopsided assignments.
  2510  	//
  2511  	// Read sessions automatically expire 6 hours after they are created and do
  2512  	// not require manual clean-up by the caller.
  2513  	CreateReadSession(context.Context, *CreateReadSessionRequest) (*ReadSession, error)
  2514  	// Reads rows from the stream in the format prescribed by the ReadSession.
  2515  	// Each response contains one or more table rows, up to a maximum of 100 MiB
  2516  	// per response; read requests which attempt to read individual rows larger
  2517  	// than 100 MiB will fail.
  2518  	//
  2519  	// Each request also returns a set of stream statistics reflecting the current
  2520  	// state of the stream.
  2521  	ReadRows(*ReadRowsRequest, BigQueryRead_ReadRowsServer) error
  2522  	// Splits a given `ReadStream` into two `ReadStream` objects. These
  2523  	// `ReadStream` objects are referred to as the primary and the residual
  2524  	// streams of the split. The original `ReadStream` can still be read from in
  2525  	// the same manner as before. Both of the returned `ReadStream` objects can
  2526  	// also be read from, and the rows returned by both child streams will be
  2527  	// the same as the rows read from the original stream.
  2528  	//
  2529  	// Moreover, the two child streams will be allocated back-to-back in the
  2530  	// original `ReadStream`. Concretely, it is guaranteed that for streams
  2531  	// original, primary, and residual, that original[0-j] = primary[0-j] and
  2532  	// original[j-n] = residual[0-m] once the streams have been read to
  2533  	// completion.
  2534  	SplitReadStream(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error)
  2535  }
  2536  
  2537  // UnimplementedBigQueryReadServer can be embedded to have forward compatible implementations.
  2538  type UnimplementedBigQueryReadServer struct {
  2539  }
  2540  
  2541  func (*UnimplementedBigQueryReadServer) CreateReadSession(context.Context, *CreateReadSessionRequest) (*ReadSession, error) {
  2542  	return nil, status1.Errorf(codes.Unimplemented, "method CreateReadSession not implemented")
  2543  }
  2544  func (*UnimplementedBigQueryReadServer) ReadRows(*ReadRowsRequest, BigQueryRead_ReadRowsServer) error {
  2545  	return status1.Errorf(codes.Unimplemented, "method ReadRows not implemented")
  2546  }
  2547  func (*UnimplementedBigQueryReadServer) SplitReadStream(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error) {
  2548  	return nil, status1.Errorf(codes.Unimplemented, "method SplitReadStream not implemented")
  2549  }
  2550  
  2551  func RegisterBigQueryReadServer(s *grpc.Server, srv BigQueryReadServer) {
  2552  	s.RegisterService(&_BigQueryRead_serviceDesc, srv)
  2553  }
  2554  
  2555  func _BigQueryRead_CreateReadSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2556  	in := new(CreateReadSessionRequest)
  2557  	if err := dec(in); err != nil {
  2558  		return nil, err
  2559  	}
  2560  	if interceptor == nil {
  2561  		return srv.(BigQueryReadServer).CreateReadSession(ctx, in)
  2562  	}
  2563  	info := &grpc.UnaryServerInfo{
  2564  		Server:     srv,
  2565  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryRead/CreateReadSession",
  2566  	}
  2567  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2568  		return srv.(BigQueryReadServer).CreateReadSession(ctx, req.(*CreateReadSessionRequest))
  2569  	}
  2570  	return interceptor(ctx, in, info, handler)
  2571  }
  2572  
  2573  func _BigQueryRead_ReadRows_Handler(srv interface{}, stream grpc.ServerStream) error {
  2574  	m := new(ReadRowsRequest)
  2575  	if err := stream.RecvMsg(m); err != nil {
  2576  		return err
  2577  	}
  2578  	return srv.(BigQueryReadServer).ReadRows(m, &bigQueryReadReadRowsServer{stream})
  2579  }
  2580  
  2581  type BigQueryRead_ReadRowsServer interface {
  2582  	Send(*ReadRowsResponse) error
  2583  	grpc.ServerStream
  2584  }
  2585  
  2586  type bigQueryReadReadRowsServer struct {
  2587  	grpc.ServerStream
  2588  }
  2589  
  2590  func (x *bigQueryReadReadRowsServer) Send(m *ReadRowsResponse) error {
  2591  	return x.ServerStream.SendMsg(m)
  2592  }
  2593  
  2594  func _BigQueryRead_SplitReadStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2595  	in := new(SplitReadStreamRequest)
  2596  	if err := dec(in); err != nil {
  2597  		return nil, err
  2598  	}
  2599  	if interceptor == nil {
  2600  		return srv.(BigQueryReadServer).SplitReadStream(ctx, in)
  2601  	}
  2602  	info := &grpc.UnaryServerInfo{
  2603  		Server:     srv,
  2604  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryRead/SplitReadStream",
  2605  	}
  2606  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2607  		return srv.(BigQueryReadServer).SplitReadStream(ctx, req.(*SplitReadStreamRequest))
  2608  	}
  2609  	return interceptor(ctx, in, info, handler)
  2610  }
  2611  
  2612  var _BigQueryRead_serviceDesc = grpc.ServiceDesc{
  2613  	ServiceName: "google.cloud.bigquery.storage.v1beta2.BigQueryRead",
  2614  	HandlerType: (*BigQueryReadServer)(nil),
  2615  	Methods: []grpc.MethodDesc{
  2616  		{
  2617  			MethodName: "CreateReadSession",
  2618  			Handler:    _BigQueryRead_CreateReadSession_Handler,
  2619  		},
  2620  		{
  2621  			MethodName: "SplitReadStream",
  2622  			Handler:    _BigQueryRead_SplitReadStream_Handler,
  2623  		},
  2624  	},
  2625  	Streams: []grpc.StreamDesc{
  2626  		{
  2627  			StreamName:    "ReadRows",
  2628  			Handler:       _BigQueryRead_ReadRows_Handler,
  2629  			ServerStreams: true,
  2630  		},
  2631  	},
  2632  	Metadata: "google/cloud/bigquery/storage/v1beta2/storage.proto",
  2633  }
  2634  
  2635  // BigQueryWriteClient is the client API for BigQueryWrite service.
  2636  //
  2637  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  2638  //
  2639  // Deprecated: Do not use.
  2640  type BigQueryWriteClient interface {
  2641  	// Deprecated: Do not use.
  2642  	// Creates a write stream to the given table.
  2643  	// Additionally, every table has a special COMMITTED stream named '_default'
  2644  	// to which data can be written. This stream doesn't need to be created using
  2645  	// CreateWriteStream. It is a stream that can be used simultaneously by any
  2646  	// number of clients. Data written to this stream is considered committed as
  2647  	// soon as an acknowledgement is received.
  2648  	CreateWriteStream(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
  2649  	// Deprecated: Do not use.
  2650  	// Appends data to the given stream.
  2651  	//
  2652  	// If `offset` is specified, the `offset` is checked against the end of
  2653  	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
  2654  	// attempt is made to append to an offset beyond the current end of the stream
  2655  	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
  2656  	// written to. User can retry with adjusted offset within the same RPC
  2657  	// stream. If `offset` is not specified, append happens at the end of the
  2658  	// stream.
  2659  	//
  2660  	// The response contains the offset at which the append happened. Responses
  2661  	// are received in the same order in which requests are sent. There will be
  2662  	// one response for each successful request. If the `offset` is not set in
  2663  	// response, it means append didn't happen due to some errors. If one request
  2664  	// fails, all the subsequent requests will also fail until a success request
  2665  	// is made again.
  2666  	//
  2667  	// If the stream is of `PENDING` type, data will only be available for read
  2668  	// operations after the stream is committed.
  2669  	AppendRows(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error)
  2670  	// Deprecated: Do not use.
  2671  	// Gets a write stream.
  2672  	GetWriteStream(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
  2673  	// Deprecated: Do not use.
  2674  	// Finalize a write stream so that no new data can be appended to the
  2675  	// stream. Finalize is not supported on the '_default' stream.
  2676  	FinalizeWriteStream(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error)
  2677  	// Deprecated: Do not use.
  2678  	// Atomically commits a group of `PENDING` streams that belong to the same
  2679  	// `parent` table.
  2680  	// Streams must be finalized before commit and cannot be committed multiple
  2681  	// times. Once a stream is committed, data in the stream becomes available
  2682  	// for read operations.
  2683  	BatchCommitWriteStreams(ctx context.Context, in *BatchCommitWriteStreamsRequest, opts ...grpc.CallOption) (*BatchCommitWriteStreamsResponse, error)
  2684  	// Deprecated: Do not use.
  2685  	// Flushes rows to a BUFFERED stream.
  2686  	// If users are appending rows to BUFFERED stream, flush operation is
  2687  	// required in order for the rows to become available for reading. A
  2688  	// Flush operation flushes up to any previously flushed offset in a BUFFERED
  2689  	// stream, to the offset specified in the request.
  2690  	// Flush is not supported on the _default stream, since it is not BUFFERED.
  2691  	FlushRows(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error)
  2692  }
  2693  
  2694  type bigQueryWriteClient struct {
  2695  	cc grpc.ClientConnInterface
  2696  }
  2697  
  2698  // Deprecated: Do not use.
  2699  func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient {
  2700  	return &bigQueryWriteClient{cc}
  2701  }
  2702  
  2703  // Deprecated: Do not use.
  2704  func (c *bigQueryWriteClient) CreateWriteStream(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error) {
  2705  	out := new(WriteStream)
  2706  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/CreateWriteStream", in, out, opts...)
  2707  	if err != nil {
  2708  		return nil, err
  2709  	}
  2710  	return out, nil
  2711  }
  2712  
  2713  // Deprecated: Do not use.
  2714  func (c *bigQueryWriteClient) AppendRows(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error) {
  2715  	stream, err := c.cc.NewStream(ctx, &_BigQueryWrite_serviceDesc.Streams[0], "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/AppendRows", opts...)
  2716  	if err != nil {
  2717  		return nil, err
  2718  	}
  2719  	x := &bigQueryWriteAppendRowsClient{stream}
  2720  	return x, nil
  2721  }
  2722  
  2723  type BigQueryWrite_AppendRowsClient interface {
  2724  	Send(*AppendRowsRequest) error
  2725  	Recv() (*AppendRowsResponse, error)
  2726  	grpc.ClientStream
  2727  }
  2728  
  2729  type bigQueryWriteAppendRowsClient struct {
  2730  	grpc.ClientStream
  2731  }
  2732  
  2733  func (x *bigQueryWriteAppendRowsClient) Send(m *AppendRowsRequest) error {
  2734  	return x.ClientStream.SendMsg(m)
  2735  }
  2736  
  2737  func (x *bigQueryWriteAppendRowsClient) Recv() (*AppendRowsResponse, error) {
  2738  	m := new(AppendRowsResponse)
  2739  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2740  		return nil, err
  2741  	}
  2742  	return m, nil
  2743  }
  2744  
  2745  // Deprecated: Do not use.
  2746  func (c *bigQueryWriteClient) GetWriteStream(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error) {
  2747  	out := new(WriteStream)
  2748  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/GetWriteStream", in, out, opts...)
  2749  	if err != nil {
  2750  		return nil, err
  2751  	}
  2752  	return out, nil
  2753  }
  2754  
  2755  // Deprecated: Do not use.
  2756  func (c *bigQueryWriteClient) FinalizeWriteStream(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error) {
  2757  	out := new(FinalizeWriteStreamResponse)
  2758  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/FinalizeWriteStream", in, out, opts...)
  2759  	if err != nil {
  2760  		return nil, err
  2761  	}
  2762  	return out, nil
  2763  }
  2764  
  2765  // Deprecated: Do not use.
  2766  func (c *bigQueryWriteClient) BatchCommitWriteStreams(ctx context.Context, in *BatchCommitWriteStreamsRequest, opts ...grpc.CallOption) (*BatchCommitWriteStreamsResponse, error) {
  2767  	out := new(BatchCommitWriteStreamsResponse)
  2768  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/BatchCommitWriteStreams", in, out, opts...)
  2769  	if err != nil {
  2770  		return nil, err
  2771  	}
  2772  	return out, nil
  2773  }
  2774  
  2775  // Deprecated: Do not use.
  2776  func (c *bigQueryWriteClient) FlushRows(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error) {
  2777  	out := new(FlushRowsResponse)
  2778  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/FlushRows", in, out, opts...)
  2779  	if err != nil {
  2780  		return nil, err
  2781  	}
  2782  	return out, nil
  2783  }
  2784  
  2785  // BigQueryWriteServer is the server API for BigQueryWrite service.
  2786  //
  2787  // Deprecated: Do not use.
  2788  type BigQueryWriteServer interface {
  2789  	// Deprecated: Do not use.
  2790  	// Creates a write stream to the given table.
  2791  	// Additionally, every table has a special COMMITTED stream named '_default'
  2792  	// to which data can be written. This stream doesn't need to be created using
  2793  	// CreateWriteStream. It is a stream that can be used simultaneously by any
  2794  	// number of clients. Data written to this stream is considered committed as
  2795  	// soon as an acknowledgement is received.
  2796  	CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error)
  2797  	// Deprecated: Do not use.
  2798  	// Appends data to the given stream.
  2799  	//
  2800  	// If `offset` is specified, the `offset` is checked against the end of
  2801  	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
  2802  	// attempt is made to append to an offset beyond the current end of the stream
  2803  	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
  2804  	// written to. User can retry with adjusted offset within the same RPC
  2805  	// stream. If `offset` is not specified, append happens at the end of the
  2806  	// stream.
  2807  	//
  2808  	// The response contains the offset at which the append happened. Responses
  2809  	// are received in the same order in which requests are sent. There will be
  2810  	// one response for each successful request. If the `offset` is not set in
  2811  	// response, it means append didn't happen due to some errors. If one request
  2812  	// fails, all the subsequent requests will also fail until a success request
  2813  	// is made again.
  2814  	//
  2815  	// If the stream is of `PENDING` type, data will only be available for read
  2816  	// operations after the stream is committed.
  2817  	AppendRows(BigQueryWrite_AppendRowsServer) error
  2818  	// Deprecated: Do not use.
  2819  	// Gets a write stream.
  2820  	GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error)
  2821  	// Deprecated: Do not use.
  2822  	// Finalize a write stream so that no new data can be appended to the
  2823  	// stream. Finalize is not supported on the '_default' stream.
  2824  	FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error)
  2825  	// Deprecated: Do not use.
  2826  	// Atomically commits a group of `PENDING` streams that belong to the same
  2827  	// `parent` table.
  2828  	// Streams must be finalized before commit and cannot be committed multiple
  2829  	// times. Once a stream is committed, data in the stream becomes available
  2830  	// for read operations.
  2831  	BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error)
  2832  	// Deprecated: Do not use.
  2833  	// Flushes rows to a BUFFERED stream.
  2834  	// If users are appending rows to BUFFERED stream, flush operation is
  2835  	// required in order for the rows to become available for reading. A
  2836  	// Flush operation flushes up to any previously flushed offset in a BUFFERED
  2837  	// stream, to the offset specified in the request.
  2838  	// Flush is not supported on the _default stream, since it is not BUFFERED.
  2839  	FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error)
  2840  }
  2841  
  2842  // UnimplementedBigQueryWriteServer can be embedded to have forward compatible implementations.
  2843  type UnimplementedBigQueryWriteServer struct {
  2844  }
  2845  
  2846  func (*UnimplementedBigQueryWriteServer) CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error) {
  2847  	return nil, status1.Errorf(codes.Unimplemented, "method CreateWriteStream not implemented")
  2848  }
  2849  func (*UnimplementedBigQueryWriteServer) AppendRows(BigQueryWrite_AppendRowsServer) error {
  2850  	return status1.Errorf(codes.Unimplemented, "method AppendRows not implemented")
  2851  }
  2852  func (*UnimplementedBigQueryWriteServer) GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error) {
  2853  	return nil, status1.Errorf(codes.Unimplemented, "method GetWriteStream not implemented")
  2854  }
  2855  func (*UnimplementedBigQueryWriteServer) FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error) {
  2856  	return nil, status1.Errorf(codes.Unimplemented, "method FinalizeWriteStream not implemented")
  2857  }
  2858  func (*UnimplementedBigQueryWriteServer) BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error) {
  2859  	return nil, status1.Errorf(codes.Unimplemented, "method BatchCommitWriteStreams not implemented")
  2860  }
  2861  func (*UnimplementedBigQueryWriteServer) FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error) {
  2862  	return nil, status1.Errorf(codes.Unimplemented, "method FlushRows not implemented")
  2863  }
  2864  
  2865  // Deprecated: Do not use.
  2866  func RegisterBigQueryWriteServer(s *grpc.Server, srv BigQueryWriteServer) {
  2867  	s.RegisterService(&_BigQueryWrite_serviceDesc, srv)
  2868  }
  2869  
  2870  func _BigQueryWrite_CreateWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2871  	in := new(CreateWriteStreamRequest)
  2872  	if err := dec(in); err != nil {
  2873  		return nil, err
  2874  	}
  2875  	if interceptor == nil {
  2876  		return srv.(BigQueryWriteServer).CreateWriteStream(ctx, in)
  2877  	}
  2878  	info := &grpc.UnaryServerInfo{
  2879  		Server:     srv,
  2880  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/CreateWriteStream",
  2881  	}
  2882  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2883  		return srv.(BigQueryWriteServer).CreateWriteStream(ctx, req.(*CreateWriteStreamRequest))
  2884  	}
  2885  	return interceptor(ctx, in, info, handler)
  2886  }
  2887  
  2888  func _BigQueryWrite_AppendRows_Handler(srv interface{}, stream grpc.ServerStream) error {
  2889  	return srv.(BigQueryWriteServer).AppendRows(&bigQueryWriteAppendRowsServer{stream})
  2890  }
  2891  
  2892  type BigQueryWrite_AppendRowsServer interface {
  2893  	Send(*AppendRowsResponse) error
  2894  	Recv() (*AppendRowsRequest, error)
  2895  	grpc.ServerStream
  2896  }
  2897  
  2898  type bigQueryWriteAppendRowsServer struct {
  2899  	grpc.ServerStream
  2900  }
  2901  
  2902  func (x *bigQueryWriteAppendRowsServer) Send(m *AppendRowsResponse) error {
  2903  	return x.ServerStream.SendMsg(m)
  2904  }
  2905  
  2906  func (x *bigQueryWriteAppendRowsServer) Recv() (*AppendRowsRequest, error) {
  2907  	m := new(AppendRowsRequest)
  2908  	if err := x.ServerStream.RecvMsg(m); err != nil {
  2909  		return nil, err
  2910  	}
  2911  	return m, nil
  2912  }
  2913  
  2914  func _BigQueryWrite_GetWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2915  	in := new(GetWriteStreamRequest)
  2916  	if err := dec(in); err != nil {
  2917  		return nil, err
  2918  	}
  2919  	if interceptor == nil {
  2920  		return srv.(BigQueryWriteServer).GetWriteStream(ctx, in)
  2921  	}
  2922  	info := &grpc.UnaryServerInfo{
  2923  		Server:     srv,
  2924  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/GetWriteStream",
  2925  	}
  2926  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2927  		return srv.(BigQueryWriteServer).GetWriteStream(ctx, req.(*GetWriteStreamRequest))
  2928  	}
  2929  	return interceptor(ctx, in, info, handler)
  2930  }
  2931  
  2932  func _BigQueryWrite_FinalizeWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2933  	in := new(FinalizeWriteStreamRequest)
  2934  	if err := dec(in); err != nil {
  2935  		return nil, err
  2936  	}
  2937  	if interceptor == nil {
  2938  		return srv.(BigQueryWriteServer).FinalizeWriteStream(ctx, in)
  2939  	}
  2940  	info := &grpc.UnaryServerInfo{
  2941  		Server:     srv,
  2942  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/FinalizeWriteStream",
  2943  	}
  2944  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2945  		return srv.(BigQueryWriteServer).FinalizeWriteStream(ctx, req.(*FinalizeWriteStreamRequest))
  2946  	}
  2947  	return interceptor(ctx, in, info, handler)
  2948  }
  2949  
  2950  func _BigQueryWrite_BatchCommitWriteStreams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2951  	in := new(BatchCommitWriteStreamsRequest)
  2952  	if err := dec(in); err != nil {
  2953  		return nil, err
  2954  	}
  2955  	if interceptor == nil {
  2956  		return srv.(BigQueryWriteServer).BatchCommitWriteStreams(ctx, in)
  2957  	}
  2958  	info := &grpc.UnaryServerInfo{
  2959  		Server:     srv,
  2960  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/BatchCommitWriteStreams",
  2961  	}
  2962  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2963  		return srv.(BigQueryWriteServer).BatchCommitWriteStreams(ctx, req.(*BatchCommitWriteStreamsRequest))
  2964  	}
  2965  	return interceptor(ctx, in, info, handler)
  2966  }
  2967  
  2968  func _BigQueryWrite_FlushRows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2969  	in := new(FlushRowsRequest)
  2970  	if err := dec(in); err != nil {
  2971  		return nil, err
  2972  	}
  2973  	if interceptor == nil {
  2974  		return srv.(BigQueryWriteServer).FlushRows(ctx, in)
  2975  	}
  2976  	info := &grpc.UnaryServerInfo{
  2977  		Server:     srv,
  2978  		FullMethod: "/google.cloud.bigquery.storage.v1beta2.BigQueryWrite/FlushRows",
  2979  	}
  2980  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2981  		return srv.(BigQueryWriteServer).FlushRows(ctx, req.(*FlushRowsRequest))
  2982  	}
  2983  	return interceptor(ctx, in, info, handler)
  2984  }
  2985  
  2986  var _BigQueryWrite_serviceDesc = grpc.ServiceDesc{
  2987  	ServiceName: "google.cloud.bigquery.storage.v1beta2.BigQueryWrite",
  2988  	HandlerType: (*BigQueryWriteServer)(nil),
  2989  	Methods: []grpc.MethodDesc{
  2990  		{
  2991  			MethodName: "CreateWriteStream",
  2992  			Handler:    _BigQueryWrite_CreateWriteStream_Handler,
  2993  		},
  2994  		{
  2995  			MethodName: "GetWriteStream",
  2996  			Handler:    _BigQueryWrite_GetWriteStream_Handler,
  2997  		},
  2998  		{
  2999  			MethodName: "FinalizeWriteStream",
  3000  			Handler:    _BigQueryWrite_FinalizeWriteStream_Handler,
  3001  		},
  3002  		{
  3003  			MethodName: "BatchCommitWriteStreams",
  3004  			Handler:    _BigQueryWrite_BatchCommitWriteStreams_Handler,
  3005  		},
  3006  		{
  3007  			MethodName: "FlushRows",
  3008  			Handler:    _BigQueryWrite_FlushRows_Handler,
  3009  		},
  3010  	},
  3011  	Streams: []grpc.StreamDesc{
  3012  		{
  3013  			StreamName:    "AppendRows",
  3014  			Handler:       _BigQueryWrite_AppendRows_Handler,
  3015  			ServerStreams: true,
  3016  			ClientStreams: true,
  3017  		},
  3018  	},
  3019  	Metadata: "google/cloud/bigquery/storage/v1beta2/storage.proto",
  3020  }
  3021  

View as plain text