Documentation ¶
Overview ¶
Package server contains 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 NewEmbedded(options ...EmbeddedOption) (common.TestingServer, error)
- func NewHTTPPullerHandler(logger *zap.Logger, r MetricsStreamer, opts ...HTTPPullerOption) http.Handler
- func StreamServerMetrics(registry metrics.Registry) grpc.StreamServerInterceptor
- func UnaryServerMetrics(registry metrics.Registry) grpc.UnaryServerInterceptor
- func ValidateDescribeTableRequest(logger *zap.Logger, request *api_service_protos.TDescribeTableRequest) error
- func ValidateListSplitsRequest(logger *zap.Logger, request *api_service_protos.TListSplitsRequest) error
- func ValidateReadSplitsRequest(logger *zap.Logger, request *api_service_protos.TReadSplitsRequest) error
- type DataSourceCollection
- type EmbeddedOption
- func WithConversionConfig(conversionConfig *config.TConversionConfig) EmbeddedOption
- func WithLoggerConfig(loggerConfig *config.TLoggerConfig) EmbeddedOption
- func WithMetricsServerConfig(metricsServerConfig *config.TMetricsServerConfig) EmbeddedOption
- func WithPagingConfig(pagingConfig *config.TPagingConfig) EmbeddedOption
- func WithPprofServerConfig(pprofServerConfig *config.TPprofServerConfig) EmbeddedOption
- type HTTPPullerOption
- type Launcher
- type MetricsStreamer
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func NewEmbedded ¶ added in v0.1.2
func NewEmbedded(options ...EmbeddedOption) (common.TestingServer, error)
func NewHTTPPullerHandler ¶
func NewHTTPPullerHandler(logger *zap.Logger, r MetricsStreamer, opts ...HTTPPullerOption) 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 *zap.Logger, request *api_service_protos.TDescribeTableRequest) error
func ValidateListSplitsRequest ¶
func ValidateListSplitsRequest(logger *zap.Logger, request *api_service_protos.TListSplitsRequest) error
func ValidateReadSplitsRequest ¶
func ValidateReadSplitsRequest(logger *zap.Logger, request *api_service_protos.TReadSplitsRequest) error
Types ¶
type DataSourceCollection ¶
type DataSourceCollection struct {
// contains filtered or unexported fields
}
func NewDataSourceCollection ¶
func NewDataSourceCollection( queryLoggerFactory common.QueryLoggerFactory, memoryAllocator memory.Allocator, readLimiterFactory *paging.ReadLimiterFactory, converterCollection conversion.Collection, cfg *config.TServerConfig, ) *DataSourceCollection
func (*DataSourceCollection) DescribeTable ¶
func (dsc *DataSourceCollection) DescribeTable( ctx context.Context, logger *zap.Logger, request *api_service_protos.TDescribeTableRequest, ) (*api_service_protos.TDescribeTableResponse, error)
func (*DataSourceCollection) DoReadSplit ¶
func (dsc *DataSourceCollection) DoReadSplit( logger *zap.Logger, stream api_service.Connector_ReadSplitsServer, request *api_service_protos.TReadSplitsRequest, split *api_service_protos.TSplit, ) error
type EmbeddedOption ¶ added in v0.1.2
type EmbeddedOption interface {
// contains filtered or unexported methods
}
EmbeddedOption parametrizes initialization of Connector server embedded into tests
func WithConversionConfig ¶ added in v0.1.2
func WithConversionConfig(conversionConfig *config.TConversionConfig) EmbeddedOption
func WithLoggerConfig ¶ added in v0.1.2
func WithLoggerConfig(loggerConfig *config.TLoggerConfig) EmbeddedOption
func WithMetricsServerConfig ¶ added in v0.2.13
func WithMetricsServerConfig(metricsServerConfig *config.TMetricsServerConfig) EmbeddedOption
func WithPagingConfig ¶ added in v0.1.2
func WithPagingConfig(pagingConfig *config.TPagingConfig) EmbeddedOption
func WithPprofServerConfig ¶ added in v0.1.2
func WithPprofServerConfig(pprofServerConfig *config.TPprofServerConfig) EmbeddedOption
type HTTPPullerOption ¶ added in v0.1.2
type HTTPPullerOption interface {
// contains filtered or unexported methods
}
func WithSpack ¶
func WithSpack() HTTPPullerOption
type Launcher ¶ added in v0.1.1
type Launcher struct {
// contains filtered or unexported fields
}
func NewLauncher ¶ added in v0.1.1
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package datasource describes the interface that must be satisfied by any external data source accessible through the connector.
|
Package datasource describes the interface that must be satisfied by any external data source accessible through the connector. |
rdbms
Package rdbms contains generalized abstractions suitable for use with any relational database.
|
Package rdbms contains generalized abstractions suitable for use with any relational database. |
rdbms/clickhouse
Package clickhouse contains code specific for ClickHouse database.
|
Package clickhouse contains code specific for ClickHouse database. |
rdbms/postgresql
Package postgresql contains code specific for PostgreSQL database.
|
Package postgresql contains code specific for PostgreSQL database. |
rdbms/utils
Package utils contains helper types and functions that can be used by any relational data source.
|
Package utils contains helper types and functions that can be used by any relational data source. |
rdbms/ydb
Package ydb contains code specific for YDB database.
|
Package ydb contains code specific for YDB database. |
s3
Package s3 contains the implementation of S3 (Simple Storage Service) based data source
|
Package s3 contains the implementation of S3 (Simple Storage Service) based data source |
Package paging contains logic of splitting incoming data stream into the separate pages or blocks.
|
Package paging contains logic of splitting incoming data stream into the separate pages or blocks. |
Package streaming contains the logic of converting the data stream coming from the data source into the data stream sent over the network to the client.
|
Package streaming contains the logic of converting the data stream coming from the data source into the data stream sent over the network to the client. |
Package utils contains various helpers and utility functions
|
Package utils contains various helpers and utility functions |
Click to show internal directories.
Click to hide internal directories.