[Enhancement] opensource staros - java code
- open source staros java source code
Why I'm doing:
What I'm doing:
#63826
What type of PR is this:
- [ ] BugFix
- [ ] Feature
- [x] Enhancement
- [ ] Refactor
- [ ] UT
- [ ] Doc
- [ ] Tool
Does this PR entail a change in behavior?
- [ ] Yes, this PR will result in a change in behavior.
- [x] No, this PR will not result in a change in behavior.
If yes, please specify the type of change:
- [ ] Interface/UI changes: syntax, type conversion, expression evaluation, display information
- [ ] Parameter changes: default values, similar parameters but with different default values
- [ ] Policy changes: use new policy to replace old one, functionality automatically enabled
- [ ] Feature removed
- [ ] Miscellaneous: upgrade & downgrade compatibility, etc.
Checklist:
- [ ] I have added test cases for my bug fix or my new feature
- [ ] This pr needs user documentation (for new or modified features or behaviors)
- [ ] I have added documentation for my new feature or new function
- [ ] This is a backport pr
Bugfix cherry-pick branch check:
- [x] I have checked the version labels which the pr will be auto-backported to the target branch
- [ ] 4.0
- [ ] 3.5
- [ ] 3.4
- [ ] 3.3
[!NOTE] Introduce the StarOS Java implementation with shard/worker management, gRPC agent, placement/scheduling, file stores, utilities, and comprehensive tests.
- Starlet (gRPC) Agent:
StarletAgentwith heartbeat, add/remove shard RPCs, retries, and channel/stub lifecycle.- Mock agents for unit tests.
- Worker Management:
Worker,WorkerGroup,WorkerManagerwith create/update/delete, heartbeats, dump/load image, and dynamic thread-pool sizing.- Resource provisioning via
DefaultResourceManager(external or builtin test server) and factory.- Shard Management:
Shard,ShardGroup,MetaGroup(PACK/SPREAD/EXCLUDE), anonymous group handling, and meta-group operations.- Health/balance checker and
ShardSchedulerV2(add/remove to worker/group, batch, balancing, temp replicas).ShardPolicyFilterwith EXCLUDE policy.- File Store/Path:
- S3/HDFS/Azure Blob/ADLS2/GS stores, replace/update flows, path and checksum utilities.
- Utilities/Infra:
- Config, logging, ID generator, abstract server, metrics, log dumping tool (
ReadImage).- HTTP/Service:
- HTTP dispatcher/service endpoints;
StarManagerorchestration.- Tests:
- Extensive unit tests covering managers, scheduler, shard/replica states, file stores, HTTP, journal replayer, and provisioner.
Written by Cursor Bugbot for commit dfe707903f9e973ed0aec61dcf306e1cfd5b59fb. This will update automatically on new commits. Configure here.
@cursor review
@cursor review
๐งช CI Insights
Here's what we observed from your CI run for dfe70790.
๐ข All jobs passed!
But CI Insights is watching ๐
@cursor review
@cursor review
@cursor review
@mergifyio rebase
rebase
โ Branch has been successfully rebased
@cursor review
@mergifyio rebase
rebase
โ Branch has been successfully rebased
Quality Gate failed
Failed conditions
10 Security Hotspots
E Reliability Rating on New Code (required โฅ A)
See analysis details on SonarQube Cloud
Catch issues before they fail your Quality Gate with our IDE extension
SonarQube for IDE
[Java-Extensions Incremental Coverage Report]
:white_check_mark: pass : 0 / 0 (0%)
[FE Incremental Coverage Report]
:white_check_mark: pass : 0 / 0 (0%)
[BE Incremental Coverage Report]
:white_check_mark: pass : 0 / 0 (0%)
@cursor review