node

type API struct {
	// common api
	api.Common
	api.Device
	api.Validation
	api.DataSync
	api.Asset
	WaitQuiet func(ctx context.Context) error
	// edge api
	ExternalServiceAddress func(ctx context.Context, candidateURL string) (string, error)
	UserNATPunch           func(ctx context.Context, sourceURL string, req *types.NatPunchReq) error
	// candidate api
	GetBlocksOfAsset         func(ctx context.Context, assetCID string, randomSeed int64, randomCount int) ([]string, error)
	CheckNetworkConnectivity func(ctx context.Context, network, targetURL string) error
}

type Manager struct {
	Edges      int // online edge node count
	Candidates int // online candidate node count

	*db.SQLDB
	*rsa.PrivateKey // scheduler privateKey
	dtypes.ServerID // scheduler server id
	// contains filtered or unexported fields
}

type Node struct {
	NodeID string

	*API
	jsonrpc.ClientCloser

	// node info
	PublicKey  *rsa.PublicKey
	RemoteAddr string
	TCPPort    int

	NATType     types.NatType
	CPUUsage    float64
	MemoryUsage float64
	DiskUsage   float64
	ExternalIP  string

	OnlineDuration int
	Type           types.NodeType
	PortMapping    string
	BandwidthDown  int64
	BandwidthUp    int64
	DiskSpace      float64
	// contains filtered or unexported fields
}