hash

package

v0.0.4 Latest Latest Go to latest Published: Apr 29, 2024 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Conn represents a connection with its address.

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

ConsistentHashBalancer uses consistent hashing to distribute load among connected backends.

func (b *ConsistentHashBalancer) Close()

Close closes the balancer and cleans up resources.

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

HandleSubConnStateChange updates the state of a SubConn.

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

Pick selects a server connection using consistent hashing.

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

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

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

ConsistentHashBalancerBuilder constructs ConsistentHashBalancer instances.

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

Build builds a new ConsistentHashBalancer with the provided PickerBuildInfo.

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

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

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

Pick selects a connection using a simple hash function.

type SimpleHashBalancerBuilder struct {
	Filter loadbalance.Filter
}

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