knative
/
docs
mirror of https://github.com/knative/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Issue 1977 (#1979) 

* update samples to use flow, update cron to use v1.Destination as sink

* parallel examples to flows, fix some missing pieces

* add pointer to where the functions live
This commit is contained in:
Ville Aikas 2019-11-12 17:37:23 +02:00 committed by Knative Prow Robot
parent a8a1032de0
commit 6178ad5361
27 changed files with 214 additions and 127 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
docs/eventing/README.md
View File

@ -82,6 +82,15 @@ be persisted using Apache Kafka or NATS Streaming.
See the [List of Channel implementations](../eventing/channels/channels.yaml).
### Higher Level eventing constructs
There are cases where you may want to utilize a set of co-operating functions
together and for those use cases, Knative Eventing provides two additional
resources:
1. **[Sequence](./sequence.md)** provides a way to define an in-order list of functions.
1. **[Parallel](./parallel.md)** provides a way to define a list of branches for events.
### Future design goals
The focus for the next Eventing release will be to enable easy implementation of

4
docs/eventing/samples/parallel/README.md
View File

@ -6,8 +6,8 @@ various flows.
All examples require:
- A Kubernetes cluster with
- Knative Eventing v0.9+
- Knative Service v0.8+
- Knative Eventing v0.11+
- Knative Serving v0.8+
All examples are using the
[default channel template](../../channels/default-channels.md).

37
docs/eventing/samples/parallel/multiple-branches/README.md
View File

@ -78,12 +78,33 @@ spec:
kubectl create -f ./filters.yaml -f ./transformers.yaml
```
### Create the Service displaying the events created by Sequence
```yaml
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
name: event-display
spec:
template:
spec:
containers:
- image: gcr.io/knative-releases/github.com/knative/eventing-sources/cmd/event_display
```
Change `default` below to create the `Sequence` in the Namespace where you want
your resources to be created.
```shell
kubectl -n default create -f ./event-display.yaml
```
### Create the Parallel
The `parallel.yaml` file contains the specifications for creating the Parallel.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
metadata:
name: odd-even-parallel
@ -113,9 +134,10 @@ spec:
kind: Service
name: odd-transformer
reply:
apiVersion: serving.knative.dev/v1
kind: Service
name: event-display
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: event-display
```
```shell
@ -136,9 +158,10 @@ spec:
schedule: "*/1 * * * *"
data: '{"message": "Even or odd?"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Parallel
name: odd-even-parallel
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
name: odd-even-parallel
```
```shell

7
docs/eventing/samples/parallel/multiple-branches/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/1 * * * *"
data: '{"message": "Even or odd?"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Parallel
name: odd-even-parallel
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
name: odd-even-parallel

9
docs/eventing/samples/parallel/multiple-branches/parallel.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
metadata:
name: odd-even-parallel
@ -28,6 +28,7 @@ spec:
kind: Service
name: odd-transformer
reply:
apiVersion: serving.knative.dev/v1
kind: Service
name: event-display
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: event-display

39
docs/eventing/samples/parallel/mutual-exclusivity/README.md
View File

@ -2,7 +2,7 @@ In this example, we are going to see how we can create a Parallel with mutually
exclusive branches.
This example is the same as the
[multiple barnaches example](../multiple-branches/README.md) except that we are now
[multiple branches example](../multiple-branches/README.md) except that we are now
going to rely on the Knative
[switch](https://github.com/lionelvillard/knative-functions#switch) function
to provide a soft mutual exclusivity guarantee.
@ -69,12 +69,33 @@ spec:
kubectl create -f ./switcher.yaml -f ./transformers.yaml
```
### Create the Service displaying the events created by Sequence
```yaml
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
name: event-display
spec:
template:
spec:
containers:
- image: gcr.io/knative-releases/github.com/knative/eventing-sources/cmd/event_display
```
Change `default` below to create the `Sequence` in the Namespace where you want
your resources to be created.
```shell
kubectl -n default create -f ./event-display.yaml
```
### Create the Parallel object
The `parallel.yaml` file contains the specifications for creating the Parallel object.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
metadata:
name: me-odd-even-parallel
@ -98,9 +119,10 @@ spec:
kind: Service
name: me-odd-transformer
reply:
apiVersion: serving.knative.dev/v1
kind: Service
name: me-event-display
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: me-event-display
```
```shell
@ -121,9 +143,10 @@ spec:
schedule: "*/1 * * * *"
data: '{"message": "Even or odd?"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Parallel
name: me-odd-even-parallel
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
name: me-odd-even-parallel
```
```shell

7
docs/eventing/samples/parallel/mutual-exclusivity/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/1 * * * *"
data: '{"message": "Even or odd?"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Parallel
name: me-odd-even-parallel
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
name: me-odd-even-parallel

9
docs/eventing/samples/parallel/mutual-exclusivity/parallel.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Parallel
metadata:
name: me-odd-even-parallel
@ -22,6 +22,7 @@ spec:
kind: Service
name: me-odd-transformer
reply:
apiVersion: serving.knative.dev/v1
kind: Service
name: me-event-display
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: me-event-display

