The highest tagged major version is v5.

scache

package

v1.4.0 Latest Latest Go to latest Published: Jun 13, 2020 License: Apache-2.0 Imports: 7 Imported by: 3

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

Repository

github.com/didi/nightingale

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetLeafNids(nid int64, exclNid []int64) ([]int64, error)
func Init()
func RebuildConsistentHashRing(hashRing *ConsistentHashRing, nodes []string, replicas int)
func SyncCollects()
func SyncStras()
type CollectCacheMap
- func NewCollectCache() *CollectCacheMap
type ConsistentHashRing
- func NewConsistentHashRing(replicas int32, nodes []string) *ConsistentHashRing
type NodeMap
- func NewNodeMap() NodeMap
type StraCacheMap
- func NewStraCache() *StraCacheMap

Constants ¶

This section is empty.

Variables ¶

View Source

var JudgeActiveNode = NewNodeMap()

Functions ¶

func GetLeafNids ¶

func GetLeafNids(nid int64, exclNid []int64) ([]int64, error)

func Init ¶

func Init()

func RebuildConsistentHashRing ¶

func RebuildConsistentHashRing(hashRing *ConsistentHashRing, nodes []string, replicas int)

func SyncCollects ¶

func SyncCollects()

func SyncStras ¶

func SyncStras()

Types ¶

type CollectCacheMap ¶

type CollectCacheMap struct {
	sync.RWMutex
	Data map[string]*model.Collect
}

var CollectCache *CollectCacheMap

func NewCollectCache ¶

func NewCollectCache() *CollectCacheMap

func (*CollectCacheMap) GetBy ¶

func (c *CollectCacheMap) GetBy(endpoint string) *model.Collect

func (*CollectCacheMap) Set ¶

func (c *CollectCacheMap) Set(endpoint string, collect *model.Collect)

func (*CollectCacheMap) SetAll ¶

func (c *CollectCacheMap) SetAll(strasMap map[string]*model.Collect)

type ConsistentHashRing ¶

type ConsistentHashRing struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var JudgeHashRing *ConsistentHashRing

func NewConsistentHashRing ¶

func NewConsistentHashRing(replicas int32, nodes []string) *ConsistentHashRing

func (*ConsistentHashRing) GetNode ¶

func (r *ConsistentHashRing) GetNode(pk string) (string, error)

func (*ConsistentHashRing) GetRing ¶

func (r *ConsistentHashRing) GetRing() *consistent.Consistent

func (*ConsistentHashRing) Set ¶

func (r *ConsistentHashRing) Set(ring *consistent.Consistent)

type NodeMap ¶

type NodeMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNodeMap ¶

func NewNodeMap() NodeMap

func (*NodeMap) GetInstanceBy ¶

func (n *NodeMap) GetInstanceBy(node string) (string, bool)

func (*NodeMap) GetNodeBy ¶

func (n *NodeMap) GetNodeBy(instance string) (string, bool)

func (*NodeMap) GetNodes ¶

func (n *NodeMap) GetNodes() []string

func (*NodeMap) Len ¶

func (n *NodeMap) Len() int

func (*NodeMap) Set ¶

func (n *NodeMap) Set(nodeMap map[string]string)

type StraCacheMap ¶

type StraCacheMap struct {
	sync.RWMutex
	Data map[string][]*model.Stra
}

var StraCache *StraCacheMap

func NewStraCache ¶

func NewStraCache() *StraCacheMap

func (*StraCacheMap) GetAll ¶

func (s *StraCacheMap) GetAll() []*model.Stra

func (*StraCacheMap) GetByNode ¶

func (s *StraCacheMap) GetByNode(node string) []*model.Stra

func (*StraCacheMap) Set ¶

func (s *StraCacheMap) Set(node string, stras []*model.Stra)

func (*StraCacheMap) SetAll ¶

func (s *StraCacheMap) SetAll(strasMap map[string][]*model.Stra)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL