ringhash

Documentation

Index

• Constants
• func IPToUInt32(ip string) uint32
• type Config
  • func (c *Config) SetDefault()
  • func (c *Config) Verify() error
• type ContinuumSelector
  • func NewContinuum(instanceSet *model.InstanceSet, vnodeCount int, hashFunc hash.HashFuncWithSeed, ...) (*ContinuumSelector, error)
  • func (c *ContinuumSelector) Select(value interface{}) (int, *model.ReplicateNodes, error)
  • func (c ContinuumSelector) String() string
• type KetamaLoadBalancer
  • func (k *KetamaLoadBalancer) ChooseInstance(criteria *loadbalancer.Criteria, inputInstances model.ServiceInstances) (model.Instance, error)
  • func (k *KetamaLoadBalancer) Destroy() error
  • func (k *KetamaLoadBalancer) Init(ctx *plugin.InitContext) error
  • func (k *KetamaLoadBalancer) Name() string
  • func (k *KetamaLoadBalancer) Type() common.Type
• type L5CSTLoadBalancer
  • func (l *L5CSTLoadBalancer) ChooseInstance(criteria *loadbalancer.Criteria, inputInstances model.ServiceInstances) (model.Instance, error)
  • func (l *L5CSTLoadBalancer) Init(ctx *plugin.InitContext) error
  • func (l *L5CSTLoadBalancer) Name() string
  • func (l *L5CSTLoadBalancer) Type() common.Type
• type L5ContinuumSelector
  • func NewL5Continuum(instanceSet *model.InstanceSet, id int32) (*L5ContinuumSelector, error)
  • func (c *L5ContinuumSelector) Select(value interface{}) (int, *model.ReplicateNodes, error)

Constants

const (
	// 默认虚拟节点数
	DefaultVnodeCount = 10
)

Functions

func IPToUInt32

func IPToUInt32(ip string) uint32

IPToUInt32 ip转uint32

Types

type Config

type Config struct {
	HashFunction string `yaml:"hashFunction" json:"hashFunction"`
	VnodeCount   int    `yaml:"vnodeCount" json:"vnodeCount"`
}

一致性hash配置对象

func (*Config) SetDefault

func (c *Config) SetDefault()

设置一致性hash默认值

func (*Config) Verify

func (c *Config) Verify() error

检验一致性hash配置

type ContinuumSelector

type ContinuumSelector struct {
	model.SelectorBase
	// contains filtered or unexported fields
}

一致性hash环

func NewContinuum

func NewContinuum(
	instanceSet *model.InstanceSet, vnodeCount int, hashFunc hash.HashFuncWithSeed, id int32) (*ContinuumSelector, error)

创建hash环

func (*ContinuumSelector) Select

func (c *ContinuumSelector) Select(value interface{}) (int, *model.ReplicateNodes, error)

选择实例下标

func (ContinuumSelector) String

func (c ContinuumSelector) String() string

打印hash环

type KetamaLoadBalancer

type KetamaLoadBalancer struct {
	*plugin.PluginBase
	// contains filtered or unexported fields
}

ketama算法的一致性hash负载均衡器

func (*KetamaLoadBalancer) ChooseInstance

func (k *KetamaLoadBalancer) ChooseInstance(criteria *loadbalancer.Criteria,
	inputInstances model.ServiceInstances) (model.Instance, error)

ChooseInstance 获取单个服务实例

func (*KetamaLoadBalancer) Destroy

func (k *KetamaLoadBalancer) Destroy() error

销毁插件，可用于释放资源

func (*KetamaLoadBalancer) Init

func (k *KetamaLoadBalancer) Init(ctx *plugin.InitContext) error

初始化插件

func (*KetamaLoadBalancer) Name

func (k *KetamaLoadBalancer) Name() string

插件名，一个类型下插件名唯一

func (*KetamaLoadBalancer) Type

func (k *KetamaLoadBalancer) Type() common.Type

插件类型

type L5CSTLoadBalancer

type L5CSTLoadBalancer struct {
	*plugin.PluginBase
}

l5一致性算法的hash负载均衡器

func (*L5CSTLoadBalancer) ChooseInstance

func (l *L5CSTLoadBalancer) ChooseInstance(criteria *loadbalancer.Criteria,
	inputInstances model.ServiceInstances) (model.Instance, error)

ChooseInstance 获取单个服务实例

func (*L5CSTLoadBalancer) Init

func (l *L5CSTLoadBalancer) Init(ctx *plugin.InitContext) error

初始化插件

func (*L5CSTLoadBalancer) Name

func (l *L5CSTLoadBalancer) Name() string

插件名，一个类型下插件名唯一

func (*L5CSTLoadBalancer) Type

func (l *L5CSTLoadBalancer) Type() common.Type

插件类型

type L5ContinuumSelector

type L5ContinuumSelector struct {
	model.SelectorBase
	// contains filtered or unexported fields
}

L5ContinuumSelector 一致性hash环

func NewL5Continuum

func NewL5Continuum(
	instanceSet *model.InstanceSet, id int32) (*L5ContinuumSelector, error)

NewL5Continuum 创建hash环

func (*L5ContinuumSelector) Select

func (c *L5ContinuumSelector) Select(value interface{}) (int, *model.ReplicateNodes, error)

Select 选择实例下标