Knative Eventing 示例
Knative Eventing 示例
示例
- 参考 https://github.com/knative/docs/blob/main/code-samples/eventing/README.md 可以找到对应 event 的示例
- Send CloudEvent to the Broker
命令
- broker
kn broker create --help
kn broker create default --class MTChannelBasedBroker -n default
kn broker create mybroker --namespace myproject --class Kafka --broker-config rabbitmq.com/v1beta1:RabbitmqCluster:mycluster:test- trigger
kn trigger create -h
kn trigger create mytrigger --broker default --filter type=dev.knative.samples.helloworld --sink ksvc:mysvc
# 创建事件命令，实现过滤验证
curl -v "http://broker-ingress.knative-eventing.svc.cluster.local/knative-samples/default" \
-X POST \
-H "Ce-Id: 536808d3-88be-4077-9d7a-a3f162705f79" \
-H "Ce-Specversion: 1.0" \
-H "Ce-Type: dev.knative.samples.helloworld" \
-H "Ce-Source: dev.knative.samples/helloworldsource" \
-H "Content-Type: application/json" \
-d '{"msg":"Hello World from the curl pod."}'
exit- channel
kn channel -h
kn channel create -h
kn channel create imc1 --type messaging.knative.dev:v1:InMemoryChannel
kn channel list
# 可以往 channel 发送消息- subscription
kn subscription -h
kn subscription create -h
kn subscription create sub0 --channel imc1 --sink ksvc:receiver
kn subscription listBroker/Trigger 示例
- 以 curl 事件源创建事件，并展示
curl source --CloudEvent--> (Broker -> Trigger) -> event-display-hi- event-display Kservice 创建
$ kn service create event-display-hi --image xiexianbin/event_display --port 8080 --scale-min 1 -n event-demo
$ kn service list镜像 xiexianbin/knative_event_display 需参考制作
可用示例
gitlab -> GitLab Source --CloudEvent--> Sink（Knative Service）https://github.com/knative/docs/blob/main/code-samples/eventing/gitlab-source/README.md