node

Feb 22, 2024

Changes in this version

type Node

+ func (n *Node) WatchMem()

Jan 31, 2024

Changes in this version

+ const Cach_prefix_Tag

+ const St_Error

+ const St_Normal

+ const St_Warning

+ const Stage_BuildCache

+ const Stage_BuildDir

+ const Stage_BuildLog

+ const Stage_Complete

+ const Stage_ConnectRpc

+ const Stage_CreateP2p

+ const Stage_QueryChain

+ const Stage_ReadConfig

+ const Stage_Register

+ const Stage_Startup

+ const Stage_SyncBlock

type DataDir

+ Podr2PubkeyFile string

+ type GetStatus interface

+ GetAuthIdleFlag func() bool

+ GetCalcTagFlag func() bool

+ GetCpuCores func() int

+ GetGenIdleFlag func() bool

+ GetInitStage func() [Stage_Complete + 1]string

+ GetLastReconnectRpcTime func() string

+ GetPID func() int32

+ GetReportFileFlag func() bool

+ GetTaskPeriod func() string

+ type MinerState interface

+ GetMinerSpaceInfo func() (uint64, uint64, uint64, uint64)

+ GetMinerState func() string

+ SaveMinerSpaceInfo func(decSpace, validSpace, usedSpace, lockedSpace uint64)

+ SaveMinerState func(state string) error

+ func NewMinerState() MinerState

+ type MinerStateType struct

+ func (m *MinerStateType) GetMinerSpaceInfo() (uint64, uint64, uint64, uint64)

+ func (m *MinerStateType) GetMinerState() string

+ func (m *MinerStateType) SaveMinerSpaceInfo(decSpace, validSpace, usedSpace, lockedSpace uint64)

+ func (m *MinerStateType) SaveMinerState(state string) error

type Node

+ func NewEmptyNode() *Node

+ func (n *Node) ListenLocal()

+ func (n *Node) QueryPeerFromOss(peerid string) (peer.AddrInfo, error)

+ type PeerRecord interface

+ BackupPeer func(path string) error

+ GetAllPeerId func() []string

+ GetPeer func(peerid string) (peer.AddrInfo, error)

+ HasPeer func(peerid string) bool

+ LoadPeer func(path string) error

+ SavePeer func(addr peer.AddrInfo) error

+ func NewPeerRecord() PeerRecord

+ type PeerRecordType struct

+ func (p *PeerRecordType) BackupPeer(path string) error

+ func (p *PeerRecordType) GetAllPeerId() []string

+ func (p *PeerRecordType) GetPeer(peerid string) (peer.AddrInfo, error)

+ func (p *PeerRecordType) HasPeer(peerid string) bool

+ func (p *PeerRecordType) LoadPeer(path string) error

+ func (p *PeerRecordType) SavePeer(addr peer.AddrInfo) error

+ type RunningRecord interface

+ func NewRunningRecord() RunningRecord

+ type RunningRecordType struct

+ func (s *RunningRecordType) GetAuthIdleFlag() bool

+ func (s *RunningRecordType) GetCalcTagFlag() bool

+ func (s *RunningRecordType) GetCpuCores() int

+ func (s *RunningRecordType) GetGenIdleFlag() bool

+ func (s *RunningRecordType) GetInitStage() [Stage_Complete + 1]string

+ func (s *RunningRecordType) GetLastReconnectRpcTime() string

+ func (s *RunningRecordType) GetPID() int32

+ func (s *RunningRecordType) GetReportFileFlag() bool

+ func (s *RunningRecordType) GetTaskPeriod() string

+ func (s *RunningRecordType) SetAuthIdleFlag(flag bool)

+ func (s *RunningRecordType) SetCalcTagFlag(flag bool)

+ func (s *RunningRecordType) SetCpuCores(num int)

+ func (s *RunningRecordType) SetGenIdleFlag(flag bool)

+ func (s *RunningRecordType) SetInitStage(stage uint8, msg string)

+ func (s *RunningRecordType) SetLastReconnectRpcTime(t string)

+ func (s *RunningRecordType) SetPID(pid int32)

+ func (s *RunningRecordType) SetReportFileFlag(flag bool)

+ func (s *RunningRecordType) SetTaskPeriod(msg string)

