aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvitalyisaev <vitalyisaev@ydb.tech>2023-11-24 15:04:29 +0300
committervitalyisaev <vitalyisaev@ydb.tech>2023-11-24 16:08:53 +0300
commit407cda542d4c3b5048e8a342d4bf4db7ed560ff7 (patch)
treed3c645e5dc047f1537758c90612e663a018573a9
parent2bb1b2fb5d0028e709fb516f0c88c3a66ba6a457 (diff)
downloadydb-407cda542d4c3b5048e8a342d4bf4db7ed560ff7.tar.gz
YQ Connector: make paging config section optional
-rw-r--r--ydb/library/yql/providers/generic/connector/app/server/config.go11
1 files changed, 11 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/generic/connector/app/server/config.go b/ydb/library/yql/providers/generic/connector/app/server/config.go
index 165bf8c3a48..098dba87473 100644
--- a/ydb/library/yql/providers/generic/connector/app/server/config.go
+++ b/ydb/library/yql/providers/generic/connector/app/server/config.go
@@ -10,6 +10,15 @@ import (
"google.golang.org/protobuf/encoding/prototext"
)
+func fillServerConfigDefaults(c *config.TServerConfig) {
+ if c.Paging == nil {
+ c.Paging = &config.TPagingConfig{
+ BytesPerPage: 4 * 1024 * 1024,
+ PrefetchQueueCapacity: 2,
+ }
+ }
+}
+
func validateServerConfig(c *config.TServerConfig) error {
if err := validateConnectorServerConfig(c.ConnectorServer); err != nil {
return fmt.Errorf("validate `connector_server`: %w", err)
@@ -159,6 +168,8 @@ func newConfigFromPath(configPath string) (*config.TServerConfig, error) {
return nil, fmt.Errorf("prototext unmarshal `%v`: %w", string(data), err)
}
+ fillServerConfigDefaults(&cfg)
+
if err := validateServerConfig(&cfg); err != nil {
return nil, fmt.Errorf("validate config: %w", err)
}