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