Versions in this module Expand all Collapse all v9 v9.0.2 Sep 28, 2022 Changes in this version + const DescriptorCMD + const DescriptorPATH + const DescriptorUNKNOWN + var NewFlightServiceClient = flight.NewFlightServiceClient + 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 SerializeSchema(rec *arrow.Schema, mem memory.Allocator) []byte + type Action = flight.Action + type ActionType = flight.ActionType + type AuthConn interface + Read func() ([]byte, error) + Send func([]byte) error + type BaseFlightServer struct + func (s *BaseFlightServer) GetAuthHandler() ServerAuthHandler + func (s *BaseFlightServer) Handshake(stream flight.FlightService_HandshakeServer) error + func (s *BaseFlightServer) SetAuthHandler(handler ServerAuthHandler) + type BasicAuth = flight.BasicAuth + 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 = flight.Criteria + 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 DescriptorType = flight.FlightDescriptor_DescriptorType + type Empty = flight.Empty + type FlightData = flight.FlightData + type FlightDescriptor = flight.FlightDescriptor + type FlightEndpoint = flight.FlightEndpoint + type FlightInfo = flight.FlightInfo + type FlightServer = flight.FlightServiceServer + type FlightServiceClient = flight.FlightServiceClient + type FlightService_DoActionClient = flight.FlightService_DoActionClient + type FlightService_DoActionServer = flight.FlightService_DoActionServer + type FlightService_DoExchangeClient = flight.FlightService_DoExchangeClient + type FlightService_DoExchangeServer = flight.FlightService_DoExchangeServer + type FlightService_DoGetClient = flight.FlightService_DoGetClient + type FlightService_DoGetServer = flight.FlightService_DoGetServer + type FlightService_DoPutClient = flight.FlightService_DoPutClient + type FlightService_DoPutServer = flight.FlightService_DoPutServer + type FlightService_HandshakeClient = flight.FlightService_HandshakeClient + type FlightService_HandshakeServer = flight.FlightService_HandshakeServer + type FlightService_ListActionsClient = flight.FlightService_ListActionsClient + type FlightService_ListActionsServer = flight.FlightService_ListActionsServer + type FlightService_ListFlightsClient = flight.FlightService_ListFlightsClient + type FlightService_ListFlightsServer = flight.FlightService_ListFlightsServer + type HandshakeRequest = flight.HandshakeRequest + type HandshakeResponse = flight.HandshakeResponse + type Location = flight.Location + type PutResult = flight.PutResult + 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 = flight.Result + type SchemaResult = flight.SchemaResult + type Server interface + Addr func() net.Addr + Init func(addr string) error + InitListener func(lis net.Listener) + RegisterFlightService func(FlightServer) + Serve func() error + SetShutdownOnSignals func(sig ...os.Signal) + Shutdown func() + func NewFlightServer(opt ...grpc.ServerOption) Server + func NewServerWithMiddleware(middleware []ServerMiddleware, opts ...grpc.ServerOption) 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 = flight.Ticket + 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