mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-05 02:09:56 +00:00
Merge pull request #120365 from aramase/aramase/c/kms_scheme_cleanup
register API types only once for encryption config
This commit is contained in:
commit
10d257889d
@ -104,6 +104,15 @@ const (
|
|||||||
kmsReloadHealthCheckName = "kms-providers"
|
kmsReloadHealthCheckName = "kms-providers"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var codecs serializer.CodecFactory
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
configScheme := runtime.NewScheme()
|
||||||
|
utilruntime.Must(apiserverconfig.AddToScheme(configScheme))
|
||||||
|
utilruntime.Must(apiserverconfigv1.AddToScheme(configScheme))
|
||||||
|
codecs = serializer.NewCodecFactory(configScheme)
|
||||||
|
}
|
||||||
|
|
||||||
type kmsPluginHealthzResponse struct {
|
type kmsPluginHealthzResponse struct {
|
||||||
err error
|
err error
|
||||||
received time.Time
|
received time.Time
|
||||||
@ -475,11 +484,6 @@ func loadConfig(filepath string, reload bool) (*apiserverconfig.EncryptionConfig
|
|||||||
return nil, "", fmt.Errorf("encryption provider configuration file %q is empty", filepath)
|
return nil, "", fmt.Errorf("encryption provider configuration file %q is empty", filepath)
|
||||||
}
|
}
|
||||||
|
|
||||||
scheme := runtime.NewScheme()
|
|
||||||
codecs := serializer.NewCodecFactory(scheme)
|
|
||||||
utilruntime.Must(apiserverconfig.AddToScheme(scheme))
|
|
||||||
utilruntime.Must(apiserverconfigv1.AddToScheme(scheme))
|
|
||||||
|
|
||||||
configObj, gvk, err := codecs.UniversalDecoder().Decode(data, nil, nil)
|
configObj, gvk, err := codecs.UniversalDecoder().Decode(data, nil, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, "", fmt.Errorf("error decoding encryption provider configuration file %q: %w", filepath, err)
|
return nil, "", fmt.Errorf("error decoding encryption provider configuration file %q: %w", filepath, err)
|
||||||
|
Loading…
Reference in New Issue
Block a user