Versions in this module Expand all Collapse all v7 v7.0.1 Jul 14, 2022 v7.0.0 Jan 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 + func AuthFromContext(ctx context.Context) interface + func CreateServerBearerTokenAuthInterceptors(validator BasicAuthValidator) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor) + func DeserializeSchema(info []byte, mem memory.Allocator) (*arrow.Schema, error) + func RegisterFlightServiceService(s grpc.ServiceRegistrar, srv *FlightServiceService) + func SerializeSchema(rec *arrow.Schema, mem memory.Allocator) []byte + 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 AuthConn interface + Read func() ([]byte, error) + Send func([]byte) error + 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 BasicAuthValidator interface + IsValid func(bearerToken string) (interface{}, error) + Validate func(username, password string) (string, error) + type Client interface + Authenticate func(context.Context, ...grpc.CallOption) error + AuthenticateBasicToken func(ctx context.Context, username string, password string, opts ...grpc.CallOption) (context.Context, error) + Close func() error + func NewClientWithMiddleware(addr string, auth ClientAuthHandler, middleware []ClientMiddleware, ...) (Client, error) + func NewFlightClient(addr string, auth ClientAuthHandler, opts ...grpc.DialOption) (Client, error) + type ClientAuthHandler interface + Authenticate func(context.Context, AuthConn) error + GetToken func(context.Context) (string, error) + type ClientHeadersMiddleware interface + HeadersReceived func(ctx context.Context, md metadata.MD) + type ClientMiddleware struct + Stream grpc.StreamClientInterceptor + Unary grpc.UnaryClientInterceptor + func CreateClientMiddleware(middleware CustomClientMiddleware) ClientMiddleware + type ClientPostCallMiddleware interface + CallCompleted func(ctx context.Context, err error) + 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 CustomClientMiddleware interface + StartCall func(ctx context.Context) context.Context + type CustomServerMiddleware interface + CallCompleted func(ctx context.Context, err error) + StartCall func(ctx context.Context) context.Context + type DataStreamReader interface + Recv func() (*FlightData, error) + type DataStreamWriter interface + Send func(*FlightData) error + 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 FlightServiceService struct + 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 + func NewFlightServiceService(s interface{}) *FlightServiceService + 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 Reader struct + func NewRecordReader(r DataStreamReader, opts ...ipc.Option) (*Reader, error) + func (r *Reader) LatestAppMetadata() []byte + func (r *Reader) LatestFlightDescriptor() *FlightDescriptor + func (r *Reader) Release() + func (r *Reader) Retain() + 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 Server interface + Addr func() net.Addr + Init func(addr string) error + RegisterFlightService func(*FlightServiceService) + Serve func() error + SetShutdownOnSignals func(sig ...os.Signal) + Shutdown func() + func NewFlightServer(auth ServerAuthHandler, opt ...grpc.ServerOption) Server + func NewServerWithMiddleware(auth ServerAuthHandler, middleware []ServerMiddleware, ...) Server + type ServerAuthHandler interface + Authenticate func(AuthConn) error + IsValid func(token string) (interface{}, error) + type ServerMiddleware struct + Stream grpc.StreamServerInterceptor + Unary grpc.UnaryServerInterceptor + func CreateServerBasicAuthMiddleware(validator BasicAuthValidator) ServerMiddleware + func CreateServerMiddleware(middleware CustomServerMiddleware) ServerMiddleware + 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 UnstableFlightServiceService 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 Writer struct + func NewRecordWriter(w DataStreamWriter, opts ...ipc.Option) *Writer + func (w *Writer) SetFlightDescriptor(descr *FlightDescriptor) + func (w *Writer) Write(rec arrow.Record) error + func (w *Writer) WriteWithAppMetadata(rec arrow.Record, appMeta []byte) error 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/v14 github.com/apache/arrow/go/v15 github.com/apache/arrow/go/v16 github.com/apache/arrow/go/v6 github.com/apache/arrow/go/v8 github.com/apache/arrow/go/v9