hashring

Documentation

Index

• func AddOrUpdateHashRing(key string, c *consistent.Consistent)
• func DeleteHashRing(key string)
• func GetHashRing(key string) (*consistent.Consistent, bool)
• func NewServiceInstanceHashRing(instances []ServiceInstance) *consistent.Consistent
• func RangeHashRing(fn func(key, value interface{}) bool)
• func SplitKey(key string) (namespace, name, instanceName string, err error)
• type ServiceInstance
  • func (si ServiceInstance) String() string

Functions

func AddOrUpdateHashRing

func AddOrUpdateHashRing(key string, c *consistent.Consistent)

AddOrUpdateHashRing adds or updates a hash ring in cache

func DeleteHashRing

func DeleteHashRing(key string)

DeleteHashRing deletes a hash ring from cache

func GetHashRing

func GetHashRing(key string) (*consistent.Consistent, bool)

GetHashRing returns a hash ring from cache

func NewServiceInstanceHashRing

func NewServiceInstanceHashRing(instances []ServiceInstance) *consistent.Consistent

func RangeHashRing

func RangeHashRing(fn func(key, value interface{}) bool)

RangeHashRing ranges all hash rings

func SplitKey

func SplitKey(key string) (namespace, name, instanceName string, err error)

Types

type ServiceInstance

type ServiceInstance struct {
	Namespace    string
	Name         string
	InstanceName string
}

ServiceInstance is the implementation of the consistent.Member interface

func (ServiceInstance) String

func (si ServiceInstance) String() string

String gets service instance key