node

Documentation

Index

• Constants
• func RenameDir(oldDir, newDir string) error
• func SelectIdleFiles(dir string, count uint32) ([]string, error)
• type Bucket
• type Node
  • func New() *Node
  • func (n *Node) GetAllPeerId() []string
  • func (n *Node) GetPeer(peerid string) (peer.AddrInfo, bool)
  • func (n *Node) HasPeer(peerid string) bool
  • func (n *Node) RebuildDirs()
  • func (n *Node) Run()
  • func (n *Node) SavePeer(peerid string, addr peer.AddrInfo)
  • func (n *Node) SetPublickey(pubkey []byte) error
  • func (n *Node) TaskMgt()
• type ProofFileType
• type RandomList
• type T

Constants

const (
	Active = iota
	Calculate
	Missing
	Recovery
)

const (
	Cach_prefix_metadata = "metadata:"
	//Cach_prefix_report       = "report:"
	Cach_prefix_idle         = "idle:"
	Cach_prefix_idleSiama    = "sigmaidle:"
	Cach_prefix_serviceSiama = "sigmaservice:"
	// Cach_AggrProof_Reported    = "AggrProofReported"
	Cach_AggrProof_Transfered  = "AggrProofTransfered"
	Cach_IdleChallengeBlock    = "ChallengeIdleBlock"
	Cach_ServiceChallengeBlock = "ChallengeServiceBlock"
	Cach_prefix_MyLost         = "mylost:"
	Cach_prefix_recovery       = "recovery:"
	Cach_prefix_TargetMiner    = "targetminer:"
	Cach_prefix_File           = "file:"
	Cach_prefix_ParseBlock     = "parseblocks"
)

const MaxReplaceFiles = 30

const P2PResponseOK uint32 = 200

Functions

func RenameDir

func RenameDir(oldDir, newDir string) error

func SelectIdleFiles

func SelectIdleFiles(dir string, count uint32) ([]string, error)

Types

type Bucket

type Bucket interface {
	Run()
}

type Node

type Node struct {
	confile.Confile
	logger.Logger
	cache.Cache
	sdk.SDK
	// 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() []string

func (*Node) GetPeer

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

func (*Node) HasPeer

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

func (*Node) RebuildDirs

func (n *Node) RebuildDirs()

func (*Node) Run

func (n *Node) Run()

func (*Node) SavePeer

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

func (*Node) SetPublickey

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

func (*Node) TaskMgt

func (n *Node) TaskMgt()

type ProofFileType

type ProofFileType struct {
	Names []string `json:"names"`
	Us    []string `json:"us"`
	Mus   []string `json:"mus"`
	Sigma string   `json:"sigma"`
}

type RandomList

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

type T

type T struct {
	Name string   `json:"name"`
	U    string   `json:"u"`
	Phi  []string `json:"phi"`
}