Versions in this module Expand all Collapse all v16 v16.1.0 May 9, 2024 v16.0.0 Apr 16, 2024 Changes in this version + const CancelFlightInfoActionType + const CancelStatusCancelled + const CancelStatusCancelling + const CancelStatusNotCancellable + const CancelStatusUnspecified + const CloseSessionActionType + const CloseSessionResultClosed + const CloseSessionResultClosing + const CloseSessionResultNotCloseable + const CloseSessionResultUnspecified + const DescriptorCMD + const DescriptorPATH + const DescriptorUNKNOWN + const GetSessionOptionsActionType + const LocationReuseConnection + const RenewFlightEndpointActionType + const SetSessionOptionsActionType + const SetSessionOptionsResultErrorError + const SetSessionOptionsResultErrorInvalidName + const SetSessionOptionsResultErrorInvalidValue + const SetSessionOptionsResultErrorUnspecified + var NewFlightServiceClient = flight.NewFlightServiceClient + func AuthFromContext(ctx context.Context) interface + func ConcatenateReaders(rdrs []array.RecordReader, ch chan<- StreamChunk) + func CreateServerBearerTokenAuthInterceptors(validator BasicAuthValidator) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor) + func DeserializeSchema(info []byte, mem memory.Allocator) (*arrow.Schema, error) + func NewSessionOptionValue(value any) (flight.SessionOptionValue, error) + func NewSessionOptionValues(options map[string]any) (map[string]*flight.SessionOptionValue, error) + func ReadUntilEOF(stream FlightService_DoActionClient) error + func RegisterFlightServiceServer(s *grpc.Server, srv FlightServer) + func SerializeSchema(rec *arrow.Schema, mem memory.Allocator) []byte + func StreamChunksFromReader(rdr array.RecordReader, ch chan<- StreamChunk) + 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 CancelFlightInfoRequest = flight.CancelFlightInfoRequest + type CancelFlightInfoResult = flight.CancelFlightInfoResult + type CancelStatus = flight.CancelStatus + 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) + CancelFlightInfo func(ctx context.Context, request *CancelFlightInfoRequest, opts ...grpc.CallOption) (*CancelFlightInfoResult, error) + Close func() error + CloseSession func(ctx context.Context, request *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResult, error) + GetSessionOptions func(ctx context.Context, request *GetSessionOptionsRequest, ...) (*GetSessionOptionsResult, error) + RenewFlightEndpoint func(ctx context.Context, request *RenewFlightEndpointRequest, ...) (*FlightEndpoint, error) + SetSessionOptions func(ctx context.Context, request *SetSessionOptionsRequest, ...) (*SetSessionOptionsResult, error) + func NewClientFromConn(cc grpc.ClientConnInterface, auth ClientAuthHandler) Client + func NewClientWithMiddleware(addr string, auth ClientAuthHandler, middleware []ClientMiddleware, ...) (Client, error) + func NewClientWithMiddlewareCtx(ctx context.Context, addr string, auth ClientAuthHandler, ...) (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 + func NewClientCookieMiddleware() ClientMiddleware + type ClientPostCallMiddleware interface + CallCompleted func(ctx context.Context, err error) + type CloseSessionRequest = flight.CloseSessionRequest + type CloseSessionResult = flight.CloseSessionResult + type CookieMiddleware interface + Clone func() CookieMiddleware + func NewCookieMiddleware() CookieMiddleware + 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 GetSessionOptionsRequest = flight.GetSessionOptionsRequest + type GetSessionOptionsResult = flight.GetSessionOptionsResult + type HandshakeRequest = flight.HandshakeRequest + type HandshakeResponse = flight.HandshakeResponse + type Location = flight.Location + type MessageReader interface + Chunk func() StreamChunk + Err func() error + LatestAppMetadata func() []byte + LatestFlightDescriptor func() *FlightDescriptor + type MetadataWriter interface + WriteMetadata func([]byte) error + type PollInfo = flight.PollInfo + type PutResult = flight.PutResult + type Reader struct + func NewRecordReader(r DataStreamReader, opts ...ipc.Option) (*Reader, error) + func (r *Reader) Chunk() StreamChunk + func (r *Reader) LatestAppMetadata() []byte + func (r *Reader) LatestFlightDescriptor() *FlightDescriptor + func (r *Reader) Release() + func (r *Reader) Retain() + type RenewFlightEndpointRequest = flight.RenewFlightEndpointRequest + 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 SessionOptionValue = flight.SessionOptionValue + type SetSessionOptionsRequest = flight.SetSessionOptionsRequest + type SetSessionOptionsResult = flight.SetSessionOptionsResult + type SetSessionOptionsResultError = flight.SetSessionOptionsResult_Error + type StreamChunk struct + AppMetadata []byte + Data arrow.Record + Desc *FlightDescriptor + Err error + 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) WriteMetadata(appMetadata []byte) 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/v17 github.com/apache/arrow/go/v6 github.com/apache/arrow/go/v7 github.com/apache/arrow/go/v8 github.com/apache/arrow/go/v9