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: snowpipe streaming #5110

Merged
merged 7 commits into from
Dec 4, 2024
+5,477 −52

chore: some more addition of test cases

db5364b
Select commit
Loading
Failed to load commit list.
Merged

feat: snowpipe streaming #5110

chore: some more addition of test cases
db5364b
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Dec 4, 2024 in 1s

86.30% of diff hit (target 74.25%)

View this Pull Request on Codecov

86.30% of diff hit (target 74.25%)

Annotations

Check warning on line 99 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/apiadapter.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/apiadapter.go#L97-L99 

Added lines #L97 - L99 were not covered by tests

Check warning on line 117 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/apiadapter.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/apiadapter.go#L115-L117 

Added lines #L115 - L117 were not covered by tests

Check warning on line 34 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L33-L34 

Added lines #L33 - L34 were not covered by tests

Check warning on line 39 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L38-L39 

Added lines #L38 - L39 were not covered by tests

Check warning on line 64 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L63-L64 

Added lines #L63 - L64 were not covered by tests

Check warning on line 71 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L70-L71 

Added lines #L70 - L71 were not covered by tests

Check warning on line 121 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L120-L121 

Added lines #L120 - L121 were not covered by tests

Check warning on line 124 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L123-L124 

Added lines #L123 - L124 were not covered by tests

Check warning on line 131 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L130-L131 

Added lines #L130 - L131 were not covered by tests

Check warning on line 134 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L133-L134 

Added lines #L133 - L134 were not covered by tests

Check warning on line 138 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L137-L138 

Added lines #L137 - L138 were not covered by tests

Check warning on line 157 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L156-L157 

Added lines #L156 - L157 were not covered by tests

Check warning on line 163 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L162-L163 

Added lines #L162 - L163 were not covered by tests

Check warning on line 166 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L165-L166 

Added lines #L165 - L166 were not covered by tests

Check warning on line 185 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L184-L185 

Added lines #L184 - L185 were not covered by tests

Check warning on line 191 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L190-L191 

Added lines #L190 - L191 were not covered by tests

Check warning on line 211 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L210-L211 

Added lines #L210 - L211 were not covered by tests

Check warning on line 216 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L215-L216 

Added lines #L215 - L216 were not covered by tests

Check warning on line 242 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L241-L242 

Added lines #L241 - L242 were not covered by tests

Check warning on line 246 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go#L245-L246 

Added lines #L245 - L246 were not covered by tests

Check warning on line 100 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go#L100 

Added line #L100 was not covered by tests

Check warning on line 115 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go#L112-L115 

Added lines #L112 - L115 were not covered by tests

Check warning on line 121 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go#L120-L121 

Added lines #L120 - L121 were not covered by tests

Check warning on line 41 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/api/api.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/api/api.go#L40-L41 

Added lines #L40 - L41 were not covered by tests

Check warning on line 50 in router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/api/api.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/api/api.go#L49-L50 

Added lines #L49 - L50 were not covered by tests
View more details on Codecov