diff options
| author | 2025-03-09 17:47:56 +0100 | |
|---|---|---|
| committer | 2025-12-01 22:08:04 +0100 | |
| commit | b1af8fd87760b34e3ff2fd3bda38f211815a0473 (patch) | |
| tree | 9317fad1a7ec298d7a8d2678e4e422953bbc6f33 /vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go | |
| parent | [chore] update URLs to forked source (diff) | |
| download | gotosocial-b1af8fd87760b34e3ff2fd3bda38f211815a0473.tar.xz | |
[chore] remove vendor
Diffstat (limited to 'vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go')
| -rw-r--r-- | vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go | 72 |
1 files changed, 0 insertions, 72 deletions
diff --git a/vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go b/vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go deleted file mode 100644 index 22045bf39..000000000 --- a/vendor/google.golang.org/grpc/balancer/roundrobin/roundrobin.go +++ /dev/null @@ -1,72 +0,0 @@ -/* - * - * Copyright 2017 gRPC authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -// Package roundrobin defines a roundrobin balancer. Roundrobin balancer is -// installed as one of the default balancers in gRPC, users don't need to -// explicitly install this balancer. -package roundrobin - -import ( - "fmt" - - "google.golang.org/grpc/balancer" - "google.golang.org/grpc/balancer/endpointsharding" - "google.golang.org/grpc/balancer/pickfirst/pickfirstleaf" - "google.golang.org/grpc/grpclog" - internalgrpclog "google.golang.org/grpc/internal/grpclog" -) - -// Name is the name of round_robin balancer. -const Name = "round_robin" - -var logger = grpclog.Component("roundrobin") - -func init() { - balancer.Register(builder{}) -} - -type builder struct{} - -func (bb builder) Name() string { - return Name -} - -func (bb builder) Build(cc balancer.ClientConn, opts balancer.BuildOptions) balancer.Balancer { - childBuilder := balancer.Get(pickfirstleaf.Name).Build - bal := &rrBalancer{ - cc: cc, - Balancer: endpointsharding.NewBalancer(cc, opts, childBuilder, endpointsharding.Options{}), - } - bal.logger = internalgrpclog.NewPrefixLogger(logger, fmt.Sprintf("[%p] ", bal)) - bal.logger.Infof("Created") - return bal -} - -type rrBalancer struct { - balancer.Balancer - cc balancer.ClientConn - logger *internalgrpclog.PrefixLogger -} - -func (b *rrBalancer) UpdateClientConnState(ccs balancer.ClientConnState) error { - return b.Balancer.UpdateClientConnState(balancer.ClientConnState{ - // Enable the health listener in pickfirst children for client side health - // checks and outlier detection, if configured. - ResolverState: pickfirstleaf.EnableHealthListener(ccs.ResolverState), - }) -} |
