package weightedroundrobin

import "google.golang.org/grpc/balancer/weightedroundrobin"

Package weightedroundrobin provides an implementation of the weighted round robin LB policy, as defined in gRFC A58.

Experimental

Notice: This package is EXPERIMENTAL and may be changed or removed in a later release.

Index ¶

• Constants
• func SetAddrInfo(addr resolver.Address, addrInfo AddrInfo) resolver.Address
• func SetAddrInfoInEndpoint(endpoint resolver.Endpoint, addrInfo AddrInfo) resolver.Endpoint
• type AddrInfo
• func GetAddrInfo(addr resolver.Address) AddrInfo
• func (a AddrInfo) Equal(o any) bool
• func (a AddrInfo) String() string

Constants ¶

const Name = "weighted_round_robin"

Name is the name of the weighted round robin balancer.

Functions ¶

func SetAddrInfo ¶

func SetAddrInfo(addr resolver.Address, addrInfo AddrInfo) resolver.Address

SetAddrInfo returns a copy of addr in which the BalancerAttributes field is updated with addrInfo.

func SetAddrInfoInEndpoint ¶

func SetAddrInfoInEndpoint(endpoint resolver.Endpoint, addrInfo AddrInfo) resolver.Endpoint

SetAddrInfoInEndpoint returns a copy of endpoint in which the Attributes field is updated with addrInfo.

Types ¶

type AddrInfo ¶

type AddrInfo struct {
	Weight uint32
}

AddrInfo will be stored in the BalancerAttributes field of Address in order to use weighted roundrobin balancer.

func GetAddrInfo ¶

func GetAddrInfo(addr resolver.Address) AddrInfo

GetAddrInfo returns the AddrInfo stored in the BalancerAttributes field of addr.

func (AddrInfo) Equal ¶

func (a AddrInfo) Equal(o any) bool

Equal allows the values to be compared by Attributes.Equal.

func (AddrInfo) String ¶

func (a AddrInfo) String() string

Source Files ¶

balancer.go config.go logging.go scheduler.go weightedroundrobin.go

Directories ¶