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.26.0 18// protoc v3.12.2 19// source: google/cloud/bigquery/storage/v1beta2/stream.proto 20 21package storage 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 _ "google.golang.org/genproto/googleapis/api/annotations" 28 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 29 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 30 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 31) 32 33const ( 34 // Verify that this generated code is sufficiently up-to-date. 35 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 36 // Verify that runtime/protoimpl is sufficiently up-to-date. 37 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 38) 39 40// Data format for input or output data. 41type DataFormat int32 42 43const ( 44 DataFormat_DATA_FORMAT_UNSPECIFIED DataFormat = 0 45 // Avro is a standard open source row based file format. 46 // See https://avro.apache.org/ for more details. 47 DataFormat_AVRO DataFormat = 1 48 // Arrow is a standard open source column-based message format. 49 // See https://arrow.apache.org/ for more details. 50 DataFormat_ARROW DataFormat = 2 51) 52 53// Enum value maps for DataFormat. 54var ( 55 DataFormat_name = map[int32]string{ 56 0: "DATA_FORMAT_UNSPECIFIED", 57 1: "AVRO", 58 2: "ARROW", 59 } 60 DataFormat_value = map[string]int32{ 61 "DATA_FORMAT_UNSPECIFIED": 0, 62 "AVRO": 1, 63 "ARROW": 2, 64 } 65) 66 67func (x DataFormat) Enum() *DataFormat { 68 p := new(DataFormat) 69 *p = x 70 return p 71} 72 73func (x DataFormat) String() string { 74 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 75} 76 77func (DataFormat) Descriptor() protoreflect.EnumDescriptor { 78 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[0].Descriptor() 79} 80 81func (DataFormat) Type() protoreflect.EnumType { 82 return &file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[0] 83} 84 85func (x DataFormat) Number() protoreflect.EnumNumber { 86 return protoreflect.EnumNumber(x) 87} 88 89// Deprecated: Use DataFormat.Descriptor instead. 90func (DataFormat) EnumDescriptor() ([]byte, []int) { 91 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0} 92} 93 94// Type enum of the stream. 95type WriteStream_Type int32 96 97const ( 98 // Unknown type. 99 WriteStream_TYPE_UNSPECIFIED WriteStream_Type = 0 100 // Data will commit automatically and appear as soon as the write is 101 // acknowledged. 102 WriteStream_COMMITTED WriteStream_Type = 1 103 // Data is invisible until the stream is committed. 104 WriteStream_PENDING WriteStream_Type = 2 105 // Data is only visible up to the offset to which it was flushed. 106 WriteStream_BUFFERED WriteStream_Type = 3 107) 108 109// Enum value maps for WriteStream_Type. 110var ( 111 WriteStream_Type_name = map[int32]string{ 112 0: "TYPE_UNSPECIFIED", 113 1: "COMMITTED", 114 2: "PENDING", 115 3: "BUFFERED", 116 } 117 WriteStream_Type_value = map[string]int32{ 118 "TYPE_UNSPECIFIED": 0, 119 "COMMITTED": 1, 120 "PENDING": 2, 121 "BUFFERED": 3, 122 } 123) 124 125func (x WriteStream_Type) Enum() *WriteStream_Type { 126 p := new(WriteStream_Type) 127 *p = x 128 return p 129} 130 131func (x WriteStream_Type) String() string { 132 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 133} 134 135func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor { 136 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[1].Descriptor() 137} 138 139func (WriteStream_Type) Type() protoreflect.EnumType { 140 return &file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[1] 141} 142 143func (x WriteStream_Type) Number() protoreflect.EnumNumber { 144 return protoreflect.EnumNumber(x) 145} 146 147// Deprecated: Use WriteStream_Type.Descriptor instead. 148func (WriteStream_Type) EnumDescriptor() ([]byte, []int) { 149 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{2, 0} 150} 151 152// Information about the ReadSession. 153type ReadSession struct { 154 state protoimpl.MessageState 155 sizeCache protoimpl.SizeCache 156 unknownFields protoimpl.UnknownFields 157 158 // Output only. Unique identifier for the session, in the form 159 // `projects/{project_id}/locations/{location}/sessions/{session_id}`. 160 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 161 // Output only. Time at which the session becomes invalid. After this time, subsequent 162 // requests to read this Session will return errors. The expire_time is 163 // automatically assigned and currently cannot be specified or updated. 164 ExpireTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"` 165 // Immutable. Data format of the output data. 166 DataFormat DataFormat `protobuf:"varint,3,opt,name=data_format,json=dataFormat,proto3,enum=google.cloud.bigquery.storage.v1beta2.DataFormat" json:"data_format,omitempty"` 167 // The schema for the read. If read_options.selected_fields is set, the 168 // schema may be different from the table schema as it will only contain 169 // the selected fields. 170 // 171 // Types that are assignable to Schema: 172 // *ReadSession_AvroSchema 173 // *ReadSession_ArrowSchema 174 Schema isReadSession_Schema `protobuf_oneof:"schema"` 175 // Immutable. Table that this ReadSession is reading from, in the form 176 // `projects/{project_id}/datasets/{dataset_id}/tables/{table_id} 177 Table string `protobuf:"bytes,6,opt,name=table,proto3" json:"table,omitempty"` 178 // Optional. Any modifiers which are applied when reading from the specified table. 179 TableModifiers *ReadSession_TableModifiers `protobuf:"bytes,7,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"` 180 // Optional. Read options for this session (e.g. column selection, filters). 181 ReadOptions *ReadSession_TableReadOptions `protobuf:"bytes,8,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` 182 // Output only. A list of streams created with the session. 183 // 184 // At least one stream is created with the session. In the future, larger 185 // request_stream_count values *may* result in this list being unpopulated, 186 // in that case, the user will need to use a List method to get the streams 187 // instead, which is not yet available. 188 Streams []*ReadStream `protobuf:"bytes,10,rep,name=streams,proto3" json:"streams,omitempty"` 189} 190 191func (x *ReadSession) Reset() { 192 *x = ReadSession{} 193 if protoimpl.UnsafeEnabled { 194 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0] 195 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 196 ms.StoreMessageInfo(mi) 197 } 198} 199 200func (x *ReadSession) String() string { 201 return protoimpl.X.MessageStringOf(x) 202} 203 204func (*ReadSession) ProtoMessage() {} 205 206func (x *ReadSession) ProtoReflect() protoreflect.Message { 207 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0] 208 if protoimpl.UnsafeEnabled && x != nil { 209 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 210 if ms.LoadMessageInfo() == nil { 211 ms.StoreMessageInfo(mi) 212 } 213 return ms 214 } 215 return mi.MessageOf(x) 216} 217 218// Deprecated: Use ReadSession.ProtoReflect.Descriptor instead. 219func (*ReadSession) Descriptor() ([]byte, []int) { 220 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0} 221} 222 223func (x *ReadSession) GetName() string { 224 if x != nil { 225 return x.Name 226 } 227 return "" 228} 229 230func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp { 231 if x != nil { 232 return x.ExpireTime 233 } 234 return nil 235} 236 237func (x *ReadSession) GetDataFormat() DataFormat { 238 if x != nil { 239 return x.DataFormat 240 } 241 return DataFormat_DATA_FORMAT_UNSPECIFIED 242} 243 244func (m *ReadSession) GetSchema() isReadSession_Schema { 245 if m != nil { 246 return m.Schema 247 } 248 return nil 249} 250 251func (x *ReadSession) GetAvroSchema() *AvroSchema { 252 if x, ok := x.GetSchema().(*ReadSession_AvroSchema); ok { 253 return x.AvroSchema 254 } 255 return nil 256} 257 258func (x *ReadSession) GetArrowSchema() *ArrowSchema { 259 if x, ok := x.GetSchema().(*ReadSession_ArrowSchema); ok { 260 return x.ArrowSchema 261 } 262 return nil 263} 264 265func (x *ReadSession) GetTable() string { 266 if x != nil { 267 return x.Table 268 } 269 return "" 270} 271 272func (x *ReadSession) GetTableModifiers() *ReadSession_TableModifiers { 273 if x != nil { 274 return x.TableModifiers 275 } 276 return nil 277} 278 279func (x *ReadSession) GetReadOptions() *ReadSession_TableReadOptions { 280 if x != nil { 281 return x.ReadOptions 282 } 283 return nil 284} 285 286func (x *ReadSession) GetStreams() []*ReadStream { 287 if x != nil { 288 return x.Streams 289 } 290 return nil 291} 292 293type isReadSession_Schema interface { 294 isReadSession_Schema() 295} 296 297type ReadSession_AvroSchema struct { 298 // Output only. Avro schema. 299 AvroSchema *AvroSchema `protobuf:"bytes,4,opt,name=avro_schema,json=avroSchema,proto3,oneof"` 300} 301 302type ReadSession_ArrowSchema struct { 303 // Output only. Arrow schema. 304 ArrowSchema *ArrowSchema `protobuf:"bytes,5,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"` 305} 306 307func (*ReadSession_AvroSchema) isReadSession_Schema() {} 308 309func (*ReadSession_ArrowSchema) isReadSession_Schema() {} 310 311// Information about a single stream that gets data out of the storage system. 312// Most of the information about `ReadStream` instances is aggregated, making 313// `ReadStream` lightweight. 314type ReadStream struct { 315 state protoimpl.MessageState 316 sizeCache protoimpl.SizeCache 317 unknownFields protoimpl.UnknownFields 318 319 // Output only. Name of the stream, in the form 320 // `projects/{project_id}/locations/{location}/sessions/{session_id}/streams/{stream_id}`. 321 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 322} 323 324func (x *ReadStream) Reset() { 325 *x = ReadStream{} 326 if protoimpl.UnsafeEnabled { 327 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1] 328 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 329 ms.StoreMessageInfo(mi) 330 } 331} 332 333func (x *ReadStream) String() string { 334 return protoimpl.X.MessageStringOf(x) 335} 336 337func (*ReadStream) ProtoMessage() {} 338 339func (x *ReadStream) ProtoReflect() protoreflect.Message { 340 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1] 341 if protoimpl.UnsafeEnabled && x != nil { 342 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 343 if ms.LoadMessageInfo() == nil { 344 ms.StoreMessageInfo(mi) 345 } 346 return ms 347 } 348 return mi.MessageOf(x) 349} 350 351// Deprecated: Use ReadStream.ProtoReflect.Descriptor instead. 352func (*ReadStream) Descriptor() ([]byte, []int) { 353 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{1} 354} 355 356func (x *ReadStream) GetName() string { 357 if x != nil { 358 return x.Name 359 } 360 return "" 361} 362 363// Information about a single stream that gets data inside the storage system. 364type WriteStream struct { 365 state protoimpl.MessageState 366 sizeCache protoimpl.SizeCache 367 unknownFields protoimpl.UnknownFields 368 369 // Output only. Name of the stream, in the form 370 // `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`. 371 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 372 // Immutable. Type of the stream. 373 Type WriteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1beta2.WriteStream_Type" json:"type,omitempty"` 374 // Output only. Create time of the stream. For the _default stream, this is the 375 // creation_time of the table. 376 CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` 377 // Output only. Commit time of the stream. 378 // If a stream is of `COMMITTED` type, then it will have a commit_time same as 379 // `create_time`. If the stream is of `PENDING` type, commit_time being empty 380 // means it is not committed. 381 CommitTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"` 382 // Output only. The schema of the destination table. It is only returned in 383 // `CreateWriteStream` response. Caller should generate data that's 384 // compatible with this schema to send in initial `AppendRowsRequest`. 385 // The table schema could go out of date during the life time of the stream. 386 TableSchema *TableSchema `protobuf:"bytes,5,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"` 387} 388 389func (x *WriteStream) Reset() { 390 *x = WriteStream{} 391 if protoimpl.UnsafeEnabled { 392 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2] 393 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 394 ms.StoreMessageInfo(mi) 395 } 396} 397 398func (x *WriteStream) String() string { 399 return protoimpl.X.MessageStringOf(x) 400} 401 402func (*WriteStream) ProtoMessage() {} 403 404func (x *WriteStream) ProtoReflect() protoreflect.Message { 405 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2] 406 if protoimpl.UnsafeEnabled && x != nil { 407 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 408 if ms.LoadMessageInfo() == nil { 409 ms.StoreMessageInfo(mi) 410 } 411 return ms 412 } 413 return mi.MessageOf(x) 414} 415 416// Deprecated: Use WriteStream.ProtoReflect.Descriptor instead. 417func (*WriteStream) Descriptor() ([]byte, []int) { 418 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{2} 419} 420 421func (x *WriteStream) GetName() string { 422 if x != nil { 423 return x.Name 424 } 425 return "" 426} 427 428func (x *WriteStream) GetType() WriteStream_Type { 429 if x != nil { 430 return x.Type 431 } 432 return WriteStream_TYPE_UNSPECIFIED 433} 434 435func (x *WriteStream) GetCreateTime() *timestamppb.Timestamp { 436 if x != nil { 437 return x.CreateTime 438 } 439 return nil 440} 441 442func (x *WriteStream) GetCommitTime() *timestamppb.Timestamp { 443 if x != nil { 444 return x.CommitTime 445 } 446 return nil 447} 448 449func (x *WriteStream) GetTableSchema() *TableSchema { 450 if x != nil { 451 return x.TableSchema 452 } 453 return nil 454} 455 456// Additional attributes when reading a table. 457type ReadSession_TableModifiers struct { 458 state protoimpl.MessageState 459 sizeCache protoimpl.SizeCache 460 unknownFields protoimpl.UnknownFields 461 462 // The snapshot time of the table. If not set, interpreted as now. 463 SnapshotTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"` 464} 465 466func (x *ReadSession_TableModifiers) Reset() { 467 *x = ReadSession_TableModifiers{} 468 if protoimpl.UnsafeEnabled { 469 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3] 470 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 471 ms.StoreMessageInfo(mi) 472 } 473} 474 475func (x *ReadSession_TableModifiers) String() string { 476 return protoimpl.X.MessageStringOf(x) 477} 478 479func (*ReadSession_TableModifiers) ProtoMessage() {} 480 481func (x *ReadSession_TableModifiers) ProtoReflect() protoreflect.Message { 482 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3] 483 if protoimpl.UnsafeEnabled && x != nil { 484 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 485 if ms.LoadMessageInfo() == nil { 486 ms.StoreMessageInfo(mi) 487 } 488 return ms 489 } 490 return mi.MessageOf(x) 491} 492 493// Deprecated: Use ReadSession_TableModifiers.ProtoReflect.Descriptor instead. 494func (*ReadSession_TableModifiers) Descriptor() ([]byte, []int) { 495 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0, 0} 496} 497 498func (x *ReadSession_TableModifiers) GetSnapshotTime() *timestamppb.Timestamp { 499 if x != nil { 500 return x.SnapshotTime 501 } 502 return nil 503} 504 505// Options dictating how we read a table. 506type ReadSession_TableReadOptions struct { 507 state protoimpl.MessageState 508 sizeCache protoimpl.SizeCache 509 unknownFields protoimpl.UnknownFields 510 511 // Names of the fields in the table that should be read. If empty, all 512 // fields will be read. If the specified field is a nested field, all 513 // the sub-fields in the field will be selected. The output field order is 514 // unrelated to the order of fields in selected_fields. 515 SelectedFields []string `protobuf:"bytes,1,rep,name=selected_fields,json=selectedFields,proto3" json:"selected_fields,omitempty"` 516 // SQL text filtering statement, similar to a WHERE clause in a query. 517 // Aggregates are not supported. 518 // 519 // Examples: "int_field > 5" 520 // "date_field = CAST('2014-9-27' as DATE)" 521 // "nullable_field is not NULL" 522 // "st_equals(geo_field, st_geofromtext("POINT(2, 2)"))" 523 // "numeric_field BETWEEN 1.0 AND 5.0" 524 // 525 // Restricted to a maximum length for 1 MB. 526 RowRestriction string `protobuf:"bytes,2,opt,name=row_restriction,json=rowRestriction,proto3" json:"row_restriction,omitempty"` 527 // Optional. Options specific to the Apache Arrow output format. 528 ArrowSerializationOptions *ArrowSerializationOptions `protobuf:"bytes,3,opt,name=arrow_serialization_options,json=arrowSerializationOptions,proto3" json:"arrow_serialization_options,omitempty"` 529} 530 531func (x *ReadSession_TableReadOptions) Reset() { 532 *x = ReadSession_TableReadOptions{} 533 if protoimpl.UnsafeEnabled { 534 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4] 535 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 536 ms.StoreMessageInfo(mi) 537 } 538} 539 540func (x *ReadSession_TableReadOptions) String() string { 541 return protoimpl.X.MessageStringOf(x) 542} 543 544func (*ReadSession_TableReadOptions) ProtoMessage() {} 545 546func (x *ReadSession_TableReadOptions) ProtoReflect() protoreflect.Message { 547 mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4] 548 if protoimpl.UnsafeEnabled && x != nil { 549 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 550 if ms.LoadMessageInfo() == nil { 551 ms.StoreMessageInfo(mi) 552 } 553 return ms 554 } 555 return mi.MessageOf(x) 556} 557 558// Deprecated: Use ReadSession_TableReadOptions.ProtoReflect.Descriptor instead. 559func (*ReadSession_TableReadOptions) Descriptor() ([]byte, []int) { 560 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0, 1} 561} 562 563func (x *ReadSession_TableReadOptions) GetSelectedFields() []string { 564 if x != nil { 565 return x.SelectedFields 566 } 567 return nil 568} 569 570func (x *ReadSession_TableReadOptions) GetRowRestriction() string { 571 if x != nil { 572 return x.RowRestriction 573 } 574 return "" 575} 576 577func (x *ReadSession_TableReadOptions) GetArrowSerializationOptions() *ArrowSerializationOptions { 578 if x != nil { 579 return x.ArrowSerializationOptions 580 } 581 return nil 582} 583 584var File_google_cloud_bigquery_storage_v1beta2_stream_proto protoreflect.FileDescriptor 585 586var file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc = []byte{ 587 0x0a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 588 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 589 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70, 590 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 591 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 592 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 593 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 594 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 595 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 596 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 597 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 598 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61, 599 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x30, 0x67, 0x6f, 0x6f, 0x67, 600 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 601 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 602 0x32, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x31, 0x67, 0x6f, 603 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 604 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 605 0x74, 0x61, 0x32, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 606 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 607 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 608 0x22, 0xa0, 0x09, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 609 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 610 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x65, 0x78, 0x70, 611 0x69, 0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 612 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 613 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 614 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x57, 0x0a, 0x0b, 0x64, 615 0x61, 0x74, 0x61, 0x5f, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 616 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 617 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 618 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72, 619 0x6d, 0x61, 0x74, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x0a, 0x64, 0x61, 0x74, 0x61, 0x46, 0x6f, 620 0x72, 0x6d, 0x61, 0x74, 0x12, 0x59, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73, 0x63, 0x68, 621 0x65, 0x6d, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 622 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 623 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 624 0x32, 0x2e, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 625 0x03, 0x48, 0x00, 0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 626 0x5c, 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 627 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 628 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 629 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x72, 630 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x00, 631 0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x3b, 0x0a, 632 0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x25, 0xe0, 0x41, 633 0x05, 0xfa, 0x41, 0x1f, 0x0a, 0x1d, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67, 634 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 635 0x62, 0x6c, 0x65, 0x52, 0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x6f, 0x0a, 0x0f, 0x74, 0x61, 636 0x62, 0x6c, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x07, 0x20, 637 0x01, 0x28, 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 638 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 639 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 640 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 641 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0e, 0x74, 0x61, 0x62, 642 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x6b, 0x0a, 0x0c, 0x72, 643 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 644 0x0b, 0x32, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 645 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 646 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 647 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 648 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0b, 0x72, 0x65, 0x61, 649 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x50, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 650 0x61, 0x6d, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 651 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 652 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 653 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 654 0x03, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x1a, 0x51, 0x0a, 0x0e, 0x54, 0x61, 655 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x3f, 0x0a, 0x0d, 656 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 657 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 658 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 659 0x0c, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x1a, 0xec, 0x01, 660 0x0a, 0x10, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 661 0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x66, 662 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x73, 0x65, 0x6c, 663 0x65, 0x63, 0x74, 0x65, 0x64, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x72, 664 0x6f, 0x77, 0x5f, 0x72, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 665 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x72, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63, 666 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x85, 0x01, 0x0a, 0x1b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 667 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 668 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x40, 0x2e, 0x67, 0x6f, 0x6f, 669 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 670 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 671 0x61, 0x32, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 672 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41, 673 0x01, 0x52, 0x19, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 674 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x3a, 0x6b, 0xea, 0x41, 675 0x68, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 676 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 677 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x70, 678 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 679 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 680 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 681 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x42, 0x08, 0x0a, 0x06, 0x73, 0x63, 0x68, 682 0x65, 0x6d, 0x61, 0x22, 0xa2, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 683 0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 684 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x3a, 0x7b, 0xea, 0x41, 0x78, 685 0x0a, 0x29, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 686 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 687 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x4b, 0x70, 0x72, 0x6f, 688 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 689 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 690 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x73, 691 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 692 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x22, 0x98, 0x04, 0x0a, 0x0b, 0x57, 0x72, 0x69, 693 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 694 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 695 0x65, 0x12, 0x50, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 696 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 697 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 698 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 699 0x65, 0x61, 0x6d, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x04, 0x74, 700 0x79, 0x70, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 701 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 702 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 703 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 704 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 705 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 706 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 707 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x6f, 0x6d, 708 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x5a, 0x0a, 0x0c, 0x74, 0x61, 0x62, 0x6c, 0x65, 709 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 710 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 711 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 712 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 713 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 714 0x65, 0x6d, 0x61, 0x22, 0x46, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x54, 715 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 716 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x54, 0x45, 0x44, 0x10, 0x01, 717 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x45, 0x4e, 0x44, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x0c, 0x0a, 718 0x08, 0x42, 0x55, 0x46, 0x46, 0x45, 0x52, 0x45, 0x44, 0x10, 0x03, 0x3a, 0x76, 0xea, 0x41, 0x73, 719 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 720 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 721 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x45, 0x70, 0x72, 722 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 723 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73, 724 0x65, 0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 725 0x65, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 726 0x61, 0x6d, 0x7d, 0x2a, 0x3e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 727 0x74, 0x12, 0x1b, 0x0a, 0x17, 0x44, 0x41, 0x54, 0x41, 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 728 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08, 729 0x0a, 0x04, 0x41, 0x56, 0x52, 0x4f, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x52, 0x52, 0x4f, 730 0x57, 0x10, 0x02, 0x42, 0xe0, 0x01, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 731 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 732 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 733 0x32, 0x42, 0x0b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 734 0x5a, 0x4c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 735 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 736 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 737 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 738 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0xea, 0x41, 739 0x55, 0x0a, 0x1d, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 740 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c, 0x65, 741 0x12, 0x34, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 742 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x7b, 0x64, 743 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x7b, 744 0x74, 0x61, 0x62, 0x6c, 0x65, 0x7d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 745} 746 747var ( 748 file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescOnce sync.Once 749 file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc 750) 751 752func file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP() []byte { 753 file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescOnce.Do(func() { 754 file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData) 755 }) 756 return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData 757} 758 759var file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes = make([]protoimpl.EnumInfo, 2) 760var file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 5) 761var file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes = []interface{}{ 762 (DataFormat)(0), // 0: google.cloud.bigquery.storage.v1beta2.DataFormat 763 (WriteStream_Type)(0), // 1: google.cloud.bigquery.storage.v1beta2.WriteStream.Type 764 (*ReadSession)(nil), // 2: google.cloud.bigquery.storage.v1beta2.ReadSession 765 (*ReadStream)(nil), // 3: google.cloud.bigquery.storage.v1beta2.ReadStream 766 (*WriteStream)(nil), // 4: google.cloud.bigquery.storage.v1beta2.WriteStream 767 (*ReadSession_TableModifiers)(nil), // 5: google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers 768 (*ReadSession_TableReadOptions)(nil), // 6: google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions 769 (*timestamppb.Timestamp)(nil), // 7: google.protobuf.Timestamp 770 (*AvroSchema)(nil), // 8: google.cloud.bigquery.storage.v1beta2.AvroSchema 771 (*ArrowSchema)(nil), // 9: google.cloud.bigquery.storage.v1beta2.ArrowSchema 772 (*TableSchema)(nil), // 10: google.cloud.bigquery.storage.v1beta2.TableSchema 773 (*ArrowSerializationOptions)(nil), // 11: google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions 774} 775var file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs = []int32{ 776 7, // 0: google.cloud.bigquery.storage.v1beta2.ReadSession.expire_time:type_name -> google.protobuf.Timestamp 777 0, // 1: google.cloud.bigquery.storage.v1beta2.ReadSession.data_format:type_name -> google.cloud.bigquery.storage.v1beta2.DataFormat 778 8, // 2: google.cloud.bigquery.storage.v1beta2.ReadSession.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta2.AvroSchema 779 9, // 3: google.cloud.bigquery.storage.v1beta2.ReadSession.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSchema 780 5, // 4: google.cloud.bigquery.storage.v1beta2.ReadSession.table_modifiers:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers 781 6, // 5: google.cloud.bigquery.storage.v1beta2.ReadSession.read_options:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions 782 3, // 6: google.cloud.bigquery.storage.v1beta2.ReadSession.streams:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream 783 1, // 7: google.cloud.bigquery.storage.v1beta2.WriteStream.type:type_name -> google.cloud.bigquery.storage.v1beta2.WriteStream.Type 784 7, // 8: google.cloud.bigquery.storage.v1beta2.WriteStream.create_time:type_name -> google.protobuf.Timestamp 785 7, // 9: google.cloud.bigquery.storage.v1beta2.WriteStream.commit_time:type_name -> google.protobuf.Timestamp 786 10, // 10: google.cloud.bigquery.storage.v1beta2.WriteStream.table_schema:type_name -> google.cloud.bigquery.storage.v1beta2.TableSchema 787 7, // 11: google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers.snapshot_time:type_name -> google.protobuf.Timestamp 788 11, // 12: google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions.arrow_serialization_options:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions 789 13, // [13:13] is the sub-list for method output_type 790 13, // [13:13] is the sub-list for method input_type 791 13, // [13:13] is the sub-list for extension type_name 792 13, // [13:13] is the sub-list for extension extendee 793 0, // [0:13] is the sub-list for field type_name 794} 795 796func init() { file_google_cloud_bigquery_storage_v1beta2_stream_proto_init() } 797func file_google_cloud_bigquery_storage_v1beta2_stream_proto_init() { 798 if File_google_cloud_bigquery_storage_v1beta2_stream_proto != nil { 799 return 800 } 801 file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init() 802 file_google_cloud_bigquery_storage_v1beta2_avro_proto_init() 803 file_google_cloud_bigquery_storage_v1beta2_table_proto_init() 804 if !protoimpl.UnsafeEnabled { 805 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 806 switch v := v.(*ReadSession); i { 807 case 0: 808 return &v.state 809 case 1: 810 return &v.sizeCache 811 case 2: 812 return &v.unknownFields 813 default: 814 return nil 815 } 816 } 817 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 818 switch v := v.(*ReadStream); i { 819 case 0: 820 return &v.state 821 case 1: 822 return &v.sizeCache 823 case 2: 824 return &v.unknownFields 825 default: 826 return nil 827 } 828 } 829 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 830 switch v := v.(*WriteStream); i { 831 case 0: 832 return &v.state 833 case 1: 834 return &v.sizeCache 835 case 2: 836 return &v.unknownFields 837 default: 838 return nil 839 } 840 } 841 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 842 switch v := v.(*ReadSession_TableModifiers); i { 843 case 0: 844 return &v.state 845 case 1: 846 return &v.sizeCache 847 case 2: 848 return &v.unknownFields 849 default: 850 return nil 851 } 852 } 853 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 854 switch v := v.(*ReadSession_TableReadOptions); i { 855 case 0: 856 return &v.state 857 case 1: 858 return &v.sizeCache 859 case 2: 860 return &v.unknownFields 861 default: 862 return nil 863 } 864 } 865 } 866 file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0].OneofWrappers = []interface{}{ 867 (*ReadSession_AvroSchema)(nil), 868 (*ReadSession_ArrowSchema)(nil), 869 } 870 type x struct{} 871 out := protoimpl.TypeBuilder{ 872 File: protoimpl.DescBuilder{ 873 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 874 RawDescriptor: file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc, 875 NumEnums: 2, 876 NumMessages: 5, 877 NumExtensions: 0, 878 NumServices: 0, 879 }, 880 GoTypes: file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes, 881 DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs, 882 EnumInfos: file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes, 883 MessageInfos: file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes, 884 }.Build() 885 File_google_cloud_bigquery_storage_v1beta2_stream_proto = out.File 886 file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc = nil 887 file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes = nil 888 file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs = nil 889} 890