Skip to content

Instantly share code, notes, and snippets.

@kylebrandt

kylebrandt/Flight.pb.go

Created September 19, 2019 13:47
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kylebrandt/1c2af2d1d71a133e66c622d4d30cc12d to your computer and use it in GitHub Desktop.
Save kylebrandt/1c2af2d1d71a133e66c622d4d30cc12d to your computer and use it in GitHub Desktop.
Download ZIP
protoc genenrated Flight.proto
Raw
Flight.pb.go
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: Flight.proto
package arrow_flight_protocol
import (
fmt "fmt"
proto "github.com/golang/protobuf/proto"
math "math"
context "golang.org/x/net/context"
grpc "google.golang.org/grpc"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
//
// 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
)
var FlightDescriptor_DescriptorType_name = map[int32]string{
0: "UNKNOWN",
1: "PATH",
2: "CMD",
}
var FlightDescriptor_DescriptorType_value = map[string]int32{
"UNKNOWN": 0,
"PATH": 1,
"CMD": 2,
}
func (x FlightDescriptor_DescriptorType) String() string {
return proto.EnumName(FlightDescriptor_DescriptorType_name, int32(x))
}
func (FlightDescriptor_DescriptorType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{9, 0}
}
//
// The request that a client provides to a server on handshake.
type HandshakeRequest struct {
//
// A defined protocol version
ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion" json:"protocol_version,omitempty"`
//
// Arbitrary auth/handshake info.
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *HandshakeRequest) Reset() { *m = HandshakeRequest{} }
func (m *HandshakeRequest) String() string { return proto.CompactTextString(m) }
func (*HandshakeRequest) ProtoMessage() {}
func (*HandshakeRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{0}
}
func (m *HandshakeRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_HandshakeRequest.Unmarshal(m, b)
}
func (m *HandshakeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_HandshakeRequest.Marshal(b, m, deterministic)
}
func (dst *HandshakeRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_HandshakeRequest.Merge(dst, src)
}
func (m *HandshakeRequest) XXX_Size() int {
return xxx_messageInfo_HandshakeRequest.Size(m)
}
func (m *HandshakeRequest) XXX_DiscardUnknown() {
xxx_messageInfo_HandshakeRequest.DiscardUnknown(m)
}
var xxx_messageInfo_HandshakeRequest proto.InternalMessageInfo
func (m *HandshakeRequest) GetProtocolVersion() uint64 {
if m != nil {
return m.ProtocolVersion
}
return 0
}
func (m *HandshakeRequest) GetPayload() []byte {
if m != nil {
return m.Payload
}
return nil
}
type HandshakeResponse struct {
//
// A defined protocol version
ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion" json:"protocol_version,omitempty"`
//
// Arbitrary auth/handshake info.
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *HandshakeResponse) Reset() { *m = HandshakeResponse{} }
func (m *HandshakeResponse) String() string { return proto.CompactTextString(m) }
func (*HandshakeResponse) ProtoMessage() {}
func (*HandshakeResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{1}
}
func (m *HandshakeResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_HandshakeResponse.Unmarshal(m, b)
}
func (m *HandshakeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_HandshakeResponse.Marshal(b, m, deterministic)
}
func (dst *HandshakeResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_HandshakeResponse.Merge(dst, src)
}
func (m *HandshakeResponse) XXX_Size() int {
return xxx_messageInfo_HandshakeResponse.Size(m)
}
func (m *HandshakeResponse) XXX_DiscardUnknown() {
xxx_messageInfo_HandshakeResponse.DiscardUnknown(m)
}
var xxx_messageInfo_HandshakeResponse proto.InternalMessageInfo
func (m *HandshakeResponse) GetProtocolVersion() uint64 {
if m != nil {
return m.ProtocolVersion
}
return 0
}
func (m *HandshakeResponse) GetPayload() []byte {
if m != nil {
return m.Payload
}
return nil
}
//
// A message for doing simple auth.
type BasicAuth struct {
Username string `protobuf:"bytes,2,opt,name=username" json:"username,omitempty"`
Password string `protobuf:"bytes,3,opt,name=password" json:"password,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BasicAuth) Reset() { *m = BasicAuth{} }
func (m *BasicAuth) String() string { return proto.CompactTextString(m) }
func (*BasicAuth) ProtoMessage() {}
func (*BasicAuth) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{2}
}
func (m *BasicAuth) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BasicAuth.Unmarshal(m, b)
}
func (m *BasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BasicAuth.Marshal(b, m, deterministic)
}
func (dst *BasicAuth) XXX_Merge(src proto.Message) {
xxx_messageInfo_BasicAuth.Merge(dst, src)
}
func (m *BasicAuth) XXX_Size() int {
return xxx_messageInfo_BasicAuth.Size(m)
}
func (m *BasicAuth) XXX_DiscardUnknown() {
xxx_messageInfo_BasicAuth.DiscardUnknown(m)
}
var xxx_messageInfo_BasicAuth proto.InternalMessageInfo
func (m *BasicAuth) GetUsername() string {
if m != nil {
return m.Username
}
return ""
}
func (m *BasicAuth) GetPassword() string {
if m != nil {
return m.Password
}
return ""
}
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{3}
}
func (m *Empty) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Empty.Unmarshal(m, b)
}
func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
}
func (dst *Empty) XXX_Merge(src proto.Message) {
xxx_messageInfo_Empty.Merge(dst, src)
}
func (m *Empty) XXX_Size() int {
return xxx_messageInfo_Empty.Size(m)
}
func (m *Empty) XXX_DiscardUnknown() {
xxx_messageInfo_Empty.DiscardUnknown(m)
}
var xxx_messageInfo_Empty proto.InternalMessageInfo
//
// 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 {
Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ActionType) Reset() { *m = ActionType{} }
func (m *ActionType) String() string { return proto.CompactTextString(m) }
func (*ActionType) ProtoMessage() {}
func (*ActionType) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{4}
}
func (m *ActionType) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ActionType.Unmarshal(m, b)
}
func (m *ActionType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ActionType.Marshal(b, m, deterministic)
}
func (dst *ActionType) XXX_Merge(src proto.Message) {
xxx_messageInfo_ActionType.Merge(dst, src)
}
func (m *ActionType) XXX_Size() int {
return xxx_messageInfo_ActionType.Size(m)
}
func (m *ActionType) XXX_DiscardUnknown() {
xxx_messageInfo_ActionType.DiscardUnknown(m)
}
var xxx_messageInfo_ActionType proto.InternalMessageInfo
func (m *ActionType) GetType() string {
if m != nil {
return m.Type
}
return ""
}
func (m *ActionType) GetDescription() string {
if m != nil {
return m.Description
}
return ""
}
//
// A service specific expression that can be used to return a limited set
// of available Arrow Flight streams.
type Criteria struct {
Expression []byte `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Criteria) Reset() { *m = Criteria{} }
func (m *Criteria) String() string { return proto.CompactTextString(m) }
func (*Criteria) ProtoMessage() {}
func (*Criteria) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{5}
}
func (m *Criteria) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Criteria.Unmarshal(m, b)
}
func (m *Criteria) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Criteria.Marshal(b, m, deterministic)
}
func (dst *Criteria) XXX_Merge(src proto.Message) {
xxx_messageInfo_Criteria.Merge(dst, src)
}
func (m *Criteria) XXX_Size() int {
return xxx_messageInfo_Criteria.Size(m)
}
func (m *Criteria) XXX_DiscardUnknown() {
xxx_messageInfo_Criteria.DiscardUnknown(m)
}
var xxx_messageInfo_Criteria proto.InternalMessageInfo
func (m *Criteria) GetExpression() []byte {
if m != nil {
return m.Expression
}
return nil
}
//
// An opaque action specific for the service.
type Action struct {
Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Action) Reset() { *m = Action{} }
func (m *Action) String() string { return proto.CompactTextString(m) }
func (*Action) ProtoMessage() {}
func (*Action) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{6}
}
func (m *Action) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Action.Unmarshal(m, b)
}
func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Action.Marshal(b, m, deterministic)
}
func (dst *Action) XXX_Merge(src proto.Message) {
xxx_messageInfo_Action.Merge(dst, src)
}
func (m *Action) XXX_Size() int {
return xxx_messageInfo_Action.Size(m)
}
func (m *Action) XXX_DiscardUnknown() {
xxx_messageInfo_Action.DiscardUnknown(m)
}
var xxx_messageInfo_Action proto.InternalMessageInfo
func (m *Action) GetType() string {
if m != nil {
return m.Type
}
return ""
}
func (m *Action) GetBody() []byte {
if m != nil {
return m.Body
}
return nil
}
//
// An opaque result returned after executing an action.
type Result struct {
Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Result) Reset() { *m = Result{} }
func (m *Result) String() string { return proto.CompactTextString(m) }
func (*Result) ProtoMessage() {}
func (*Result) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{7}
}
func (m *Result) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Result.Unmarshal(m, b)
}
func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Result.Marshal(b, m, deterministic)
}
func (dst *Result) XXX_Merge(src proto.Message) {
xxx_messageInfo_Result.Merge(dst, src)
}
func (m *Result) XXX_Size() int {
return xxx_messageInfo_Result.Size(m)
}
func (m *Result) XXX_DiscardUnknown() {
xxx_messageInfo_Result.DiscardUnknown(m)
}
var xxx_messageInfo_Result proto.InternalMessageInfo
func (m *Result) GetBody() []byte {
if m != nil {
return m.Body
}
return nil
}
//
// Wrap the result of a getSchema call
type SchemaResult struct {
// schema of the dataset as described in Schema.fbs::Schema.
Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SchemaResult) Reset() { *m = SchemaResult{} }
func (m *SchemaResult) String() string { return proto.CompactTextString(m) }
func (*SchemaResult) ProtoMessage() {}
func (*SchemaResult) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{8}
}
func (m *SchemaResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SchemaResult.Unmarshal(m, b)
}
func (m *SchemaResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SchemaResult.Marshal(b, m, deterministic)
}
func (dst *SchemaResult) XXX_Merge(src proto.Message) {
xxx_messageInfo_SchemaResult.Merge(dst, src)
}
func (m *SchemaResult) XXX_Size() int {
return xxx_messageInfo_SchemaResult.Size(m)
}
func (m *SchemaResult) XXX_DiscardUnknown() {
xxx_messageInfo_SchemaResult.DiscardUnknown(m)
}
var xxx_messageInfo_SchemaResult proto.InternalMessageInfo
func (m *SchemaResult) GetSchema() []byte {
if m != nil {
return m.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 {
Type FlightDescriptor_DescriptorType `protobuf:"varint,1,opt,name=type,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" json:"path,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FlightDescriptor) Reset() { *m = FlightDescriptor{} }
func (m *FlightDescriptor) String() string { return proto.CompactTextString(m) }
func (*FlightDescriptor) ProtoMessage() {}
func (*FlightDescriptor) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{9}
}
func (m *FlightDescriptor) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FlightDescriptor.Unmarshal(m, b)
}
func (m *FlightDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FlightDescriptor.Marshal(b, m, deterministic)
}
func (dst *FlightDescriptor) XXX_Merge(src proto.Message) {
xxx_messageInfo_FlightDescriptor.Merge(dst, src)
}
func (m *FlightDescriptor) XXX_Size() int {
return xxx_messageInfo_FlightDescriptor.Size(m)
}
func (m *FlightDescriptor) XXX_DiscardUnknown() {
xxx_messageInfo_FlightDescriptor.DiscardUnknown(m)
}
var xxx_messageInfo_FlightDescriptor proto.InternalMessageInfo
func (m *FlightDescriptor) GetType() FlightDescriptor_DescriptorType {
if m != nil {
return m.Type
}
return FlightDescriptor_UNKNOWN
}
func (m *FlightDescriptor) GetCmd() []byte {
if m != nil {
return m.Cmd
}
return nil
}
func (m *FlightDescriptor) GetPath() []string {
if m != nil {
return m.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 {
// 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" 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" json:"endpoint,omitempty"`
// Set these to -1 if unknown.
TotalRecords int64 `protobuf:"varint,4,opt,name=total_records,json=totalRecords" json:"total_records,omitempty"`
TotalBytes int64 `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes" json:"total_bytes,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FlightInfo) Reset() { *m = FlightInfo{} }
func (m *FlightInfo) String() string { return proto.CompactTextString(m) }
func (*FlightInfo) ProtoMessage() {}
func (*FlightInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{10}
}
func (m *FlightInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FlightInfo.Unmarshal(m, b)
}
func (m *FlightInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FlightInfo.Marshal(b, m, deterministic)
}
func (dst *FlightInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_FlightInfo.Merge(dst, src)
}
func (m *FlightInfo) XXX_Size() int {
return xxx_messageInfo_FlightInfo.Size(m)
}
func (m *FlightInfo) XXX_DiscardUnknown() {
xxx_messageInfo_FlightInfo.DiscardUnknown(m)
}
var xxx_messageInfo_FlightInfo proto.InternalMessageInfo
func (m *FlightInfo) GetSchema() []byte {
if m != nil {
return m.Schema
}
return nil
}
func (m *FlightInfo) GetFlightDescriptor() *FlightDescriptor {
if m != nil {
return m.FlightDescriptor
}
return nil
}
func (m *FlightInfo) GetEndpoint() []*FlightEndpoint {
if m != nil {
return m.Endpoint
}
return nil
}
func (m *FlightInfo) GetTotalRecords() int64 {
if m != nil {
return m.TotalRecords
}
return 0
}
func (m *FlightInfo) GetTotalBytes() int64 {
if m != nil {
return m.TotalBytes
}
return 0
}
//
// A particular stream or split associated with a flight.
type FlightEndpoint struct {
//
// Token used to retrieve this stream.
Ticket *Ticket `protobuf:"bytes,1,opt,name=ticket" 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" json:"location,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FlightEndpoint) Reset() { *m = FlightEndpoint{} }
func (m *FlightEndpoint) String() string { return proto.CompactTextString(m) }
func (*FlightEndpoint) ProtoMessage() {}
func (*FlightEndpoint) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{11}
}
func (m *FlightEndpoint) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FlightEndpoint.Unmarshal(m, b)
}
func (m *FlightEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FlightEndpoint.Marshal(b, m, deterministic)
}
func (dst *FlightEndpoint) XXX_Merge(src proto.Message) {
xxx_messageInfo_FlightEndpoint.Merge(dst, src)
}
func (m *FlightEndpoint) XXX_Size() int {
return xxx_messageInfo_FlightEndpoint.Size(m)
}
func (m *FlightEndpoint) XXX_DiscardUnknown() {
xxx_messageInfo_FlightEndpoint.DiscardUnknown(m)
}
var xxx_messageInfo_FlightEndpoint proto.InternalMessageInfo
func (m *FlightEndpoint) GetTicket() *Ticket {
if m != nil {
return m.Ticket
}
return nil
}
func (m *FlightEndpoint) GetLocation() []*Location {
if m != nil {
return m.Location
}
return nil
}
//
// A location where a Flight service will accept retrieval of a particular
// stream given a ticket.
type Location struct {
Uri string `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Location) Reset() { *m = Location{} }
func (m *Location) String() string { return proto.CompactTextString(m) }
func (*Location) ProtoMessage() {}
func (*Location) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{12}
}
func (m *Location) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Location.Unmarshal(m, b)
}
func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Location.Marshal(b, m, deterministic)
}
func (dst *Location) XXX_Merge(src proto.Message) {
xxx_messageInfo_Location.Merge(dst, src)
}
func (m *Location) XXX_Size() int {
return xxx_messageInfo_Location.Size(m)
}
func (m *Location) XXX_DiscardUnknown() {
xxx_messageInfo_Location.DiscardUnknown(m)
}
var xxx_messageInfo_Location proto.InternalMessageInfo
func (m *Location) GetUri() string {
if m != nil {
return m.Uri
}
return ""
}
//
// An opaque identifier that the service can use to retrieve a particular
// portion of a stream.
type Ticket struct {
Ticket []byte `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Ticket) Reset() { *m = Ticket{} }
func (m *Ticket) String() string { return proto.CompactTextString(m) }
func (*Ticket) ProtoMessage() {}
func (*Ticket) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{13}
}
func (m *Ticket) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Ticket.Unmarshal(m, b)
}
func (m *Ticket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Ticket.Marshal(b, m, deterministic)
}
func (dst *Ticket) XXX_Merge(src proto.Message) {
xxx_messageInfo_Ticket.Merge(dst, src)
}
func (m *Ticket) XXX_Size() int {
return xxx_messageInfo_Ticket.Size(m)
}
func (m *Ticket) XXX_DiscardUnknown() {
xxx_messageInfo_Ticket.DiscardUnknown(m)
}
var xxx_messageInfo_Ticket proto.InternalMessageInfo
func (m *Ticket) GetTicket() []byte {
if m != nil {
return m.Ticket
}
return nil
}
//
// A batch of Arrow data as part of a stream of batches.
type FlightData struct {
//
// 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" 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FlightData) Reset() { *m = FlightData{} }
func (m *FlightData) String() string { return proto.CompactTextString(m) }
func (*FlightData) ProtoMessage() {}
func (*FlightData) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{14}
}
func (m *FlightData) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FlightData.Unmarshal(m, b)
}
func (m *FlightData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FlightData.Marshal(b, m, deterministic)
}
func (dst *FlightData) XXX_Merge(src proto.Message) {
xxx_messageInfo_FlightData.Merge(dst, src)
}
func (m *FlightData) XXX_Size() int {
return xxx_messageInfo_FlightData.Size(m)
}
func (m *FlightData) XXX_DiscardUnknown() {
xxx_messageInfo_FlightData.DiscardUnknown(m)
}
var xxx_messageInfo_FlightData proto.InternalMessageInfo
func (m *FlightData) GetFlightDescriptor() *FlightDescriptor {
if m != nil {
return m.FlightDescriptor
}
return nil
}
func (m *FlightData) GetDataHeader() []byte {
if m != nil {
return m.DataHeader
}
return nil
}
func (m *FlightData) GetAppMetadata() []byte {
if m != nil {
return m.AppMetadata
}
return nil
}
func (m *FlightData) GetDataBody() []byte {
if m != nil {
return m.DataBody
}
return nil
}
// *
// The response message associated with the submission of a DoPut.
type PutResult struct {
AppMetadata []byte `protobuf:"bytes,1,opt,name=app_metadata,json=appMetadata,proto3" json:"app_metadata,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *PutResult) Reset() { *m = PutResult{} }
func (m *PutResult) String() string { return proto.CompactTextString(m) }
func (*PutResult) ProtoMessage() {}
func (*PutResult) Descriptor() ([]byte, []int) {
return fileDescriptor_Flight_788befda166c6eaf, []int{15}
}
func (m *PutResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PutResult.Unmarshal(m, b)
}
func (m *PutResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PutResult.Marshal(b, m, deterministic)
}
func (dst *PutResult) XXX_Merge(src proto.Message) {
xxx_messageInfo_PutResult.Merge(dst, src)
}
func (m *PutResult) XXX_Size() int {
return xxx_messageInfo_PutResult.Size(m)
}
func (m *PutResult) XXX_DiscardUnknown() {
xxx_messageInfo_PutResult.DiscardUnknown(m)
}
var xxx_messageInfo_PutResult proto.InternalMessageInfo
func (m *PutResult) GetAppMetadata() []byte {
if m != nil {
return m.AppMetadata
}
return nil
}
func init() {
proto.RegisterType((*HandshakeRequest)(nil), "arrow.flight.protocol.HandshakeRequest")
proto.RegisterType((*HandshakeResponse)(nil), "arrow.flight.protocol.HandshakeResponse")
proto.RegisterType((*BasicAuth)(nil), "arrow.flight.protocol.BasicAuth")
proto.RegisterType((*Empty)(nil), "arrow.flight.protocol.Empty")
proto.RegisterType((*ActionType)(nil), "arrow.flight.protocol.ActionType")
proto.RegisterType((*Criteria)(nil), "arrow.flight.protocol.Criteria")
proto.RegisterType((*Action)(nil), "arrow.flight.protocol.Action")
proto.RegisterType((*Result)(nil), "arrow.flight.protocol.Result")
proto.RegisterType((*SchemaResult)(nil), "arrow.flight.protocol.SchemaResult")
proto.RegisterType((*FlightDescriptor)(nil), "arrow.flight.protocol.FlightDescriptor")
proto.RegisterType((*FlightInfo)(nil), "arrow.flight.protocol.FlightInfo")
proto.RegisterType((*FlightEndpoint)(nil), "arrow.flight.protocol.FlightEndpoint")
proto.RegisterType((*Location)(nil), "arrow.flight.protocol.Location")
proto.RegisterType((*Ticket)(nil), "arrow.flight.protocol.Ticket")
proto.RegisterType((*FlightData)(nil), "arrow.flight.protocol.FlightData")
proto.RegisterType((*PutResult)(nil), "arrow.flight.protocol.PutResult")
proto.RegisterEnum("arrow.flight.protocol.FlightDescriptor_DescriptorType", FlightDescriptor_DescriptorType_name, FlightDescriptor_DescriptorType_value)
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// FlightServiceClient is the client API for FlightService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type FlightServiceClient interface {
//
// Handshake between client and server. Depending on the server, the
// handshake may be required to determine the token that should be used for
// future operations. Both request and response are streams to allow multiple
// round-trips depending on auth mechanism.
Handshake(ctx context.Context, opts ...grpc.CallOption) (FlightService_HandshakeClient, error)
//
// Get a list of available streams given a particular criteria. Most flight
// services will expose one or more streams that are readily available for
// retrieval. This api allows listing the streams available for
// consumption. A user can also provide a criteria. The criteria can limit
// the subset of streams that can be listed via this interface. Each flight
// service allows its own definition of how to consume criteria.
ListFlights(ctx context.Context, in *Criteria, opts ...grpc.CallOption) (FlightService_ListFlightsClient, error)
//
// For a given FlightDescriptor, get information about how the flight can be
// consumed. This is a useful interface if the consumer of the interface
// already can identify the specific flight to consume. This interface can
// also allow a consumer to generate a flight stream through a specified
// descriptor. For example, a flight descriptor might be something that
// includes a SQL statement or a Pickled Python operation that will be
// executed. In those cases, the descriptor will not be previously available
// within the list of available streams provided by ListFlights but will be
// available for consumption for the duration defined by the specific flight
// service.
GetFlightInfo(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*FlightInfo, error)
//
// For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema
// This is used when a consumer needs the Schema of flight stream. Similar to
// GetFlightInfo this interface may generate a new flight that was not previously
// available in ListFlights.
GetSchema(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*SchemaResult, error)
//
// Retrieve a single stream associated with a particular descriptor
// associated with the referenced ticket. A Flight can be composed of one or
// more streams where each stream can be retrieved using a separate opaque
// ticket that the flight service uses for managing a collection of streams.
DoGet(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (FlightService_DoGetClient, error)
//
// Push a stream to the flight service associated with a particular
// flight stream. This allows a client of a flight service to upload a stream
// of data. Depending on the particular flight service, a client consumer
// could be allowed to upload a single stream per descriptor or an unlimited
// number. In the latter, the service might implement a 'seal' action that
// can be applied to a descriptor once all streams are uploaded.
DoPut(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoPutClient, error)
//
// Flight services can support an arbitrary number of simple actions in
// addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
// operations that are potentially available. DoAction allows a flight client
// to do a specific action against a flight service. An action includes
// opaque request and response objects that are specific to the type action
// being undertaken.
DoAction(ctx context.Context, in *Action, opts ...grpc.CallOption) (FlightService_DoActionClient, error)
//
// A flight service exposes all of the available action types that it has
// along with descriptions. This allows different flight consumers to
// understand the capabilities of the flight service.
ListActions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (FlightService_ListActionsClient, error)
}
type flightServiceClient struct {
cc *grpc.ClientConn
}
func NewFlightServiceClient(cc *grpc.ClientConn) FlightServiceClient {
return &flightServiceClient{cc}
}
func (c *flightServiceClient) Handshake(ctx context.Context, opts ...grpc.CallOption) (FlightService_HandshakeClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[0], "/arrow.flight.protocol.FlightService/Handshake", opts...)
if err != nil {
return nil, err
}
x := &flightServiceHandshakeClient{stream}
return x, nil
}
type FlightService_HandshakeClient interface {
Send(*HandshakeRequest) error
Recv() (*HandshakeResponse, error)
grpc.ClientStream
}
type flightServiceHandshakeClient struct {
grpc.ClientStream
}
func (x *flightServiceHandshakeClient) Send(m *HandshakeRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *flightServiceHandshakeClient) Recv() (*HandshakeResponse, error) {
m := new(HandshakeResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *flightServiceClient) ListFlights(ctx context.Context, in *Criteria, opts ...grpc.CallOption) (FlightService_ListFlightsClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[1], "/arrow.flight.protocol.FlightService/ListFlights", opts...)
if err != nil {
return nil, err
}
x := &flightServiceListFlightsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type FlightService_ListFlightsClient interface {
Recv() (*FlightInfo, error)
grpc.ClientStream
}
type flightServiceListFlightsClient struct {
grpc.ClientStream
}
func (x *flightServiceListFlightsClient) Recv() (*FlightInfo, error) {
m := new(FlightInfo)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *flightServiceClient) GetFlightInfo(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*FlightInfo, error) {
out := new(FlightInfo)
err := c.cc.Invoke(ctx, "/arrow.flight.protocol.FlightService/GetFlightInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *flightServiceClient) GetSchema(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*SchemaResult, error) {
out := new(SchemaResult)
err := c.cc.Invoke(ctx, "/arrow.flight.protocol.FlightService/GetSchema", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *flightServiceClient) DoGet(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (FlightService_DoGetClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[2], "/arrow.flight.protocol.FlightService/DoGet", opts...)
if err != nil {
return nil, err
}
x := &flightServiceDoGetClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type FlightService_DoGetClient interface {
Recv() (*FlightData, error)
grpc.ClientStream
}
type flightServiceDoGetClient struct {
grpc.ClientStream
}
func (x *flightServiceDoGetClient) Recv() (*FlightData, error) {
m := new(FlightData)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *flightServiceClient) DoPut(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoPutClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[3], "/arrow.flight.protocol.FlightService/DoPut", opts...)
if err != nil {
return nil, err
}
x := &flightServiceDoPutClient{stream}
return x, nil
}
type FlightService_DoPutClient interface {
Send(*FlightData) error
Recv() (*PutResult, error)
grpc.ClientStream
}
type flightServiceDoPutClient struct {
grpc.ClientStream
}
func (x *flightServiceDoPutClient) Send(m *FlightData) error {
return x.ClientStream.SendMsg(m)
}
func (x *flightServiceDoPutClient) Recv() (*PutResult, error) {
m := new(PutResult)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *flightServiceClient) DoAction(ctx context.Context, in *Action, opts ...grpc.CallOption) (FlightService_DoActionClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[4], "/arrow.flight.protocol.FlightService/DoAction", opts...)
if err != nil {
return nil, err
}
x := &flightServiceDoActionClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type FlightService_DoActionClient interface {
Recv() (*Result, error)
grpc.ClientStream
}
type flightServiceDoActionClient struct {
grpc.ClientStream
}
func (x *flightServiceDoActionClient) Recv() (*Result, error) {
m := new(Result)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *flightServiceClient) ListActions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (FlightService_ListActionsClient, error) {
stream, err := c.cc.NewStream(ctx, &_FlightService_serviceDesc.Streams[5], "/arrow.flight.protocol.FlightService/ListActions", opts...)
if err != nil {
return nil, err
}
x := &flightServiceListActionsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type FlightService_ListActionsClient interface {
Recv() (*ActionType, error)
grpc.ClientStream
}
type flightServiceListActionsClient struct {
grpc.ClientStream
}
func (x *flightServiceListActionsClient) Recv() (*ActionType, error) {
m := new(ActionType)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// Server API for FlightService service
type FlightServiceServer interface {
//
// Handshake between client and server. Depending on the server, the
// handshake may be required to determine the token that should be used for
// future operations. Both request and response are streams to allow multiple
// round-trips depending on auth mechanism.
Handshake(FlightService_HandshakeServer) error
//
// Get a list of available streams given a particular criteria. Most flight
// services will expose one or more streams that are readily available for
// retrieval. This api allows listing the streams available for
// consumption. A user can also provide a criteria. The criteria can limit
// the subset of streams that can be listed via this interface. Each flight
// service allows its own definition of how to consume criteria.
ListFlights(*Criteria, FlightService_ListFlightsServer) error
//
// For a given FlightDescriptor, get information about how the flight can be
// consumed. This is a useful interface if the consumer of the interface
// already can identify the specific flight to consume. This interface can
// also allow a consumer to generate a flight stream through a specified
// descriptor. For example, a flight descriptor might be something that
// includes a SQL statement or a Pickled Python operation that will be
// executed. In those cases, the descriptor will not be previously available
// within the list of available streams provided by ListFlights but will be
// available for consumption for the duration defined by the specific flight
// service.
GetFlightInfo(context.Context, *FlightDescriptor) (*FlightInfo, error)
//
// For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema
// This is used when a consumer needs the Schema of flight stream. Similar to
// GetFlightInfo this interface may generate a new flight that was not previously
// available in ListFlights.
GetSchema(context.Context, *FlightDescriptor) (*SchemaResult, error)
//
// Retrieve a single stream associated with a particular descriptor
// associated with the referenced ticket. A Flight can be composed of one or
// more streams where each stream can be retrieved using a separate opaque
// ticket that the flight service uses for managing a collection of streams.
DoGet(*Ticket, FlightService_DoGetServer) error
//
// Push a stream to the flight service associated with a particular
// flight stream. This allows a client of a flight service to upload a stream
// of data. Depending on the particular flight service, a client consumer
// could be allowed to upload a single stream per descriptor or an unlimited
// number. In the latter, the service might implement a 'seal' action that
// can be applied to a descriptor once all streams are uploaded.
DoPut(FlightService_DoPutServer) error
//
// Flight services can support an arbitrary number of simple actions in
// addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
// operations that are potentially available. DoAction allows a flight client
// to do a specific action against a flight service. An action includes
// opaque request and response objects that are specific to the type action
// being undertaken.
DoAction(*Action, FlightService_DoActionServer) error
//
// A flight service exposes all of the available action types that it has
// along with descriptions. This allows different flight consumers to
// understand the capabilities of the flight service.
ListActions(*Empty, FlightService_ListActionsServer) error
}
func RegisterFlightServiceServer(s *grpc.Server, srv FlightServiceServer) {
s.RegisterService(&_FlightService_serviceDesc, srv)
}
func _FlightService_Handshake_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(FlightServiceServer).Handshake(&flightServiceHandshakeServer{stream})
}
type FlightService_HandshakeServer interface {
Send(*HandshakeResponse) error
Recv() (*HandshakeRequest, error)
grpc.ServerStream
}
type flightServiceHandshakeServer struct {
grpc.ServerStream
}
func (x *flightServiceHandshakeServer) Send(m *HandshakeResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *flightServiceHandshakeServer) Recv() (*HandshakeRequest, error) {
m := new(HandshakeRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func _FlightService_ListFlights_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(Criteria)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(FlightServiceServer).ListFlights(m, &flightServiceListFlightsServer{stream})
}
type FlightService_ListFlightsServer interface {
Send(*FlightInfo) error
grpc.ServerStream
}
type flightServiceListFlightsServer struct {
grpc.ServerStream
}
func (x *flightServiceListFlightsServer) Send(m *FlightInfo) error {
return x.ServerStream.SendMsg(m)
}
func _FlightService_GetFlightInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(FlightDescriptor)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(FlightServiceServer).GetFlightInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/arrow.flight.protocol.FlightService/GetFlightInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(FlightServiceServer).GetFlightInfo(ctx, req.(*FlightDescriptor))
}
return interceptor(ctx, in, info, handler)
}
func _FlightService_GetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(FlightDescriptor)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(FlightServiceServer).GetSchema(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/arrow.flight.protocol.FlightService/GetSchema",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(FlightServiceServer).GetSchema(ctx, req.(*FlightDescriptor))
}
return interceptor(ctx, in, info, handler)
}
func _FlightService_DoGet_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(Ticket)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(FlightServiceServer).DoGet(m, &flightServiceDoGetServer{stream})
}
type FlightService_DoGetServer interface {
Send(*FlightData) error
grpc.ServerStream
}
type flightServiceDoGetServer struct {
grpc.ServerStream
}
func (x *flightServiceDoGetServer) Send(m *FlightData) error {
return x.ServerStream.SendMsg(m)
}
func _FlightService_DoPut_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(FlightServiceServer).DoPut(&flightServiceDoPutServer{stream})
}
type FlightService_DoPutServer interface {
Send(*PutResult) error
Recv() (*FlightData, error)
grpc.ServerStream
}
type flightServiceDoPutServer struct {
grpc.ServerStream
}
func (x *flightServiceDoPutServer) Send(m *PutResult) error {
return x.ServerStream.SendMsg(m)
}
func (x *flightServiceDoPutServer) Recv() (*FlightData, error) {
m := new(FlightData)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func _FlightService_DoAction_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(Action)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(FlightServiceServer).DoAction(m, &flightServiceDoActionServer{stream})
}
type FlightService_DoActionServer interface {
Send(*Result) error
grpc.ServerStream
}
type flightServiceDoActionServer struct {
grpc.ServerStream
}
func (x *flightServiceDoActionServer) Send(m *Result) error {
return x.ServerStream.SendMsg(m)
}
func _FlightService_ListActions_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(Empty)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(FlightServiceServer).ListActions(m, &flightServiceListActionsServer{stream})
}
type FlightService_ListActionsServer interface {
Send(*ActionType) error
grpc.ServerStream
}
type flightServiceListActionsServer struct {
grpc.ServerStream
}
func (x *flightServiceListActionsServer) Send(m *ActionType) error {
return x.ServerStream.SendMsg(m)
}
var _FlightService_serviceDesc = grpc.ServiceDesc{
ServiceName: "arrow.flight.protocol.FlightService",
HandlerType: (*FlightServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetFlightInfo",
Handler: _FlightService_GetFlightInfo_Handler,
},
{
MethodName: "GetSchema",
Handler: _FlightService_GetSchema_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "Handshake",
Handler: _FlightService_Handshake_Handler,
ServerStreams: true,
ClientStreams: true,
},
{
StreamName: "ListFlights",
Handler: _FlightService_ListFlights_Handler,
ServerStreams: true,
},
{
StreamName: "DoGet",
Handler: _FlightService_DoGet_Handler,
ServerStreams: true,
},
{
StreamName: "DoPut",
Handler: _FlightService_DoPut_Handler,
ServerStreams: true,
ClientStreams: true,
},
{
StreamName: "DoAction",
Handler: _FlightService_DoAction_Handler,
ServerStreams: true,
},
{
StreamName: "ListActions",
Handler: _FlightService_ListActions_Handler,
ServerStreams: true,
},
},
Metadata: "Flight.proto",
}
func init() { proto.RegisterFile("Flight.proto", fileDescriptor_Flight_788befda166c6eaf) }
var fileDescriptor_Flight_788befda166c6eaf = []byte{
// 821 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x55, 0x51, 0x6f, 0x23, 0x35,
0x10, 0xee, 0x36, 0x69, 0xb2, 0x99, 0xdd, 0x96, 0x3d, 0x4b, 0xa0, 0x28, 0x0a, 0xd7, 0x9c, 0x4f,
0x40, 0xe0, 0x21, 0x8a, 0x82, 0xe0, 0x85, 0xa7, 0xa4, 0x39, 0x5a, 0xa0, 0x2d, 0xd5, 0x5e, 0x8e,
0x43, 0x42, 0x28, 0x72, 0x77, 0xdd, 0xcb, 0xea, 0x92, 0xb5, 0xb1, 0x9d, 0x3b, 0xf2, 0x0c, 0xbf,
0x89, 0x5f, 0xc0, 0x2b, 0xff, 0x83, 0x9f, 0x81, 0xec, 0xf5, 0xee, 0x6d, 0x43, 0xb7, 0x8d, 0x04,
0x6f, 0xf6, 0xe7, 0x6f, 0x66, 0xbe, 0xf1, 0x8c, 0xc7, 0xe0, 0x7f, 0xbd, 0x4c, 0x5e, 0x2d, 0xd4,
0x80, 0x0b, 0xa6, 0x18, 0x7a, 0x9f, 0x08, 0xc1, 0xde, 0x0e, 0x6e, 0x4a, 0x58, 0xc4, 0x96, 0xf8,
0x25, 0x04, 0x67, 0x24, 0x8d, 0xe5, 0x82, 0xbc, 0xa6, 0x21, 0xfd, 0x65, 0x4d, 0xa5, 0x42, 0x9f,
0x42, 0x90, 0x9f, 0xcf, 0xdf, 0x50, 0x21, 0x13, 0x96, 0xb6, 0x9d, 0x9e, 0xd3, 0xaf, 0x87, 0xef,
0xe5, 0xf8, 0x0f, 0x19, 0x8c, 0xda, 0xd0, 0xe4, 0x64, 0xb3, 0x64, 0x24, 0x6e, 0xef, 0xf7, 0x9c,
0xbe, 0x1f, 0xe6, 0x5b, 0xfc, 0x23, 0x3c, 0x2a, 0x39, 0x96, 0x9c, 0xa5, 0x92, 0xfe, 0x3f, 0x9e,
0x4f, 0xa0, 0x35, 0x21, 0x32, 0x89, 0xc6, 0x6b, 0xb5, 0x40, 0x1d, 0x70, 0xd7, 0x92, 0x8a, 0x94,
0xac, 0xa8, 0xe1, 0xb5, 0xc2, 0x62, 0xaf, 0xcf, 0x38, 0x91, 0xf2, 0x2d, 0x13, 0x71, 0xbb, 0x96,
0x9d, 0xe5, 0x7b, 0xdc, 0x84, 0x83, 0x67, 0x2b, 0xae, 0x36, 0x78, 0x02, 0x30, 0x8e, 0x54, 0xc2,
0xd2, 0xd9, 0x86, 0x53, 0x84, 0xa0, 0xae, 0x36, 0x9c, 0x1a, 0x51, 0xad, 0xd0, 0xac, 0x51, 0x0f,
0xbc, 0x98, 0xca, 0x48, 0x24, 0x5c, 0xd3, 0x6c, 0x94, 0x32, 0x84, 0x3f, 0x03, 0xf7, 0x44, 0x24,
0x8a, 0x8a, 0x84, 0xa0, 0xc7, 0x00, 0xf4, 0x57, 0x2e, 0xa8, 0x2c, 0x92, 0xf3, 0xc3, 0x12, 0x82,
0x87, 0xd0, 0xc8, 0xe2, 0xdd, 0x19, 0x0b, 0x41, 0xfd, 0x9a, 0xc5, 0x1b, 0x9b, 0xb2, 0x59, 0xe3,
0x2e, 0x34, 0x42, 0x2a, 0xd7, 0x4b, 0x55, 0x9c, 0x3a, 0xa5, 0xd3, 0x8f, 0xc1, 0x7f, 0x1e, 0x2d,
0xe8, 0x8a, 0x58, 0xce, 0x07, 0xd0, 0x90, 0x66, 0x6f, 0x59, 0x76, 0x87, 0xff, 0x70, 0x20, 0xc8,
0x1a, 0x62, 0x6a, 0x95, 0x33, 0x81, 0xbe, 0x2d, 0x49, 0x38, 0x1a, 0x7d, 0x39, 0xb8, 0xb3, 0x47,
0x06, 0xdb, 0x66, 0x83, 0x77, 0x4b, 0x7d, 0x69, 0x56, 0x7a, 0x00, 0xb5, 0x68, 0x95, 0x17, 0x4b,
0x2f, 0xb5, 0x5c, 0x4e, 0xd4, 0xa2, 0x5d, 0xeb, 0xd5, 0x74, 0x82, 0x7a, 0x8d, 0x87, 0x70, 0x74,
0xdb, 0x1a, 0x79, 0xd0, 0x7c, 0x71, 0xf9, 0xdd, 0xe5, 0xf7, 0x2f, 0x2f, 0x83, 0x3d, 0xe4, 0x42,
0xfd, 0x6a, 0x3c, 0x3b, 0x0b, 0x1c, 0xd4, 0x84, 0xda, 0xc9, 0xc5, 0x34, 0xd8, 0xc7, 0xbf, 0xed,
0x03, 0x64, 0x0a, 0xbe, 0x49, 0x6f, 0x58, 0x55, 0x7e, 0x68, 0x06, 0x8f, 0x32, 0xdd, 0xf3, 0xb8,
0xf0, 0x6f, 0xc4, 0x78, 0xa3, 0x4f, 0x76, 0xcc, 0x2b, 0x0c, 0x6e, 0xb6, 0x2f, 0x68, 0x0c, 0x2e,
0x4d, 0x63, 0xce, 0x92, 0x54, 0x99, 0x34, 0xbc, 0xd1, 0x47, 0xf7, 0x3a, 0x7b, 0x66, 0xc9, 0x61,
0x61, 0x86, 0x9e, 0xc2, 0xa1, 0x62, 0x8a, 0x2c, 0xe7, 0x82, 0x46, 0x4c, 0xc4, 0xb2, 0x5d, 0xef,
0x39, 0xfd, 0x5a, 0xe8, 0x1b, 0x30, 0xcc, 0x30, 0x74, 0x0c, 0x5e, 0x46, 0xba, 0xde, 0x28, 0x2a,
0xdb, 0x07, 0x86, 0x02, 0x06, 0x9a, 0x68, 0x04, 0xff, 0xee, 0xc0, 0xd1, 0xed, 0x10, 0xe8, 0x0b,
0x68, 0xa8, 0x24, 0x7a, 0x4d, 0x95, 0xb9, 0x09, 0x6f, 0xf4, 0x61, 0x85, 0xb2, 0x99, 0x21, 0x85,
0x96, 0x8c, 0xbe, 0x02, 0x77, 0xc9, 0x22, 0x62, 0x7b, 0x59, 0xa7, 0x74, 0x5c, 0x61, 0x78, 0x6e,
0x69, 0x61, 0x61, 0x80, 0xbb, 0xe0, 0xe6, 0xa8, 0x2e, 0xf8, 0x5a, 0x24, 0xb6, 0x7d, 0xf5, 0x12,
0xf7, 0xa0, 0x91, 0x05, 0xd3, 0x55, 0x2a, 0x69, 0xf3, 0xf3, 0xe0, 0xf8, 0x4f, 0x27, 0x2f, 0xe6,
0x94, 0xa8, 0x8a, 0xa2, 0x39, 0xff, 0xb5, 0x68, 0xc7, 0xe0, 0xc5, 0x44, 0x91, 0xf9, 0x82, 0x92,
0x98, 0x0a, 0xdb, 0x91, 0xa0, 0xa1, 0x33, 0x83, 0xa0, 0x27, 0xe0, 0x13, 0xce, 0xe7, 0x2b, 0xaa,
0x88, 0x46, 0xcd, 0x70, 0xf0, 0x43, 0x8f, 0x70, 0x7e, 0x61, 0x21, 0xd4, 0x85, 0x96, 0xf1, 0x61,
0xde, 0xdb, 0xdf, 0x4d, 0x43, 0x70, 0x35, 0x32, 0xd1, 0x8f, 0x6e, 0x00, 0xad, 0xab, 0xb5, 0xb2,
0x2f, 0x6e, 0xdb, 0x9b, 0xf3, 0x2f, 0x6f, 0xa3, 0xbf, 0x0e, 0xe0, 0x30, 0x13, 0xfe, 0x9c, 0x8a,
0x37, 0x49, 0x44, 0x51, 0x0c, 0xad, 0x62, 0x3c, 0xa2, 0xaa, 0x5c, 0xb7, 0x27, 0x73, 0xa7, 0xff,
0x30, 0x31, 0x9b, 0xb4, 0x78, 0xaf, 0xef, 0x0c, 0x1d, 0xf4, 0x02, 0xbc, 0xf3, 0x44, 0xaa, 0x2c,
0xb4, 0x44, 0x55, 0x85, 0xce, 0x87, 0x57, 0xe7, 0xc9, 0xbd, 0x97, 0xae, 0xdf, 0x1f, 0xde, 0x1b,
0x3a, 0xe8, 0x67, 0x38, 0x3c, 0xa5, 0xaa, 0xf4, 0x28, 0x77, 0x2d, 0xd6, 0x4e, 0x01, 0xd0, 0x4f,
0xd0, 0x3a, 0xa5, 0x2a, 0x9b, 0x6a, 0xbb, 0xbb, 0x7e, 0x5a, 0x41, 0x2c, 0x4f, 0x47, 0xbc, 0x87,
0x2e, 0xe0, 0x60, 0xca, 0x4e, 0xa9, 0x42, 0xf7, 0x3f, 0x97, 0x07, 0x94, 0xea, 0xee, 0x35, 0x57,
0x11, 0x6a, 0x77, 0x57, 0x6b, 0x85, 0x1e, 0xe6, 0x77, 0x7a, 0x15, 0x94, 0xa2, 0x95, 0x6c, 0xd5,
0xce, 0xc1, 0x9d, 0x32, 0xfb, 0x49, 0x54, 0xa9, 0xcc, 0x8e, 0x3b, 0x55, 0xc7, 0xb9, 0x3f, 0xa3,
0xd0, 0xf4, 0x40, 0x66, 0x20, 0x51, 0xb7, 0xc2, 0xc2, 0xfc, 0x86, 0x95, 0x59, 0xbf, 0xfb, 0x22,
0xb5, 0xcf, 0xc9, 0x63, 0xe8, 0x32, 0xf1, 0x6a, 0x40, 0x38, 0x89, 0x16, 0xf4, 0xb6, 0x49, 0xb2,
0xe2, 0xcb, 0xeb, 0x86, 0x31, 0xfc, 0xfc, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xe5, 0xcc, 0x70,
0xcc, 0x83, 0x08, 0x00, 0x00,
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment