server

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 21, 2025 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlightSQLServer 

type FlightSQLServer struct {
	flightsql.BaseServer
	// contains filtered or unexported fields
}

FlightSQLServer implements the Flight SQL protocol.

func New 

func New(cfg *config.Config, logger zerolog.Logger, metrics MetricsCollector) (*FlightSQLServer, error)

New creates a new Flight SQL server (placeholder - use NewFlightSQLServer for now).

func NewFlightSQLServer 

func NewFlightSQLServer(
	qh handlers.QueryHandler,
	mh handlers.MetadataHandler,
	th handlers.TransactionHandler,
	ph handlers.PreparedStatementHandler,
	p pool.ConnectionPool,
	conv interface{},
	alloc arrowmemory.Allocator,
	c cache.Cache,
	kg cache.CacheKeyGenerator,
	m interface{},
	lg zerolog.Logger,
) *FlightSQLServer

NewFlightSQLServer wires up all dependencies (deprecated - use New instead).

func (*FlightSQLServer) BeginTransaction 

func (s *FlightSQLServer) BeginTransaction(
	ctx context.Context,
	req flightsql.ActionBeginTransactionRequest,
) ([]byte, error)

func (*FlightSQLServer) Close 

func (s *FlightSQLServer) Close(ctx context.Context) error

Close gracefully shuts down the server.

func (*FlightSQLServer) ClosePreparedStatement 

func (s *FlightSQLServer) ClosePreparedStatement(
	ctx context.Context,
	req flightsql.ActionClosePreparedStatementRequest,
) error

func (*FlightSQLServer) CreatePreparedStatement 

func (s *FlightSQLServer) CreatePreparedStatement(
	ctx context.Context,
	req flightsql.ActionCreatePreparedStatementRequest,
) (flightsql.ActionCreatePreparedStatementResult, error)

func (*FlightSQLServer) DoExchange 

func (s *FlightSQLServer) DoExchange(stream flight.FlightService_DoExchangeServer) error

DoExchange handles bidirectional Flight SQL streams. Currently unsupported, so return Unimplemented until implemented.

func (*FlightSQLServer) DoGetCatalogs 

func (s *FlightSQLServer) DoGetCatalogs(
	ctx context.Context,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetCrossReference 

func (s *FlightSQLServer) DoGetCrossReference(
	ctx context.Context,
	cmd flightsql.CrossTableRef,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetDBSchemas 

func (s *FlightSQLServer) DoGetDBSchemas(
	ctx context.Context,
	cmd flightsql.GetDBSchemas,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetExportedKeys 

func (s *FlightSQLServer) DoGetExportedKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetImportedKeys 

func (s *FlightSQLServer) DoGetImportedKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetPreparedStatement 

func (s *FlightSQLServer) DoGetPreparedStatement(
	ctx context.Context,
	cmd flightsql.PreparedStatementQuery,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetPrimaryKeys 

func (s *FlightSQLServer) DoGetPrimaryKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetSqlInfo 

func (s *FlightSQLServer) DoGetSqlInfo(
	ctx context.Context,
	cmd flightsql.GetSqlInfo,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetStatement 

func (s *FlightSQLServer) DoGetStatement(
	ctx context.Context,
	ticket flightsql.StatementQueryTicket,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

DoGetStatement streams the query results, with a fast path to the cache.

func (*FlightSQLServer) DoGetTableTypes 

func (s *FlightSQLServer) DoGetTableTypes(
	ctx context.Context,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetTables 

func (s *FlightSQLServer) DoGetTables(
	ctx context.Context,
	cmd flightsql.GetTables,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoGetXdbcTypeInfo 

func (s *FlightSQLServer) DoGetXdbcTypeInfo(
	ctx context.Context,
	cmd flightsql.GetXdbcTypeInfo,
) (*arrow.Schema, <-chan flight.StreamChunk, error)

func (*FlightSQLServer) DoPutCommandStatementUpdate 

func (s *FlightSQLServer) DoPutCommandStatementUpdate(
	ctx context.Context,
	req flightsql.StatementUpdate,
) (int64, error)

func (*FlightSQLServer) DoPutPreparedStatementQuery 

func (s *FlightSQLServer) DoPutPreparedStatementQuery(
	ctx context.Context,
	cmd flightsql.PreparedStatementQuery,
	reader flight.MessageReader,
	writer flight.MetadataWriter,
) ([]byte, error)

func (*FlightSQLServer) DoPutPreparedStatementUpdate 

func (s *FlightSQLServer) DoPutPreparedStatementUpdate(
	ctx context.Context,
	cmd flightsql.PreparedStatementUpdate,
	reader flight.MessageReader,
) (int64, error)

func (*FlightSQLServer) EndTransaction 

func (s *FlightSQLServer) EndTransaction(
	ctx context.Context,
	req flightsql.ActionEndTransactionRequest,
) error

func (*FlightSQLServer) GetFlightInfoCatalogs 

func (s *FlightSQLServer) GetFlightInfoCatalogs(
	ctx context.Context,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoCrossReference 

func (s *FlightSQLServer) GetFlightInfoCrossReference(
	ctx context.Context,
	cmd flightsql.CrossTableRef,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoExportedKeys 

func (s *FlightSQLServer) GetFlightInfoExportedKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoImportedKeys 

func (s *FlightSQLServer) GetFlightInfoImportedKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoPreparedStatement 

func (s *FlightSQLServer) GetFlightInfoPreparedStatement(
	ctx context.Context,
	cmd flightsql.PreparedStatementQuery,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoPrimaryKeys 

func (s *FlightSQLServer) GetFlightInfoPrimaryKeys(
	ctx context.Context,
	cmd flightsql.TableRef,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoSchemas 

func (s *FlightSQLServer) GetFlightInfoSchemas(
	ctx context.Context,
	cmd flightsql.GetDBSchemas,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoSqlInfo 

func (s *FlightSQLServer) GetFlightInfoSqlInfo(
	ctx context.Context,
	cmd flightsql.GetSqlInfo,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoStatement 

func (s *FlightSQLServer) GetFlightInfoStatement(
	ctx context.Context,
	cmd flightsql.StatementQuery,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

GetFlightInfoStatement handles CommandStatementQuery requests from Flight SQL clients

func (*FlightSQLServer) GetFlightInfoTableTypes 

func (s *FlightSQLServer) GetFlightInfoTableTypes(
	ctx context.Context,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoTables 

func (s *FlightSQLServer) GetFlightInfoTables(
	ctx context.Context,
	cmd flightsql.GetTables,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetFlightInfoXdbcTypeInfo 

func (s *FlightSQLServer) GetFlightInfoXdbcTypeInfo(
	ctx context.Context,
	cmd flightsql.GetXdbcTypeInfo,
	desc *flight.FlightDescriptor,
) (*flight.FlightInfo, error)

func (*FlightSQLServer) GetMiddleware 

func (s *FlightSQLServer) GetMiddleware() []grpc.ServerOption

GetMiddleware returns gRPC middleware for the server.

func (*FlightSQLServer) Register 

func (s *FlightSQLServer) Register(grpcServer *grpc.Server)

Register registers the Flight SQL server with a gRPC server.

type MetricsCollector 

type MetricsCollector interface {
	IncrementCounter(name string, labels ...string)
	RecordHistogram(name string, value float64, labels ...string)
	RecordGauge(name string, value float64, labels ...string)
	StartTimer(name string) Timer
}

MetricsCollector defines the metrics interface.

type Timer 

type Timer interface {
	Stop() float64
}

Timer represents a timing measurement.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.