-
Notifications
You must be signed in to change notification settings - Fork 29
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
5224e96
commit 3022d7a
Showing
22 changed files
with
129 additions
and
145 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 2 additions & 2 deletions
4
helm/bobbycar-core-apps/templates/cacheService-integration.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,12 +1,12 @@ | ||
kind: Secret | ||
apiVersion: v1 | ||
metadata: | ||
name: {{ .Values.cacheService.name }}-secret | ||
name: cache-service-secret | ||
stringData: | ||
application.properties: |- | ||
com.redhat.bobbycar.camelk.dg.car.cacheName: {{ .Values.kafka2datagrid.datagrid.cache.car }} | ||
com.redhat.bobbycar.camelk.dg.zone.cacheName: {{ .Values.kafka2datagrid.datagrid.cache.zone }} | ||
com.redhat.bobbycar.camelk.dg.host: {{ .Values.kafka2datagrid.datagrid.account.host }} | ||
com.redhat.bobbycar.camelk.dg.password: {{ .Values.kafka2datagrid.datagrid.account.password }} | ||
com.redhat.bobbycar.camelk.dg.user: {{ .Values.kafka2datagrid.datagrid.account.user }} | ||
com.redhat.bobbycar.camelk.dg.car.cacheName: {{ .Values.datagrid.cache.car }} | ||
com.redhat.bobbycar.camelk.dg.zone.cacheName: {{ .Values.datagrid.cache.zone }} | ||
com.redhat.bobbycar.camelk.dg.host: bobbycar-dg | ||
com.redhat.bobbycar.camelk.dg.password: {{ .Values.datagrid.account.password }} | ||
com.redhat.bobbycar.camelk.dg.user: {{ .Values.datagrid.account.user }} | ||
type: Opaque |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
4 changes: 2 additions & 2 deletions
4
helm/bobbycar-core-apps/templates/dashboard-streaming-integration.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,14 +1,14 @@ | ||
apiVersion: camel.apache.org/v1 | ||
kind: Integration | ||
metadata: | ||
name: {{ .Values.dashboardService.name }} | ||
name: dashboard-streaming-service | ||
labels: | ||
app.kubernetes.io/part-of: {{ .Values.appName }} | ||
spec: | ||
profile: OpenShift | ||
configuration: | ||
- type: secret | ||
value: {{ .Values.dashboardService.name }}-secret | ||
value: dashboard-streaming-service-secret | ||
sources: | ||
- content: {{`"package com.redhat.bobbycar.routes;\nimport org.apache.camel.builder.RouteBuilder;\n\npublic class KafkaSseRoute extends RouteBuilder {\n\t\n\t@Override\n\tpublic void configure() throws Exception {\n\n\t\t// expose Bobbycar GPS positions from Kafka as Websocket\n\t\tfrom(\"kafka:{{com.redhat.bobbycar.camelk.kafka.topic.gps}}?clientId=kafkaSseCamelClient&brokers={{com.redhat.bobbycar.camelk.kafka.brokers}}\")\n\t\t\t.log(\"GPS position received from Kafka : ${body}\")\n\t\t\t.to(\"undertow:ws://0.0.0.0:8080/api/carevents?sendToAll=true\");\n\t\tfrom(\"undertow:ws://0.0.0.0:8080/api/carevents?sendToAll=true\")\n\t\t\t.log(\"Message received from Websocket : ${body}\");\n\n\t\t// expose Bobbycar engine metrics from Kafka as Websocket\n\t\tfrom(\"kafka:{{com.redhat.bobbycar.camelk.kafka.topic.metrics}}?clientId=kafkaSseMetricsClient&brokers={{com.redhat.bobbycar.camelk.kafka.brokers}}\")\n\t\t\t.log(\"Metric received from Kafka : ${body}\")\n\t\t\t.to(\"undertow:ws://0.0.0.0:8080/api/carmetrics?sendToAll=true\");\n\t\tfrom(\"undertow:ws://0.0.0.0:8080/api/carmetrics?sendToAll=true\")\n\t\t\t.log(\"Message received from Websocket : ${body}\");\n\n\t\t// expose Bobbycar zone change events from Kafka as Websocket\n\t\tfrom(\"kafka:{{com.redhat.bobbycar.camelk.kafka.topic.zonechange}}?clientId=kafkaSseZoneChangeClient&brokers={{com.redhat.bobbycar.camelk.kafka.brokers}}\")\n\t\t\t\t.log(\"Zone change event received from Kafka : ${body}\")\n\t\t\t\t.to(\"undertow:ws://0.0.0.0:8080/api/zonechange?sendToAll=true\");\n\t\tfrom(\"undertow:ws://0.0.0.0:8080/api/zonechange?sendToAll=true\")\n\t\t\t\t.log(\"Message received from Websocket : ${body}\");\n\t\t\n\t}\n\t\n\t\n}\n"`}} | ||
name: KafkaSseRoute.java |
8 changes: 4 additions & 4 deletions
8
helm/bobbycar-core-apps/templates/dashboard-streaming-route.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
10 changes: 5 additions & 5 deletions
10
helm/bobbycar-core-apps/templates/dashboard-streaming-secret.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,13 +1,13 @@ | ||
kind: Secret | ||
apiVersion: v1 | ||
metadata: | ||
name: {{ .Values.dashboardService.name }}-secret | ||
name: dashboard-streaming-service-secret | ||
stringData: | ||
application.properties: |- | ||
com.redhat.bobbycar.camelk.kafka.brokers: {{ .Values.dashboardService.kafka.host }} | ||
com.redhat.bobbycar.camelk.kafka.topic.gps: {{ .Values.dashboardService.kafka.topicGps }} | ||
com.redhat.bobbycar.camelk.kafka.topic.metrics: {{ .Values.dashboardService.kafka.topicMetrics }} | ||
com.redhat.bobbycar.camelk.kafka.topic.zonechange: {{ .Values.dashboardService.kafka.topicZoneChange }} | ||
com.redhat.bobbycar.camelk.kafka.brokers: bobbycar-cluster-kafka-brokers:9092 | ||
com.redhat.bobbycar.camelk.kafka.topic.gps: {{ .Values.kafka.topic.gps }} | ||
com.redhat.bobbycar.camelk.kafka.topic.metrics: {{ .Values.kafka.topic.metrics }} | ||
com.redhat.bobbycar.camelk.kafka.topic.zonechange: {{ .Values.kafka.topic.zonechange }} | ||
type: Opaque | ||
|
||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 1 addition & 1 deletion
2
helm/bobbycar-core-apps/templates/kafka2datagrid-integration.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.