Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

node

package

Go to main page

Versions in this module

v0

v0.8.2

Feb 18, 2025

Changes in this version

+ func DownloadFragmentFromGW(url, fpath, account, message, signature string) error

type Node

+ func (n *Node) DownloadFragment(fid, fragment_hash, savepath string) error

v0.8.1

Jan 22, 2025

Changes in this version

+ const Registered

+ const Unregistered

+ const UnregisteredPoisKey

+ func GetLocalIP() (string, error)

+ func InitMiddlewares() []gin.HandlerFunc

+ func NewPoisProver(expendersInfo chain.ExpendersInfo, freeSpace, count int64, ...) (*pois.Prover, error)

type Node

+ func NewEmptyNode() *Node

+ func NewNodeWithConfig(cfg confile.Confiler) *Node

+ func (n *Node) CalcTag(ch chan<- bool)

+ func (n *Node) CertIdle(ch chan<- bool)

+ func (n *Node) ChallengeMgt(idleChallTaskCh chan bool, serviceChallTaskCh chan bool)

+ func (n *Node) CheckPois() error

+ func (n *Node) GenIdle(ch chan<- bool)

+ func (n *Node) InitAccRsaKey(key *acc.RsaKey)

+ func (n *Node) InitCache()

+ func (n *Node) InitCacher(cace cache.Cache)

+ func (n *Node) InitChainClient()

+ func (n *Node) InitChainclient(cli chain.Chainer)

+ func (n *Node) InitLogger(lg logger.Logger)

+ func (n *Node) InitLogs()

+ func (n *Node) InitMinerPoisInfo(poisInfo *pb.MinerPoisInfo)

+ func (n *Node) InitNode() *Node

+ func (n *Node) InitPoisProver(p *pois.Prover)

+ func (n *Node) InitRSAKeyPair(key *RSAKeyPair)

+ func (n *Node) InitRunStatus(st types.Bytes, apiEndpoint string, t string, register bool)

+ func (n *Node) InitRunstatus(rt runstatus.Runstatus)

+ func (n *Node) InitTeeRecord(tees record.TeeRecorder)

+ func (n *Node) InitWebServer(mdls []gin.HandlerFunc, hdl *web.Handler)

+ func (n *Node) InitWorkspace(ws string)

+ func (n *Node) Reconnectrpc()

+ func (n *Node) ReplaceIdle(ch chan<- bool)

+ func (n *Node) ReportFiles(ch chan<- bool)

+ func (n *Node) RestoreFiles(ch chan bool)

+ func (n *Node) RestoreLocalFiles() error

+ func (n *Node) RestoreOtherFiles() error

+ func (n *Node) Start()

+ func (n *Node) SyncTeeInfo(ch chan<- bool)

v0.7.16

Sep 20, 2024

v0.7.15

Sep 12, 2024

v0.7.14

Aug 28, 2024

v0.7.13

Aug 23, 2024

v0.7.12

Aug 21, 2024

v0.7.11

Jul 31, 2024

Changes in this version

+ const Active

+ const Cach_prefix_File

+ const Cach_prefix_MyLost

+ const Cach_prefix_ParseBlock

+ const Cach_prefix_Tag

+ const Cach_prefix_TargetMiner

+ const Cach_prefix_recovery

+ const Calculate

+ const Error

+ const ErrorInternal

+ const ErrorParam

+ const ErrorParamNotFound

+ const Missing

+ const Recovery

+ const St_Error

+ const St_Normal

+ const St_Warning

+ const Success

+ func AllowSpecificRoute(allowedPath string) gin.HandlerFunc

+ func AttestationIdle(cli *chain.ChainClient, peernode *core.PeerNode, p *Pois, r *RunningState, ...)

+ func CalcTag(cli *chain.ChainClient, cace cache.Cache, l logger.Logger, r *RunningState, ...)

+ func ChallengeMgt(cli *chain.ChainClient, l logger.Logger, ws *Workspace, r *RunningState, ...)

+ func GenIdle(l *logger.Lg, prover *pois.Prover, r *RunningState, workspace string, ...)

+ func GetFragmentFromOss(fid string, signAcc string) ([]byte, error)

+ func ProcessTeeEndpoint(endPoint string) string

+ func ReplaceIdle(cli *chain.ChainClient, l logger.Logger, p *Pois, m *pb.MinerPoisInfo, ...)

+ func ReportFiles(ch chan<- bool, cli *chain.ChainClient, r *RunningState, l *logger.Lg, ...)

+ func RestoreFiles(cli *chain.ChainClient, cace cache.Cache, l logger.Logger, fileDir string, ...)

