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