distributed 4.4.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

name: Rust Quality Pipeline for PRs

on:
  pull_request:

concurrency:
  group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }}
  cancel-in-progress: true

jobs:
  contracts:
    name: Run fail-fast contract lifecycle check
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4
        with:
          fetch-depth: 0
      - name: Resolve PR merge-base
        id: base
        run: |
          git fetch origin "${{ github.base_ref }}" --depth=1
          base=$(git merge-base HEAD "origin/${{ github.base_ref }}" || true)
          echo "sha=${base}" >> "$GITHUB_OUTPUT"
          echo "merge-base=${base}"
      - name: Install Rust toolchain
        uses: dtolnay/rust-toolchain@stable
      - name: Run contracts check
        run: |
          if [ -f contracts/catalog.json ]; then
            cargo run -p distributed_cli --quiet -- contracts check --root . --catalog contracts/catalog.json --output json
          else
            echo "No contracts/catalog.json yet; gate is present and ready for producers."
          fi

  # Framework monorepo keeps its existing quality provider. The reusable
  # quality.yaml in this directory is the contract for *consumers* (domain
  # crates / Distributed libraries), not for this workspace's entry pipeline.
  quality:
    uses: unbounded-tech/workflows-rust/.github/workflows/quality.yaml@feat/cargo-publish
    with:
      cargo_build_args: "--verbose"
      cargo_test_args: "--verbose"
      cargo_incremental: true

  all-features:
    uses: ./.github/workflows/test-all-features.yaml

  postgres:
    uses: ./.github/workflows/integration-postgres.yaml

  nats:
    uses: ./.github/workflows/integration-nats.yaml

  rabbitmq:
    uses: ./.github/workflows/integration-rabbitmq.yaml

  kafka:
    uses: ./.github/workflows/integration-kafka.yaml

  distributed-cli:
    needs: [contracts]
    uses: ./.github/workflows/integration-distributed-cli.yaml

  observability:
    uses: ./.github/workflows/integration-observability.yaml

  graphql:
    needs: [contracts]
    uses: ./.github/workflows/integration-graphql.yaml

  e2e-ui:
    needs: [contracts]
    uses: ./.github/workflows/integration-e2e-ui.yaml

  js-client:
    needs: [contracts]
    uses: ./.github/workflows/integration-js.yaml

  celld:
    uses: ./.github/workflows/integration-celld.yaml