core

package

v0.0.0-...-61db174 Latest Latest Go to latest Published: Aug 16, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrHostAlreadyExists = errors.New("host already exists")
	ErrHostNotFound      = errors.New("host not found")
)

This section is empty.

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

ConsistentHash is an implementation of consistent-hashing-algorithm

func NewConsistent(replicaNum int, hashFunc func(key string) uint64) *ConsistentHash

NewConsistent creates a consistent-hashing-algorithm

func (ch *ConsistentHash) DecLoad(address string)

DecLoad 递减缓存服务器的负载

func (ch *ConsistentHash) GetHostByKey(key string) (string, error)

GetHostByKey 根据Key查询Host

func (ch *ConsistentHash) GetHostByKeyLeast(key string) (string, error)

GetHostByKeyLeast 有界负载的一致性哈希

func (ch *ConsistentHash) GetLoads() map[string]int64

GetLoads 获取所有缓存服务器的负载数据

func (ch *ConsistentHash) IncLoad(address string)

IncLoad 递增缓存服务器的负载

func (ch *ConsistentHash) MaxLoad() int64

MaxLoad 获取单节点的最大负载 (total_load / number_of_hosts) * (1 + load_bound_factor)

func (ch *ConsistentHash) RegisterHost(address string) error

RegisterHost 注册缓存服务器

func (ch *ConsistentHash) UnregisterHost(address string) error

UnregisterHost 注销缓存服务器

type Host struct {
	// Address host:port
	Address string
	// LoadBound 缓存服务器的负载
	LoadBound int64
}