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