diff --git a/USERS.md b/USERS.md index bd0a937960..abc622978a 100644 --- a/USERS.md +++ b/USERS.md @@ -27,6 +27,7 @@ Organizations below are **officially** using Argo Events. Please send a PR with 1. [iFood](https://www.ifood.com.br) 1. [InsideBoard](https://www.insideboard.com) 1. [Intuit](https://www.intuit.com/) +1. [FikaWorks](https://fika.works/) 1. [Loam](https://www.getloam.com/) 1. [Mobimeo GmbH](https://mobimeo.com/en/home/) 1. [OneCause](https://www.onecause.com/) diff --git a/controllers/eventbus/installer/jetstream.go b/controllers/eventbus/installer/jetstream.go index b9ead295d6..3849afd8ae 100644 --- a/controllers/eventbus/installer/jetstream.go +++ b/controllers/eventbus/installer/jetstream.go @@ -196,7 +196,7 @@ func (r *jetStreamInstaller) createStatefulSet(ctx context.Context) error { ObjectMeta: metav1.ObjectMeta{ Namespace: r.eventBus.Namespace, Name: generateJetStreamStatefulSetName(r.eventBus), - Labels: r.labels, + Labels: r.mergeEventBusLabels(r.labels), Annotations: map[string]string{ common.AnnotationResourceSpecHash: hash, }, @@ -752,6 +752,19 @@ func generateJetStreamServerSecretName(eventBus *v1alpha1.EventBus) string { return fmt.Sprintf("eventbus-%s-js-server", eventBus.Name) } +func (r *jetStreamInstaller) mergeEventBusLabels(given map[string]string) map[string]string { + result := map[string]string{} + if r.eventBus.Labels != nil { + for k, v := range r.eventBus.Labels { + result[k] = v + } + } + for k, v := range given { + result[k] = v + } + return result +} + func generateJetStreamClientAuthSecretName(eventBus *v1alpha1.EventBus) string { return fmt.Sprintf("eventbus-%s-js-client-auth", eventBus.Name) }