ketama

Documentation

Index

• Constants
• func New(key string, h func() hash.Hash32) balancer.Builder
• type Picker
  • func (this *Picker) Pick(info balancer.PickInfo) (balancer.PickResult, error)
• type PickerBuilder
  • func (this *PickerBuilder) Build(info base.PickerBuildInfo) balancer.Picker

Constants

const Name = "ngrpc_balancer_ketama"

Functions

func New

func New(key string, h func() hash.Hash32) balancer.Builder

New 创建一致性 Hash 负载均衡器

使用： grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, ketama.Name))

Types

type Picker

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

func (*Picker) Pick

func (this *Picker) Pick(info balancer.PickInfo) (balancer.PickResult, error)

type PickerBuilder

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

func (*PickerBuilder) Build

func (this *PickerBuilder) Build(info base.PickerBuildInfo) balancer.Picker