Eventstore optional field in CRD

triggermesh · Sep 4, 2021 · 8674be5 · 8674be5
1 parent b51adc6
commit 8674be5
Show file tree

Hide file tree

Showing 6 changed files with 37 additions and 2 deletions.
diff --git a/config/300-function.yaml b/config/300-function.yaml
@@ -63,6 +63,12 @@ spec:
             responseMode:
               description: 'Whether function responds with CE payload only or with full event.'
               type: string
+            eventStore:
+              type: object
+              description: 'EventStore service connection string.'
+              properties:
+                uri:
+                  type: string
             ceOverrides:
               type: object
               description: "Defines overrides to control modifications of the event attributes."

diff --git a/config/controller.yaml b/config/controller.yaml
@@ -56,7 +56,7 @@ spec:
           value: triggermesh.io/routing
 
         - name: RUNTIME_KLR_PYTHON
-          value: gcr.io/triggermesh/knative-lambda-python37:v1.8.1
+          value: gcr.io/triggermesh/knative-lambda-python37:v1.9.1
         - name: RUNTIME_KLR_NODE
           value: gcr.io/triggermesh/knative-lambda-node10:v1.8.1
         - name: RUNTIME_KLR_RUBY

diff --git a/pkg/apis/function/v1alpha1/deepcopy_generated.go b/pkg/apis/function/v1alpha1/deepcopy_generated.go
diff --git a/pkg/apis/function/v1alpha1/function_types.go b/pkg/apis/function/v1alpha1/function_types.go
@@ -56,10 +56,18 @@ type FunctionSpec struct {
 	Public              bool                        `json:"public,omitempty"`
 	Code                string                      `json:"code"`
 	ResponseMode        string                      `json:"responseMode,omitempty"`
+	EventStore          EventStoreConnection        `json:"eventStore,omitempty"`
 	CloudEventOverrides *duckv1.CloudEventOverrides `json:"ceOverrides"`
 	Sink                *duckv1.Destination         `json:"sink"`
 }
 
+// EventStoreConnection contains the data to connect to
+// an EventStore instance
+type EventStoreConnection struct {
+	// URI is the gRPC location to the EventStore
+	URI string `json:"uri"`
+}
+
 // FunctionStatus communicates the observed state of the Function (from the controller).
 type FunctionStatus struct {
 	duckv1.SourceStatus `json:",inline"`

diff --git a/pkg/reconciler/function/controller.go b/pkg/reconciler/function/controller.go
@@ -38,7 +38,10 @@ import (
 	functionreconciler "github.com/triggermesh/function/pkg/client/generated/injection/reconciler/function/v1alpha1/function"
 )
 
-const runtimeEnvPrefix = "RUNTIME_"
+const (
+	eventStoreEnv    = "EVENTSTORE_URI"
+	runtimeEnvPrefix = "RUNTIME_"
+)
 
 // New creates a Reconciler and returns the result of NewImpl.
 func NewController(

diff --git a/pkg/reconciler/function/function.go b/pkg/reconciler/function/function.go
@@ -221,6 +221,7 @@ func (r *Reconciler) reconcileKnService(ctx context.Context, f *functionv1alpha1
 		resources.KnSvcImage(image),
 		resources.KnSvcMountCm(cm.Name, filename),
 		resources.KnSvcEntrypoint(klrEntrypoint),
+		resources.KnSvcEnvVar(eventStoreEnv, f.Spec.EventStore.URI),
 		resources.KnSvcEnvVar("K_SINK", sink.String()),
 		resources.KnSvcEnvVar("_HANDLER", handler),
 		resources.KnSvcEnvVar("RESPONSE_FORMAT", "CLOUDEVENTS"),