Versions in this module Expand all Collapse all v0 v0.1.0 Mar 17, 2023 Changes in this version + var ErrEmptyFlightData = errors.New("flight data body is empty") + var ErrInvalidArrowFlightConfiguration = errors.New("invalid arrow flight server configuration") + var ErrInvalidArrowFlightSchema = errors.New("invalid arrow flight schema format") + var ErrMissingFlightDescriptor = errors.New("missing flight path descriptor") + var ErrWrongFlightDescriptorPath = errors.New("expect one flight descriptor path") + type FlightService struct + func StartFlight(nodeIP string, port uint, file common.ConsistentFileStore, ...) (*FlightService, error) + func (fs *FlightService) DoAction(action *flight.Action, server flight.FlightService_DoActionServer) error + func (fs *FlightService) DoExchange(server flight.FlightService_DoExchangeServer) error + func (fs *FlightService) DoGet(ticket *flight.Ticket, server flight.FlightService_DoGetServer) error + func (fs *FlightService) DoPut(server flight.FlightService_DoPutServer) error + func (fs *FlightService) GetFlightInfo(_ context.Context, desc *flight.FlightDescriptor) (*flight.FlightInfo, error) + func (fs *FlightService) GetSchema(_ context.Context, desc *flight.FlightDescriptor) (*flight.SchemaResult, error) + func (fs *FlightService) Handshake(server flight.FlightService_HandshakeServer) error + func (fs *FlightService) ListActions(_ *flight.Empty, server flight.FlightService_ListActionsServer) error + func (fs *FlightService) ListFlights(criteria *flight.Criteria, server flight.FlightService_ListFlightsServer) error + func (fs *FlightService) Shutdown()