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

enhance: add rw/ro streaming query node replica management #38677

Open
wants to merge 11 commits into
base: master
Choose a base branch
from

fix: go test may crash

e0026cd
Select commit
Loading
Failed to load commit list.
Open

enhance: add rw/ro streaming query node replica management #38677

fix: go test may crash
e0026cd
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Jan 3, 2025 in 1s

75.19% of diff hit (target 80.00%)

View this Pull Request on Codecov

75.19% of diff hit (target 80.00%)

Annotations

Check warning on line 85 in internal/coordinator/snmanager/streaming_node_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/coordinator/snmanager/streaming_node_manager.go#L84-L85

Added lines #L84 - L85 were not covered by tests

Check warning on line 130 in internal/querycoordv2/balance/balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/balance.go#L129-L130

Added lines #L129 - L130 were not covered by tests

Check warning on line 79 in internal/querycoordv2/balance/channel_level_score_balancer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/channel_level_score_balancer.go#L72-L79

Added lines #L72 - L79 were not covered by tests

Check warning on line 495 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L489-L495

Added lines #L489 - L495 were not covered by tests

Check warning on line 504 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L498-L504

Added lines #L498 - L504 were not covered by tests

Check warning on line 508 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L506-L508

Added lines #L506 - L508 were not covered by tests

Check warning on line 515 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L510-L515

Added lines #L510 - L515 were not covered by tests

Check warning on line 521 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L518-L521

Added lines #L518 - L521 were not covered by tests

Check warning on line 524 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L524

Added line #L524 was not covered by tests

Check warning on line 529 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L528-L529

Added lines #L528 - L529 were not covered by tests

Check warning on line 533 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L533

Added line #L533 was not covered by tests

Check warning on line 535 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L535

Added line #L535 was not covered by tests

Check warning on line 543 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L543

Added line #L543 was not covered by tests

Check warning on line 545 in internal/querycoordv2/balance/multi_target_balance.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/multi_target_balance.go#L545

Added line #L545 was not covered by tests

Check warning on line 123 in internal/querycoordv2/balance/rowcount_based_balancer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/rowcount_based_balancer.go#L119-L123

Added lines #L119 - L123 were not covered by tests

Check warning on line 211 in internal/querycoordv2/balance/rowcount_based_balancer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/rowcount_based_balancer.go#L211

Added line #L211 was not covered by tests

Check warning on line 223 in internal/querycoordv2/balance/rowcount_based_balancer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/rowcount_based_balancer.go#L221-L223

Added lines #L221 - L223 were not covered by tests

Check warning on line 244 in internal/querycoordv2/balance/rowcount_based_balancer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/rowcount_based_balancer.go#L244

Added line #L244 was not covered by tests

Check warning on line 56 in internal/querycoordv2/balance/streaming_query_node_channel_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/streaming_query_node_channel_helper.go#L55-L56

Added lines #L55 - L56 were not covered by tests

Check warning on line 60 in internal/querycoordv2/balance/streaming_query_node_channel_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/balance/streaming_query_node_channel_helper.go#L59-L60

Added lines #L59 - L60 were not covered by tests

Check warning on line 507 in internal/querycoordv2/meta/replica_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/meta/replica_manager.go#L506-L507

Added lines #L506 - L507 were not covered by tests

Check warning on line 562 in internal/querycoordv2/meta/replica_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/meta/replica_manager.go#L561-L562

Added lines #L561 - L562 were not covered by tests

Check warning on line 204 in internal/querycoordv2/meta/replica_manager_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/meta/replica_manager_helper.go#L199-L204

Added lines #L199 - L204 were not covered by tests

Check warning on line 275 in internal/querycoordv2/meta/replica_manager_helper.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/meta/replica_manager_helper.go#L274-L275

Added lines #L274 - L275 were not covered by tests

Check warning on line 145 in internal/querycoordv2/observers/replica_observer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querycoordv2/observers/replica_observer.go#L145

Added line #L145 was not covered by tests