server

Documentation

Overview

Package server containes the code base of Connector GRPC service - the component of YDB's Federated Query system providing the unified interface to the external data sources.

Index

• Variables
• func NewHTTPPullerHandler(r MetricsStreamer, opts ...Option) http.Handler
• func StreamServerMetrics(registry metrics.Registry) grpc.StreamServerInterceptor
• func UnaryServerMetrics(registry metrics.Registry) grpc.UnaryServerInterceptor
• func ValidateDescribeTableRequest(logger log.Logger, request *api_service_protos.TDescribeTableRequest) error
• func ValidateListSplitsRequest(logger log.Logger, request *api_service_protos.TListSplitsRequest) error
• func ValidateReadSplitsRequest(logger log.Logger, request *api_service_protos.TReadSplitsRequest) error
• type DataSourceCollection
  • func NewDataSourceCollection(queryLoggerFactory utils.QueryLoggerFactory, memoryAllocator memory.Allocator, ...) *DataSourceCollection
  • func (dsc *DataSourceCollection) DescribeTable(ctx context.Context, logger log.Logger, ...) (*api_service_protos.TDescribeTableResponse, error)
  • func (dsc *DataSourceCollection) DoReadSplit(logger log.Logger, stream api_service.Connector_ReadSplitsServer, ...) error
• type MetricsStreamer
• type Option
  • func WithSpack() Option

Variables

var Cmd = &cobra.Command{
	Use:   "server",
	Short: "Connector server",
	Run: func(cmd *cobra.Command, args []string) {
		if err := run(cmd, args); err != nil {
			fmt.Println(err)
			os.Exit(1)
		}
	},
}

Functions

func NewHTTPPullerHandler

func NewHTTPPullerHandler(r MetricsStreamer, opts ...Option) http.Handler

NewHTTPPullerHandler returns new HTTP handler to expose gathered metrics using metrics dumper

func StreamServerMetrics

func StreamServerMetrics(registry metrics.Registry) grpc.StreamServerInterceptor

func UnaryServerMetrics

func UnaryServerMetrics(registry metrics.Registry) grpc.UnaryServerInterceptor

func ValidateDescribeTableRequest

func ValidateDescribeTableRequest(logger log.Logger, request *api_service_protos.TDescribeTableRequest) error

func ValidateListSplitsRequest

func ValidateListSplitsRequest(logger log.Logger, request *api_service_protos.TListSplitsRequest) error

func ValidateReadSplitsRequest

func ValidateReadSplitsRequest(logger log.Logger, request *api_service_protos.TReadSplitsRequest) error

Types

type DataSourceCollection

type DataSourceCollection struct {
	// contains filtered or unexported fields
}

func NewDataSourceCollection

func NewDataSourceCollection(
	queryLoggerFactory utils.QueryLoggerFactory,
	memoryAllocator memory.Allocator,
	readLimiterFactory *paging.ReadLimiterFactory,
	cfg *config.TServerConfig,
) *DataSourceCollection

func (*DataSourceCollection) DescribeTable

func (dsc *DataSourceCollection) DescribeTable(
	ctx context.Context, logger log.Logger, request *api_service_protos.TDescribeTableRequest,
) (*api_service_protos.TDescribeTableResponse, error)

func (*DataSourceCollection) DoReadSplit

func (dsc *DataSourceCollection) DoReadSplit(
	logger log.Logger,
	stream api_service.Connector_ReadSplitsServer,
	request *api_service_protos.TReadSplitsRequest,
	split *api_service_protos.TSplit,
) error

type MetricsStreamer

type MetricsStreamer interface {
	StreamJSON(context.Context, io.Writer) (int, error)
	StreamSpack(context.Context, io.Writer, solomon.CompressionType) (int, error)
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithSpack

func WithSpack() Option