Documentation
¶
Overview ¶
Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.
Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.
Index ¶
- Constants
- type EthSubscriber
- type EthSubscriberMethods
- type EthSubscriberStruct
- type FullETH
- type FullETHStruct
- type FullNode
- type FullNodeOption
- type FullNodeOptions
- type FullNodeStruct
- type IAccount
- type IAccountStruct
- type IActor
- type IActorEvent
- type IActorEventStruct
- type IActorStruct
- type IBlockStore
- type IBlockStoreStruct
- func (s *IBlockStoreStruct) ChainDeleteObj(p0 context.Context, p1 cid.Cid) error
- func (s *IBlockStoreStruct) ChainHasObj(p0 context.Context, p1 cid.Cid) (bool, error)
- func (s *IBlockStoreStruct) ChainPutObj(p0 context.Context, p1 blocks.Block) error
- func (s *IBlockStoreStruct) ChainReadObj(p0 context.Context, p1 cid.Cid) ([]byte, error)
- func (s *IBlockStoreStruct) ChainStatObj(p0 context.Context, p1 cid.Cid, p2 cid.Cid) (types.ObjStat, error)
- type IChain
- type IChainInfo
- type IChainInfoStruct
- func (s *IChainInfoStruct) BlockTime(p0 context.Context) time.Duration
- func (s *IChainInfoStruct) ChainExport(p0 context.Context, p1 abi.ChainEpoch, p2 bool, p3 types.TipSetKey) (<-chan []byte, error)
- func (s *IChainInfoStruct) ChainGetBlock(p0 context.Context, p1 cid.Cid) (*types.BlockHeader, error)
- func (s *IChainInfoStruct) ChainGetBlockMessages(p0 context.Context, p1 cid.Cid) (*types.BlockMessages, error)
- func (s *IChainInfoStruct) ChainGetEvents(p0 context.Context, p1 cid.Cid) ([]types.Event, error)
- func (s *IChainInfoStruct) ChainGetGenesis(p0 context.Context) (*types.TipSet, error)
- func (s *IChainInfoStruct) ChainGetMessage(p0 context.Context, p1 cid.Cid) (*types.Message, error)
- func (s *IChainInfoStruct) ChainGetMessagesInTipset(p0 context.Context, p1 types.TipSetKey) ([]types.MessageCID, error)
- func (s *IChainInfoStruct) ChainGetParentMessages(p0 context.Context, p1 cid.Cid) ([]types.MessageCID, error)
- func (s *IChainInfoStruct) ChainGetParentReceipts(p0 context.Context, p1 cid.Cid) ([]*types.MessageReceipt, error)
- func (s *IChainInfoStruct) ChainGetPath(p0 context.Context, p1 types.TipSetKey, p2 types.TipSetKey) ([]*types.HeadChange, error)
- func (s *IChainInfoStruct) ChainGetReceipts(p0 context.Context, p1 cid.Cid) ([]types.MessageReceipt, error)
- func (s *IChainInfoStruct) ChainGetTipSet(p0 context.Context, p1 types.TipSetKey) (*types.TipSet, error)
- func (s *IChainInfoStruct) ChainGetTipSetAfterHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)
- func (s *IChainInfoStruct) ChainGetTipSetByHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)
- func (s *IChainInfoStruct) ChainHead(p0 context.Context) (*types.TipSet, error)
- func (s *IChainInfoStruct) ChainList(p0 context.Context, p1 types.TipSetKey, p2 int) ([]types.TipSetKey, error)
- func (s *IChainInfoStruct) ChainNotify(p0 context.Context) (<-chan []*types.HeadChange, error)
- func (s *IChainInfoStruct) ChainSetHead(p0 context.Context, p1 types.TipSetKey) error
- func (s *IChainInfoStruct) GetActor(p0 context.Context, p1 address.Address) (*types.Actor, error)
- func (s *IChainInfoStruct) GetEntry(p0 context.Context, p1 abi.ChainEpoch, p2 uint64) (*types.BeaconEntry, error)
- func (s *IChainInfoStruct) GetFullBlock(p0 context.Context, p1 cid.Cid) (*types.FullBlock, error)
- func (s *IChainInfoStruct) GetParentStateRootActor(p0 context.Context, p1 *types.TipSet, p2 address.Address) (*types.Actor, error)
- func (s *IChainInfoStruct) ProtocolParameters(p0 context.Context) (*types.ProtocolParams, error)
- func (s *IChainInfoStruct) ResolveToKeyAddr(p0 context.Context, p1 address.Address, p2 *types.TipSet) (address.Address, error)
- func (s *IChainInfoStruct) StateActorCodeCIDs(p0 context.Context, p1 network.Version) (map[string]cid.Cid, error)
- func (s *IChainInfoStruct) StateActorManifestCID(p0 context.Context, p1 network.Version) (cid.Cid, error)
- func (s *IChainInfoStruct) StateCall(p0 context.Context, p1 *types.Message, p2 types.TipSetKey) (*types.InvocResult, error)
- func (s *IChainInfoStruct) StateCompute(p0 context.Context, p1 abi.ChainEpoch, p2 []*types.Message, p3 types.TipSetKey) (*types.ComputeStateOutput, error)
- func (s *IChainInfoStruct) StateGetBeaconEntry(p0 context.Context, p1 abi.ChainEpoch) (*types.BeaconEntry, error)
- func (s *IChainInfoStruct) StateGetNetworkParams(p0 context.Context) (*types.NetworkParams, error)
- func (s *IChainInfoStruct) StateGetRandomnessDigestFromBeacon(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)
- func (s *IChainInfoStruct) StateGetRandomnessDigestFromTickets(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)
- func (s *IChainInfoStruct) StateGetRandomnessFromBeacon(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, ...) (abi.Randomness, error)
- func (s *IChainInfoStruct) StateGetRandomnessFromTickets(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, ...) (abi.Randomness, error)
- func (s *IChainInfoStruct) StateMarketProposalPending(p0 context.Context, p1 cid.Cid, p2 types.TipSetKey) (bool, error)
- func (s *IChainInfoStruct) StateNetworkName(p0 context.Context) (types.NetworkName, error)
- func (s *IChainInfoStruct) StateNetworkVersion(p0 context.Context, p1 types.TipSetKey) (network.Version, error)
- func (s *IChainInfoStruct) StateReplay(p0 context.Context, p1 types.TipSetKey, p2 cid.Cid) (*types.InvocResult, error)
- func (s *IChainInfoStruct) StateSearchMsg(p0 context.Context, p1 types.TipSetKey, p2 cid.Cid, p3 abi.ChainEpoch, p4 bool) (*types.MsgLookup, error)
- func (s *IChainInfoStruct) StateVerifiedRegistryRootKey(p0 context.Context, p1 types.TipSetKey) (address.Address, error)
- func (s *IChainInfoStruct) StateVerifierStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)
- func (s *IChainInfoStruct) StateWaitMsg(p0 context.Context, p1 cid.Cid, p2 uint64, p3 abi.ChainEpoch, p4 bool) (*types.MsgLookup, error)
- func (s *IChainInfoStruct) VerifyEntry(p0, p1 *types.BeaconEntry, p2 abi.ChainEpoch) bool
- type IChainStruct
- type ICommon
- type ICommonStruct
- type IETH
- type IETHEvent
- type IETHEventStruct
- func (s *IETHEventStruct) EthGetFilterChanges(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)
- func (s *IETHEventStruct) EthGetFilterLogs(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)
- func (s *IETHEventStruct) EthGetLogs(p0 context.Context, p1 *types.EthFilterSpec) (*types.EthFilterResult, error)
- func (s *IETHEventStruct) EthNewBlockFilter(p0 context.Context) (types.EthFilterID, error)
- func (s *IETHEventStruct) EthNewFilter(p0 context.Context, p1 *types.EthFilterSpec) (types.EthFilterID, error)
- func (s *IETHEventStruct) EthNewPendingTransactionFilter(p0 context.Context) (types.EthFilterID, error)
- func (s *IETHEventStruct) EthSubscribe(p0 context.Context, p1 jsonrpc.RawParams) (types.EthSubscriptionID, error)
- func (s *IETHEventStruct) EthUninstallFilter(p0 context.Context, p1 types.EthFilterID) (bool, error)
- func (s *IETHEventStruct) EthUnsubscribe(p0 context.Context, p1 types.EthSubscriptionID) (bool, error)
- type IETHStruct
- func (s *IETHStruct) EthAccounts(p0 context.Context) ([]types.EthAddress, error)
- func (s *IETHStruct) EthAddressToFilecoinAddress(p0 context.Context, p1 types.EthAddress) (address.Address, error)
- func (s *IETHStruct) EthBlockNumber(p0 context.Context) (types.EthUint64, error)
- func (s *IETHStruct) EthCall(p0 context.Context, p1 types.EthCall, p2 types.EthBlockNumberOrHash) (types.EthBytes, error)
- func (s *IETHStruct) EthChainId(p0 context.Context) (types.EthUint64, error)
- func (s *IETHStruct) EthEstimateGas(p0 context.Context, p1 jsonrpc.RawParams) (types.EthUint64, error)
- func (s *IETHStruct) EthFeeHistory(p0 context.Context, p1 jsonrpc.RawParams) (types.EthFeeHistory, error)
- func (s *IETHStruct) EthGasPrice(p0 context.Context) (types.EthBigInt, error)
- func (s *IETHStruct) EthGetBalance(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthBigInt, error)
- func (s *IETHStruct) EthGetBlockByHash(p0 context.Context, p1 types.EthHash, p2 bool) (types.EthBlock, error)
- func (s *IETHStruct) EthGetBlockByNumber(p0 context.Context, p1 string, p2 bool) (types.EthBlock, error)
- func (s *IETHStruct) EthGetBlockReceipts(p0 context.Context, p1 types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error)
- func (s *IETHStruct) EthGetBlockReceiptsLimited(p0 context.Context, p1 types.EthBlockNumberOrHash, p2 abi.ChainEpoch) ([]*types.EthTxReceipt, error)
- func (s *IETHStruct) EthGetBlockTransactionCountByHash(p0 context.Context, p1 types.EthHash) (types.EthUint64, error)
- func (s *IETHStruct) EthGetBlockTransactionCountByNumber(p0 context.Context, p1 types.EthUint64) (types.EthUint64, error)
- func (s *IETHStruct) EthGetCode(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthBytes, error)
- func (s *IETHStruct) EthGetMessageCidByTransactionHash(p0 context.Context, p1 *types.EthHash) (*cid.Cid, error)
- func (s *IETHStruct) EthGetStorageAt(p0 context.Context, p1 types.EthAddress, p2 types.EthBytes, ...) (types.EthBytes, error)
- func (s *IETHStruct) EthGetTransactionByBlockHashAndIndex(p0 context.Context, p1 types.EthHash, p2 types.EthUint64) (types.EthTx, error)
- func (s *IETHStruct) EthGetTransactionByBlockNumberAndIndex(p0 context.Context, p1 types.EthUint64, p2 types.EthUint64) (types.EthTx, error)
- func (s *IETHStruct) EthGetTransactionByHash(p0 context.Context, p1 *types.EthHash) (*types.EthTx, error)
- func (s *IETHStruct) EthGetTransactionByHashLimited(p0 context.Context, p1 *types.EthHash, p2 abi.ChainEpoch) (*types.EthTx, error)
- func (s *IETHStruct) EthGetTransactionCount(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthUint64, error)
- func (s *IETHStruct) EthGetTransactionHashByCid(p0 context.Context, p1 cid.Cid) (*types.EthHash, error)
- func (s *IETHStruct) EthGetTransactionReceipt(p0 context.Context, p1 types.EthHash) (*types.EthTxReceipt, error)
- func (s *IETHStruct) EthGetTransactionReceiptLimited(p0 context.Context, p1 types.EthHash, p2 abi.ChainEpoch) (*types.EthTxReceipt, error)
- func (s *IETHStruct) EthMaxPriorityFeePerGas(p0 context.Context) (types.EthBigInt, error)
- func (s *IETHStruct) EthProtocolVersion(p0 context.Context) (types.EthUint64, error)
- func (s *IETHStruct) EthSendRawTransaction(p0 context.Context, p1 types.EthBytes) (types.EthHash, error)
- func (s *IETHStruct) EthSyncing(p0 context.Context) (types.EthSyncingResult, error)
- func (s *IETHStruct) EthTraceBlock(p0 context.Context, p1 string) ([]*types.EthTraceBlock, error)
- func (s *IETHStruct) EthTraceFilter(p0 context.Context, p1 types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error)
- func (s *IETHStruct) EthTraceReplayBlockTransactions(p0 context.Context, p1 string, p2 []string) ([]*types.EthTraceReplayBlockTransaction, error)
- func (s *IETHStruct) EthTraceTransaction(p0 context.Context, p1 string) ([]*types.EthTraceTransaction, error)
- func (s *IETHStruct) FilecoinAddressToEthAddress(p0 context.Context, p1 address.Address) (types.EthAddress, error)
- func (s *IETHStruct) NetListening(p0 context.Context) (bool, error)
- func (s *IETHStruct) NetVersion(p0 context.Context) (string, error)
- func (s *IETHStruct) Web3ClientVersion(p0 context.Context) (string, error)
- type IF3
- type IF3Struct
- func (s *IF3Struct) F3GetCertificate(p0 context.Context, p1 uint64) (*certs.FinalityCertificate, error)
- func (s *IF3Struct) F3GetECPowerTable(p0 context.Context, p1 types.TipSetKey) (gpbft.PowerEntries, error)
- func (s *IF3Struct) F3GetF3PowerTable(p0 context.Context, p1 types.TipSetKey) (gpbft.PowerEntries, error)
- func (s *IF3Struct) F3GetLatestCertificate(p0 context.Context) (*certs.FinalityCertificate, error)
- func (s *IF3Struct) F3GetManifest(p0 context.Context) (*manifest.Manifest, error)
- func (s *IF3Struct) F3GetOrRenewParticipationTicket(p0 context.Context, p1 address.Address, p2 types.F3ParticipationTicket, ...) (types.F3ParticipationTicket, error)
- func (s *IF3Struct) F3GetPowerTableByInstance(p0 context.Context, p1 uint64) (gpbft.PowerEntries, error)
- func (s *IF3Struct) F3GetProgress(p0 context.Context) (gpbft.InstanceProgress, error)
- func (s *IF3Struct) F3IsRunning(p0 context.Context) (bool, error)
- func (s *IF3Struct) F3ListParticipants(p0 context.Context) ([]types.F3Participant, error)
- func (s *IF3Struct) F3Participate(p0 context.Context, p1 types.F3ParticipationTicket) (types.F3ParticipationLease, error)
- type IMarket
- type IMarketStruct
- type IMessagePool
- type IMessagePoolStruct
- func (s *IMessagePoolStruct) GasBatchEstimateMessageGas(p0 context.Context, p1 []*types.EstimateMessage, p2 uint64, p3 types.TipSetKey) ([]*types.EstimateResult, error)
- func (s *IMessagePoolStruct) GasEstimateFeeCap(p0 context.Context, p1 *types.Message, p2 int64, p3 types.TipSetKey) (big.Int, error)
- func (s *IMessagePoolStruct) GasEstimateGasLimit(p0 context.Context, p1 *types.Message, p2 types.TipSetKey) (int64, error)
- func (s *IMessagePoolStruct) GasEstimateGasPremium(p0 context.Context, p1 uint64, p2 address.Address, p3 int64, ...) (big.Int, error)
- func (s *IMessagePoolStruct) GasEstimateMessageGas(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec, ...) (*types.Message, error)
- func (s *IMessagePoolStruct) MpoolBatchPush(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)
- func (s *IMessagePoolStruct) MpoolBatchPushMessage(p0 context.Context, p1 []*types.Message, p2 *types.MessageSendSpec) ([]*types.SignedMessage, error)
- func (s *IMessagePoolStruct) MpoolBatchPushUntrusted(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)
- func (s *IMessagePoolStruct) MpoolCheckMessages(p0 context.Context, p1 []*types.MessagePrototype) ([][]types.MessageCheckStatus, error)
- func (s *IMessagePoolStruct) MpoolCheckPendingMessages(p0 context.Context, p1 address.Address) ([][]types.MessageCheckStatus, error)
- func (s *IMessagePoolStruct) MpoolCheckReplaceMessages(p0 context.Context, p1 []*types.Message) ([][]types.MessageCheckStatus, error)
- func (s *IMessagePoolStruct) MpoolClear(p0 context.Context, p1 bool) error
- func (s *IMessagePoolStruct) MpoolDeleteByAdress(p0 context.Context, p1 address.Address) error
- func (s *IMessagePoolStruct) MpoolGetConfig(p0 context.Context) (*types.MpoolConfig, error)
- func (s *IMessagePoolStruct) MpoolGetNonce(p0 context.Context, p1 address.Address) (uint64, error)
- func (s *IMessagePoolStruct) MpoolPending(p0 context.Context, p1 types.TipSetKey) ([]*types.SignedMessage, error)
- func (s *IMessagePoolStruct) MpoolPublishByAddr(p0 context.Context, p1 address.Address) error
- func (s *IMessagePoolStruct) MpoolPublishMessage(p0 context.Context, p1 *types.SignedMessage) error
- func (s *IMessagePoolStruct) MpoolPush(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)
- func (s *IMessagePoolStruct) MpoolPushMessage(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec) (*types.SignedMessage, error)
- func (s *IMessagePoolStruct) MpoolPushUntrusted(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)
- func (s *IMessagePoolStruct) MpoolSelect(p0 context.Context, p1 types.TipSetKey, p2 float64) ([]*types.SignedMessage, error)
- func (s *IMessagePoolStruct) MpoolSelects(p0 context.Context, p1 types.TipSetKey, p2 []float64) ([][]*types.SignedMessage, error)
- func (s *IMessagePoolStruct) MpoolSetConfig(p0 context.Context, p1 *types.MpoolConfig) error
- func (s *IMessagePoolStruct) MpoolSub(p0 context.Context) (<-chan types.MpoolUpdate, error)
- type IMinerState
- type IMinerStateStruct
- func (s *IMinerStateStruct) StateAllMinerFaults(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) ([]*types.Fault, error)
- func (s *IMinerStateStruct) StateChangedActors(p0 context.Context, p1 cid.Cid, p2 cid.Cid) (map[string]types.Actor, error)
- func (s *IMinerStateStruct) StateCirculatingSupply(p0 context.Context, p1 types.TipSetKey) (abi.TokenAmount, error)
- func (s *IMinerStateStruct) StateComputeDataCID(p0 context.Context, p1 address.Address, p2 abi.RegisteredSealProof, ...) (cid.Cid, error)
- func (s *IMinerStateStruct) StateDealProviderCollateralBounds(p0 context.Context, p1 abi.PaddedPieceSize, p2 bool, p3 types.TipSetKey) (types.DealCollateralBounds, error)
- func (s *IMinerStateStruct) StateDecodeParams(p0 context.Context, p1 address.Address, p2 abi.MethodNum, p3 []byte, ...) (interface{}, error)
- func (s *IMinerStateStruct) StateEncodeParams(p0 context.Context, p1 cid.Cid, p2 abi.MethodNum, p3 json.RawMessage) ([]byte, error)
- func (s *IMinerStateStruct) StateGetAllAllocations(p0 context.Context, p1 types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)
- func (s *IMinerStateStruct) StateGetAllClaims(p0 context.Context, p1 types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error)
- func (s *IMinerStateStruct) StateGetAllocation(p0 context.Context, p1 address.Address, p2 verifreg.AllocationId, ...) (*verifreg.Allocation, error)
- func (s *IMinerStateStruct) StateGetAllocationForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*verifreg.Allocation, error)
- func (s *IMinerStateStruct) StateGetAllocationIdForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (verifreg.AllocationId, error)
- func (s *IMinerStateStruct) StateGetAllocations(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)
- func (s *IMinerStateStruct) StateGetClaim(p0 context.Context, p1 address.Address, p2 verifreg.ClaimId, ...) (*verifreg.Claim, error)
- func (s *IMinerStateStruct) StateGetClaims(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error)
- func (s *IMinerStateStruct) StateListActors(p0 context.Context, p1 types.TipSetKey) ([]address.Address, error)
- func (s *IMinerStateStruct) StateListMessages(p0 context.Context, p1 *types.MessageMatch, p2 types.TipSetKey, ...) ([]cid.Cid, error)
- func (s *IMinerStateStruct) StateListMiners(p0 context.Context, p1 types.TipSetKey) ([]address.Address, error)
- func (s *IMinerStateStruct) StateLookupID(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)
- func (s *IMinerStateStruct) StateLookupRobustAddress(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)
- func (s *IMinerStateStruct) StateMarketBalance(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MarketBalance, error)
- func (s *IMinerStateStruct) StateMarketDeals(p0 context.Context, p1 types.TipSetKey) (map[string]*types.MarketDeal, error)
- func (s *IMinerStateStruct) StateMarketStorageDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*types.MarketDeal, error)
- func (s *IMinerStateStruct) StateMinerActiveSectors(p0 context.Context, p1 address.Address, p2 types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)
- func (s *IMinerStateStruct) StateMinerAllocated(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*bitfield.BitField, error)
- func (s *IMinerStateStruct) StateMinerAvailableBalance(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (big.Int, error)
- func (s *IMinerStateStruct) StateMinerCreationDeposit(p0 context.Context, p1 types.TipSetKey) (types.BigInt, error)
- func (s *IMinerStateStruct) StateMinerDeadlines(p0 context.Context, p1 address.Address, p2 types.TipSetKey) ([]types.Deadline, error)
- func (s *IMinerStateStruct) StateMinerFaults(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (bitfield.BitField, error)
- func (s *IMinerStateStruct) StateMinerInfo(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MinerInfo, error)
- func (s *IMinerStateStruct) StateMinerInitialPledgeCollateral(p0 context.Context, p1 address.Address, p2 types.SectorPreCommitInfo, ...) (big.Int, error)
- func (s *IMinerStateStruct) StateMinerInitialPledgeForSector(p0 context.Context, p1 abi.ChainEpoch, p2 abi.SectorSize, p3 uint64, ...) (types.BigInt, error)
- func (s *IMinerStateStruct) StateMinerPartitions(p0 context.Context, p1 address.Address, p2 uint64, p3 types.TipSetKey) ([]types.Partition, error)
- func (s *IMinerStateStruct) StateMinerPower(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.MinerPower, error)
- func (s *IMinerStateStruct) StateMinerPreCommitDepositForPower(p0 context.Context, p1 address.Address, p2 types.SectorPreCommitInfo, ...) (big.Int, error)
- func (s *IMinerStateStruct) StateMinerProvingDeadline(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*dline.Info, error)
- func (s *IMinerStateStruct) StateMinerRecoveries(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (bitfield.BitField, error)
- func (s *IMinerStateStruct) StateMinerSectorAllocated(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, ...) (bool, error)
- func (s *IMinerStateStruct) StateMinerSectorCount(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MinerSectors, error)
- func (s *IMinerStateStruct) StateMinerSectorSize(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (abi.SectorSize, error)
- func (s *IMinerStateStruct) StateMinerSectors(p0 context.Context, p1 address.Address, p2 *bitfield.BitField, ...) ([]*lminer.SectorOnChainInfo, error)
- func (s *IMinerStateStruct) StateMinerWorkerAddress(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)
- func (s *IMinerStateStruct) StateReadState(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.ActorState, error)
- func (s *IMinerStateStruct) StateSectorExpiration(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, ...) (*lminer.SectorExpiration, error)
- func (s *IMinerStateStruct) StateSectorGetInfo(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, ...) (*lminer.SectorOnChainInfo, error)
- func (s *IMinerStateStruct) StateSectorPartition(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, ...) (*lminer.SectorLocation, error)
- func (s *IMinerStateStruct) StateSectorPreCommitInfo(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, ...) (*types.SectorPreCommitOnChainInfo, error)
- func (s *IMinerStateStruct) StateVMCirculatingSupplyInternal(p0 context.Context, p1 types.TipSetKey) (types.CirculatingSupply, error)
- func (s *IMinerStateStruct) StateVerifiedClientStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)
- type IMining
- type IMiningStruct
- type INetwork
- type INetworkStruct
- func (s *INetworkStruct) ID(p0 context.Context) (peer.ID, error)
- func (s *INetworkStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)
- func (s *INetworkStruct) NetAgentVersion(p0 context.Context, p1 peer.ID) (string, error)
- func (s *INetworkStruct) NetAutoNatStatus(p0 context.Context) (types.NatInfo, error)
- func (s *INetworkStruct) NetBandwidthStats(p0 context.Context) (metrics.Stats, error)
- func (s *INetworkStruct) NetBandwidthStatsByPeer(p0 context.Context) (map[string]metrics.Stats, error)
- func (s *INetworkStruct) NetBandwidthStatsByProtocol(p0 context.Context) (map[protocol.ID]metrics.Stats, error)
- func (s *INetworkStruct) NetConnect(p0 context.Context, p1 peer.AddrInfo) error
- func (s *INetworkStruct) NetConnectedness(p0 context.Context, p1 peer.ID) (network2.Connectedness, error)
- func (s *INetworkStruct) NetDisconnect(p0 context.Context, p1 peer.ID) error
- func (s *INetworkStruct) NetFindPeer(p0 context.Context, p1 peer.ID) (peer.AddrInfo, error)
- func (s *INetworkStruct) NetFindProvidersAsync(p0 context.Context, p1 cid.Cid, p2 int) <-chan peer.AddrInfo
- func (s *INetworkStruct) NetGetClosestPeers(p0 context.Context, p1 string) ([]peer.ID, error)
- func (s *INetworkStruct) NetPeerInfo(p0 context.Context, p1 peer.ID) (*types.ExtendedPeerInfo, error)
- func (s *INetworkStruct) NetPeers(p0 context.Context) ([]peer.AddrInfo, error)
- func (s *INetworkStruct) NetPing(p0 context.Context, p1 peer.ID) (time.Duration, error)
- func (s *INetworkStruct) NetProtectAdd(p0 context.Context, p1 []peer.ID) error
- func (s *INetworkStruct) NetProtectList(p0 context.Context) ([]peer.ID, error)
- func (s *INetworkStruct) NetProtectRemove(p0 context.Context, p1 []peer.ID) error
- func (s *INetworkStruct) NetPubsubScores(p0 context.Context) ([]types.PubsubScore, error)
- type IPaychan
- type IPaychanStruct
- func (s *IPaychanStruct) PaychAllocateLane(p0 context.Context, p1 address.Address) (uint64, error)
- func (s *IPaychanStruct) PaychAvailableFunds(p0 context.Context, p1 address.Address) (*types.ChannelAvailableFunds, error)
- func (s *IPaychanStruct) PaychAvailableFundsByFromTo(p0 context.Context, p1, p2 address.Address) (*types.ChannelAvailableFunds, error)
- func (s *IPaychanStruct) PaychCollect(p0 context.Context, p1 address.Address) (cid.Cid, error)
- func (s *IPaychanStruct) PaychFund(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (*types.ChannelInfo, error)
- func (s *IPaychanStruct) PaychGet(p0 context.Context, p1, p2 address.Address, p3 types.BigInt, ...) (*types.ChannelInfo, error)
- func (s *IPaychanStruct) PaychGetWaitReady(p0 context.Context, p1 cid.Cid) (address.Address, error)
- func (s *IPaychanStruct) PaychList(p0 context.Context) ([]address.Address, error)
- func (s *IPaychanStruct) PaychNewPayment(p0 context.Context, p1, p2 address.Address, p3 []types.VoucherSpec) (*types.PaymentInfo, error)
- func (s *IPaychanStruct) PaychSettle(p0 context.Context, p1 address.Address) (cid.Cid, error)
- func (s *IPaychanStruct) PaychStatus(p0 context.Context, p1 address.Address) (*types.Status, error)
- func (s *IPaychanStruct) PaychVoucherAdd(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, ...) (big.Int, error)
- func (s *IPaychanStruct) PaychVoucherCheckSpendable(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, ...) (bool, error)
- func (s *IPaychanStruct) PaychVoucherCheckValid(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher) error
- func (s *IPaychanStruct) PaychVoucherCreate(p0 context.Context, p1 address.Address, p2 big.Int, p3 uint64) (*types.VoucherCreateResult, error)
- func (s *IPaychanStruct) PaychVoucherList(p0 context.Context, p1 address.Address) ([]*types.SignedVoucher, error)
- func (s *IPaychanStruct) PaychVoucherSubmit(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, ...) (cid.Cid, error)
- type ISyncer
- type ISyncerStruct
- func (s *ISyncerStruct) ChainSyncHandleNewTipSet(p0 context.Context, p1 *types.ChainInfo) error
- func (s *ISyncerStruct) ChainTipSetWeight(p0 context.Context, p1 types.TipSetKey) (big.Int, error)
- func (s *ISyncerStruct) Concurrent(p0 context.Context) int64
- func (s *ISyncerStruct) SetConcurrent(p0 context.Context, p1 int64) error
- func (s *ISyncerStruct) SyncCheckpoint(p0 context.Context, p1 types.TipSetKey) error
- func (s *ISyncerStruct) SyncIncomingBlocks(p0 context.Context) (<-chan *types.BlockHeader, error)
- func (s *ISyncerStruct) SyncState(p0 context.Context) (*types.SyncState, error)
- func (s *ISyncerStruct) SyncSubmitBlock(p0 context.Context, p1 *types.BlockMsg) error
- func (s *ISyncerStruct) SyncerTracker(p0 context.Context) *types.TargetTracker
- type IWallet
- type IWalletStruct
- func (s *IWalletStruct) HasPassword(p0 context.Context) bool
- func (s *IWalletStruct) LockWallet(p0 context.Context) error
- func (s *IWalletStruct) SetPassword(p0 context.Context, p1 []byte) error
- func (s *IWalletStruct) UnLockWallet(p0 context.Context, p1 []byte) error
- func (s *IWalletStruct) WalletAddresses(p0 context.Context) []address.Address
- func (s *IWalletStruct) WalletBalance(p0 context.Context, p1 address.Address) (abi.TokenAmount, error)
- func (s *IWalletStruct) WalletDefaultAddress(p0 context.Context) (address.Address, error)
- func (s *IWalletStruct) WalletDelete(p0 context.Context, p1 address.Address) error
- func (s *IWalletStruct) WalletExport(p0 context.Context, p1 address.Address, p2 string) (*types.KeyInfo, error)
- func (s *IWalletStruct) WalletHas(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IWalletStruct) WalletImport(p0 context.Context, p1 *types.KeyInfo) (address.Address, error)
- func (s *IWalletStruct) WalletNewAddress(p0 context.Context, p1 address.Protocol) (address.Address, error)
- func (s *IWalletStruct) WalletSetDefault(p0 context.Context, p1 address.Address) error
- func (s *IWalletStruct) WalletSign(p0 context.Context, p1 address.Address, p2 []byte, p3 types.MsgMeta) (*crypto.Signature, error)
- func (s *IWalletStruct) WalletSignMessage(p0 context.Context, p1 address.Address, p2 *types.Message) (*types.SignedMessage, error)
- func (s *IWalletStruct) WalletState(p0 context.Context) int
Constants ¶
View Source
const APINamespace = "v1.FullNode"
View Source
const MajorVersion = 1
View Source
const MethodNamespace = "Filecoin"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EthSubscriber ¶ added in v1.10.0
type EthSubscriber interface {
// note: the parameter is types.EthSubscriptionResponse serialized as json object
EthSubscription(ctx context.Context, params jsonrpc.RawParams) error //rpc_method:eth_subscription notify:true
}
reverse interface to the client, called after EthSubscribe
type EthSubscriberMethods ¶ added in v1.10.0
type EthSubscriberStruct ¶ added in v1.10.0
type EthSubscriberStruct struct {
EthSubscriberMethods
}
todo: generate by venus-devtool
type FullETHStruct ¶ added in v1.10.0
type FullETHStruct struct {
IETHStruct
IETHEventStruct
}
type FullNode ¶
type FullNode interface {
IBlockStore
IChain
IMarket
IMining
IMessagePool
INetwork
IPaychan
ISyncer
IWallet
ICommon
FullETH
IActorEvent
IF3
}
func DialFullNodeRPC ¶ added in v1.2.2
func DialFullNodeRPC(ctx context.Context, addr string, token string, requestHeader http.Header, opts ...FullNodeOption) (FullNode, jsonrpc.ClientCloser, error)
DialFullNodeRPC is a more convinient way of building client, as it resolves any format (url, multiaddr) of addr string.
func NewFullNodeRPC ¶
func NewFullNodeRPC(ctx context.Context, addr string, requestHeader http.Header, opts ...FullNodeOption) (FullNode, jsonrpc.ClientCloser, error)
NewFullNodeRPC creates a new httpparse jsonrpc remotecli.
type FullNodeOption ¶ added in v1.10.0
type FullNodeOption func(*FullNodeOptions)
func FullNodeWithEthSubscribtionHandler ¶ added in v1.10.0
func FullNodeWithEthSubscribtionHandler(sh EthSubscriber) FullNodeOption
func FullNodeWithRPCOtpions ¶ added in v1.10.0
func FullNodeWithRPCOtpions(rpcOpts ...jsonrpc.Option) FullNodeOption
type FullNodeOptions ¶ added in v1.10.0
type FullNodeOptions struct {
// contains filtered or unexported fields
}
type FullNodeStruct ¶
type IAccountStruct ¶
type IActorEvent ¶ added in v1.15.0
type IActorEvent interface {
// GetActorEventsRaw returns all user-programmed and built-in actor events that match the given
// filter.
// This is a request/response API.
// Results available from this API may be limited by the MaxFilterResults and MaxFilterHeightRange
// configuration options and also the amount of historical data available in the node.
//
// This is an EXPERIMENTAL API and may be subject to change.
GetActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error) //perm:read
// SubscribeActorEventsRaw returns a long-lived stream of all user-programmed and built-in actor
// events that match the given filter.
// Events that match the given filter are written to the stream in real-time as they are emitted
// from the FVM.
// The response stream is closed when the client disconnects, when a ToHeight is specified and is
// reached, or if there is an error while writing an event to the stream.
// This API also allows clients to read all historical events matching the given filter before any
// real-time events are written to the response stream if the filter specifies an earlier
// FromHeight.
// Results available from this API may be limited by the MaxFilterResults and MaxFilterHeightRange
// configuration options and also the amount of historical data available in the node.
//
// Note: this API is only available via websocket connections.
// This is an EXPERIMENTAL API and may be subject to change.
SubscribeActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error) //perm:read
}
type IActorEventStruct ¶ added in v1.15.0
type IActorEventStruct struct {
Internal struct {
GetActorEventsRaw func(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error) `perm:"read"`
SubscribeActorEventsRaw func(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error) `perm:"read"`
}
}
func (*IActorEventStruct) GetActorEventsRaw ¶ added in v1.15.0
func (s *IActorEventStruct) GetActorEventsRaw(p0 context.Context, p1 *types.ActorEventFilter) ([]*types.ActorEvent, error)
func (*IActorEventStruct) SubscribeActorEventsRaw ¶ added in v1.15.0
func (s *IActorEventStruct) SubscribeActorEventsRaw(p0 context.Context, p1 *types.ActorEventFilter) (<-chan *types.ActorEvent, error)
type IActorStruct ¶
type IActorStruct struct {
Internal struct {
ListActor func(ctx context.Context) (map[address.Address]*types.Actor, error) `perm:"read"`
StateGetActor func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error) `perm:"read"`
}
}
type IBlockStore ¶
type IBlockStore interface {
ChainReadObj(ctx context.Context, cid cid.Cid) ([]byte, error) //perm:read
ChainDeleteObj(ctx context.Context, obj cid.Cid) error //perm:admin
ChainHasObj(ctx context.Context, obj cid.Cid) (bool, error) //perm:read
ChainStatObj(ctx context.Context, obj cid.Cid, base cid.Cid) (types.ObjStat, error) //perm:read
// ChainPutObj puts a given object into the block store
ChainPutObj(context.Context, blocks.Block) error //perm:admin
}
type IBlockStoreStruct ¶
type IBlockStoreStruct struct {
Internal struct {
ChainDeleteObj func(ctx context.Context, obj cid.Cid) error `perm:"admin"`
ChainHasObj func(ctx context.Context, obj cid.Cid) (bool, error) `perm:"read"`
ChainPutObj func(context.Context, blocks.Block) error `perm:"admin"`
ChainReadObj func(ctx context.Context, cid cid.Cid) ([]byte, error) `perm:"read"`
ChainStatObj func(ctx context.Context, obj cid.Cid, base cid.Cid) (types.ObjStat, error) `perm:"read"`
}
}
func (*IBlockStoreStruct) ChainDeleteObj ¶
func (*IBlockStoreStruct) ChainHasObj ¶
func (*IBlockStoreStruct) ChainPutObj ¶ added in v1.6.0
func (*IBlockStoreStruct) ChainReadObj ¶
type IChain ¶
type IChain interface {
IAccount
IActor
IMinerState
IChainInfo
}
type IChainInfo ¶
type IChainInfo interface {
BlockTime(ctx context.Context) time.Duration //perm:read
ChainList(ctx context.Context, tsKey types.TipSetKey, count int) ([]types.TipSetKey, error) //perm:read
ChainHead(ctx context.Context) (*types.TipSet, error) //perm:read
ChainSetHead(ctx context.Context, key types.TipSetKey) error //perm:admin
ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error) //perm:read
ChainGetTipSetByHeight(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error) //perm:read
ChainGetTipSetAfterHeight(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error) //perm:read
StateGetRandomnessFromTickets(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
StateGetRandomnessFromBeacon(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
// StateGetRandomnessDigestFromTickets is used to sample the chain for randomness.
StateGetRandomnessDigestFromTickets(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
// StateGetRandomnessDigestFromBeacon is used to sample the beacon for randomness.
StateGetRandomnessDigestFromBeacon(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
// StateGetBeaconEntry returns the beacon entry for the given filecoin epoch
// by using the recorded entries on the chain. If the entry for the requested
// epoch has not yet been produced, the call will block until the entry
// becomes available.
StateGetBeaconEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error) //perm:read
ChainGetBlock(ctx context.Context, id cid.Cid) (*types.BlockHeader, error) //perm:read
ChainGetMessage(ctx context.Context, msgID cid.Cid) (*types.Message, error) //perm:read
ChainGetBlockMessages(ctx context.Context, bid cid.Cid) (*types.BlockMessages, error) //perm:read
ChainGetMessagesInTipset(ctx context.Context, key types.TipSetKey) ([]types.MessageCID, error) //perm:read
ChainGetReceipts(ctx context.Context, id cid.Cid) ([]types.MessageReceipt, error) //perm:read
ChainGetParentMessages(ctx context.Context, bcid cid.Cid) ([]types.MessageCID, error) //perm:read
ChainGetParentReceipts(ctx context.Context, bcid cid.Cid) ([]*types.MessageReceipt, error) //perm:read
StateVerifiedRegistryRootKey(ctx context.Context, tsk types.TipSetKey) (address.Address, error) //perm:read
StateVerifierStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error) //perm:read
ChainNotify(ctx context.Context) (<-chan []*types.HeadChange, error) //perm:read
GetFullBlock(ctx context.Context, id cid.Cid) (*types.FullBlock, error) //perm:read
GetActor(ctx context.Context, addr address.Address) (*types.Actor, error) //perm:read
GetParentStateRootActor(ctx context.Context, ts *types.TipSet, addr address.Address) (*types.Actor, error) //perm:read
GetEntry(ctx context.Context, height abi.ChainEpoch, round uint64) (*types.BeaconEntry, error) //perm:read
ProtocolParameters(ctx context.Context) (*types.ProtocolParams, error) //perm:read
ResolveToKeyAddr(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) //perm:read
StateNetworkName(ctx context.Context) (types.NetworkName, error) //perm:read
// StateSearchMsg looks back up to limit epochs in the chain for a message, and returns its receipt and the tipset where it was executed
//
// NOTE: If a replacing message is found on chain, this method will return
// a MsgLookup for the replacing message - the MsgLookup.Message will be a different
// CID than the one provided in the 'cid' param, MsgLookup.Receipt will contain the
// result of the execution of the replacing message.
//
// If the caller wants to ensure that exactly the requested message was executed,
// they must check that MsgLookup.Message is equal to the provided 'cid', or set the
// `allowReplaced` parameter to false. Without this check, and with `allowReplaced`
// set to true, both the requested and original message may appear as
// successfully executed on-chain, which may look like a double-spend.
//
// A replacing message is a message with a different CID, any of Gas values, and
// different signature, but with all other parameters matching (source/destination,
// nonce, params, etc.)
StateSearchMsg(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) //perm:read
// StateWaitMsg looks back up to limit epochs in the chain for a message.
// If not found, it blocks until the message arrives on chain, and gets to the
// indicated confidence depth.
//
// NOTE: If a replacing message is found on chain, this method will return
// a MsgLookup for the replacing message - the MsgLookup.Message will be a different
// CID than the one provided in the 'cid' param, MsgLookup.Receipt will contain the
// result of the execution of the replacing message.
//
// If the caller wants to ensure that exactly the requested message was executed,
// they must check that MsgLookup.Message is equal to the provided 'cid', or set the
// `allowReplaced` parameter to false. Without this check, and with `allowReplaced`
// set to true, both the requested and original message may appear as
// successfully executed on-chain, which may look like a double-spend.
//
// A replacing message is a message with a different CID, any of Gas values, and
// different signature, but with all other parameters matching (source/destination,
// nonce, params, etc.)
StateWaitMsg(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) //perm:read
StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error) //perm:read
VerifyEntry(parent, child *types.BeaconEntry, height abi.ChainEpoch) bool //perm:read
ChainExport(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error) //perm:read
ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*types.HeadChange, error) //perm:read
// StateGetNetworkParams return current network params
StateGetNetworkParams(ctx context.Context) (*types.NetworkParams, error) //perm:read
// StateActorCodeCIDs returns the CIDs of all the builtin actors for the given network version
StateActorCodeCIDs(context.Context, network.Version) (map[string]cid.Cid, error) //perm:read
// ChainGetGenesis returns the genesis tipset.
ChainGetGenesis(context.Context) (*types.TipSet, error) //perm:read
// StateActorManifestCID returns the CID of the builtin actors manifest for the given network version
StateActorManifestCID(context.Context, network.Version) (cid.Cid, error) //perm:read
StateCall(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*types.InvocResult, error) //perm:read
StateReplay(context.Context, types.TipSetKey, cid.Cid) (*types.InvocResult, error) //perm:read
// ChainGetEvents returns the events under an event AMT root CID.
ChainGetEvents(context.Context, cid.Cid) ([]types.Event, error) //perm:read
// StateCompute is a flexible command that applies the given messages on the given tipset.
// The messages are run as though the VM were at the provided height.
//
// When called, StateCompute will:
// - Load the provided tipset, or use the current chain head if not provided
// - Compute the tipset state of the provided tipset on top of the parent state
// - (note that this step runs before vmheight is applied to the execution)
// - Execute state upgrade if any were scheduled at the epoch, or in null
// blocks preceding the tipset
// - Call the cron actor on null blocks preceding the tipset
// - For each block in the tipset
// - Apply messages in blocks in the specified
// - Award block reward by calling the reward actor
// - Call the cron actor for the current epoch
// - If the specified vmheight is higher than the current epoch, apply any
// needed state upgrades to the state
// - Apply the specified messages to the state
//
// The vmheight parameter sets VM execution epoch, and can be used to simulate
// message execution in different network versions. If the specified vmheight
// epoch is higher than the epoch of the specified tipset, any state upgrades
// until the vmheight will be executed on the state before applying messages
// specified by the user.
//
// Note that the initial tipset state computation is not affected by the
// vmheight parameter - only the messages in the `apply` set are
//
// If the caller wants to simply compute the state, vmheight should be set to
// the epoch of the specified tipset.
//
// Messages in the `apply` parameter must have the correct nonces, and gas
// values set.
StateCompute(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*types.ComputeStateOutput, error) //perm:read
// StateMarketProposalPending returns whether a given proposal CID is marked as pending in the market actor
StateMarketProposalPending(ctx context.Context, proposalCid cid.Cid, tsk types.TipSetKey) (bool, error) //perm:read
}
type IChainInfoStruct ¶
type IChainInfoStruct struct {
Internal struct {
BlockTime func(ctx context.Context) time.Duration `perm:"read"`
ChainExport func(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error) `perm:"read"`
ChainGetBlock func(ctx context.Context, id cid.Cid) (*types.BlockHeader, error) `perm:"read"`
ChainGetBlockMessages func(ctx context.Context, bid cid.Cid) (*types.BlockMessages, error) `perm:"read"`
ChainGetEvents func(context.Context, cid.Cid) ([]types.Event, error) `perm:"read"`
ChainGetGenesis func(context.Context) (*types.TipSet, error) `perm:"read"`
ChainGetMessage func(ctx context.Context, msgID cid.Cid) (*types.Message, error) `perm:"read"`
ChainGetMessagesInTipset func(ctx context.Context, key types.TipSetKey) ([]types.MessageCID, error) `perm:"read"`
ChainGetParentMessages func(ctx context.Context, bcid cid.Cid) ([]types.MessageCID, error) `perm:"read"`
ChainGetParentReceipts func(ctx context.Context, bcid cid.Cid) ([]*types.MessageReceipt, error) `perm:"read"`
ChainGetPath func(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*types.HeadChange, error) `perm:"read"`
ChainGetReceipts func(ctx context.Context, id cid.Cid) ([]types.MessageReceipt, error) `perm:"read"`
ChainGetTipSet func(ctx context.Context, key types.TipSetKey) (*types.TipSet, error) `perm:"read"`
ChainGetTipSetAfterHeight func(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error) `perm:"read"`
ChainGetTipSetByHeight func(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error) `perm:"read"`
ChainHead func(ctx context.Context) (*types.TipSet, error) `perm:"read"`
ChainList func(ctx context.Context, tsKey types.TipSetKey, count int) ([]types.TipSetKey, error) `perm:"read"`
ChainNotify func(ctx context.Context) (<-chan []*types.HeadChange, error) `perm:"read"`
ChainSetHead func(ctx context.Context, key types.TipSetKey) error `perm:"admin"`
GetActor func(ctx context.Context, addr address.Address) (*types.Actor, error) `perm:"read"`
GetEntry func(ctx context.Context, height abi.ChainEpoch, round uint64) (*types.BeaconEntry, error) `perm:"read"`
GetFullBlock func(ctx context.Context, id cid.Cid) (*types.FullBlock, error) `perm:"read"`
GetParentStateRootActor func(ctx context.Context, ts *types.TipSet, addr address.Address) (*types.Actor, error) `perm:"read"`
ProtocolParameters func(ctx context.Context) (*types.ProtocolParams, error) `perm:"read"`
ResolveToKeyAddr func(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) `perm:"read"`
StateActorCodeCIDs func(context.Context, network.Version) (map[string]cid.Cid, error) `perm:"read"`
StateActorManifestCID func(context.Context, network.Version) (cid.Cid, error) `perm:"read"`
StateCall func(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*types.InvocResult, error) `perm:"read"`
StateCompute func(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*types.ComputeStateOutput, error) `perm:"read"`
StateGetBeaconEntry func(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error) `perm:"read"`
StateGetNetworkParams func(ctx context.Context) (*types.NetworkParams, error) `perm:"read"`
StateGetRandomnessDigestFromBeacon func(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
StateGetRandomnessDigestFromTickets func(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
StateGetRandomnessFromBeacon func(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
StateGetRandomnessFromTickets func(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
StateMarketProposalPending func(ctx context.Context, proposalCid cid.Cid, tsk types.TipSetKey) (bool, error) `perm:"read"`
StateNetworkName func(ctx context.Context) (types.NetworkName, error) `perm:"read"`
StateNetworkVersion func(ctx context.Context, tsk types.TipSetKey) (network.Version, error) `perm:"read"`
StateReplay func(context.Context, types.TipSetKey, cid.Cid) (*types.InvocResult, error) `perm:"read"`
StateSearchMsg func(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) `perm:"read"`
StateVerifiedRegistryRootKey func(ctx context.Context, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
StateVerifierStatus func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error) `perm:"read"`
StateWaitMsg func(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) `perm:"read"`
VerifyEntry func(parent, child *types.BeaconEntry, height abi.ChainEpoch) bool `perm:"read"`
}
}
func (*IChainInfoStruct) BlockTime ¶
func (s *IChainInfoStruct) BlockTime(p0 context.Context) time.Duration
func (*IChainInfoStruct) ChainExport ¶
func (s *IChainInfoStruct) ChainExport(p0 context.Context, p1 abi.ChainEpoch, p2 bool, p3 types.TipSetKey) (<-chan []byte, error)
func (*IChainInfoStruct) ChainGetBlock ¶
func (s *IChainInfoStruct) ChainGetBlock(p0 context.Context, p1 cid.Cid) (*types.BlockHeader, error)
func (*IChainInfoStruct) ChainGetBlockMessages ¶
func (s *IChainInfoStruct) ChainGetBlockMessages(p0 context.Context, p1 cid.Cid) (*types.BlockMessages, error)
func (*IChainInfoStruct) ChainGetEvents ¶ added in v1.10.0
func (*IChainInfoStruct) ChainGetGenesis ¶ added in v1.8.0
func (*IChainInfoStruct) ChainGetMessage ¶
func (*IChainInfoStruct) ChainGetMessagesInTipset ¶
func (s *IChainInfoStruct) ChainGetMessagesInTipset(p0 context.Context, p1 types.TipSetKey) ([]types.MessageCID, error)
func (*IChainInfoStruct) ChainGetParentMessages ¶
func (s *IChainInfoStruct) ChainGetParentMessages(p0 context.Context, p1 cid.Cid) ([]types.MessageCID, error)
func (*IChainInfoStruct) ChainGetParentReceipts ¶
func (s *IChainInfoStruct) ChainGetParentReceipts(p0 context.Context, p1 cid.Cid) ([]*types.MessageReceipt, error)
func (*IChainInfoStruct) ChainGetPath ¶
func (s *IChainInfoStruct) ChainGetPath(p0 context.Context, p1 types.TipSetKey, p2 types.TipSetKey) ([]*types.HeadChange, error)
func (*IChainInfoStruct) ChainGetReceipts ¶
func (s *IChainInfoStruct) ChainGetReceipts(p0 context.Context, p1 cid.Cid) ([]types.MessageReceipt, error)
func (*IChainInfoStruct) ChainGetTipSet ¶
func (*IChainInfoStruct) ChainGetTipSetAfterHeight ¶
func (s *IChainInfoStruct) ChainGetTipSetAfterHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)
func (*IChainInfoStruct) ChainGetTipSetByHeight ¶
func (s *IChainInfoStruct) ChainGetTipSetByHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)
func (*IChainInfoStruct) ChainNotify ¶
func (s *IChainInfoStruct) ChainNotify(p0 context.Context) (<-chan []*types.HeadChange, error)
func (*IChainInfoStruct) ChainSetHead ¶
func (*IChainInfoStruct) GetEntry ¶
func (s *IChainInfoStruct) GetEntry(p0 context.Context, p1 abi.ChainEpoch, p2 uint64) (*types.BeaconEntry, error)
func (*IChainInfoStruct) GetFullBlock ¶
func (*IChainInfoStruct) GetParentStateRootActor ¶
func (*IChainInfoStruct) ProtocolParameters ¶
func (s *IChainInfoStruct) ProtocolParameters(p0 context.Context) (*types.ProtocolParams, error)
func (*IChainInfoStruct) ResolveToKeyAddr ¶
func (*IChainInfoStruct) StateActorCodeCIDs ¶ added in v1.6.0
func (*IChainInfoStruct) StateActorManifestCID ¶ added in v1.8.0
func (*IChainInfoStruct) StateCall ¶ added in v1.8.0
func (s *IChainInfoStruct) StateCall(p0 context.Context, p1 *types.Message, p2 types.TipSetKey) (*types.InvocResult, error)
func (*IChainInfoStruct) StateCompute ¶ added in v1.10.1
func (s *IChainInfoStruct) StateCompute(p0 context.Context, p1 abi.ChainEpoch, p2 []*types.Message, p3 types.TipSetKey) (*types.ComputeStateOutput, error)
func (*IChainInfoStruct) StateGetBeaconEntry ¶ added in v1.6.0
func (s *IChainInfoStruct) StateGetBeaconEntry(p0 context.Context, p1 abi.ChainEpoch) (*types.BeaconEntry, error)
func (*IChainInfoStruct) StateGetNetworkParams ¶ added in v1.6.0
func (s *IChainInfoStruct) StateGetNetworkParams(p0 context.Context) (*types.NetworkParams, error)
func (*IChainInfoStruct) StateGetRandomnessDigestFromBeacon ¶ added in v1.14.0
func (s *IChainInfoStruct) StateGetRandomnessDigestFromBeacon(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)
func (*IChainInfoStruct) StateGetRandomnessDigestFromTickets ¶ added in v1.14.0
func (s *IChainInfoStruct) StateGetRandomnessDigestFromTickets(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)
func (*IChainInfoStruct) StateGetRandomnessFromBeacon ¶
func (s *IChainInfoStruct) StateGetRandomnessFromBeacon(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, p3 []byte, p4 types.TipSetKey) (abi.Randomness, error)
func (*IChainInfoStruct) StateGetRandomnessFromTickets ¶
func (s *IChainInfoStruct) StateGetRandomnessFromTickets(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, p3 []byte, p4 types.TipSetKey) (abi.Randomness, error)
func (*IChainInfoStruct) StateMarketProposalPending ¶ added in v1.18.0
func (*IChainInfoStruct) StateNetworkName ¶
func (s *IChainInfoStruct) StateNetworkName(p0 context.Context) (types.NetworkName, error)
func (*IChainInfoStruct) StateNetworkVersion ¶
func (*IChainInfoStruct) StateReplay ¶ added in v1.10.0
func (s *IChainInfoStruct) StateReplay(p0 context.Context, p1 types.TipSetKey, p2 cid.Cid) (*types.InvocResult, error)
func (*IChainInfoStruct) StateSearchMsg ¶
func (*IChainInfoStruct) StateVerifiedRegistryRootKey ¶
func (*IChainInfoStruct) StateVerifierStatus ¶
func (s *IChainInfoStruct) StateVerifierStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)
func (*IChainInfoStruct) StateWaitMsg ¶
func (*IChainInfoStruct) VerifyEntry ¶
func (s *IChainInfoStruct) VerifyEntry(p0, p1 *types.BeaconEntry, p2 abi.ChainEpoch) bool
type IChainStruct ¶
type IChainStruct struct {
IAccountStruct
IActorStruct
IMinerStateStruct
IChainInfoStruct
}
type ICommonStruct ¶ added in v1.7.0
type ICommonStruct struct {
Internal struct {
NodeStatus func(ctx context.Context, inclChainStatus bool) (types.NodeStatus, error) `perm:"read"`
StartTime func(context.Context) (time.Time, error) `perm:"read"`
Version func(ctx context.Context) (types.Version, error) `perm:"read"`
}
}
func (*ICommonStruct) NodeStatus ¶ added in v1.9.0
func (s *ICommonStruct) NodeStatus(p0 context.Context, p1 bool) (types.NodeStatus, error)
type IETH ¶ added in v1.10.0
type IETH interface {
// These methods are used for Ethereum-compatible JSON-RPC calls
//
// EthAccounts will always return [] since we don't expect Lotus to manage private keys
EthAccounts(ctx context.Context) ([]types.EthAddress, error) //perm:read
// EthAddressToFilecoinAddress converts an EthAddress into an f410 Filecoin Address
EthAddressToFilecoinAddress(ctx context.Context, ethAddress types.EthAddress) (address.Address, error) //perm:read
// FilecoinAddressToEthAddress converts an f410 or f0 Filecoin Address to an EthAddress
FilecoinAddressToEthAddress(ctx context.Context, filecoinAddress address.Address) (types.EthAddress, error) //perm:read
// EthBlockNumber returns the height of the latest (heaviest) TipSet
EthBlockNumber(ctx context.Context) (types.EthUint64, error) //perm:read
// EthGetBlockTransactionCountByNumber returns the number of messages in the TipSet
EthGetBlockTransactionCountByNumber(ctx context.Context, blkNum types.EthUint64) (types.EthUint64, error) //perm:read
// EthGetBlockTransactionCountByHash returns the number of messages in the TipSet
EthGetBlockTransactionCountByHash(ctx context.Context, blkHash types.EthHash) (types.EthUint64, error) //perm:read
EthGetBlockByHash(ctx context.Context, blkHash types.EthHash, fullTxInfo bool) (types.EthBlock, error) //perm:read
EthGetBlockByNumber(ctx context.Context, blkNum string, fullTxInfo bool) (types.EthBlock, error) //perm:read
EthGetTransactionByHash(ctx context.Context, txHash *types.EthHash) (*types.EthTx, error) //perm:read
EthGetTransactionByHashLimited(ctx context.Context, txHash *types.EthHash, limit abi.ChainEpoch) (*types.EthTx, error) //perm:read
EthGetTransactionHashByCid(ctx context.Context, cid cid.Cid) (*types.EthHash, error) //perm:read
EthGetMessageCidByTransactionHash(ctx context.Context, txHash *types.EthHash) (*cid.Cid, error) //perm:read
EthGetTransactionCount(ctx context.Context, sender types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthUint64, error) //perm:read
EthGetBlockReceipts(ctx context.Context, blkParam types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error) //perm:read
EthGetBlockReceiptsLimited(ctx context.Context, blkParam types.EthBlockNumberOrHash, limit abi.ChainEpoch) ([]*types.EthTxReceipt, error) //perm:read
EthGetTransactionReceipt(ctx context.Context, txHash types.EthHash) (*types.EthTxReceipt, error) //perm:read
EthGetTransactionReceiptLimited(ctx context.Context, txHash types.EthHash, limit abi.ChainEpoch) (*types.EthTxReceipt, error) //perm:read
EthGetTransactionByBlockHashAndIndex(ctx context.Context, blkHash types.EthHash, txIndex types.EthUint64) (types.EthTx, error) //perm:read
EthGetTransactionByBlockNumberAndIndex(ctx context.Context, blkNum types.EthUint64, txIndex types.EthUint64) (types.EthTx, error) //perm:read
EthGetCode(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) //perm:read
EthGetStorageAt(ctx context.Context, address types.EthAddress, position types.EthBytes, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) //perm:read
EthGetBalance(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBigInt, error) //perm:read
EthChainId(ctx context.Context) (types.EthUint64, error) //perm:read
EthSyncing(ctx context.Context) (types.EthSyncingResult, error) //perm:read
NetVersion(ctx context.Context) (string, error) //perm:read
NetListening(ctx context.Context) (bool, error) //perm:read
EthProtocolVersion(ctx context.Context) (types.EthUint64, error) //perm:read
EthGasPrice(ctx context.Context) (types.EthBigInt, error) //perm:read
EthFeeHistory(ctx context.Context, p jsonrpc.RawParams) (types.EthFeeHistory, error) //perm:read
EthMaxPriorityFeePerGas(ctx context.Context) (types.EthBigInt, error) //perm:read
EthEstimateGas(ctx context.Context, p jsonrpc.RawParams) (types.EthUint64, error) //perm:read
EthCall(ctx context.Context, tx types.EthCall, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) //perm:read
EthSendRawTransaction(ctx context.Context, rawTx types.EthBytes) (types.EthHash, error) //perm:read
// Returns the client version
Web3ClientVersion(ctx context.Context) (string, error) //perm:read
// Returns an OpenEthereum-compatible trace of the given block (implementing `trace_block`),
// translating Filecoin semantics into Ethereum semantics and tracing both EVM and FVM calls.
//
// Features:
//
// - FVM actor create events, calls, etc. show up as if they were EVM smart contract events.
// - Native FVM call inputs are ABI-encoded (Solidity ABI) as if they were calls to a
// `handle_filecoin_method(uint64 method, uint64 codec, bytes params)` function
// (where `codec` is the IPLD codec of `params`).
// - Native FVM call outputs (return values) are ABI-encoded as `(uint32 exit_code, uint64
// codec, bytes output)` where `codec` is the IPLD codec of `output`.
//
// Limitations (for now):
//
// 1. Block rewards are not included in the trace.
// 2. SELFDESTRUCT operations are not included in the trace.
// 3. EVM smart contract "create" events always specify `0xfe` as the "code" for newly created EVM smart contracts.
EthTraceBlock(ctx context.Context, blkNum string) ([]*types.EthTraceBlock, error) //perm:read
// Replays all transactions in a block returning the requested traces for each transaction
EthTraceReplayBlockTransactions(ctx context.Context, blkNum string, traceTypes []string) ([]*types.EthTraceReplayBlockTransaction, error) //perm:read
// Implmements OpenEthereum-compatible API method trace_transaction
EthTraceTransaction(ctx context.Context, txHash string) ([]*types.EthTraceTransaction, error) //perm:read
// Implements OpenEthereum-compatible API method trace_filter
EthTraceFilter(ctx context.Context, filter types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error) //perm:read
}
type IETHEvent ¶ added in v1.10.0
type IETHEvent interface {
// Returns event logs matching given filter spec.
EthGetLogs(ctx context.Context, filter *types.EthFilterSpec) (*types.EthFilterResult, error) //perm:read
// Polling method for a filter, returns event logs which occurred since last poll.
// (requires write perm since timestamp of last filter execution will be written)
EthGetFilterChanges(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) //perm:read
// Returns event logs matching filter with given id.
// (requires write perm since timestamp of last filter execution will be written)
EthGetFilterLogs(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) //perm:read
// Installs a persistent filter based on given filter spec.
EthNewFilter(ctx context.Context, filter *types.EthFilterSpec) (types.EthFilterID, error) //perm:read
// Installs a persistent filter to notify when a new block arrives.
EthNewBlockFilter(ctx context.Context) (types.EthFilterID, error) //perm:read
// Installs a persistent filter to notify when new messages arrive in the message pool.
EthNewPendingTransactionFilter(ctx context.Context) (types.EthFilterID, error) //perm:read
// Uninstalls a filter with given id.
EthUninstallFilter(ctx context.Context, id types.EthFilterID) (bool, error) //perm:read
// Subscribe to different event types using websockets
// eventTypes is one or more of:
// - newHeads: notify when new blocks arrive.
// - pendingTransactions: notify when new messages arrive in the message pool.
// - logs: notify new event logs that match a criteria
// params contains additional parameters used with the log event type
// The client will receive a stream of EthSubscriptionResponse values until EthUnsubscribe is called.
EthSubscribe(ctx context.Context, params jsonrpc.RawParams) (types.EthSubscriptionID, error) //perm:read
// Unsubscribe from a websocket subscription
EthUnsubscribe(ctx context.Context, id types.EthSubscriptionID) (bool, error) //perm:read
}
type IETHEventStruct ¶ added in v1.10.0
type IETHEventStruct struct {
Internal struct {
EthGetFilterChanges func(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) `perm:"read"`
EthGetFilterLogs func(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) `perm:"read"`
EthGetLogs func(ctx context.Context, filter *types.EthFilterSpec) (*types.EthFilterResult, error) `perm:"read"`
EthNewBlockFilter func(ctx context.Context) (types.EthFilterID, error) `perm:"read"`
EthNewFilter func(ctx context.Context, filter *types.EthFilterSpec) (types.EthFilterID, error) `perm:"read"`
EthNewPendingTransactionFilter func(ctx context.Context) (types.EthFilterID, error) `perm:"read"`
EthSubscribe func(ctx context.Context, params jsonrpc.RawParams) (types.EthSubscriptionID, error) `perm:"read"`
EthUninstallFilter func(ctx context.Context, id types.EthFilterID) (bool, error) `perm:"read"`
EthUnsubscribe func(ctx context.Context, id types.EthSubscriptionID) (bool, error) `perm:"read"`
}
}
func (*IETHEventStruct) EthGetFilterChanges ¶ added in v1.10.0
func (s *IETHEventStruct) EthGetFilterChanges(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)
func (*IETHEventStruct) EthGetFilterLogs ¶ added in v1.10.0
func (s *IETHEventStruct) EthGetFilterLogs(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)
func (*IETHEventStruct) EthGetLogs ¶ added in v1.10.0
func (s *IETHEventStruct) EthGetLogs(p0 context.Context, p1 *types.EthFilterSpec) (*types.EthFilterResult, error)
func (*IETHEventStruct) EthNewBlockFilter ¶ added in v1.10.0
func (s *IETHEventStruct) EthNewBlockFilter(p0 context.Context) (types.EthFilterID, error)
func (*IETHEventStruct) EthNewFilter ¶ added in v1.10.0
func (s *IETHEventStruct) EthNewFilter(p0 context.Context, p1 *types.EthFilterSpec) (types.EthFilterID, error)
func (*IETHEventStruct) EthNewPendingTransactionFilter ¶ added in v1.10.0
func (s *IETHEventStruct) EthNewPendingTransactionFilter(p0 context.Context) (types.EthFilterID, error)
func (*IETHEventStruct) EthSubscribe ¶ added in v1.10.0
func (s *IETHEventStruct) EthSubscribe(p0 context.Context, p1 jsonrpc.RawParams) (types.EthSubscriptionID, error)
func (*IETHEventStruct) EthUninstallFilter ¶ added in v1.10.0
func (s *IETHEventStruct) EthUninstallFilter(p0 context.Context, p1 types.EthFilterID) (bool, error)
func (*IETHEventStruct) EthUnsubscribe ¶ added in v1.10.0
func (s *IETHEventStruct) EthUnsubscribe(p0 context.Context, p1 types.EthSubscriptionID) (bool, error)
type IETHStruct ¶ added in v1.10.0
type IETHStruct struct {
Internal struct {
EthAccounts func(ctx context.Context) ([]types.EthAddress, error) `perm:"read"`
EthAddressToFilecoinAddress func(ctx context.Context, ethAddress types.EthAddress) (address.Address, error) `perm:"read"`
EthBlockNumber func(ctx context.Context) (types.EthUint64, error) `perm:"read"`
EthCall func(ctx context.Context, tx types.EthCall, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) `perm:"read"`
EthChainId func(ctx context.Context) (types.EthUint64, error) `perm:"read"`
EthEstimateGas func(ctx context.Context, p jsonrpc.RawParams) (types.EthUint64, error) `perm:"read"`
EthFeeHistory func(ctx context.Context, p jsonrpc.RawParams) (types.EthFeeHistory, error) `perm:"read"`
EthGasPrice func(ctx context.Context) (types.EthBigInt, error) `perm:"read"`
EthGetBalance func(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBigInt, error) `perm:"read"`
EthGetBlockByHash func(ctx context.Context, blkHash types.EthHash, fullTxInfo bool) (types.EthBlock, error) `perm:"read"`
EthGetBlockByNumber func(ctx context.Context, blkNum string, fullTxInfo bool) (types.EthBlock, error) `perm:"read"`
EthGetBlockReceipts func(ctx context.Context, blkParam types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error) `perm:"read"`
EthGetBlockReceiptsLimited func(ctx context.Context, blkParam types.EthBlockNumberOrHash, limit abi.ChainEpoch) ([]*types.EthTxReceipt, error) `perm:"read"`
EthGetBlockTransactionCountByHash func(ctx context.Context, blkHash types.EthHash) (types.EthUint64, error) `perm:"read"`
EthGetBlockTransactionCountByNumber func(ctx context.Context, blkNum types.EthUint64) (types.EthUint64, error) `perm:"read"`
EthGetCode func(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) `perm:"read"`
EthGetMessageCidByTransactionHash func(ctx context.Context, txHash *types.EthHash) (*cid.Cid, error) `perm:"read"`
EthGetStorageAt func(ctx context.Context, address types.EthAddress, position types.EthBytes, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) `perm:"read"`
EthGetTransactionByBlockHashAndIndex func(ctx context.Context, blkHash types.EthHash, txIndex types.EthUint64) (types.EthTx, error) `perm:"read"`
EthGetTransactionByBlockNumberAndIndex func(ctx context.Context, blkNum types.EthUint64, txIndex types.EthUint64) (types.EthTx, error) `perm:"read"`
EthGetTransactionByHash func(ctx context.Context, txHash *types.EthHash) (*types.EthTx, error) `perm:"read"`
EthGetTransactionByHashLimited func(ctx context.Context, txHash *types.EthHash, limit abi.ChainEpoch) (*types.EthTx, error) `perm:"read"`
EthGetTransactionCount func(ctx context.Context, sender types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthUint64, error) `perm:"read"`
EthGetTransactionHashByCid func(ctx context.Context, cid cid.Cid) (*types.EthHash, error) `perm:"read"`
EthGetTransactionReceipt func(ctx context.Context, txHash types.EthHash) (*types.EthTxReceipt, error) `perm:"read"`
EthGetTransactionReceiptLimited func(ctx context.Context, txHash types.EthHash, limit abi.ChainEpoch) (*types.EthTxReceipt, error) `perm:"read"`
EthMaxPriorityFeePerGas func(ctx context.Context) (types.EthBigInt, error) `perm:"read"`
EthProtocolVersion func(ctx context.Context) (types.EthUint64, error) `perm:"read"`
EthSendRawTransaction func(ctx context.Context, rawTx types.EthBytes) (types.EthHash, error) `perm:"read"`
EthSyncing func(ctx context.Context) (types.EthSyncingResult, error) `perm:"read"`
EthTraceBlock func(ctx context.Context, blkNum string) ([]*types.EthTraceBlock, error) `perm:"read"`
EthTraceFilter func(ctx context.Context, filter types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error) `perm:"read"`
EthTraceReplayBlockTransactions func(ctx context.Context, blkNum string, traceTypes []string) ([]*types.EthTraceReplayBlockTransaction, error) `perm:"read"`
EthTraceTransaction func(ctx context.Context, txHash string) ([]*types.EthTraceTransaction, error) `perm:"read"`
FilecoinAddressToEthAddress func(ctx context.Context, filecoinAddress address.Address) (types.EthAddress, error) `perm:"read"`
NetListening func(ctx context.Context) (bool, error) `perm:"read"`
NetVersion func(ctx context.Context) (string, error) `perm:"read"`
Web3ClientVersion func(ctx context.Context) (string, error) `perm:"read"`
}
}
func (*IETHStruct) EthAccounts ¶ added in v1.10.0
func (s *IETHStruct) EthAccounts(p0 context.Context) ([]types.EthAddress, error)
func (*IETHStruct) EthAddressToFilecoinAddress ¶ added in v1.10.0
func (s *IETHStruct) EthAddressToFilecoinAddress(p0 context.Context, p1 types.EthAddress) (address.Address, error)
func (*IETHStruct) EthBlockNumber ¶ added in v1.10.0
func (*IETHStruct) EthCall ¶ added in v1.10.0
func (s *IETHStruct) EthCall(p0 context.Context, p1 types.EthCall, p2 types.EthBlockNumberOrHash) (types.EthBytes, error)
func (*IETHStruct) EthChainId ¶ added in v1.10.0
func (*IETHStruct) EthEstimateGas ¶ added in v1.10.0
func (*IETHStruct) EthFeeHistory ¶ added in v1.10.0
func (s *IETHStruct) EthFeeHistory(p0 context.Context, p1 jsonrpc.RawParams) (types.EthFeeHistory, error)
func (*IETHStruct) EthGasPrice ¶ added in v1.10.0
func (*IETHStruct) EthGetBalance ¶ added in v1.10.0
func (s *IETHStruct) EthGetBalance(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthBigInt, error)
func (*IETHStruct) EthGetBlockByHash ¶ added in v1.10.0
func (*IETHStruct) EthGetBlockByNumber ¶ added in v1.10.0
func (*IETHStruct) EthGetBlockReceipts ¶ added in v1.17.0
func (s *IETHStruct) EthGetBlockReceipts(p0 context.Context, p1 types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error)
func (*IETHStruct) EthGetBlockReceiptsLimited ¶ added in v1.17.0
func (s *IETHStruct) EthGetBlockReceiptsLimited(p0 context.Context, p1 types.EthBlockNumberOrHash, p2 abi.ChainEpoch) ([]*types.EthTxReceipt, error)
func (*IETHStruct) EthGetBlockTransactionCountByHash ¶ added in v1.10.0
func (*IETHStruct) EthGetBlockTransactionCountByNumber ¶ added in v1.10.0
func (*IETHStruct) EthGetCode ¶ added in v1.10.0
func (s *IETHStruct) EthGetCode(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthBytes, error)
func (*IETHStruct) EthGetMessageCidByTransactionHash ¶ added in v1.10.0
func (*IETHStruct) EthGetStorageAt ¶ added in v1.10.0
func (s *IETHStruct) EthGetStorageAt(p0 context.Context, p1 types.EthAddress, p2 types.EthBytes, p3 types.EthBlockNumberOrHash) (types.EthBytes, error)
func (*IETHStruct) EthGetTransactionByBlockHashAndIndex ¶ added in v1.10.0
func (*IETHStruct) EthGetTransactionByBlockNumberAndIndex ¶ added in v1.10.0
func (*IETHStruct) EthGetTransactionByHash ¶ added in v1.10.0
func (*IETHStruct) EthGetTransactionByHashLimited ¶ added in v1.12.0
func (s *IETHStruct) EthGetTransactionByHashLimited(p0 context.Context, p1 *types.EthHash, p2 abi.ChainEpoch) (*types.EthTx, error)
func (*IETHStruct) EthGetTransactionCount ¶ added in v1.10.0
func (s *IETHStruct) EthGetTransactionCount(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthUint64, error)
func (*IETHStruct) EthGetTransactionHashByCid ¶ added in v1.10.0
func (*IETHStruct) EthGetTransactionReceipt ¶ added in v1.10.0
func (s *IETHStruct) EthGetTransactionReceipt(p0 context.Context, p1 types.EthHash) (*types.EthTxReceipt, error)
func (*IETHStruct) EthGetTransactionReceiptLimited ¶ added in v1.12.0
func (s *IETHStruct) EthGetTransactionReceiptLimited(p0 context.Context, p1 types.EthHash, p2 abi.ChainEpoch) (*types.EthTxReceipt, error)
func (*IETHStruct) EthMaxPriorityFeePerGas ¶ added in v1.10.0
func (*IETHStruct) EthProtocolVersion ¶ added in v1.10.0
func (*IETHStruct) EthSendRawTransaction ¶ added in v1.10.0
func (*IETHStruct) EthSyncing ¶ added in v1.14.0
func (s *IETHStruct) EthSyncing(p0 context.Context) (types.EthSyncingResult, error)
func (*IETHStruct) EthTraceBlock ¶ added in v1.14.0
func (s *IETHStruct) EthTraceBlock(p0 context.Context, p1 string) ([]*types.EthTraceBlock, error)
func (*IETHStruct) EthTraceFilter ¶ added in v1.17.0
func (s *IETHStruct) EthTraceFilter(p0 context.Context, p1 types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error)
func (*IETHStruct) EthTraceReplayBlockTransactions ¶ added in v1.14.0
func (s *IETHStruct) EthTraceReplayBlockTransactions(p0 context.Context, p1 string, p2 []string) ([]*types.EthTraceReplayBlockTransaction, error)
func (*IETHStruct) EthTraceTransaction ¶ added in v1.16.0
func (s *IETHStruct) EthTraceTransaction(p0 context.Context, p1 string) ([]*types.EthTraceTransaction, error)
func (*IETHStruct) FilecoinAddressToEthAddress ¶ added in v1.10.0
func (s *IETHStruct) FilecoinAddressToEthAddress(p0 context.Context, p1 address.Address) (types.EthAddress, error)
func (*IETHStruct) NetListening ¶ added in v1.10.0
func (s *IETHStruct) NetListening(p0 context.Context) (bool, error)
func (*IETHStruct) NetVersion ¶ added in v1.10.0
func (s *IETHStruct) NetVersion(p0 context.Context) (string, error)
func (*IETHStruct) Web3ClientVersion ¶ added in v1.10.0
func (s *IETHStruct) Web3ClientVersion(p0 context.Context) (string, error)
type IF3 ¶ added in v1.16.0
type IF3 interface {
// F3GetOrRenewParticipationTicket retrieves or renews a participation ticket
// necessary for a miner to engage in the F3 consensus process for the given
// number of instances.
//
// This function accepts an optional previous ticket. If provided, a new ticket
// will be issued only under one the following conditions:
// 1. The previous ticket has expired.
// 2. The issuer of the previous ticket matches the node processing this
// request.
//
// If there is an issuer mismatch (ErrF3ParticipationIssuerMismatch), the miner
// must retry obtaining a new ticket to ensure it is only participating in one F3
// instance at any time. If the number of instances is beyond the maximum leasable
// participation instances accepted by the node ErrF3ParticipationTooManyInstances
// is returned.
//
// Note: Successfully acquiring a ticket alone does not constitute participation.
// The retrieved ticket must be used to invoke F3Participate to actively engage
// in the F3 consensus process.
F3GetOrRenewParticipationTicket(ctx context.Context, minerID address.Address, previous types.F3ParticipationTicket, instances uint64) (types.F3ParticipationTicket, error) //perm:sign
// F3Participate enrolls a storage provider in the F3 consensus process using a
// provided participation ticket. This ticket grants a temporary lease that enables
// the provider to sign transactions as part of the F3 consensus.
//
// The function verifies the ticket's validity and checks if the ticket's issuer
// aligns with the current node. If there is an issuer mismatch
// (ErrF3ParticipationIssuerMismatch), the provider should retry with the same
// ticket, assuming the issue is due to transient network problems or operational
// deployment conditions. If the ticket is invalid
// (ErrF3ParticipationTicketInvalid) or has expired
// (ErrF3ParticipationTicketExpired), the provider must obtain a new ticket by
// calling F3GetOrRenewParticipationTicket.
//
// The start instance associated to the given ticket cannot be less than the
// start instance of any existing lease held by the miner. Otherwise,
// ErrF3ParticipationTicketStartBeforeExisting is returned. In this case, the
// miner should acquire a new ticket before attempting to participate again.
//
// For details on obtaining or renewing a ticket, see F3GetOrRenewParticipationTicket.
F3Participate(ctx context.Context, ticket types.F3ParticipationTicket) (types.F3ParticipationLease, error) //perm:sign
// F3GetCertificate returns a finality certificate at given instance number
F3GetCertificate(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error) //perm:read
// F3GetLatestCertificate returns the latest finality certificate
F3GetLatestCertificate(ctx context.Context) (*certs.FinalityCertificate, error) //perm:read
// F3GetECPowerTable returns a F3 specific power table for use in standalone F3 nodes.
F3GetECPowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) //perm:read
// F3GetF3PowerTable returns a F3 specific power table.
F3GetF3PowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) //perm:read
// F3GetManifest returns the current manifest being used for F3
F3GetManifest(ctx context.Context) (*manifest.Manifest, error) //perm:read
// F3GetPowerTableByInstance returns the power table (committee) used to validate the specified instance.
F3GetPowerTableByInstance(ctx context.Context, instance uint64) (gpbft.PowerEntries, error) //perm:read
// F3IsRunning returns true if the F3 instance is running, false if it's not running but
// it's enabled, and an error when disabled entirely.
F3IsRunning(ctx context.Context) (bool, error) //perm:read
// F3GetProgress returns the progress of the current F3 instance in terms of instance ID, round and phase.
F3GetProgress(ctx context.Context) (gpbft.InstanceProgress, error) //perm:read
// F3ListParticipants returns the list of miners that are currently participating in F3 via this node.
F3ListParticipants(ctx context.Context) ([]types.F3Participant, error) //perm:read
}
type IF3Struct ¶ added in v1.16.0
type IF3Struct struct {
Internal struct {
F3GetCertificate func(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error) `perm:"read"`
F3GetECPowerTable func(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) `perm:"read"`
F3GetF3PowerTable func(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) `perm:"read"`
F3GetLatestCertificate func(ctx context.Context) (*certs.FinalityCertificate, error) `perm:"read"`
F3GetManifest func(ctx context.Context) (*manifest.Manifest, error) `perm:"read"`
F3GetOrRenewParticipationTicket func(ctx context.Context, minerID address.Address, previous types.F3ParticipationTicket, instances uint64) (types.F3ParticipationTicket, error) `perm:"sign"`
F3GetPowerTableByInstance func(ctx context.Context, instance uint64) (gpbft.PowerEntries, error) `perm:"read"`
F3GetProgress func(ctx context.Context) (gpbft.InstanceProgress, error) `perm:"read"`
F3IsRunning func(ctx context.Context) (bool, error) `perm:"read"`
F3ListParticipants func(ctx context.Context) ([]types.F3Participant, error) `perm:"read"`
F3Participate func(ctx context.Context, ticket types.F3ParticipationTicket) (types.F3ParticipationLease, error) `perm:"sign"`
}
}
func (*IF3Struct) F3GetCertificate ¶ added in v1.16.0
func (*IF3Struct) F3GetECPowerTable ¶ added in v1.16.0
func (*IF3Struct) F3GetF3PowerTable ¶ added in v1.16.0
func (*IF3Struct) F3GetLatestCertificate ¶ added in v1.16.0
func (*IF3Struct) F3GetManifest ¶ added in v1.17.0
func (*IF3Struct) F3GetOrRenewParticipationTicket ¶ added in v1.17.0
func (*IF3Struct) F3GetPowerTableByInstance ¶ added in v1.19.0
func (*IF3Struct) F3GetProgress ¶ added in v1.17.0
func (*IF3Struct) F3IsRunning ¶ added in v1.17.0
func (*IF3Struct) F3ListParticipants ¶ added in v1.17.0
func (*IF3Struct) F3Participate ¶ added in v1.16.0
func (s *IF3Struct) F3Participate(p0 context.Context, p1 types.F3ParticipationTicket) (types.F3ParticipationLease, error)
type IMarketStruct ¶
type IMarketStruct struct {
Internal struct {
StateMarketParticipants func(ctx context.Context, tsk types.TipSetKey) (map[string]types.MarketBalance, error) `perm:"read"`
}
}
func (*IMarketStruct) StateMarketParticipants ¶
func (s *IMarketStruct) StateMarketParticipants(p0 context.Context, p1 types.TipSetKey) (map[string]types.MarketBalance, error)
type IMessagePool ¶
type IMessagePool interface {
MpoolDeleteByAdress(ctx context.Context, addr address.Address) error //perm:admin
MpoolPublishByAddr(context.Context, address.Address) error //perm:write
MpoolPublishMessage(ctx context.Context, smsg *types.SignedMessage) error //perm:write
MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error) //perm:write
MpoolGetConfig(context.Context) (*types.MpoolConfig, error) //perm:read
MpoolSetConfig(ctx context.Context, cfg *types.MpoolConfig) error //perm:admin
MpoolSelect(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error) //perm:read
MpoolSelects(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error) //perm:read
MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error) //perm:read
MpoolClear(ctx context.Context, local bool) error //perm:write
MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error) //perm:write
MpoolPushMessage(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec) (*types.SignedMessage, error) //perm:sign
MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) //perm:write
MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) //perm:write
MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *types.MessageSendSpec) ([]*types.SignedMessage, error) //perm:sign
MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error) //perm:read
MpoolSub(ctx context.Context) (<-chan types.MpoolUpdate, error) //perm:read
GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error) //perm:read
GasBatchEstimateMessageGas(ctx context.Context, estimateMessages []*types.EstimateMessage, fromNonce uint64, tsk types.TipSetKey) ([]*types.EstimateResult, error) //perm:read
GasEstimateFeeCap(ctx context.Context, msg *types.Message, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error) //perm:read
GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error) //perm:read
GasEstimateGasLimit(ctx context.Context, msgIn *types.Message, tsk types.TipSetKey) (int64, error) //perm:read
// MpoolCheckMessages performs logical checks on a batch of messages
MpoolCheckMessages(ctx context.Context, protos []*types.MessagePrototype) ([][]types.MessageCheckStatus, error) //perm:read
// MpoolCheckPendingMessages performs logical checks for all pending messages from a given address
MpoolCheckPendingMessages(ctx context.Context, addr address.Address) ([][]types.MessageCheckStatus, error) //perm:read
// MpoolCheckReplaceMessages performs logical checks on pending messages with replacement
MpoolCheckReplaceMessages(ctx context.Context, msg []*types.Message) ([][]types.MessageCheckStatus, error) //perm:read
}
type IMessagePoolStruct ¶
type IMessagePoolStruct struct {
Internal struct {
GasBatchEstimateMessageGas func(ctx context.Context, estimateMessages []*types.EstimateMessage, fromNonce uint64, tsk types.TipSetKey) ([]*types.EstimateResult, error) `perm:"read"`
GasEstimateFeeCap func(ctx context.Context, msg *types.Message, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
GasEstimateGasLimit func(ctx context.Context, msgIn *types.Message, tsk types.TipSetKey) (int64, error) `perm:"read"`
GasEstimateGasPremium func(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
GasEstimateMessageGas func(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error) `perm:"read"`
MpoolBatchPush func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) `perm:"write"`
MpoolBatchPushMessage func(ctx context.Context, msgs []*types.Message, spec *types.MessageSendSpec) ([]*types.SignedMessage, error) `perm:"sign"`
MpoolBatchPushUntrusted func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) `perm:"write"`
MpoolCheckMessages func(ctx context.Context, protos []*types.MessagePrototype) ([][]types.MessageCheckStatus, error) `perm:"read"`
MpoolCheckPendingMessages func(ctx context.Context, addr address.Address) ([][]types.MessageCheckStatus, error) `perm:"read"`
MpoolCheckReplaceMessages func(ctx context.Context, msg []*types.Message) ([][]types.MessageCheckStatus, error) `perm:"read"`
MpoolClear func(ctx context.Context, local bool) error `perm:"write"`
MpoolDeleteByAdress func(ctx context.Context, addr address.Address) error `perm:"admin"`
MpoolGetConfig func(context.Context) (*types.MpoolConfig, error) `perm:"read"`
MpoolGetNonce func(ctx context.Context, addr address.Address) (uint64, error) `perm:"read"`
MpoolPending func(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error) `perm:"read"`
MpoolPublishByAddr func(context.Context, address.Address) error `perm:"write"`
MpoolPublishMessage func(ctx context.Context, smsg *types.SignedMessage) error `perm:"write"`
MpoolPush func(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error) `perm:"write"`
MpoolPushMessage func(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec) (*types.SignedMessage, error) `perm:"sign"`
MpoolPushUntrusted func(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error) `perm:"write"`
MpoolSelect func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error) `perm:"read"`
MpoolSelects func(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error) `perm:"read"`
MpoolSetConfig func(ctx context.Context, cfg *types.MpoolConfig) error `perm:"admin"`
MpoolSub func(ctx context.Context) (<-chan types.MpoolUpdate, error) `perm:"read"`
}
}
func (*IMessagePoolStruct) GasBatchEstimateMessageGas ¶
func (s *IMessagePoolStruct) GasBatchEstimateMessageGas(p0 context.Context, p1 []*types.EstimateMessage, p2 uint64, p3 types.TipSetKey) ([]*types.EstimateResult, error)
func (*IMessagePoolStruct) GasEstimateFeeCap ¶
func (*IMessagePoolStruct) GasEstimateGasLimit ¶
func (*IMessagePoolStruct) GasEstimateGasPremium ¶
func (*IMessagePoolStruct) GasEstimateMessageGas ¶
func (*IMessagePoolStruct) MpoolBatchPush ¶
func (s *IMessagePoolStruct) MpoolBatchPush(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)
func (*IMessagePoolStruct) MpoolBatchPushMessage ¶
func (s *IMessagePoolStruct) MpoolBatchPushMessage(p0 context.Context, p1 []*types.Message, p2 *types.MessageSendSpec) ([]*types.SignedMessage, error)
func (*IMessagePoolStruct) MpoolBatchPushUntrusted ¶
func (s *IMessagePoolStruct) MpoolBatchPushUntrusted(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)
func (*IMessagePoolStruct) MpoolCheckMessages ¶
func (s *IMessagePoolStruct) MpoolCheckMessages(p0 context.Context, p1 []*types.MessagePrototype) ([][]types.MessageCheckStatus, error)
func (*IMessagePoolStruct) MpoolCheckPendingMessages ¶
func (s *IMessagePoolStruct) MpoolCheckPendingMessages(p0 context.Context, p1 address.Address) ([][]types.MessageCheckStatus, error)
func (*IMessagePoolStruct) MpoolCheckReplaceMessages ¶
func (s *IMessagePoolStruct) MpoolCheckReplaceMessages(p0 context.Context, p1 []*types.Message) ([][]types.MessageCheckStatus, error)
func (*IMessagePoolStruct) MpoolClear ¶
func (s *IMessagePoolStruct) MpoolClear(p0 context.Context, p1 bool) error
func (*IMessagePoolStruct) MpoolDeleteByAdress ¶
func (*IMessagePoolStruct) MpoolGetConfig ¶
func (s *IMessagePoolStruct) MpoolGetConfig(p0 context.Context) (*types.MpoolConfig, error)
func (*IMessagePoolStruct) MpoolGetNonce ¶
func (*IMessagePoolStruct) MpoolPending ¶
func (s *IMessagePoolStruct) MpoolPending(p0 context.Context, p1 types.TipSetKey) ([]*types.SignedMessage, error)
func (*IMessagePoolStruct) MpoolPublishByAddr ¶
func (*IMessagePoolStruct) MpoolPublishMessage ¶
func (s *IMessagePoolStruct) MpoolPublishMessage(p0 context.Context, p1 *types.SignedMessage) error
func (*IMessagePoolStruct) MpoolPush ¶
func (s *IMessagePoolStruct) MpoolPush(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)
func (*IMessagePoolStruct) MpoolPushMessage ¶
func (s *IMessagePoolStruct) MpoolPushMessage(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec) (*types.SignedMessage, error)
func (*IMessagePoolStruct) MpoolPushUntrusted ¶
func (s *IMessagePoolStruct) MpoolPushUntrusted(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)
func (*IMessagePoolStruct) MpoolSelect ¶
func (s *IMessagePoolStruct) MpoolSelect(p0 context.Context, p1 types.TipSetKey, p2 float64) ([]*types.SignedMessage, error)
func (*IMessagePoolStruct) MpoolSelects ¶
func (s *IMessagePoolStruct) MpoolSelects(p0 context.Context, p1 types.TipSetKey, p2 []float64) ([][]*types.SignedMessage, error)
func (*IMessagePoolStruct) MpoolSetConfig ¶
func (s *IMessagePoolStruct) MpoolSetConfig(p0 context.Context, p1 *types.MpoolConfig) error
func (*IMessagePoolStruct) MpoolSub ¶
func (s *IMessagePoolStruct) MpoolSub(p0 context.Context) (<-chan types.MpoolUpdate, error)
type IMinerState ¶
type IMinerState interface {
StateReadState(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.ActorState, error) //perm:read
StateListMessages(ctx context.Context, match *types.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error) //perm:read
StateDecodeParams(ctx context.Context, toAddr address.Address, method abi.MethodNum, params []byte, tsk types.TipSetKey) (interface{}, error) //perm:read
StateEncodeParams(ctx context.Context, toActCode cid.Cid, method abi.MethodNum, params json.RawMessage) ([]byte, error) //perm:read
StateMinerSectorAllocated(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error) //perm:read
// StateSectorPreCommitInfo returns the PreCommit info for the specified miner's sector.
// Returns nil and no error if the sector isn't precommitted.
//
// Note that the sector number may be allocated while PreCommitInfo is nil. This means that either allocated sector
// numbers were compacted, and the sector number was marked as allocated in order to reduce size of the allocated
// sectors bitfield, or that the sector was precommitted, but the precommit has expired.
StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*types.SectorPreCommitOnChainInfo, error) //perm:read
StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorOnChainInfo, error) //perm:read
StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error) //perm:read
StateMinerSectorSize(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (abi.SectorSize, error) //perm:read
StateMinerInfo(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (types.MinerInfo, error) //perm:read
StateMinerWorkerAddress(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (address.Address, error) //perm:read
StateMinerFaults(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error) //perm:read
StateAllMinerFaults(ctx context.Context, lookback abi.ChainEpoch, ts types.TipSetKey) ([]*types.Fault, error) //perm:read
StateMinerRecoveries(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error) //perm:read
StateMinerProvingDeadline(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (*dline.Info, error) //perm:read
StateMinerPartitions(ctx context.Context, maddr address.Address, dlIdx uint64, tsk types.TipSetKey) ([]types.Partition, error) //perm:read
StateMinerDeadlines(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]types.Deadline, error) //perm:read
StateMinerSectors(ctx context.Context, maddr address.Address, sectorNos *bitfield.BitField, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error) //perm:read
StateMarketStorageDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*types.MarketDeal, error) //perm:read
// StateGetAllocationForPendingDeal returns the allocation for a given deal ID of a pending deal. Returns nil if
// pending allocation is not found.
StateGetAllocationForPendingDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*verifreg.Allocation, error) //perm:read
// StateGetAllocationIdForPendingDeal is like StateGetAllocationForPendingDeal except it returns the allocation ID
StateGetAllocationIdForPendingDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (verifreg.AllocationId, error) //perm:read
// StateGetAllocation returns the allocation for a given address and allocation ID.
StateGetAllocation(ctx context.Context, clientAddr address.Address, allocationID verifreg.AllocationId, tsk types.TipSetKey) (*verifreg.Allocation, error) //perm:read
// StateGetAllAllocations returns the all the allocations available in verified registry actor.
StateGetAllAllocations(ctx context.Context, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) //perm:read
// StateGetAllocations returns the all the allocations for a given client.
StateGetAllocations(ctx context.Context, clientAddr address.Address, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) //perm:read
// StateGetClaim returns the claim for a given address and claim ID.
StateGetClaim(ctx context.Context, providerAddr address.Address, claimID verifreg.ClaimId, tsk types.TipSetKey) (*verifreg.Claim, error) //perm:read
// StateGetClaims returns the all the claims for a given provider.
StateGetClaims(ctx context.Context, providerAddr address.Address, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) //perm:read
// StateGetAllClaims returns the all the claims available in verified registry actor.
StateGetAllClaims(ctx context.Context, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) //perm:read
// StateComputeDataCID computes DataCID from a set of on-chain deals
StateComputeDataCID(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, deals []abi.DealID, tsk types.TipSetKey) (cid.Cid, error) //perm:read
StateMinerPreCommitDepositForPower(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error) //perm:read
// StateMinerInitialPledgeCollateral attempts to calculate the initial pledge collateral based on a SectorPreCommitInfo.
// This method uses the DealIDs field in SectorPreCommitInfo to determine the amount of verified
// deal space in the sector in order to perform a QAP calculation. Since network version 22 and
// the introduction of DDO, the DealIDs field can no longer be used to reliably determine verified
// deal space; therefore, this method is deprecated. Use StateMinerInitialPledgeForSector instead
// and pass in the verified deal space directly.
//
// Deprecated: Use StateMinerInitialPledgeForSector instead.
StateMinerInitialPledgeCollateral(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error) //perm:read
// StateMinerInitialPledgeForSector returns the initial pledge collateral for a given sector
// duration, size, and combined size of any verified pieces within the sector. This calculation
// depends on current network conditions (total power, total pledge and current rewards) at the
// given tipset.
StateMinerInitialPledgeForSector(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, verifiedSize uint64, tsk types.TipSetKey) (types.BigInt, error) //perm:read
// StateMinerCreationDeposit calculates the deposit required for creating a new miner
// according to FIP-0077 specification. This deposit is based on the network's current
// economic parameters including circulating supply, network power, and pledge collateral.
//
// See: node/impl/full/state.go StateMinerCreationDeposit implementation.
StateMinerCreationDeposit(ctx context.Context, tsk types.TipSetKey) (types.BigInt, error) //perm:read
StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (types.CirculatingSupply, error) //perm:read
StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error) //perm:read
StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]*types.MarketDeal, error) //perm:read
StateMinerActiveSectors(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error) //perm:read
StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error) //perm:read
// StateLookupRobustAddress returns the public key address of the given ID address for non-account addresses (multisig, miners etc)
StateLookupRobustAddress(context.Context, address.Address, types.TipSetKey) (address.Address, error) //perm:read
StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error) //perm:read
StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error) //perm:read
StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.MinerPower, error) //perm:read
StateMinerAvailableBalance(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (big.Int, error) //perm:read
StateSectorExpiration(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorExpiration, error) //perm:read
StateChangedActors(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error) //perm:read
StateMinerSectorCount(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MinerSectors, error) //perm:read
StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MarketBalance, error) //perm:read
StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (types.DealCollateralBounds, error) //perm:read
StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error) //perm:read
// StateMinerAllocated returns a bitfield containing all sector numbers marked as allocated in miner state
StateMinerAllocated(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error) //perm:read
}
type IMinerStateStruct ¶
type IMinerStateStruct struct {
Internal struct {
StateAllMinerFaults func(ctx context.Context, lookback abi.ChainEpoch, ts types.TipSetKey) ([]*types.Fault, error) `perm:"read"`
StateChangedActors func(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error) `perm:"read"`
StateCirculatingSupply func(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error) `perm:"read"`
StateComputeDataCID func(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, deals []abi.DealID, tsk types.TipSetKey) (cid.Cid, error) `perm:"read"`
StateDealProviderCollateralBounds func(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (types.DealCollateralBounds, error) `perm:"read"`
StateDecodeParams func(ctx context.Context, toAddr address.Address, method abi.MethodNum, params []byte, tsk types.TipSetKey) (interface{}, error) `perm:"read"`
StateEncodeParams func(ctx context.Context, toActCode cid.Cid, method abi.MethodNum, params json.RawMessage) ([]byte, error) `perm:"read"`
StateGetAllAllocations func(ctx context.Context, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) `perm:"read"`
StateGetAllClaims func(ctx context.Context, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) `perm:"read"`
StateGetAllocation func(ctx context.Context, clientAddr address.Address, allocationID verifreg.AllocationId, tsk types.TipSetKey) (*verifreg.Allocation, error) `perm:"read"`
StateGetAllocationForPendingDeal func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*verifreg.Allocation, error) `perm:"read"`
StateGetAllocationIdForPendingDeal func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (verifreg.AllocationId, error) `perm:"read"`
StateGetAllocations func(ctx context.Context, clientAddr address.Address, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) `perm:"read"`
StateGetClaim func(ctx context.Context, providerAddr address.Address, claimID verifreg.ClaimId, tsk types.TipSetKey) (*verifreg.Claim, error) `perm:"read"`
StateGetClaims func(ctx context.Context, providerAddr address.Address, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) `perm:"read"`
StateListActors func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error) `perm:"read"`
StateListMessages func(ctx context.Context, match *types.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error) `perm:"read"`
StateListMiners func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error) `perm:"read"`
StateLookupID func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
StateLookupRobustAddress func(context.Context, address.Address, types.TipSetKey) (address.Address, error) `perm:"read"`
StateMarketBalance func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MarketBalance, error) `perm:"read"`
StateMarketDeals func(ctx context.Context, tsk types.TipSetKey) (map[string]*types.MarketDeal, error) `perm:"read"`
StateMarketStorageDeal func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*types.MarketDeal, error) `perm:"read"`
StateMinerActiveSectors func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error) `perm:"read"`
StateMinerAllocated func(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error) `perm:"read"`
StateMinerAvailableBalance func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
StateMinerCreationDeposit func(ctx context.Context, tsk types.TipSetKey) (types.BigInt, error) `perm:"read"`
StateMinerDeadlines func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]types.Deadline, error) `perm:"read"`
StateMinerFaults func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error) `perm:"read"`
StateMinerInfo func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (types.MinerInfo, error) `perm:"read"`
StateMinerInitialPledgeCollateral func(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
StateMinerInitialPledgeForSector func(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, verifiedSize uint64, tsk types.TipSetKey) (types.BigInt, error) `perm:"read"`
StateMinerPartitions func(ctx context.Context, maddr address.Address, dlIdx uint64, tsk types.TipSetKey) ([]types.Partition, error) `perm:"read"`
StateMinerPower func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.MinerPower, error) `perm:"read"`
StateMinerPreCommitDepositForPower func(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
StateMinerProvingDeadline func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (*dline.Info, error) `perm:"read"`
StateMinerRecoveries func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error) `perm:"read"`
StateMinerSectorAllocated func(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error) `perm:"read"`
StateMinerSectorCount func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MinerSectors, error) `perm:"read"`
StateMinerSectorSize func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (abi.SectorSize, error) `perm:"read"`
StateMinerSectors func(ctx context.Context, maddr address.Address, sectorNos *bitfield.BitField, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error) `perm:"read"`
StateMinerWorkerAddress func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
StateReadState func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.ActorState, error) `perm:"read"`
StateSectorExpiration func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorExpiration, error) `perm:"read"`
StateSectorGetInfo func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorOnChainInfo, error) `perm:"read"`
StateSectorPartition func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error) `perm:"read"`
StateSectorPreCommitInfo func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*types.SectorPreCommitOnChainInfo, error) `perm:"read"`
StateVMCirculatingSupplyInternal func(ctx context.Context, tsk types.TipSetKey) (types.CirculatingSupply, error) `perm:"read"`
StateVerifiedClientStatus func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error) `perm:"read"`
}
}
func (*IMinerStateStruct) StateAllMinerFaults ¶ added in v1.7.0
func (s *IMinerStateStruct) StateAllMinerFaults(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) ([]*types.Fault, error)
func (*IMinerStateStruct) StateChangedActors ¶ added in v1.7.0
func (*IMinerStateStruct) StateCirculatingSupply ¶
func (s *IMinerStateStruct) StateCirculatingSupply(p0 context.Context, p1 types.TipSetKey) (abi.TokenAmount, error)
func (*IMinerStateStruct) StateComputeDataCID ¶ added in v1.8.0
func (*IMinerStateStruct) StateDealProviderCollateralBounds ¶
func (s *IMinerStateStruct) StateDealProviderCollateralBounds(p0 context.Context, p1 abi.PaddedPieceSize, p2 bool, p3 types.TipSetKey) (types.DealCollateralBounds, error)
func (*IMinerStateStruct) StateDecodeParams ¶ added in v1.7.0
func (*IMinerStateStruct) StateEncodeParams ¶ added in v1.7.0
func (*IMinerStateStruct) StateGetAllAllocations ¶ added in v1.15.0
func (s *IMinerStateStruct) StateGetAllAllocations(p0 context.Context, p1 types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)
func (*IMinerStateStruct) StateGetAllClaims ¶ added in v1.15.0
func (*IMinerStateStruct) StateGetAllocation ¶ added in v1.8.0
func (s *IMinerStateStruct) StateGetAllocation(p0 context.Context, p1 address.Address, p2 verifreg.AllocationId, p3 types.TipSetKey) (*verifreg.Allocation, error)
func (*IMinerStateStruct) StateGetAllocationForPendingDeal ¶ added in v1.8.0
func (s *IMinerStateStruct) StateGetAllocationForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*verifreg.Allocation, error)
func (*IMinerStateStruct) StateGetAllocationIdForPendingDeal ¶ added in v1.15.0
func (s *IMinerStateStruct) StateGetAllocationIdForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (verifreg.AllocationId, error)
func (*IMinerStateStruct) StateGetAllocations ¶ added in v1.8.0
func (s *IMinerStateStruct) StateGetAllocations(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)
func (*IMinerStateStruct) StateGetClaim ¶ added in v1.8.0
func (*IMinerStateStruct) StateGetClaims ¶ added in v1.8.0
func (*IMinerStateStruct) StateListActors ¶
func (*IMinerStateStruct) StateListMessages ¶ added in v1.7.0
func (s *IMinerStateStruct) StateListMessages(p0 context.Context, p1 *types.MessageMatch, p2 types.TipSetKey, p3 abi.ChainEpoch) ([]cid.Cid, error)
func (*IMinerStateStruct) StateListMiners ¶
func (*IMinerStateStruct) StateLookupID ¶
func (*IMinerStateStruct) StateLookupRobustAddress ¶ added in v1.6.0
func (*IMinerStateStruct) StateMarketBalance ¶
func (s *IMinerStateStruct) StateMarketBalance(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MarketBalance, error)
func (*IMinerStateStruct) StateMarketDeals ¶
func (s *IMinerStateStruct) StateMarketDeals(p0 context.Context, p1 types.TipSetKey) (map[string]*types.MarketDeal, error)
func (*IMinerStateStruct) StateMarketStorageDeal ¶
func (s *IMinerStateStruct) StateMarketStorageDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*types.MarketDeal, error)
func (*IMinerStateStruct) StateMinerActiveSectors ¶
func (s *IMinerStateStruct) StateMinerActiveSectors(p0 context.Context, p1 address.Address, p2 types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)
func (*IMinerStateStruct) StateMinerAllocated ¶ added in v1.8.0
func (*IMinerStateStruct) StateMinerAvailableBalance ¶
func (*IMinerStateStruct) StateMinerCreationDeposit ¶ added in v1.19.0
func (*IMinerStateStruct) StateMinerDeadlines ¶
func (*IMinerStateStruct) StateMinerFaults ¶
func (*IMinerStateStruct) StateMinerInfo ¶
func (*IMinerStateStruct) StateMinerInitialPledgeCollateral ¶
func (*IMinerStateStruct) StateMinerInitialPledgeForSector ¶ added in v1.17.0
func (s *IMinerStateStruct) StateMinerInitialPledgeForSector(p0 context.Context, p1 abi.ChainEpoch, p2 abi.SectorSize, p3 uint64, p4 types.TipSetKey) (types.BigInt, error)
func (*IMinerStateStruct) StateMinerPartitions ¶
func (*IMinerStateStruct) StateMinerPower ¶
func (s *IMinerStateStruct) StateMinerPower(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.MinerPower, error)
func (*IMinerStateStruct) StateMinerPreCommitDepositForPower ¶
func (*IMinerStateStruct) StateMinerProvingDeadline ¶
func (*IMinerStateStruct) StateMinerRecoveries ¶
func (*IMinerStateStruct) StateMinerSectorAllocated ¶
func (*IMinerStateStruct) StateMinerSectorCount ¶
func (s *IMinerStateStruct) StateMinerSectorCount(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MinerSectors, error)
func (*IMinerStateStruct) StateMinerSectorSize ¶
func (s *IMinerStateStruct) StateMinerSectorSize(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (abi.SectorSize, error)
func (*IMinerStateStruct) StateMinerSectors ¶
func (*IMinerStateStruct) StateMinerWorkerAddress ¶
func (*IMinerStateStruct) StateReadState ¶ added in v1.7.0
func (s *IMinerStateStruct) StateReadState(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.ActorState, error)
func (*IMinerStateStruct) StateSectorExpiration ¶
func (s *IMinerStateStruct) StateSectorExpiration(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, p3 types.TipSetKey) (*lminer.SectorExpiration, error)
func (*IMinerStateStruct) StateSectorGetInfo ¶
func (s *IMinerStateStruct) StateSectorGetInfo(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, p3 types.TipSetKey) (*lminer.SectorOnChainInfo, error)
func (*IMinerStateStruct) StateSectorPartition ¶
func (s *IMinerStateStruct) StateSectorPartition(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, p3 types.TipSetKey) (*lminer.SectorLocation, error)
func (*IMinerStateStruct) StateSectorPreCommitInfo ¶
func (s *IMinerStateStruct) StateSectorPreCommitInfo(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, p3 types.TipSetKey) (*types.SectorPreCommitOnChainInfo, error)
func (*IMinerStateStruct) StateVMCirculatingSupplyInternal ¶
func (s *IMinerStateStruct) StateVMCirculatingSupplyInternal(p0 context.Context, p1 types.TipSetKey) (types.CirculatingSupply, error)
func (*IMinerStateStruct) StateVerifiedClientStatus ¶
func (s *IMinerStateStruct) StateVerifiedClientStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)
type IMiningStruct ¶
type IMiningStruct struct {
Internal struct {
MinerCreateBlock func(ctx context.Context, bt *types.BlockTemplate) (*types.BlockMsg, error) `perm:"write"`
MinerGetBaseInfo func(ctx context.Context, maddr address.Address, round abi.ChainEpoch, tsk types.TipSetKey) (*types.MiningBaseInfo, error) `perm:"read"`
}
}
func (*IMiningStruct) MinerCreateBlock ¶
func (s *IMiningStruct) MinerCreateBlock(p0 context.Context, p1 *types.BlockTemplate) (*types.BlockMsg, error)
func (*IMiningStruct) MinerGetBaseInfo ¶
func (s *IMiningStruct) MinerGetBaseInfo(p0 context.Context, p1 address.Address, p2 abi.ChainEpoch, p3 types.TipSetKey) (*types.MiningBaseInfo, error)
type INetwork ¶
type INetwork interface {
NetFindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo //perm:read
NetGetClosestPeers(ctx context.Context, key string) ([]peer.ID, error) //perm:read
NetConnectedness(context.Context, peer.ID) (network2.Connectedness, error) //perm:read
NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error) //perm:read
NetConnect(ctx context.Context, pi peer.AddrInfo) error //perm:admin
NetPeers(ctx context.Context) ([]peer.AddrInfo, error) //perm:read
NetPeerInfo(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error) //perm:read
NetAgentVersion(ctx context.Context, p peer.ID) (string, error) //perm:read
NetPing(ctx context.Context, p peer.ID) (time.Duration, error) //perm:read
NetAddrsListen(ctx context.Context) (peer.AddrInfo, error) //perm:read
NetDisconnect(ctx context.Context, p peer.ID) error //perm:admin
NetAutoNatStatus(context.Context) (types.NatInfo, error) //perm:read
NetPubsubScores(context.Context) ([]types.PubsubScore, error) //perm:read
ID(ctx context.Context) (peer.ID, error) //perm:read
// NetBandwidthStats returns statistics about the nodes total bandwidth
// usage and current rate across all peers and protocols.
NetBandwidthStats(ctx context.Context) (metrics.Stats, error) //perm:read
// NetBandwidthStatsByPeer returns statistics about the nodes bandwidth
// usage and current rate per peer
NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error) //perm:read
// NetBandwidthStatsByProtocol returns statistics about the nodes bandwidth
// usage and current rate per protocol
NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error) //perm:read
NetProtectAdd(ctx context.Context, acl []peer.ID) error //perm:admin
NetProtectRemove(ctx context.Context, acl []peer.ID) error //perm:admin
NetProtectList(ctx context.Context) ([]peer.ID, error) //perm:read
}
type INetworkStruct ¶
type INetworkStruct struct {
Internal struct {
ID func(ctx context.Context) (peer.ID, error) `perm:"read"`
NetAddrsListen func(ctx context.Context) (peer.AddrInfo, error) `perm:"read"`
NetAgentVersion func(ctx context.Context, p peer.ID) (string, error) `perm:"read"`
NetAutoNatStatus func(context.Context) (types.NatInfo, error) `perm:"read"`
NetBandwidthStats func(ctx context.Context) (metrics.Stats, error) `perm:"read"`
NetBandwidthStatsByPeer func(ctx context.Context) (map[string]metrics.Stats, error) `perm:"read"`
NetBandwidthStatsByProtocol func(ctx context.Context) (map[protocol.ID]metrics.Stats, error) `perm:"read"`
NetConnect func(ctx context.Context, pi peer.AddrInfo) error `perm:"admin"`
NetConnectedness func(context.Context, peer.ID) (network2.Connectedness, error) `perm:"read"`
NetDisconnect func(ctx context.Context, p peer.ID) error `perm:"admin"`
NetFindPeer func(ctx context.Context, p peer.ID) (peer.AddrInfo, error) `perm:"read"`
NetFindProvidersAsync func(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo `perm:"read"`
NetGetClosestPeers func(ctx context.Context, key string) ([]peer.ID, error) `perm:"read"`
NetPeerInfo func(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error) `perm:"read"`
NetPeers func(ctx context.Context) ([]peer.AddrInfo, error) `perm:"read"`
NetPing func(ctx context.Context, p peer.ID) (time.Duration, error) `perm:"read"`
NetProtectAdd func(ctx context.Context, acl []peer.ID) error `perm:"admin"`
NetProtectList func(ctx context.Context) ([]peer.ID, error) `perm:"read"`
NetProtectRemove func(ctx context.Context, acl []peer.ID) error `perm:"admin"`
NetPubsubScores func(context.Context) ([]types.PubsubScore, error) `perm:"read"`
}
}
func (*INetworkStruct) NetAddrsListen ¶
func (*INetworkStruct) NetAgentVersion ¶ added in v1.6.1
func (*INetworkStruct) NetAutoNatStatus ¶ added in v1.6.1
func (*INetworkStruct) NetBandwidthStats ¶ added in v1.6.1
func (*INetworkStruct) NetBandwidthStatsByPeer ¶ added in v1.6.1
func (*INetworkStruct) NetBandwidthStatsByProtocol ¶ added in v1.6.1
func (*INetworkStruct) NetConnect ¶ added in v1.6.1
func (*INetworkStruct) NetConnectedness ¶ added in v1.6.1
func (s *INetworkStruct) NetConnectedness(p0 context.Context, p1 peer.ID) (network2.Connectedness, error)
func (*INetworkStruct) NetDisconnect ¶ added in v1.6.1
func (*INetworkStruct) NetFindPeer ¶ added in v1.6.1
func (*INetworkStruct) NetFindProvidersAsync ¶ added in v1.6.1
func (*INetworkStruct) NetGetClosestPeers ¶ added in v1.6.1
func (*INetworkStruct) NetPeerInfo ¶ added in v1.6.1
func (s *INetworkStruct) NetPeerInfo(p0 context.Context, p1 peer.ID) (*types.ExtendedPeerInfo, error)
func (*INetworkStruct) NetProtectAdd ¶ added in v1.6.1
func (*INetworkStruct) NetProtectList ¶ added in v1.6.1
func (*INetworkStruct) NetProtectRemove ¶ added in v1.6.1
func (*INetworkStruct) NetPubsubScores ¶ added in v1.8.0
func (s *INetworkStruct) NetPubsubScores(p0 context.Context) ([]types.PubsubScore, error)
type IPaychan ¶
type IPaychan interface {
// PaychGet gets or creates a payment channel between address pair
// The specified amount will be reserved for use. If there aren't enough non-reserved funds
// available, funds will be added through an on-chain message.
// - When opts.OffChain is true, this call will not cause any messages to be sent to the chain (no automatic
// channel creation/funds adding). If the operation can't be performed without sending a message an error will be
// returned. Note that even when this option is specified, this call can be blocked by previous operations on the
// channel waiting for on-chain operations.
PaychGet(ctx context.Context, from, to address.Address, amt types.BigInt, opts types.PaychGetOpts) (*types.ChannelInfo, error) //perm:sign
// PaychFund gets or creates a payment channel between address pair.
// The specified amount will be added to the channel through on-chain send for future use
PaychFund(ctx context.Context, from, to address.Address, amt types.BigInt) (*types.ChannelInfo, error) //perm:sign
// PaychAvailableFunds get the status of an outbound payment channel
// @pch: payment channel address
PaychAvailableFunds(ctx context.Context, ch address.Address) (*types.ChannelAvailableFunds, error) //perm:sign
// PaychAvailableFundsByFromTo get the status of an outbound payment channel
// @from: the payment channel sender
// @to: he payment channel recipient
PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*types.ChannelAvailableFunds, error) //perm:sign
// PaychGetWaitReady waits until the create channel / add funds message with the sentinel
// @sentinel: given message CID arrives.
// @ch: the returned channel address can safely be used against the Manager methods.
PaychGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error) //perm:sign
// PaychAllocateLane Allocate late creates a lane within a payment channel so that calls to
// CreatePaymentVoucher will automatically make vouchers only for the difference in total
PaychAllocateLane(ctx context.Context, ch address.Address) (uint64, error) //perm:sign
// PaychNewPayment aggregate vouchers into a new lane
// @from: the payment channel sender
// @to: the payment channel recipient
// @vouchers: the outstanding (non-redeemed) vouchers
PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []types.VoucherSpec) (*types.PaymentInfo, error) //perm:sign
// PaychList list the addresses of all channels that have been created
PaychList(ctx context.Context) ([]address.Address, error) //perm:read
// PaychStatus get the payment channel status
// @pch: payment channel address
PaychStatus(ctx context.Context, pch address.Address) (*types.Status, error) //perm:read
// PaychSettle update payment channel status to settle
// After a settlement period (currently 12 hours) either party to the payment channel can call collect on chain
// @pch: payment channel address
PaychSettle(ctx context.Context, addr address.Address) (cid.Cid, error) //perm:sign
// PaychCollect update payment channel status to collect
// Collect sends the value of submitted vouchers to the channel recipient (the provider),
// and refunds the remaining channel balance to the channel creator (the client).
// @pch: payment channel address
PaychCollect(ctx context.Context, addr address.Address) (cid.Cid, error) //perm:sign
// PaychVoucherCheckValid checks if the given voucher is valid (is or could become spendable at some point).
// If the channel is not in the store, fetches the channel from state (and checks that
// the channel To address is owned by the wallet).
// @pch: payment channel address
// @sv: voucher
PaychVoucherCheckValid(ctx context.Context, ch address.Address, sv *types.SignedVoucher) error //perm:read
// PaychVoucherCheckSpendable checks if the given voucher is currently spendable
// @pch: payment channel address
// @sv: voucher
PaychVoucherCheckSpendable(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (bool, error) //perm:read
// PaychVoucherAdd adds a voucher for an inbound channel.
// If the channel is not in the store, fetches the channel from state (and checks that
// the channel To address is owned by the wallet).
PaychVoucherAdd(ctx context.Context, ch address.Address, sv *types.SignedVoucher, proof []byte, minDelta big.Int) (big.Int, error) //perm:write
// PaychVoucherCreate creates a new signed voucher on the given payment channel
// with the given lane and amount. The value passed in is exactly the value
// that will be used to create the voucher, so if previous vouchers exist, the
// actual additional value of this voucher will only be the difference between
// the two.
// If there are insufficient funds in the channel to create the voucher,
// returns a nil voucher and the shortfall.
PaychVoucherCreate(ctx context.Context, pch address.Address, amt big.Int, lane uint64) (*types.VoucherCreateResult, error) //perm:sign
// PaychVoucherList list vouchers in payment channel
// @pch: payment channel address
PaychVoucherList(ctx context.Context, pch address.Address) ([]*types.SignedVoucher, error) //perm:write
// PaychVoucherSubmit Submit voucher to chain to update payment channel state
// @pch: payment channel address
// @sv: voucher in payment channel
PaychVoucherSubmit(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error) //perm:sign
}
type IPaychanStruct ¶
type IPaychanStruct struct {
Internal struct {
PaychAllocateLane func(ctx context.Context, ch address.Address) (uint64, error) `perm:"sign"`
PaychAvailableFunds func(ctx context.Context, ch address.Address) (*types.ChannelAvailableFunds, error) `perm:"sign"`
PaychAvailableFundsByFromTo func(ctx context.Context, from, to address.Address) (*types.ChannelAvailableFunds, error) `perm:"sign"`
PaychCollect func(ctx context.Context, addr address.Address) (cid.Cid, error) `perm:"sign"`
PaychFund func(ctx context.Context, from, to address.Address, amt types.BigInt) (*types.ChannelInfo, error) `perm:"sign"`
PaychGet func(ctx context.Context, from, to address.Address, amt types.BigInt, opts types.PaychGetOpts) (*types.ChannelInfo, error) `perm:"sign"`
PaychGetWaitReady func(ctx context.Context, sentinel cid.Cid) (address.Address, error) `perm:"sign"`
PaychList func(ctx context.Context) ([]address.Address, error) `perm:"read"`
PaychNewPayment func(ctx context.Context, from, to address.Address, vouchers []types.VoucherSpec) (*types.PaymentInfo, error) `perm:"sign"`
PaychSettle func(ctx context.Context, addr address.Address) (cid.Cid, error) `perm:"sign"`
PaychStatus func(ctx context.Context, pch address.Address) (*types.Status, error) `perm:"read"`
PaychVoucherAdd func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, proof []byte, minDelta big.Int) (big.Int, error) `perm:"write"`
PaychVoucherCheckSpendable func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (bool, error) `perm:"read"`
PaychVoucherCheckValid func(ctx context.Context, ch address.Address, sv *types.SignedVoucher) error `perm:"read"`
PaychVoucherCreate func(ctx context.Context, pch address.Address, amt big.Int, lane uint64) (*types.VoucherCreateResult, error) `perm:"sign"`
PaychVoucherList func(ctx context.Context, pch address.Address) ([]*types.SignedVoucher, error) `perm:"write"`
PaychVoucherSubmit func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error) `perm:"sign"`
}
}
func (*IPaychanStruct) PaychAllocateLane ¶
func (*IPaychanStruct) PaychAvailableFunds ¶
func (s *IPaychanStruct) PaychAvailableFunds(p0 context.Context, p1 address.Address) (*types.ChannelAvailableFunds, error)
func (*IPaychanStruct) PaychAvailableFundsByFromTo ¶
func (s *IPaychanStruct) PaychAvailableFundsByFromTo(p0 context.Context, p1, p2 address.Address) (*types.ChannelAvailableFunds, error)
func (*IPaychanStruct) PaychCollect ¶
func (*IPaychanStruct) PaychFund ¶ added in v1.6.0
func (s *IPaychanStruct) PaychFund(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (*types.ChannelInfo, error)
func (*IPaychanStruct) PaychGet ¶
func (s *IPaychanStruct) PaychGet(p0 context.Context, p1, p2 address.Address, p3 types.BigInt, p4 types.PaychGetOpts) (*types.ChannelInfo, error)
func (*IPaychanStruct) PaychGetWaitReady ¶
func (*IPaychanStruct) PaychNewPayment ¶
func (s *IPaychanStruct) PaychNewPayment(p0 context.Context, p1, p2 address.Address, p3 []types.VoucherSpec) (*types.PaymentInfo, error)
func (*IPaychanStruct) PaychSettle ¶
func (*IPaychanStruct) PaychStatus ¶
func (*IPaychanStruct) PaychVoucherAdd ¶
func (*IPaychanStruct) PaychVoucherCheckSpendable ¶
func (*IPaychanStruct) PaychVoucherCheckValid ¶
func (s *IPaychanStruct) PaychVoucherCheckValid(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher) error
func (*IPaychanStruct) PaychVoucherCreate ¶
func (*IPaychanStruct) PaychVoucherList ¶
func (s *IPaychanStruct) PaychVoucherList(p0 context.Context, p1 address.Address) ([]*types.SignedVoucher, error)
func (*IPaychanStruct) PaychVoucherSubmit ¶
type ISyncer ¶
type ISyncer interface {
ChainSyncHandleNewTipSet(ctx context.Context, ci *types.ChainInfo) error //perm:write
SetConcurrent(ctx context.Context, concurrent int64) error //perm:admin
SyncerTracker(ctx context.Context) *types.TargetTracker //perm:read
Concurrent(ctx context.Context) int64 //perm:read
ChainTipSetWeight(ctx context.Context, tsk types.TipSetKey) (big.Int, error) //perm:read
SyncSubmitBlock(ctx context.Context, blk *types.BlockMsg) error //perm:write
SyncState(ctx context.Context) (*types.SyncState, error) //perm:read
// SyncIncomingBlocks returns a channel streaming incoming, potentially not
// yet synced block headers.
SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error) //perm:read
// SyncCheckpoint marks a blocks as checkpointed, meaning that it won't ever fork away from it.
SyncCheckpoint(ctx context.Context, tsk types.TipSetKey) error //perm:admin
}
type ISyncerStruct ¶
type ISyncerStruct struct {
Internal struct {
ChainSyncHandleNewTipSet func(ctx context.Context, ci *types.ChainInfo) error `perm:"write"`
ChainTipSetWeight func(ctx context.Context, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
Concurrent func(ctx context.Context) int64 `perm:"read"`
SetConcurrent func(ctx context.Context, concurrent int64) error `perm:"admin"`
SyncCheckpoint func(ctx context.Context, tsk types.TipSetKey) error `perm:"admin"`
SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`
SyncState func(ctx context.Context) (*types.SyncState, error) `perm:"read"`
SyncSubmitBlock func(ctx context.Context, blk *types.BlockMsg) error `perm:"write"`
SyncerTracker func(ctx context.Context) *types.TargetTracker `perm:"read"`
}
}
func (*ISyncerStruct) ChainSyncHandleNewTipSet ¶
func (*ISyncerStruct) ChainTipSetWeight ¶
func (*ISyncerStruct) Concurrent ¶
func (s *ISyncerStruct) Concurrent(p0 context.Context) int64
func (*ISyncerStruct) SetConcurrent ¶
func (s *ISyncerStruct) SetConcurrent(p0 context.Context, p1 int64) error
func (*ISyncerStruct) SyncCheckpoint ¶ added in v1.17.0
func (*ISyncerStruct) SyncIncomingBlocks ¶ added in v1.14.0
func (s *ISyncerStruct) SyncIncomingBlocks(p0 context.Context) (<-chan *types.BlockHeader, error)
func (*ISyncerStruct) SyncSubmitBlock ¶
func (*ISyncerStruct) SyncerTracker ¶
func (s *ISyncerStruct) SyncerTracker(p0 context.Context) *types.TargetTracker
type IWallet ¶
type IWallet interface {
WalletSign(ctx context.Context, k address.Address, msg []byte, meta types.MsgMeta) (*crypto.Signature, error) //perm:sign
WalletExport(ctx context.Context, addr address.Address, password string) (*types.KeyInfo, error) //perm:admin
WalletImport(ctx context.Context, key *types.KeyInfo) (address.Address, error) //perm:admin
WalletDelete(ctx context.Context, addr address.Address) error //perm:admin
WalletHas(ctx context.Context, addr address.Address) (bool, error) //perm:write
WalletNewAddress(ctx context.Context, protocol address.Protocol) (address.Address, error) //perm:write
WalletBalance(ctx context.Context, addr address.Address) (abi.TokenAmount, error) //perm:read
WalletDefaultAddress(ctx context.Context) (address.Address, error) //perm:write
WalletAddresses(ctx context.Context) []address.Address //perm:admin
WalletSetDefault(ctx context.Context, addr address.Address) error //perm:write
WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error) //perm:sign
LockWallet(ctx context.Context) error //perm:admin
UnLockWallet(ctx context.Context, password []byte) error //perm:admin
SetPassword(ctx context.Context, password []byte) error //perm:admin
HasPassword(ctx context.Context) bool //perm:admin
WalletState(ctx context.Context) int //perm:admin
}
type IWalletStruct ¶
type IWalletStruct struct {
Internal struct {
HasPassword func(ctx context.Context) bool `perm:"admin"`
LockWallet func(ctx context.Context) error `perm:"admin"`
SetPassword func(ctx context.Context, password []byte) error `perm:"admin"`
UnLockWallet func(ctx context.Context, password []byte) error `perm:"admin"`
WalletAddresses func(ctx context.Context) []address.Address `perm:"admin"`
WalletBalance func(ctx context.Context, addr address.Address) (abi.TokenAmount, error) `perm:"read"`
WalletDefaultAddress func(ctx context.Context) (address.Address, error) `perm:"write"`
WalletDelete func(ctx context.Context, addr address.Address) error `perm:"admin"`
WalletExport func(ctx context.Context, addr address.Address, password string) (*types.KeyInfo, error) `perm:"admin"`
WalletHas func(ctx context.Context, addr address.Address) (bool, error) `perm:"write"`
WalletImport func(ctx context.Context, key *types.KeyInfo) (address.Address, error) `perm:"admin"`
WalletNewAddress func(ctx context.Context, protocol address.Protocol) (address.Address, error) `perm:"write"`
WalletSetDefault func(ctx context.Context, addr address.Address) error `perm:"write"`
WalletSign func(ctx context.Context, k address.Address, msg []byte, meta types.MsgMeta) (*crypto.Signature, error) `perm:"sign"`
WalletSignMessage func(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error) `perm:"sign"`
WalletState func(ctx context.Context) int `perm:"admin"`
}
}
func (*IWalletStruct) HasPassword ¶
func (s *IWalletStruct) HasPassword(p0 context.Context) bool
func (*IWalletStruct) LockWallet ¶
func (s *IWalletStruct) LockWallet(p0 context.Context) error
func (*IWalletStruct) SetPassword ¶
func (s *IWalletStruct) SetPassword(p0 context.Context, p1 []byte) error
func (*IWalletStruct) UnLockWallet ¶
func (s *IWalletStruct) UnLockWallet(p0 context.Context, p1 []byte) error
func (*IWalletStruct) WalletAddresses ¶
func (s *IWalletStruct) WalletAddresses(p0 context.Context) []address.Address
func (*IWalletStruct) WalletBalance ¶
func (s *IWalletStruct) WalletBalance(p0 context.Context, p1 address.Address) (abi.TokenAmount, error)
func (*IWalletStruct) WalletDefaultAddress ¶
func (*IWalletStruct) WalletDelete ¶ added in v1.8.0
func (*IWalletStruct) WalletExport ¶
func (*IWalletStruct) WalletImport ¶
func (*IWalletStruct) WalletNewAddress ¶
func (*IWalletStruct) WalletSetDefault ¶
func (*IWalletStruct) WalletSign ¶
func (*IWalletStruct) WalletSignMessage ¶
func (s *IWalletStruct) WalletSignMessage(p0 context.Context, p1 address.Address, p2 *types.Message) (*types.SignedMessage, error)
func (*IWalletStruct) WalletState ¶
func (s *IWalletStruct) WalletState(p0 context.Context) int
Source Files
¶
Click to show internal directories.
Click to hide internal directories.