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

Driver Node should only ping arrays within the zone on which the pod is scheduled #378

Merged
Merged
Changes from 1 commit
Commits
Show all changes
41 commits
Select commit Hold shift + click to select a range
dbe9cb0
Add snapshot check and topology add during zone volume creation
falfaroc Dec 3, 2024
19bcb43
Add topology checks for clones
tdawe Dec 4, 2024
559f607
Add zone snapshot and restore e2e test
falfaroc Dec 5, 2024
c86b87c
Address failed PR checks
falfaroc Dec 5, 2024
e22ab62
Update README
falfaroc Dec 5, 2024
6ded989
Add setNodePodLabel and zone probing for nodes
falfaroc Dec 6, 2024
22d00d6
rb
falfaroc Dec 6, 2024
ebd8f37
Update modified goscaleio
falfaroc Dec 9, 2024
d4897b0
Use modified Authentication in goscaleio
falfaroc Dec 9, 2024
0e71a35
set timeout for probe calls with long response time
lukeatdell Dec 11, 2024
0483cc0
clarify comment
lukeatdell Dec 11, 2024
e0671d0
handle when one array has a long response time.
lukeatdell Dec 11, 2024
979ebea
optimize GetCapacity
lukeatdell Dec 11, 2024
8204ed1
optimize GetCapacity
lukeatdell Dec 11, 2024
a88e059
tidying
lukeatdell Dec 11, 2024
825b2d7
revert changes to probe calls due to data race
lukeatdell Dec 12, 2024
21e7043
update test context creation
lukeatdell Dec 12, 2024
cf89ec3
update goscaleio for context impl
lukeatdell Dec 13, 2024
cf06c7f
clarify return value for Probe()
lukeatdell Dec 13, 2024
a262f0e
Merge branch 'feature/multi-availability-zone' into usr/falfaroc/mult…
lukeatdell Dec 13, 2024
0b0d135
fix merge issue
lukeatdell Dec 13, 2024
8099403
use withContext from goscaleio
lukeatdell Dec 16, 2024
5978819
refactor changes and add UT
lukeatdell Dec 16, 2024
d0ff2fc
remove debug logs
lukeatdell Dec 17, 2024
addfc10
support context when adding pod labels
lukeatdell Dec 17, 2024
1e0c233
add tests to SetPodZoneLabel
lukeatdell Dec 17, 2024
8011ee1
tidying controller_tests
lukeatdell Dec 17, 2024
7582c91
fix int test
lukeatdell Dec 17, 2024
5415a15
linting
lukeatdell Dec 17, 2024
6671d8d
adding more tests to cover additions
lukeatdell Dec 17, 2024
62be51c
linting
lukeatdell Dec 17, 2024
bab6660
reverting debug changes
lukeatdell Dec 17, 2024
095147b
refactoring
lukeatdell Dec 17, 2024
e636b06
update copyright
lukeatdell Dec 18, 2024
4b71e12
tidying comments
lukeatdell Dec 18, 2024
d82cdfd
fix bug after regression tests
lukeatdell Dec 18, 2024
8939c70
update goscaleio
lukeatdell Dec 18, 2024
90867b3
PR comments: tdawe
lukeatdell Dec 18, 2024
5ea281b
PR comments: falfaroc
lukeatdell Dec 18, 2024
c6e56f5
align tests with new error messages from prev commit
lukeatdell Dec 18, 2024
5f49dac
add tests for systemProbeAll
lukeatdell Dec 18, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
optimize GetCapacity
lukeatdell committed Dec 11, 2024
commit 979ebeaacd6bfbe26388e676f4b5ed66174b07f7
15 changes: 7 additions & 8 deletions service/controller.go
Original file line number Diff line number Diff line change
@@ -2379,14 +2379,13 @@ func (s *service) GetCapacity(
// If using availability zones, get capacity for the system in the zone
// using accessible topology parameter from k8s.
if s.opts.zoneLabelKey != "" {
for topoKey, topoValue := range req.AccessibleTopology.Segments {
if topoKey == s.opts.zoneLabelKey {
for _, array := range s.opts.arrays {
if topoValue == string(array.AvailabilityZone.Name) {
systemID = array.SystemID
break
}
}
zoneLabel, ok := req.AccessibleTopology.Segments[s.opts.zoneLabelKey]
if !ok {
Log.Infof("could not get availability zone from accessible topology. Getting capacity for all systems")
}
for _, array := range s.opts.arrays {
if zoneLabel == string(array.AvailabilityZone.Name) {
systemID = array.SystemID
break
}
}