Commit 1a4aa2eb authored by Danyal Prout's avatar Danyal Prout

Review feedback

parent 3b232e74
......@@ -691,10 +691,10 @@ func sortBatchRPCResponse(req []*RPCReq, res []*RPCRes) {
}
type BackendGroup struct {
Name string
Backends []*Backend
UseWeightedRouting bool
Consensus *ConsensusPoller
Name string
Backends []*Backend
WeightedRouting bool
Consensus *ConsensusPoller
}
func (bg *BackendGroup) Forward(ctx context.Context, rpcReqs []*RPCReq, isBatch bool) ([]*RPCRes, string, error) {
......@@ -750,7 +750,7 @@ func (bg *BackendGroup) Forward(ctx context.Context, rpcReqs []*RPCReq, isBatch
}
}
rpcReqs = rewrittenReqs
} else if bg.UseWeightedRouting {
} else if bg.WeightedRouting {
backends = randomizeFirstBackendByWeight(backends)
}
......@@ -820,7 +820,7 @@ func (bg *BackendGroup) Forward(ctx context.Context, rpcReqs []*RPCReq, isBatch
}
func randomizeFirstBackendByWeight(backends []*Backend) []*Backend {
if len(backends) == 0 {
if len(backends) <= 1 {
return backends
}
......@@ -916,7 +916,7 @@ func (bg *BackendGroup) loadBalancedConsensusGroup() []*Backend {
backendsDegraded[i], backendsDegraded[j] = backendsDegraded[j], backendsDegraded[i]
})
if bg.UseWeightedRouting {
if bg.WeightedRouting {
backendsHealthy = randomizeFirstBackendByWeight(backendsHealthy)
backendsDegraded = randomizeFirstBackendByWeight(backendsDegraded)
}
......
......@@ -95,11 +95,11 @@ type BackendConfig struct {
ClientKeyFile string `toml:"client_key_file"`
StripTrailingXFF bool `toml:"strip_trailing_xff"`
Weight int `toml:"weight"`
ConsensusSkipPeerCountCheck bool `toml:"consensus_skip_peer_count"`
ConsensusForcedCandidate bool `toml:"consensus_forced_candidate"`
ConsensusReceiptsTarget string `toml:"consensus_receipts_target"`
Weight int `toml:"weight"`
}
type BackendsConfig map[string]*BackendConfig
......@@ -107,7 +107,7 @@ type BackendsConfig map[string]*BackendConfig
type BackendGroupConfig struct {
Backends []string `toml:"backends"`
UseWeightedRouting bool `toml:"weighted_routing"`
WeightedRouting bool `toml:"weighted_routing"`
ConsensusAware bool `toml:"consensus_aware"`
ConsensusAsyncHandler string `toml:"consensus_handler"`
......
......@@ -176,9 +176,9 @@ func Start(config *Config) (*Server, func(), error) {
backends = append(backends, backendsByName[bName])
}
group := &BackendGroup{
Name: bgName,
UseWeightedRouting: bg.UseWeightedRouting,
Backends: backends,
Name: bgName,
WeightedRouting: bg.WeightedRouting,
Backends: backends,
}
backendGroups[bgName] = group
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment