rabbitmq / rabbitmq-stream-dotnet-client

RabbitMQ client for the stream protocol
https://rabbitmq.github.io/rabbitmq-stream-dotnet-client/stable/htmlsingle/index.html
Other
122 stars 41 forks source link

Implement Add/Remove super stream feature #357

Closed Gsantomaggio closed 9 months ago

Gsantomaggio commented 9 months ago

Implement the super-stream creation/deletion.

There are two ways to create the super-stream:

  1. Based on partitions with:

    const string SuperStream = "my-first-system-super-stream";
    var spec = new PartitionsSuperStreamSpec(SuperStream, 2);
    await system.CreateSuperStream(spec);
  2. Based on keys with:

    const string SuperStream = "countries";
    var system = await StreamSystem.Create(new StreamSystemConfig());
    var conf = new BindingsSuperStreamSpec(SuperStream, new[] { "italy", "france", "spain", "germany", "uk" });
    await system.CreateSuperStream(conf);
codecov[bot] commented 9 months ago

Codecov Report

Attention: 11 lines in your changes are missing coverage. Please review.

Comparison is base (335a0f3) 92.35% compared to head (6abf247) 92.10%.

Files Patch % Lines
RabbitMQ.Stream.Client/CreateSuperStream.cs 95.00% 3 Missing :warning:
RabbitMQ.Stream.Client/DeleteSuperStream.cs 89.65% 3 Missing :warning:
RabbitMQ.Stream.Client/StreamSpec.cs 95.23% 2 Missing and 1 partial :warning:
RabbitMQ.Stream.Client/StreamSystem.cs 88.23% 1 Missing and 1 partial :warning:
Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #357 +/- ## ========================================== - Coverage 92.35% 92.10% -0.26% ========================================== Files 116 118 +2 Lines 11738 12021 +283 Branches 915 927 +12 ========================================== + Hits 10841 11072 +231 - Misses 690 734 +44 - Partials 207 215 +8 ```

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.