diff --git a/clients/config_client/config_client.go b/clients/config_client/config_client.go index 54ee973e..42531947 100644 --- a/clients/config_client/config_client.go +++ b/clients/config_client/config_client.go @@ -131,6 +131,8 @@ func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error) { } if clientConfig.OpenKMS { + filter.RegisterDefaultConfigEncryptionFilter() + nacos_inner_encryption.RegisterConfigEncryptionKmsPlugins() var kmsClient *nacos_inner_encryption.KmsClient switch clientConfig.KMSVersion { case constant.KMSv1, constant.DEFAULT_KMS_VERSION: diff --git a/common/encryption/kms_plugins.go b/common/encryption/kms_plugins.go index c8402964..1d3b7b5a 100644 --- a/common/encryption/kms_plugins.go +++ b/common/encryption/kms_plugins.go @@ -22,7 +22,7 @@ import ( "strings" ) -func init() { +func RegisterConfigEncryptionKmsPlugins() { if err := GetDefaultHandler().RegisterPlugin(&KmsAes128Plugin{}); err != nil { logger.Errorf("failed to register encryption plugin[%s] to defaultHandler", KmsAes128AlgorithmName) } else { diff --git a/common/filter/config_filter.go b/common/filter/config_filter.go index a220b6f3..97a3379d 100644 --- a/common/filter/config_filter.go +++ b/common/filter/config_filter.go @@ -41,7 +41,7 @@ type IConfigFilter interface { GetFilterName() string } -func init() { +func RegisterDefaultConfigEncryptionFilter() { err := RegisterConfigFilter(GetDefaultConfigFilterChainManager(), GetDefaultConfigEncryptionFilter()) if err != nil { logger.Errorf("failed to register configFilter[%s] to DefaultConfigFilterChainManager",