resNodeDM

Documentation

Index

• type DirectDB
  • func NewDirectDB(rndb resNodeDB.ResNodeDB) (nmm DirectDB, err error)
  • func (rnm DirectDB) GetAllArray() (nodes []resNode.Node, err error)
  • func (rnm DirectDB) GetAllMap() (nodesMap map[int64]*resNode.Node, err error)
  • func (rnm DirectDB) Insert(node resNode.Node) (err error)
  • func (rnm DirectDB) QueryByID(nodeID int64) (resNode.Node, error)
  • func (rnm DirectDB) Update(node resNode.Node) (err error)
  • func (rnm DirectDB) UpdateNodes(nodes []resNode.Node) (err error)
• type MemoryMap
  • func NewMemoryMap(rndb resNodeDB.ResNodeDB) (nmm MemoryMap, err error)
  • func (rnm MemoryMap) GetAllArray() (nodes []resNode.Node, err error)
  • func (rnm MemoryMap) GetAllMap() (nodesMap map[int64]*resNode.Node, err error)
  • func (rnm MemoryMap) Insert(node resNode.Node) (err error)
  • func (rnm MemoryMap) QueryByID(nodeID int64) (resNode.Node, error)
  • func (rnm MemoryMap) Update(node resNode.Node) (err error)
  • func (rnm MemoryMap) UpdateNodes(nodes []resNode.Node) (err error)
• type ResNodeDM

Types

type DirectDB

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

func NewDirectDB

func NewDirectDB(rndb resNodeDB.ResNodeDB) (nmm DirectDB, err error)

func (DirectDB) GetAllArray

func (rnm DirectDB) GetAllArray() (nodes []resNode.Node, err error)

func (DirectDB) GetAllMap

func (rnm DirectDB) GetAllMap() (nodesMap map[int64]*resNode.Node, err error)

func (DirectDB) Insert

func (rnm DirectDB) Insert(node resNode.Node) (err error)

func (DirectDB) QueryByID

func (rnm DirectDB) QueryByID(nodeID int64) (resNode.Node, error)

func (DirectDB) Update

func (rnm DirectDB) Update(node resNode.Node) (err error)

func (DirectDB) UpdateNodes

func (rnm DirectDB) UpdateNodes(nodes []resNode.Node) (err error)

type MemoryMap

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

func NewMemoryMap

func NewMemoryMap(rndb resNodeDB.ResNodeDB) (nmm MemoryMap, err error)

func (MemoryMap) GetAllArray

func (rnm MemoryMap) GetAllArray() (nodes []resNode.Node, err error)

func (MemoryMap) GetAllMap

func (rnm MemoryMap) GetAllMap() (nodesMap map[int64]*resNode.Node, err error)

func (MemoryMap) Insert

func (rnm MemoryMap) Insert(node resNode.Node) (err error)

func (MemoryMap) QueryByID

func (rnm MemoryMap) QueryByID(nodeID int64) (resNode.Node, error)

func (MemoryMap) Update

func (rnm MemoryMap) Update(node resNode.Node) (err error)

func (MemoryMap) UpdateNodes

func (rnm MemoryMap) UpdateNodes(nodes []resNode.Node) (err error)

type ResNodeDM

type ResNodeDM interface {
	QueryByID(nodeID int64) (resNode.Node, error)
	GetAllArray() (nodes []resNode.Node, err error)
	GetAllMap() (nodesMap map[int64]*resNode.Node, err error)
	Update(node resNode.Node) (err error)
	UpdateNodes(nodes []resNode.Node) (err error)
	Insert(node resNode.Node) (err error)
}