+ func RestoreLocalFiles(cli *chain.ChainClient, l logger.Logger, cace cache.Cache, fileDir string) error

+ func RestoreOtherFiles(cli *chain.ChainClient, l logger.Logger, fileDir string) error

+ func SplitByN(filePath string, N int64) (Data [][]byte, sep int64, err error)

+ func Subscribe(ctx context.Context, h host.Host, minerRecord MinerRecord, bootnode string)

+ func SyncTeeInfo(cli *chain.ChainClient, l *logger.Lg, peernode *core.PeerNode, ...)

+ func WatchMem()

+ type DataDir struct

+ AccDir string

+ DbDir string

+ LogDir string

+ PeersFile string

+ Podr2PubkeyFile string

+ PoisDir string

+ RandomDir string

+ SpaceDir string

+ type GenProofResponse struct

+ MU string

+ Sigma string

+ StatueMsg StatueMsg

+ type GetStatus interface

+ GetAuthIdleFlag func() bool

+ GetCalcTagFlag func() bool

+ GetChainStatus func() bool

+ GetCpuCores func() int

+ GetCurrentRpc func() string

+ GetGenIdleFlag func() bool

+ GetIdleChallengeFlag func() bool

+ GetLastReconnectRpcTime func() string

+ GetMinerSignatureAcc func() string

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

+ GetMinerState func() string

+ GetPID func() int

+ GetReceiveFlag func() bool

+ GetReportFileFlag func() bool

+ GetServiceChallengeFlag func() bool

+ type HashSelf interface

+ CHash func() ([]byte, crypto.Hash)

+ LoadField func(d []byte) error

+ New func() *HashSelf

+ type MinerRecord interface

+ BackupPeer func(path string) error

+ GetAllMinerAcc func() []string

+ GetAllPeerId func() []string

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

+ HasPeer func(peerid string) bool

+ LoadPeer func(path string) error

+ SaveMinerAcc func(acc string, peerid string)

+ SavePeer func(addr peer.AddrInfo) error

+ func NewPeerRecord() MinerRecord

+ type Node struct

+ func New() *Node

+ type PeerRecordType struct

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

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

+ 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) SaveMinerAcc(acc string, peerid string)

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

+ type Pois struct

+ func NewPOIS(poisDir, spaceDir, accDir string, expendersInfo chain.ExpendersInfo, ...) (*Pois, error)

+ type QElement struct

+ I int64

+ V string

+ type RSAKeyPair struct

+ Spk *rsa.PublicKey

+ func NewRsaKey(pubkey []byte) (*RSAKeyPair, error)

+ func (keyPair RSAKeyPair) AggrAppendProof(AggrSigma string, aSigma string) (string, bool)

+ func (keyPair RSAKeyPair) AggrGenProof(QSlice []QElement, Tag []Tag) string

+ func (keyPair RSAKeyPair) GenProof(QSlice []QElement, h HashSelf, Phi []string, Matrix [][]byte) <-chan GenProofResponse

+ func (r *RSAKeyPair) VerifyAttest(name, u, phiHash, attest, customData string) (bool, error)

+ type RandomList struct

+ Index []uint32

+ Random [][]byte

+ type RunningState struct

+ func NewRunTime() *RunningState

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

+ func (m *RunningState) SetMinerSignAcc(acc string)

+ func (m *RunningState) SetMinerSpaceInfo(decSpace, validSpace, usedSpace, lockedSpace uint64)

+ func (m *RunningState) SetMinerState(state string) error

+ func (s *RunningState) GetAuthIdleFlag() bool

+ func (s *RunningState) GetCalcTagFlag() bool

+ func (s *RunningState) GetChainStatus() bool

+ func (s *RunningState) GetCpuCores() int

+ func (s *RunningState) GetCurrentRpc() string

+ func (s *RunningState) GetGenIdleFlag() bool

+ func (s *RunningState) GetIdleChallengeFlag() bool

+ func (s *RunningState) GetLastReconnectRpcTime() string

+ func (s *RunningState) GetMinerSignatureAcc() string

+ func (s *RunningState) GetMinerState() string

+ func (s *RunningState) GetPID() int

+ func (s *RunningState) GetReceiveFlag() bool

+ func (s *RunningState) GetReportFileFlag() bool

+ func (s *RunningState) GetServiceChallengeFlag() bool

+ func (s *RunningState) ListenLocal()

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

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

+ func (s *RunningState) SetChainStatus(status bool)

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

+ func (s *RunningState) SetCurrentRpc(rpc string)

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