+ type SetStatus interface

+ SetAuthIdleFlag func(flag bool)

+ SetCalcTagFlag func(flag bool)

+ SetCpuCores func(num int)

+ SetGenIdleFlag func(flag bool)

+ SetInitStage func(st uint8, msg string)

+ SetLastReconnectRpcTime func(t string)

+ SetPID func(pid int32)

+ SetReportFileFlag func(flag bool)

+ SetTaskPeriod func(msg string)

+ type TagfileType struct

+ FragmentName []byte

+ Index uint16

+ Signature []byte

+ Tag *pb.Tag

+ TeeAccountId []byte

+ USig []byte

+ type TeeInfoType struct

+ EndPoint string

+ Type uint8

+ type TeeRecord interface

+ DeleteTee func(workAccount string)

+ GetAllMarkerTeeEndpoint func() []string

+ GetAllTeeEndpoint func() []string

+ GetAllVerifierTeeEndpoint func() []string

+ GetTee func(workAccount string) (TeeInfoType, error)

+ GetTeeWorkAccount func(endpoint string) (string, error)

+ SaveTee func(workAccount, endPoint string, teeType uint8) error

+ func NewTeeRecord() TeeRecord

+ type TeeRecordType struct

+ func (t *TeeRecordType) DeleteTee(workAccount string)

+ func (t *TeeRecordType) GetAllMarkerTeeEndpoint() []string

+ func (t *TeeRecordType) GetAllTeeEndpoint() []string

+ func (t *TeeRecordType) GetAllVerifierTeeEndpoint() []string

+ func (t *TeeRecordType) GetTee(workAccount string) (TeeInfoType, error)

+ func (t *TeeRecordType) GetTeeWorkAccount(endpoint string) (string, error)

+ func (t *TeeRecordType) SaveTee(workAccount, endPoint string, teeType uint8) error

Dec 13, 2023

Changes in this version

type Node

+ func (n *Node) GetFragmentFromOss(fid string) ([]byte, error)

Nov 29, 2023

Changes in this version

type DataDir

+ TagDir string

type Node

+ func (n *Node) GetAllTeeWorkEndPoint() []string

Oct 30, 2023

Changes in this version

type Node

+ MinerPoisInfo *pb.MinerPoisInfo

+ func (n *Node) GetPodr2Key() *proof.RSAKeyPair

Sep 5, 2023

Changes in this version

type DataDir

+ PeersFile string

type Node

+ func (n *Node) GetCpuCore() int

+ func (n *Node) ReportLogs(file string)

+ func (n *Node) SaveCpuCore(cores int)

+ func (n *Node) UpdatePeerFirst()

+ func (n *Node) UpdatePeers()

Aug 31, 2023

Changes in this version

+ type DataDir struct

+ AccDir string

+ DbDir string

+ LogDir string

+ PoisDir string

+ RandomDir string

+ SpaceDir string

type Node

+ DataDir *DataDir

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

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

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

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

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

+ type Pois struct

Jul 21, 2023

Changes in this version

type Node

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

+ func (n *Node) RemovePeerIntranetAddr()

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

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

Jul 8, 2023

Changes in this version

type Node

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

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

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

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

Jul 4, 2023

Changes in this version

+ const Active

+ const Cach_AggrProof_Transfered

+ const Cach_IdleChallengeBlock

+ const Cach_ServiceChallengeBlock

+ const Cach_prefix_File

+ const Cach_prefix_MyLost

+ const Cach_prefix_ParseBlock

+ const Cach_prefix_TargetMiner

+ const Cach_prefix_idle

+ const Cach_prefix_idleSiama

+ const Cach_prefix_metadata

+ const Cach_prefix_recovery

+ const Cach_prefix_serviceSiama

+ const Calculate

+ const MaxReplaceFiles

+ const Missing

+ const P2PResponseOK

+ const Recovery

+ func RenameDir(oldDir, newDir string) error

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

+ type Bucket interface

+ Run func()

+ type Node struct

+ 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 struct

+ Mus []string

+ Names []string

+ Sigma string

+ Us []string

+ type RandomList struct

+ Index []uint32

+ Random [][]byte

+ type T struct

+ Name string

+ Phi []string

+ U string