shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: trim inactive app toggles

Browse Source
This commit is contained in:
lingniu
2026-07-01 14:28:08 +08:00
parent 1eed7623d1
commit cd12a84e51
8 changed files with 8 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/apps/gb32960-ingest-app/src/main/resources/application.yml
View File

@@ -122,8 +122,6 @@ lingniu:
enabled: ${SINK_ARCHIVE_ENABLED:true} enabled: ${SINK_ARCHIVE_ENABLED:true}
type: local type: local
path: ${SINK_ARCHIVE_PATH:./archive/} path: ${SINK_ARCHIVE_PATH:./archive/}
event-history:
enabled: false
management: management:
endpoints: endpoints:

3
modules/apps/gb32960-ingest-app/src/test/java/com/lingniu/ingest/gb32960app/Gb32960IngestAppDefaultsTest.java
View File

@@ -50,17 +50,18 @@ class Gb32960IngestAppDefaultsTest {
.containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}") .containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}")
.containsEntry("lingniu.ingest.identity.mysql.table-name", .containsEntry("lingniu.ingest.identity.mysql.table-name",
"${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}") "${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}")
.containsEntry("lingniu.ingest.event-history.enabled", false)
.containsEntry("management.endpoints.web.exposure.include", .containsEntry("management.endpoints.web.exposure.include",
"health,info,metrics,prometheus,gb32960sessions"); "health,info,metrics,prometheus,gb32960sessions");
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
.noneMatch(name -> name.startsWith("lingniu.ingest.event-history."))
.noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store.")) .noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat."))
.noneMatch(name -> name.startsWith(legacyKafkaPrefix)) .noneMatch(name -> name.startsWith(legacyKafkaPrefix))
.noneMatch(name -> name.equals(kafkaTypeProperty)); .noneMatch(name -> name.equals(kafkaTypeProperty));
assertThat(applicationYaml()) assertThat(applicationYaml())
.doesNotContain("event-history:")
.doesNotContain("event-file-store:") .doesNotContain("event-file-store:")
.doesNotContain("vehicle-state:") .doesNotContain("vehicle-state:")
.doesNotContain("vehicle-stat:"); .doesNotContain("vehicle-stat:");

2
modules/apps/jt808-ingest-app/src/main/resources/application.yml
View File

@@ -82,8 +82,6 @@ lingniu:
dlq: ${KAFKA_TOPIC_JT808_DLQ:vehicle.dlq.jt808.v1} dlq: ${KAFKA_TOPIC_JT808_DLQ:vehicle.dlq.jt808.v1}
consumer: consumer:
enabled: false enabled: false
event-history:
enabled: false
management: management:
endpoints: endpoints:

3
modules/apps/jt808-ingest-app/src/test/java/com/lingniu/ingest/jt808app/Jt808IngestAppDefaultsTest.java
View File

@@ -43,14 +43,15 @@ class Jt808IngestAppDefaultsTest {
.containsEntry("lingniu.ingest.identity.mysql.password", "${VEHICLE_IDENTITY_MYSQL_PASSWORD:}") .containsEntry("lingniu.ingest.identity.mysql.password", "${VEHICLE_IDENTITY_MYSQL_PASSWORD:}")
.containsEntry("lingniu.ingest.identity.mysql.initialize-schema", .containsEntry("lingniu.ingest.identity.mysql.initialize-schema",
"${VEHICLE_IDENTITY_MYSQL_INITIALIZE_SCHEMA:true}") "${VEHICLE_IDENTITY_MYSQL_INITIALIZE_SCHEMA:true}")
.containsEntry("lingniu.ingest.event-history.enabled", false)
.containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus"); .containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus");
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
.noneMatch(name -> name.startsWith("lingniu.ingest.event-history."))
.noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store.")) .noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat.")); .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat."));
assertThat(applicationYaml()) assertThat(applicationYaml())
.doesNotContain("event-history:")
.doesNotContain("event-file-store:") .doesNotContain("event-file-store:")
.doesNotContain("vehicle-state:") .doesNotContain("vehicle-state:")
.doesNotContain("vehicle-stat:"); .doesNotContain("vehicle-stat:");

4
modules/apps/vehicle-history-app/src/main/resources/application.yml
View File

