Versions in this module Expand all Collapse all v9 v9.0.0 Jul 29, 2022 Changes in this version + var File_Flight_proto protoreflect.FileDescriptor + var FlightDescriptor_DescriptorType_name = map[int32]string + var FlightDescriptor_DescriptorType_value = map[string]int32 + var FlightService_ServiceDesc = grpc.ServiceDesc + func RegisterFlightServiceServer(s grpc.ServiceRegistrar, srv FlightServiceServer) + type Action struct + Body []byte + Type string + func (*Action) Descriptor() ([]byte, []int) + func (*Action) ProtoMessage() + func (x *Action) GetBody() []byte + func (x *Action) GetType() string + func (x *Action) ProtoReflect() protoreflect.Message + func (x *Action) Reset() + func (x *Action) String() string + type ActionType struct + Description string + Type string + func (*ActionType) Descriptor() ([]byte, []int) + func (*ActionType) ProtoMessage() + func (x *ActionType) GetDescription() string + func (x *ActionType) GetType() string + func (x *ActionType) ProtoReflect() protoreflect.Message + func (x *ActionType) Reset() + func (x *ActionType) String() string + type BasicAuth struct + Password string + Username string + func (*BasicAuth) Descriptor() ([]byte, []int) + func (*BasicAuth) ProtoMessage() + func (x *BasicAuth) GetPassword() string + func (x *BasicAuth) GetUsername() string + func (x *BasicAuth) ProtoReflect() protoreflect.Message + func (x *BasicAuth) Reset() + func (x *BasicAuth) String() string + type Criteria struct + Expression []byte + func (*Criteria) Descriptor() ([]byte, []int) + func (*Criteria) ProtoMessage() + func (x *Criteria) GetExpression() []byte + func (x *Criteria) ProtoReflect() protoreflect.Message + func (x *Criteria) Reset() + func (x *Criteria) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type FlightData struct + AppMetadata []byte + DataBody []byte + DataHeader []byte + FlightDescriptor *FlightDescriptor + func (*FlightData) Descriptor() ([]byte, []int) + func (*FlightData) ProtoMessage() + func (x *FlightData) GetAppMetadata() []byte + func (x *FlightData) GetDataBody() []byte + func (x *FlightData) GetDataHeader() []byte + func (x *FlightData) GetFlightDescriptor() *FlightDescriptor + func (x *FlightData) ProtoReflect() protoreflect.Message + func (x *FlightData) Reset() + func (x *FlightData) String() string + type FlightDescriptor struct + Cmd []byte + Path []string + Type FlightDescriptor_DescriptorType + func (*FlightDescriptor) Descriptor() ([]byte, []int) + func (*FlightDescriptor) ProtoMessage() + func (x *FlightDescriptor) GetCmd() []byte + func (x *FlightDescriptor) GetPath() []string + func (x *FlightDescriptor) GetType() FlightDescriptor_DescriptorType + func (x *FlightDescriptor) ProtoReflect() protoreflect.Message + func (x *FlightDescriptor) Reset() + func (x *FlightDescriptor) String() string + type FlightDescriptor_DescriptorType int32 + const FlightDescriptor_CMD + const FlightDescriptor_PATH + const FlightDescriptor_UNKNOWN + func (FlightDescriptor_DescriptorType) Descriptor() protoreflect.EnumDescriptor + func (FlightDescriptor_DescriptorType) EnumDescriptor() ([]byte, []int) + func (FlightDescriptor_DescriptorType) Type() protoreflect.EnumType + func (x FlightDescriptor_DescriptorType) Enum() *FlightDescriptor_DescriptorType + func (x FlightDescriptor_DescriptorType) Number() protoreflect.EnumNumber + func (x FlightDescriptor_DescriptorType) String() string + type FlightEndpoint struct + Location []*Location + Ticket *Ticket + func (*FlightEndpoint) Descriptor() ([]byte, []int) + func (*FlightEndpoint) ProtoMessage() + func (x *FlightEndpoint) GetLocation() []*Location + func (x *FlightEndpoint) GetTicket() *Ticket + func (x *FlightEndpoint) ProtoReflect() protoreflect.Message + func (x *FlightEndpoint) Reset() + func (x *FlightEndpoint) String() string + type FlightInfo struct + Endpoint []*FlightEndpoint + FlightDescriptor *FlightDescriptor + Schema []byte + TotalBytes int64 + TotalRecords int64 + func (*FlightInfo) Descriptor() ([]byte, []int) + func (*FlightInfo) ProtoMessage() + func (x *FlightInfo) GetEndpoint() []*FlightEndpoint + func (x *FlightInfo) GetFlightDescriptor() *FlightDescriptor + func (x *FlightInfo) GetSchema() []byte + func (x *FlightInfo) GetTotalBytes() int64 + func (x *FlightInfo) GetTotalRecords() int64 + func (x *FlightInfo) ProtoReflect() protoreflect.Message + func (x *FlightInfo) Reset() + func (x *FlightInfo) String() string + type FlightServiceClient interface + DoAction func(ctx context.Context, in *Action, opts ...grpc.CallOption) (FlightService_DoActionClient, error) + DoExchange func(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoExchangeClient, error) + DoGet func(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (FlightService_DoGetClient, error) + DoPut func(ctx context.Context, opts ...grpc.CallOption) (FlightService_DoPutClient, error) + GetFlightInfo func(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*FlightInfo, error) + GetSchema func(ctx context.Context, in *FlightDescriptor, opts ...grpc.CallOption) (*SchemaResult, error) + Handshake func(ctx context.Context, opts ...grpc.CallOption) (FlightService_HandshakeClient, error) + ListActions func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (FlightService_ListActionsClient, error) + ListFlights func(ctx context.Context, in *Criteria, opts ...grpc.CallOption) (FlightService_ListFlightsClient, error) + func NewFlightServiceClient(cc grpc.ClientConnInterface) FlightServiceClient + type FlightServiceServer interface + DoAction func(*Action, FlightService_DoActionServer) error + DoExchange func(FlightService_DoExchangeServer) error + DoGet func(*Ticket, FlightService_DoGetServer) error + DoPut func(FlightService_DoPutServer) error + GetFlightInfo func(context.Context, *FlightDescriptor) (*FlightInfo, error) + GetSchema func(context.Context, *FlightDescriptor) (*SchemaResult, error) + Handshake func(FlightService_HandshakeServer) error + ListActions func(*Empty, FlightService_ListActionsServer) error + ListFlights func(*Criteria, FlightService_ListFlightsServer) error + type FlightService_DoActionClient interface + Recv func() (*Result, error) + type FlightService_DoActionServer interface + Send func(*Result) error + type FlightService_DoExchangeClient interface + Recv func() (*FlightData, error) + Send func(*FlightData) error + type FlightService_DoExchangeServer interface + Recv func() (*FlightData, error) + Send func(*FlightData) error + type FlightService_DoGetClient interface + Recv func() (*FlightData, error) + type FlightService_DoGetServer interface + Send func(*FlightData) error + type FlightService_DoPutClient interface + Recv func() (*PutResult, error) + Send func(*FlightData) error + type FlightService_DoPutServer interface + Recv func() (*FlightData, error) + Send func(*PutResult) error + type FlightService_HandshakeClient interface + Recv func() (*HandshakeResponse, error) + Send func(*HandshakeRequest) error + type FlightService_HandshakeServer interface + Recv func() (*HandshakeRequest, error) + Send func(*HandshakeResponse) error + type FlightService_ListActionsClient interface + Recv func() (*ActionType, error) + type FlightService_ListActionsServer interface + Send func(*ActionType) error + type FlightService_ListFlightsClient interface + Recv func() (*FlightInfo, error) + type FlightService_ListFlightsServer interface + Send func(*FlightInfo) error + type HandshakeRequest struct + Payload []byte + ProtocolVersion uint64 + func (*HandshakeRequest) Descriptor() ([]byte, []int) + func (*HandshakeRequest) ProtoMessage() + func (x *HandshakeRequest) GetPayload() []byte + func (x *HandshakeRequest) GetProtocolVersion() uint64 + func (x *HandshakeRequest) ProtoReflect() protoreflect.Message + func (x *HandshakeRequest) Reset() + func (x *HandshakeRequest) String() string + type HandshakeResponse struct + Payload []byte + ProtocolVersion uint64 + func (*HandshakeResponse) Descriptor() ([]byte, []int) + func (*HandshakeResponse) ProtoMessage() + func (x *HandshakeResponse) GetPayload() []byte + func (x *HandshakeResponse) GetProtocolVersion() uint64 + func (x *HandshakeResponse) ProtoReflect() protoreflect.Message + func (x *HandshakeResponse) Reset() + func (x *HandshakeResponse) String() string + type Location struct + Uri string + func (*Location) Descriptor() ([]byte, []int) + func (*Location) ProtoMessage() + func (x *Location) GetUri() string + func (x *Location) ProtoReflect() protoreflect.Message + func (x *Location) Reset() + func (x *Location) String() string + type PutResult struct + AppMetadata []byte + func (*PutResult) Descriptor() ([]byte, []int) + func (*PutResult) ProtoMessage() + func (x *PutResult) GetAppMetadata() []byte + func (x *PutResult) ProtoReflect() protoreflect.Message + func (x *PutResult) Reset() + func (x *PutResult) String() string + type Result struct + Body []byte + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (x *Result) GetBody() []byte + func (x *Result) ProtoReflect() protoreflect.Message + func (x *Result) Reset() + func (x *Result) String() string + type SchemaResult struct + Schema []byte + func (*SchemaResult) Descriptor() ([]byte, []int) + func (*SchemaResult) ProtoMessage() + func (x *SchemaResult) GetSchema() []byte + func (x *SchemaResult) ProtoReflect() protoreflect.Message + func (x *SchemaResult) Reset() + func (x *SchemaResult) String() string + type Ticket struct + Ticket []byte + func (*Ticket) Descriptor() ([]byte, []int) + func (*Ticket) ProtoMessage() + func (x *Ticket) GetTicket() []byte + func (x *Ticket) ProtoReflect() protoreflect.Message + func (x *Ticket) Reset() + func (x *Ticket) String() string + type UnimplementedFlightServiceServer struct + func (UnimplementedFlightServiceServer) DoAction(*Action, FlightService_DoActionServer) error + func (UnimplementedFlightServiceServer) DoExchange(FlightService_DoExchangeServer) error + func (UnimplementedFlightServiceServer) DoGet(*Ticket, FlightService_DoGetServer) error + func (UnimplementedFlightServiceServer) DoPut(FlightService_DoPutServer) error + func (UnimplementedFlightServiceServer) GetFlightInfo(context.Context, *FlightDescriptor) (*FlightInfo, error) + func (UnimplementedFlightServiceServer) GetSchema(context.Context, *FlightDescriptor) (*SchemaResult, error) + func (UnimplementedFlightServiceServer) Handshake(FlightService_HandshakeServer) error + func (UnimplementedFlightServiceServer) ListActions(*Empty, FlightService_ListActionsServer) error + func (UnimplementedFlightServiceServer) ListFlights(*Criteria, FlightService_ListFlightsServer) error + type UnsafeFlightServiceServer interface Other modules containing this package github.com/apache/arrow/go/v10 github.com/apache/arrow/go/v11 github.com/apache/arrow/go/v12 github.com/apache/arrow/go/v13 github.com/apache/arrow/go/v8