| // |
| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you under the Apache License, Version 2.0 (the |
| // "License"); you may not use this file except in compliance |
| // with the License. You may obtain a copy of the License at |
| // <p> |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // <p> |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.25.0 |
| // protoc v3.9.1 |
| // source: Flight.proto |
| |
| package flight |
| |
| import ( |
| proto "github.com/golang/protobuf/proto" |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| reflect "reflect" |
| sync "sync" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| // This is a compile-time assertion that a sufficiently up-to-date version |
| // of the legacy proto package is being used. |
| const _ = proto.ProtoPackageIsVersion4 |
| |
| // |
| // Describes what type of descriptor is defined. |
| type FlightDescriptor_DescriptorType int32 |
| |
| const ( |
| // Protobuf pattern, not used. |
| FlightDescriptor_UNKNOWN FlightDescriptor_DescriptorType = 0 |
| // |
| // A named path that identifies a dataset. A path is composed of a string |
| // or list of strings describing a particular dataset. This is conceptually |
| // similar to a path inside a filesystem. |
| FlightDescriptor_PATH FlightDescriptor_DescriptorType = 1 |
| // |
| // An opaque command to generate a dataset. |
| FlightDescriptor_CMD FlightDescriptor_DescriptorType = 2 |
| ) |
| |
| // Enum value maps for FlightDescriptor_DescriptorType. |
| var ( |
| FlightDescriptor_DescriptorType_name = map[int32]string{ |
| 0: "UNKNOWN", |
| 1: "PATH", |
| 2: "CMD", |
| } |
| FlightDescriptor_DescriptorType_value = map[string]int32{ |
| "UNKNOWN": 0, |
| "PATH": 1, |
| "CMD": 2, |
| } |
| ) |
| |
| func (x FlightDescriptor_DescriptorType) Enum() *FlightDescriptor_DescriptorType { |
| p := new(FlightDescriptor_DescriptorType) |
| *p = x |
| return p |
| } |
| |
| func (x FlightDescriptor_DescriptorType) String() string { |
| return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) |
| } |
| |
| func (FlightDescriptor_DescriptorType) Descriptor() protoreflect.EnumDescriptor { |
| return file_Flight_proto_enumTypes[0].Descriptor() |
| } |
| |
| func (FlightDescriptor_DescriptorType) Type() protoreflect.EnumType { |
| return &file_Flight_proto_enumTypes[0] |
| } |
| |
| func (x FlightDescriptor_DescriptorType) Number() protoreflect.EnumNumber { |
| return protoreflect.EnumNumber(x) |
| } |
| |
| // Deprecated: Use FlightDescriptor_DescriptorType.Descriptor instead. |
| func (FlightDescriptor_DescriptorType) EnumDescriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{9, 0} |
| } |
| |
| // |
| // The request that a client provides to a server on handshake. |
| type HandshakeRequest struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // |
| // A defined protocol version |
| ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` |
| // |
| // Arbitrary auth/handshake info. |
| Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` |
| } |
| |
| func (x *HandshakeRequest) Reset() { |
| *x = HandshakeRequest{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakeRequest) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakeRequest) ProtoMessage() {} |
| |
| func (x *HandshakeRequest) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[0] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakeRequest.ProtoReflect.Descriptor instead. |
| func (*HandshakeRequest) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *HandshakeRequest) GetProtocolVersion() uint64 { |
| if x != nil { |
| return x.ProtocolVersion |
| } |
| return 0 |
| } |
| |
| func (x *HandshakeRequest) GetPayload() []byte { |
| if x != nil { |
| return x.Payload |
| } |
| return nil |
| } |
| |
| type HandshakeResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // |
| // A defined protocol version |
| ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` |
| // |
| // Arbitrary auth/handshake info. |
| Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` |
| } |
| |
| func (x *HandshakeResponse) Reset() { |
| *x = HandshakeResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakeResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakeResponse) ProtoMessage() {} |
| |
| func (x *HandshakeResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[1] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakeResponse.ProtoReflect.Descriptor instead. |
| func (*HandshakeResponse) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (x *HandshakeResponse) GetProtocolVersion() uint64 { |
| if x != nil { |
| return x.ProtocolVersion |
| } |
| return 0 |
| } |
| |
| func (x *HandshakeResponse) GetPayload() []byte { |
| if x != nil { |
| return x.Payload |
| } |
| return nil |
| } |
| |
| // |
| // A message for doing simple auth. |
| type BasicAuth struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` |
| Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` |
| } |
| |
| func (x *BasicAuth) Reset() { |
| *x = BasicAuth{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *BasicAuth) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*BasicAuth) ProtoMessage() {} |
| |
| func (x *BasicAuth) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[2] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use BasicAuth.ProtoReflect.Descriptor instead. |
| func (*BasicAuth) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *BasicAuth) GetUsername() string { |
| if x != nil { |
| return x.Username |
| } |
| return "" |
| } |
| |
| func (x *BasicAuth) GetPassword() string { |
| if x != nil { |
| return x.Password |
| } |
| return "" |
| } |
| |
| type Empty struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *Empty) Reset() { |
| *x = Empty{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Empty) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Empty) ProtoMessage() {} |
| |
| func (x *Empty) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[3] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Empty.ProtoReflect.Descriptor instead. |
| func (*Empty) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{3} |
| } |
| |
| // |
| // Describes an available action, including both the name used for execution |
| // along with a short description of the purpose of the action. |
| type ActionType struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` |
| Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` |
| } |
| |
| func (x *ActionType) Reset() { |
| *x = ActionType{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ActionType) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ActionType) ProtoMessage() {} |
| |
| func (x *ActionType) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[4] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ActionType.ProtoReflect.Descriptor instead. |
| func (*ActionType) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *ActionType) GetType() string { |
| if x != nil { |
| return x.Type |
| } |
| return "" |
| } |
| |
| func (x *ActionType) GetDescription() string { |
| if x != nil { |
| return x.Description |
| } |
| return "" |
| } |
| |
| // |
| // A service specific expression that can be used to return a limited set |
| // of available Arrow Flight streams. |
| type Criteria struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Expression []byte `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"` |
| } |
| |
| func (x *Criteria) Reset() { |
| *x = Criteria{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Criteria) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Criteria) ProtoMessage() {} |
| |
| func (x *Criteria) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[5] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Criteria.ProtoReflect.Descriptor instead. |
| func (*Criteria) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{5} |
| } |
| |
| func (x *Criteria) GetExpression() []byte { |
| if x != nil { |
| return x.Expression |
| } |
| return nil |
| } |
| |
| // |
| // An opaque action specific for the service. |
| type Action struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` |
| Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` |
| } |
| |
| func (x *Action) Reset() { |
| *x = Action{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Action) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Action) ProtoMessage() {} |
| |
| func (x *Action) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[6] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Action.ProtoReflect.Descriptor instead. |
| func (*Action) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{6} |
| } |
| |
| func (x *Action) GetType() string { |
| if x != nil { |
| return x.Type |
| } |
| return "" |
| } |
| |
| func (x *Action) GetBody() []byte { |
| if x != nil { |
| return x.Body |
| } |
| return nil |
| } |
| |
| // |
| // An opaque result returned after executing an action. |
| type Result struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` |
| } |
| |
| func (x *Result) Reset() { |
| *x = Result{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Result) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Result) ProtoMessage() {} |
| |
| func (x *Result) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[7] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Result.ProtoReflect.Descriptor instead. |
| func (*Result) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{7} |
| } |
| |
| func (x *Result) GetBody() []byte { |
| if x != nil { |
| return x.Body |
| } |
| return nil |
| } |
| |
| // |
| // Wrap the result of a getSchema call |
| type SchemaResult struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // schema of the dataset as described in Schema.fbs::Schema. |
| Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` |
| } |
| |
| func (x *SchemaResult) Reset() { |
| *x = SchemaResult{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[8] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *SchemaResult) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*SchemaResult) ProtoMessage() {} |
| |
| func (x *SchemaResult) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[8] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use SchemaResult.ProtoReflect.Descriptor instead. |
| func (*SchemaResult) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{8} |
| } |
| |
| func (x *SchemaResult) GetSchema() []byte { |
| if x != nil { |
| return x.Schema |
| } |
| return nil |
| } |
| |
| // |
| // The name or tag for a Flight. May be used as a way to retrieve or generate |
| // a flight or be used to expose a set of previously defined flights. |
| type FlightDescriptor struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Type FlightDescriptor_DescriptorType `protobuf:"varint,1,opt,name=type,proto3,enum=arrow.flight.protocol.FlightDescriptor_DescriptorType" json:"type,omitempty"` |
| // |
| // Opaque value used to express a command. Should only be defined when |
| // type = CMD. |
| Cmd []byte `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` |
| // |
| // List of strings identifying a particular dataset. Should only be defined |
| // when type = PATH. |
| Path []string `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"` |
| } |
| |
| func (x *FlightDescriptor) Reset() { |
| *x = FlightDescriptor{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *FlightDescriptor) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FlightDescriptor) ProtoMessage() {} |
| |
| func (x *FlightDescriptor) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[9] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FlightDescriptor.ProtoReflect.Descriptor instead. |
| func (*FlightDescriptor) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{9} |
| } |
| |
| func (x *FlightDescriptor) GetType() FlightDescriptor_DescriptorType { |
| if x != nil { |
| return x.Type |
| } |
| return FlightDescriptor_UNKNOWN |
| } |
| |
| func (x *FlightDescriptor) GetCmd() []byte { |
| if x != nil { |
| return x.Cmd |
| } |
| return nil |
| } |
| |
| func (x *FlightDescriptor) GetPath() []string { |
| if x != nil { |
| return x.Path |
| } |
| return nil |
| } |
| |
| // |
| // The access coordinates for retrieval of a dataset. With a FlightInfo, a |
| // consumer is able to determine how to retrieve a dataset. |
| type FlightInfo struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // schema of the dataset as described in Schema.fbs::Schema. |
| Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` |
| // |
| // The descriptor associated with this info. |
| FlightDescriptor *FlightDescriptor `protobuf:"bytes,2,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"` |
| // |
| // A list of endpoints associated with the flight. To consume the whole |
| // flight, all endpoints must be consumed. |
| Endpoint []*FlightEndpoint `protobuf:"bytes,3,rep,name=endpoint,proto3" json:"endpoint,omitempty"` |
| // Set these to -1 if unknown. |
| TotalRecords int64 `protobuf:"varint,4,opt,name=total_records,json=totalRecords,proto3" json:"total_records,omitempty"` |
| TotalBytes int64 `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"` |
| } |
| |
| func (x *FlightInfo) Reset() { |
| *x = FlightInfo{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[10] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *FlightInfo) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FlightInfo) ProtoMessage() {} |
| |
| func (x *FlightInfo) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[10] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FlightInfo.ProtoReflect.Descriptor instead. |
| func (*FlightInfo) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{10} |
| } |
| |
| func (x *FlightInfo) GetSchema() []byte { |
| if x != nil { |
| return x.Schema |
| } |
| return nil |
| } |
| |
| func (x *FlightInfo) GetFlightDescriptor() *FlightDescriptor { |
| if x != nil { |
| return x.FlightDescriptor |
| } |
| return nil |
| } |
| |
| func (x *FlightInfo) GetEndpoint() []*FlightEndpoint { |
| if x != nil { |
| return x.Endpoint |
| } |
| return nil |
| } |
| |
| func (x *FlightInfo) GetTotalRecords() int64 { |
| if x != nil { |
| return x.TotalRecords |
| } |
| return 0 |
| } |
| |
| func (x *FlightInfo) GetTotalBytes() int64 { |
| if x != nil { |
| return x.TotalBytes |
| } |
| return 0 |
| } |
| |
| // |
| // A particular stream or split associated with a flight. |
| type FlightEndpoint struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // |
| // Token used to retrieve this stream. |
| Ticket *Ticket `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"` |
| // |
| // A list of URIs where this ticket can be redeemed. If the list is |
| // empty, the expectation is that the ticket can only be redeemed on the |
| // current service where the ticket was generated. |
| Location []*Location `protobuf:"bytes,2,rep,name=location,proto3" json:"location,omitempty"` |
| } |
| |
| func (x *FlightEndpoint) Reset() { |
| *x = FlightEndpoint{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[11] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *FlightEndpoint) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FlightEndpoint) ProtoMessage() {} |
| |
| func (x *FlightEndpoint) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[11] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FlightEndpoint.ProtoReflect.Descriptor instead. |
| func (*FlightEndpoint) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{11} |
| } |
| |
| func (x *FlightEndpoint) GetTicket() *Ticket { |
| if x != nil { |
| return x.Ticket |
| } |
| return nil |
| } |
| |
| func (x *FlightEndpoint) GetLocation() []*Location { |
| if x != nil { |
| return x.Location |
| } |
| return nil |
| } |
| |
| // |
| // A location where a Flight service will accept retrieval of a particular |
| // stream given a ticket. |
| type Location struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` |
| } |
| |
| func (x *Location) Reset() { |
| *x = Location{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[12] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Location) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Location) ProtoMessage() {} |
| |
| func (x *Location) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[12] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Location.ProtoReflect.Descriptor instead. |
| func (*Location) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{12} |
| } |
| |
| func (x *Location) GetUri() string { |
| if x != nil { |
| return x.Uri |
| } |
| return "" |
| } |
| |
| // |
| // An opaque identifier that the service can use to retrieve a particular |
| // portion of a stream. |
| type Ticket struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Ticket []byte `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"` |
| } |
| |
| func (x *Ticket) Reset() { |
| *x = Ticket{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[13] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Ticket) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Ticket) ProtoMessage() {} |
| |
| func (x *Ticket) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[13] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Ticket.ProtoReflect.Descriptor instead. |
| func (*Ticket) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{13} |
| } |
| |
| func (x *Ticket) GetTicket() []byte { |
| if x != nil { |
| return x.Ticket |
| } |
| return nil |
| } |
| |
| // |
| // A batch of Arrow data as part of a stream of batches. |
| type FlightData struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // |
| // The descriptor of the data. This is only relevant when a client is |
| // starting a new DoPut stream. |
| FlightDescriptor *FlightDescriptor `protobuf:"bytes,1,opt,name=flight_descriptor,json=flightDescriptor,proto3" json:"flight_descriptor,omitempty"` |
| // |
| // Header for message data as described in Message.fbs::Message. |
| DataHeader []byte `protobuf:"bytes,2,opt,name=data_header,json=dataHeader,proto3" json:"data_header,omitempty"` |
| // |
| // Application-defined metadata. |
| AppMetadata []byte `protobuf:"bytes,3,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"` |
| // |
| // The actual batch of Arrow data. Preferably handled with minimal-copies |
| // coming last in the definition to help with sidecar patterns (it is |
| // expected that some implementations will fetch this field off the wire |
| // with specialized code to avoid extra memory copies). |
| DataBody []byte `protobuf:"bytes,1000,opt,name=data_body,json=dataBody,proto3" json:"data_body,omitempty"` |
| } |
| |
| func (x *FlightData) Reset() { |
| *x = FlightData{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[14] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *FlightData) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FlightData) ProtoMessage() {} |
| |
| func (x *FlightData) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[14] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FlightData.ProtoReflect.Descriptor instead. |
| func (*FlightData) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{14} |
| } |
| |
| func (x *FlightData) GetFlightDescriptor() *FlightDescriptor { |
| if x != nil { |
| return x.FlightDescriptor |
| } |
| return nil |
| } |
| |
| func (x *FlightData) GetDataHeader() []byte { |
| if x != nil { |
| return x.DataHeader |
| } |
| return nil |
| } |
| |
| func (x *FlightData) GetAppMetadata() []byte { |
| if x != nil { |
| return x.AppMetadata |
| } |
| return nil |
| } |
| |
| func (x *FlightData) GetDataBody() []byte { |
| if x != nil { |
| return x.DataBody |
| } |
| return nil |
| } |
| |
| //* |
| // The response message associated with the submission of a DoPut. |
| type PutResult struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| AppMetadata []byte `protobuf:"bytes,1,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"` |
| } |
| |
| func (x *PutResult) Reset() { |
| *x = PutResult{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_Flight_proto_msgTypes[15] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *PutResult) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*PutResult) ProtoMessage() {} |
| |
| func (x *PutResult) ProtoReflect() protoreflect.Message { |
| mi := &file_Flight_proto_msgTypes[15] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use PutResult.ProtoReflect.Descriptor instead. |
| func (*PutResult) Descriptor() ([]byte, []int) { |
| return file_Flight_proto_rawDescGZIP(), []int{15} |
| } |
| |
| func (x *PutResult) GetAppMetadata() []byte { |
| if x != nil { |
| return x.AppMetadata |
| } |
| return nil |
| } |
| |
| var File_Flight_proto protoreflect.FileDescriptor |
| |
| var file_Flight_proto_rawDesc = []byte{ |
| 0x0a, 0x0c, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x15, |
| 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, |
| 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x22, 0x57, 0x0a, 0x10, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, |
| 0x6b, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x29, 0x0a, 0x10, 0x70, 0x72, 0x6f, |
| 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, |
| 0x01, 0x28, 0x04, 0x52, 0x0f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, |
| 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, |
| 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x58, |
| 0x0a, 0x11, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, |
| 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x5f, |
| 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x70, |
| 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, |
| 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, |
| 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x43, 0x0a, 0x09, 0x42, 0x61, 0x73, 0x69, |
| 0x63, 0x41, 0x75, 0x74, 0x68, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, |
| 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, |
| 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x18, 0x03, 0x20, |
| 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x61, 0x73, 0x73, 0x77, 0x6f, 0x72, 0x64, 0x22, 0x07, 0x0a, |
| 0x05, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x42, 0x0a, 0x0a, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, |
| 0x54, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, |
| 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, |
| 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, |
| 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x2a, 0x0a, 0x08, 0x43, 0x72, |
| 0x69, 0x74, 0x65, 0x72, 0x69, 0x61, 0x12, 0x1e, 0x0a, 0x0a, 0x65, 0x78, 0x70, 0x72, 0x65, 0x73, |
| 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x72, |
| 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x30, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, |
| 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, |
| 0x74, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x02, 0x20, 0x01, |
| 0x28, 0x0c, 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x22, 0x1c, 0x0a, 0x06, 0x52, 0x65, 0x73, 0x75, |
| 0x6c, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, |
| 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x22, 0x26, 0x0a, 0x0c, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, |
| 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, |
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0xb6, |
| 0x01, 0x0a, 0x10, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, |
| 0x74, 0x6f, 0x72, 0x12, 0x4a, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, |
| 0x0e, 0x32, 0x36, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, |
| 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, |
| 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x2e, 0x44, 0x65, 0x73, 0x63, 0x72, |
| 0x69, 0x70, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, |
| 0x10, 0x0a, 0x03, 0x63, 0x6d, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x63, 0x6d, |
| 0x64, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, |
| 0x04, 0x70, 0x61, 0x74, 0x68, 0x22, 0x30, 0x0a, 0x0e, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, |
| 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, |
| 0x57, 0x4e, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x50, 0x41, 0x54, 0x48, 0x10, 0x01, 0x12, 0x07, |
| 0x0a, 0x03, 0x43, 0x4d, 0x44, 0x10, 0x02, 0x22, 0x83, 0x02, 0x0a, 0x0a, 0x46, 0x6c, 0x69, 0x67, |
| 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, |
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x54, |
| 0x0a, 0x11, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, |
| 0x74, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x61, 0x72, 0x72, 0x6f, |
| 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, |
| 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, |
| 0x6f, 0x72, 0x52, 0x10, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, |
| 0x70, 0x74, 0x6f, 0x72, 0x12, 0x41, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, |
| 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, |
| 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, |
| 0x6c, 0x69, 0x67, 0x68, 0x74, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x08, 0x65, |
| 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x6f, 0x74, 0x61, 0x6c, |
| 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, |
| 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x1f, 0x0a, 0x0b, |
| 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, |
| 0x03, 0x52, 0x0a, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x42, 0x79, 0x74, 0x65, 0x73, 0x22, 0x84, 0x01, |
| 0x0a, 0x0e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, |
| 0x12, 0x35, 0x0a, 0x06, 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, |
| 0x32, 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, |
| 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x52, |
| 0x06, 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x3b, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, |
| 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x61, 0x72, 0x72, 0x6f, |
| 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, |
| 0x6c, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, |
| 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x1c, 0x0a, 0x08, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, |
| 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72, 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, |
| 0x72, 0x69, 0x22, 0x20, 0x0a, 0x06, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x16, 0x0a, 0x06, |
| 0x74, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x74, 0x69, |
| 0x63, 0x6b, 0x65, 0x74, 0x22, 0xc4, 0x01, 0x0a, 0x0a, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, |
| 0x61, 0x74, 0x61, 0x12, 0x54, 0x0a, 0x11, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x64, 0x65, |
| 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, |
| 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, |
| 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, |
| 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x52, 0x10, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, |
| 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x12, 0x1f, 0x0a, 0x0b, 0x64, 0x61, 0x74, |
| 0x61, 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0a, |
| 0x64, 0x61, 0x74, 0x61, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x70, |
| 0x70, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, |
| 0x52, 0x0b, 0x61, 0x70, 0x70, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1c, 0x0a, |
| 0x09, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x62, 0x6f, 0x64, 0x79, 0x18, 0xe8, 0x07, 0x20, 0x01, 0x28, |
| 0x0c, 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, 0x42, 0x6f, 0x64, 0x79, 0x22, 0x2e, 0x0a, 0x09, 0x50, |
| 0x75, 0x74, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x70, 0x70, 0x5f, |
| 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0b, |
| 0x61, 0x70, 0x70, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x32, 0xa7, 0x06, 0x0a, 0x0d, |
| 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x64, 0x0a, |
| 0x09, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x12, 0x27, 0x2e, 0x61, 0x72, 0x72, |
| 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, |
| 0x6f, 0x6c, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x75, |
| 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, |
| 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x48, 0x61, 0x6e, 0x64, |
| 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, |
| 0x01, 0x30, 0x01, 0x12, 0x55, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x6c, 0x69, 0x67, 0x68, |
| 0x74, 0x73, 0x12, 0x1f, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, |
| 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x72, 0x69, 0x74, 0x65, |
| 0x72, 0x69, 0x61, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, |
| 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, |
| 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x00, 0x30, 0x01, 0x12, 0x5d, 0x0a, 0x0d, 0x47, 0x65, |
| 0x74, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x27, 0x2e, 0x61, 0x72, |
| 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, |
| 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, |
| 0x70, 0x74, 0x6f, 0x72, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, |
| 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, |
| 0x67, 0x68, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x00, 0x12, 0x5b, 0x0a, 0x09, 0x47, 0x65, 0x74, |
| 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x27, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, |
| 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, |
| 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x1a, |
| 0x23, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, |
| 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x52, 0x65, |
| 0x73, 0x75, 0x6c, 0x74, 0x22, 0x00, 0x12, 0x4d, 0x0a, 0x05, 0x44, 0x6f, 0x47, 0x65, 0x74, 0x12, |
| 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, |
| 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x54, 0x69, 0x63, 0x6b, 0x65, 0x74, 0x1a, 0x21, |
| 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, |
| 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, |
| 0x61, 0x22, 0x00, 0x30, 0x01, 0x12, 0x52, 0x0a, 0x05, 0x44, 0x6f, 0x50, 0x75, 0x74, 0x12, 0x21, |
| 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, |
| 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, |
| 0x61, 0x1a, 0x20, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, |
| 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x50, 0x75, 0x74, 0x52, 0x65, 0x73, |
| 0x75, 0x6c, 0x74, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x58, 0x0a, 0x0a, 0x44, 0x6f, 0x45, |
| 0x78, 0x63, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x12, 0x21, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, |
| 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, |
| 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 0x61, 0x1a, 0x21, 0x2e, 0x61, 0x72, 0x72, |
| 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, |
| 0x6f, 0x6c, 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x44, 0x61, 0x74, 0x61, 0x22, 0x00, 0x28, |
| 0x01, 0x30, 0x01, 0x12, 0x4c, 0x0a, 0x08, 0x44, 0x6f, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, |
| 0x1d, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, |
| 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0x1d, |
| 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, |
| 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x00, 0x30, |
| 0x01, 0x12, 0x52, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, |
| 0x12, 0x1c, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, |
| 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x21, |
| 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x2e, 0x70, 0x72, |
| 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, |
| 0x65, 0x22, 0x00, 0x30, 0x01, 0x42, 0x48, 0x0a, 0x1c, 0x6f, 0x72, 0x67, 0x2e, 0x61, 0x70, 0x61, |
| 0x63, 0x68, 0x65, 0x2e, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, |
| 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x5a, 0x28, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, |
| 0x6d, 0x2f, 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2f, 0x67, |
| 0x6f, 0x2f, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x3b, 0x66, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x62, |
| 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, |
| } |
| |
| var ( |
| file_Flight_proto_rawDescOnce sync.Once |
| file_Flight_proto_rawDescData = file_Flight_proto_rawDesc |
| ) |
| |
| func file_Flight_proto_rawDescGZIP() []byte { |
| file_Flight_proto_rawDescOnce.Do(func() { |
| file_Flight_proto_rawDescData = protoimpl.X.CompressGZIP(file_Flight_proto_rawDescData) |
| }) |
| return file_Flight_proto_rawDescData |
| } |
| |
| var file_Flight_proto_enumTypes = make([]protoimpl.EnumInfo, 1) |
| var file_Flight_proto_msgTypes = make([]protoimpl.MessageInfo, 16) |
| var file_Flight_proto_goTypes = []interface{}{ |
| (FlightDescriptor_DescriptorType)(0), // 0: arrow.flight.protocol.FlightDescriptor.DescriptorType |
| (*HandshakeRequest)(nil), // 1: arrow.flight.protocol.HandshakeRequest |
| (*HandshakeResponse)(nil), // 2: arrow.flight.protocol.HandshakeResponse |
| (*BasicAuth)(nil), // 3: arrow.flight.protocol.BasicAuth |
| (*Empty)(nil), // 4: arrow.flight.protocol.Empty |
| (*ActionType)(nil), // 5: arrow.flight.protocol.ActionType |
| (*Criteria)(nil), // 6: arrow.flight.protocol.Criteria |
| (*Action)(nil), // 7: arrow.flight.protocol.Action |
| (*Result)(nil), // 8: arrow.flight.protocol.Result |
| (*SchemaResult)(nil), // 9: arrow.flight.protocol.SchemaResult |
| (*FlightDescriptor)(nil), // 10: arrow.flight.protocol.FlightDescriptor |
| (*FlightInfo)(nil), // 11: arrow.flight.protocol.FlightInfo |
| (*FlightEndpoint)(nil), // 12: arrow.flight.protocol.FlightEndpoint |
| (*Location)(nil), // 13: arrow.flight.protocol.Location |
| (*Ticket)(nil), // 14: arrow.flight.protocol.Ticket |
| (*FlightData)(nil), // 15: arrow.flight.protocol.FlightData |
| (*PutResult)(nil), // 16: arrow.flight.protocol.PutResult |
| } |
| var file_Flight_proto_depIdxs = []int32{ |
| 0, // 0: arrow.flight.protocol.FlightDescriptor.type:type_name -> arrow.flight.protocol.FlightDescriptor.DescriptorType |
| 10, // 1: arrow.flight.protocol.FlightInfo.flight_descriptor:type_name -> arrow.flight.protocol.FlightDescriptor |
| 12, // 2: arrow.flight.protocol.FlightInfo.endpoint:type_name -> arrow.flight.protocol.FlightEndpoint |
| 14, // 3: arrow.flight.protocol.FlightEndpoint.ticket:type_name -> arrow.flight.protocol.Ticket |
| 13, // 4: arrow.flight.protocol.FlightEndpoint.location:type_name -> arrow.flight.protocol.Location |
| 10, // 5: arrow.flight.protocol.FlightData.flight_descriptor:type_name -> arrow.flight.protocol.FlightDescriptor |
| 1, // 6: arrow.flight.protocol.FlightService.Handshake:input_type -> arrow.flight.protocol.HandshakeRequest |
| 6, // 7: arrow.flight.protocol.FlightService.ListFlights:input_type -> arrow.flight.protocol.Criteria |
| 10, // 8: arrow.flight.protocol.FlightService.GetFlightInfo:input_type -> arrow.flight.protocol.FlightDescriptor |
| 10, // 9: arrow.flight.protocol.FlightService.GetSchema:input_type -> arrow.flight.protocol.FlightDescriptor |
| 14, // 10: arrow.flight.protocol.FlightService.DoGet:input_type -> arrow.flight.protocol.Ticket |
| 15, // 11: arrow.flight.protocol.FlightService.DoPut:input_type -> arrow.flight.protocol.FlightData |
| 15, // 12: arrow.flight.protocol.FlightService.DoExchange:input_type -> arrow.flight.protocol.FlightData |
| 7, // 13: arrow.flight.protocol.FlightService.DoAction:input_type -> arrow.flight.protocol.Action |
| 4, // 14: arrow.flight.protocol.FlightService.ListActions:input_type -> arrow.flight.protocol.Empty |
| 2, // 15: arrow.flight.protocol.FlightService.Handshake:output_type -> arrow.flight.protocol.HandshakeResponse |
| 11, // 16: arrow.flight.protocol.FlightService.ListFlights:output_type -> arrow.flight.protocol.FlightInfo |
| 11, // 17: arrow.flight.protocol.FlightService.GetFlightInfo:output_type -> arrow.flight.protocol.FlightInfo |
| 9, // 18: arrow.flight.protocol.FlightService.GetSchema:output_type -> arrow.flight.protocol.SchemaResult |
| 15, // 19: arrow.flight.protocol.FlightService.DoGet:output_type -> arrow.flight.protocol.FlightData |
| 16, // 20: arrow.flight.protocol.FlightService.DoPut:output_type -> arrow.flight.protocol.PutResult |
| 15, // 21: arrow.flight.protocol.FlightService.DoExchange:output_type -> arrow.flight.protocol.FlightData |
| 8, // 22: arrow.flight.protocol.FlightService.DoAction:output_type -> arrow.flight.protocol.Result |
| 5, // 23: arrow.flight.protocol.FlightService.ListActions:output_type -> arrow.flight.protocol.ActionType |
| 15, // [15:24] is the sub-list for method output_type |
| 6, // [6:15] is the sub-list for method input_type |
| 6, // [6:6] is the sub-list for extension type_name |
| 6, // [6:6] is the sub-list for extension extendee |
| 0, // [0:6] is the sub-list for field type_name |
| } |
| |
| func init() { file_Flight_proto_init() } |
| func file_Flight_proto_init() { |
| if File_Flight_proto != nil { |
| return |
| } |
| if !protoimpl.UnsafeEnabled { |
| file_Flight_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakeRequest); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakeResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*BasicAuth); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Empty); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ActionType); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Criteria); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Action); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Result); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*SchemaResult); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*FlightDescriptor); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*FlightInfo); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*FlightEndpoint); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Location); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Ticket); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*FlightData); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_Flight_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*PutResult); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: file_Flight_proto_rawDesc, |
| NumEnums: 1, |
| NumMessages: 16, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_Flight_proto_goTypes, |
| DependencyIndexes: file_Flight_proto_depIdxs, |
| EnumInfos: file_Flight_proto_enumTypes, |
| MessageInfos: file_Flight_proto_msgTypes, |
| }.Build() |
| File_Flight_proto = out.File |
| file_Flight_proto_rawDesc = nil |
| file_Flight_proto_goTypes = nil |
| file_Flight_proto_depIdxs = nil |
| } |