25
docs/eventing/samples/sequence/sequence-reply-to-event-display/README.md
View File

@ -11,6 +11,9 @@ taking the output of that `Sequence` and displaying the resulting output.
![Logical Configuration](./sequence-reply-to-event-display.png)
The functions used in these examples live in
(https://github.com/vaikas/transformer)[https://github.com/vaikas/transformer]
## Prerequisites
For this example, we'll assume you have set up an `InMemoryChannel` as well as
@ -37,7 +40,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -51,7 +54,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -64,7 +67,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"
@ -83,7 +86,7 @@ If you are using a different type of Channel, you need to change the
spec.channelTemplate to point to your desired Channel.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence
@ -105,9 +108,10 @@ spec:
kind: Service
name: third
reply:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
ref:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
```
Change `default` below to create the `Sequence` in the Namespace where you want
@ -152,9 +156,10 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence
```
```shell

7
docs/eventing/samples/sequence/sequence-reply-to-event-display/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence

9
docs/eventing/samples/sequence/sequence-reply-to-event-display/sequence.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence
@ -20,6 +20,7 @@ spec:
kind: Service
name: third
reply:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
ref:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display

6
docs/eventing/samples/sequence/sequence-reply-to-event-display/steps.yaml
View File

@ -6,7 +6,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -20,7 +20,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -33,7 +33,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"

40
docs/eventing/samples/sequence/sequence-reply-to-sequence/README.md
View File

@ -12,6 +12,9 @@ finally displaying the resulting output.
![Logical Configuration](./sequence-reply-to-sequence.png)
The functions used in these examples live in
(https://github.com/vaikas/transformer)[https://github.com/vaikas/transformer]
## Prerequisites
For this example, we'll assume you have set up a an `InMemoryChannel` as well as
@ -38,7 +41,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -52,7 +55,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -65,7 +68,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"
@ -78,7 +81,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "3"
@ -92,7 +95,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "4"
@ -105,7 +108,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "5"
@ -124,7 +127,7 @@ If you are using a different type of Channel, you need to change the
spec.channelTemplate to point to your desired Channel.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: first-sequence
@ -146,9 +149,10 @@ spec:
kind: Service
name: third
reply:
kind: Sequence
apiVersion: messaging.knative.dev/v1alpha1
name: second-sequence
ref:
kind: Sequence
apiVersion: flows.knative.dev/v1alpha1
name: second-sequence
```
Change `default` below to create the `Sequence` in the Namespace where you want
@ -165,7 +169,7 @@ If you are using a different type of Channel, you need to change the
spec.channelTemplate to point to your desired Channel.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: second-sequence
@ -187,9 +191,10 @@ spec:
kind: Service
name: sixth
reply:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
ref:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
```
### Create the Service displaying the events created by Sequence
@ -227,9 +232,10 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: first-sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: first-sequence
```
```shell

7
docs/eventing/samples/sequence/sequence-reply-to-sequence/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: first-sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: first-sequence

9
docs/eventing/samples/sequence/sequence-reply-to-sequence/sequence1.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: first-sequence
@ -20,6 +20,7 @@ spec:
kind: Service
name: third
reply:
kind: Sequence
apiVersion: messaging.knative.dev/v1alpha1
name: second-sequence
ref:
kind: Sequence
apiVersion: flows.knative.dev/v1alpha1
name: second-sequence

9
docs/eventing/samples/sequence/sequence-reply-to-sequence/sequence2.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: second-sequence
@ -20,6 +20,7 @@ spec:
kind: Service
name: sixth
reply:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display
ref:
kind: Service
apiVersion: serving.knative.dev/v1
name: event-display

12
docs/eventing/samples/sequence/sequence-reply-to-sequence/steps.yaml
View File

@ -6,7 +6,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -20,7 +20,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -33,7 +33,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"
@ -47,7 +47,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "3"
@ -60,7 +60,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "4"
@ -73,7 +73,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "5"

24
docs/eventing/samples/sequence/sequence-terminal/README.md
View File

@ -11,6 +11,9 @@ can then do either external work, or out of band create additional events.
![Logical Configuration](./sequence-terminal.png)
The functions used in these examples live in
(https://github.com/vaikas/transformer)[https://github.com/vaikas/transformer]
## Prerequisites
For this example, we'll assume you have set up an `InMemoryChannel` as well as
@ -36,7 +39,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -50,7 +53,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -63,7 +66,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"
@ -82,7 +85,7 @@ If you are using a different type of Channel, you need to change the
spec.channelTemplate to point to your desired Channel.
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence
@ -126,9 +129,10 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence
```
Here, if you are using different type of Channel, you need to change the
@ -151,7 +155,7 @@ kubectl -n default get pods
Let's look at the logs for the first `Step` in the `Sequence`:
```shell
kubectl -n default logs -l serving.knative.dev/service=first -c user-container
kubectl -n default logs --tail=50 -l serving.knative.dev/service=first -c user-container
Got Event Context: Context Attributes,
specversion: 0.2
type: dev.knative.cronjob.event
@ -186,7 +190,7 @@ Got Transport Context: Transport Context,
Then we can look at the output of the second Step in the `Sequence`:
```shell
kubectl -n default logs -l serving.knative.dev/service=second -c user-container
kubectl -n default logs --tail=50 -l serving.knative.dev/service=second -c user-container
Got Event Context: Context Attributes,
cloudEventsVersion: 0.1
eventType: samples.http.mod3
@ -222,7 +226,7 @@ Exciting :)
Then we can look at the output of the last Step in the `Sequence`:
```shell
kubectl -n default logs -l serving.knative.dev/service=third -c user-container
kubectl -n default logs --tail=50 -l serving.knative.dev/service=third -c user-container
Got Event Context: Context Attributes,
cloudEventsVersion: 0.1
eventType: samples.http.mod3

7
docs/eventing/samples/sequence/sequence-terminal/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
name: sequence
ref:
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence

2
docs/eventing/samples/sequence/sequence-terminal/sequence.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence

6
docs/eventing/samples/sequence/sequence-terminal/steps.yaml
View File

@ -6,7 +6,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -20,7 +20,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -33,7 +33,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"

29
docs/eventing/samples/sequence/sequence-with-broker-trigger/README.md
View File

@ -23,6 +23,9 @@ If you want to use different type of `Channel`, you will have to modify the
![Logical Configuration](./sequence-with-broker-trigger.png)
The functions used in these examples live in
(https://github.com/vaikas/transformer)[https://github.com/vaikas/transformer]
## Setup
### Create the Knative Services
@ -39,7 +42,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -53,7 +56,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -66,7 +69,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"
@ -88,7 +91,7 @@ spec.channelTemplate to point to your desired Channel.
Also, change the spec.reply.name to point to your `Broker`
```yaml
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence
@ -110,9 +113,10 @@ spec:
kind: Service
name: third
reply:
kind: Broker
apiVersion: eventing.knative.dev/v1alpha1
name: broker-test
ref:
kind: Broker
apiVersion: eventing.knative.dev/v1alpha1
name: default
```
Change `default` below to create the `Sequence` in the Namespace where you have
@ -136,9 +140,10 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
name: broker-test
ref:
apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
name: default
```
Here, if you are using different type of Channel, you need to change the
@ -165,7 +170,7 @@ spec:
type: dev.knative.cronjob.event
subscriber:
ref:
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence
```
@ -227,7 +232,7 @@ kubectl -n default get pods
Then look at the logs for the event-display pod:
```shell
kubectl -n default logs -l serving.knative.dev/service=sequence-display -c user-container
kubectl -n default logs --tail=50 -l serving.knative.dev/service=sequence-display -c user-container
☁️ cloudevents.Event
Validation: valid
Context Attributes,

