v0.39.0
The present release includes fixes to TRG response handling, cleanup facilities, and a new Kafka integration plugin.
-
Kafka integration plugin:
- [core] Kafka plugin to publish FSM state transitions
- [core] Check if kafka message status can be read
- [core] Store environment state in varStack and make kafka plugin get it from there
- [core] Use UnixMilli(), since Go 1.17 supports it
- [core] Initialize loggers in CCDB and Kafka plugins
- [core] A different (working) approach to obtaining current state
- [core] Update kafka topics to the agreed convention
- [core] rename kafkaBroker to kafkaEndpoint for consistency, fix log
- [core] Publish an empty env list to kafka at init
- [core] Publish Error state and react to DESTROY in kafka plugin
- [core] Use one common callback in the kafka plugin
- [core] several improvements to logging in kafka and ccdb plugins
- [core] make some member of kafka plugin private
- [core] include STANDBY in the states which can initiate GO_ERROR
- [core] Port kafka plugin to kafka-go package
- [core] Minor string fixes in kafka plugin
-
Other integration plugin fixes:
- [core] Make TRG RunList line parsing forward-compatible
- [core] TRG: Improve run parsing
- [core] TRG should ignore the daq trigger
- [core] Handle daq & standalone trg reconciliation gracefully
-
Miscellaneous:
- [core] Add dirty hack for FLP cleanup before DEPLOY
- [core] Properly set facility & partition for shmcleaner logs