server

package

v0.0.2 Latest Latest Go to latest Published: Dec 13, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

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 MetricsStreamer
type Option
- func WithSpack() Option

Constants ¶

This section is empty.

Variables ¶

View Source

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 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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
datasource 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.
paging 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.
streaming 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.
utils Package utils contains various helpers and utility functions	Package utils contains various helpers and utility functions

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL