chain

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2023 License: Apache-2.0 Imports: 28 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExtractSegmenthash

func ExtractSegmenthash(segment []string) []string

Types

type ChainSDK

type ChainSDK struct {
	*core.Node
	// contains filtered or unexported fields
}

func NewChainSDK

func NewChainSDK(
	ctx context.Context,
	name string,
	rpcs []string,
	mnemonic string,
	t time.Duration,
	workspace string,
	p2pPort int,
	bootnodes []string,
	protocolPrefix string,
) (*ChainSDK, error)

func (*ChainSDK) BuySpace added in v0.3.0

func (c *ChainSDK) BuySpace(count uint32) (string, error)

func (*ChainSDK) CheckSpaceUsageAuthorization

func (c *ChainSDK) CheckSpaceUsageAuthorization(puk []byte) (bool, error)

func (*ChainSDK) ClaimRestoralNoExistOrder

func (c *ChainSDK) ClaimRestoralNoExistOrder(puk []byte, rootHash, restoralFragmentHash string) (string, error)

ClaimRestoralNoExistOrder

func (*ChainSDK) ClaimRestoralOrder

func (c *ChainSDK) ClaimRestoralOrder(fragmentHash string) (string, error)

ClaimRestoralOrder

func (*ChainSDK) ClaimRewards

func (c *ChainSDK) ClaimRewards() (string, error)

ClaimRewards

func (*ChainSDK) CreateBucket

func (c *ChainSDK) CreateBucket(owner_pkey []byte, name string) (string, error)

func (*ChainSDK) DeleteBucket

func (c *ChainSDK) DeleteBucket(owner_pkey []byte, name string) (string, error)

func (*ChainSDK) DeleteFile

func (c *ChainSDK) DeleteFile(puk []byte, filehash []string) (string, []pattern.FileHash, error)

func (*ChainSDK) DeleteFiller added in v0.0.74

func (c *ChainSDK) DeleteFiller(filehash string) (string, error)

func (*ChainSDK) EnabledP2P added in v0.2.4

func (c *ChainSDK) EnabledP2P() bool

func (*ChainSDK) Exit

func (c *ChainSDK) Exit(role string) (string, error)

func (*ChainSDK) ExpansionSpace added in v0.3.0

func (c *ChainSDK) ExpansionSpace(count uint32) (string, error)

func (*ChainSDK) GenerateRestoralOrder

func (c *ChainSDK) GenerateRestoralOrder(rootHash, fragmentHash string) (string, error)

GenerateRestoralOrder

func (*ChainSDK) GenerateStorageOrder

func (c *ChainSDK) GenerateStorageOrder(roothash string, segment []pattern.SegmentDataInfo, owner []byte, filename, buckname string, filesize uint64) (string, error)

func (*ChainSDK) GetChainState

func (c *ChainSDK) GetChainState() bool

func (*ChainSDK) GetKeyEvents

func (c *ChainSDK) GetKeyEvents() types.StorageKey

func (*ChainSDK) GetMetadata

func (c *ChainSDK) GetMetadata() *types.Metadata

func (*ChainSDK) GetRoleName

func (c *ChainSDK) GetRoleName() string

func (*ChainSDK) GetSignatureAcc

func (c *ChainSDK) GetSignatureAcc() string

func (*ChainSDK) GetSignatureAccPulickey

func (c *ChainSDK) GetSignatureAccPulickey() []byte

func (*ChainSDK) GetSubstrateAPI

func (c *ChainSDK) GetSubstrateAPI() *gsrpc.SubstrateAPI

func (*ChainSDK) GetTokenSymbol

func (c *ChainSDK) GetTokenSymbol() string

func (*ChainSDK) IncreaseStakingAmount

func (c *ChainSDK) IncreaseStakingAmount(tokens *big.Int) (string, error)

Storage miners increase deposit function

func (*ChainSDK) IncreaseStorageNodeStakingAmount

func (c *ChainSDK) IncreaseStorageNodeStakingAmount(token string) (string, error)

func (*ChainSDK) NetListening

func (c *ChainSDK) NetListening() (bool, error)

func (*ChainSDK) ProcessingData

func (c *ChainSDK) ProcessingData(file string) ([]pattern.SegmentDataInfo, string, error)

ProcessingData

func (*ChainSDK) QuaryAuthorizedAcc

func (c *ChainSDK) QuaryAuthorizedAcc(puk []byte) (types.AccountID, error)

func (*ChainSDK) QuaryAuthorizedAccount

func (c *ChainSDK) QuaryAuthorizedAccount(puk []byte) (string, error)

func (*ChainSDK) QuaryStorageNodeRewardInfo

