Top 4.3% forks on proxy.golang.org
proxy.golang.org : github.com/RedHatInsights/ccx-notification-writer
Entry point to the notification writer service. The service contains consumer (usually Kafka consumer) that consumes messages from given source, processes those messages and stores them in configured data store. The main task for this service is to listen to configured Kafka topic, consume all messages from such topic, and write OCP results (in JSON format) with additional information (like organization ID, cluster name, Kafka offset etc.) into a database table named new_reports. Multiple reports can be consumed and written into the database for the same cluster, because the primary (compound) key for new_reports table is set to the combination (org_id, cluster, updated_at). When some message does not conform to expected schema (for example if org_id is missing for any reason), such message is dropped and the error message with all relevant information about the issue is stored into the log. Messages are expected to contain report body represented as JSON. This body is shrunk before it's stored into database so the database remains relatively small. Package kafka contains an implementation of Producer interface that can be used to produce (that is send) messages to properly configured Kafka broker.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/%21red%21hat%21insights/ccx-notification-writer
License: Apache-2.0
Latest release: over 1 year ago
First release: over 2 years ago
Namespace: github.com/RedHatInsights
Stars: 1 on GitHub
Forks: 10 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 7 days ago