Documentation ¶
Index ¶
- Constants
- type DataDir
- type GetStatus
- type MinerState
- type MinerStateType
- type Node
- func (n *Node) GetFragmentFromOss(fid string) ([]byte, error)
- func (n *Node) GetPodr2Key() *proof.RSAKeyPair
- func (n *Node) InitPois(firstflag bool, front, rear, freeSpace, count int64, key_n, key_g big.Int) error
- func (n *Node) ListenLocal()
- func (n *Node) QueryPeerFromOss(peerid string) (peer.AddrInfo, error)
- func (n *Node) RebuildDirs()
- func (n *Node) ReportLogs(file string)
- func (n *Node) Run()
- func (n *Node) SetPublickey(pubkey []byte) error
- func (n *Node) WatchMem()
- type PeerRecord
- type PeerRecordType
- 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 Pois
- type RandomList
- type RunningRecord
- type RunningRecordType
- 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
- type TagfileType
- type TeeInfoType
- type TeeRecord
- type TeeRecordType
- 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
Constants ¶
View Source
const ( Active = iota Calculate Missing Recovery )
View Source
const ( // Record the fid of stored files Cach_prefix_File = "file:" // Record the block of reported tags Cach_prefix_Tag = "tag:" Cach_prefix_MyLost = "mylost:" Cach_prefix_recovery = "recovery:" Cach_prefix_TargetMiner = "targetminer:" Cach_prefix_ParseBlock = "parseblocks" )
View Source
const ( St_Normal uint8 = iota St_Warning St_Error )
View Source
const ( Stage_Startup uint8 = iota Stage_ReadConfig Stage_ConnectRpc Stage_CreateP2p Stage_SyncBlock Stage_QueryChain Stage_Register Stage_BuildDir Stage_BuildCache Stage_BuildLog Stage_Complete )
init stage
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MinerState ¶ added in v0.7.9
type MinerState interface { // set SaveMinerState(state string) error SaveMinerSpaceInfo(decSpace, validSpace, usedSpace, lockedSpace uint64) //get GetMinerState() string GetMinerSpaceInfo() (uint64, uint64, uint64, uint64) }
func NewMinerState ¶ added in v0.7.9
func NewMinerState() MinerState
type MinerStateType ¶ added in v0.7.9
type MinerStateType struct {
// contains filtered or unexported fields
}
func (*MinerStateType) GetMinerSpaceInfo ¶ added in v0.7.9
func (m *MinerStateType) GetMinerSpaceInfo() (uint64, uint64, uint64, uint64)
func (*MinerStateType) GetMinerState ¶ added in v0.7.9
func (m *MinerStateType) GetMinerState() string
func (*MinerStateType) SaveMinerSpaceInfo ¶ added in v0.7.9
func (m *MinerStateType) SaveMinerSpaceInfo(decSpace, validSpace, usedSpace, lockedSpace uint64)
func (*MinerStateType) SaveMinerState ¶ added in v0.7.9
func (m *MinerStateType) SaveMinerState(state string) error
type Node ¶
type Node struct { sdk.SDK core.P2P confile.Confile logger.Logger cache.Cache MinerState TeeRecord PeerRecord RunningRecord *gin.Engine *proof.RSAKeyPair *pb.MinerPoisInfo *DataDir *Pois }
func NewEmptyNode ¶ added in v0.7.9
func NewEmptyNode() *Node
New is used to build a empty node instance
func (*Node) GetFragmentFromOss ¶ added in v0.7.8
func (*Node) GetPodr2Key ¶ added in v0.7.3
func (n *Node) GetPodr2Key() *proof.RSAKeyPair
func (*Node) ListenLocal ¶ added in v0.7.9
func (n *Node) ListenLocal()
func (*Node) QueryPeerFromOss ¶ added in v0.7.9
func (*Node) RebuildDirs ¶
func (n *Node) RebuildDirs()
func (*Node) ReportLogs ¶ added in v0.7.1
func (*Node) SetPublickey ¶
type PeerRecord ¶ added in v0.7.9
type PeerRecord interface { // SavePeer saves or updates peer information SavePeer(addr peer.AddrInfo) error // HasPeer(peerid string) bool // GetPeer(peerid string) (peer.AddrInfo, error) // GetAllPeerId() []string // BackupPeer(path string) error // LoadPeer(path string) error }
func NewPeerRecord ¶ added in v0.7.9
func NewPeerRecord() PeerRecord
type PeerRecordType ¶ added in v0.7.9
type PeerRecordType struct {
// contains filtered or unexported fields
}
func (*PeerRecordType) BackupPeer ¶ added in v0.7.9
func (p *PeerRecordType) BackupPeer(path string) error
func (*PeerRecordType) GetAllPeerId ¶ added in v0.7.9
func (p *PeerRecordType) GetAllPeerId() []string
func (*PeerRecordType) GetPeer ¶ added in v0.7.9
func (p *PeerRecordType) GetPeer(peerid string) (peer.AddrInfo, error)
func (*PeerRecordType) HasPeer ¶ added in v0.7.9
func (p *PeerRecordType) HasPeer(peerid string) bool
func (*PeerRecordType) LoadPeer ¶ added in v0.7.9
func (p *PeerRecordType) LoadPeer(path string) error
type RandomList ¶
type RunningRecord ¶ added in v0.7.9
func NewRunningRecord ¶ added in v0.7.9
func NewRunningRecord() RunningRecord
type RunningRecordType ¶ added in v0.7.9
type RunningRecordType struct {
// contains filtered or unexported fields
}
func (*RunningRecordType) GetAuthIdleFlag ¶ added in v0.7.9
func (s *RunningRecordType) GetAuthIdleFlag() bool
func (*RunningRecordType) GetCalcTagFlag ¶ added in v0.7.9
func (s *RunningRecordType) GetCalcTagFlag() bool
func (*RunningRecordType) GetCpuCores ¶ added in v0.7.9
func (s *RunningRecordType) GetCpuCores() int
func (*RunningRecordType) GetGenIdleFlag ¶ added in v0.7.9
func (s *RunningRecordType) GetGenIdleFlag() bool
func (*RunningRecordType) GetInitStage ¶ added in v0.7.9
func (s *RunningRecordType) GetInitStage() [Stage_Complete + 1]string
func (*RunningRecordType) GetLastReconnectRpcTime ¶ added in v0.7.9
func (s *RunningRecordType) GetLastReconnectRpcTime() string
func (*RunningRecordType) GetPID ¶ added in v0.7.9
func (s *RunningRecordType) GetPID() int32
func (*RunningRecordType) GetReportFileFlag ¶ added in v0.7.9
func (s *RunningRecordType) GetReportFileFlag() bool
func (*RunningRecordType) GetTaskPeriod ¶ added in v0.7.9
func (s *RunningRecordType) GetTaskPeriod() string
func (*RunningRecordType) SetAuthIdleFlag ¶ added in v0.7.9
func (s *RunningRecordType) SetAuthIdleFlag(flag bool)
func (*RunningRecordType) SetCalcTagFlag ¶ added in v0.7.9
func (s *RunningRecordType) SetCalcTagFlag(flag bool)
func (*RunningRecordType) SetCpuCores ¶ added in v0.7.9
func (s *RunningRecordType) SetCpuCores(num int)
func (*RunningRecordType) SetGenIdleFlag ¶ added in v0.7.9
func (s *RunningRecordType) SetGenIdleFlag(flag bool)
func (*RunningRecordType) SetInitStage ¶ added in v0.7.9
func (s *RunningRecordType) SetInitStage(stage uint8, msg string)
func (*RunningRecordType) SetLastReconnectRpcTime ¶ added in v0.7.9
func (s *RunningRecordType) SetLastReconnectRpcTime(t string)
func (*RunningRecordType) SetPID ¶ added in v0.7.9
func (s *RunningRecordType) SetPID(pid int32)
func (*RunningRecordType) SetReportFileFlag ¶ added in v0.7.9
func (s *RunningRecordType) SetReportFileFlag(flag bool)
func (*RunningRecordType) SetTaskPeriod ¶ added in v0.7.9
func (s *RunningRecordType) SetTaskPeriod(msg string)
type TagfileType ¶ added in v0.7.9
type TagfileType struct { Tag *pb.Tag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` USig []byte `protobuf:"bytes,2,opt,name=u_sig,json=uSig,proto3" json:"u_sig,omitempty"` Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` FragmentName []byte `protobuf:"bytes,4,opt,name=fragment_name,json=fragmentName,proto3" json:"fragment_name,omitempty"` TeeAccountId []byte `protobuf:"bytes,5,opt,name=tee_account_id,json=teeAccountId,proto3" json:"tee_account_id,omitempty"` Index uint16 `protobuf:"bytes,6,opt,name=index,json=index,proto3" json:"index,omitempty"` }
type TeeInfoType ¶ added in v0.7.9
type TeeRecord ¶ added in v0.7.9
type TeeRecord interface { // SaveTee saves or updates tee information SaveTee(workAccount, endPoint string, teeType uint8) error // GetTee(workAccount string) (TeeInfoType, error) // GetTeeWorkAccount(endpoint string) (string, error) // DeleteTee(workAccount string) // GetAllTeeEndpoint() []string // GetAllMarkerTeeEndpoint() []string // GetAllVerifierTeeEndpoint() []string }
func NewTeeRecord ¶ added in v0.7.9
func NewTeeRecord() TeeRecord
type TeeRecordType ¶ added in v0.7.9
type TeeRecordType struct {
// contains filtered or unexported fields
}
func (*TeeRecordType) DeleteTee ¶ added in v0.7.9
func (t *TeeRecordType) DeleteTee(workAccount string)
func (*TeeRecordType) GetAllMarkerTeeEndpoint ¶ added in v0.7.9
func (t *TeeRecordType) GetAllMarkerTeeEndpoint() []string
func (*TeeRecordType) GetAllTeeEndpoint ¶ added in v0.7.9
func (t *TeeRecordType) GetAllTeeEndpoint() []string
func (*TeeRecordType) GetAllVerifierTeeEndpoint ¶ added in v0.7.9
func (t *TeeRecordType) GetAllVerifierTeeEndpoint() []string
func (*TeeRecordType) GetTee ¶ added in v0.7.9
func (t *TeeRecordType) GetTee(workAccount string) (TeeInfoType, error)
func (*TeeRecordType) GetTeeWorkAccount ¶ added in v0.7.9
func (t *TeeRecordType) GetTeeWorkAccount(endpoint string) (string, error)
Click to show internal directories.
Click to hide internal directories.