chash

Documentation

Index

• type HashingBalancer
  • func NewBalancer(proxies []proxy.Proxy, hashon string) *HashingBalancer
  • func (b *HashingBalancer) Proxies() []proxy.Proxy
  • func (b *HashingBalancer) Select(ctx context.Context, c *app.RequestContext) (proxy.Proxy, error)

Types

type HashingBalancer

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

HashingBalancer implements a consistent hashing balancer with virtual nodes.

func NewBalancer

func NewBalancer(proxies []proxy.Proxy, hashon string) *HashingBalancer

NewBalancer creates a new HashingBalancer instance. It initializes the hash ring with virtual nodes for each proxy.

func (*HashingBalancer) Proxies

func (b *HashingBalancer) Proxies() []proxy.Proxy

Proxies returns the list of proxies managed by the balancer.

func (*HashingBalancer) Select

func (b *HashingBalancer) Select(ctx context.Context, c *app.RequestContext) (proxy.Proxy, error)

Select picks a proxy from the hash ring based on a hashed value from the request. If the selected proxy is unavailable, it moves clockwise along the ring to find the next available one.