config

package
v0.5.10 Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ELogLevel_name = map[int32]string{
		0: "TRACE",
		1: "DEBUG",
		2: "INFO",
		3: "WARN",
		4: "ERROR",
		5: "FATAL",
	}
	ELogLevel_value = map[string]int32{
		"TRACE": 0,
		"DEBUG": 1,
		"INFO":  2,
		"WARN":  3,
		"ERROR": 4,
		"FATAL": 5,
	}
)

Enum value maps for ELogLevel.

View Source 
var File_app_config_bench_proto protoreflect.FileDescriptor
View Source 
var File_app_config_client_proto protoreflect.FileDescriptor
View Source 
var File_app_config_server_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ELogLevel 

type ELogLevel int32

ELogLevel enumerates standard levels of logging 

const (
	ELogLevel_TRACE ELogLevel = 0
	ELogLevel_DEBUG ELogLevel = 1
	ELogLevel_INFO  ELogLevel = 2
	ELogLevel_WARN  ELogLevel = 3
	ELogLevel_ERROR ELogLevel = 4
	ELogLevel_FATAL ELogLevel = 5
)

func (ELogLevel) Descriptor 

func (ELogLevel) Descriptor() protoreflect.EnumDescriptor

func (ELogLevel) Enum 

func (x ELogLevel) Enum() *ELogLevel

func (ELogLevel) EnumDescriptor deprecated 

