Documentation ¶
Index ¶
- Variables
- type ELogLevel
- type TBenchmarkConfig
- func (*TBenchmarkConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TBenchmarkConfig) GetDataSourceInstance() *common.TDataSourceInstance
- func (x *TBenchmarkConfig) GetResultDir() string
- func (m *TBenchmarkConfig) GetServer() isTBenchmarkConfig_Server
- func (x *TBenchmarkConfig) GetServerLocal() *TServerConfig
- func (x *TBenchmarkConfig) GetServerRemote() *common.TEndpoint
- func (x *TBenchmarkConfig) GetTable() string
- func (x *TBenchmarkConfig) GetTestCases() []*TBenchmarkTestCase
- func (*TBenchmarkConfig) ProtoMessage()
- func (x *TBenchmarkConfig) ProtoReflect() protoreflect.Message
- func (x *TBenchmarkConfig) Reset()
- func (x *TBenchmarkConfig) String() string
- type TBenchmarkConfig_ServerLocal
- type TBenchmarkConfig_ServerRemote
- type TBenchmarkServerParams
- func (*TBenchmarkServerParams) Descriptor() ([]byte, []int)deprecated
- func (x *TBenchmarkServerParams) GetPaging() *TPagingConfig
- func (*TBenchmarkServerParams) ProtoMessage()
- func (x *TBenchmarkServerParams) ProtoReflect() protoreflect.Message
- func (x *TBenchmarkServerParams) Reset()
- func (x *TBenchmarkServerParams) String() string
- type TBenchmarkTestCase
- func (*TBenchmarkTestCase) Descriptor() ([]byte, []int)deprecated
- func (x *TBenchmarkTestCase) GetColumns() []string
- func (x *TBenchmarkTestCase) GetServerParams() *TBenchmarkServerParams
- func (*TBenchmarkTestCase) ProtoMessage()
- func (x *TBenchmarkTestCase) ProtoReflect() protoreflect.Message
- func (x *TBenchmarkTestCase) Reset()
- func (x *TBenchmarkTestCase) String() string
- type TClientConfig
- func (*TClientConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TClientConfig) GetDataSourceInstance() *common.TDataSourceInstance
- func (x *TClientConfig) GetEndpoint() *common.TEndpoint
- func (x *TClientConfig) GetTls() *TClientTLSConfig
- func (*TClientConfig) ProtoMessage()
- func (x *TClientConfig) ProtoReflect() protoreflect.Message
- func (x *TClientConfig) Reset()
- func (x *TClientConfig) String() string
- type TClientTLSConfig
- type TConnectorServerConfig
- func (*TConnectorServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TConnectorServerConfig) GetEndpoint() *common.TEndpoint
- func (x *TConnectorServerConfig) GetTls() *TServerTLSConfig
- func (*TConnectorServerConfig) ProtoMessage()
- func (x *TConnectorServerConfig) ProtoReflect() protoreflect.Message
- func (x *TConnectorServerConfig) Reset()
- func (x *TConnectorServerConfig) String() string
- type TConversionConfig
- func (*TConversionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TConversionConfig) GetUseUnsafeConverters() bool
- func (*TConversionConfig) ProtoMessage()
- func (x *TConversionConfig) ProtoReflect() protoreflect.Message
- func (x *TConversionConfig) Reset()
- func (x *TConversionConfig) String() string
- type TLoggerConfig
- func (*TLoggerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TLoggerConfig) GetEnableSqlQueryLogging() bool
- func (x *TLoggerConfig) GetLogLevel() ELogLevel
- func (*TLoggerConfig) ProtoMessage()
- func (x *TLoggerConfig) ProtoReflect() protoreflect.Message
- func (x *TLoggerConfig) Reset()
- func (x *TLoggerConfig) String() string
- type TMetricsServerConfig
- func (*TMetricsServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TMetricsServerConfig) GetEndpoint() *common.TEndpoint
- func (x *TMetricsServerConfig) GetTls() *TServerTLSConfig
- func (*TMetricsServerConfig) ProtoMessage()
- func (x *TMetricsServerConfig) ProtoReflect() protoreflect.Message
- func (x *TMetricsServerConfig) Reset()
- func (x *TMetricsServerConfig) String() string
- type TPagingConfig
- func (*TPagingConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TPagingConfig) GetBytesPerPage() uint64
- func (x *TPagingConfig) GetPrefetchQueueCapacity() uint32
- func (x *TPagingConfig) GetRowsPerPage() uint64
- func (*TPagingConfig) ProtoMessage()
- func (x *TPagingConfig) ProtoReflect() protoreflect.Message
- func (x *TPagingConfig) Reset()
- func (x *TPagingConfig) String() string
- type TPprofServerConfig
- func (*TPprofServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TPprofServerConfig) GetEndpoint() *common.TEndpoint
- func (x *TPprofServerConfig) GetTls() *TServerTLSConfig
- func (*TPprofServerConfig) ProtoMessage()
- func (x *TPprofServerConfig) ProtoReflect() protoreflect.Message
- func (x *TPprofServerConfig) Reset()
- func (x *TPprofServerConfig) String() string
- type TServerConfig
- func (*TServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TServerConfig) GetConnectorServer() *TConnectorServerConfig
- func (x *TServerConfig) GetConversion() *TConversionConfig
- func (x *TServerConfig) GetEndpoint() *common.TEndpointdeprecated
- func (x *TServerConfig) GetLogger() *TLoggerConfig
- func (x *TServerConfig) GetMetricsServer() *TMetricsServerConfig
- func (x *TServerConfig) GetPaging() *TPagingConfig
- func (x *TServerConfig) GetPprofServer() *TPprofServerConfig
- func (x *TServerConfig) GetReadLimit() *TServerReadLimit
- func (x *TServerConfig) GetTls() *TServerTLSConfigdeprecated
- func (*TServerConfig) ProtoMessage()
- func (x *TServerConfig) ProtoReflect() protoreflect.Message
- func (x *TServerConfig) Reset()
- func (x *TServerConfig) String() string
- type TServerReadLimit
- type TServerTLSConfig
- func (*TServerTLSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TServerTLSConfig) GetCert() string
- func (x *TServerTLSConfig) GetKey() string
- func (*TServerTLSConfig) ProtoMessage()
- func (x *TServerTLSConfig) ProtoReflect() protoreflect.Message
- func (x *TServerTLSConfig) Reset()
- func (x *TServerTLSConfig) String() string
Constants ¶
This section is empty.
Variables ¶
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.
var File_app_config_bench_proto protoreflect.FileDescriptor
var File_app_config_client_proto protoreflect.FileDescriptor
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
func (ELogLevel) Descriptor ¶
func (ELogLevel) Descriptor() protoreflect.EnumDescriptor
func (ELogLevel) EnumDescriptor
deprecated
func (ELogLevel) Number ¶
func (x ELogLevel) Number() protoreflect.EnumNumber
func (ELogLevel) Type ¶
func (ELogLevel) Type() protoreflect.EnumType
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() *common.TEndpoint
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 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 we'll be applied to built-in server during 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 vary ServerParams *TBenchmarkServerParams `protobuf:"bytes,1,opt,name=server_params,json=serverParams,proto3" json:"server_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) 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 TClientConfig ¶ added in v0.1.1
type TClientConfig struct { // Connector service instance network address we connect to Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 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"` // 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) GetDataSourceInstance ¶ added in v0.1.1
func (x *TClientConfig) GetDataSourceInstance() *common.TDataSourceInstance
func (*TClientConfig) GetEndpoint ¶ added in v0.1.1
func (x *TClientConfig) GetEndpoint() *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"` // 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) 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"` // 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) 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 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 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 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 { // TODO: remove it after YQ-2057 // // Deprecated: Do not use. Endpoint *common.TEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // Deprecated: Do not use. Tls *TServerTLSConfig `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` 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"` // 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) GetEndpoint
deprecated
func (x *TServerConfig) GetEndpoint() *common.TEndpoint
Deprecated: Do not use.
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: Do not use.
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