ceph/src/arrow/go/arrow/flight/Flight.pb.go

   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
  24 package flight
  25
  26 import (
  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
  34 const (
  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.
  43 const _ = proto.ProtoPackageIsVersion4
  44
  45 //
  46 // Describes what type of descriptor is defined.
  47 type FlightDescriptor_DescriptorType int32
  48
  49 const (
  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.
  63 var (
  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
  76 func (x FlightDescriptor_DescriptorType) Enum() *FlightDescriptor_DescriptorType {
  77         p := new(FlightDescriptor_DescriptorType)
  78         *p = x
  79         return p
  80 }
  81
  82 func (x FlightDescriptor_DescriptorType) String() string {
  83         return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
  84 }
  85
  86 func (FlightDescriptor_DescriptorType) Descriptor() protoreflect.EnumDescriptor {
  87         return file_Flight_proto_enumTypes[0].Descriptor()
  88 }
  89
  90 func (FlightDescriptor_DescriptorType) Type() protoreflect.EnumType {
  91         return &file_Flight_proto_enumTypes[0]
  92 }
  93
  94 func (x FlightDescriptor_DescriptorType) Number() protoreflect.EnumNumber {
  95         return protoreflect.EnumNumber(x)
  96 }
  97
  98 // Deprecated: Use FlightDescriptor_DescriptorType.Descriptor instead.
  99 func (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.
 105 type 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
 118 func (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
 127 func (x *HandshakeRequest) String() string {
 128         return protoimpl.X.MessageStringOf(x)
 129 }
 130
 131 func (*HandshakeRequest) ProtoMessage() {}
 132
 133 func (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.
 146 func (*HandshakeRequest) Descriptor() ([]byte, []int) {
 147         return file_Flight_proto_rawDescGZIP(), []int{0}
 148 }
 149
 150 func (x *HandshakeRequest) GetProtocolVersion() uint64 {
 151         if x != nil {
 152                 return x.ProtocolVersion
 153         }
 154         return 0
 155 }
 156
 157 func (x *HandshakeRequest) GetPayload() []byte {
 158         if x != nil {
 159                 return x.Payload
 160         }
 161         return nil
 162 }
 163
 164 type 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
 177 func (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
 186 func (x *HandshakeResponse) String() string {
 187         return protoimpl.X.MessageStringOf(x)
 188 }
 189
 190 func (*HandshakeResponse) ProtoMessage() {}
 191
 192 func (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.
 205 func (*HandshakeResponse) Descriptor() ([]byte, []int) {
 206         return file_Flight_proto_rawDescGZIP(), []int{1}
 207 }
 208
 209 func (x *HandshakeResponse) GetProtocolVersion() uint64 {
 210         if x != nil {
 211                 return x.ProtocolVersion
 212         }
 213         return 0
 214 }
 215
 216 func (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.
 225 type 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
 234 func (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
 243 func (x *BasicAuth) String() string {
 244         return protoimpl.X.MessageStringOf(x)
 245 }
 246
 247 func (*BasicAuth) ProtoMessage() {}
 248
 249 func (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.
 262 func (*BasicAuth) Descriptor() ([]byte, []int) {
 263         return file_Flight_proto_rawDescGZIP(), []int{2}
 264 }
 265
 266 func (x *BasicAuth) GetUsername() string {
 267         if x != nil {
 268                 return x.Username
 269         }
 270         return ""
 271 }
 272
 273 func (x *BasicAuth) GetPassword() string {
 274         if x != nil {
 275                 return x.Password
 276         }
 277         return ""
 278 }
 279
 280 type Empty struct {
 281         state         protoimpl.MessageState
 282         sizeCache     protoimpl.SizeCache
 283         unknownFields protoimpl.UnknownFields
 284 }
 285
 286 func (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
 295 func (x *Empty) String() string {
 296         return protoimpl.X.MessageStringOf(x)
 297 }
 298
 299 func (*Empty) ProtoMessage() {}
 300
 301 func (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.
 314 func (*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.
 321 type 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
 330 func (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
 339 func (x *ActionType) String() string {
 340         return protoimpl.X.MessageStringOf(x)
 341 }
 342
 343 func (*ActionType) ProtoMessage() {}
 344
 345 func (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.
 358 func (*ActionType) Descriptor() ([]byte, []int) {
 359         return file_Flight_proto_rawDescGZIP(), []int{4}
 360 }
 361
 362 func (x *ActionType) GetType() string {
 363         if x != nil {
 364                 return x.Type
 365         }
 366         return ""
 367 }
 368
 369 func (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.
 379 type 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
 387 func (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
 396 func (x *Criteria) String() string {
 397         return protoimpl.X.MessageStringOf(x)
 398 }
 399
 400 func (*Criteria) ProtoMessage() {}
 401
 402 func (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.
 415 func (*Criteria) Descriptor() ([]byte, []int) {
 416         return file_Flight_proto_rawDescGZIP(), []int{5}
 417 }
 418
 419 func (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.
 428 type 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
 437 func (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
 446 func (x *Action) String() string {
 447         return protoimpl.X.MessageStringOf(x)
 448 }
 449
 450 func (*Action) ProtoMessage() {}
 451
 452 func (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.
 465 func (*Action) Descriptor() ([]byte, []int) {
 466         return file_Flight_proto_rawDescGZIP(), []int{6}
 467 }
 468
 469 func (x *Action) GetType() string {
 470         if x != nil {
 471                 return x.Type
 472         }
 473         return ""
 474 }
 475
 476 func (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.
 485 type 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
 493 func (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
 502 func (x *Result) String() string {
 503         return protoimpl.X.MessageStringOf(x)
 504 }
 505
 506 func (*Result) ProtoMessage() {}
 507
 508 func (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.
 521 func (*Result) Descriptor() ([]byte, []int) {
 522         return file_Flight_proto_rawDescGZIP(), []int{7}
 523 }
 524
 525 func (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
 534 type 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
 543 func (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
 552 func (x *SchemaResult) String() string {
 553         return protoimpl.X.MessageStringOf(x)
 554 }
 555
 556 func (*SchemaResult) ProtoMessage() {}
 557
 558 func (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.
 571 func (*SchemaResult) Descriptor() ([]byte, []int) {
 572         return file_Flight_proto_rawDescGZIP(), []int{8}
 573 }
 574
 575 func (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.
 585 type 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
 601 func (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
 610 func (x *FlightDescriptor) String() string {
 611         return protoimpl.X.MessageStringOf(x)
 612 }
 613
 614 func (*FlightDescriptor) ProtoMessage() {}
 615
 616 func (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.
 629 func (*FlightDescriptor) Descriptor() ([]byte, []int) {
 630         return file_Flight_proto_rawDescGZIP(), []int{9}
 631 }
 632
 633 func (x *FlightDescriptor) GetType() FlightDescriptor_DescriptorType {
 634         if x != nil {
 635                 return x.Type
 636         }
 637         return FlightDescriptor_UNKNOWN
 638 }
 639
 640 func (x *FlightDescriptor) GetCmd() []byte {
 641         if x != nil {
 642                 return x.Cmd
 643         }
 644         return nil
 645 }
 646
 647 func (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.
 657 type 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
 676 func (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
 685 func (x *FlightInfo) String() string {
 686         return protoimpl.X.MessageStringOf(x)
 687 }
 688
 689 func (*FlightInfo) ProtoMessage() {}
 690
 691 func (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.
 704 func (*FlightInfo) Descriptor() ([]byte, []int) {
 705         return file_Flight_proto_rawDescGZIP(), []int{10}
 706 }
 707
 708 func (x *FlightInfo) GetSchema() []byte {
 709         if x != nil {
 710                 return x.Schema
 711         }
 712         return nil
 713 }
 714
 715 func (x *FlightInfo) GetFlightDescriptor() *FlightDescriptor {
 716         if x != nil {
 717                 return x.FlightDescriptor
 718         }
 719         return nil
 720 }
 721
 722 func (x *FlightInfo) GetEndpoint() []*FlightEndpoint {
 723         if x != nil {
 724                 return x.Endpoint
 725         }
 726         return nil
 727 }
 728
 729 func (x *FlightInfo) GetTotalRecords() int64 {
 730         if x != nil {
 731                 return x.TotalRecords
 732         }
 733         return 0
 734 }
 735
 736 func (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.
 745 type 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
 760 func (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
 769 func (x *FlightEndpoint) String() string {
 770         return protoimpl.X.MessageStringOf(x)
 771 }
 772
 773 func (*FlightEndpoint) ProtoMessage() {}
 774
 775 func (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.
 788 func (*FlightEndpoint) Descriptor() ([]byte, []int) {
 789         return file_Flight_proto_rawDescGZIP(), []int{11}
 790 }
 791
 792 func (x *FlightEndpoint) GetTicket() *Ticket {
 793         if x != nil {
 794                 return x.Ticket
 795         }
 796         return nil
 797 }
 798
 799 func (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.
 809 type 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
 817 func (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
 826 func (x *Location) String() string {
 827         return protoimpl.X.MessageStringOf(x)
 828 }
 829
 830 func (*Location) ProtoMessage() {}
 831
 832 func (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.
 845 func (*Location) Descriptor() ([]byte, []int) {
 846         return file_Flight_proto_rawDescGZIP(), []int{12}
 847 }
 848
 849 func (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.
 859 type 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
 867 func (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
 876 func (x *Ticket) String() string {
 877         return protoimpl.X.MessageStringOf(x)
 878 }
 879
 880 func (*Ticket) ProtoMessage() {}
 881
 882 func (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.
 895 func (*Ticket) Descriptor() ([]byte, []int) {
 896         return file_Flight_proto_rawDescGZIP(), []int{13}
 897 }
 898
 899 func (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.
 908 type 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
 931 func (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
 940 func (x *FlightData) String() string {
 941         return protoimpl.X.MessageStringOf(x)
 942 }
 943
 944 func (*FlightData) ProtoMessage() {}
 945
 946 func (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.
 959 func (*FlightData) Descriptor() ([]byte, []int) {
 960         return file_Flight_proto_rawDescGZIP(), []int{14}
 961 }
 962
 963 func (x *FlightData) GetFlightDescriptor() *FlightDescriptor {
 964         if x != nil {
 965                 return x.FlightDescriptor
 966         }
 967         return nil
 968 }
 969
 970 func (x *FlightData) GetDataHeader() []byte {
 971         if x != nil {
 972                 return x.DataHeader
 973         }
 974         return nil
 975 }
 976
 977 func (x *FlightData) GetAppMetadata() []byte {
 978         if x != nil {
 979                 return x.AppMetadata
 980         }
 981         return nil
 982 }
 983
 984 func (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.
 993 type 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
1001 func (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
1010 func (x *PutResult) String() string {
1011         return protoimpl.X.MessageStringOf(x)
1012 }
1013
1014 func (*PutResult) ProtoMessage() {}
1015
1016 func (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.
1029 func (*PutResult) Descriptor() ([]byte, []int) {
1030         return file_Flight_proto_rawDescGZIP(), []int{15}
1031 }
1032
1033 func (x *PutResult) GetAppMetadata() []byte {
1034         if x != nil {
1035                 return x.AppMetadata
1036         }
1037         return nil
1038 }
1039
1040 var File_Flight_proto protoreflect.FileDescriptor
1041
1042 var 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
1190 var (
1191         file_Flight_proto_rawDescOnce sync.Once
1192         file_Flight_proto_rawDescData = file_Flight_proto_rawDesc
1193 )
1194
1195 func 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
1202 var file_Flight_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
1203 var file_Flight_proto_msgTypes = make([]protoimpl.MessageInfo, 16)
1204 var 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 }
1223 var 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
1255 func init() { file_Flight_proto_init() }
1256 func 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 }