diff --git a/internal/configuration/settings.go b/internal/configuration/settings.go index aa5b614..e0eeaf1 100644 --- a/internal/configuration/settings.go +++ b/internal/configuration/settings.go @@ -20,6 +20,7 @@ import ( const ( ConfigMapsNamespace = "nkl" ResyncPeriod = 0 + NklPrefix = ConfigMapsNamespace + "-" ) type WorkQueueSettings struct { diff --git a/internal/translation/translator.go b/internal/translation/translator.go index d37b161..17650f4 100644 --- a/internal/translation/translator.go +++ b/internal/translation/translator.go @@ -6,6 +6,7 @@ package translation import ( "fmt" + "github.com/nginxinc/kubernetes-nginx-ingress/internal/configuration" "github.com/nginxinc/kubernetes-nginx-ingress/internal/core" nginxClient "github.com/nginxinc/nginx-plus-go-client/client" "github.com/sirupsen/logrus" @@ -13,8 +14,6 @@ import ( "strings" ) -const NklPrefix = "nkl-" - func Translate(event *core.Event) (core.ServerUpdateEvents, error) { logrus.Debug("Translate::Translate") @@ -27,7 +26,7 @@ func filterPorts(ports []v1.ServicePort) []v1.ServicePort { var portsOfInterest []v1.ServicePort for _, port := range ports { - if strings.HasPrefix(port.Name, NklPrefix) { + if strings.HasPrefix(port.Name, configuration.NklPrefix) { portsOfInterest = append(portsOfInterest, port) } } diff --git a/internal/translation/translation_test.go b/internal/translation/translator_test.go similarity index 99% rename from internal/translation/translation_test.go rename to internal/translation/translator_test.go index a37163e..8e3d709 100644 --- a/internal/translation/translation_test.go +++ b/internal/translation/translator_test.go @@ -6,6 +6,7 @@ package translation import ( "fmt" + "github.com/nginxinc/kubernetes-nginx-ingress/internal/configuration" "github.com/nginxinc/kubernetes-nginx-ingress/internal/core" v1 "k8s.io/api/core/v1" "math/rand" @@ -653,7 +654,7 @@ func generateUpdatablePorts(portCount int, updatableCount int) []v1.ServicePort nonupdatable := make([]string, portCount-updatableCount) for i := range updatable { - updatable[i] = NklPrefix + updatable[i] = configuration.NklPrefix } for j := range nonupdatable {