scache

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
  • func (c *CollectCacheMap) GetBy(endpoint string) *model.Collect
  • func (c *CollectCacheMap) Set(endpoint string, collect *model.Collect)
  • func (c *CollectCacheMap) SetAll(strasMap map[string]*model.Collect)
• type ConsistentHashRing
  • func NewConsistentHashRing(replicas int32, nodes []string) *ConsistentHashRing
  • func (r *ConsistentHashRing) GetNode(pk string) (string, error)
  • func (r *ConsistentHashRing) GetRing() *consistent.Consistent
  • func (r *ConsistentHashRing) Set(ring *consistent.Consistent)
• type NodeMap
  • func NewNodeMap() NodeMap
  • func (n *NodeMap) GetInstanceBy(node string) (string, bool)
  • func (n *NodeMap) GetNodeBy(instance string) (string, bool)
  • func (n *NodeMap) GetNodes() []string
  • func (n *NodeMap) Len() int
  • func (n *NodeMap) Set(nodeMap map[string]string)
• type StraCacheMap
  • func NewStraCache() *StraCacheMap
  • func (s *StraCacheMap) GetAll() []*model.Stra
  • func (s *StraCacheMap) GetByNode(node string) []*model.Stra
  • func (s *StraCacheMap) Set(node string, stras []*model.Stra)
  • func (s *StraCacheMap) SetAll(strasMap map[string][]*model.Stra)

Variables

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)