cdviz-collector

Crates.iocdviz-collector
lib.rscdviz-collector
version
sourcesrc
created_at2024-12-12 14:58:06.8669
updated_at2024-12-12 20:10:13.66348
descriptionA service & cli to collect SDLC/CI/CD events and to dispatch as cdevents.
homepagehttps://cdviz.dev
repositoryhttps://github.com/cdviz-dev/cdviz-collector
max_upload_size
id1481322
Cargo.toml error:TOML parse error at line 20, column 1 | 20 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include`
size0
David Bernard (davidB)

documentation

README

cdviz-collector

keywords: cdevents, sdlc, cicd status: wip

A service & cli to collect SDLC/CI/CD events and to dispatch as cdevents.

Goals:

  • to create cdevents by polling some sources (folder on fs, S3, AWS ECR, ...)
  • to receive cdevents from http, kafka, nats
  • to send (broadcast) cdevents to various destination database, http, kafka, nats
  • to expose some metrics (TBD)

cdviz-collector is configured via a config file + override by environment variables.

flowchart LR
  classDef future stroke-dasharray: 5 5

  q>in memory queue of cdevents]

  subgraph sources
    src_http(HTTP)
    src_fs_content(FS folder with cdevents)
    src_fs_activity(FS folder activity):::future
    src_s3_content(S3 with cdevents)
    src_s3_activity(S3 activity):::future
    src_kafka(Kafka):::future
    src_nats(NATS):::future
    src_ecr(AWS ECR):::future
    src_misc(...):::future
  end
  src_http --> q
  src_fs_content --> q
  src_fs_activity --> q
  src_s3_content --> q
  src_s3_activity --> q
  src_kafka --> q
  src_nats --> q
  src_ecr --> q
  src_misc --> q

  subgraph sinks
    sink_stdout(stdout)
    sink_db(DB)
    sink_http(HTTP)
    sink_kafka(Kafka):::future
    sink_nats(NATS):::future
  end
  q --> sink_stdout
  q --> sink_http
  q --> sink_db
  q --> sink_kafka
  q --> sink_nats
Commit count: 142

cargo fmt