Skip to content

feat: use gRPC Bidirectional Streaming for Mapper

Codecov / codecov/patch succeeded Oct 5, 2024 in 0s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 76 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L69-L76 

Added lines #L69 - L76 were not covered by tests

Check warning on line 81 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L80-L81 

Added lines #L80 - L81 were not covered by tests

Check warning on line 124 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L120-L124 

Added lines #L120 - L124 were not covered by tests

Check warning on line 137 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L132-L137 

Added lines #L132 - L137 were not covered by tests

Check warning on line 95 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L95 

Added line #L95 was not covered by tests

Check warning on line 117 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L113-L117 

Added lines #L113 - L117 were not covered by tests

Check warning on line 133 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L130-L133 

Added lines #L130 - L133 were not covered by tests

Check warning on line 135 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L135 

Added line #L135 was not covered by tests

Check warning on line 141 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L137-L141 

Added lines #L137 - L141 were not covered by tests

Check warning on line 153 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L153 

Added line #L153 was not covered by tests

Check warning on line 162 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L161-L162 

Added lines #L161 - L162 were not covered by tests

Check warning on line 166 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L165-L166 

Added lines #L165 - L166 were not covered by tests

Check warning on line 173 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L168-L173 

Added lines #L168 - L173 were not covered by tests

Check warning on line 180 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L175-L180 

Added lines #L175 - L180 were not covered by tests

Check warning on line 183 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L182-L183 

Added lines #L182 - L183 were not covered by tests

Check warning on line 193 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L187-L193 

Added lines #L187 - L193 were not covered by tests

Check warning on line 196 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L196 

Added line #L196 was not covered by tests

Check warning on line 200 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L200 

Added line #L200 was not covered by tests

Check warning on line 203 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L202-L203 

Added lines #L202 - L203 were not covered by tests

Check warning on line 205 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L205 

Added line #L205 was not covered by tests

Check warning on line 207 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L207 

Added line #L207 was not covered by tests

Check warning on line 215 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L213-L215 

Added lines #L213 - L215 were not covered by tests

Check warning on line 221 in src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapperTestKit.java#L220-L221 

Added lines #L220 - L221 were not covered by tests

Check warning on line 30 in src/main/java/io/numaproj/numaflow/mapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Service.java#L30 

Added line #L30 was not covered by tests

Check warning on line 33 in src/main/java/io/numaproj/numaflow/mapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Service.java#L33 

Added line #L33 was not covered by tests
View more details on Codecov