1// 2// Licensed to the Apache Software Foundation (ASF) under one 3// or more contributor license agreements. See the NOTICE file 4// distributed with this work for additional information 5// regarding copyright ownership. The ASF licenses this file 6// to you under the Apache License, Version 2.0 (the 7// "License"); you may not use this file except in compliance 8// with the License. You may obtain a copy of the License at 9// <p> 10// http://www.apache.org/licenses/LICENSE-2.0 11// <p> 12// Unless required by applicable law or agreed to in writing, software 13// distributed under the License is distributed on an "AS IS" BASIS, 14// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 15// See the License for the specific language governing permissions and 16// limitations under the License. 17 18// Code generated by protoc-gen-go. DO NOT EDIT. 19// versions: 20// protoc-gen-go v1.25.0 21// protoc v3.9.1 22// source: Flight.proto 23 24package flight 25 26import ( 27 proto "github.com/golang/protobuf/proto" 28 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 29 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 30 reflect "reflect" 31 sync "sync" 32) 33 34const ( 35 // Verify that this generated code is sufficiently up-to-date. 36 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 37 // Verify that runtime/protoimpl is sufficiently up-to-date. 38 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 39) 40 41// This is a compile-time assertion that a sufficiently up-to-date version 42// of the legacy proto package is being used. 43const _ = proto.ProtoPackageIsVersion4 44 45// 46// Describes what type of descriptor is defined. 47type FlightDescriptor_DescriptorType int32 48 49const ( 50 // Protobuf pattern, not used. 51 FlightDescriptor_UNKNOWN FlightDescriptor_DescriptorType = 0 52 // 53 // A named path that identifies a dataset. A path is composed of a string 54 // or list of strings describing a particular dataset. This is conceptually 55 // similar to a path inside a filesystem. 56 FlightDescriptor_PATH FlightDescriptor_DescriptorType = 1 57 // 58 // An opaque command to generate a dataset. 59 FlightDescriptor_CMD FlightDescriptor_DescriptorType = 2 60) 61 62// Enum value maps for FlightDescriptor_DescriptorType. 63var ( 64 FlightDescriptor_DescriptorType_name = map[int32]string{ 65 0: "UNKNOWN", 66 1: "PATH", 67 2: "CMD", 68 } 69 FlightDescriptor_DescriptorType_value = map[string]int32{ 70 "UNKNOWN": 0, 71 "PATH": 1, 72 "CMD": 2, 73 } 74) 75 76func (x FlightDescriptor_DescriptorType) Enum() *FlightDescriptor_DescriptorType { 77 p := new(FlightDescriptor_DescriptorType) 78 *p = x 79 return p 80} 81 82func (x FlightDescriptor_DescriptorType) String() string { 83 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 84} 85 86func (FlightDescriptor_DescriptorType) Descriptor() protoreflect.EnumDescriptor { 87 return file_Flight_proto_enumTypes[0].Descriptor() 88} 89 90func (FlightDescriptor_DescriptorType) Type() protoreflect.EnumType { 91 return &file_Flight_proto_enumTypes[0] 92} 93 94func (x FlightDescriptor_DescriptorType) Number() protoreflect.EnumNumber { 95 return protoreflect.EnumNumber(x) 96} 97 98// Deprecated: Use FlightDescriptor_DescriptorType.Descriptor instead. 99func (FlightDescriptor_DescriptorType) EnumDescriptor() ([]byte, []int) { 100 return file_Flight_proto_rawDescGZIP(), []int{9, 0} 101} 102 103// 104// The request that a client provides to a server on handshake. 105type HandshakeRequest struct { 106 state protoimpl.MessageState 107 sizeCache protoimpl.SizeCache 108 unknownFields protoimpl.UnknownFields 109 110 // 111 // A defined protocol version 112 ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` 113 // 114 // Arbitrary auth/handshake info. 115 Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` 116} 117 118func (x *HandshakeRequest) Reset() { 119 *x = HandshakeRequest{} 120 if protoimpl.UnsafeEnabled { 121 mi := &file_Flight_proto_msgTypes[0] 122 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 123 ms.StoreMessageInfo(mi) 124 } 125} 126 127func (x *HandshakeRequest) String() string { 128 return protoimpl.X.MessageStringOf(x) 129} 130 131func (*HandshakeRequest) ProtoMessage() {} 132 133func (x *HandshakeRequest) ProtoReflect() protoreflect.Message { 134 mi := &file_Flight_proto_msgTypes[0] 135 if protoimpl.UnsafeEnabled && x != nil { 136 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 137 if ms.LoadMessageInfo() == nil { 138 ms.StoreMessageInfo(mi) 139 } 140 return ms 141 } 142 return mi.MessageOf(x) 143} 144 145// Deprecated: Use HandshakeRequest.ProtoReflect.Descriptor instead. 146func (*HandshakeRequest) Descriptor() ([]byte, []int) { 147 return file_Flight_proto_rawDescGZIP(), []int{0} 148} 149 150func (x *HandshakeRequest) GetProtocolVersion() uint64 { 151 if x != nil { 152 return x.ProtocolVersion 153 } 154 return 0 155} 156 157func (x *HandshakeRequest) GetPayload() []byte { 158 if x != nil { 159 return x.Payload 160 } 161 return nil 162} 163 164type HandshakeResponse struct { 165 state protoimpl.MessageState 166 sizeCache protoimpl.SizeCache 167 unknownFields protoimpl.UnknownFields 168 169 // 170 // A defined protocol version 171 ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` 172 // 173 // Arbitrary auth/handshake info. 174 Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` 175} 176 177func (x *HandshakeResponse) Reset() { 178 *x = HandshakeResponse{} 179 if protoimpl.UnsafeEnabled { 180 mi := &file_Flight_proto_msgTypes[1] 181 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 182 ms.StoreMessageInfo(mi) 183 } 184} 185 186func (x *HandshakeResponse) String() string { 187 return protoimpl.X.MessageStringOf(x) 188} 189 190func (*HandshakeResponse) ProtoMessage() {} 191 192func (x *HandshakeResponse) ProtoReflect() protoreflect.Message { 193 mi := &file_Flight_proto_msgTypes[1] 194 if protoimpl.UnsafeEnabled && x != nil { 195 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 196 if ms.LoadMessageInfo() == nil { 197 ms.StoreMessageInfo(mi) 198 } 199 return ms 200 } 201 return mi.MessageOf(x) 202} 203 204// Deprecated: Use HandshakeResponse.ProtoReflect.Descriptor instead. 205func (*HandshakeResponse) Descriptor() ([]byte, []int) { 206 return file_Flight_proto_rawDescGZIP(), []int{1} 207} 208 209func (x *HandshakeResponse) GetProtocolVersion() uint64 { 210 if x != nil { 211 return x.ProtocolVersion 212 } 213 return 0 214} 215 216func (x *HandshakeResponse) GetPayload() []byte { 217 if x != nil { 218 return x.Payload 219 } 220 return nil 221} 222 223// 224// A message for doing simple auth. 225type BasicAuth struct { 226 state protoimpl.MessageState 227 sizeCache protoimpl.SizeCache 228 unknownFields protoimpl.UnknownFields 229 230 Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` 231 Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` 232} 233 234func (x *BasicAuth) Reset() { 235 *x = BasicAuth{} 236 if protoimpl.UnsafeEnabled { 237 mi := &file_Flight_proto_msgTypes[2] 238 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 239 ms.StoreMessageInfo(mi) 240 } 241} 242 243func (x *BasicAuth) String() string { 244 return protoimpl.X.MessageStringOf(x) 245} 246 247func (*BasicAuth) ProtoMessage() {} 248 249func (x *BasicAuth) ProtoReflect() protoreflect.Message { 250 mi := &file_Flight_proto_msgTypes[2] 251 if protoimpl.UnsafeEnabled && x != nil { 252 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 253 if ms.LoadMessageInfo() == nil { 254 ms.StoreMessageInfo(mi) 255 } 256 return ms 257 } 258 return mi.MessageOf(x) 259} 260 261// Deprecated: Use BasicAuth.ProtoReflect.Descriptor instead. 262func (*BasicAuth) Descriptor() ([]byte, []int) { 263 return file_Flight_proto_rawDescGZIP(), []int{2} 264} 265 266func (x *BasicAuth) GetUsername() string { 267 if x != nil { 268 return x.Username 269 } 270 return "" 271} 272 273func (x *BasicAuth) GetPassword() string { 274 if x != nil { 275 return x.Password 276 } 277 return "" 278} 279 280type Empty struct { 281 state protoimpl.MessageState 282 sizeCache protoimpl.SizeCache 283 unknownFields protoimpl.UnknownFields 284} 285 286func (x *Empty) Reset() { 287 *x = Empty{} 288 if protoimpl.UnsafeEnabled { 289 mi := &file_Flight_proto_msgTypes[3] 290 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 291 ms.StoreMessageInfo(mi) 292 } 293} 294 295func (x *Empty) String() string { 296 return protoimpl.X.MessageStringOf(x) 297} 298 299func (*Empty) ProtoMessage() {} 300 301func (x *Empty) ProtoReflect() protoreflect.Message { 302 mi := &file_Flight_proto_msgTypes[3] 303 if protoimpl.UnsafeEnabled && x != nil { 304 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 305 if ms.LoadMessageInfo() == nil { 306 ms.StoreMessageInfo(mi) 307 } 308 return ms 309 } 310 return mi.MessageOf(x) 311} 312 313// Deprecated: Use Empty.ProtoReflect.Descriptor instead. 314func (*Empty) Descriptor() ([]byte, []int) { 315 return file_Flight_proto_rawDescGZIP(), []int{3} 316} 317 318// 319// Describes an available action, including both the name used for execution 320// along with a short description of the purpose of the action. 321type ActionType struct { 322 state protoimpl.MessageState 323 sizeCache protoimpl.SizeCache 324 unknownFields protoimpl.UnknownFields 325 326 Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` 327 Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` 328} 329 330func (x *ActionType) Reset() { 331 *x = ActionType{} 332 if protoimpl.UnsafeEnabled { 333 mi := &file_Flight_proto_msgTypes[4] 334 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 335 ms.StoreMessageInfo(mi) 336 } 337} 338 339func (x *ActionType) String() string { 340 return protoimpl.X.MessageStringOf(x) 341} 342 343func (*ActionType) ProtoMessage() {} 344 345func (x *ActionType) ProtoReflect() protoreflect.Message { 346 mi := &file_Flight_proto_msgTypes[4] 347 if protoimpl.UnsafeEnabled && x != nil { 348 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 349 if ms.LoadMessageInfo() == nil { 350 ms.StoreMessageInfo(mi) 351 } 352 return ms 353 } 354 return mi.MessageOf(x) 355} 356 357// Deprecated: Use ActionType.ProtoReflect.Descriptor instead. 358func (*ActionType) Descriptor() ([]byte, []int) { 359 return file_Flight_proto_rawDescGZIP(), []int{4} 360} 361 362func (x *ActionType) GetType() string { 363 if x != nil { 364 return x.Type 365 } 366 return "" 367} 368 369func (x *ActionType) GetDescription() string { 370 if x != nil { 371 return x.Description 372 } 373 return "" 374} 375 376// 377// A service specific expression that can be used to return a limited set 378// of available Arrow Flight streams. 379type Criteria struct { 380 state protoimpl.MessageState 381 sizeCache protoimpl.SizeCache 382 unknownFields protoimpl.UnknownFields 383 384 Expression []byte `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"` 385} 386 387func (x *Criteria) Reset() { 388 *x = Criteria{} 389 if protoimpl.UnsafeEnabled { 390 mi := &file_Flight_proto_msgTypes[5] 391 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 392 ms.StoreMessageInfo(mi) 393 } 394} 395 396func (x *Criteria) String() string { 397 return protoimpl.X.MessageStringOf(x) 398} 399 400func (*Criteria) ProtoMessage() {} 401 402func (x *Criteria) ProtoReflect() protoreflect.Message { 403 mi := &file_Flight_proto_msgTypes[5] 404 if protoimpl.UnsafeEnabled && x != nil { 405 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 406 if ms.LoadMessageInfo() == nil { 407 ms.StoreMessageInfo(mi) 408 } 409 return ms 410 } 411 return mi.MessageOf(x) 412} 413 414// Deprecated: Use Criteria.ProtoReflect.Descriptor instead. 415func (*Criteria) Descriptor() ([]byte, []int) { 416 return file_Flight_proto_rawDescGZIP(), []int{5} 417} 418 419func (x *Criteria) GetExpression() []byte { 420 if x != nil { 421 return x.Expression 422 } 423 return nil 424} 425 426// 427// An opaque action specific for the service. 428type Action struct { 429 state protoimpl.MessageState 430 sizeCache protoimpl.SizeCache 431 unknownFields protoimpl.UnknownFields 432 433 Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` 434 Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` 435} 436 437func (x *Action) Reset() { 438 *x = Action{} 439 if protoimpl.UnsafeEnabled { 440 mi := &file_Flight_proto_msgTypes[6] 441 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 442 ms.StoreMessageInfo(mi) 443 } 444} 445 446func (x *Action) String() string { 447 return protoimpl.X.MessageStringOf(x) 448} 449 450func (*Action) ProtoMessage() {} 451 452func (x *Action) ProtoReflect() protoreflect.Message { 453 mi := &file_Flight_proto_msgTypes[6] 454 if protoimpl.UnsafeEnabled && x != nil { 455 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 456 if ms.LoadMessageInfo() == nil { 457 ms.StoreMessageInfo(mi) 458 } 459 return ms 460 } 461 return mi.MessageOf(x) 462} 463 464// Deprecated: Use Action.ProtoReflect.Descriptor instead. 465func (*Action) Descriptor() ([]byte, []int) { 466 return file_Flight_proto_rawDescGZIP(), []int{6} 467} 468 469func (x *Action) GetType() string { 470 if x != nil { 471 return x.Type 472 } 473 return "" 474} 475 476func (x *Action) GetBody() []byte { 477 if x != nil { 478 return x.Body 479 } 480 return nil 481} 482 483// 484// An opaque result returned after executing an action. 485type Result struct { 486 state protoimpl.MessageState 487 sizeCache protoimpl.SizeCache 488 unknownFields protoimpl.UnknownFields 489 490 Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` 491} 492 493func (x *Result) Reset() { 494 *x = Result{} 495 if protoimpl.UnsafeEnabled { 496 mi := &file_Flight_proto_msgTypes[7] 497 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 498 ms.StoreMessageInfo(mi) 499 } 500} 501 502func (x *Result) String() string { 503 return protoimpl.X.MessageStringOf(x) 504} 505 506func (*Result) ProtoMessage() {} 507 508func (x *Result) ProtoReflect() protoreflect.Message { 509 mi := &file_Flight_proto_msgTypes[7] 510 if protoimpl.UnsafeEnabled && x != nil { 511 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 512 if ms.LoadMessageInfo() == nil { 513 ms.StoreMessageInfo(mi) 514 } 515 return ms 516 } 517 return mi.MessageOf(x) 518} 519 520// Deprecated: Use Result.ProtoReflect.Descriptor instead. 521func (*Result) Descriptor() ([]byte, []int) { 522 return file_Flight_proto_rawDescGZIP(), []int{7} 523} 524 525func (x *Result) GetBody() []byte { 526 if x != nil { 527 return x.Body 528 } 529 return nil 530} 531 532// 533// Wrap the result of a getSchema call 534type SchemaResult struct { 535 state protoimpl.MessageState 536 sizeCache protoimpl.SizeCache 537 unknownFields protoimpl.UnknownFields 538 539 // schema of the dataset as described in Schema.fbs::Schema. 540 Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` 541} 542 543func (x *SchemaResult) Reset() { 544 *x = SchemaResult{} 545 if protoimpl.UnsafeEnabled { 546 mi := &file_Flight_proto_msgTypes[8] 547 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 548 ms.StoreMessageInfo(mi) 549 } 550} 551 552func (x *SchemaResult) String() string { 553 return protoimpl.X.MessageStringOf(x) 554} 555 556func (*SchemaResult) ProtoMessage() {} 557 558func (x *SchemaResult) ProtoReflect() protoreflect.Message { 559 mi := &file_Flight_proto_msgTypes[8] 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 SchemaResult.ProtoReflect.Descriptor instead. 571func (*SchemaResult) Descriptor() ([]byte, []int) { 572 return file_Flight_proto_rawDescGZIP(), []int{8} 573} 574 575func (x *SchemaResult) GetSchema() []byte { 576 if x != nil { 577 return x.Schema 578 } 579 return nil 580} 581 582// 583// The name or tag for a Flight. May be used as a way to retrieve or generate 584// a flight or be used to expose a set of previously defined flights. 585type FlightDescriptor struct { 586 state protoimpl.MessageState 587 sizeCache protoimpl.SizeCache 588 unknownFields protoimpl.UnknownFields 589 590 Type FlightDescriptor_DescriptorType `protobuf:"varint,1,opt,name=type,proto3,enum=arrow.flight.protocol.FlightDescriptor_DescriptorType" json:"type,omitempty"` 591 // 592 // Opaque value used to express a command. Should only be defined when 593 // type = CMD. 594 Cmd []byte `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 595 // 596 // List of strings identifying a particular dataset. Should only be defined 597 // when type = PATH. 598 Path []string `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"` 599} 600 601func (x *FlightDescriptor) Reset() { 602 *x = FlightDescriptor{} 603 if protoimpl.UnsafeEnabled { 604 mi := &file_Flight_proto_msgTypes[9] 605 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 606 ms.StoreMessageInfo(mi) 607 } 608} 609 610func (x *FlightDescriptor) String() string { 611 return protoimpl.X.MessageStringOf(x) 612} 613 614func (*FlightDescriptor) ProtoMessage() {} 615 616func (x *FlightDescriptor) ProtoReflect() protoreflect.Message { 617 mi := &file_Flight_proto_msgTypes[9] 618 if protoimpl.UnsafeEnabled && x != nil { 619 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 620 if ms.LoadMessageInfo() == nil { 621 ms.StoreMessageInfo(mi) 622 } 623 return ms 624 } 625 return mi.MessageOf(x) 626} 627 628// Deprecated: Use FlightDescriptor.ProtoReflect.Descriptor instead. 629func (*FlightDescriptor) Descriptor() ([]byte, []int) { 630 return file_Flight_proto_rawDescGZIP(), []int{9} 631} 632 633func (x *FlightDescriptor) GetType() FlightDescriptor_DescriptorType { 634 if x != nil { 635 return x.Type 636 } 637 return FlightDescriptor_UNKNOWN 638} 639 640func (x *FlightDescriptor) GetCmd() []byte { 641 if x != nil { 642 return x.Cmd 643 } 644 return nil 645} 646 647func (x *FlightDescriptor) GetPath() []string { 648 if x != nil { 649 return x.Path 650 } 651 return nil 652} 653 654// 655// The access coordinates for retrieval of a dataset. With a FlightInfo, a 656// consumer is able to determine how to retrieve a dataset. 657type FlightInfo struct { 658 state protoimpl.MessageState 659 sizeCache protoimpl.SizeCache 660 unknownFields protoimpl.UnknownFields 661 662 // schema of the dataset as described in Schema.fbs::Schema. 663 Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` 664 // 665 // The descriptor associated with this info. 666 FlightDescriptor *FlightDescriptor `protobuf:"bytes,2,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"` 667 // 668 // A list of endpoints associated with the flight. To consume the whole 669 // flight, all endpoints must be consumed. 670 Endpoint []*FlightEndpoint `protobuf:"bytes,3,rep,name=endpoint,proto3" json:"endpoint,omitempty"` 671 // Set these to -1 if unknown. 672 TotalRecords int64 `protobuf:"varint,4,opt,name=total_records,json=totalRecords,proto3" json:"total_records,omitempty"` 673 TotalBytes int64 `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"` 674} 675 676func (x *FlightInfo) Reset() { 677 *x = FlightInfo{} 678 if protoimpl.UnsafeEnabled { 679 mi := &file_Flight_proto_msgTypes[10] 680 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 681 ms.StoreMessageInfo(mi) 682 } 683} 684 685func (x *FlightInfo) String() string { 686 return protoimpl.X.MessageStringOf(x) 687} 688 689func (*FlightInfo) ProtoMessage() {} 690 691func (x *FlightInfo) ProtoReflect() protoreflect.Message { 692 mi := &file_Flight_proto_msgTypes[10] 693 if protoimpl.UnsafeEnabled && x != nil { 694 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 695 if ms.LoadMessageInfo() == nil { 696 ms.StoreMessageInfo(mi) 697 } 698 return ms 699 } 700 return mi.MessageOf(x) 701} 702 703// Deprecated: Use FlightInfo.ProtoReflect.Descriptor instead. 704func (*FlightInfo) Descriptor() ([]byte, []int) { 705 return file_Flight_proto_rawDescGZIP(), []int{10} 706} 707 708func (x *FlightInfo) GetSchema() []byte { 709 if x != nil { 710 return x.Schema 711 } 712 return nil 713} 714 715func (x *FlightInfo) GetFlightDescriptor() *FlightDescriptor { 716 if x != nil { 717 return x.FlightDescriptor 718 } 719 return nil 720} 721 722func (x *FlightInfo) GetEndpoint() []*FlightEndpoint { 723 if x != nil { 724 return x.Endpoint 725 } 726 return nil 727} 728 729func (x *FlightInfo) GetTotalRecords() int64 { 730 if x != nil { 731 return x.TotalRecords 732 } 733 return 0 734} 735 736func (x *FlightInfo) GetTotalBytes() int64 { 737 if x != nil { 738 return x.TotalBytes 739 } 740 return 0 741} 742 743// 744// A particular stream or split associated with a flight. 745type FlightEndpoint struct { 746 state protoimpl.MessageState 747 sizeCache protoimpl.SizeCache 748 unknownFields protoimpl.UnknownFields 749 750 // 751 // Token used to retrieve this stream. 752 Ticket *Ticket `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"` 753 // 754 // A list of URIs where this ticket can be redeemed. If the list is 755 // empty, the expectation is that the ticket can only be redeemed on the 756 // current service where the ticket was generated. 757 Location []*Location `protobuf:"bytes,2,rep,name=location,proto3" json:"location,omitempty"` 758} 759 760func (x *FlightEndpoint) Reset() { 761 *x = FlightEndpoint{} 762 if protoimpl.UnsafeEnabled { 763 mi := &file_Flight_proto_msgTypes[11] 764 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 765 ms.StoreMessageInfo(mi) 766 } 767} 768 769func (x *FlightEndpoint) String() string { 770 return protoimpl.X.MessageStringOf(x) 771} 772 773func (*FlightEndpoint) ProtoMessage() {} 774 775func (x *FlightEndpoint) ProtoReflect() protoreflect.Message { 776 mi := &file_Flight_proto_msgTypes[11] 777 if protoimpl.UnsafeEnabled && x != nil { 778 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 779 if ms.LoadMessageInfo() == nil { 780 ms.StoreMessageInfo(mi) 781 } 782 return ms 783 } 784 return mi.MessageOf(x) 785} 786 787// Deprecated: Use FlightEndpoint.ProtoReflect.Descriptor instead. 788func (*FlightEndpoint) Descriptor() ([]byte, []int) { 789 return file_Flight_proto_rawDescGZIP(), []int{11} 790} 791 792func (x *FlightEndpoint) GetTicket() *Ticket { 793 if x != nil { 794 return x.Ticket 795 } 796 return nil 797} 798 799func (x *FlightEndpoint) GetLocation() []*Location { 800 if x != nil { 801 return x.Location 802 } 803 return nil 804} 805 806// 807// A location where a Flight service will accept retrieval of a particular 808// stream given a ticket. 809type Location struct { 810 state protoimpl.MessageState 811 sizeCache protoimpl.SizeCache 812 unknownFields protoimpl.UnknownFields 813 814 Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` 815} 816 817func (x *Location) Reset() { 818 *x = Location{} 819 if protoimpl.UnsafeEnabled { 820 mi := &file_Flight_proto_msgTypes[12] 821 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 822 ms.StoreMessageInfo(mi) 823 } 824} 825 826func (x *Location) String() string { 827 return protoimpl.X.MessageStringOf(x) 828} 829 830func (*Location) ProtoMessage() {} 831 832func (x *Location) ProtoReflect() protoreflect.Message { 833 mi := &file_Flight_proto_msgTypes[12] 834 if protoimpl.UnsafeEnabled && x != nil { 835 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 836 if ms.LoadMessageInfo() == nil { 837 ms.StoreMessageInfo(mi) 838 } 839 return ms 840 } 841 return mi.MessageOf(x) 842} 843 844// Deprecated: Use Location.ProtoReflect.Descriptor instead. 845func (*Location) Descriptor() ([]byte, []int) { 846 return file_Flight_proto_rawDescGZIP(), []int{12} 847} 848 849func (x *Location) GetUri() string { 850 if x != nil { 851 return x.Uri 852 } 853 return "" 854} 855 856// 857// An opaque identifier that the service can use to retrieve a particular 858// portion of a stream. 859type Ticket struct { 860 state protoimpl.MessageState 861 sizeCache protoimpl.SizeCache 862 unknownFields protoimpl.UnknownFields 863 864 Ticket []byte `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"` 865} 866 867func (x *Ticket) Reset() { 868 *x = Ticket{} 869 if protoimpl.UnsafeEnabled { 870 mi := &file_Flight_proto_msgTypes[13] 871 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 872 ms.StoreMessageInfo(mi) 873 } 874} 875 876func (x *Ticket) String() string { 877 return protoimpl.X.MessageStringOf(x) 878} 879 880func (*Ticket) ProtoMessage() {} 881 882func (x *Ticket) ProtoReflect() protoreflect.Message { 883 mi := &file_Flight_proto_msgTypes[13] 884 if protoimpl.UnsafeEnabled && x != nil { 885 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 886 if ms.LoadMessageInfo() == nil { 887 ms.StoreMessageInfo(mi) 888 } 889 return ms 890 } 891 return mi.MessageOf(x) 892} 893 894// Deprecated: Use Ticket.ProtoReflect.Descriptor instead. 895func (*Ticket) Descriptor() ([]byte, []int) { 896 return file_Flight_proto_rawDescGZIP(), []int{13} 897} 898 899func (x *Ticket) GetTicket() []byte { 900 if x != nil { 901 return x.Ticket 902 } 903 return nil 904} 905 906// 907// A batch of Arrow data as part of a stream of batches. 908type FlightData struct { 909 state protoimpl.MessageState 910 sizeCache protoimpl.SizeCache 911 unknownFields protoimpl.UnknownFields 912 913 // 914 // The descriptor of the data. This is only relevant when a client is 915 // starting a new DoPut stream. 916 FlightDescriptor *FlightDescriptor `protobuf:"bytes,1,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"` 917 // 918 // Header for message data as described in Message.fbs::Message. 919 DataHeader []byte `protobuf:"bytes,2,opt,name=data_header,json=dataHeader,proto3" json:"data_header,omitempty"` 920 // 921 // Application-defined metadata. 922 AppMetadata []byte `protobuf:"bytes,3,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"` 923 // 924 // The actual batch of Arrow data. Preferably handled with minimal-copies 925 // coming last in the definition to help with sidecar patterns (it is 926 // expected that some implementations will fetch this field off the wire 927 // with specialized code to avoid extra memory copies). 928 DataBody []byte `protobuf:"bytes,1000,opt,name=data_body,json=dataBody,proto3" json:"data_body,omitempty"` 929} 930 931func (x *FlightData) Reset() { 932 *x = FlightData{} 933 if protoimpl.UnsafeEnabled { 934 mi := &file_Flight_proto_msgTypes[14] 935 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 936 ms.StoreMessageInfo(mi) 937 } 938} 939 940func (x *FlightData) String() string { 941 return protoimpl.X.MessageStringOf(x) 942} 943 944func (*FlightData) ProtoMessage() {} 945 946func (x *FlightData) ProtoReflect() protoreflect.Message { 947 mi := &file_Flight_proto_msgTypes[14] 948 if protoimpl.UnsafeEnabled && x != nil { 949 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 950 if ms.LoadMessageInfo() == nil { 951 ms.StoreMessageInfo(mi) 952 } 953 return ms 954 } 955 return mi.MessageOf(x) 956} 957 958// Deprecated: Use FlightData.ProtoReflect.Descriptor instead. 959func (*FlightData) Descriptor() ([]byte, []int) { 960 return file_Flight_proto_rawDescGZIP(), []int{14} 961} 962 963func (x *FlightData) GetFlightDescriptor() *FlightDescriptor { 964 if x != nil { 965 return x.FlightDescriptor 966 } 967 return nil 968} 969 970func (x *FlightData) GetDataHeader() []byte { 971 if x != nil { 972 return x.DataHeader 973 } 974 return nil 975} 976 977func (x *FlightData) GetAppMetadata() []byte { 978 if x != nil { 979 return x.AppMetadata 980 } 981 return nil 982} 983 984func (x *FlightData) GetDataBody() []byte { 985 if x != nil { 986 return x.DataBody 987 } 988 return nil 989} 990 991//* 992// The response message associated with the submission of a DoPut. 993type PutResult struct { 994 state protoimpl.MessageState 995 sizeCache protoimpl.SizeCache 996 unknownFields protoimpl.UnknownFields 997 998 AppMetadata []byte `protobuf:"bytes,1,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"` 999} 1000 1001func (x *PutResult) Reset() { 1002 *x = PutResult{} 1003 if protoimpl.UnsafeEnabled { 1004 mi := &file_Flight_proto_msgTypes[15] 1005 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1006 ms.StoreMessageInfo(mi) 1007 } 1008} 1009 1010func (x *PutResult) String() string { 1011 return protoimpl.X.MessageStringOf(x) 1012} 1013 1014func (*PutResult) ProtoMessage() {} 1015 1016func (x *PutResult) ProtoReflect() protoreflect.Message { 1017 mi := &file_Flight_proto_msgTypes[15] 1018 if protoimpl.UnsafeEnabled && x != nil { 1019 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1020 if ms.LoadMessageInfo() == nil { 1021 ms.StoreMessageInfo(mi) 1022 } 1023 return ms 1024 } 1025 return mi.MessageOf(x) 1026} 1027 1028// Deprecated: Use PutResult.ProtoReflect.Descriptor instead. 1029func (*PutResult) Descriptor() ([]byte, []int) { 1030 return file_Flight_proto_rawDescGZIP(), []int{15} 1031} 1032 1033func (x *PutResult) GetAppMetadata() []byte { 1034 if x != nil { 1035 return x.AppMetadata 1036 } 1037 return nil 1038} 1039 1040var File_Flight_proto protoreflect.FileDescriptor 1041 1042var file_Flight_proto_rawDesc = []byte{ 1043 0x0a, 0x0c, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x15, 1044 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 1045 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x22, 0x57, 0x0a, 0x10, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 1046 0x6b, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x29, 0x0a, 0x10, 0x70, 0x72, 0x6f, 1047 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 1048 0x01, 0x28, 0x04, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 1049 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 1050 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x58, 1051 0x0a, 0x11, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 1052 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 1053 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x70, 1054 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 1055 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 1056 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x43, 0x0a, 0x09, 0x42, 0x61, 0x73, 0x69, 1057 0x63, 0x41, 0x75, 0x74, 0x68, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 1058 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 1059 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x18, 0x03, 0x20, 1060 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x22, 0x07, 0x0a, 1061 0x05, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x42, 0x0a, 0x0a, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 1062 0x54, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 1063 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 1064 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 1065 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x2a, 0x0a, 0x08, 0x43, 0x72, 1066 0x69, 0x74, 0x65, 0x72, 0x69, 0x61, 0x12, 0x1e, 0x0a, 0x0a, 0x65, 0x78, 0x70, 0x72, 0x65, 0x73, 1067 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x72, 1068 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x30, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 1069 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 1070 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x02, 0x20, 0x01, 1071 0x28, 0x0c, 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x22, 0x1c, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, 1072 0x6c, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 1073 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x22, 0x26, 0x0a, 0x0c, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 1074 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 1075 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0xb6, 1076 0x01, 0x0a, 0x10, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 1077 0x74, 0x6f, 0x72, 0x12, 0x4a, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 1078 0x0e, 0x32, 0x36, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 1079 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 1080 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x2e, 0x44, 0x65, 0x73, 0x63, 0x72, 1081 0x69, 0x70, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 1082 0x10, 0x0a, 0x03, 0x63, 0x6d, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x63, 0x6d, 1083 0x64, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 1084 0x04, 0x70, 0x61, 0x74, 0x68, 0x22, 0x30, 0x0a, 0x0e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 1085 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 1086 0x57, 0x4e, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x50, 0x41, 0x54, 0x48, 0x10, 0x01, 0x12, 0x07, 1087 0x0a, 0x03, 0x43, 0x4d, 0x44, 0x10, 0x02, 0x22, 0x83, 0x02, 0x0a, 0x0a, 0x46, 0x6c, 0x69, 0x67, 1088 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 1089 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x54, 1090 0x0a, 0x11, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 1091 0x74, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x61, 0x72, 0x72, 0x6f, 1092 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 1093 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1094 0x6f, 0x72, 0x52, 0x10, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 1095 0x70, 0x74, 0x6f, 0x72, 0x12, 0x41, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 1096 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 1097 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 1098 0x6c, 0x69, 0x67, 0x68, 0x74, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x08, 0x65, 1099 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x6f, 0x74, 0x61, 0x6c, 1100 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 1101 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 1102 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 1103 0x03, 0x52, 0x0a, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x42, 0x79, 0x74, 0x65, 0x73, 0x22, 0x84, 0x01, 1104 0x0a, 0x0e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 1105 0x12, 0x35, 0x0a, 0x06, 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 1106 0x32, 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 1107 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x52, 1108 0x06, 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x3b, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 1109 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x61, 0x72, 0x72, 0x6f, 1110 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 1111 0x6c, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 1112 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x1c, 0x0a, 0x08, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1113 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72, 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 1114 0x72, 0x69, 0x22, 0x20, 0x0a, 0x06, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x16, 0x0a, 0x06, 1115 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x74, 0x69, 1116 0x63, 0x6b, 0x65, 0x74, 0x22, 0xc4, 0x01, 0x0a, 0x0a, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 1117 0x61, 0x74, 0x61, 0x12, 0x54, 0x0a, 0x11, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x64, 0x65, 1118 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 1119 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 1120 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 1121 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x52, 0x10, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 1122 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x12, 0x1f, 0x0a, 0x0b, 0x64, 0x61, 0x74, 1123 0x61, 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0a, 1124 0x64, 0x61, 0x74, 0x61, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x70, 1125 0x70, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 1126 0x52, 0x0b, 0x61, 0x70, 0x70, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1c, 0x0a, 1127 0x09, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x62, 0x6f, 0x64, 0x79, 0x18, 0xe8, 0x07, 0x20, 0x01, 0x28, 1128 0x0c, 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, 0x42, 0x6f, 0x64, 0x79, 0x22, 0x2e, 0x0a, 0x09, 0x50, 1129 0x75, 0x74, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x70, 0x70, 0x5f, 1130 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, 1131 0x61, 0x70, 0x70, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x32, 0xa7, 0x06, 0x0a, 0x0d, 1132 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x64, 0x0a, 1133 0x09, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x12, 0x27, 0x2e, 0x61, 0x72, 0x72, 1134 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 1135 0x6f, 0x6c, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x75, 1136 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 1137 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x48, 0x61, 0x6e, 0x64, 1138 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 1139 0x01, 0x30, 0x01, 0x12, 0x55, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x6c, 0x69, 0x67, 0x68, 1140 0x74, 0x73, 0x12, 0x1f, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 1141 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x72, 0x69, 0x74, 0x65, 1142 0x72, 0x69, 0x61, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 1143 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 1144 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x00, 0x30, 0x01, 0x12, 0x5d, 0x0a, 0x0d, 0x47, 0x65, 1145 0x74, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x27, 0x2e, 0x61, 0x72, 1146 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 1147 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 1148 0x70, 0x74, 0x6f, 0x72, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 1149 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 1150 0x67, 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x00, 0x12, 0x5b, 0x0a, 0x09, 0x47, 0x65, 0x74, 1151 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x27, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 1152 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 1153 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x1a, 1154 0x23, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 1155 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, 1156 0x73, 0x75, 0x6c, 0x74, 0x22, 0x00, 0x12, 0x4d, 0x0a, 0x05, 0x44, 0x6f, 0x47, 0x65, 0x74, 0x12, 1157 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 1158 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x1a, 0x21, 1159 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 1160 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 1161 0x61, 0x22, 0x00, 0x30, 0x01, 0x12, 0x52, 0x0a, 0x05, 0x44, 0x6f, 0x50, 0x75, 0x74, 0x12, 0x21, 1162 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 1163 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 1164 0x61, 0x1a, 0x20, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 1165 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x50, 0x75, 0x74, 0x52, 0x65, 0x73, 1166 0x75, 0x6c, 0x74, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x58, 0x0a, 0x0a, 0x44, 0x6f, 0x45, 1167 0x78, 0x63, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x12, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 1168 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 1169 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 0x61, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, 1170 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 1171 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 0x61, 0x22, 0x00, 0x28, 1172 0x01, 0x30, 0x01, 0x12, 0x4c, 0x0a, 0x08, 0x44, 0x6f, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 1173 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 1174 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0x1d, 1175 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 1176 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x00, 0x30, 1177 0x01, 0x12, 0x52, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 1178 0x12, 0x1c, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 1179 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x21, 1180 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 1181 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 1182 0x65, 0x22, 0x00, 0x30, 0x01, 0x42, 0x48, 0x0a, 0x1c, 0x6f, 0x72, 0x67, 0x2e, 0x61, 0x70, 0x61, 1183 0x63, 0x68, 0x65, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 1184 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x5a, 0x28, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 1185 0x6d, 0x2f, 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2f, 0x67, 1186 0x6f, 0x2f, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x3b, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x62, 1187 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1188} 1189 1190var ( 1191 file_Flight_proto_rawDescOnce sync.Once 1192 file_Flight_proto_rawDescData = file_Flight_proto_rawDesc 1193) 1194 1195func file_Flight_proto_rawDescGZIP() []byte { 1196 file_Flight_proto_rawDescOnce.Do(func() { 1197 file_Flight_proto_rawDescData = protoimpl.X.CompressGZIP(file_Flight_proto_rawDescData) 1198 }) 1199 return file_Flight_proto_rawDescData 1200} 1201 1202var file_Flight_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 1203var file_Flight_proto_msgTypes = make([]protoimpl.MessageInfo, 16) 1204var file_Flight_proto_goTypes = []interface{}{ 1205 (FlightDescriptor_DescriptorType)(0), // 0: arrow.flight.protocol.FlightDescriptor.DescriptorType 1206 (*HandshakeRequest)(nil), // 1: arrow.flight.protocol.HandshakeRequest 1207 (*HandshakeResponse)(nil), // 2: arrow.flight.protocol.HandshakeResponse 1208 (*BasicAuth)(nil), // 3: arrow.flight.protocol.BasicAuth 1209 (*Empty)(nil), // 4: arrow.flight.protocol.Empty 1210 (*ActionType)(nil), // 5: arrow.flight.protocol.ActionType 1211 (*Criteria)(nil), // 6: arrow.flight.protocol.Criteria 1212 (*Action)(nil), // 7: arrow.flight.protocol.Action 1213 (*Result)(nil), // 8: arrow.flight.protocol.Result 1214 (*SchemaResult)(nil), // 9: arrow.flight.protocol.SchemaResult 1215 (*FlightDescriptor)(nil), // 10: arrow.flight.protocol.FlightDescriptor 1216 (*FlightInfo)(nil), // 11: arrow.flight.protocol.FlightInfo 1217 (*FlightEndpoint)(nil), // 12: arrow.flight.protocol.FlightEndpoint 1218 (*Location)(nil), // 13: arrow.flight.protocol.Location 1219 (*Ticket)(nil), // 14: arrow.flight.protocol.Ticket 1220 (*FlightData)(nil), // 15: arrow.flight.protocol.FlightData 1221 (*PutResult)(nil), // 16: arrow.flight.protocol.PutResult 1222} 1223var file_Flight_proto_depIdxs = []int32{ 1224 0, // 0: arrow.flight.protocol.FlightDescriptor.type:type_name -> arrow.flight.protocol.FlightDescriptor.DescriptorType 1225 10, // 1: arrow.flight.protocol.FlightInfo.flight_descriptor:type_name -> arrow.flight.protocol.FlightDescriptor 1226 12, // 2: arrow.flight.protocol.FlightInfo.endpoint:type_name -> arrow.flight.protocol.FlightEndpoint 1227 14, // 3: arrow.flight.protocol.FlightEndpoint.ticket:type_name -> arrow.flight.protocol.Ticket 1228 13, // 4: arrow.flight.protocol.FlightEndpoint.location:type_name -> arrow.flight.protocol.Location 1229 10, // 5: arrow.flight.protocol.FlightData.flight_descriptor:type_name -> arrow.flight.protocol.FlightDescriptor 1230 1, // 6: arrow.flight.protocol.FlightService.Handshake:input_type -> arrow.flight.protocol.HandshakeRequest 1231 6, // 7: arrow.flight.protocol.FlightService.ListFlights:input_type -> arrow.flight.protocol.Criteria 1232 10, // 8: arrow.flight.protocol.FlightService.GetFlightInfo:input_type -> arrow.flight.protocol.FlightDescriptor 1233 10, // 9: arrow.flight.protocol.FlightService.GetSchema:input_type -> arrow.flight.protocol.FlightDescriptor 1234 14, // 10: arrow.flight.protocol.FlightService.DoGet:input_type -> arrow.flight.protocol.Ticket 1235 15, // 11: arrow.flight.protocol.FlightService.DoPut:input_type -> arrow.flight.protocol.FlightData 1236 15, // 12: arrow.flight.protocol.FlightService.DoExchange:input_type -> arrow.flight.protocol.FlightData 1237 7, // 13: arrow.flight.protocol.FlightService.DoAction:input_type -> arrow.flight.protocol.Action 1238 4, // 14: arrow.flight.protocol.FlightService.ListActions:input_type -> arrow.flight.protocol.Empty 1239 2, // 15: arrow.flight.protocol.FlightService.Handshake:output_type -> arrow.flight.protocol.HandshakeResponse 1240 11, // 16: arrow.flight.protocol.FlightService.ListFlights:output_type -> arrow.flight.protocol.FlightInfo 1241 11, // 17: arrow.flight.protocol.FlightService.GetFlightInfo:output_type -> arrow.flight.protocol.FlightInfo 1242 9, // 18: arrow.flight.protocol.FlightService.GetSchema:output_type -> arrow.flight.protocol.SchemaResult 1243 15, // 19: arrow.flight.protocol.FlightService.DoGet:output_type -> arrow.flight.protocol.FlightData 1244 16, // 20: arrow.flight.protocol.FlightService.DoPut:output_type -> arrow.flight.protocol.PutResult 1245 15, // 21: arrow.flight.protocol.FlightService.DoExchange:output_type -> arrow.flight.protocol.FlightData 1246 8, // 22: arrow.flight.protocol.FlightService.DoAction:output_type -> arrow.flight.protocol.Result 1247 5, // 23: arrow.flight.protocol.FlightService.ListActions:output_type -> arrow.flight.protocol.ActionType 1248 15, // [15:24] is the sub-list for method output_type 1249 6, // [6:15] is the sub-list for method input_type 1250 6, // [6:6] is the sub-list for extension type_name 1251 6, // [6:6] is the sub-list for extension extendee 1252 0, // [0:6] is the sub-list for field type_name 1253} 1254 1255func init() { file_Flight_proto_init() } 1256func file_Flight_proto_init() { 1257 if File_Flight_proto != nil { 1258 return 1259 } 1260 if !protoimpl.UnsafeEnabled { 1261 file_Flight_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1262 switch v := v.(*HandshakeRequest); i { 1263 case 0: 1264 return &v.state 1265 case 1: 1266 return &v.sizeCache 1267 case 2: 1268 return &v.unknownFields 1269 default: 1270 return nil 1271 } 1272 } 1273 file_Flight_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1274 switch v := v.(*HandshakeResponse); i { 1275 case 0: 1276 return &v.state 1277 case 1: 1278 return &v.sizeCache 1279 case 2: 1280 return &v.unknownFields 1281 default: 1282 return nil 1283 } 1284 } 1285 file_Flight_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1286 switch v := v.(*BasicAuth); i { 1287 case 0: 1288 return &v.state 1289 case 1: 1290 return &v.sizeCache 1291 case 2: 1292 return &v.unknownFields 1293 default: 1294 return nil 1295 } 1296 } 1297 file_Flight_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1298 switch v := v.(*Empty); i { 1299 case 0: 1300 return &v.state 1301 case 1: 1302 return &v.sizeCache 1303 case 2: 1304 return &v.unknownFields 1305 default: 1306 return nil 1307 } 1308 } 1309 file_Flight_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1310 switch v := v.(*ActionType); i { 1311 case 0: 1312 return &v.state 1313 case 1: 1314 return &v.sizeCache 1315 case 2: 1316 return &v.unknownFields 1317 default: 1318 return nil 1319 } 1320 } 1321 file_Flight_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1322 switch v := v.(*Criteria); i { 1323 case 0: 1324 return &v.state 1325 case 1: 1326 return &v.sizeCache 1327 case 2: 1328 return &v.unknownFields 1329 default: 1330 return nil 1331 } 1332 } 1333 file_Flight_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1334 switch v := v.(*Action); i { 1335 case 0: 1336 return &v.state 1337 case 1: 1338 return &v.sizeCache 1339 case 2: 1340 return &v.unknownFields 1341 default: 1342 return nil 1343 } 1344 } 1345 file_Flight_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1346 switch v := v.(*Result); i { 1347 case 0: 1348 return &v.state 1349 case 1: 1350 return &v.sizeCache 1351 case 2: 1352 return &v.unknownFields 1353 default: 1354 return nil 1355 } 1356 } 1357 file_Flight_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1358 switch v := v.(*SchemaResult); i { 1359 case 0: 1360 return &v.state 1361 case 1: 1362 return &v.sizeCache 1363 case 2: 1364 return &v.unknownFields 1365 default: 1366 return nil 1367 } 1368 } 1369 file_Flight_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1370 switch v := v.(*FlightDescriptor); i { 1371 case 0: 1372 return &v.state 1373 case 1: 1374 return &v.sizeCache 1375 case 2: 1376 return &v.unknownFields 1377 default: 1378 return nil 1379 } 1380 } 1381 file_Flight_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 1382 switch v := v.(*FlightInfo); i { 1383 case 0: 1384 return &v.state 1385 case 1: 1386 return &v.sizeCache 1387 case 2: 1388 return &v.unknownFields 1389 default: 1390 return nil 1391 } 1392 } 1393 file_Flight_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 1394 switch v := v.(*FlightEndpoint); i { 1395 case 0: 1396 return &v.state 1397 case 1: 1398 return &v.sizeCache 1399 case 2: 1400 return &v.unknownFields 1401 default: 1402 return nil 1403 } 1404 } 1405 file_Flight_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { 1406 switch v := v.(*Location); i { 1407 case 0: 1408 return &v.state 1409 case 1: 1410 return &v.sizeCache 1411 case 2: 1412 return &v.unknownFields 1413 default: 1414 return nil 1415 } 1416 } 1417 file_Flight_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { 1418 switch v := v.(*Ticket); i { 1419 case 0: 1420 return &v.state 1421 case 1: 1422 return &v.sizeCache 1423 case 2: 1424 return &v.unknownFields 1425 default: 1426 return nil 1427 } 1428 } 1429 file_Flight_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { 1430 switch v := v.(*FlightData); i { 1431 case 0: 1432 return &v.state 1433 case 1: 1434 return &v.sizeCache 1435 case 2: 1436 return &v.unknownFields 1437 default: 1438 return nil 1439 } 1440 } 1441 file_Flight_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { 1442 switch v := v.(*PutResult); i { 1443 case 0: 1444 return &v.state 1445 case 1: 1446 return &v.sizeCache 1447 case 2: 1448 return &v.unknownFields 1449 default: 1450 return nil 1451 } 1452 } 1453 } 1454 type x struct{} 1455 out := protoimpl.TypeBuilder{ 1456 File: protoimpl.DescBuilder{ 1457 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1458 RawDescriptor: file_Flight_proto_rawDesc, 1459 NumEnums: 1, 1460 NumMessages: 16, 1461 NumExtensions: 0, 1462 NumServices: 1, 1463 }, 1464 GoTypes: file_Flight_proto_goTypes, 1465 DependencyIndexes: file_Flight_proto_depIdxs, 1466 EnumInfos: file_Flight_proto_enumTypes, 1467 MessageInfos: file_Flight_proto_msgTypes, 1468 }.Build() 1469 File_Flight_proto = out.File 1470 file_Flight_proto_rawDesc = nil 1471 file_Flight_proto_goTypes = nil 1472 file_Flight_proto_depIdxs = nil 1473} 1474