+ func (s *RunningState) SetIdleChallengeFlag(flag bool)

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

+ func (s *RunningState) SetPID(pid int)

+ func (s *RunningState) SetReceiveFlag(flag bool)

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

+ func (s *RunningState) SetServiceChallengeFlag(flag bool)

+ type RunningStater interface

+ type SetStatus interface

+ SetAuthIdleFlag func(flag bool)

+ SetCalcTagFlag func(flag bool)

+ SetChainStatus func(status bool)

+ SetCpuCores func(num int)

+ SetCurrentRpc func(rpc string)

+ SetGenIdleFlag func(flag bool)

+ SetIdleChallengeFlag func(flag bool)

+ SetLastReconnectRpcTime func(t string)

+ SetMinerSignAcc func(acc string)

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

+ SetMinerState func(state string) error

+ SetPID func(pid int)

+ SetReceiveFlag func(flag bool)

+ SetReportFileFlag func(flag bool)

+ SetServiceChallengeFlag func(flag bool)

+ type StatueMsg struct

+ Msg string

+ StatusCode int

+ type T struct

+ Name string

+ Phi []string

+ U string

+ type Tag struct

+ Attest string

+ PhiHash string

+ T T

+ type TagfileType struct

+ FragmentName []byte

+ Index uint16

+ Signature []byte

+ Tag *pb.Tag

+ TeeAccountId []byte

+ USig []byte

+ type TeeInfo struct

+ EndPoint string

+ Type uint8

+ type TeeRecord struct

+ func NewTeeRecord() *TeeRecord

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

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

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

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

+ func (t *TeeRecord) GetTee(workAccount string) (TeeInfo, error)

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

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

+ type TeeRecorder interface

+ DeleteTee func(workAccount string)

+ GetAllMarkerTeeEndpoint func() []string

+ GetAllTeeEndpoint func() []string

+ GetAllVerifierTeeEndpoint func() []string

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

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

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

+ type Workspace struct

+ func NewWorkspace() *Workspace

+ func (w *Workspace) Build(rootDir string) error

+ func (w *Workspace) Check() error

+ func (w *Workspace) GetChallRandomDir() string

+ func (w *Workspace) GetChallRndomDir() string

+ func (w *Workspace) GetDbDir() string

+ func (w *Workspace) GetFileDir() string

+ func (w *Workspace) GetIdleProve() string

+ func (w *Workspace) GetLogDir() string

+ func (w *Workspace) GetPeerRecord() string

+ func (w *Workspace) GetPodr2Key() string

+ func (w *Workspace) GetPoisAccDir() string

+ func (w *Workspace) GetPoisDir() string

+ func (w *Workspace) GetRootDir() string

+ func (w *Workspace) GetServiceProve() string

+ func (w *Workspace) GetSpaceDir() string

+ func (w *Workspace) GetTmpDir() string

+ func (w *Workspace) LoadIdleProve() (idleProofInfo, error)

+ func (w *Workspace) LoadRsaPublicKey() ([]byte, error)

+ func (w *Workspace) LoadServiceProve() (serviceProofInfo, error)

+ func (w *Workspace) RemoveAndBuild(rootDir string) error

+ func (w *Workspace) SaveChallRandom(challStart uint32, randomIndexList []types.U32, randomList []chain.Random) error

+ func (w *Workspace) SaveIdleProve(idleProofRecord idleProofInfo) error

+ func (w *Workspace) SaveRsaPublicKey(pub []byte) error

+ func (w *Workspace) SaveServiceProve(serviceProofRecord serviceProofInfo) error

+ type Workspacer interface

+ Build func(rootDir string) error

+ GetChallRndomDir func() string

+ GetDbDir func() string

+ GetFileDir func() string

+ GetIdleProve func() string

+ GetLogDir func() string

+ GetPeerRecord func() string

+ GetPodr2Key func() string

+ GetPoisAccDir func() string

+ GetPoisDir func() string

+ GetRootDir func() string

+ GetServiceProve func() string

+ GetSpaceDir func() string

+ GetTmpDir func() string

+ LoadIdleProve func() (idleProofInfo, error)

+ LoadRsaPublicKey func() ([]byte, error)

+ LoadServiceProve func() (serviceProofInfo, error)

+ RemoveAndBuild func(rootDir string) error

+ SaveChallRandom func(challStart uint32, randomIndexList []types.U32, randomList []chain.Random) error

+ SaveIdleProve func(idleProofRecord idleProofInfo) error

+ SaveRsaPublicKey func(pub []byte) error

+ SaveServiceProve func(serviceProofRecord serviceProofInfo) error