feat: Adding support for token authentication in Pulsar EventSource (#…

…1359) Signed-off-by: Arnar Gauti Ingason <[email protected]>
argoproj · Sep 24, 2021 · 42fe43e · 42fe43e
1 parent 10321c7
commit 42fe43e
Show file tree

Hide file tree

Showing 9 changed files with 475 additions and 363 deletions.
diff --git a/api/event-source.html b/api/event-source.html
diff --git a/api/event-source.md b/api/event-source.md
diff --git a/api/openapi-spec/swagger.json b/api/openapi-spec/swagger.json
diff --git a/eventsources/sources/pulsar/start.go b/eventsources/sources/pulsar/start.go
@@ -97,6 +97,15 @@ func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byt
 		TLSValidateHostname:        pulsarEventSource.TLSValidateHostname,
 	}
 
+	if pulsarEventSource.AuthTokenSecret != nil {
+		token, err := common.GetSecretFromVolume(pulsarEventSource.AuthTokenSecret)
+		if err != nil {
+			log.Errorw("failed to get AuthTokenSecret from the volume", "error", err)
+			return err
+		}
+		clientOpt.Authentication = pulsar.NewAuthenticationToken(token)
+	}
+
 	if pulsarEventSource.TLS != nil {
 		log.Info("setting tls auth option...")
 		var clientCertPath, clientKeyPath string

diff --git a/pkg/apis/eventsource/v1alpha1/generated.pb.go b/pkg/apis/eventsource/v1alpha1/generated.pb.go
diff --git a/pkg/apis/eventsource/v1alpha1/generated.proto b/pkg/apis/eventsource/v1alpha1/generated.proto
diff --git a/pkg/apis/eventsource/v1alpha1/openapi_generated.go b/pkg/apis/eventsource/v1alpha1/openapi_generated.go
diff --git a/pkg/apis/eventsource/v1alpha1/types.go b/pkg/apis/eventsource/v1alpha1/types.go
@@ -1024,6 +1024,9 @@ type PulsarEventSource struct {
 	// Metadata holds the user defined metadata which will passed along the event payload.
 	// +optional
 	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,10,rep,name=metadata"`
+	// Authentication token for the pulsar client.
+	// +optional
+	AuthTokenSecret *corev1.SecretKeySelector `json:"authTokenSecret,omitempty" protobuf:"bytes,11,opt,name=authTokenSecret"`
 }
 
 // GenericEventSource refers to a generic event source. It can be used to implement a custom event source.

diff --git a/pkg/apis/eventsource/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/eventsource/v1alpha1/zz_generated.deepcopy.go