Rename certsManagerController to certsCreatorController

This commit is contained in:
Joshua Casey
2024-12-03 12:20:45 -06:00
committed by Joshua Casey
parent 8ea393e3de
commit cfb51b3337
5 changed files with 11 additions and 11 deletions
@@ -146,7 +146,7 @@ func PrepareControllers(c *Config) (controllerinit.RunnerBuilder, error) { //nol
// API certs controllers are responsible for managing the TLS certificates used to serve Pinniped's API.
WithController(
apicerts.NewCertsManagerController(
apicerts.NewCertsCreatorController(
c.ServerInstallationInfo.Namespace,
c.NamesConfig.ServingCertificateSecret,
c.Labels,
@@ -300,7 +300,7 @@ func PrepareControllers(c *Config) (controllerinit.RunnerBuilder, error) { //nol
singletonWorker,
).
WithController(
apicerts.NewCertsManagerController(
apicerts.NewCertsCreatorController(
c.ServerInstallationInfo.Namespace,
c.NamesConfig.ImpersonationSignerSecret,
c.Labels,
@@ -26,7 +26,7 @@ const (
TLSCertificateChainSecretKey = "tlsCertificateChain"
)
type certsManagerController struct {
type certsCreatorController struct {
namespace string
certsSecretResourceName string
certsSecretLabels map[string]string
@@ -41,7 +41,7 @@ type certsManagerController struct {
serviceNameForGeneratedCertCommonName string
}
func NewCertsManagerController(
func NewCertsCreatorController(
namespace string,
certsSecretResourceName string,
certsSecretLabels map[string]string,
@@ -56,7 +56,7 @@ func NewCertsManagerController(
return controllerlib.New(
controllerlib.Config{
Name: "certs-manager-controller",
Syncer: &certsManagerController{
Syncer: &certsCreatorController{
namespace: namespace,
certsSecretResourceName: certsSecretResourceName,
certsSecretLabels: certsSecretLabels,
@@ -80,7 +80,7 @@ func NewCertsManagerController(
)
}
func (c *certsManagerController) Sync(ctx controllerlib.Context) error {
func (c *certsCreatorController) Sync(ctx controllerlib.Context) error {
// Try to get the secret from the informer cache.
_, err := c.secretInformer.Lister().Secrets(c.namespace).Get(c.certsSecretResourceName)
notFound := apierrors.IsNotFound(err)
@@ -140,6 +140,6 @@ func (c *certsManagerController) Sync(ctx controllerlib.Context) error {
return fmt.Errorf("could not create secret: %w", err)
}
plog.Info("certsManagerController Sync successfully created secret")
plog.Info("certsCreatorController Sync successfully created secret")
return nil
}
@@ -39,7 +39,7 @@ func TestManagerControllerOptions(t *testing.T) {
observableWithInformerOption = testutil.NewObservableWithInformerOption()
observableWithInitialEventOption = testutil.NewObservableWithInitialEventOption()
secretsInformer := k8sinformers.NewSharedInformerFactory(nil, 0).Core().V1().Secrets()
_ = NewCertsManagerController(
_ = NewCertsCreatorController(
installedInNamespace,
certsSecretResourceName,
make(map[string]string),
@@ -134,7 +134,7 @@ func TestManagerControllerSync(t *testing.T) {
// nested Before's can keep adding things to the informer caches.
var startInformersAndController = func(serviceName string) {
// Set this at the last second to allow for injection of server override.
subject = NewCertsManagerController(
subject = NewCertsCreatorController(
installedInNamespace,
certsSecretResourceName,
map[string]string{
@@ -293,7 +293,7 @@ func startControllers(
controllerManager := controllerlib.
NewManager().
WithController(
apicerts.NewCertsManagerController(
apicerts.NewCertsCreatorController(
namespace,
certsSecretResourceName,
map[string]string{
+1 -1
View File
@@ -349,7 +349,7 @@ func prepareControllers(
),
singletonWorker).
WithController(
apicerts.NewCertsManagerController(
apicerts.NewCertsCreatorController(
podInfo.Namespace,
certificateName,
cfg.Labels,