node

package
v0.7.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2024 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

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 DataDir added in v0.7.0 

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

type GetStatus added in v0.7.9 

type GetStatus interface {
	GetInitStage() [Stage_Complete + 1]string
	GetTaskPeriod() string
	GetCpuCores() int
	GetPID() int32
	GetLastReconnectRpcTime() string
	GetCalcTagFlag() bool
	GetReportFileFlag() bool
	GetGenIdleFlag() bool
	GetAuthIdleFlag() bool
}

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 New 

func New() *Node

New is used to build a node instance

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 (n *Node) GetFragmentFromOss(fid string) ([]byte, error)

func (*Node) GetPodr2Key added in v0.7.3 

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

func (*Node) InitPois added in v0.7.0 

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

func (*Node) ListenLocal added in v0.7.9 

func (n *Node) ListenLocal()

func (*Node) QueryPeerFromOss added in v0.7.9 

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

func (*Node) RebuildDirs 

func (n *Node) RebuildDirs()

func (*Node) ReportLogs added in v0.7.1 

func (n *Node) ReportLogs(file string)

func (*Node) Run 

func (n *Node) Run()

func (*Node) SetPublickey 

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

func (*Node) WatchMem added in v0.7.10 

func (n *Node) WatchMem()

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

func (*PeerRecordType) SavePeer added in v0.7.9 

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

type Pois added in v0.7.0 

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"`
}

type RunningRecord added in v0.7.9 

type RunningRecord interface {
	SetStatus
	GetStatus
}

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 SetStatus added in v0.7.9 

type SetStatus interface {
	SetInitStage(st uint8, msg string)
	SetTaskPeriod(msg string)
	SetCpuCores(num int)
	SetPID(pid int32)
	SetLastReconnectRpcTime(t string)
	SetCalcTagFlag(flag bool)
	SetReportFileFlag(flag bool)
	SetGenIdleFlag(flag bool)
	SetAuthIdleFlag(flag bool)
}

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 TeeInfoType struct {
	EndPoint string
	Type     uint8
}

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)

func (*TeeRecordType) SaveTee added in v0.7.9 

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

SaveTee saves or updates tee information

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.