naming

Documentation

Index

• Constants
• Variables
• func NewConsistentHashRing(replicas int32, nodes []string) *consistent.Consistent
• func RebuildConsistentHashRing(datasourceId int64, nodes []string)
• type DatasourceHashRingType
  • func (chr *DatasourceHashRingType) GetNode(datasourceId int64, pk string) (string, error)
  • func (chr *DatasourceHashRingType) IsHit(datasourceId int64, pk string, currentNode string) bool
  • func (chr *DatasourceHashRingType) Set(datasourceId int64, r *consistent.Consistent)
• type Naming
  • func NewNaming(ctx *ctx.Context, heartbeat aconf.HeartbeatConfig, isCenter bool) *Naming
  • func (n *Naming) ActiveServers(datasourceId int64) ([]string, error)
  • func (n *Naming) DeleteInactiveInstances()
  • func (n *Naming) Heartbeats() error

Constants

const NodeReplicas = 500

Variables

var DatasourceHashRing = DatasourceHashRingType{Rings: make(map[int64]*consistent.Consistent)}

var HostDatasource int64 = 100000

for alert_rule sharding

Functions

func NewConsistentHashRing

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

func RebuildConsistentHashRing

func RebuildConsistentHashRing(datasourceId int64, nodes []string)

Types

type DatasourceHashRingType

type DatasourceHashRingType struct {
	sync.RWMutex
	Rings map[int64]*consistent.Consistent
}

func (*DatasourceHashRingType) GetNode

func (chr *DatasourceHashRingType) GetNode(datasourceId int64, pk string) (string, error)

func (*DatasourceHashRingType) IsHit

func (chr *DatasourceHashRingType) IsHit(datasourceId int64, pk string, currentNode string) bool

func (*DatasourceHashRingType) Set

func (chr *DatasourceHashRingType) Set(datasourceId int64, r *consistent.Consistent)

type Naming

type Naming struct {
	// contains filtered or unexported fields
}

func NewNaming

func NewNaming(ctx *ctx.Context, heartbeat aconf.HeartbeatConfig, isCenter bool) *Naming

func (*Naming) ActiveServers

func (n *Naming) ActiveServers(datasourceId int64) ([]string, error)

func (*Naming) DeleteInactiveInstances

func (n *Naming) DeleteInactiveInstances()

func (*Naming) Heartbeats

func (n *Naming) Heartbeats() error