func (c *ChainSDK) QuaryStorageNodeRewardInfo(puk []byte) (pattern.RewardsType, error)

func (*ChainSDK) QueryAccountInfo

func (c *ChainSDK) QueryAccountInfo(puk []byte) (types.AccountInfo, error)

QueryAccountInfo

func (*ChainSDK) QueryAllBucketName

func (c *ChainSDK) QueryAllBucketName(owner []byte) ([]string, error)

func (*ChainSDK) QueryAssignedMinerPeerId added in v0.2.4

func (c *ChainSDK) QueryAssignedMinerPeerId(minerTaskList []pattern.MinerTaskList) ([]peer.ID, error)

func (*ChainSDK) QueryAssignedProof

func (c *ChainSDK) QueryAssignedProof() ([][]pattern.ProofAssignmentInfo, error)

func (*ChainSDK) QueryBlockHeight

func (c *ChainSDK) QueryBlockHeight(hash string) (uint32, error)

QueryBlockHeight

func (*ChainSDK) QueryBucketInfo

func (c *ChainSDK) QueryBucketInfo(puk []byte, bucketname string) (pattern.BucketInfo, error)

QueryBucketInfo

func (*ChainSDK) QueryBucketList

func (c *ChainSDK) QueryBucketList(puk []byte) ([]types.Bytes, error)

func (*ChainSDK) QueryChallenge

func (c *ChainSDK) QueryChallenge(pubkey []byte) (pattern.ChallengeInfo, error)

func (*ChainSDK) QueryChallengeExpiration added in v0.3.1

func (c *ChainSDK) QueryChallengeExpiration() (uint32, error)

func (*ChainSDK) QueryChallengeSnapshot

func (c *ChainSDK) QueryChallengeSnapshot() (pattern.ChallengeSnapShot, error)

func (*ChainSDK) QueryChallengeSt

func (c *ChainSDK) QueryChallengeSt() (pattern.ChallengeSnapshot, error)

func (*ChainSDK) QueryDeossPeerIdList

func (c *ChainSDK) QueryDeossPeerIdList() ([]string, error)

QueryDeossPeerPublickey

func (*ChainSDK) QueryDeossPeerPublickey

func (c *ChainSDK) QueryDeossPeerPublickey(pubkey []byte) ([]byte, error)

QueryDeossPeerPublickey

func (*ChainSDK) QueryFileMetadata

func (c *ChainSDK) QueryFileMetadata(roothash string) (pattern.FileMetadata, error)

QueryFileMetaData

func (*ChainSDK) QueryFillerMap added in v0.0.74

func (c *ChainSDK) QueryFillerMap(filehash string) (pattern.IdleMetadata, error)

QueryFillerMap

func (*ChainSDK) QueryNodeSynchronizationSt

func (c *ChainSDK) QueryNodeSynchronizationSt() (bool, error)

QueryNodeSynchronizationSt

func (*ChainSDK) QueryPendingReplacements

func (c *ChainSDK) QueryPendingReplacements(puk []byte) (uint32, error)

func (*ChainSDK) QueryRestoralOrder

func (c *ChainSDK) QueryRestoralOrder(fragmentHash string) (pattern.RestoralOrderInfo, error)

QueryRestoralOrder

func (*ChainSDK) QueryRestoralOrderList added in v0.0.74

func (c *ChainSDK) QueryRestoralOrderList() ([]pattern.RestoralOrderInfo, error)

QueryRestoralOrder

func (*ChainSDK) QueryRestoralTarget added in v0.0.74

func (c *ChainSDK) QueryRestoralTarget(puk []byte) (pattern.RestoralTargetInfo, error)

QueryRestoralOrder

func (*ChainSDK) QueryRestoralTargetList

func (c *ChainSDK) QueryRestoralTargetList() ([]pattern.RestoralTargetInfo, error)

QueryRestoralTargetList

func (*ChainSDK) QuerySminerList

func (c *ChainSDK) QuerySminerList() ([]types.AccountID, error)

QuerySminerList

func (*ChainSDK) QuerySpacePricePerGib

func (c *ChainSDK) QuerySpacePricePerGib() (string, error)

func (*ChainSDK) QueryStorageMiner

func (c *ChainSDK) QueryStorageMiner(puk []byte) (pattern.MinerInfo, error)

QueryStorageMiner

func (*ChainSDK) QueryStorageNodeReward

func (c *ChainSDK) QueryStorageNodeReward(puk []byte) (pattern.MinerReward, error)

QueryMinerRewards

func (*ChainSDK) QueryStorageOrder

func (c *ChainSDK) QueryStorageOrder(roothash string) (pattern.StorageOrder, error)

func (*ChainSDK) QueryTeeAssignedProof

