hash

Documentation

Index

• type Conn
• type ConsistentHashBalancer
  • func (b *ConsistentHashBalancer) Close()
  • func (b *ConsistentHashBalancer) HandleSubConnStateChange(sc balancer.SubConn, state connectivity.State)
  • func (b *ConsistentHashBalancer) Pick(info balancer.PickInfo) (balancer.PickResult, error)
  • func (b *ConsistentHashBalancer) UpdateState(newState resolver.State)
• type ConsistentHashBalancerBuilder
  • func (b *ConsistentHashBalancerBuilder) Build(info base.PickerBuildInfo) balancer.Picker
• type SimpleHashBalancer
  • func (b *SimpleHashBalancer) Pick(info balancer.PickInfo) (balancer.PickResult, error)
• type SimpleHashBalancerBuilder
  • func (b *SimpleHashBalancerBuilder) Build(info base.PickerBuildInfo) balancer.Picker

Types

type Conn

type Conn struct {
	SubConn balancer.SubConn
	Address resolver.Address
}

Conn represents a connection with its address.

type ConsistentHashBalancer

type ConsistentHashBalancer struct {
	// contains filtered or unexported fields
}

ConsistentHashBalancer uses consistent hashing to distribute load among connected backends.

func (*ConsistentHashBalancer) Close

func (b *ConsistentHashBalancer) Close()

Close closes the balancer and cleans up resources.

func (*ConsistentHashBalancer) HandleSubConnStateChange

func (b *ConsistentHashBalancer) HandleSubConnStateChange(sc balancer.SubConn, state connectivity.State)

HandleSubConnStateChange updates the state of a SubConn.

func (*ConsistentHashBalancer) Pick

func (b *ConsistentHashBalancer) Pick(info balancer.PickInfo) (balancer.PickResult, error)

Pick selects a server connection using consistent hashing.

func (*ConsistentHashBalancer) UpdateState

func (b *ConsistentHashBalancer) UpdateState(newState resolver.State)

UpdateState syncs the balancer state with the latest information about backends.

type ConsistentHashBalancerBuilder

type ConsistentHashBalancerBuilder struct {
	// contains filtered or unexported fields
}

ConsistentHashBalancerBuilder constructs ConsistentHashBalancer instances.

func (*ConsistentHashBalancerBuilder) Build

func (b *ConsistentHashBalancerBuilder) Build(info base.PickerBuildInfo) balancer.Picker

Build builds a new ConsistentHashBalancer with the provided PickerBuildInfo.

type SimpleHashBalancer

type SimpleHashBalancer struct {
	// contains filtered or unexported fields
}

SimpleHashBalancer is a load balancer that makes decision based on a hash value.

func (*SimpleHashBalancer) Pick

func (b *SimpleHashBalancer) Pick(info balancer.PickInfo) (balancer.PickResult, error)

Pick selects a connection using a simple hash function.

type SimpleHashBalancerBuilder

type SimpleHashBalancerBuilder struct {
	Filter loadbalance.Filter
}

func (*SimpleHashBalancerBuilder) Build

func (b *SimpleHashBalancerBuilder) Build(info base.PickerBuildInfo) balancer.Picker