naming

Documentation

Index

• Constants
• Variables
• func ActiveServers(cluster string) ([]string, error)
• func Heartbeat(ctx context.Context) error
• func IamLeader(cluster string) (bool, error)
• func NewConsistentHashRing(replicas int32, nodes []string) *consistent.Consistent
• func RebuildConsistentHashRing(cluster string, nodes []string)
• type ClusterHashRingType
  • func (chr *ClusterHashRingType) GetNode(cluster, pk string) (string, error)
  • func (chr *ClusterHashRingType) IsHit(cluster string, pk string, currentNode string) bool
  • func (chr *ClusterHashRingType) Set(cluster string, r *consistent.Consistent)

Constants

const NodeReplicas = 500

Variables

var ClusterHashRing = ClusterHashRingType{Rings: make(map[string]*consistent.Consistent)}

for alert_rule sharding

Functions

func ActiveServers

func ActiveServers(cluster string) ([]string, error)

func Heartbeat

func Heartbeat(ctx context.Context) error

func IamLeader

func IamLeader(cluster string) (bool, error)

func NewConsistentHashRing

func NewConsistentHashRing(replicas int32, nodes []string) *consistent.Consistent

func RebuildConsistentHashRing

func RebuildConsistentHashRing(cluster string, nodes []string)

Types

type ClusterHashRingType

type ClusterHashRingType struct {
	sync.RWMutex
	Rings map[string]*consistent.Consistent
}

func (*ClusterHashRingType) GetNode

func (chr *ClusterHashRingType) GetNode(cluster, pk string) (string, error)

func (*ClusterHashRingType) IsHit

func (chr *ClusterHashRingType) IsHit(cluster string, pk string, currentNode string) bool

func (*ClusterHashRingType) Set

func (chr *ClusterHashRingType) Set(cluster string, r *consistent.Consistent)