- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewDynamicTransformers (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go
) if err != nil { t.Fatalf("failed to load encryption config: %v", err) } d := NewDynamicEncryptionConfiguration( "test-controller", "does not matter", encryptionconfig.NewDynamicTransformers( encryptionConfiguration.Transformers, encryptionConfiguration.HealthChecks[0], closeTransformers, 0, // set grace period to 0 so that the time.Sleep in DynamicTransformers.Set finishes quickly
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
} // Here the dynamic transformers take ownership of the transformers and their cancellation. dynamicTransformers := encryptionconfig.NewDynamicTransformers(encryptionConfiguration.Transformers, encryptionConfiguration.HealthChecks[0], closeTransformers, encryptionConfiguration.KMSCloseGracePeriod) // add post start hook to start hot reload controller
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
kmsPluginHealthzCheck healthz.HealthChecker closeTransformers context.CancelFunc kmsCloseGracePeriod time.Duration } // NewDynamicTransformers returns transformers, health checks for kms providers and an ability to close transformers. func NewDynamicTransformers( transformerOverrides map[schema.GroupResource]storagevalue.Transformer, kmsPluginHealthzCheck healthz.HealthChecker, closeTransformers context.CancelFunc,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0)