func (ELogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use ELogLevel.Descriptor instead.

func (ELogLevel) Number 

func (x ELogLevel) Number() protoreflect.EnumNumber

func (ELogLevel) String 

func (x ELogLevel) String() string

func (ELogLevel) Type 

func (ELogLevel) Type() protoreflect.EnumType

type TBenchmarkClientParams added in v0.2.21 

type TBenchmarkClientParams struct {

	// number of queries emited per second by benchmark tool
	QueriesPerSecond float32 `protobuf:"fixed32,1,opt,name=queries_per_second,json=queriesPerSecond,proto3" json:"queries_per_second,omitempty"`
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	Duration string `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

TBenchmarkLoadParams contains settings for network client used within benchmarking tool.

func (*TBenchmarkClientParams) Descriptor deprecated added in v0.2.21 

func (*TBenchmarkClientParams) Descriptor() ([]byte, []int)

Deprecated: Use TBenchmarkClientParams.ProtoReflect.Descriptor instead.

func (*TBenchmarkClientParams) GetDuration added in v0.2.21 

func (x *TBenchmarkClientParams) GetDuration() string

func (*TBenchmarkClientParams) GetQueriesPerSecond added in v0.2.21 

func (x *TBenchmarkClientParams) GetQueriesPerSecond() float32

func (*TBenchmarkClientParams) ProtoMessage added in v0.2.21 

func (*TBenchmarkClientParams) ProtoMessage()

func (*TBenchmarkClientParams) ProtoReflect added in v0.2.21 

func (x *TBenchmarkClientParams) ProtoReflect() protoreflect.Message

func (*TBenchmarkClientParams) Reset added in v0.2.21 

func (x *TBenchmarkClientParams) Reset()

func (*TBenchmarkClientParams) String added in v0.2.21 

func (x *TBenchmarkClientParams) String() string

type TBenchmarkConfig added in v0.1.2 

type TBenchmarkConfig struct {

	// We can either connect to remote Connector server
	// or run our own server within the same process.
	//
	// Types that are assignable to Server:
	//
	//	*TBenchmarkConfig_ServerRemote
	//	*TBenchmarkConfig_ServerLocal
	Server isTBenchmarkConfig_Server `protobuf_oneof:"server"`
	// A data source instance from which we'll read the data
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,3,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// A table from which we'll read the data
	Table string `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
	// A list of test cases that will be executed during benchmark session
	TestCases []*TBenchmarkTestCase `protobuf:"bytes,5,rep,name=test_cases,json=testCases,proto3" json:"test_cases,omitempty"`
	// Directory to store benchmark results
	ResultDir string `protobuf:"bytes,6,opt,name=result_dir,json=resultDir,proto3" json:"result_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*TBenchmarkConfig) Descriptor deprecated added in v0.1.2 

func (*TBenchmarkConfig) Descriptor() ([]byte, []int)

Deprecated: Use TBenchmarkConfig.ProtoReflect.Descriptor instead.

func (*TBenchmarkConfig) GetDataSourceInstance added in v0.1.2 

func (x *TBenchmarkConfig) GetDataSourceInstance() *common.TDataSourceInstance

func (*TBenchmarkConfig) GetResultDir added in v0.1.2 

func (x *TBenchmarkConfig) GetResultDir() string

func (*TBenchmarkConfig) GetServer added in v0.1.2 

func (m *TBenchmarkConfig) GetServer() isTBenchmarkConfig_Server

func (*TBenchmarkConfig) GetServerLocal added in v0.1.2 

func (x *TBenchmarkConfig) GetServerLocal() *TServerConfig

func (*TBenchmarkConfig) GetServerRemote added in v0.1.2 

func (x *TBenchmarkConfig) GetServerRemote() *TClientConfig

func (*TBenchmarkConfig) GetTable added in v0.1.2 

func (x *TBenchmarkConfig) GetTable() string

func (*TBenchmarkConfig) GetTestCases added in v0.1.2 

func (x *TBenchmarkConfig) GetTestCases() []*TBenchmarkTestCase

func (*TBenchmarkConfig) ProtoMessage added in v0.1.2 

func (*TBenchmarkConfig) ProtoMessage()

func (*TBenchmarkConfig) ProtoReflect added in v0.1.2 

func (x *TBenchmarkConfig) ProtoReflect() protoreflect.Message

func (*TBenchmarkConfig) Reset added in v0.1.2 

func (x *TBenchmarkConfig) Reset()

func (*TBenchmarkConfig) String added in v0.1.2 

func (x *TBenchmarkConfig) String() string

type TBenchmarkConfig_ServerLocal added in v0.1.2 

type TBenchmarkConfig_ServerLocal struct {
	ServerLocal *TServerConfig `protobuf:"bytes,2,opt,name=server_local,json=serverLocal,proto3,oneof"`
}

type TBenchmarkConfig_ServerRemote added in v0.1.2 

type TBenchmarkConfig_ServerRemote struct {
	ServerRemote *TClientConfig `protobuf:"bytes,1,opt,name=server_remote,json=serverRemote,proto3,oneof"`
}

type TBenchmarkServerParams added in v0.1.2 

type TBenchmarkServerParams struct {
	Paging *TPagingConfig `protobuf:"bytes,1,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

TBenchmarkServerParams contains server config params that will be applied to embedded Connector server at the time of start.

func (*TBenchmarkServerParams) Descriptor deprecated added in v0.1.2 

func (*TBenchmarkServerParams) Descriptor() ([]byte, []int)

Deprecated: Use TBenchmarkServerParams.ProtoReflect.Descriptor instead.

func (*TBenchmarkServerParams) GetPaging added in v0.1.2 

func (x *TBenchmarkServerParams) GetPaging() *TPagingConfig

func (*TBenchmarkServerParams) ProtoMessage added in v0.1.2 

func (*TBenchmarkServerParams) ProtoMessage()

func (*TBenchmarkServerParams) ProtoReflect added in v0.1.2 

func (x *TBenchmarkServerParams) ProtoReflect() protoreflect.Message

func (*TBenchmarkServerParams) Reset added in v0.1.2 

func (x *TBenchmarkServerParams) Reset()

func (*TBenchmarkServerParams) String added in v0.1.2 

func (x *TBenchmarkServerParams) String() string

type TBenchmarkTestCase added in v0.1.2 

type TBenchmarkTestCase struct {

	// Custom server parameters that may change from time to time
	// (applicable only if locally deployed (embedded) server is used).
	ServerParams *TBenchmarkServerParams `protobuf:"bytes,1,opt,name=server_params,json=serverParams,proto3" json:"server_params,omitempty"`
	// Custom parameters for client used within benchmarking tool.
	// If not set, the default behavior is enabled.
	ClientParams *TBenchmarkClientParams `protobuf:"bytes,3,opt,name=client_params,json=clientParams,proto3" json:"client_params,omitempty"`
	// List of columns that will be read from the tables.
	// If empty, all the columns will be read.
	Columns []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*TBenchmarkTestCase) Descriptor deprecated added in v0.1.2 

func (*TBenchmarkTestCase) Descriptor() ([]byte, []int)

Deprecated: Use TBenchmarkTestCase.ProtoReflect.Descriptor instead.

func (*TBenchmarkTestCase) GetClientParams added in v0.2.21 

func (x *TBenchmarkTestCase) GetClientParams() *TBenchmarkClientParams

func (*TBenchmarkTestCase) GetColumns added in v0.1.2 

func (x *TBenchmarkTestCase) GetColumns() []string

func (*TBenchmarkTestCase) GetServerParams added in v0.1.2 

func (x *TBenchmarkTestCase) GetServerParams() *TBenchmarkServerParams

func (*TBenchmarkTestCase) ProtoMessage added in v0.1.2 

func (*TBenchmarkTestCase) ProtoMessage()

func (*TBenchmarkTestCase) ProtoReflect added in v0.1.2 

func (x *TBenchmarkTestCase) ProtoReflect() protoreflect.Message

func (*TBenchmarkTestCase) Reset added in v0.1.2 

func (x *TBenchmarkTestCase) Reset()

func (*TBenchmarkTestCase) String added in v0.1.2 

func (x *TBenchmarkTestCase) String() string

type TClickHouseConfig added in v0.5.4 

type TClickHouseConfig struct {

	// Timeout for ClickHouse connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string `` /* 126-byte string literal not displayed */
	// Timeout for ClickHouse connection pinging.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	PingConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TClickHouseConfig contains settings specific for ClickHouse data source

func (*TClickHouseConfig) Descriptor deprecated added in v0.5.4 

func (*TClickHouseConfig) Descriptor() ([]byte, []int)

Deprecated: Use TClickHouseConfig.ProtoReflect.Descriptor instead.

func (*TClickHouseConfig) GetExponentialBackoff added in v0.5.4 

func (x *TClickHouseConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TClickHouseConfig) GetOpenConnectionTimeout added in v0.5.4 

func (x *TClickHouseConfig) GetOpenConnectionTimeout() string

func (*TClickHouseConfig) GetPingConnectionTimeout added in v0.5.4 

func (x *TClickHouseConfig) GetPingConnectionTimeout() string

func (*TClickHouseConfig) ProtoMessage added in v0.5.4 

func (*TClickHouseConfig) ProtoMessage()

func (*TClickHouseConfig) ProtoReflect added in v0.5.4 

func (x *TClickHouseConfig) ProtoReflect() protoreflect.Message

func (*TClickHouseConfig) Reset added in v0.5.4 

func (x *TClickHouseConfig) Reset()

func (*TClickHouseConfig) String added in v0.5.4 

func (x *TClickHouseConfig) String() string

type TClientConfig added in v0.1.1 

type TClientConfig struct {

	// Connector GRPC API endpoint to connect
	ConnectorServerEndpoint *common.TEndpoint `` /* 132-byte string literal not displayed */
	// TLS credentials for Connector
	Tls *TClientTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// Data source instance we read data from
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,3,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// Solomon metrics endpoint to connect
	MetricsServerEndpoint *common.TEndpoint `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Connector client configuration

func (*TClientConfig) Descriptor deprecated added in v0.1.1 

func (*TClientConfig) Descriptor() ([]byte, []int)

Deprecated: Use TClientConfig.ProtoReflect.Descriptor instead.

func (*TClientConfig) GetConnectorServerEndpoint added in v0.2.13 

func (x *TClientConfig) GetConnectorServerEndpoint() *common.TEndpoint

func (*TClientConfig) GetDataSourceInstance added in v0.1.1 

func (x *TClientConfig) GetDataSourceInstance() *common.TDataSourceInstance

func (*TClientConfig) GetMetricsServerEndpoint added in v0.2.13 

func (x *TClientConfig) GetMetricsServerEndpoint() *common.TEndpoint

func (*TClientConfig) GetTls added in v0.1.1 

func (x *TClientConfig) GetTls() *TClientTLSConfig

func (*TClientConfig) ProtoMessage added in v0.1.1 

func (*TClientConfig) ProtoMessage()

func (*TClientConfig) ProtoReflect added in v0.1.1 

func (x *TClientConfig) ProtoReflect() protoreflect.Message

func (*TClientConfig) Reset added in v0.1.1 

func (x *TClientConfig) Reset()

func (*TClientConfig) String added in v0.1.1 

func (x *TClientConfig) String() string

type TClientTLSConfig added in v0.1.1 

type TClientTLSConfig struct {

	// CA certificate path
	Ca string `protobuf:"bytes,1,opt,name=ca,proto3" json:"ca,omitempty"`
	// Disables certificate host name checking.
	// Should be used carefully only for debugging purposes.
	// See https://pkg.go.dev/crypto/tls#Config for more details.
	InsecureSkipVerify bool `protobuf:"varint,2,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

func (*TClientTLSConfig) Descriptor deprecated added in v0.1.1 

func (*TClientTLSConfig) Descriptor() ([]byte, []int)

Deprecated: Use TClientTLSConfig.ProtoReflect.Descriptor instead.

func (*TClientTLSConfig) GetCa added in v0.1.1 

func (x *TClientTLSConfig) GetCa() string

func (*TClientTLSConfig) GetInsecureSkipVerify added in v0.2.21 

func (x *TClientTLSConfig) GetInsecureSkipVerify() bool

func (*TClientTLSConfig) ProtoMessage added in v0.1.1 

func (*TClientTLSConfig) ProtoMessage()

func (*TClientTLSConfig) ProtoReflect added in v0.1.1 

func (x *TClientTLSConfig) ProtoReflect() protoreflect.Message

func (*TClientTLSConfig) Reset added in v0.1.1 

func (x *TClientTLSConfig) Reset()

func (*TClientTLSConfig) String added in v0.1.1 

func (x *TClientTLSConfig) String() string

type TConnectorServerConfig 

type TConnectorServerConfig struct {

	// Network address server will be listening on
	Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// TLS settings.
	// Leave it empty for insecure connections.
	Tls *TServerTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// Defines maximum GRPC request size
	MaxRecvMessageSize uint64 `protobuf:"varint,3,opt,name=max_recv_message_size,json=maxRecvMessageSize,proto3" json:"max_recv_message_size,omitempty"`
	// contains filtered or unexported fields
}

TConnectorServerConfig - configuration of the main GRPC server

func (*TConnectorServerConfig) Descriptor deprecated 

func (*TConnectorServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TConnectorServerConfig.ProtoReflect.Descriptor instead.

func (*TConnectorServerConfig) GetEndpoint 

func (x *TConnectorServerConfig) GetEndpoint() *common.TEndpoint

func (*TConnectorServerConfig) GetMaxRecvMessageSize added in v0.5.9 

func (x *TConnectorServerConfig) GetMaxRecvMessageSize() uint64

func (*TConnectorServerConfig) GetTls 

func (x *TConnectorServerConfig) GetTls() *TServerTLSConfig

func (*TConnectorServerConfig) ProtoMessage 

func (*TConnectorServerConfig) ProtoMessage()

func (*TConnectorServerConfig) ProtoReflect 

func (x *TConnectorServerConfig) ProtoReflect() protoreflect.Message

func (*TConnectorServerConfig) Reset 

func (x *TConnectorServerConfig) Reset()

func (*TConnectorServerConfig) String 

func (x *TConnectorServerConfig) String() string

type TConversionConfig added in v0.1.2 

type TConversionConfig struct {

	// Enables microoptimized code that can potentially crash the service
	UseUnsafeConverters bool `protobuf:"varint,1,opt,name=use_unsafe_converters,json=useUnsafeConverters,proto3" json:"use_unsafe_converters,omitempty"`
	// contains filtered or unexported fields
}

TConversionConfig configures some aspects of the data conversion process between the data source native type system, Go type system and Arrow type system

func (*TConversionConfig) Descriptor deprecated added in v0.1.2 

func (*TConversionConfig) Descriptor() ([]byte, []int)

Deprecated: Use TConversionConfig.ProtoReflect.Descriptor instead.

func (*TConversionConfig) GetUseUnsafeConverters added in v0.1.2 

func (x *TConversionConfig) GetUseUnsafeConverters() bool

func (*TConversionConfig) ProtoMessage added in v0.1.2 

func (*TConversionConfig) ProtoMessage()

func (*TConversionConfig) ProtoReflect added in v0.1.2 

func (x *TConversionConfig) ProtoReflect() protoreflect.Message

func (*TConversionConfig) Reset added in v0.1.2 

func (x *TConversionConfig) Reset()

func (*TConversionConfig) String added in v0.1.2 

func (x *TConversionConfig) String() string

type TDatasourcesConfig added in v0.2.18 

type TDatasourcesConfig struct {
	Clickhouse  *TClickHouseConfig  `protobuf:"bytes,3,opt,name=clickhouse,proto3" json:"clickhouse,omitempty"`
	Greenplum   *TGreenplumConfig   `protobuf:"bytes,6,opt,name=greenplum,proto3" json:"greenplum,omitempty"`
	MsSqlServer *TMsSQLServerConfig `protobuf:"bytes,4,opt,name=ms_sql_server,json=msSqlServer,proto3" json:"ms_sql_server,omitempty"`
	Mysql       *TMySQLConfig       `protobuf:"bytes,2,opt,name=mysql,proto3" json:"mysql,omitempty"`
	Oracle      *TOracleConfig      `protobuf:"bytes,7,opt,name=oracle,proto3" json:"oracle,omitempty"`
	Postgresql  *TPostgreSQLConfig  `protobuf:"bytes,5,opt,name=postgresql,proto3" json:"postgresql,omitempty"`
	Ydb         *TYdbConfig         `protobuf:"bytes,1,opt,name=ydb,proto3" json:"ydb,omitempty"`
	// contains filtered or unexported fields
}

TDatasouceConfig is a collection of datasource-specific settings

func (*TDatasourcesConfig) Descriptor deprecated added in v0.2.18 

func (*TDatasourcesConfig) Descriptor() ([]byte, []int)

Deprecated: Use TDatasourcesConfig.ProtoReflect.Descriptor instead.

func (*TDatasourcesConfig) GetClickhouse added in v0.5.4 

func (x *TDatasourcesConfig) GetClickhouse() *TClickHouseConfig

func (*TDatasourcesConfig) GetGreenplum added in v0.5.5 

func (x *TDatasourcesConfig) GetGreenplum() *TGreenplumConfig

func (*TDatasourcesConfig) GetMsSqlServer added in v0.5.5 

func (x *TDatasourcesConfig) GetMsSqlServer() *TMsSQLServerConfig

func (*TDatasourcesConfig) GetMysql added in v0.4.0 

func (x *TDatasourcesConfig) GetMysql() *TMySQLConfig

func (*TDatasourcesConfig) GetOracle added in v0.5.5 

func (x *TDatasourcesConfig) GetOracle() *TOracleConfig

func (*TDatasourcesConfig) GetPostgresql added in v0.5.5 

func (x *TDatasourcesConfig) GetPostgresql() *TPostgreSQLConfig

func (*TDatasourcesConfig) GetYdb added in v0.2.18 

func (x *TDatasourcesConfig) GetYdb() *TYdbConfig

func (*TDatasourcesConfig) ProtoMessage added in v0.2.18 

func (*TDatasourcesConfig) ProtoMessage()

func (*TDatasourcesConfig) ProtoReflect added in v0.2.18 

func (x *TDatasourcesConfig) ProtoReflect() protoreflect.Message

func (*TDatasourcesConfig) Reset added in v0.2.18 

func (x *TDatasourcesConfig) Reset()

func (*TDatasourcesConfig) String added in v0.2.18 

func (x *TDatasourcesConfig) String() string

type TExponentialBackoffConfig added in v0.2.21 

type TExponentialBackoffConfig struct {

	// Initial interval between retries
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	InitialInterval string `protobuf:"bytes,1,opt,name=initial_interval,json=initialInterval,proto3" json:"initial_interval,omitempty"`
	// Maximum total time for retries
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	MaxInterval string `protobuf:"bytes,2,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`
	// Randomization factor to add jitter to intervals
	RandomizationFactor float64 `protobuf:"fixed64,3,opt,name=randomization_factor,json=randomizationFactor,proto3" json:"randomization_factor,omitempty"`
	// Multiplier for increasing the interval after each retry
	Multiplier float64 `protobuf:"fixed64,4,opt,name=multiplier,proto3" json:"multiplier,omitempty"`
	// Maximum interval between retries
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	MaxElapsedTime string `protobuf:"bytes,5,opt,name=max_elapsed_time,json=maxElapsedTime,proto3" json:"max_elapsed_time,omitempty"`
	// contains filtered or unexported fields
}

TExponentialBackoffConfig provides configuration for the exponential backoff which is used for retries of the operations ended up with transient errors.

func (*TExponentialBackoffConfig) Descriptor deprecated added in v0.2.21 

func (*TExponentialBackoffConfig) Descriptor() ([]byte, []int)

Deprecated: Use TExponentialBackoffConfig.ProtoReflect.Descriptor instead.

func (*TExponentialBackoffConfig) GetInitialInterval added in v0.2.21 

func (x *TExponentialBackoffConfig) GetInitialInterval() string

func (*TExponentialBackoffConfig) GetMaxElapsedTime added in v0.2.21 

func (x *TExponentialBackoffConfig) GetMaxElapsedTime() string

func (*TExponentialBackoffConfig) GetMaxInterval added in v0.2.21 

func (x *TExponentialBackoffConfig) GetMaxInterval() string

func (*TExponentialBackoffConfig) GetMultiplier added in v0.2.21 

func (x *TExponentialBackoffConfig) GetMultiplier() float64

func (*TExponentialBackoffConfig) GetRandomizationFactor added in v0.2.21 

func (x *TExponentialBackoffConfig) GetRandomizationFactor() float64

func (*TExponentialBackoffConfig) ProtoMessage added in v0.2.21 

func (*TExponentialBackoffConfig) ProtoMessage()

func (*TExponentialBackoffConfig) ProtoReflect added in v0.2.21 

func (x *TExponentialBackoffConfig) ProtoReflect() protoreflect.Message

func (*TExponentialBackoffConfig) Reset added in v0.2.21 

func (x *TExponentialBackoffConfig) Reset()

func (*TExponentialBackoffConfig) String added in v0.2.21 

func (x *TExponentialBackoffConfig) String() string

type TGreenplumConfig added in v0.5.5 

type TGreenplumConfig struct {

	// Timeout for Greenplum connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TGreenplumConfig contains settings specific for Greenplum data source

func (*TGreenplumConfig) Descriptor deprecated added in v0.5.5 

func (*TGreenplumConfig) Descriptor() ([]byte, []int)

Deprecated: Use TGreenplumConfig.ProtoReflect.Descriptor instead.

func (*TGreenplumConfig) GetExponentialBackoff added in v0.5.5 

func (x *TGreenplumConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TGreenplumConfig) GetOpenConnectionTimeout added in v0.5.5 

func (x *TGreenplumConfig) GetOpenConnectionTimeout() string

func (*TGreenplumConfig) ProtoMessage added in v0.5.5 

func (*TGreenplumConfig) ProtoMessage()

func (*TGreenplumConfig) ProtoReflect added in v0.5.5 

func (x *TGreenplumConfig) ProtoReflect() protoreflect.Message

func (*TGreenplumConfig) Reset added in v0.5.5 

func (x *TGreenplumConfig) Reset()

func (*TGreenplumConfig) String added in v0.5.5 

func (x *TGreenplumConfig) String() string

type TLoggerConfig 

type TLoggerConfig struct {

	// Level of logging
	LogLevel ELogLevel `` /* 127-byte string literal not displayed */
	// Is logging of queries enabled
	EnableSqlQueryLogging bool `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

TLogger represents logger configuration

func (*TLoggerConfig) Descriptor deprecated 

func (*TLoggerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TLoggerConfig.ProtoReflect.Descriptor instead.

func (*TLoggerConfig) GetEnableSqlQueryLogging 

func (x *TLoggerConfig) GetEnableSqlQueryLogging() bool

func (*TLoggerConfig) GetLogLevel 

func (x *TLoggerConfig) GetLogLevel() ELogLevel

func (*TLoggerConfig) ProtoMessage 

func (*TLoggerConfig) ProtoMessage()

func (*TLoggerConfig) ProtoReflect 

func (x *TLoggerConfig) ProtoReflect() protoreflect.Message

func (*TLoggerConfig) Reset 

func (x *TLoggerConfig) Reset()

func (*TLoggerConfig) String 

func (x *TLoggerConfig) String() string

type TMetricsServerConfig 

type TMetricsServerConfig struct {

	// Network address server will be listening on
	Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// TLS settings.
	// Leave it empty for insecure connections.
	Tls *TServerTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

TMetricsConfig - configuration of the metrics service

func (*TMetricsServerConfig) Descriptor deprecated 

func (*TMetricsServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TMetricsServerConfig.ProtoReflect.Descriptor instead.

func (*TMetricsServerConfig) GetEndpoint 

func (x *TMetricsServerConfig) GetEndpoint() *common.TEndpoint

func (*TMetricsServerConfig) GetTls 

func (x *TMetricsServerConfig) GetTls() *TServerTLSConfig

func (*TMetricsServerConfig) ProtoMessage 

func (*TMetricsServerConfig) ProtoMessage()

func (*TMetricsServerConfig) ProtoReflect 

func (x *TMetricsServerConfig) ProtoReflect() protoreflect.Message

func (*TMetricsServerConfig) Reset 

func (x *TMetricsServerConfig) Reset()

func (*TMetricsServerConfig) String 

func (x *TMetricsServerConfig) String() string

type TMsSQLServerConfig added in v0.5.5 

type TMsSQLServerConfig struct {

	// Timeout for ClickHouse connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string `` /* 126-byte string literal not displayed */
	// Timeout for MsSQLServer connection pinging.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	PingConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TMsSQLServerConfig contains settings specific for MsSQLServer data source

func (*TMsSQLServerConfig) Descriptor deprecated added in v0.5.5 

func (*TMsSQLServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TMsSQLServerConfig.ProtoReflect.Descriptor instead.

func (*TMsSQLServerConfig) GetExponentialBackoff added in v0.5.5 

func (x *TMsSQLServerConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TMsSQLServerConfig) GetOpenConnectionTimeout added in v0.5.6 

func (x *TMsSQLServerConfig) GetOpenConnectionTimeout() string

func (*TMsSQLServerConfig) GetPingConnectionTimeout added in v0.5.5 

func (x *TMsSQLServerConfig) GetPingConnectionTimeout() string

func (*TMsSQLServerConfig) ProtoMessage added in v0.5.5 

func (*TMsSQLServerConfig) ProtoMessage()

func (*TMsSQLServerConfig) ProtoReflect added in v0.5.5 

func (x *TMsSQLServerConfig) ProtoReflect() protoreflect.Message

func (*TMsSQLServerConfig) Reset added in v0.5.5 

func (x *TMsSQLServerConfig) Reset()

func (*TMsSQLServerConfig) String added in v0.5.5 

func (x *TMsSQLServerConfig) String() string

type TMySQLConfig added in v0.4.0 

type TMySQLConfig struct {
	ResultChanCapacity uint64 `protobuf:"varint,1,opt,name=result_chan_capacity,json=resultChanCapacity,proto3" json:"result_chan_capacity,omitempty"`
	// Timeout for MySQL connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

func (*TMySQLConfig) Descriptor deprecated added in v0.4.0 

func (*TMySQLConfig) Descriptor() ([]byte, []int)

Deprecated: Use TMySQLConfig.ProtoReflect.Descriptor instead.

func (*TMySQLConfig) GetExponentialBackoff added in v0.5.5 

func (x *TMySQLConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TMySQLConfig) GetOpenConnectionTimeout added in v0.5.5 

func (x *TMySQLConfig) GetOpenConnectionTimeout() string

func (*TMySQLConfig) GetResultChanCapacity added in v0.4.0 

func (x *TMySQLConfig) GetResultChanCapacity() uint64

func (*TMySQLConfig) ProtoMessage added in v0.4.0 

func (*TMySQLConfig) ProtoMessage()

func (*TMySQLConfig) ProtoReflect added in v0.4.0 

func (x *TMySQLConfig) ProtoReflect() protoreflect.Message

func (*TMySQLConfig) Reset added in v0.4.0 

func (x *TMySQLConfig) Reset()

func (*TMySQLConfig) String added in v0.4.0 

func (x *TMySQLConfig) String() string

type TOracleConfig added in v0.5.5 

type TOracleConfig struct {

	// Timeout for Oracle connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string `` /* 126-byte string literal not displayed */
	// Timeout for Oracle connection pinging.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	PingConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TOracleConfig contains settings specific for Oracle data source

func (*TOracleConfig) Descriptor deprecated added in v0.5.5 

func (*TOracleConfig) Descriptor() ([]byte, []int)

Deprecated: Use TOracleConfig.ProtoReflect.Descriptor instead.

func (*TOracleConfig) GetExponentialBackoff added in v0.5.5 

func (x *TOracleConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TOracleConfig) GetOpenConnectionTimeout added in v0.5.5 

func (x *TOracleConfig) GetOpenConnectionTimeout() string

func (*TOracleConfig) GetPingConnectionTimeout added in v0.5.5 

func (x *TOracleConfig) GetPingConnectionTimeout() string

func (*TOracleConfig) ProtoMessage added in v0.5.5 

func (*TOracleConfig) ProtoMessage()

func (*TOracleConfig) ProtoReflect added in v0.5.5 

func (x *TOracleConfig) ProtoReflect() protoreflect.Message

func (*TOracleConfig) Reset added in v0.5.5 

func (x *TOracleConfig) Reset()

func (*TOracleConfig) String added in v0.5.5 

func (x *TOracleConfig) String() string

type TPagingConfig 

type TPagingConfig struct {

	// Configures the limit of a page size in rows.
	// It may override other limits. Ignored if set to zero.
	RowsPerPage uint64 `protobuf:"varint,1,opt,name=rows_per_page,json=rowsPerPage,proto3" json:"rows_per_page,omitempty"`
	// Configures the limit of a page size in bytes.
	// It may override other limits. Ignored if set to zero.
	BytesPerPage uint64 `protobuf:"varint,2,opt,name=bytes_per_page,json=bytesPerPage,proto3" json:"bytes_per_page,omitempty"`
	// Connector service can read ahead some data from the data source before returning it to the client.
	// This setting configures the number of pages that may reside in the service's address space
	// waiting for the client readiness for the data consumption.
	// Tune this carefully cause this may cause service OOMs.
	PrefetchQueueCapacity uint32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

TPagingConfig configures the way of splitting of the data stream into the fragments (or pages) in order to return them as separate GRPC messages to the client.

func (*TPagingConfig) Descriptor deprecated 

func (*TPagingConfig) Descriptor() ([]byte, []int)

Deprecated: Use TPagingConfig.ProtoReflect.Descriptor instead.

func (*TPagingConfig) GetBytesPerPage 

func (x *TPagingConfig) GetBytesPerPage() uint64

func (*TPagingConfig) GetPrefetchQueueCapacity 

func (x *TPagingConfig) GetPrefetchQueueCapacity() uint32

func (*TPagingConfig) GetRowsPerPage 

func (x *TPagingConfig) GetRowsPerPage() uint64

func (*TPagingConfig) ProtoMessage 

func (*TPagingConfig) ProtoMessage()

func (*TPagingConfig) ProtoReflect 

func (x *TPagingConfig) ProtoReflect() protoreflect.Message

func (*TPagingConfig) Reset 

func (x *TPagingConfig) Reset()

func (*TPagingConfig) String 

func (x *TPagingConfig) String() string

type TPostgreSQLConfig added in v0.5.5 

type TPostgreSQLConfig struct {

	// Timeout for PostgreSQL connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string                     `` /* 126-byte string literal not displayed */
	ExponentialBackoff    *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TPostgreSQLConfig contains settings specific for PostgreSQL data source

func (*TPostgreSQLConfig) Descriptor deprecated added in v0.5.5 

func (*TPostgreSQLConfig) Descriptor() ([]byte, []int)

Deprecated: Use TPostgreSQLConfig.ProtoReflect.Descriptor instead.

func (*TPostgreSQLConfig) GetExponentialBackoff added in v0.5.5 

func (x *TPostgreSQLConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TPostgreSQLConfig) GetOpenConnectionTimeout added in v0.5.5 

func (x *TPostgreSQLConfig) GetOpenConnectionTimeout() string

func (*TPostgreSQLConfig) ProtoMessage added in v0.5.5 

func (*TPostgreSQLConfig) ProtoMessage()

func (*TPostgreSQLConfig) ProtoReflect added in v0.5.5 

func (x *TPostgreSQLConfig) ProtoReflect() protoreflect.Message

func (*TPostgreSQLConfig) Reset added in v0.5.5 

func (x *TPostgreSQLConfig) Reset()

func (*TPostgreSQLConfig) String added in v0.5.5 

func (x *TPostgreSQLConfig) String() string

type TPprofServerConfig 

type TPprofServerConfig struct {

	// Network address server will be listening on
	Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// TLS settings.
	// Leave it empty for insecure connections.
	Tls *TServerTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

TPprofServerConfig configures HTTP server delivering Go runtime profiler data

func (*TPprofServerConfig) Descriptor deprecated 

func (*TPprofServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TPprofServerConfig.ProtoReflect.Descriptor instead.

func (*TPprofServerConfig) GetEndpoint 

func (x *TPprofServerConfig) GetEndpoint() *common.TEndpoint

func (*TPprofServerConfig) GetTls 

func (x *TPprofServerConfig) GetTls() *TServerTLSConfig

func (*TPprofServerConfig) ProtoMessage 

func (*TPprofServerConfig) ProtoMessage()

func (*TPprofServerConfig) ProtoReflect 

func (x *TPprofServerConfig) ProtoReflect() protoreflect.Message

func (*TPprofServerConfig) Reset 

func (x *TPprofServerConfig) Reset()

func (*TPprofServerConfig) String 

func (x *TPprofServerConfig) String() string

type TServerConfig 

type TServerConfig struct {

	// Deprecated: Marked as deprecated in app/config/server.proto.
	Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Deprecated: Marked as deprecated in app/config/server.proto.
	Tls *TServerTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// TConnectorServerConfig contains configuration of the main GRPC server
	ConnectorServer *TConnectorServerConfig `protobuf:"bytes,5,opt,name=connector_server,json=connectorServer,proto3" json:"connector_server,omitempty"`
	// This is a rough restriction for YQ memory consumption until
	// https://st.yandex-team.ru/YQ-2057 is implemented.
	// Leave it empty if you want to avoid any memory limits.
	ReadLimit *TServerReadLimit `protobuf:"bytes,3,opt,name=read_limit,json=readLimit,proto3" json:"read_limit,omitempty"`
	// Logger config
	Logger *TLoggerConfig `protobuf:"bytes,4,opt,name=logger,proto3" json:"logger,omitempty"`
	// Go runtime profiler.
	// Disabled if this part of config is empty.
	PprofServer *TPprofServerConfig `protobuf:"bytes,6,opt,name=pprof_server,json=pprofServer,proto3" json:"pprof_server,omitempty"`
	// Metrics server config
	MetricsServer *TMetricsServerConfig `protobuf:"bytes,7,opt,name=metrics_server,json=metricsServer,proto3" json:"metrics_server,omitempty"`
	// Paging config
	Paging *TPagingConfig `protobuf:"bytes,8,opt,name=paging,proto3" json:"paging,omitempty"`
	// Data types conversion config
	Conversion *TConversionConfig `protobuf:"bytes,9,opt,name=conversion,proto3" json:"conversion,omitempty"`
	// Datasource-specific config
	Datasources *TDatasourcesConfig `protobuf:"bytes,10,opt,name=datasources,proto3" json:"datasources,omitempty"`
	// contains filtered or unexported fields
}

Connector server configuration

func (*TServerConfig) Descriptor deprecated 

func (*TServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use TServerConfig.ProtoReflect.Descriptor instead.

func (*TServerConfig) GetConnectorServer 

func (x *TServerConfig) GetConnectorServer() *TConnectorServerConfig

func (*TServerConfig) GetConversion added in v0.1.2 

func (x *TServerConfig) GetConversion() *TConversionConfig

func (*TServerConfig) GetDatasources added in v0.2.18 

func (x *TServerConfig) GetDatasources() *TDatasourcesConfig

func (*TServerConfig) GetEndpoint deprecated 

func (x *TServerConfig) GetEndpoint() *common.TEndpoint

Deprecated: Marked as deprecated in app/config/server.proto.

func (*TServerConfig) GetLogger 

func (x *TServerConfig) GetLogger() *TLoggerConfig

func (*TServerConfig) GetMetricsServer 

func (x *TServerConfig) GetMetricsServer() *TMetricsServerConfig

func (*TServerConfig) GetPaging 

func (x *TServerConfig) GetPaging() *TPagingConfig

func (*TServerConfig) GetPprofServer 

func (x *TServerConfig) GetPprofServer() *TPprofServerConfig

func (*TServerConfig) GetReadLimit 

func (x *TServerConfig) GetReadLimit() *TServerReadLimit

func (*TServerConfig) GetTls deprecated 

func (x *TServerConfig) GetTls() *TServerTLSConfig

Deprecated: Marked as deprecated in app/config/server.proto.

func (*TServerConfig) ProtoMessage 

func (*TServerConfig) ProtoMessage()

func (*TServerConfig) ProtoReflect 

func (x *TServerConfig) ProtoReflect() protoreflect.Message

func (*TServerConfig) Reset 

func (x *TServerConfig) Reset()

func (*TServerConfig) String 

func (x *TServerConfig) String() string

type TServerReadLimit 

type TServerReadLimit struct {

	// The number of rows extracted from the data source
	Rows uint64 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

ServerReadLimit limitates the amount of data extracted from the data source on every read request.

func (*TServerReadLimit) Descriptor deprecated 

func (*TServerReadLimit) Descriptor() ([]byte, []int)

Deprecated: Use TServerReadLimit.ProtoReflect.Descriptor instead.

func (*TServerReadLimit) GetRows 

func (x *TServerReadLimit) GetRows() uint64

func (*TServerReadLimit) ProtoMessage 

func (*TServerReadLimit) ProtoMessage()

func (*TServerReadLimit) ProtoReflect 

func (x *TServerReadLimit) ProtoReflect() protoreflect.Message

func (*TServerReadLimit) Reset 

func (x *TServerReadLimit) Reset()

func (*TServerReadLimit) String 

func (x *TServerReadLimit) String() string

type TServerTLSConfig 

type TServerTLSConfig struct {

	// TLS private key path
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// TLS public cert path
	Cert string `protobuf:"bytes,3,opt,name=cert,proto3" json:"cert,omitempty"`
	// contains filtered or unexported fields
}

func (*TServerTLSConfig) Descriptor deprecated 

func (*TServerTLSConfig) Descriptor() ([]byte, []int)

Deprecated: Use TServerTLSConfig.ProtoReflect.Descriptor instead.

func (*TServerTLSConfig) GetCert 

func (x *TServerTLSConfig) GetCert() string

func (*TServerTLSConfig) GetKey 

func (x *TServerTLSConfig) GetKey() string

func (*TServerTLSConfig) ProtoMessage 

func (*TServerTLSConfig) ProtoMessage()

func (*TServerTLSConfig) ProtoReflect 

func (x *TServerTLSConfig) ProtoReflect() protoreflect.Message

func (*TServerTLSConfig) Reset 

func (x *TServerTLSConfig) Reset()

func (*TServerTLSConfig) String 

func (x *TServerTLSConfig) String() string

type TYdbConfig added in v0.2.18 

type TYdbConfig struct {

	// Timeout for YDB connection opening.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	OpenConnectionTimeout string `` /* 126-byte string literal not displayed */
	// Timeout for YDB connection pinging.
	// Valid values should satisfy `time.ParseDuration` (e. g. '5s', '100ms', '3h').
	PingConnectionTimeout string `` /* 126-byte string literal not displayed */
	// Flag forcing the usage of underlay networks for dedicated YDB databases
	UseUnderlayNetworkForDedicatedDatabases bool                       `` /* 187-byte string literal not displayed */
	ExponentialBackoff                      *TExponentialBackoffConfig `protobuf:"bytes,10,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

TYdbConfig contains settings specific for YDB data source

func (*TYdbConfig) Descriptor deprecated added in v0.2.18 

func (*TYdbConfig) Descriptor() ([]byte, []int)

Deprecated: Use TYdbConfig.ProtoReflect.Descriptor instead.

func (*TYdbConfig) GetExponentialBackoff added in v0.2.21 

func (x *TYdbConfig) GetExponentialBackoff() *TExponentialBackoffConfig

func (*TYdbConfig) GetOpenConnectionTimeout added in v0.2.18 

func (x *TYdbConfig) GetOpenConnectionTimeout() string

func (*TYdbConfig) GetPingConnectionTimeout added in v0.2.18 

func (x *TYdbConfig) GetPingConnectionTimeout() string

func (*TYdbConfig) GetUseUnderlayNetworkForDedicatedDatabases added in v0.3.1 

func (x *TYdbConfig) GetUseUnderlayNetworkForDedicatedDatabases() bool

func (*TYdbConfig) ProtoMessage added in v0.2.18 

func (*TYdbConfig) ProtoMessage()

func (*TYdbConfig) ProtoReflect added in v0.2.18 

func (x *TYdbConfig) ProtoReflect() protoreflect.Message

func (*TYdbConfig) Reset added in v0.2.18 

func (x *TYdbConfig) Reset()

func (*TYdbConfig) String added in v0.2.18 

func (x *TYdbConfig) String() string

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.