@@ -96,10 +96,6 @@ lingniu:
enabled: true enabled: true
api: api:
specialized-enabled: ${EVENT_HISTORY_SPECIALIZED_API_ENABLED:false} specialized-enabled: ${EVENT_HISTORY_SPECIALIZED_API_ENABLED:false}
vehicle-state:
enabled: false
vehicle-stat:
enabled: false
management: management:
endpoints: endpoints:

4
modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java
View File

@@ -39,8 +39,6 @@ class VehicleHistoryAppDefaultsTest {
.containsEntry("lingniu.ingest.tdengine-history.maximum-pool-size", "${TDENGINE_MAX_POOL_SIZE:16}") .containsEntry("lingniu.ingest.tdengine-history.maximum-pool-size", "${TDENGINE_MAX_POOL_SIZE:16}")
.containsEntry("lingniu.ingest.tdengine-history.minimum-idle", "${TDENGINE_MIN_IDLE:0}") .containsEntry("lingniu.ingest.tdengine-history.minimum-idle", "${TDENGINE_MIN_IDLE:0}")
.containsEntry("lingniu.ingest.event-history.enabled", true) .containsEntry("lingniu.ingest.event-history.enabled", true)
.containsEntry("lingniu.ingest.vehicle-state.enabled", false)
.containsEntry("lingniu.ingest.vehicle-stat.enabled", false)
.containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", "${KAFKA_CONSUMER_ENABLED:true}") .containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", "${KAFKA_CONSUMER_ENABLED:true}")
.containsEntry("lingniu.ingest.sink.kafka.consumer.max-poll-records", "${KAFKA_CONSUMER_MAX_POLL_RECORDS:2000}") .containsEntry("lingniu.ingest.sink.kafka.consumer.max-poll-records", "${KAFKA_CONSUMER_MAX_POLL_RECORDS:2000}")
.containsEntry("lingniu.ingest.sink.kafka.consumer.concurrency", "${KAFKA_CONSUMER_CONCURRENCY:3}") .containsEntry("lingniu.ingest.sink.kafka.consumer.concurrency", "${KAFKA_CONSUMER_CONCURRENCY:3}")
@@ -104,6 +102,8 @@ class VehicleHistoryAppDefaultsTest {
.containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus"); .containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus");
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat."))
.noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store.")); .noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store."));
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
.noneMatch(name -> name.equals("lingniu.ingest.tdengine-history.telemetry-fields-enabled")); .noneMatch(name -> name.equals("lingniu.ingest.tdengine-history.telemetry-fields-enabled"));

2
modules/apps/yutong-mqtt-app/src/main/resources/application.yml
View File

@@ -92,8 +92,6 @@ lingniu:
enabled: ${SINK_ARCHIVE_ENABLED:true} enabled: ${SINK_ARCHIVE_ENABLED:true}
type: local type: local
path: ${SINK_ARCHIVE_PATH:./archive/} path: ${SINK_ARCHIVE_PATH:./archive/}
event-history:
enabled: false
management: management:
endpoints: endpoints:

3
modules/apps/yutong-mqtt-app/src/test/java/com/lingniu/ingest/yutongmqttapp/YutongMqttAppDefaultsTest.java
View File

@@ -37,14 +37,15 @@ class YutongMqttAppDefaultsTest {
.containsEntry("lingniu.ingest.identity.mysql.table-name", .containsEntry("lingniu.ingest.identity.mysql.table-name",
"${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}") "${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}")
.containsEntry("lingniu.ingest.sink.archive.enabled", "${SINK_ARCHIVE_ENABLED:true}") .containsEntry("lingniu.ingest.sink.archive.enabled", "${SINK_ARCHIVE_ENABLED:true}")
.containsEntry("lingniu.ingest.event-history.enabled", false)
.containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus"); .containsEntry("management.endpoints.web.exposure.include", "health,info,metrics,prometheus");
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
.noneMatch(name -> name.startsWith("lingniu.ingest.event-history."))
.noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store.")) .noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat.")); .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat."));
assertThat(applicationYaml()) assertThat(applicationYaml())
.doesNotContain("event-history:")
.doesNotContain("event-file-store:") .doesNotContain("event-file-store:")
.doesNotContain("vehicle-state:") .doesNotContain("vehicle-state:")
.doesNotContain("vehicle-stat:"); .doesNotContain("vehicle-stat:");