Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: udsink bidirectional streaming #141

Merged
merged 2 commits into from
Sep 26, 2024

feat: udsink bidirectional streaming

68ade2f
Select commit
Loading
Failed to load commit list.
Merged

feat: udsink bidirectional streaming #141

feat: udsink bidirectional streaming
68ade2f
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Sep 26, 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 49 in src/main/java/io/numaproj/numaflow/sinker/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/Service.java#L48-L49 

Added lines #L48 - L49 were not covered by tests

Check warning on line 117 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L116-L117 

Added lines #L116 - L117 were not covered by tests

Check warning on line 122 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L122 

Added line #L122 was not covered by tests

Check warning on line 132 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L132 

Added line #L132 was not covered by tests

Check warning on line 142 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L140-L142 

Added lines #L140 - L142 were not covered by tests

Check warning on line 157 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L157 

Added line #L157 was not covered by tests

Check warning on line 180 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L177-L180 

Added lines #L177 - L180 were not covered by tests

Check warning on line 184 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L183-L184 

Added lines #L183 - L184 were not covered by tests

Check warning on line 190 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L190 

Added line #L190 was not covered by tests

Check warning on line 198 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L198 

Added line #L198 was not covered by tests

Check warning on line 203 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L201-L203 

Added lines #L201 - L203 were not covered by tests

Check warning on line 206 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L206 

Added line #L206 was not covered by tests

Check warning on line 209 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L209 

Added line #L209 was not covered by tests

Check warning on line 103 in src/main/java/io/numaproj/numaflow/sourcer/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sourcer/Service.java#L102-L103 

Added lines #L102 - L103 were not covered by tests
View more details on Codecov