wiring up controller and CRD

Author: odacremolbap

README.md

@@ -16,7 +16,8 @@ ko apply -f ./config
 
 ## Usage
 
-- [Getting Started](docs/getting-started.md).
+- [Getting Started (Redis Broker)](docs/getting-started-redis.md).
+- [Getting Started (Memory Broker)](docs/getting-started-memory.md).
 - [Broker Observability](docs/observable-broker.md).
 
 ## Contributing

cmd/core-controller/main.go

@@ -3,12 +3,14 @@ package main
 import (
 	"knative.dev/pkg/injection/sharedmain"
 
+	"github.com/triggermesh/triggermesh-core/pkg/reconciler/memorybroker"
 	"github.com/triggermesh/triggermesh-core/pkg/reconciler/redisbroker"
 	"github.com/triggermesh/triggermesh-core/pkg/reconciler/trigger"
 )
 
 func main() {
 	sharedmain.Main("core-controller",
+		memorybroker.NewController,
 		redisbroker.NewController,
 		trigger.NewController,
 	)

config/200-clusterroles.yaml

@@ -57,6 +57,7 @@ rules:
 - apiGroups:
   - eventing.triggermesh.io
   resources:
+  - memorybrokers
   - redisbrokers
   - triggers
   verbs:
@@ -67,6 +68,7 @@ rules:
 - apiGroups:
   - eventing.triggermesh.io
   resources:
+  - memorybrokers/status
   - redisbrokers/status
   - triggers/status
   verbs:
@@ -78,6 +80,7 @@ rules:
 - apiGroups:
   - eventing.triggermesh.io
   resources:
+  - memorybrokers/finalizers
   - redisbrokers/finalizers
   - triggers/finalizers
   verbs:
@@ -87,6 +90,7 @@ rules:
 - apiGroups:
   - eventing.triggermesh.io
   resources:
+  - memorybrokers
   - redisbrokers
   - triggers
   verbs:

config/200-triggermesh-core-addressable-resolvers.yaml

@@ -13,6 +13,7 @@ rules:
 - apiGroups:
   - eventing.triggermesh.io
   resources:
+  - memorybrokers
   - redisbrokers
   verbs:
   - get

config/300-memorybroker.yaml

@@ -0,0 +1,130 @@
+# Copyright 2022 TriggerMesh Inc.
+# SPDX-License-Identifier: Apache-2.0
+
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  name: memorybrokers.eventing.triggermesh.io
+  labels:
+    triggermesh.io/crd-install: 'true'
+spec:
+  group: eventing.triggermesh.io
+  scope: Namespaced
+  names:
+    kind: MemoryBroker
+    listKind: MemoryBrokerList
+    plural: memorybrokers
+    singular: memorybroker
+    categories:
+    - all
+    - triggermesh
+    - brokers
+
+  versions:
+  - name: v1alpha1
+    served: true
+    storage: true
+    subresources:
+      status: {}
+    schema:
+      openAPIV3Schema:
+        description: MemoryBroker is the Schema for the memorybrokers API
+        type: object
+        properties:
+          apiVersion:
+            description: 'APIVersion defines the versioned schema of this representation
+              of an object. Servers should convert recognized schemas to the latest
+              internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources'
+            type: string
+          kind:
+            description: 'Kind is a string value representing the REST resource this
+              object represents. Servers may infer this from the endpoint the client
+              submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+            type: string
+          metadata:
+            type: object
+          spec:
+            description: MemoryBrokerSpec defines the desired state of MemoryBroker
+            type: object
+            properties:
+              memory:
+                description: Memory options.
+                type: object
+                properties:
+                  bufferSize:
+                    description: Maximum number of elements to buffer.
+                    type: integer
+              broker:
+                description: Broker options.
+                type: object
+                properties:
+                  port:
+                    description: Broker HTTP port.
+                    type: integer
+                  observability:
+                    description: Observability parameters for the Broker.
+                    type: object
+                    properties:
+                      valueFromConfigMap:
+                        description: ConfigMap that contains the observability parameters.
+                        type: string
+                    required:
+                    - valueFromConfigMap
+
+          status:
+            description: Status represents the current state of the Broker. This data may be out of date.
+            type: object
+            properties:
+              address:
+                description: Broker is Addressable. It exposes the endpoint as an URI to get events delivered into the Broker mesh.
+                type: object
+                properties:
+                  url:
+                    type: string
+              conditions:
+                description: Conditions the latest available observations of a resource's current state.
+                type: array
+                items:
+                  type: object
+                  required:
+                    - type
+                    - status
+                  properties:
+                    lastTransitionTime:
+                      description: 'LastTransitionTime is the last time the condition transitioned from one status to another. We use VolatileTime in place of metav1.Time to exclude this from creating equality.Semantic differences (all other things held constant).'
+                      type: string
+                    message:
+                      description: 'A human readable message indicating details about the transition.'
+                      type: string
+                    reason:
+                      description: 'The reason for the condition''s last transition.'
+                      type: string
+                    severity:
+                      description: 'Severity with which to treat failures of this type of condition. When this is not specified, it defaults to Error.'
+                      type: string
+                    status:
+                      description: 'Status of the condition, one of True, False, Unknown.'
+                      type: string
+                    type:
+                      description: 'Type of condition.'
+                      type: string
+              observedGeneration:
+                description: ObservedGeneration is the 'Generation' of the Service that was last processed by the controller.
+                type: integer
+                format: int64
+    additionalPrinterColumns:
+    - name: URL
+      type: string
+      jsonPath: .status.address.url
+    - name: Age
+      type: date
+      jsonPath: .metadata.creationTimestamp
+    - name: Ready
+      type: string
+      jsonPath: .status.conditions[?(@.type=='Ready')].status
+    - name: Reason
+      type: string
+      jsonPath: .status.conditions[?(@.type=='Ready')].reason
+
+
+

config/500-core-controller.yaml

@@ -66,6 +66,8 @@ spec:
         - name: METRICS_DOMAIN
           value: triggermesh.io
         # Deployment images
+        - name: MEMORYBROKER_BROKER_IMAGE
+          value: gcr.io/triggermesh/memory-broker:dev
         - name: REDISBROKER_REDIS_IMAGE
           value: redis/redis-stack-server:latest
         - name: REDISBROKER_BROKER_IMAGE

docs/assets/manifests/getting-started-memory/broker.yaml

@@ -0,0 +1,4 @@
+apiVersion: eventing.triggermesh.io/v1alpha1
+kind: MemoryBroker
+metadata:
+  name: demo

docs/assets/manifests/getting-started-memory/trigger.yaml

@@ -0,0 +1,27 @@
+apiVersion: eventing.triggermesh.io/v1alpha1
+kind: Trigger
+metadata:
+  name: mdemo
+spec:
+  broker:
+    kind: MemoryBroker
+    group: eventing.triggermesh.io
+    name: demo
+  filters:
+  - any:
+    - exact:
+        type: demo.type1
+  target:
+    ref:
+      apiVersion: v1
+      kind: Service
+      name: display-target
+
+  delivery:
+    retry: 3
+    deadLetterSink:
+      ref:
+        kind: Service
+        apiVersion: v1
+        name: display-deadlettersink
+

docs/assets/manifests/getting-started/broker.yaml renamed to docs/assets/manifests/getting-started-redis/broker.yaml

@@ -1,7 +1,7 @@
 apiVersion: eventing.triggermesh.io/v1alpha1
 kind: Trigger
 metadata:
-  name: demo
+  name: rdemo
 spec:
   broker:
     kind: RedisBroker