dnm

Documentation

Index

• type NodeRecordSys
  • func NewRecordSys(db *uleveldb.ULevelDB) *NodeRecordSys
  • func (r *NodeRecordSys) Add(cid string, name string) error
  • func (r *NodeRecordSys) Get(cid string) (string, error)
  • func (r *NodeRecordSys) GetCanUseNode() string
  • func (r *NodeRecordSys) GetNameUseIp(ip string) (string, error)
  • func (r *NodeRecordSys) HandleDagNode(cons []*dagnode.DataNodeClient, name string) error
  • func (r *NodeRecordSys) Remove(name, dataName string)

Types

type NodeRecordSys

type NodeRecordSys struct {
	Db       *uleveldb.ULevelDB
	RN       map[string]*dagNodeInfo
	NodeLock sync.Mutex
}

NodeRecordSys is a struct for record the dag node

func NewRecordSys

func NewRecordSys(db *uleveldb.ULevelDB) *NodeRecordSys

NewRecordSys create a new record system

func (*NodeRecordSys) Add

func (r *NodeRecordSys) Add(cid string, name string) error

Add a new record

func (*NodeRecordSys) Get

func (r *NodeRecordSys) Get(cid string) (string, error)

Get a record by cid

func (*NodeRecordSys) GetCanUseNode

func (r *NodeRecordSys) GetCanUseNode() string

GetCanUseNode get the can use node

func (*NodeRecordSys) GetNameUseIp

func (r *NodeRecordSys) GetNameUseIp(ip string) (string, error)

GetNameUseIp get the name by ip

func (*NodeRecordSys) HandleDagNode

func (r *NodeRecordSys) HandleDagNode(cons []*dagnode.DataNodeClient, name string) error

HandleDagNode handle the dag node

func (*NodeRecordSys) Remove

func (r *NodeRecordSys) Remove(name, dataName string)

Remove a record