Source file src/google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1alpha2/storage.pb.go

Documentation: google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1alpha2

     1  // Copyright 2021 Google LLC
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.25.0-devel
    18  // 	protoc        v3.13.0
    19  // source: google/cloud/bigquery/storage/v1alpha2/storage.proto
    20  
    21  package storage
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	proto "github.com/golang/protobuf/proto"
    29  	_ "google.golang.org/genproto/googleapis/api/annotations"
    30  	status "google.golang.org/genproto/googleapis/rpc/status"
    31  	grpc "google.golang.org/grpc"
    32  	codes "google.golang.org/grpc/codes"
    33  	status1 "google.golang.org/grpc/status"
    34  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    35  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    36  	_ "google.golang.org/protobuf/types/known/emptypb"
    37  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    38  	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
    39  )
    40  
    41  const (
    42  	// Verify that this generated code is sufficiently up-to-date.
    43  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    44  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    45  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    46  )
    47  
    48  // This is a compile-time assertion that a sufficiently up-to-date version
    49  // of the legacy proto package is being used.
    50  const _ = proto.ProtoPackageIsVersion4
    51  
    52  // Request message for `CreateWriteStream`.
    53  type CreateWriteStreamRequest struct {
    54  	state         protoimpl.MessageState
    55  	sizeCache     protoimpl.SizeCache
    56  	unknownFields protoimpl.UnknownFields
    57  
    58  	// Required. Reference to the table to which the stream belongs, in the format
    59  	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
    60  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    61  	// Required. Stream to be created.
    62  	WriteStream *WriteStream `protobuf:"bytes,2,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
    63  }
    64  
    65  func (x *CreateWriteStreamRequest) Reset() {
    66  	*x = CreateWriteStreamRequest{}
    67  	if protoimpl.UnsafeEnabled {
    68  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[0]
    69  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    70  		ms.StoreMessageInfo(mi)
    71  	}
    72  }
    73  
    74  func (x *CreateWriteStreamRequest) String() string {
    75  	return protoimpl.X.MessageStringOf(x)
    76  }
    77  
    78  func (*CreateWriteStreamRequest) ProtoMessage() {}
    79  
    80  func (x *CreateWriteStreamRequest) ProtoReflect() protoreflect.Message {
    81  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[0]
    82  	if protoimpl.UnsafeEnabled && x != nil {
    83  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    84  		if ms.LoadMessageInfo() == nil {
    85  			ms.StoreMessageInfo(mi)
    86  		}
    87  		return ms
    88  	}
    89  	return mi.MessageOf(x)
    90  }
    91  
    92  // Deprecated: Use CreateWriteStreamRequest.ProtoReflect.Descriptor instead.
    93  func (*CreateWriteStreamRequest) Descriptor() ([]byte, []int) {
    94  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{0}
    95  }
    96  
    97  func (x *CreateWriteStreamRequest) GetParent() string {
    98  	if x != nil {
    99  		return x.Parent
   100  	}
   101  	return ""
   102  }
   103  
   104  func (x *CreateWriteStreamRequest) GetWriteStream() *WriteStream {
   105  	if x != nil {
   106  		return x.WriteStream
   107  	}
   108  	return nil
   109  }
   110  
   111  // Request message for `AppendRows`.
   112  type AppendRowsRequest struct {
   113  	state         protoimpl.MessageState
   114  	sizeCache     protoimpl.SizeCache
   115  	unknownFields protoimpl.UnknownFields
   116  
   117  	// Required. The stream that is the target of the append operation. This value must be
   118  	// specified for the initial request. If subsequent requests specify the
   119  	// stream name, it must equal to the value provided in the first request.
   120  	// To write to the _default stream, populate this field with a string in the
   121  	// format `projects/{project}/datasets/{dataset}/tables/{table}/_default`.
   122  	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
   123  	// Optional. If present, the write is only performed if the next append offset is same
   124  	// as the provided value. If not present, the write is performed at the
   125  	// current end of stream. Specifying a value for this field is not allowed
   126  	// when calling AppendRows for the '_default' stream.
   127  	Offset *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
   128  	// Input rows. The `writer_schema` field must be specified at the initial
   129  	// request and currently, it will be ignored if specified in following
   130  	// requests. Following requests must have data in the same format as the
   131  	// initial request.
   132  	//
   133  	// Types that are assignable to Rows:
   134  	//	*AppendRowsRequest_ProtoRows
   135  	Rows isAppendRowsRequest_Rows `protobuf_oneof:"rows"`
   136  	// Only initial request setting is respected. If true, drop unknown input
   137  	// fields. Otherwise, the extra fields will cause append to fail. Default
   138  	// value is false.
   139  	IgnoreUnknownFields bool `protobuf:"varint,5,opt,name=ignore_unknown_fields,json=ignoreUnknownFields,proto3" json:"ignore_unknown_fields,omitempty"`
   140  }
   141  
   142  func (x *AppendRowsRequest) Reset() {
   143  	*x = AppendRowsRequest{}
   144  	if protoimpl.UnsafeEnabled {
   145  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[1]
   146  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   147  		ms.StoreMessageInfo(mi)
   148  	}
   149  }
   150  
   151  func (x *AppendRowsRequest) String() string {
   152  	return protoimpl.X.MessageStringOf(x)
   153  }
   154  
   155  func (*AppendRowsRequest) ProtoMessage() {}
   156  
   157  func (x *AppendRowsRequest) ProtoReflect() protoreflect.Message {
   158  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[1]
   159  	if protoimpl.UnsafeEnabled && x != nil {
   160  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   161  		if ms.LoadMessageInfo() == nil {
   162  			ms.StoreMessageInfo(mi)
   163  		}
   164  		return ms
   165  	}
   166  	return mi.MessageOf(x)
   167  }
   168  
   169  // Deprecated: Use AppendRowsRequest.ProtoReflect.Descriptor instead.
   170  func (*AppendRowsRequest) Descriptor() ([]byte, []int) {
   171  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{1}
   172  }
   173  
   174  func (x *AppendRowsRequest) GetWriteStream() string {
   175  	if x != nil {
   176  		return x.WriteStream
   177  	}
   178  	return ""
   179  }
   180  
   181  func (x *AppendRowsRequest) GetOffset() *wrapperspb.Int64Value {
   182  	if x != nil {
   183  		return x.Offset
   184  	}
   185  	return nil
   186  }
   187  
   188  func (m *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows {
   189  	if m != nil {
   190  		return m.Rows
   191  	}
   192  	return nil
   193  }
   194  
   195  func (x *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData {
   196  	if x, ok := x.GetRows().(*AppendRowsRequest_ProtoRows); ok {
   197  		return x.ProtoRows
   198  	}
   199  	return nil
   200  }
   201  
   202  func (x *AppendRowsRequest) GetIgnoreUnknownFields() bool {
   203  	if x != nil {
   204  		return x.IgnoreUnknownFields
   205  	}
   206  	return false
   207  }
   208  
   209  type isAppendRowsRequest_Rows interface {
   210  	isAppendRowsRequest_Rows()
   211  }
   212  
   213  type AppendRowsRequest_ProtoRows struct {
   214  	ProtoRows *AppendRowsRequest_ProtoData `protobuf:"bytes,4,opt,name=proto_rows,json=protoRows,proto3,oneof"`
   215  }
   216  
   217  func (*AppendRowsRequest_ProtoRows) isAppendRowsRequest_Rows() {}
   218  
   219  // Response message for `AppendRows`.
   220  type AppendRowsResponse struct {
   221  	state         protoimpl.MessageState
   222  	sizeCache     protoimpl.SizeCache
   223  	unknownFields protoimpl.UnknownFields
   224  
   225  	// Types that are assignable to Response:
   226  	//	*AppendRowsResponse_Offset
   227  	//	*AppendRowsResponse_Error
   228  	Response isAppendRowsResponse_Response `protobuf_oneof:"response"`
   229  	// If backend detects a schema update, pass it to user so that user can
   230  	// use it to input new type of message. It will be empty when there is no
   231  	// schema updates.
   232  	UpdatedSchema *TableSchema `protobuf:"bytes,3,opt,name=updated_schema,json=updatedSchema,proto3" json:"updated_schema,omitempty"`
   233  }
   234  
   235  func (x *AppendRowsResponse) Reset() {
   236  	*x = AppendRowsResponse{}
   237  	if protoimpl.UnsafeEnabled {
   238  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[2]
   239  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   240  		ms.StoreMessageInfo(mi)
   241  	}
   242  }
   243  
   244  func (x *AppendRowsResponse) String() string {
   245  	return protoimpl.X.MessageStringOf(x)
   246  }
   247  
   248  func (*AppendRowsResponse) ProtoMessage() {}
   249  
   250  func (x *AppendRowsResponse) ProtoReflect() protoreflect.Message {
   251  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[2]
   252  	if protoimpl.UnsafeEnabled && x != nil {
   253  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   254  		if ms.LoadMessageInfo() == nil {
   255  			ms.StoreMessageInfo(mi)
   256  		}
   257  		return ms
   258  	}
   259  	return mi.MessageOf(x)
   260  }
   261  
   262  // Deprecated: Use AppendRowsResponse.ProtoReflect.Descriptor instead.
   263  func (*AppendRowsResponse) Descriptor() ([]byte, []int) {
   264  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{2}
   265  }
   266  
   267  func (m *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response {
   268  	if m != nil {
   269  		return m.Response
   270  	}
   271  	return nil
   272  }
   273  
   274  func (x *AppendRowsResponse) GetOffset() int64 {
   275  	if x, ok := x.GetResponse().(*AppendRowsResponse_Offset); ok {
   276  		return x.Offset
   277  	}
   278  	return 0
   279  }
   280  
   281  func (x *AppendRowsResponse) GetError() *status.Status {
   282  	if x, ok := x.GetResponse().(*AppendRowsResponse_Error); ok {
   283  		return x.Error
   284  	}
   285  	return nil
   286  }
   287  
   288  func (x *AppendRowsResponse) GetUpdatedSchema() *TableSchema {
   289  	if x != nil {
   290  		return x.UpdatedSchema
   291  	}
   292  	return nil
   293  }
   294  
   295  type isAppendRowsResponse_Response interface {
   296  	isAppendRowsResponse_Response()
   297  }
   298  
   299  type AppendRowsResponse_Offset struct {
   300  	// The row offset at which the last append occurred.
   301  	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3,oneof"`
   302  }
   303  
   304  type AppendRowsResponse_Error struct {
   305  	// Error in case of append failure. If set, it means rows are not accepted
   306  	// into the system. Users can retry or continue with other requests within
   307  	// the same connection.
   308  	// ALREADY_EXISTS: happens when offset is specified, it means the row is
   309  	//   already appended, it is safe to ignore this error.
   310  	// OUT_OF_RANGE: happens when offset is specified, it means the specified
   311  	//   offset is beyond the end of the stream.
   312  	// INVALID_ARGUMENT: error caused by malformed request or data.
   313  	// RESOURCE_EXHAUSTED: request rejected due to throttling. Only happens when
   314  	//   append without offset.
   315  	// ABORTED: request processing is aborted because of prior failures, request
   316  	//   can be retried if previous failure is fixed.
   317  	// INTERNAL: server side errors that can be retried.
   318  	Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
   319  }
   320  
   321  func (*AppendRowsResponse_Offset) isAppendRowsResponse_Response() {}
   322  
   323  func (*AppendRowsResponse_Error) isAppendRowsResponse_Response() {}
   324  
   325  // Request message for `GetWriteStreamRequest`.
   326  type GetWriteStreamRequest struct {
   327  	state         protoimpl.MessageState
   328  	sizeCache     protoimpl.SizeCache
   329  	unknownFields protoimpl.UnknownFields
   330  
   331  	// Required. Name of the stream to get, in the form of
   332  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   333  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   334  }
   335  
   336  func (x *GetWriteStreamRequest) Reset() {
   337  	*x = GetWriteStreamRequest{}
   338  	if protoimpl.UnsafeEnabled {
   339  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[3]
   340  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   341  		ms.StoreMessageInfo(mi)
   342  	}
   343  }
   344  
   345  func (x *GetWriteStreamRequest) String() string {
   346  	return protoimpl.X.MessageStringOf(x)
   347  }
   348  
   349  func (*GetWriteStreamRequest) ProtoMessage() {}
   350  
   351  func (x *GetWriteStreamRequest) ProtoReflect() protoreflect.Message {
   352  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[3]
   353  	if protoimpl.UnsafeEnabled && x != nil {
   354  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   355  		if ms.LoadMessageInfo() == nil {
   356  			ms.StoreMessageInfo(mi)
   357  		}
   358  		return ms
   359  	}
   360  	return mi.MessageOf(x)
   361  }
   362  
   363  // Deprecated: Use GetWriteStreamRequest.ProtoReflect.Descriptor instead.
   364  func (*GetWriteStreamRequest) Descriptor() ([]byte, []int) {
   365  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{3}
   366  }
   367  
   368  func (x *GetWriteStreamRequest) GetName() string {
   369  	if x != nil {
   370  		return x.Name
   371  	}
   372  	return ""
   373  }
   374  
   375  // Request message for `BatchCommitWriteStreams`.
   376  type BatchCommitWriteStreamsRequest struct {
   377  	state         protoimpl.MessageState
   378  	sizeCache     protoimpl.SizeCache
   379  	unknownFields protoimpl.UnknownFields
   380  
   381  	// Required. Parent table that all the streams should belong to, in the form of
   382  	// `projects/{project}/datasets/{dataset}/tables/{table}`.
   383  	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
   384  	// Required. The group of streams that will be committed atomically.
   385  	WriteStreams []string `protobuf:"bytes,2,rep,name=write_streams,json=writeStreams,proto3" json:"write_streams,omitempty"`
   386  }
   387  
   388  func (x *BatchCommitWriteStreamsRequest) Reset() {
   389  	*x = BatchCommitWriteStreamsRequest{}
   390  	if protoimpl.UnsafeEnabled {
   391  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[4]
   392  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   393  		ms.StoreMessageInfo(mi)
   394  	}
   395  }
   396  
   397  func (x *BatchCommitWriteStreamsRequest) String() string {
   398  	return protoimpl.X.MessageStringOf(x)
   399  }
   400  
   401  func (*BatchCommitWriteStreamsRequest) ProtoMessage() {}
   402  
   403  func (x *BatchCommitWriteStreamsRequest) ProtoReflect() protoreflect.Message {
   404  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[4]
   405  	if protoimpl.UnsafeEnabled && x != nil {
   406  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   407  		if ms.LoadMessageInfo() == nil {
   408  			ms.StoreMessageInfo(mi)
   409  		}
   410  		return ms
   411  	}
   412  	return mi.MessageOf(x)
   413  }
   414  
   415  // Deprecated: Use BatchCommitWriteStreamsRequest.ProtoReflect.Descriptor instead.
   416  func (*BatchCommitWriteStreamsRequest) Descriptor() ([]byte, []int) {
   417  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{4}
   418  }
   419  
   420  func (x *BatchCommitWriteStreamsRequest) GetParent() string {
   421  	if x != nil {
   422  		return x.Parent
   423  	}
   424  	return ""
   425  }
   426  
   427  func (x *BatchCommitWriteStreamsRequest) GetWriteStreams() []string {
   428  	if x != nil {
   429  		return x.WriteStreams
   430  	}
   431  	return nil
   432  }
   433  
   434  // Response message for `BatchCommitWriteStreams`.
   435  type BatchCommitWriteStreamsResponse struct {
   436  	state         protoimpl.MessageState
   437  	sizeCache     protoimpl.SizeCache
   438  	unknownFields protoimpl.UnknownFields
   439  
   440  	// The time at which streams were committed in microseconds granularity.
   441  	CommitTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
   442  }
   443  
   444  func (x *BatchCommitWriteStreamsResponse) Reset() {
   445  	*x = BatchCommitWriteStreamsResponse{}
   446  	if protoimpl.UnsafeEnabled {
   447  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[5]
   448  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   449  		ms.StoreMessageInfo(mi)
   450  	}
   451  }
   452  
   453  func (x *BatchCommitWriteStreamsResponse) String() string {
   454  	return protoimpl.X.MessageStringOf(x)
   455  }
   456  
   457  func (*BatchCommitWriteStreamsResponse) ProtoMessage() {}
   458  
   459  func (x *BatchCommitWriteStreamsResponse) ProtoReflect() protoreflect.Message {
   460  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[5]
   461  	if protoimpl.UnsafeEnabled && x != nil {
   462  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   463  		if ms.LoadMessageInfo() == nil {
   464  			ms.StoreMessageInfo(mi)
   465  		}
   466  		return ms
   467  	}
   468  	return mi.MessageOf(x)
   469  }
   470  
   471  // Deprecated: Use BatchCommitWriteStreamsResponse.ProtoReflect.Descriptor instead.
   472  func (*BatchCommitWriteStreamsResponse) Descriptor() ([]byte, []int) {
   473  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{5}
   474  }
   475  
   476  func (x *BatchCommitWriteStreamsResponse) GetCommitTime() *timestamppb.Timestamp {
   477  	if x != nil {
   478  		return x.CommitTime
   479  	}
   480  	return nil
   481  }
   482  
   483  // Request message for invoking `FinalizeWriteStream`.
   484  type FinalizeWriteStreamRequest struct {
   485  	state         protoimpl.MessageState
   486  	sizeCache     protoimpl.SizeCache
   487  	unknownFields protoimpl.UnknownFields
   488  
   489  	// Required. Name of the stream to finalize, in the form of
   490  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   491  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   492  }
   493  
   494  func (x *FinalizeWriteStreamRequest) Reset() {
   495  	*x = FinalizeWriteStreamRequest{}
   496  	if protoimpl.UnsafeEnabled {
   497  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[6]
   498  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   499  		ms.StoreMessageInfo(mi)
   500  	}
   501  }
   502  
   503  func (x *FinalizeWriteStreamRequest) String() string {
   504  	return protoimpl.X.MessageStringOf(x)
   505  }
   506  
   507  func (*FinalizeWriteStreamRequest) ProtoMessage() {}
   508  
   509  func (x *FinalizeWriteStreamRequest) ProtoReflect() protoreflect.Message {
   510  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[6]
   511  	if protoimpl.UnsafeEnabled && x != nil {
   512  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   513  		if ms.LoadMessageInfo() == nil {
   514  			ms.StoreMessageInfo(mi)
   515  		}
   516  		return ms
   517  	}
   518  	return mi.MessageOf(x)
   519  }
   520  
   521  // Deprecated: Use FinalizeWriteStreamRequest.ProtoReflect.Descriptor instead.
   522  func (*FinalizeWriteStreamRequest) Descriptor() ([]byte, []int) {
   523  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{6}
   524  }
   525  
   526  func (x *FinalizeWriteStreamRequest) GetName() string {
   527  	if x != nil {
   528  		return x.Name
   529  	}
   530  	return ""
   531  }
   532  
   533  // Response message for `FinalizeWriteStream`.
   534  type FinalizeWriteStreamResponse struct {
   535  	state         protoimpl.MessageState
   536  	sizeCache     protoimpl.SizeCache
   537  	unknownFields protoimpl.UnknownFields
   538  
   539  	// Number of rows in the finalized stream.
   540  	RowCount int64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
   541  }
   542  
   543  func (x *FinalizeWriteStreamResponse) Reset() {
   544  	*x = FinalizeWriteStreamResponse{}
   545  	if protoimpl.UnsafeEnabled {
   546  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[7]
   547  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   548  		ms.StoreMessageInfo(mi)
   549  	}
   550  }
   551  
   552  func (x *FinalizeWriteStreamResponse) String() string {
   553  	return protoimpl.X.MessageStringOf(x)
   554  }
   555  
   556  func (*FinalizeWriteStreamResponse) ProtoMessage() {}
   557  
   558  func (x *FinalizeWriteStreamResponse) ProtoReflect() protoreflect.Message {
   559  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[7]
   560  	if protoimpl.UnsafeEnabled && x != nil {
   561  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   562  		if ms.LoadMessageInfo() == nil {
   563  			ms.StoreMessageInfo(mi)
   564  		}
   565  		return ms
   566  	}
   567  	return mi.MessageOf(x)
   568  }
   569  
   570  // Deprecated: Use FinalizeWriteStreamResponse.ProtoReflect.Descriptor instead.
   571  func (*FinalizeWriteStreamResponse) Descriptor() ([]byte, []int) {
   572  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{7}
   573  }
   574  
   575  func (x *FinalizeWriteStreamResponse) GetRowCount() int64 {
   576  	if x != nil {
   577  		return x.RowCount
   578  	}
   579  	return 0
   580  }
   581  
   582  // Request message for `FlushRows`.
   583  type FlushRowsRequest struct {
   584  	state         protoimpl.MessageState
   585  	sizeCache     protoimpl.SizeCache
   586  	unknownFields protoimpl.UnknownFields
   587  
   588  	// Required. The stream that is the target of the flush operation.
   589  	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
   590  	// Ending offset of the flush operation. Rows before this offset(including
   591  	// this offset) will be flushed.
   592  	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
   593  }
   594  
   595  func (x *FlushRowsRequest) Reset() {
   596  	*x = FlushRowsRequest{}
   597  	if protoimpl.UnsafeEnabled {
   598  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[8]
   599  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   600  		ms.StoreMessageInfo(mi)
   601  	}
   602  }
   603  
   604  func (x *FlushRowsRequest) String() string {
   605  	return protoimpl.X.MessageStringOf(x)
   606  }
   607  
   608  func (*FlushRowsRequest) ProtoMessage() {}
   609  
   610  func (x *FlushRowsRequest) ProtoReflect() protoreflect.Message {
   611  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[8]
   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 FlushRowsRequest.ProtoReflect.Descriptor instead.
   623  func (*FlushRowsRequest) Descriptor() ([]byte, []int) {
   624  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{8}
   625  }
   626  
   627  func (x *FlushRowsRequest) GetWriteStream() string {
   628  	if x != nil {
   629  		return x.WriteStream
   630  	}
   631  	return ""
   632  }
   633  
   634  func (x *FlushRowsRequest) GetOffset() int64 {
   635  	if x != nil {
   636  		return x.Offset
   637  	}
   638  	return 0
   639  }
   640  
   641  // Respond message for `FlushRows`.
   642  type FlushRowsResponse struct {
   643  	state         protoimpl.MessageState
   644  	sizeCache     protoimpl.SizeCache
   645  	unknownFields protoimpl.UnknownFields
   646  
   647  	// The rows before this offset (including this offset) are flushed.
   648  	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
   649  }
   650  
   651  func (x *FlushRowsResponse) Reset() {
   652  	*x = FlushRowsResponse{}
   653  	if protoimpl.UnsafeEnabled {
   654  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[9]
   655  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   656  		ms.StoreMessageInfo(mi)
   657  	}
   658  }
   659  
   660  func (x *FlushRowsResponse) String() string {
   661  	return protoimpl.X.MessageStringOf(x)
   662  }
   663  
   664  func (*FlushRowsResponse) ProtoMessage() {}
   665  
   666  func (x *FlushRowsResponse) ProtoReflect() protoreflect.Message {
   667  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[9]
   668  	if protoimpl.UnsafeEnabled && x != nil {
   669  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   670  		if ms.LoadMessageInfo() == nil {
   671  			ms.StoreMessageInfo(mi)
   672  		}
   673  		return ms
   674  	}
   675  	return mi.MessageOf(x)
   676  }
   677  
   678  // Deprecated: Use FlushRowsResponse.ProtoReflect.Descriptor instead.
   679  func (*FlushRowsResponse) Descriptor() ([]byte, []int) {
   680  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{9}
   681  }
   682  
   683  func (x *FlushRowsResponse) GetOffset() int64 {
   684  	if x != nil {
   685  		return x.Offset
   686  	}
   687  	return 0
   688  }
   689  
   690  type AppendRowsRequest_ProtoData struct {
   691  	state         protoimpl.MessageState
   692  	sizeCache     protoimpl.SizeCache
   693  	unknownFields protoimpl.UnknownFields
   694  
   695  	// Proto schema used to serialize the data.
   696  	WriterSchema *ProtoSchema `protobuf:"bytes,1,opt,name=writer_schema,json=writerSchema,proto3" json:"writer_schema,omitempty"`
   697  	// Serialized row data in protobuf message format.
   698  	Rows *ProtoRows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
   699  }
   700  
   701  func (x *AppendRowsRequest_ProtoData) Reset() {
   702  	*x = AppendRowsRequest_ProtoData{}
   703  	if protoimpl.UnsafeEnabled {
   704  		mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[10]
   705  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   706  		ms.StoreMessageInfo(mi)
   707  	}
   708  }
   709  
   710  func (x *AppendRowsRequest_ProtoData) String() string {
   711  	return protoimpl.X.MessageStringOf(x)
   712  }
   713  
   714  func (*AppendRowsRequest_ProtoData) ProtoMessage() {}
   715  
   716  func (x *AppendRowsRequest_ProtoData) ProtoReflect() protoreflect.Message {
   717  	mi := &file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[10]
   718  	if protoimpl.UnsafeEnabled && x != nil {
   719  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   720  		if ms.LoadMessageInfo() == nil {
   721  			ms.StoreMessageInfo(mi)
   722  		}
   723  		return ms
   724  	}
   725  	return mi.MessageOf(x)
   726  }
   727  
   728  // Deprecated: Use AppendRowsRequest_ProtoData.ProtoReflect.Descriptor instead.
   729  func (*AppendRowsRequest_ProtoData) Descriptor() ([]byte, []int) {
   730  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP(), []int{1, 0}
   731  }
   732  
   733  func (x *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema {
   734  	if x != nil {
   735  		return x.WriterSchema
   736  	}
   737  	return nil
   738  }
   739  
   740  func (x *AppendRowsRequest_ProtoData) GetRows() *ProtoRows {
   741  	if x != nil {
   742  		return x.Rows
   743  	}
   744  	return nil
   745  }
   746  
   747  var File_google_cloud_bigquery_storage_v1alpha2_storage_proto protoreflect.FileDescriptor
   748  
   749  var file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDesc = []byte{
   750  	0x0a, 0x34, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   751  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   752  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
   753  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x26, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
   754  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
   755  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x1a, 0x1c,
   756  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74,
   757  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f,
   758  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e,
   759  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
   760  	0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72,
   761  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61,
   762  	0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   763  	0x6f, 0x1a, 0x35, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f,
   764  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
   765  	0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
   766  	0x75, 0x66, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   767  	0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f,
   768  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32,
   769  	0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67,
   770  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71,
   771  	0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x61,
   772  	0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   773  	0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
   774  	0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f,
   775  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f,
   776  	0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
   777  	0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
   778  	0x2f, 0x77, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
   779  	0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x73, 0x74, 0x61, 0x74,
   780  	0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbd, 0x01, 0x0a, 0x18, 0x43, 0x72, 0x65,
   781  	0x61, 0x74, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,
   782  	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18,
   783  	0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x2c, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x26, 0x0a, 0x24, 0x62,
   784  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67,
   785  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61,
   786  	0x62, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x5b, 0x0a, 0x0c, 0x77,
   787  	0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28,
   788  	0x0b, 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
   789  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   790  	0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65,
   791  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0b, 0x77, 0x72, 0x69,
   792  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0xf5, 0x03, 0x0a, 0x11, 0x41, 0x70, 0x70,
   793  	0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x55,
   794  	0x0a, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01,
   795  	0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69,
   796  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f,
   797  	0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69,
   798  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x53,
   799  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x38, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18,
   800  	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
   801  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x49, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c,
   802  	0x75, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12,
   803  	0x64, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x04, 0x20,
   804  	0x01, 0x28, 0x0b, 0x32, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   805  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
   806  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x41, 0x70, 0x70,
   807  	0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x50,
   808  	0x72, 0x6f, 0x74, 0x6f, 0x44, 0x61, 0x74, 0x61, 0x48, 0x00, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x74,
   809  	0x6f, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x32, 0x0a, 0x15, 0x69, 0x67, 0x6e, 0x6f, 0x72, 0x65, 0x5f,
   810  	0x75, 0x6e, 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x5f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x05,
   811  	0x20, 0x01, 0x28, 0x08, 0x52, 0x13, 0x69, 0x67, 0x6e, 0x6f, 0x72, 0x65, 0x55, 0x6e, 0x6b, 0x6e,
   812  	0x6f, 0x77, 0x6e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x1a, 0xac, 0x01, 0x0a, 0x09, 0x50, 0x72,
   813  	0x6f, 0x74, 0x6f, 0x44, 0x61, 0x74, 0x61, 0x12, 0x58, 0x0a, 0x0d, 0x77, 0x72, 0x69, 0x74, 0x65,
   814  	0x72, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33,
   815  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69,
   816  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76,
   817  	0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x53, 0x63, 0x68,
   818  	0x65, 0x6d, 0x61, 0x52, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x72, 0x53, 0x63, 0x68, 0x65, 0x6d,
   819  	0x61, 0x12, 0x45, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
   820  	0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
   821  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
   822  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x52, 0x6f,
   823  	0x77, 0x73, 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73,
   824  	0x22, 0xc2, 0x01, 0x0a, 0x12, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52,
   825  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x18, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
   826  	0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
   827  	0x74, 0x12, 0x2a, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
   828  	0x32, 0x12, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x74,
   829  	0x61, 0x74, 0x75, 0x73, 0x48, 0x00, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x5a, 0x0a,
   830  	0x0e, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18,
   831  	0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
   832  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
   833  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x54,
   834  	0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x0d, 0x75, 0x70, 0x64, 0x61,
   835  	0x74, 0x65, 0x64, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x0a, 0x0a, 0x08, 0x72, 0x65, 0x73,
   836  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5f, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x57, 0x72, 0x69, 0x74,
   837  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46,
   838  	0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41,
   839  	0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74,
   840  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
   841  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
   842  	0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x90, 0x01, 0x0a, 0x1e, 0x42, 0x61, 0x74, 0x63, 0x68,
   843  	0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61,
   844  	0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x06, 0x70, 0x61, 0x72,
   845  	0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x2c, 0xe0, 0x41, 0x02, 0xfa, 0x41,
   846  	0x26, 0x0a, 0x24, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61,
   847  	0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
   848  	0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12,
   849  	0x28, 0x0a, 0x0d, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
   850  	0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0c, 0x77, 0x72, 0x69,
   851  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x22, 0x5e, 0x0a, 0x1f, 0x42, 0x61, 0x74,
   852  	0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
   853  	0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3b, 0x0a, 0x0b,
   854  	0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
   855  	0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   856  	0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x63,
   857  	0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x64, 0x0a, 0x1a, 0x46, 0x69, 0x6e,
   858  	0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
   859  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
   860  	0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a, 0x62,
   861  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67,
   862  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72,
   863  	0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22,
   864  	0x3a, 0x0a, 0x1b, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65,
   865  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b,
   866  	0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28,
   867  	0x03, 0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x81, 0x01, 0x0a, 0x10,
   868  	0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
   869  	0x12, 0x55, 0x0a, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
   870  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x32, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2c, 0x0a, 0x2a,
   871  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
   872  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57,
   873  	0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0b, 0x77, 0x72, 0x69, 0x74,
   874  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
   875  	0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22,
   876  	0x2b, 0x0a, 0x11, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70,
   877  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01,
   878  	0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x32, 0xab, 0x0c, 0x0a,
   879  	0x0d, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x57, 0x72, 0x69, 0x74, 0x65, 0x12, 0xe9,
   880  	0x01, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74,
   881  	0x72, 0x65, 0x61, 0x6d, 0x12, 0x40, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   882  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   883  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x43, 0x72,
   884  	0x65, 0x61, 0x74, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
   885  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
   886  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73,
   887  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e,
   888  	0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x5d, 0x82, 0xd3, 0xe4,
   889  	0x93, 0x02, 0x41, 0x22, 0x31, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x7b,
   890  	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
   891  	0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62,
   892  	0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74,
   893  	0x72, 0x65, 0x61, 0x6d, 0xda, 0x41, 0x13, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x77, 0x72,
   894  	0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0xe4, 0x01, 0x0a, 0x0a, 0x41,
   895  	0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   896  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   897  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
   898  	0x61, 0x32, 0x2e, 0x41, 0x70, 0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71,
   899  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   900  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   901  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x41, 0x70,
   902  	0x70, 0x65, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   903  	0x22, 0x5b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22, 0x41, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
   904  	0x68, 0x61, 0x32, 0x2f, 0x7b, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61,
   905  	0x6d, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74,
   906  	0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a,
   907  	0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x01, 0x2a, 0xda, 0x41,
   908  	0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x28, 0x01, 0x30,
   909  	0x01, 0x12, 0xd1, 0x01, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74,
   910  	0x72, 0x65, 0x61, 0x6d, 0x12, 0x3d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   911  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   912  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x47, 0x65,
   913  	0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75,
   914  	0x65, 0x73, 0x74, 0x1a, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   915  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
   916  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69,
   917  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e,
   918  	0x22, 0x39, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
   919  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74,
   920  	0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a,
   921  	0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x01, 0x2a, 0xda, 0x41,
   922  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xeb, 0x01, 0x0a, 0x13, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69,
   923  	0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x42, 0x2e,
   924  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
   925  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
   926  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x57,
   927  	0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
   928  	0x74, 0x1a, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
   929  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   930  	0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x46, 0x69, 0x6e, 0x61, 0x6c,
   931  	0x69, 0x7a, 0x65, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,
   932  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e, 0x22, 0x39,
   933  	0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
   934  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73,
   935  	0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x73,
   936  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e,
   937  	0x61, 0x6d, 0x65, 0x12, 0xee, 0x01, 0x0a, 0x17, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d,
   938  	0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12,
   939  	0x46, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
   940  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
   941  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f,
   942  	0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
   943  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   944  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
   945  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32,
   946  	0x2e, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x57, 0x72, 0x69, 0x74,
   947  	0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   948  	0x22, 0x42, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x33, 0x12, 0x31, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
   949  	0x68, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
   950  	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f,
   951  	0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x06, 0x70, 0x61,
   952  	0x72, 0x65, 0x6e, 0x74, 0x12, 0xdd, 0x01, 0x0a, 0x09, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f,
   953  	0x77, 0x73, 0x12, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
   954  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
   955  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x46, 0x6c, 0x75, 0x73,
   956  	0x68, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x39, 0x2e, 0x67,
   957  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
   958  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61,
   959  	0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x52, 0x6f, 0x77, 0x73, 0x52,
   960  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22,
   961  	0x41, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x7b, 0x77, 0x72, 0x69, 0x74,
   962  	0x65, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
   963  	0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x74,
   964  	0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f,
   965  	0x2a, 0x7d, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0c, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74,
   966  	0x72, 0x65, 0x61, 0x6d, 0x1a, 0xb3, 0x01, 0x88, 0x02, 0x01, 0xca, 0x41, 0x1e, 0x62, 0x69, 0x67,
   967  	0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f,
   968  	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x8b, 0x01, 0x68,
   969  	0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   970  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62,
   971  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f,
   972  	0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63,
   973  	0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
   974  	0x2e, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2c, 0x68, 0x74, 0x74, 0x70,
   975  	0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
   976  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75,
   977  	0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x7b, 0x0a, 0x2a, 0x63, 0x6f,
   978  	0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
   979  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
   980  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x5a, 0x4d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   981  	0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70,
   982  	0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f,
   983  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73,
   984  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x3b,
   985  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   986  }
   987  
   988  var (
   989  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescOnce sync.Once
   990  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescData = file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDesc
   991  )
   992  
   993  func file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescGZIP() []byte {
   994  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescOnce.Do(func() {
   995  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescData)
   996  	})
   997  	return file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDescData
   998  }
   999  
  1000  var file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
  1001  var file_google_cloud_bigquery_storage_v1alpha2_storage_proto_goTypes = []interface{}{
  1002  	(*CreateWriteStreamRequest)(nil),        // 0: google.cloud.bigquery.storage.v1alpha2.CreateWriteStreamRequest
  1003  	(*AppendRowsRequest)(nil),               // 1: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest
  1004  	(*AppendRowsResponse)(nil),              // 2: google.cloud.bigquery.storage.v1alpha2.AppendRowsResponse
  1005  	(*GetWriteStreamRequest)(nil),           // 3: google.cloud.bigquery.storage.v1alpha2.GetWriteStreamRequest
  1006  	(*BatchCommitWriteStreamsRequest)(nil),  // 4: google.cloud.bigquery.storage.v1alpha2.BatchCommitWriteStreamsRequest
  1007  	(*BatchCommitWriteStreamsResponse)(nil), // 5: google.cloud.bigquery.storage.v1alpha2.BatchCommitWriteStreamsResponse
  1008  	(*FinalizeWriteStreamRequest)(nil),      // 6: google.cloud.bigquery.storage.v1alpha2.FinalizeWriteStreamRequest
  1009  	(*FinalizeWriteStreamResponse)(nil),     // 7: google.cloud.bigquery.storage.v1alpha2.FinalizeWriteStreamResponse
  1010  	(*FlushRowsRequest)(nil),                // 8: google.cloud.bigquery.storage.v1alpha2.FlushRowsRequest
  1011  	(*FlushRowsResponse)(nil),               // 9: google.cloud.bigquery.storage.v1alpha2.FlushRowsResponse
  1012  	(*AppendRowsRequest_ProtoData)(nil),     // 10: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.ProtoData
  1013  	(*WriteStream)(nil),                     // 11: google.cloud.bigquery.storage.v1alpha2.WriteStream
  1014  	(*wrapperspb.Int64Value)(nil),           // 12: google.protobuf.Int64Value
  1015  	(*status.Status)(nil),                   // 13: google.rpc.Status
  1016  	(*TableSchema)(nil),                     // 14: google.cloud.bigquery.storage.v1alpha2.TableSchema
  1017  	(*timestamppb.Timestamp)(nil),           // 15: google.protobuf.Timestamp
  1018  	(*ProtoSchema)(nil),                     // 16: google.cloud.bigquery.storage.v1alpha2.ProtoSchema
  1019  	(*ProtoRows)(nil),                       // 17: google.cloud.bigquery.storage.v1alpha2.ProtoRows
  1020  }
  1021  var file_google_cloud_bigquery_storage_v1alpha2_storage_proto_depIdxs = []int32{
  1022  	11, // 0: google.cloud.bigquery.storage.v1alpha2.CreateWriteStreamRequest.write_stream:type_name -> google.cloud.bigquery.storage.v1alpha2.WriteStream
  1023  	12, // 1: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.offset:type_name -> google.protobuf.Int64Value
  1024  	10, // 2: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.proto_rows:type_name -> google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.ProtoData
  1025  	13, // 3: google.cloud.bigquery.storage.v1alpha2.AppendRowsResponse.error:type_name -> google.rpc.Status
  1026  	14, // 4: google.cloud.bigquery.storage.v1alpha2.AppendRowsResponse.updated_schema:type_name -> google.cloud.bigquery.storage.v1alpha2.TableSchema
  1027  	15, // 5: google.cloud.bigquery.storage.v1alpha2.BatchCommitWriteStreamsResponse.commit_time:type_name -> google.protobuf.Timestamp
  1028  	16, // 6: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.ProtoData.writer_schema:type_name -> google.cloud.bigquery.storage.v1alpha2.ProtoSchema
  1029  	17, // 7: google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest.ProtoData.rows:type_name -> google.cloud.bigquery.storage.v1alpha2.ProtoRows
  1030  	0,  // 8: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.CreateWriteStream:input_type -> google.cloud.bigquery.storage.v1alpha2.CreateWriteStreamRequest
  1031  	1,  // 9: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.AppendRows:input_type -> google.cloud.bigquery.storage.v1alpha2.AppendRowsRequest
  1032  	3,  // 10: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.GetWriteStream:input_type -> google.cloud.bigquery.storage.v1alpha2.GetWriteStreamRequest
  1033  	6,  // 11: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.FinalizeWriteStream:input_type -> google.cloud.bigquery.storage.v1alpha2.FinalizeWriteStreamRequest
  1034  	4,  // 12: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.BatchCommitWriteStreams:input_type -> google.cloud.bigquery.storage.v1alpha2.BatchCommitWriteStreamsRequest
  1035  	8,  // 13: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.FlushRows:input_type -> google.cloud.bigquery.storage.v1alpha2.FlushRowsRequest
  1036  	11, // 14: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.CreateWriteStream:output_type -> google.cloud.bigquery.storage.v1alpha2.WriteStream
  1037  	2,  // 15: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.AppendRows:output_type -> google.cloud.bigquery.storage.v1alpha2.AppendRowsResponse
  1038  	11, // 16: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.GetWriteStream:output_type -> google.cloud.bigquery.storage.v1alpha2.WriteStream
  1039  	7,  // 17: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.FinalizeWriteStream:output_type -> google.cloud.bigquery.storage.v1alpha2.FinalizeWriteStreamResponse
  1040  	5,  // 18: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.BatchCommitWriteStreams:output_type -> google.cloud.bigquery.storage.v1alpha2.BatchCommitWriteStreamsResponse
  1041  	9,  // 19: google.cloud.bigquery.storage.v1alpha2.BigQueryWrite.FlushRows:output_type -> google.cloud.bigquery.storage.v1alpha2.FlushRowsResponse
  1042  	14, // [14:20] is the sub-list for method output_type
  1043  	8,  // [8:14] is the sub-list for method input_type
  1044  	8,  // [8:8] is the sub-list for extension type_name
  1045  	8,  // [8:8] is the sub-list for extension extendee
  1046  	0,  // [0:8] is the sub-list for field type_name
  1047  }
  1048  
  1049  func init() { file_google_cloud_bigquery_storage_v1alpha2_storage_proto_init() }
  1050  func file_google_cloud_bigquery_storage_v1alpha2_storage_proto_init() {
  1051  	if File_google_cloud_bigquery_storage_v1alpha2_storage_proto != nil {
  1052  		return
  1053  	}
  1054  	file_google_cloud_bigquery_storage_v1alpha2_protobuf_proto_init()
  1055  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_init()
  1056  	file_google_cloud_bigquery_storage_v1alpha2_table_proto_init()
  1057  	if !protoimpl.UnsafeEnabled {
  1058  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1059  			switch v := v.(*CreateWriteStreamRequest); i {
  1060  			case 0:
  1061  				return &v.state
  1062  			case 1:
  1063  				return &v.sizeCache
  1064  			case 2:
  1065  				return &v.unknownFields
  1066  			default:
  1067  				return nil
  1068  			}
  1069  		}
  1070  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1071  			switch v := v.(*AppendRowsRequest); i {
  1072  			case 0:
  1073  				return &v.state
  1074  			case 1:
  1075  				return &v.sizeCache
  1076  			case 2:
  1077  				return &v.unknownFields
  1078  			default:
  1079  				return nil
  1080  			}
  1081  		}
  1082  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1083  			switch v := v.(*AppendRowsResponse); i {
  1084  			case 0:
  1085  				return &v.state
  1086  			case 1:
  1087  				return &v.sizeCache
  1088  			case 2:
  1089  				return &v.unknownFields
  1090  			default:
  1091  				return nil
  1092  			}
  1093  		}
  1094  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1095  			switch v := v.(*GetWriteStreamRequest); i {
  1096  			case 0:
  1097  				return &v.state
  1098  			case 1:
  1099  				return &v.sizeCache
  1100  			case 2:
  1101  				return &v.unknownFields
  1102  			default:
  1103  				return nil
  1104  			}
  1105  		}
  1106  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1107  			switch v := v.(*BatchCommitWriteStreamsRequest); i {
  1108  			case 0:
  1109  				return &v.state
  1110  			case 1:
  1111  				return &v.sizeCache
  1112  			case 2:
  1113  				return &v.unknownFields
  1114  			default:
  1115  				return nil
  1116  			}
  1117  		}
  1118  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1119  			switch v := v.(*BatchCommitWriteStreamsResponse); i {
  1120  			case 0:
  1121  				return &v.state
  1122  			case 1:
  1123  				return &v.sizeCache
  1124  			case 2:
  1125  				return &v.unknownFields
  1126  			default:
  1127  				return nil
  1128  			}
  1129  		}
  1130  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1131  			switch v := v.(*FinalizeWriteStreamRequest); i {
  1132  			case 0:
  1133  				return &v.state
  1134  			case 1:
  1135  				return &v.sizeCache
  1136  			case 2:
  1137  				return &v.unknownFields
  1138  			default:
  1139  				return nil
  1140  			}
  1141  		}
  1142  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1143  			switch v := v.(*FinalizeWriteStreamResponse); i {
  1144  			case 0:
  1145  				return &v.state
  1146  			case 1:
  1147  				return &v.sizeCache
  1148  			case 2:
  1149  				return &v.unknownFields
  1150  			default:
  1151  				return nil
  1152  			}
  1153  		}
  1154  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1155  			switch v := v.(*FlushRowsRequest); i {
  1156  			case 0:
  1157  				return &v.state
  1158  			case 1:
  1159  				return &v.sizeCache
  1160  			case 2:
  1161  				return &v.unknownFields
  1162  			default:
  1163  				return nil
  1164  			}
  1165  		}
  1166  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1167  			switch v := v.(*FlushRowsResponse); i {
  1168  			case 0:
  1169  				return &v.state
  1170  			case 1:
  1171  				return &v.sizeCache
  1172  			case 2:
  1173  				return &v.unknownFields
  1174  			default:
  1175  				return nil
  1176  			}
  1177  		}
  1178  		file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1179  			switch v := v.(*AppendRowsRequest_ProtoData); i {
  1180  			case 0:
  1181  				return &v.state
  1182  			case 1:
  1183  				return &v.sizeCache
  1184  			case 2:
  1185  				return &v.unknownFields
  1186  			default:
  1187  				return nil
  1188  			}
  1189  		}
  1190  	}
  1191  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[1].OneofWrappers = []interface{}{
  1192  		(*AppendRowsRequest_ProtoRows)(nil),
  1193  	}
  1194  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes[2].OneofWrappers = []interface{}{
  1195  		(*AppendRowsResponse_Offset)(nil),
  1196  		(*AppendRowsResponse_Error)(nil),
  1197  	}
  1198  	type x struct{}
  1199  	out := protoimpl.TypeBuilder{
  1200  		File: protoimpl.DescBuilder{
  1201  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1202  			RawDescriptor: file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDesc,
  1203  			NumEnums:      0,
  1204  			NumMessages:   11,
  1205  			NumExtensions: 0,
  1206  			NumServices:   1,
  1207  		},
  1208  		GoTypes:           file_google_cloud_bigquery_storage_v1alpha2_storage_proto_goTypes,
  1209  		DependencyIndexes: file_google_cloud_bigquery_storage_v1alpha2_storage_proto_depIdxs,
  1210  		MessageInfos:      file_google_cloud_bigquery_storage_v1alpha2_storage_proto_msgTypes,
  1211  	}.Build()
  1212  	File_google_cloud_bigquery_storage_v1alpha2_storage_proto = out.File
  1213  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_rawDesc = nil
  1214  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_goTypes = nil
  1215  	file_google_cloud_bigquery_storage_v1alpha2_storage_proto_depIdxs = nil
  1216  }
  1217  
  1218  // Reference imports to suppress errors if they are not otherwise used.
  1219  var _ context.Context
  1220  var _ grpc.ClientConnInterface
  1221  
  1222  // This is a compile-time assertion to ensure that this generated file
  1223  // is compatible with the grpc package it is being compiled against.
  1224  const _ = grpc.SupportPackageIsVersion6
  1225  
  1226  // BigQueryWriteClient is the client API for BigQueryWrite service.
  1227  //
  1228  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1229  //
  1230  // Deprecated: Do not use.
  1231  type BigQueryWriteClient interface {
  1232  	// Creates a write stream to the given table.
  1233  	// Additionally, every table has a special COMMITTED stream named '_default'
  1234  	// to which data can be written. This stream doesn't need to be created using
  1235  	// CreateWriteStream. It is a stream that can be used simultaneously by any
  1236  	// number of clients. Data written to this stream is considered committed as
  1237  	// soon as an acknowledgement is received.
  1238  	CreateWriteStream(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
  1239  	// Appends data to the given stream.
  1240  	//
  1241  	// If `offset` is specified, the `offset` is checked against the end of
  1242  	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
  1243  	// attempt is made to append to an offset beyond the current end of the stream
  1244  	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
  1245  	// written to. User can retry with adjusted offset within the same RPC
  1246  	// stream. If `offset` is not specified, append happens at the end of the
  1247  	// stream.
  1248  	//
  1249  	// The response contains the offset at which the append happened. Responses
  1250  	// are received in the same order in which requests are sent. There will be
  1251  	// one response for each successful request. If the `offset` is not set in
  1252  	// response, it means append didn't happen due to some errors. If one request
  1253  	// fails, all the subsequent requests will also fail until a success request
  1254  	// is made again.
  1255  	//
  1256  	// If the stream is of `PENDING` type, data will only be available for read
  1257  	// operations after the stream is committed.
  1258  	AppendRows(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error)
  1259  	// Gets a write stream.
  1260  	GetWriteStream(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
  1261  	// Finalize a write stream so that no new data can be appended to the
  1262  	// stream. Finalize is not supported on the '_default' stream.
  1263  	FinalizeWriteStream(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error)
  1264  	// Atomically commits a group of `PENDING` streams that belong to the same
  1265  	// `parent` table.
  1266  	// Streams must be finalized before commit and cannot be committed multiple
  1267  	// times. Once a stream is committed, data in the stream becomes available
  1268  	// for read operations.
  1269  	BatchCommitWriteStreams(ctx context.Context, in *BatchCommitWriteStreamsRequest, opts ...grpc.CallOption) (*BatchCommitWriteStreamsResponse, error)
  1270  	// Flushes rows to a BUFFERED stream.
  1271  	// If users are appending rows to BUFFERED stream, flush operation is
  1272  	// required in order for the rows to become available for reading. A
  1273  	// Flush operation flushes up to any previously flushed offset in a BUFFERED
  1274  	// stream, to the offset specified in the request.
  1275  	// Flush is not supported on the _default stream, since it is not BUFFERED.
  1276  	FlushRows(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error)
  1277  }
  1278  
  1279  type bigQueryWriteClient struct {
  1280  	cc grpc.ClientConnInterface
  1281  }
  1282  
  1283  // Deprecated: Do not use.
  1284  func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient {
  1285  	return &bigQueryWriteClient{cc}
  1286  }
  1287  
  1288  func (c *bigQueryWriteClient) CreateWriteStream(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error) {
  1289  	out := new(WriteStream)
  1290  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/CreateWriteStream", in, out, opts...)
  1291  	if err != nil {
  1292  		return nil, err
  1293  	}
  1294  	return out, nil
  1295  }
  1296  
  1297  func (c *bigQueryWriteClient) AppendRows(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error) {
  1298  	stream, err := c.cc.NewStream(ctx, &_BigQueryWrite_serviceDesc.Streams[0], "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/AppendRows", opts...)
  1299  	if err != nil {
  1300  		return nil, err
  1301  	}
  1302  	x := &bigQueryWriteAppendRowsClient{stream}
  1303  	return x, nil
  1304  }
  1305  
  1306  type BigQueryWrite_AppendRowsClient interface {
  1307  	Send(*AppendRowsRequest) error
  1308  	Recv() (*AppendRowsResponse, error)
  1309  	grpc.ClientStream
  1310  }
  1311  
  1312  type bigQueryWriteAppendRowsClient struct {
  1313  	grpc.ClientStream
  1314  }
  1315  
  1316  func (x *bigQueryWriteAppendRowsClient) Send(m *AppendRowsRequest) error {
  1317  	return x.ClientStream.SendMsg(m)
  1318  }
  1319  
  1320  func (x *bigQueryWriteAppendRowsClient) Recv() (*AppendRowsResponse, error) {
  1321  	m := new(AppendRowsResponse)
  1322  	if err := x.ClientStream.RecvMsg(m); err != nil {
  1323  		return nil, err
  1324  	}
  1325  	return m, nil
  1326  }
  1327  
  1328  func (c *bigQueryWriteClient) GetWriteStream(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error) {
  1329  	out := new(WriteStream)
  1330  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/GetWriteStream", in, out, opts...)
  1331  	if err != nil {
  1332  		return nil, err
  1333  	}
  1334  	return out, nil
  1335  }
  1336  
  1337  func (c *bigQueryWriteClient) FinalizeWriteStream(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error) {
  1338  	out := new(FinalizeWriteStreamResponse)
  1339  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/FinalizeWriteStream", in, out, opts...)
  1340  	if err != nil {
  1341  		return nil, err
  1342  	}
  1343  	return out, nil
  1344  }
  1345  
  1346  func (c *bigQueryWriteClient) BatchCommitWriteStreams(ctx context.Context, in *BatchCommitWriteStreamsRequest, opts ...grpc.CallOption) (*BatchCommitWriteStreamsResponse, error) {
  1347  	out := new(BatchCommitWriteStreamsResponse)
  1348  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/BatchCommitWriteStreams", in, out, opts...)
  1349  	if err != nil {
  1350  		return nil, err
  1351  	}
  1352  	return out, nil
  1353  }
  1354  
  1355  func (c *bigQueryWriteClient) FlushRows(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error) {
  1356  	out := new(FlushRowsResponse)
  1357  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/FlushRows", in, out, opts...)
  1358  	if err != nil {
  1359  		return nil, err
  1360  	}
  1361  	return out, nil
  1362  }
  1363  
  1364  // BigQueryWriteServer is the server API for BigQueryWrite service.
  1365  //
  1366  // Deprecated: Do not use.
  1367  type BigQueryWriteServer interface {
  1368  	// Creates a write stream to the given table.
  1369  	// Additionally, every table has a special COMMITTED stream named '_default'
  1370  	// to which data can be written. This stream doesn't need to be created using
  1371  	// CreateWriteStream. It is a stream that can be used simultaneously by any
  1372  	// number of clients. Data written to this stream is considered committed as
  1373  	// soon as an acknowledgement is received.
  1374  	CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error)
  1375  	// Appends data to the given stream.
  1376  	//
  1377  	// If `offset` is specified, the `offset` is checked against the end of
  1378  	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
  1379  	// attempt is made to append to an offset beyond the current end of the stream
  1380  	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
  1381  	// written to. User can retry with adjusted offset within the same RPC
  1382  	// stream. If `offset` is not specified, append happens at the end of the
  1383  	// stream.
  1384  	//
  1385  	// The response contains the offset at which the append happened. Responses
  1386  	// are received in the same order in which requests are sent. There will be
  1387  	// one response for each successful request. If the `offset` is not set in
  1388  	// response, it means append didn't happen due to some errors. If one request
  1389  	// fails, all the subsequent requests will also fail until a success request
  1390  	// is made again.
  1391  	//
  1392  	// If the stream is of `PENDING` type, data will only be available for read
  1393  	// operations after the stream is committed.
  1394  	AppendRows(BigQueryWrite_AppendRowsServer) error
  1395  	// Gets a write stream.
  1396  	GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error)
  1397  	// Finalize a write stream so that no new data can be appended to the
  1398  	// stream. Finalize is not supported on the '_default' stream.
  1399  	FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error)
  1400  	// Atomically commits a group of `PENDING` streams that belong to the same
  1401  	// `parent` table.
  1402  	// Streams must be finalized before commit and cannot be committed multiple
  1403  	// times. Once a stream is committed, data in the stream becomes available
  1404  	// for read operations.
  1405  	BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error)
  1406  	// Flushes rows to a BUFFERED stream.
  1407  	// If users are appending rows to BUFFERED stream, flush operation is
  1408  	// required in order for the rows to become available for reading. A
  1409  	// Flush operation flushes up to any previously flushed offset in a BUFFERED
  1410  	// stream, to the offset specified in the request.
  1411  	// Flush is not supported on the _default stream, since it is not BUFFERED.
  1412  	FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error)
  1413  }
  1414  
  1415  // UnimplementedBigQueryWriteServer can be embedded to have forward compatible implementations.
  1416  type UnimplementedBigQueryWriteServer struct {
  1417  }
  1418  
  1419  func (*UnimplementedBigQueryWriteServer) CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error) {
  1420  	return nil, status1.Errorf(codes.Unimplemented, "method CreateWriteStream not implemented")
  1421  }
  1422  func (*UnimplementedBigQueryWriteServer) AppendRows(BigQueryWrite_AppendRowsServer) error {
  1423  	return status1.Errorf(codes.Unimplemented, "method AppendRows not implemented")
  1424  }
  1425  func (*UnimplementedBigQueryWriteServer) GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error) {
  1426  	return nil, status1.Errorf(codes.Unimplemented, "method GetWriteStream not implemented")
  1427  }
  1428  func (*UnimplementedBigQueryWriteServer) FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error) {
  1429  	return nil, status1.Errorf(codes.Unimplemented, "method FinalizeWriteStream not implemented")
  1430  }
  1431  func (*UnimplementedBigQueryWriteServer) BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error) {
  1432  	return nil, status1.Errorf(codes.Unimplemented, "method BatchCommitWriteStreams not implemented")
  1433  }
  1434  func (*UnimplementedBigQueryWriteServer) FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error) {
  1435  	return nil, status1.Errorf(codes.Unimplemented, "method FlushRows not implemented")
  1436  }
  1437  
  1438  // Deprecated: Do not use.
  1439  func RegisterBigQueryWriteServer(s *grpc.Server, srv BigQueryWriteServer) {
  1440  	s.RegisterService(&_BigQueryWrite_serviceDesc, srv)
  1441  }
  1442  
  1443  func _BigQueryWrite_CreateWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1444  	in := new(CreateWriteStreamRequest)
  1445  	if err := dec(in); err != nil {
  1446  		return nil, err
  1447  	}
  1448  	if interceptor == nil {
  1449  		return srv.(BigQueryWriteServer).CreateWriteStream(ctx, in)
  1450  	}
  1451  	info := &grpc.UnaryServerInfo{
  1452  		Server:     srv,
  1453  		FullMethod: "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/CreateWriteStream",
  1454  	}
  1455  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1456  		return srv.(BigQueryWriteServer).CreateWriteStream(ctx, req.(*CreateWriteStreamRequest))
  1457  	}
  1458  	return interceptor(ctx, in, info, handler)
  1459  }
  1460  
  1461  func _BigQueryWrite_AppendRows_Handler(srv interface{}, stream grpc.ServerStream) error {
  1462  	return srv.(BigQueryWriteServer).AppendRows(&bigQueryWriteAppendRowsServer{stream})
  1463  }
  1464  
  1465  type BigQueryWrite_AppendRowsServer interface {
  1466  	Send(*AppendRowsResponse) error
  1467  	Recv() (*AppendRowsRequest, error)
  1468  	grpc.ServerStream
  1469  }
  1470  
  1471  type bigQueryWriteAppendRowsServer struct {
  1472  	grpc.ServerStream
  1473  }
  1474  
  1475  func (x *bigQueryWriteAppendRowsServer) Send(m *AppendRowsResponse) error {
  1476  	return x.ServerStream.SendMsg(m)
  1477  }
  1478  
  1479  func (x *bigQueryWriteAppendRowsServer) Recv() (*AppendRowsRequest, error) {
  1480  	m := new(AppendRowsRequest)
  1481  	if err := x.ServerStream.RecvMsg(m); err != nil {
  1482  		return nil, err
  1483  	}
  1484  	return m, nil
  1485  }
  1486  
  1487  func _BigQueryWrite_GetWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1488  	in := new(GetWriteStreamRequest)
  1489  	if err := dec(in); err != nil {
  1490  		return nil, err
  1491  	}
  1492  	if interceptor == nil {
  1493  		return srv.(BigQueryWriteServer).GetWriteStream(ctx, in)
  1494  	}
  1495  	info := &grpc.UnaryServerInfo{
  1496  		Server:     srv,
  1497  		FullMethod: "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/GetWriteStream",
  1498  	}
  1499  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1500  		return srv.(BigQueryWriteServer).GetWriteStream(ctx, req.(*GetWriteStreamRequest))
  1501  	}
  1502  	return interceptor(ctx, in, info, handler)
  1503  }
  1504  
  1505  func _BigQueryWrite_FinalizeWriteStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1506  	in := new(FinalizeWriteStreamRequest)
  1507  	if err := dec(in); err != nil {
  1508  		return nil, err
  1509  	}
  1510  	if interceptor == nil {
  1511  		return srv.(BigQueryWriteServer).FinalizeWriteStream(ctx, in)
  1512  	}
  1513  	info := &grpc.UnaryServerInfo{
  1514  		Server:     srv,
  1515  		FullMethod: "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/FinalizeWriteStream",
  1516  	}
  1517  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1518  		return srv.(BigQueryWriteServer).FinalizeWriteStream(ctx, req.(*FinalizeWriteStreamRequest))
  1519  	}
  1520  	return interceptor(ctx, in, info, handler)
  1521  }
  1522  
  1523  func _BigQueryWrite_BatchCommitWriteStreams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1524  	in := new(BatchCommitWriteStreamsRequest)
  1525  	if err := dec(in); err != nil {
  1526  		return nil, err
  1527  	}
  1528  	if interceptor == nil {
  1529  		return srv.(BigQueryWriteServer).BatchCommitWriteStreams(ctx, in)
  1530  	}
  1531  	info := &grpc.UnaryServerInfo{
  1532  		Server:     srv,
  1533  		FullMethod: "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/BatchCommitWriteStreams",
  1534  	}
  1535  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1536  		return srv.(BigQueryWriteServer).BatchCommitWriteStreams(ctx, req.(*BatchCommitWriteStreamsRequest))
  1537  	}
  1538  	return interceptor(ctx, in, info, handler)
  1539  }
  1540  
  1541  func _BigQueryWrite_FlushRows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1542  	in := new(FlushRowsRequest)
  1543  	if err := dec(in); err != nil {
  1544  		return nil, err
  1545  	}
  1546  	if interceptor == nil {
  1547  		return srv.(BigQueryWriteServer).FlushRows(ctx, in)
  1548  	}
  1549  	info := &grpc.UnaryServerInfo{
  1550  		Server:     srv,
  1551  		FullMethod: "/google.cloud.bigquery.storage.v1alpha2.BigQueryWrite/FlushRows",
  1552  	}
  1553  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1554  		return srv.(BigQueryWriteServer).FlushRows(ctx, req.(*FlushRowsRequest))
  1555  	}
  1556  	return interceptor(ctx, in, info, handler)
  1557  }
  1558  
  1559  var _BigQueryWrite_serviceDesc = grpc.ServiceDesc{
  1560  	ServiceName: "google.cloud.bigquery.storage.v1alpha2.BigQueryWrite",
  1561  	HandlerType: (*BigQueryWriteServer)(nil),
  1562  	Methods: []grpc.MethodDesc{
  1563  		{
  1564  			MethodName: "CreateWriteStream",
  1565  			Handler:    _BigQueryWrite_CreateWriteStream_Handler,
  1566  		},
  1567  		{
  1568  			MethodName: "GetWriteStream",
  1569  			Handler:    _BigQueryWrite_GetWriteStream_Handler,
  1570  		},
  1571  		{
  1572  			MethodName: "FinalizeWriteStream",
  1573  			Handler:    _BigQueryWrite_FinalizeWriteStream_Handler,
  1574  		},
  1575  		{
  1576  			MethodName: "BatchCommitWriteStreams",
  1577  			Handler:    _BigQueryWrite_BatchCommitWriteStreams_Handler,
  1578  		},
  1579  		{
  1580  			MethodName: "FlushRows",
  1581  			Handler:    _BigQueryWrite_FlushRows_Handler,
  1582  		},
  1583  	},
  1584  	Streams: []grpc.StreamDesc{
  1585  		{
  1586  			StreamName:    "AppendRows",
  1587  			Handler:       _BigQueryWrite_AppendRows_Handler,
  1588  			ServerStreams: true,
  1589  			ClientStreams: true,
  1590  		},
  1591  	},
  1592  	Metadata: "google/cloud/bigquery/storage/v1alpha2/storage.proto",
  1593  }
  1594  

View as plain text