func (c *ChainSDK) QueryTeeAssignedProof(puk []byte) ([]pattern.ProofAssignmentInfo, error)

func (*ChainSDK) QueryTeeInfoList

func (c *ChainSDK) QueryTeeInfoList() ([]pattern.TeeWorkerInfo, error)

func (*ChainSDK) QueryTeePeerID

func (c *ChainSDK) QueryTeePeerID(puk []byte) ([]byte, error)

func (*ChainSDK) QueryTeePodr2Puk

func (c *ChainSDK) QueryTeePodr2Puk() ([]byte, error)

func (*ChainSDK) QueryTeeWorkerList

func (c *ChainSDK) QueryTeeWorkerList() ([]pattern.TeeWorkerSt, error)

func (*ChainSDK) QueryUserSpaceInfo

func (c *ChainSDK) QueryUserSpaceInfo(puk []byte) (pattern.UserSpaceInfo, error)

func (*ChainSDK) QueryUserSpaceSt

func (c *ChainSDK) QueryUserSpaceSt(puk []byte) (pattern.UserSpaceSt, error)

func (*ChainSDK) Reconnect

func (c *ChainSDK) Reconnect() error

func (*ChainSDK) RedundancyRecovery

func (c *ChainSDK) RedundancyRecovery(outpath string, shardspath []string) error

func (*ChainSDK) Register

func (c *ChainSDK) Register(role string, puk []byte, earnings string, pledge uint64) (string, string, error)

func (*ChainSDK) RenewalSpace added in v0.3.0

func (c *ChainSDK) RenewalSpace(days uint32) (string, error)

func (*ChainSDK) ReplaceFile

func (c *ChainSDK) ReplaceFile(roothash []string) (string, []string, error)

func (*ChainSDK) ReplaceIdleFiles

func (c *ChainSDK) ReplaceIdleFiles(roothash []pattern.FileHash) (string, []pattern.FileHash, error)

func (*ChainSDK) ReportFiles

func (c *ChainSDK) ReportFiles(roothash []string) (string, []string, error)

func (*ChainSDK) ReportProof

func (c *ChainSDK) ReportProof(idlesigma, servicesigma string) (string, error)

func (*ChainSDK) RestoralComplete added in v0.0.76

func (c *ChainSDK) RestoralComplete(restoralFragmentHash string) (string, error)

ClaimRestoralNoExistOrder

func (*ChainSDK) RetrieveFile added in v0.2.4

func (c *ChainSDK) RetrieveFile(roothash, savepath string) error

func (*ChainSDK) SetChainState

func (c *ChainSDK) SetChainState(state bool)

func (*ChainSDK) Sign

func (c *ChainSDK) Sign(msg []byte) ([]byte, error)

func (*ChainSDK) StorageData added in v0.2.4

func (c *ChainSDK) StorageData(roothash string, segment []pattern.SegmentDataInfo, minerTaskList []pattern.MinerTaskList) error

func (*ChainSDK) StoreFile added in v0.2.4

func (c *ChainSDK) StoreFile(owner []byte, file string, bucket string) (string, error)

func (*ChainSDK) SubmitFileReport

func (c *ChainSDK) SubmitFileReport(roothash []pattern.FileHash) (string, []pattern.FileHash, error)

func (*ChainSDK) SubmitIdleFile

func (c *ChainSDK) SubmitIdleFile(teeAcc []byte, idlefiles []pattern.IdleFileMeta) (string, error)

func (*ChainSDK) SubmitIdleMetadata

func (c *ChainSDK) SubmitIdleMetadata(teeAcc []byte, idlefiles []pattern.IdleMetadata) (string, error)

func (*ChainSDK) SyncState

func (c *ChainSDK) SyncState() (pattern.SysSyncState, error)

func (*ChainSDK) SysProperties

func (c *ChainSDK) SysProperties() (pattern.SysProperties, error)

func (*ChainSDK) SysVersion

func (c *ChainSDK) SysVersion() (string, error)

func (*ChainSDK) UpdateEarningsAcc

func (c *ChainSDK) UpdateEarningsAcc(puk []byte) (string, error)

func (*ChainSDK) UpdateEarningsAccount

func (c *ChainSDK) UpdateEarningsAccount(earnings string) (string, error)

func (*ChainSDK) UploadDeclaration

func (c *ChainSDK) UploadDeclaration(filehash string, dealinfo []pattern.SegmentList, user pattern.UserBrief, filesize uint64) (string, error)

func (*ChainSDK) Verify

func (c *ChainSDK) Verify(msg []byte, sig []byte) (bool, error)

func (*ChainSDK) Withdraw

func (c *ChainSDK) Withdraw() (string, error)

Withdraw

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL