diff options
author | vitalyisaev <vitalyisaev@ydb.tech> | 2023-11-24 15:04:29 +0300 |
---|---|---|
committer | vitalyisaev <vitalyisaev@ydb.tech> | 2023-11-24 16:08:53 +0300 |
commit | 407cda542d4c3b5048e8a342d4bf4db7ed560ff7 (patch) | |
tree | d3c645e5dc047f1537758c90612e663a018573a9 | |
parent | 2bb1b2fb5d0028e709fb516f0c88c3a66ba6a457 (diff) | |
download | ydb-407cda542d4c3b5048e8a342d4bf4db7ed560ff7.tar.gz |
YQ Connector: make paging config section optional
-rw-r--r-- | ydb/library/yql/providers/generic/connector/app/server/config.go | 11 |
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) } |