alive

Documentation

Index

• type Alive
  • func NewAlive(expired int) *Alive
  • func (a *Alive) IsAlive(addr string) bool
  • func (a *Alive) LoadBalance(n int) ([]string, error)
  • func (a *Alive) Update(addr string, cap int64)

Types

type Alive

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

Function: Alive is used to update datanode's alived status. Check is datanode alived. Give suitable addresses of datanodes to stored new filekeys.

func NewAlive

func NewAlive(expired int) *Alive

func (*Alive) IsAlive

func (a *Alive) IsAlive(addr string) bool

Check if datanode is alived.

func (*Alive) LoadBalance

func (a *Alive) LoadBalance(n int) ([]string, error)

LoadBalance: sorted by the capacity of datanode. Perfer datanodes with small cap and addresses of returns are unique. Input how many datanode should be returned. But it also depends on how many alived datanodes I have. Return a serious of datanode to stroed related file.

func (*Alive) Update

func (a *Alive) Update(addr string, cap int64)

Update datanode time. (keep alive) If datanode is not register before, then create it in list and map.