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.

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

client: Make tsoStream receives asynchronously #8483

Merged
merged 26 commits into from
Sep 14, 2024

Merge branch 'master' into m/make-tso-stream-async

5314485
Select commit
Loading
Failed to load commit list.
Merged

client: Make tsoStream receives asynchronously #8483

Merge branch 'master' into m/make-tso-stream-async
5314485
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Sep 14, 2024 in 1s

81.14% of diff hit (target 77.66%)

View this Pull Request on Codecov

81.14% of diff hit (target 77.66%)

Annotations

Check warning on line 123 in client/tso_batch_controller.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_batch_controller.go#L123

Added line #L123 was not covered by tests

Check warning on line 138 in client/tso_batch_controller.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_batch_controller.go#L138

Added line #L138 was not covered by tests

Check warning on line 165 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L164-L165

Added lines #L164 - L165 were not covered by tests

Check warning on line 203 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L203

Added line #L203 was not covered by tests

Check warning on line 281 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L281

Added line #L281 was not covered by tests

Check warning on line 314 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L313-L314

Added lines #L313 - L314 were not covered by tests

Check warning on line 326 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L326

Added line #L326 was not covered by tests

Check warning on line 347 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L344-L347

Added lines #L344 - L347 were not covered by tests

Check warning on line 358 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L357-L358

Added lines #L357 - L358 were not covered by tests

Check warning on line 377 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L377

Added line #L377 was not covered by tests

Check warning on line 527 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L527

Added line #L527 was not covered by tests

Check warning on line 529 in client/tso_dispatcher.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_dispatcher.go#L529

Added line #L529 was not covered by tests

Check warning on line 279 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L279

Added line #L279 was not covered by tests

Check warning on line 285 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L282-L285

Added lines #L282 - L285 were not covered by tests

Check warning on line 323 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L323

Added line #L323 was not covered by tests

Check warning on line 329 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L329

Added line #L329 was not covered by tests

Check warning on line 341 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L340-L341

Added lines #L340 - L341 were not covered by tests

Check warning on line 348 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L344-L348

Added lines #L344 - L348 were not covered by tests

Check warning on line 403 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L402-L403

Added lines #L402 - L403 were not covered by tests

Check warning on line 412 in client/tso_stream.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

client/tso_stream.go#L411-L412

Added lines #L411 - L412 were not covered by tests