node

Documentation

Index

• Constants
• func RenameDir(oldDir, newDir string) error
• type DataDir
• type Node
  • func New() *Node
  • func (n *Node) GetAllPeerID() []peer.ID
  • func (n *Node) GetAllPeerIDMap() map[string]peer.AddrInfo
  • func (n *Node) GetAllPeerIdString() []string
  • func (n *Node) GetAllTeeWorkAccount() []string
  • func (n *Node) GetAllTeeWorkPeerId() [][]byte
  • func (n *Node) GetAllTeeWorkPeerIdString() []string
  • func (n *Node) GetPeer(peerid string) (peer.AddrInfo, bool)
  • func (n *Node) GetTeeWork(account string) ([]byte, bool)
  • func (n *Node) HasPeer(peerid string) bool
  • func (n *Node) InitPois(front, rear, freeSpace, count int64, key_n, key_g big.Int) error
  • func (n *Node) LoadPeersFromDisk(path string) error
  • func (n *Node) RebuildDirs()
  • func (n *Node) RemovePeerIntranetAddr()
  • func (n *Node) Run()
  • func (n *Node) SaveOrUpdatePeerUnSafe(peerid string, addr peer.AddrInfo)
  • func (n *Node) SavePeer(peerid string, addr peer.AddrInfo)
  • func (n *Node) SavePeersToDisk(path string) error
  • func (n *Node) SaveTeeWork(account string, peerid []byte)
  • func (n *Node) SetPublickey(pubkey []byte) error
• type Pois
• type RandomList

Constants

const (
	Active = iota
	Calculate
	Missing
	Recovery
)

const (
	Cach_prefix_metadata    = "metadata:"
	Cach_prefix_MyLost      = "mylost:"
	Cach_prefix_recovery    = "recovery:"
	Cach_prefix_TargetMiner = "targetminer:"
	Cach_prefix_File        = "file:"
	Cach_prefix_ParseBlock  = "parseblocks"
)

Functions

func RenameDir

func RenameDir(oldDir, newDir string) error

Types

type DataDir

type DataDir struct {
	DbDir     string
	LogDir    string
	SpaceDir  string
	PoisDir   string
	AccDir    string
	RandomDir string
}

type Node

type Node struct {
	DataDir *DataDir

	sdk.SDK
	confile.Confile
	logger.Logger
	cache.Cache
	*Pois
	// contains filtered or unexported fields
}

func New

func New() *Node

New is used to build a node instance

func (*Node) GetAllPeerID

func (n *Node) GetAllPeerID() []peer.ID

func (*Node) GetAllPeerIDMap

func (n *Node) GetAllPeerIDMap() map[string]peer.AddrInfo

func (*Node) GetAllPeerIdString

func (n *Node) GetAllPeerIdString() []string

func (*Node) GetAllTeeWorkAccount

func (n *Node) GetAllTeeWorkAccount() []string

func (*Node) GetAllTeeWorkPeerId

func (n *Node) GetAllTeeWorkPeerId() [][]byte

func (*Node) GetAllTeeWorkPeerIdString

func (n *Node) GetAllTeeWorkPeerIdString() []string

func (*Node) GetPeer

func (n *Node) GetPeer(peerid string) (peer.AddrInfo, bool)

func (*Node) GetTeeWork

func (n *Node) GetTeeWork(account string) ([]byte, bool)

func (*Node) HasPeer

func (n *Node) HasPeer(peerid string) bool

func (*Node) InitPois

func (n *Node) InitPois(front, rear, freeSpace, count int64, key_n, key_g big.Int) error

func (*Node) LoadPeersFromDisk

func (n *Node) LoadPeersFromDisk(path string) error

func (*Node) RebuildDirs

func (n *Node) RebuildDirs()

func (*Node) RemovePeerIntranetAddr

func (n *Node) RemovePeerIntranetAddr()

func (*Node) Run

func (n *Node) Run()

func (*Node) SaveOrUpdatePeerUnSafe

func (n *Node) SaveOrUpdatePeerUnSafe(peerid string, addr peer.AddrInfo)

func (*Node) SavePeer

func (n *Node) SavePeer(peerid string, addr peer.AddrInfo)

func (*Node) SavePeersToDisk

func (n *Node) SavePeersToDisk(path string) error

func (*Node) SaveTeeWork

func (n *Node) SaveTeeWork(account string, peerid []byte)

func (*Node) SetPublickey

func (n *Node) SetPublickey(pubkey []byte) error

type Pois

type Pois struct {
	*pois.Prover
	*acc.RsaKey
	pattern.ExpendersInfo
	// contains filtered or unexported fields
}

type RandomList

type RandomList struct {
	Index  []uint32 `json:"index"`
	Random [][]byte `json:"random"`
}