numaproj / numaflow

Kubernetes-native platform to run massively parallel data/streaming jobs
https://numaflow.numaproj.io/
Apache License 2.0
1.29k stars 115 forks source link

Reorganize Rust Code #2098

Closed vigith closed 1 month ago

vigith commented 1 month ago

Summary

Adopt the following structure

.
└── src
    └── numaflow-core
        ├── lib.rs
        ├── map
        │   └── mod.rs
        ├── message.rs
        ├── monovertex
        │   └── forwarder
        │       └── mod.rs
        ├── pipeline
        │   └── forwarder
        │       └── mod.rs
        ├── reduce
        │   └── mod.rs
        ├── sink
        │   └── mod.rs
        ├── source
        │   ├── mod.rs
        │   └── tickgen
        │       └── mod.rs
        ├── transfomer
        │   └── mod.rs
        └── watermark
            └── mod.rs