naming

Documentation

Index

• Constants
• Variables
• func ActiveServers(ctx context.Context, cluster string) ([]string, error)
• func Heartbeat(ctx context.Context, cfg HeartbeatConfig) error
• func RebuildConsistentHashRing(nodes []string)
• type ConsistentHashRing
  • func NewConsistentHashRing(replicas int32, nodes []string) *ConsistentHashRing
  • func (chr *ConsistentHashRing) GetNode(pk string) (string, error)
  • func (chr *ConsistentHashRing) GetRing() *consistent.Consistent
  • func (chr *ConsistentHashRing) Set(r *consistent.Consistent)
• type HeartbeatConfig

Constants

const NodeReplicas = 500

Variables

var HashRing = NewConsistentHashRing(int32(NodeReplicas), []string{})

for alert_rule sharding

Functions

func ActiveServers

func ActiveServers(ctx context.Context, cluster string) ([]string, error)

func Heartbeat

func Heartbeat(ctx context.Context, cfg HeartbeatConfig) error

func RebuildConsistentHashRing

func RebuildConsistentHashRing(nodes []string)

Types

type ConsistentHashRing

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

func NewConsistentHashRing

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

func (*ConsistentHashRing) GetNode

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

func (*ConsistentHashRing) GetRing

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

func (*ConsistentHashRing) Set

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

type HeartbeatConfig

type HeartbeatConfig struct {
	IP       string
	Interval int64
	Endpoint string
	Cluster  string
}