Performance bottle neck on single parent propagating events to increasing children

[arg-foo]

User Story
As a developer, I want to optimize the performance bottleneck when a single parent propagates events to an increasing number of children so that the system scales efficiently, maintaining low latency and high throughput as the number of child agents grows.

---

Details & Requirements

1. Scalability Analysis and Bottleneck Identification

   • Profile the current event propagation mechanism to pinpoint performance bottlenecks as the number of children increases. (Currently caused by the parent being required to process all messages from its child to propagate events to its children)
   • Measure latency, throughput, and resource usage to understand the impact of scaling.

2. Testing & Benchmarking

   • Develop load tests simulating increasing numbers of children to measure the impact on performance.
   • Benchmark the current implementation against the optimized solution to validate improvements.

---

Acceptance Criteria

• The system maintains low latency and high throughput as the number of children increases.
• Load testing demonstrates significant performance improvements over the current dispatch model.

[arg-foo]

graph TD
    A[GAgent A] -->|PublishEventAsync| B[StreamCoordinatorGrain]
    
    subgraph "Event Flow Decision"
        B -->|if no parent| C[DownwardsEventAsync]
        B -->|if has parent| D[UpwardsEventAsync]
    end
    
    C -->|For each group| E1[EventPubChildrenGroupGrain 1]
    C -->|For each group| E2[EventPubChildrenGroupGrain 2]
    
    E1 -->|OnNextAsync| F1[Child GAgent 1]
    E1 -->|OnNextAsync| F2[Child GAgent 2]
    E2 -->|OnNextAsync| F3[Child GAgent 3]
    
    D -->|Self handling| G[Self Stream]
    D -->|Parent handling| H[Parent StreamCoordinatorGrain]
    
    subgraph "Child Management"
        B <-->|RegisterChildAsync| I[Group Assignment]
        I -->|Add to group| E1
        I -->|Add to group| E2
    end

Loading

[arg-foo]

Code Review is done. Would like to have a load test done on this feature to ensure validity of the feature.