From 16e12bf17a2c629eecdf53dc114a7b5f62eb82fc Mon Sep 17 00:00:00 2001 From: Tapajit Chandra Paul Date: Fri, 5 Jul 2024 17:13:57 +0600 Subject: [PATCH] Fix druid for pg Signed-off-by: Tapajit Chandra Paul --- apis/kubedb/constants.go | 2 ++ apis/kubedb/v1alpha2/druid_helpers.go | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/apis/kubedb/constants.go b/apis/kubedb/constants.go index 0cf0853f91..78a28e5774 100644 --- a/apis/kubedb/constants.go +++ b/apis/kubedb/constants.go @@ -978,6 +978,8 @@ const ( DruidPortRouters = 8888 DruidExporterPort = 9104 + DruidMetadataStorageTypePostgres = "Postgres" + // Common Runtime Configurations Properties // ZooKeeper DruidZKServiceHost = "druid.zk.service.host" diff --git a/apis/kubedb/v1alpha2/druid_helpers.go b/apis/kubedb/v1alpha2/druid_helpers.go index e35ec814b0..46eae241dc 100644 --- a/apis/kubedb/v1alpha2/druid_helpers.go +++ b/apis/kubedb/v1alpha2/druid_helpers.go @@ -316,7 +316,8 @@ func (d *Druid) AddDruidExtensionLoadList(druidExtensionLoadList string, extensi func (d *Druid) GetMetadataStorageType(metadataStorage string) DruidMetadataStorageType { if metadataStorage == string(DruidMetadataStorageMySQL) || metadataStorage == strings.ToLower(string(DruidMetadataStorageMySQL)) { return DruidMetadataStorageMySQL - } else if metadataStorage == string(DruidMetadataStoragePostgreSQL) || metadataStorage == strings.ToLower(string(DruidMetadataStoragePostgreSQL)) { + } else if metadataStorage == string(DruidMetadataStoragePostgreSQL) || metadataStorage == strings.ToLower(string(DruidMetadataStoragePostgreSQL)) || + metadataStorage == kubedb.DruidMetadataStorageTypePostgres || metadataStorage == strings.ToLower(string(kubedb.DruidMetadataStorageTypePostgres)) { return DruidMetadataStoragePostgreSQL } else { panic(fmt.Sprintf("Unknown metadata storage type: %s", metadataStorage))