Skip to content

SSM/SRM Topics for GJC #39

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
iyourshaw merged 5 commits into from
Oct 6, 2025
Merged

SSM/SRM Topics for GJC #39

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
40c6c44
Add topics
iyourshaw Sep 25, 2025
3ce52c5
cimms priority/preemption event topic
iyourshaw Sep 29, 2025
b0c58d7
Add to mongo script
iyourshaw Sep 29, 2025
61857f4
add processed ssm/srm connectors and mongo collections
iyourshaw Sep 29, 2025
dad6638
Merge remote-tracking branch 'cdot/develop' into ssm-srm-topics
iyourshaw Oct 3, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 10 additions & 1 deletion jikkou/kafka-connectors-values.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,12 @@ apps:
- topicName: topic.ProcessedBsm
collectionName: ProcessedBsm
generateTimestamp: true
- topicName: topic.ProcessedSrm
collectionName: ProcessedSrm
generateTimestamp: true
- topicName: topic.ProcessedSsm
collectionName: ProcessedSsm
generateTimestamp: true
intersection_api:
name: intersection_api
connectors:
Expand Down Expand Up @@ -271,7 +277,10 @@ apps:
collectionName: CmRtcmMinimumDataEventAggregation
generateTimestamp: true
timestampField: eventGeneratedAt

- topicName: topic.CmPriorityPreemptionRequestEvent
collectionName: CmPriorityPreemptionRequestEvent
useTimestamp: true
timestampField: eventGeneratedAt


# Record BSM events:
Expand Down
3 changes: 3 additions & 0 deletions jikkou/kafka-topics-values.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -88,6 +88,8 @@ apps:
- topic.ProcessedMapWKT
- topic.ProcessedBsm
- topic.ProcessedRtcm
- topic.ProcessedSrm
- topic.ProcessedSsm
tableTopics: {}
customTopics: {}
conflictmonitor:
Expand Down Expand Up @@ -128,6 +130,7 @@ apps:
- topic.CmMapMessageCountProgressionEventAggregation
- topic.CmSpatMessageCountProgressionEventAggregation
- topic.CmRevocableEnabledLaneAlignmentEventAggregation
- topic.CmPriorityPreemptionRequestEvent
tableTopics:
- topic.CmLaneDirectionOfTravelNotification
- topic.CmConnectionOfTravelNotification
Expand Down
7 changes: 5 additions & 2 deletions mongo/create_indexes.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,9 @@ const odeCollections = [
const geoJsonConverterCollections = [
{name: "ProcessedMap", ttlField: "recordGeneratedAt", timeField: "properties.timeStamp", intersectionField: "properties.intersectionId", expireTime: expireSeconds},
{name: "ProcessedSpat", ttlField: "recordGeneratedAt", timeField: "utcTimeStamp", intersectionField: "intersectionId", expireTime: expireSeconds},
{name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds}
{name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds},
{name: "ProcessedSrm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds},
{name: "ProcessedSsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds}
];


Expand All @@ -104,7 +106,7 @@ const conflictMonitorCollections = [
{ name: "CmTimestampDeltaEvent", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
{ name: "CmSpatTransitionEvent", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
{ name: "CmEventStateProgressionEvent", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },

{ name: "CmPriorityPreemptionRequestEvent", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },



Expand All @@ -113,6 +115,7 @@ const conflictMonitorCollections = [
{ name: "CmBsmMessageCountProgressionEvents", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
{ name: "CmRevocableEnabledLaneAlignmentEvent", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },


{ name: "CmSpatMinimumDataEventAggregation", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
{ name: "CmMapMinimumDataEventAggregation", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
{ name: "CmIntersectionReferenceAlignmentEventAggregation", ttlField: "eventGeneratedAt", timeField: "eventGeneratedAt", intersectionField: "intersectionID", expireTime: expireSeconds },
Expand Down
Loading