[go: nahoru, domu]
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

Jump to bottom

examples: Add custom load balancer example #6691

Merged
merged 20 commits into from
Apr 17, 2024
Merged

examples: Add custom load balancer example #6691

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
df3e8f5
Add custom lb example
zasweq Oct 3, 2023
c6bc434
Responded to Doug's comments
zasweq Mar 27, 2024
07df211
Add balancer aggregator
zasweq Mar 28, 2024
03a9363
Responded to Doug's comments
zasweq Mar 29, 2024
92ab13e
Implemented offline discussion
zasweq Apr 1, 2024
56c1b45
Fix vet
zasweq Apr 2, 2024
02589a6
Vet
zasweq Apr 2, 2024
f773141
Error early in UpdateClientConnState on empty endpoints list
zasweq Apr 2, 2024
4a72716
Responded to all comments except race condition
zasweq Apr 4, 2024
c1d0178
Fix race condition
zasweq Apr 4, 2024
94bef61
Doug's comments and sync picker updates upward, and fix race on bool
zasweq Apr 4, 2024
e33e4ed
Unexport balancerAggregator
zasweq Apr 4, 2024
436afcc
Responded to Doug's comments
zasweq Apr 9, 2024
ddc8c0a
Switched unsafe to atomic pointer
zasweq Apr 9, 2024
8b60402
Responded to Doug's comments
zasweq Apr 10, 2024
9985a3e
Vet
zasweq Apr 10, 2024
03036ce
Responded to Doug's comments
zasweq Apr 12, 2024
aead17f
Fix tests
zasweq Apr 12, 2024
1ef2e43
Moved config init to init function
zasweq Apr 15, 2024
7af9e93
Responded to Doug's comments
zasweq Apr 17, 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
Moved config init to init function
  • Loading branch information
@zasweq
zasweq committed Apr 15, 2024
commit 1ef2e437f3fe7818696b348dd64d8d3593f12758
4 changes: 3 additions & 1 deletion examples/features/customloadbalancer/client/customroundrobin/customroundrobin.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,11 @@ import (
"google.golang.org/grpc/serviceconfig"
)

var gracefulSwitchPickFirst serviceconfig.LoadBalancingConfig

func init() {
balancer.Register(customRoundRobinBuilder{})
gracefulSwitchPickFirst, _ = endpointsharding.ParseConfig(json.RawMessage(endpointsharding.PickFirstConfig))
dfawley marked this conversation as resolved.
Show resolved Hide resolved
}

const customRRName = "custom_round_robin"
Expand Down Expand Up @@ -99,7 +102,6 @@ func (crr *customRoundRobin) UpdateClientConnState(state balancer.ClientConnStat
// A call to UpdateClientConnState should always produce a new Picker. That
// is guaranteed to happen since the aggregator will always call
// UpdateChildState in its UpdateClientConnState.
gracefulSwitchPickFirst, _ := endpointsharding.ParseConfig(json.RawMessage(endpointsharding.PickFirstConfig))
return crr.Balancer.UpdateClientConnState(balancer.ClientConnState{
dfawley marked this conversation as resolved.
Show resolved Hide resolved
BalancerConfig: gracefulSwitchPickFirst,
ResolverState: state.ResolverState,
Expand Down
Loading