7
docs/eventing/samples/sequence/sequence-with-broker-trigger/cron-source.yaml
View File

@ -6,6 +6,7 @@ spec:
schedule: "*/2 * * * *"
data: '{"message": "Hello world!"}'
sink:
apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
name: broker-test
ref:
apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
name: default

2
docs/eventing/samples/sequence/sequence-with-broker-trigger/display-trigger.yaml
View File

@ -13,7 +13,7 @@ kind: Trigger
metadata:
name: display-trigger
spec:
broker: broker-test
broker: default
filter:
sourceAndType:
type: samples.http.mod3

9
docs/eventing/samples/sequence/sequence-with-broker-trigger/sequence.yaml
View File

@ -1,4 +1,4 @@
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
metadata:
name: sequence
@ -20,6 +20,7 @@ spec:
kind: Service
name: third
reply:
kind: Broker
apiVersion: eventing.knative.dev/v1alpha1
name: broker-test
ref:
kind: Broker
apiVersion: eventing.knative.dev/v1alpha1
name: default

6
docs/eventing/samples/sequence/sequence-with-broker-trigger/steps.yaml
View File

@ -6,7 +6,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "0"
@ -20,7 +20,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "1"
@ -33,7 +33,7 @@ spec:
template:
spec:
containers:
- image: us.gcr.io/probable-summer-223122/cmd-03315b715ae8f3e08e3a9378df706fbb@sha256:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
- image: gcr.io/vaikas-knative/cmd-736bbd9d5a42b6282732cf4569e3c0ff@sha256:f069e4e58d6b420d66304d3bbde019160eb12ca17bb98fc3b88e0de5ad2cacd1
env:
- name: STEP
value: "2"

4
docs/eventing/samples/sequence/sequence-with-broker-trigger/trigger.yaml
View File

@ -3,12 +3,12 @@ kind: Trigger
metadata:
name: sequence-trigger
spec:
broker: broker-test
broker: default
filter:
sourceAndType:
type: dev.knative.cronjob.event
subscriber:
ref:
apiVersion: messaging.knative.dev/v1alpha1
apiVersion: flows.knative.dev/v1alpha1
kind: Sequence
name: sequence