Documentation
¶
Index ¶
- Constants
- Variables
- func PermissionedFullAPI(a api.FullNode) api.FullNode
- func PermissionedStorMinerAPI(a api.StorageMiner) api.StorageMiner
- func PermissionedWalletAPI(a api.WalletAPI) api.WalletAPI
- func PermissionedWorkerAPI(a api.WorkerAPI) api.WorkerAPI
- type CommonStruct
- func (c *CommonStruct) AuthNew(ctx context.Context, perms []auth.Permission) ([]byte, error)
- func (c *CommonStruct) AuthVerify(ctx context.Context, token string) ([]auth.Permission, error)
- func (c *CommonStruct) Closing(ctx context.Context) (<-chan struct{}, error)
- func (c *CommonStruct) GC(ctx context.Context) error
- func (c *CommonStruct) ID(ctx context.Context) (peer.ID, error)
- func (c *CommonStruct) LogList(ctx context.Context) ([]string, error)
- func (c *CommonStruct) LogSetLevel(ctx context.Context, group, level string) error
- func (c *CommonStruct) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)
- func (c *CommonStruct) NetAgentVersion(ctx context.Context, p peer.ID) (string, error)
- func (c *CommonStruct) NetAutoNatStatus(ctx context.Context) (api.NatInfo, error)
- func (c *CommonStruct) NetBandwidthStats(ctx context.Context) (metrics.Stats, error)
- func (c *CommonStruct) NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error)
- func (c *CommonStruct) NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error)
- func (c *CommonStruct) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error
- func (c *CommonStruct) NetBlockList(ctx context.Context) (api.NetBlockList, error)
- func (c *CommonStruct) NetBlockRemove(ctx context.Context, acl api.NetBlockList) error
- func (c *CommonStruct) NetConnect(ctx context.Context, p peer.AddrInfo) error
- func (c *CommonStruct) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)
- func (c *CommonStruct) NetDisconnect(ctx context.Context, p peer.ID) error
- func (c *CommonStruct) NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)
- func (c *CommonStruct) NetPeerInfo(ctx context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)
- func (c *CommonStruct) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)
- func (c *CommonStruct) NetPubsubScores(ctx context.Context) ([]api.PubsubScore, error)
- func (c *CommonStruct) Session(ctx context.Context) (uuid.UUID, error)
- func (c *CommonStruct) Shutdown(ctx context.Context) error
- func (c *CommonStruct) Version(ctx context.Context) (api.APIVersion, error)
- type FullNodeStruct
- func (c *FullNodeStruct) BeaconGetEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)
- func (c *FullNodeStruct) ChainAllowNoWindowPoSt(ctx context.Context, tsk types.TipSetKey, challenge abi.ChainEpoch, ...) (bool, error)
- func (c *FullNodeStruct) ChainDeleteObj(ctx context.Context, obj cid.Cid) error
- func (c *FullNodeStruct) ChainExport(ctx context.Context, nroots abi.ChainEpoch, iom bool, tsk types.TipSetKey) (<-chan []byte, error)
- func (c *FullNodeStruct) ChainGetBlock(ctx context.Context, b cid.Cid) (*types.BlockHeader, error)
- func (c *FullNodeStruct) ChainGetBlockMessages(ctx context.Context, b cid.Cid) (*api.BlockMessages, error)
- func (c *FullNodeStruct) ChainGetGenesis(ctx context.Context) (*types.TipSet, error)
- func (c *FullNodeStruct) ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)
- func (c *FullNodeStruct) ChainGetNode(ctx context.Context, p string) (*api.IpldObject, error)
- func (c *FullNodeStruct) ChainGetParentMessages(ctx context.Context, b cid.Cid) ([]api.Message, error)
- func (c *FullNodeStruct) ChainGetParentReceipts(ctx context.Context, b cid.Cid) ([]*types.MessageReceipt, error)
- func (c *FullNodeStruct) ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)
- func (c *FullNodeStruct) ChainGetRandomnessFromBeacon(ctx context.Context, tsk types.TipSetKey, ...) (abi.Randomness, error)
- func (c *FullNodeStruct) ChainGetRandomnessFromTickets(ctx context.Context, tsk types.TipSetKey, ...) (abi.Randomness, error)
- func (c *FullNodeStruct) ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error)
- func (c *FullNodeStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
- func (c *FullNodeStruct) ChainHasObj(ctx context.Context, o cid.Cid) (bool, error)
- func (c *FullNodeStruct) ChainHead(ctx context.Context) (*types.TipSet, error)
- func (c *FullNodeStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
- func (c *FullNodeStruct) ChainReadObj(ctx context.Context, obj cid.Cid) ([]byte, error)
- func (c *FullNodeStruct) ChainSetHead(ctx context.Context, tsk types.TipSetKey) error
- func (c *FullNodeStruct) ChainStatObj(ctx context.Context, obj, base cid.Cid) (api.ObjStat, error)
- func (c *FullNodeStruct) ChainTipSetWeight(ctx context.Context, tsk types.TipSetKey) (types.BigInt, error)
- func (c *FullNodeStruct) ClientCalcCommP(ctx context.Context, inpath string) (*api.CommPRet, error)
- func (c *FullNodeStruct) ClientCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (c *FullNodeStruct) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
- func (c *FullNodeStruct) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCIDSize, error)
- func (c *FullNodeStruct) ClientDealSize(ctx context.Context, root cid.Cid) (api.DataSize, error)
- func (c *FullNodeStruct) ClientExpertNominate(ctx context.Context, wallet address.Address, expert address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) ClientExpertRegisterFile(ctx context.Context, params *api.ExpertRegisterFileParams) (*cid.Cid, error)
- func (c *FullNodeStruct) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)
- func (c *FullNodeStruct) ClientGenCar(ctx context.Context, ref api.FileRef, outpath string) error
- func (c *FullNodeStruct) ClientGetDealInfo(ctx context.Context, deal cid.Cid) (*api.DealInfo, error)
- func (c *FullNodeStruct) ClientGetDealStatus(ctx context.Context, statusCode uint64) (string, error)
- func (c *FullNodeStruct) ClientGetDealUpdates(ctx context.Context) (<-chan api.DealInfo, error)
- func (c *FullNodeStruct) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error)
- func (c *FullNodeStruct) ClientImport(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)
- func (c *FullNodeStruct) ClientImportAndDeal(ctx context.Context, params *api.ImportAndDealParams) (*api.ImportRes, error)
- func (c *FullNodeStruct) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
- func (c *FullNodeStruct) ClientListDeals(ctx context.Context) ([]api.DealInfo, error)
- func (c *FullNodeStruct) ClientListImports(ctx context.Context) ([]api.Import, error)
- func (c *FullNodeStruct) ClientMinerQueryOffer(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)
- func (c *FullNodeStruct) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)
- func (c *FullNodeStruct) ClientRemove(ctx context.Context, root cid.Cid, wallet address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error
- func (c *FullNodeStruct) ClientRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (c *FullNodeStruct) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error
- func (c *FullNodeStruct) ClientRetrieveApplyForWithdraw(ctx context.Context, wallet address.Address, target address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) ClientRetrieveBind(ctx context.Context, wallet address.Address, miners []address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) ClientRetrieveGetDeal(ctx context.Context, dealID retrievalmarket.DealID) (*api.RetrievalDeal, error)
- func (c *FullNodeStruct) ClientRetrieveListDeals(ctx context.Context) (map[retrievalmarket.DealID]*api.RetrievalDeal, error)
- func (c *FullNodeStruct) ClientRetrievePledge(ctx context.Context, wallet address.Address, target address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) ClientRetrieveQuery(ctx context.Context, wallet address.Address, root cid.Cid, piece *cid.Cid, ...) (*api.RetrievalDeal, error)
- func (c *FullNodeStruct) ClientRetrieveTryRestartInsufficientFunds(ctx context.Context, paymentChannel address.Address) error
- func (c *FullNodeStruct) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)
- func (c *FullNodeStruct) ClientRetrieveWithdraw(ctx context.Context, wallet address.Address, amount abi.TokenAmount) (cid.Cid, error)
- func (c *FullNodeStruct) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
- func (c *FullNodeStruct) CreateBackup(ctx context.Context, fpath string) error
- func (c *FullNodeStruct) FlowchAllocateLane(ctx context.Context, ch address.Address) (uint64, error)
- func (c *FullNodeStruct) FlowchAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)
- func (c *FullNodeStruct) FlowchAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)
- func (c *FullNodeStruct) FlowchCollect(ctx context.Context, a address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) FlowchGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)
- func (c *FullNodeStruct) FlowchGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error)
- func (c *FullNodeStruct) FlowchList(ctx context.Context) ([]address.Address, error)
- func (c *FullNodeStruct) FlowchNewPayment(ctx context.Context, from, to address.Address, vouchers []api.FlowVoucherSpec) (*api.FlowInfo, error)
- func (c *FullNodeStruct) FlowchSettle(ctx context.Context, a address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) FlowchStatus(ctx context.Context, pch address.Address) (*api.FlowchStatus, error)
- func (c *FullNodeStruct) FlowchVoucherAdd(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher, ...) (types.BigInt, error)
- func (c *FullNodeStruct) FlowchVoucherCheckSpendable(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher, ...) (bool, error)
- func (c *FullNodeStruct) FlowchVoucherCheckValid(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher) error
- func (c *FullNodeStruct) FlowchVoucherCreate(ctx context.Context, pch address.Address, amt types.BigInt, lane uint64) (*api.FlowVoucherCreateResult, error)
- func (c *FullNodeStruct) FlowchVoucherList(ctx context.Context, pch address.Address) ([]*flowch.SignedVoucher, error)
- func (c *FullNodeStruct) FlowchVoucherSubmit(ctx context.Context, ch address.Address, sv *flowch.SignedVoucher, ...) (cid.Cid, error)
- func (c *FullNodeStruct) GasEstimateFeeCap(ctx context.Context, msg *types.Message, maxqueueblks int64, ...) (types.BigInt, error)
- func (c *FullNodeStruct) GasEstimateGasLimit(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (int64, error)
- func (c *FullNodeStruct) GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, ...) (types.BigInt, error)
- func (c *FullNodeStruct) GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, ...) (*types.Message, error)
- func (c *FullNodeStruct) MinerCreateBlock(ctx context.Context, bt *api.BlockTemplate) (*types.BlockMsg, error)
- func (c *FullNodeStruct) MinerGetBaseInfo(ctx context.Context, maddr address.Address, epoch abi.ChainEpoch, ...) (*api.MiningBaseInfo, error)
- func (c *FullNodeStruct) MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
- func (c *FullNodeStruct) MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error)
- func (c *FullNodeStruct) MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
- func (c *FullNodeStruct) MpoolClear(ctx context.Context, local bool) error
- func (c *FullNodeStruct) MpoolGetConfig(ctx context.Context) (*types.MpoolConfig, error)
- func (c *FullNodeStruct) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)
- func (c *FullNodeStruct) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)
- func (c *FullNodeStruct) MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
- func (c *FullNodeStruct) MpoolPushMessage(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec) (*types.SignedMessage, error)
- func (c *FullNodeStruct) MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
- func (c *FullNodeStruct) MpoolSelect(ctx context.Context, tsk types.TipSetKey, tq float64) ([]*types.SignedMessage, error)
- func (c *FullNodeStruct) MpoolSetConfig(ctx context.Context, cfg *types.MpoolConfig) error
- func (c *FullNodeStruct) MpoolSub(ctx context.Context) (<-chan api.MpoolUpdate, error)
- func (c *FullNodeStruct) MsigAddApprove(ctx context.Context, msig address.Address, src address.Address, txID uint64, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigAddCancel(ctx context.Context, msig address.Address, src address.Address, txID uint64, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigAddPropose(ctx context.Context, msig address.Address, src address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigApprove(ctx context.Context, msig address.Address, txID uint64, signer address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) MsigApproveTxnHash(ctx context.Context, msig address.Address, txID uint64, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigCancel(ctx context.Context, msig address.Address, txID uint64, to address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigCreate(ctx context.Context, req uint64, addrs []address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigGetAvailableBalance(ctx context.Context, a address.Address, tsk types.TipSetKey) (types.BigInt, error)
- func (c *FullNodeStruct) MsigGetPending(ctx context.Context, a address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
- func (c *FullNodeStruct) MsigGetVested(ctx context.Context, a address.Address, sTsk types.TipSetKey, ...) (types.BigInt, error)
- func (c *FullNodeStruct) MsigGetVestingSchedule(ctx context.Context, a address.Address, tsk types.TipSetKey) (api.MsigVesting, error)
- func (c *FullNodeStruct) MsigPropose(ctx context.Context, msig address.Address, to address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigRemoveSigner(ctx context.Context, msig address.Address, proposer address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigSwapApprove(ctx context.Context, msig address.Address, src address.Address, txID uint64, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigSwapCancel(ctx context.Context, msig address.Address, src address.Address, txID uint64, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MsigSwapPropose(ctx context.Context, msig address.Address, src address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) PaychAllocateLane(ctx context.Context, ch address.Address) (uint64, error)
- func (c *FullNodeStruct) PaychAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)
- func (c *FullNodeStruct) PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)
- func (c *FullNodeStruct) PaychCollect(ctx context.Context, a address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) PaychGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)
- func (c *FullNodeStruct) PaychGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error)
- func (c *FullNodeStruct) PaychList(ctx context.Context) ([]address.Address, error)
- func (c *FullNodeStruct) PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []api.VoucherSpec) (*api.PaymentInfo, error)
- func (c *FullNodeStruct) PaychSettle(ctx context.Context, a address.Address) (cid.Cid, error)
- func (c *FullNodeStruct) PaychStatus(ctx context.Context, pch address.Address) (*api.PaychStatus, error)
- func (c *FullNodeStruct) PaychVoucherAdd(ctx context.Context, addr address.Address, sv *paych.SignedVoucher, ...) (types.BigInt, error)
- func (c *FullNodeStruct) PaychVoucherCheckSpendable(ctx context.Context, addr address.Address, sv *paych.SignedVoucher, ...) (bool, error)
- func (c *FullNodeStruct) PaychVoucherCheckValid(ctx context.Context, addr address.Address, sv *paych.SignedVoucher) error
- func (c *FullNodeStruct) PaychVoucherCreate(ctx context.Context, pch address.Address, amt types.BigInt, lane uint64) (*api.VoucherCreateResult, error)
- func (c *FullNodeStruct) PaychVoucherList(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error)
- func (c *FullNodeStruct) PaychVoucherSubmit(ctx context.Context, ch address.Address, sv *paych.SignedVoucher, ...) (cid.Cid, error)
- func (c *FullNodeStruct) StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
- func (c *FullNodeStruct) StateAllMinerFaults(ctx context.Context, cutoff abi.ChainEpoch, endTsk types.TipSetKey) ([]*api.Fault, error)
- func (c *FullNodeStruct) StateBlockReward(ctx context.Context, bid cid.Cid, tsk types.TipSetKey) (*api.BlockReward, error)
- func (c *FullNodeStruct) StateCall(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*api.InvocResult, error)
- func (c *FullNodeStruct) StateChangedActors(ctx context.Context, olnstate cid.Cid, newstate cid.Cid) (map[string]types.Actor, error)
- func (c *FullNodeStruct) StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)
- func (c *FullNodeStruct) StateCoinbase(ctx context.Context, caddr address.Address, tsk types.TipSetKey) (*vesting.CoinbaseInfo, error)
- func (c *FullNodeStruct) StateCompute(ctx context.Context, height abi.ChainEpoch, msgs []*types.Message, ...) (*api.ComputeStateOutput, error)
- func (c *FullNodeStruct) StateDataIndex(ctx context.Context, epoch abi.ChainEpoch, tsk types.TipSetKey) ([]*api.DataIndex, error)
- func (c *FullNodeStruct) StateDecodeParams(ctx context.Context, toAddr address.Address, method abi.MethodNum, ...) (interface{}, error)
- func (c *FullNodeStruct) StateExpertDatas(ctx context.Context, addr address.Address, filter *bitfield.BitField, ...) ([]*expert.DataOnChainInfo, error)
- func (c *FullNodeStruct) StateExpertFileInfo(ctx context.Context, pieceCID cid.Cid, tsk types.TipSetKey) (*api.ExpertFileInfo, error)
- func (c *FullNodeStruct) StateExpertInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ExpertInfo, error)
- func (c *FullNodeStruct) StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)
- func (c *FullNodeStruct) StateGetReceipt(ctx context.Context, msg cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
- func (c *FullNodeStruct) StateGovernParams(ctx context.Context, tsk types.TipSetKey) (*govern.GovParams, error)
- func (c *FullNodeStruct) StateGovernSupervisor(ctx context.Context, tsk types.TipSetKey) (address.Address, error)
- func (c *FullNodeStruct) StateGovernorList(ctx context.Context, tsk types.TipSetKey) ([]*govern.GovernorInfo, error)
- func (c *FullNodeStruct) StateKnowledgeInfo(ctx context.Context, tsk types.TipSetKey) (*knowledge.Info, error)
- func (c *FullNodeStruct) StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
- func (c *FullNodeStruct) StateListExperts(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
- func (c *FullNodeStruct) StateListMessages(ctx context.Context, match *api.MessageMatch, tsk types.TipSetKey, ...) ([]cid.Cid, error)
- func (c *FullNodeStruct) StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
- func (c *FullNodeStruct) StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
- func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)
- func (c *FullNodeStruct) StateMarketRemainingQuota(ctx context.Context, pieceCid cid.Cid, tsk types.TipSetKey) (int64, error)
- func (c *FullNodeStruct) StateMarketStorageDeal(ctx context.Context, dealid abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
- func (c *FullNodeStruct) StateMinerActiveSectors(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
- func (c *FullNodeStruct) StateMinerActives(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)
- func (c *FullNodeStruct) StateMinerDeadlines(ctx context.Context, actor address.Address, tsk types.TipSetKey) ([]api.Deadline, error)
- func (c *FullNodeStruct) StateMinerFaults(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)
- func (c *FullNodeStruct) StateMinerFunds(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (miner.Funds, error)
- func (c *FullNodeStruct) StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)
- func (c *FullNodeStruct) StateMinerPartitions(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error)
- func (c *FullNodeStruct) StateMinerPower(ctx context.Context, a address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
- func (c *FullNodeStruct) StateMinerProvingDeadline(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)
- func (c *FullNodeStruct) StateMinerRecoveries(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)
- func (c *FullNodeStruct) StateMinerSectorAllocated(ctx context.Context, maddr address.Address, s abi.SectorNumber, ...) (bool, error)
- func (c *FullNodeStruct) StateMinerSectorCount(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MinerSectors, error)
- func (c *FullNodeStruct) StateMinerSectors(ctx context.Context, addr address.Address, sectorNos *bitfield.BitField, ...) ([]*miner.SectorOnChainInfo, error)
- func (c *FullNodeStruct) StateMinerStoredAnyPiece(ctx context.Context, addr address.Address, pieceIDs []cid.Cid, ...) (bool, error)
- func (c *FullNodeStruct) StateNetworkName(ctx context.Context) (dtypes.NetworkName, error)
- func (c *FullNodeStruct) StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)
- func (c *FullNodeStruct) StateReadState(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ActorState, error)
- func (c *FullNodeStruct) StateReplay(ctx context.Context, tsk types.TipSetKey, mc cid.Cid) (*api.InvocResult, error)
- func (c *FullNodeStruct) StateRetrievalInfo(ctx context.Context, tsk types.TipSetKey) (*api.RetrievalInfo, error)
- func (c *FullNodeStruct) StateRetrievalPledge(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalState, error)
- func (c *FullNodeStruct) StateRetrievalPledgeFrom(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalPledgeInfo, error)
- func (c *FullNodeStruct) StateRetrievalPledgeList(ctx context.Context, tsk types.TipSetKey) (map[address.Address]*api.RetrievalState, error)
- func (c *FullNodeStruct) StateSearchMsg(ctx context.Context, msgc cid.Cid) (*api.MsgLookup, error)
- func (c *FullNodeStruct) StateSearchMsgLimited(ctx context.Context, msgc cid.Cid, limit abi.ChainEpoch) (*api.MsgLookup, error)
- func (c *FullNodeStruct) StateSectorExpiration(ctx context.Context, maddr address.Address, n abi.SectorNumber, ...) (*miner.SectorExpiration, error)
- func (c *FullNodeStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error)
- func (c *FullNodeStruct) StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorLocation, error)
- func (c *FullNodeStruct) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, ...) (miner.SectorPreCommitOnChainInfo, error)
- func (c *FullNodeStruct) StateTotalMinedDetail(ctx context.Context, tsk types.TipSetKey) (*reward.TotalMinedDetail, error)
- func (c *FullNodeStruct) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)
- func (c *FullNodeStruct) StateVoteTally(ctx context.Context, tsk types.TipSetKey) (*vote.Tally, error)
- func (c *FullNodeStruct) StateVoterInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*vote.VoterInfo, error)
- func (c *FullNodeStruct) StateWaitMsg(ctx context.Context, msgc cid.Cid, confidence uint64) (*api.MsgLookup, error)
- func (c *FullNodeStruct) StateWaitMsgLimited(ctx context.Context, msgc cid.Cid, confidence uint64, limit abi.ChainEpoch) (*api.MsgLookup, error)
- func (c *FullNodeStruct) SyncCheckBad(ctx context.Context, bcid cid.Cid) (string, error)
- func (c *FullNodeStruct) SyncCheckpoint(ctx context.Context, tsk types.TipSetKey) error
- func (c *FullNodeStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error)
- func (c *FullNodeStruct) SyncMarkBad(ctx context.Context, bcid cid.Cid) error
- func (c *FullNodeStruct) SyncState(ctx context.Context) (*api.SyncState, error)
- func (c *FullNodeStruct) SyncSubmitBlock(ctx context.Context, blk *types.BlockMsg) error
- func (c *FullNodeStruct) SyncUnmarkAllBad(ctx context.Context) error
- func (c *FullNodeStruct) SyncUnmarkBad(ctx context.Context, bcid cid.Cid) error
- func (c *FullNodeStruct) SyncValidateTipset(ctx context.Context, tsk types.TipSetKey) (bool, error)
- func (c *FullNodeStruct) WalletBalance(ctx context.Context, a address.Address) (types.BigInt, error)
- func (c *FullNodeStruct) WalletDefaultAddress(ctx context.Context) (address.Address, error)
- func (c *FullNodeStruct) WalletDelete(ctx context.Context, addr address.Address) error
- func (c *FullNodeStruct) WalletExport(ctx context.Context, a address.Address) (*types.KeyInfo, error)
- func (c *FullNodeStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)
- func (c *FullNodeStruct) WalletImport(ctx context.Context, ki *types.KeyInfo) (address.Address, error)
- func (c *FullNodeStruct) WalletList(ctx context.Context) ([]address.Address, error)
- func (c *FullNodeStruct) WalletNew(ctx context.Context, typ types.KeyType) (address.Address, error)
- func (c *FullNodeStruct) WalletSetDefault(ctx context.Context, a address.Address) error
- func (c *FullNodeStruct) WalletSign(ctx context.Context, k address.Address, msg []byte) (*crypto.Signature, error)
- func (c *FullNodeStruct) WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error)
- func (c *FullNodeStruct) WalletValidateAddress(ctx context.Context, str string) (address.Address, error)
- func (c *FullNodeStruct) WalletVerify(ctx context.Context, k address.Address, msg []byte, sig *crypto.Signature) (bool, error)
- type GatewayStruct
- func (g GatewayStruct) ChainGetBlockMessages(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)
- func (g GatewayStruct) ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)
- func (g GatewayStruct) ChainGetTipSet(ctx context.Context, tsk types.TipSetKey) (*types.TipSet, error)
- func (g GatewayStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
- func (g GatewayStruct) ChainHasObj(ctx context.Context, c cid.Cid) (bool, error)
- func (g GatewayStruct) ChainHead(ctx context.Context) (*types.TipSet, error)
- func (g GatewayStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
- func (g GatewayStruct) ChainReadObj(ctx context.Context, c cid.Cid) ([]byte, error)
- func (g GatewayStruct) GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, ...) (*types.Message, error)
- func (g GatewayStruct) MpoolPush(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)
- func (g GatewayStruct) MsigGetAvailableBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.BigInt, error)
- func (g GatewayStruct) MsigGetPending(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
- func (g GatewayStruct) MsigGetVested(ctx context.Context, addr address.Address, start types.TipSetKey, ...) (types.BigInt, error)
- func (g GatewayStruct) StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
- func (g GatewayStruct) StateGetActor(ctx context.Context, actor address.Address, ts types.TipSetKey) (*types.Actor, error)
- func (g GatewayStruct) StateGetReceipt(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
- func (g GatewayStruct) StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
- func (g GatewayStruct) StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
- func (g GatewayStruct) StateMarketStorageDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
- func (g GatewayStruct) StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)
- func (g GatewayStruct) StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
- func (g GatewayStruct) StateMinerProvingDeadline(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)
- func (g GatewayStruct) StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)
- func (g GatewayStruct) StateReadState(ctx context.Context, addr address.Address, ts types.TipSetKey) (*api.ActorState, error)
- func (g GatewayStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error)
- func (g GatewayStruct) StateWaitMsg(ctx context.Context, msg cid.Cid, confidence uint64) (*api.MsgLookup, error)
- type StorageMinerStruct
- func (c *StorageMinerStruct) ActorAddress(ctx context.Context) (address.Address, error)
- func (c *StorageMinerStruct) ActorAddressConfig(ctx context.Context) (api.AddressConfig, error)
- func (c *StorageMinerStruct) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)
- func (c *StorageMinerStruct) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, ...) (map[abi.SectorNumber]string, error)
- func (c *StorageMinerStruct) CreateBackup(ctx context.Context, fpath string) error
- func (c *StorageMinerStruct) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
- func (c *StorageMinerStruct) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
- func (c *StorageMinerStruct) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
- func (c *StorageMinerStruct) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
- func (c *StorageMinerStruct) DealsImportData(ctx context.Context, dealPropCid cid.Cid, file string) error
- func (c *StorageMinerStruct) DealsList(ctx context.Context) ([]api.MarketDeal, error)
- func (c *StorageMinerStruct) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)
- func (c *StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
- func (c *StorageMinerStruct) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
- func (c *StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
- func (c *StorageMinerStruct) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
- func (c *StorageMinerStruct) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error
- func (c *StorageMinerStruct) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (c *StorageMinerStruct) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
- func (c *StorageMinerStruct) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
- func (c *StorageMinerStruct) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
- func (c *StorageMinerStruct) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
- func (c *StorageMinerStruct) MarketImportDealData(ctx context.Context, propcid cid.Cid, path string) error
- func (c *StorageMinerStruct) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
- func (c *StorageMinerStruct) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
- func (c *StorageMinerStruct) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
- func (c *StorageMinerStruct) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
- func (c *StorageMinerStruct) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
- func (c *StorageMinerStruct) MarketPublishPendingDeals(ctx context.Context) error
- func (c *StorageMinerStruct) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, ...) error
- func (c *StorageMinerStruct) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, ...) error
- func (c *StorageMinerStruct) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
- func (c *StorageMinerStruct) MiningBase(ctx context.Context) (*types.TipSet, error)
- func (c *StorageMinerStruct) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
- func (c *StorageMinerStruct) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
- func (c *StorageMinerStruct) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)
- func (c *StorageMinerStruct) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)
- func (c *StorageMinerStruct) PledgeSector(ctx context.Context) (abi.SectorID, error)
- func (c *StorageMinerStruct) ReturnAddPiece(ctx context.Context, callID storiface.CallID, pi abi.PieceInfo, ...) error
- func (c *StorageMinerStruct) ReturnFetch(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error
- func (c *StorageMinerStruct) ReturnFinalizeSector(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error
- func (c *StorageMinerStruct) ReturnMoveStorage(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error
- func (c *StorageMinerStruct) ReturnReadPiece(ctx context.Context, callID storiface.CallID, ok bool, ...) error
- func (c *StorageMinerStruct) ReturnReleaseUnsealed(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error
- func (c *StorageMinerStruct) ReturnSealCommit1(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, ...) error
- func (c *StorageMinerStruct) ReturnSealCommit2(ctx context.Context, callID storiface.CallID, proof storage.Proof, ...) error
- func (c *StorageMinerStruct) ReturnSealPreCommit1(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, ...) error
- func (c *StorageMinerStruct) ReturnSealPreCommit2(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, ...) error
- func (c *StorageMinerStruct) ReturnUnsealPiece(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error
- func (c *StorageMinerStruct) SealingAbort(ctx context.Context, call storiface.CallID) error
- func (c *StorageMinerStruct) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
- func (c *StorageMinerStruct) SectorGetExpectedSealDuration(ctx context.Context) (time.Duration, error)
- func (c *StorageMinerStruct) SectorGetSealDelay(ctx context.Context) (time.Duration, error)
- func (c *StorageMinerStruct) SectorRemove(ctx context.Context, number abi.SectorNumber) error
- func (c *StorageMinerStruct) SectorSetExpectedSealDuration(ctx context.Context, delay time.Duration) error
- func (c *StorageMinerStruct) SectorSetSealDelay(ctx context.Context, delay time.Duration) error
- func (c *StorageMinerStruct) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
- func (c *StorageMinerStruct) SectorTerminate(ctx context.Context, number abi.SectorNumber) error
- func (c *StorageMinerStruct) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)
- func (c *StorageMinerStruct) SectorTerminatePending(ctx context.Context) ([]abi.SectorID, error)
- func (c *StorageMinerStruct) SectorsList(ctx context.Context) ([]abi.SectorNumber, error)
- func (c *StorageMinerStruct) SectorsListInStates(ctx context.Context, states []api.SectorState) ([]abi.SectorNumber, error)
- func (c *StorageMinerStruct) SectorsRefs(ctx context.Context) (map[string][]api.SealedRef, error)
- func (c *StorageMinerStruct) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
- func (c *StorageMinerStruct) SectorsSummary(ctx context.Context) (map[api.SectorState]int, error)
- func (c *StorageMinerStruct) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error
- func (c *StorageMinerStruct) StorageAddLocal(ctx context.Context, path string) error
- func (c *StorageMinerStruct) StorageAttach(ctx context.Context, si stores.StorageInfo, st fsutil.FsStat) error
- func (c *StorageMinerStruct) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, ...) ([]stores.StorageInfo, error)
- func (c *StorageMinerStruct) StorageDeclareSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ...) error
- func (c *StorageMinerStruct) StorageDropSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ...) error
- func (c *StorageMinerStruct) StorageFindSector(ctx context.Context, si abi.SectorID, types storiface.SectorFileType, ...) ([]stores.SectorStorageInfo, error)
- func (c *StorageMinerStruct) StorageInfo(ctx context.Context, id stores.ID) (stores.StorageInfo, error)
- func (c *StorageMinerStruct) StorageList(ctx context.Context) (map[stores.ID][]stores.Decl, error)
- func (c *StorageMinerStruct) StorageLocal(ctx context.Context) (map[stores.ID]string, error)
- func (c *StorageMinerStruct) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) error
- func (c *StorageMinerStruct) StorageReportHealth(ctx context.Context, id stores.ID, report stores.HealthReport) error
- func (c *StorageMinerStruct) StorageStat(ctx context.Context, id stores.ID) (fsutil.FsStat, error)
- func (c *StorageMinerStruct) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) (bool, error)
- func (c *StorageMinerStruct) WorkerConnect(ctx context.Context, url string) error
- func (c *StorageMinerStruct) WorkerJobs(ctx context.Context) (map[uuid.UUID][]storiface.WorkerJob, error)
- func (c *StorageMinerStruct) WorkerStats(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
- type WalletStruct
- func (c *WalletStruct) WalletDelete(ctx context.Context, addr address.Address) error
- func (c *WalletStruct) WalletExport(ctx context.Context, a address.Address) (*types.KeyInfo, error)
- func (c *WalletStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)
- func (c *WalletStruct) WalletImport(ctx context.Context, ki *types.KeyInfo) (address.Address, error)
- func (c *WalletStruct) WalletList(ctx context.Context) ([]address.Address, error)
- func (c *WalletStruct) WalletNew(ctx context.Context, typ types.KeyType) (address.Address, error)
- func (c *WalletStruct) WalletSign(ctx context.Context, k address.Address, msg []byte, meta api.MsgMeta) (*crypto.Signature, error)
- type WorkerStruct
- func (w *WorkerStruct) AddPiece(ctx context.Context, sector storage.SectorRef, ...) (storiface.CallID, error)
- func (w *WorkerStruct) Enabled(ctx context.Context) (bool, error)
- func (w *WorkerStruct) Fetch(ctx context.Context, id storage.SectorRef, fileType storiface.SectorFileType, ...) (storiface.CallID, error)
- func (w *WorkerStruct) FinalizeSector(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (storiface.CallID, error)
- func (w *WorkerStruct) Info(ctx context.Context) (storiface.WorkerInfo, error)
- func (w *WorkerStruct) MoveStorage(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error)
- func (w *WorkerStruct) Paths(ctx context.Context) ([]stores.StoragePath, error)
- func (w *WorkerStruct) ProcessSession(ctx context.Context) (uuid.UUID, error)
- func (w *WorkerStruct) ReadPiece(ctx context.Context, sink io.Writer, sector storage.SectorRef, ...) (storiface.CallID, error)
- func (w *WorkerStruct) ReleaseUnsealed(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (storiface.CallID, error)
- func (w *WorkerStruct) Remove(ctx context.Context, sector abi.SectorID) error
- func (w *WorkerStruct) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (storiface.CallID, error)
- func (w *WorkerStruct) SealCommit2(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error)
- func (w *WorkerStruct) SealPreCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (storiface.CallID, error)
- func (w *WorkerStruct) SealPreCommit2(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error)
- func (w *WorkerStruct) Session(ctx context.Context) (uuid.UUID, error)
- func (w *WorkerStruct) SetEnabled(ctx context.Context, enabled bool) error
- func (w *WorkerStruct) StorageAddLocal(ctx context.Context, path string) error
- func (w *WorkerStruct) TaskDisable(ctx context.Context, tt sealtasks.TaskType) error
- func (w *WorkerStruct) TaskEnable(ctx context.Context, tt sealtasks.TaskType) error
- func (w *WorkerStruct) TaskTypes(ctx context.Context) (map[sealtasks.TaskType]struct{}, error)
- func (w *WorkerStruct) UnsealPiece(ctx context.Context, sector storage.SectorRef, ...) (storiface.CallID, error)
- func (w *WorkerStruct) Version(ctx context.Context) (api.Version, error)
- func (w *WorkerStruct) WaitQuiet(ctx context.Context) error
Constants ¶
View Source
const ( PermRead auth.Permission = "read" // default PermWrite auth.Permission = "write" PermSign auth.Permission = "sign" // Use wallet keys for signing PermAdmin auth.Permission = "admin" // Manage permissions )
Variables ¶
View Source
var AllPermissions = []auth.Permission{PermRead, PermWrite, PermSign, PermAdmin}
View Source
var DefaultPerms = []auth.Permission{PermRead}
Functions ¶
func PermissionedStorMinerAPI ¶
func PermissionedStorMinerAPI(a api.StorageMiner) api.StorageMiner
Types ¶
type CommonStruct ¶
type CommonStruct struct {
Internal struct {
AuthVerify func(ctx context.Context, token string) ([]auth.Permission, error) `perm:"read"`
AuthNew func(ctx context.Context, perms []auth.Permission) ([]byte, error) `perm:"admin"`
NetConnectedness func(context.Context, peer.ID) (network.Connectedness, error) `perm:"read"`
NetPeers func(context.Context) ([]peer.AddrInfo, error) `perm:"read"`
NetConnect func(context.Context, peer.AddrInfo) error `perm:"write"`
NetAddrsListen func(context.Context) (peer.AddrInfo, error) `perm:"read"`
NetDisconnect func(context.Context, peer.ID) error `perm:"write"`
NetFindPeer func(context.Context, peer.ID) (peer.AddrInfo, error) `perm:"read"`
NetPubsubScores func(context.Context) ([]api.PubsubScore, error) `perm:"read"`
NetAutoNatStatus func(context.Context) (api.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"`
NetAgentVersion func(ctx context.Context, p peer.ID) (string, error) `perm:"read"`
NetPeerInfo func(context.Context, peer.ID) (*api.ExtendedPeerInfo, error) `perm:"read"`
NetBlockAdd func(ctx context.Context, acl api.NetBlockList) error `perm:"admin"`
NetBlockRemove func(ctx context.Context, acl api.NetBlockList) error `perm:"admin"`
NetBlockList func(ctx context.Context) (api.NetBlockList, error) `perm:"read"`
ID func(context.Context) (peer.ID, error) `perm:"read"`
Version func(context.Context) (api.APIVersion, error) `perm:"read"`
LogList func(context.Context) ([]string, error) `perm:"write"`
LogSetLevel func(context.Context, string, string) error `perm:"write"`
GC func(context.Context) error `perm:"admin"`
Shutdown func(context.Context) error `perm:"admin"`
Session func(context.Context) (uuid.UUID, error) `perm:"read"`
Closing func(context.Context) (<-chan struct{}, error) `perm:"read"`
}
}
func (*CommonStruct) AuthNew ¶
func (c *CommonStruct) AuthNew(ctx context.Context, perms []auth.Permission) ([]byte, error)
func (*CommonStruct) AuthVerify ¶
func (c *CommonStruct) AuthVerify(ctx context.Context, token string) ([]auth.Permission, error)
func (*CommonStruct) Closing ¶
func (c *CommonStruct) Closing(ctx context.Context) (<-chan struct{}, error)
func (*CommonStruct) LogList ¶
func (c *CommonStruct) LogList(ctx context.Context) ([]string, error)
func (*CommonStruct) LogSetLevel ¶
func (c *CommonStruct) LogSetLevel(ctx context.Context, group, level string) error
func (*CommonStruct) NetAddrsListen ¶
func (*CommonStruct) NetAgentVersion ¶
func (*CommonStruct) NetAutoNatStatus ¶
func (*CommonStruct) NetBandwidthStats ¶
func (*CommonStruct) NetBandwidthStatsByPeer ¶
func (*CommonStruct) NetBandwidthStatsByProtocol ¶
func (*CommonStruct) NetBlockAdd ¶
func (c *CommonStruct) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error
func (*CommonStruct) NetBlockList ¶
func (c *CommonStruct) NetBlockList(ctx context.Context) (api.NetBlockList, error)
func (*CommonStruct) NetBlockRemove ¶
func (c *CommonStruct) NetBlockRemove(ctx context.Context, acl api.NetBlockList) error
func (*CommonStruct) NetConnect ¶
func (*CommonStruct) NetConnectedness ¶
func (c *CommonStruct) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)
func (*CommonStruct) NetDisconnect ¶
func (*CommonStruct) NetFindPeer ¶
func (*CommonStruct) NetPeerInfo ¶
func (c *CommonStruct) NetPeerInfo(ctx context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)
func (*CommonStruct) NetPubsubScores ¶
func (c *CommonStruct) NetPubsubScores(ctx context.Context) ([]api.PubsubScore, error)
func (*CommonStruct) Version ¶
func (c *CommonStruct) Version(ctx context.Context) (api.APIVersion, error)
Version implements API.Version
type FullNodeStruct ¶
type FullNodeStruct struct {
CommonStruct
Internal struct {
ChainNotify func(context.Context) (<-chan []*api.HeadChange, error) `perm:"read"`
ChainHead func(context.Context) (*types.TipSet, error) `perm:"read"`
ChainGetRandomnessFromTickets func(context.Context, types.TipSetKey, crypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error) `perm:"read"`
ChainGetRandomnessFromBeacon func(context.Context, types.TipSetKey, crypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error) `perm:"read"`
ChainAllowNoWindowPoSt func(context.Context, types.TipSetKey, abi.ChainEpoch, abi.Randomness) (bool, error) `perm:"read"`
ChainGetBlock func(context.Context, cid.Cid) (*types.BlockHeader, error) `perm:"read"`
ChainGetTipSet func(context.Context, types.TipSetKey) (*types.TipSet, error) `perm:"read"`
ChainGetBlockMessages func(context.Context, cid.Cid) (*api.BlockMessages, error) `perm:"read"`
ChainGetParentReceipts func(context.Context, cid.Cid) ([]*types.MessageReceipt, error) `perm:"read"`
ChainGetParentMessages func(context.Context, cid.Cid) ([]api.Message, error) `perm:"read"`
ChainGetTipSetByHeight func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error) `perm:"read"`
ChainReadObj func(context.Context, cid.Cid) ([]byte, error) `perm:"read"`
ChainDeleteObj func(context.Context, cid.Cid) error `perm:"admin"`
ChainHasObj func(context.Context, cid.Cid) (bool, error) `perm:"read"`
ChainStatObj func(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error) `perm:"read"`
ChainSetHead func(context.Context, types.TipSetKey) error `perm:"admin"`
ChainGetGenesis func(context.Context) (*types.TipSet, error) `perm:"read"`
ChainTipSetWeight func(context.Context, types.TipSetKey) (types.BigInt, error) `perm:"read"`
ChainGetNode func(ctx context.Context, p string) (*api.IpldObject, error) `perm:"read"`
ChainGetMessage func(context.Context, cid.Cid) (*types.Message, error) `perm:"read"`
ChainGetPath func(context.Context, types.TipSetKey, types.TipSetKey) ([]*api.HeadChange, error) `perm:"read"`
ChainExport func(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error) `perm:"read"`
BeaconGetEntry func(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error) `perm:"read"`
GasEstimateGasPremium func(context.Context, uint64, address.Address, int64, types.TipSetKey) (types.BigInt, error) `perm:"read"`
GasEstimateGasLimit func(context.Context, *types.Message, types.TipSetKey) (int64, error) `perm:"read"`
GasEstimateFeeCap func(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error) `perm:"read"`
GasEstimateMessageGas func(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error) `perm:"read"`
SyncState func(context.Context) (*api.SyncState, error) `perm:"read"`
SyncSubmitBlock func(ctx context.Context, blk *types.BlockMsg) error `perm:"write"`
SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`
SyncCheckpoint func(ctx context.Context, key types.TipSetKey) error `perm:"admin"`
SyncMarkBad func(ctx context.Context, bcid cid.Cid) error `perm:"admin"`
SyncUnmarkBad func(ctx context.Context, bcid cid.Cid) error `perm:"admin"`
SyncUnmarkAllBad func(ctx context.Context) error `perm:"admin"`
SyncCheckBad func(ctx context.Context, bcid cid.Cid) (string, error) `perm:"read"`
SyncValidateTipset func(ctx context.Context, tsk types.TipSetKey) (bool, error) `perm:"read"`
MpoolGetConfig func(context.Context) (*types.MpoolConfig, error) `perm:"read"`
MpoolSetConfig func(context.Context, *types.MpoolConfig) error `perm:"write"`
MpoolSelect func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error) `perm:"read"`
MpoolPending func(context.Context, types.TipSetKey) ([]*types.SignedMessage, error) `perm:"read"`
MpoolClear func(context.Context, bool) error `perm:"write"`
MpoolPush func(context.Context, *types.SignedMessage) (cid.Cid, error) `perm:"write"`
MpoolPushUntrusted func(context.Context, *types.SignedMessage) (cid.Cid, error) `perm:"write"`
MpoolPushMessage func(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error) `perm:"sign"`
MpoolGetNonce func(context.Context, address.Address) (uint64, error) `perm:"read"`
MpoolSub func(context.Context) (<-chan api.MpoolUpdate, error) `perm:"read"`
MpoolBatchPush func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) `perm:"write"`
MpoolBatchPushUntrusted func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error) `perm:"write"`
MpoolBatchPushMessage func(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error) `perm:"sign"`
MinerGetBaseInfo func(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*api.MiningBaseInfo, error) `perm:"read"`
MinerCreateBlock func(context.Context, *api.BlockTemplate) (*types.BlockMsg, error) `perm:"write"`
WalletNew func(context.Context, types.KeyType) (address.Address, error) `perm:"write"`
WalletHas func(context.Context, address.Address) (bool, error) `perm:"write"`
WalletList func(context.Context) ([]address.Address, error) `perm:"write"`
WalletBalance func(context.Context, address.Address) (types.BigInt, error) `perm:"read"`
WalletSign func(context.Context, address.Address, []byte) (*crypto.Signature, error) `perm:"sign"`
WalletSignMessage func(context.Context, address.Address, *types.Message) (*types.SignedMessage, error) `perm:"sign"`
WalletVerify func(context.Context, address.Address, []byte, *crypto.Signature) (bool, error) `perm:"read"`
WalletDefaultAddress func(context.Context) (address.Address, error) `perm:"write"`
WalletSetDefault func(context.Context, address.Address) error `perm:"admin"`
WalletExport func(context.Context, address.Address) (*types.KeyInfo, error) `perm:"admin"`
WalletImport func(context.Context, *types.KeyInfo) (address.Address, error) `perm:"admin"`
WalletDelete func(context.Context, address.Address) error `perm:"write"`
WalletValidateAddress func(context.Context, string) (address.Address, error) `perm:"read"`
ClientImport func(ctx context.Context, ref api.FileRef) (*api.ImportRes, error) `perm:"admin"`
ClientListImports func(ctx context.Context) ([]api.Import, error) `perm:"write"`
ClientRemoveImport func(ctx context.Context, importID multistore.StoreID) error `perm:"admin"`
ClientHasLocal func(ctx context.Context, root cid.Cid) (bool, error) `perm:"write"`
ClientFindData func(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error) `perm:"read"`
ClientMinerQueryOffer func(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error) `perm:"read"`
ClientStartDeal func(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error) `perm:"admin"`
ClientImportAndDeal func(ctx context.Context, params *api.ImportAndDealParams) (*api.ImportRes, error) `perm:"admin"`
ClientExpertRegisterFile func(ctx context.Context, params *api.ExpertRegisterFileParams) (*cid.Cid, error) `perm:"admin"`
ClientGetDealInfo func(context.Context, cid.Cid) (*api.DealInfo, error) `perm:"read"`
ClientGetDealStatus func(context.Context, uint64) (string, error) `perm:"read"`
ClientListDeals func(ctx context.Context) ([]api.DealInfo, error) `perm:"write"`
ClientGetDealUpdates func(ctx context.Context) (<-chan api.DealInfo, error) `perm:"read"`
ClientRetrieve func(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error `perm:"admin"`
ClientRetrieveWithEvents func(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error) `perm:"admin"`
ClientQueryAsk func(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error) `perm:"read"`
ClientDealPieceCID func(ctx context.Context, root cid.Cid) (api.DataCIDSize, error) `perm:"read"`
ClientCalcCommP func(ctx context.Context, inpath string) (*api.CommPRet, error) `perm:"read"`
ClientGenCar func(ctx context.Context, ref api.FileRef, outpath string) error `perm:"write"`
ClientDealSize func(ctx context.Context, root cid.Cid) (api.DataSize, error) `perm:"read"`
ClientListDataTransfers func(ctx context.Context) ([]api.DataTransferChannel, error) `perm:"write"`
ClientDataTransferUpdates func(ctx context.Context) (<-chan api.DataTransferChannel, error) `perm:"write"`
ClientRestartDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error `perm:"write"`
ClientCancelDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error `perm:"write"`
ClientRetrieveTryRestartInsufficientFunds func(ctx context.Context, paymentChannel address.Address) error `perm:"write"`
ClientRetrieveGetDeal func(ctx context.Context, dealID retrievalmarket.DealID) (*api.RetrievalDeal, error) `perm:"read"`
ClientRetrieveListDeals func(ctx context.Context) (map[retrievalmarket.DealID]*api.RetrievalDeal, error) `perm:"read"`
ClientRemove func(ctx context.Context, root cid.Cid, wallet address.Address) (cid.Cid, error) `perm:"admin"`
ClientRetrieveQuery func(ctx context.Context, wallet address.Address, root cid.Cid, piece *cid.Cid, miner address.Address) (*api.RetrievalDeal, error) `perm:"read"`
ClientRetrievePledge func(ctx context.Context, wallet address.Address, target address.Address, miners []address.Address, amount abi.TokenAmount) (cid.Cid, error) `perm:"admin"`
ClientRetrieveBind func(ctx context.Context, wallet address.Address, miners []address.Address, reverse bool) (cid.Cid, error) `perm:"admin"`
ClientRetrieveApplyForWithdraw func(ctx context.Context, wallet address.Address, target address.Address, amount abi.TokenAmount) (cid.Cid, error) `perm:"admin"`
ClientRetrieveWithdraw func(ctx context.Context, wallet address.Address, amount abi.TokenAmount) (cid.Cid, error) `perm:"admin"`
ClientExpertNominate func(ctx context.Context, wallet address.Address, expert address.Address) (cid.Cid, error) `perm:"admin"`
StateNetworkName func(context.Context) (dtypes.NetworkName, error) `perm:"read"`
StateMinerSectors func(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error) `perm:"read"`
StateMinerActiveSectors func(context.Context, address.Address, types.TipSetKey) ([]*miner.SectorOnChainInfo, error) `perm:"read"`
StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error) `perm:"read"`
StateMinerPower func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error) `perm:"read"`
StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (miner.MinerInfo, error) `perm:"read"`
StateMinerDeadlines func(context.Context, address.Address, types.TipSetKey) ([]api.Deadline, error) `perm:"read"`
StateMinerPartitions func(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error) `perm:"read"`
StateMinerFaults func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error) `perm:"read"`
StateMinerActives func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error) `perm:"read"`
StateAllMinerFaults func(context.Context, abi.ChainEpoch, types.TipSetKey) ([]*api.Fault, error) `perm:"read"`
StateMinerRecoveries func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error) `perm:"read"`
/* StateMinerPreCommitDepositForPower func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (types.BigInt, error) `perm:"read"`
StateMinerInitialPledgeCollateral func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (types.BigInt, error) `perm:"read"` */
StateCoinbase func(context.Context, address.Address, types.TipSetKey) (*vesting.CoinbaseInfo, error) `perm:"read"`
StateMinerFunds func(context.Context, address.Address, types.TipSetKey) (miner.Funds, error) `perm:"read"`
StateMinerSectorAllocated func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (bool, error) `perm:"read"`
StateSectorPreCommitInfo func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error) `perm:"read"`
StateSectorGetInfo func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorOnChainInfo, error) `perm:"read"`
StateSectorExpiration func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorExpiration, error) `perm:"read"`
StateSectorPartition func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorLocation, error) `perm:"read"`
StateCall func(context.Context, *types.Message, types.TipSetKey) (*api.InvocResult, error) `perm:"read"`
StateReplay func(context.Context, types.TipSetKey, cid.Cid) (*api.InvocResult, error) `perm:"read"`
StateBlockReward func(ctx context.Context, bid cid.Cid, tsk types.TipSetKey) (*api.BlockReward, error) `perm:"read"`
StateGetActor func(context.Context, address.Address, types.TipSetKey) (*types.Actor, error) `perm:"read"`
StateReadState func(context.Context, address.Address, types.TipSetKey) (*api.ActorState, error) `perm:"read"`
StateWaitMsg func(ctx context.Context, cid cid.Cid, confidence uint64) (*api.MsgLookup, error) `perm:"read"`
StateWaitMsgLimited func(context.Context, cid.Cid, uint64, abi.ChainEpoch) (*api.MsgLookup, error) `perm:"read"`
StateSearchMsg func(context.Context, cid.Cid) (*api.MsgLookup, error) `perm:"read"`
StateSearchMsgLimited func(context.Context, cid.Cid, abi.ChainEpoch) (*api.MsgLookup, error) `perm:"read"`
StateListMiners func(context.Context, types.TipSetKey) ([]address.Address, error) `perm:"read"`
StateListActors func(context.Context, types.TipSetKey) ([]address.Address, error) `perm:"read"`
// StateMarketBalance func(context.Context, address.Address, types.TipSetKey) (api.MarketBalance, error) `perm:"read"`
// StateMarketParticipants func(context.Context, types.TipSetKey) (map[string]api.MarketBalance, error) `perm:"read"`
StateMarketDeals func(context.Context, types.TipSetKey) (map[string]api.MarketDeal, error) `perm:"read"`
StateMarketStorageDeal func(context.Context, abi.DealID, types.TipSetKey) (*api.MarketDeal, error) `perm:"read"`
StateMarketRemainingQuota func(context.Context, cid.Cid, types.TipSetKey) (int64, error) `perm:"read"`
StateLookupID func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
StateAccountKey func(context.Context, address.Address, types.TipSetKey) (address.Address, error) `perm:"read"`
StateChangedActors func(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error) `perm:"read"`
StateGetReceipt func(context.Context, cid.Cid, types.TipSetKey) (*types.MessageReceipt, error) `perm:"read"`
StateMinerSectorCount func(context.Context, address.Address, types.TipSetKey) (api.MinerSectors, error) `perm:"read"`
StateListMessages func(ctx context.Context, match *api.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error) `perm:"read"`
StateDecodeParams func(context.Context, address.Address, abi.MethodNum, []byte, types.TipSetKey) (interface{}, error) `perm:"read"`
StateCompute func(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*api.ComputeStateOutput, error) `perm:"read"`
/* StateVerifierStatus func(context.Context, address.Address, types.TipSetKey) (*abi.StoragePower, error) `perm:"read"`
StateVerifiedClientStatus func(context.Context, address.Address, types.TipSetKey) (*abi.StoragePower, error) `perm:"read"`
StateVerifiedRegistryRootKey func(ctx context.Context, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
StateDealProviderCollateralBounds func(context.Context, abi.PaddedPieceSize, bool, types.TipSetKey) (api.DealCollateralBounds, error) `perm:"read"` */
StateTotalMinedDetail func(ctx context.Context, tsk types.TipSetKey) (*reward.TotalMinedDetail, error) `perm:"read"`
StateCirculatingSupply func(context.Context, types.TipSetKey) (abi.TokenAmount, error) `perm:"read"`
StateVMCirculatingSupplyInternal func(context.Context, types.TipSetKey) (api.CirculatingSupply, error) `perm:"read"`
StateNetworkVersion func(context.Context, types.TipSetKey) (stnetwork.Version, error) `perm:"read"`
StateListExperts func(context.Context, types.TipSetKey) ([]address.Address, error) `perm:"read"`
StateExpertInfo func(context.Context, address.Address, types.TipSetKey) (*api.ExpertInfo, error) `perm:"read"`
StateExpertDatas func(context.Context, address.Address, *bitfield.BitField, bool, types.TipSetKey) ([]*expert.DataOnChainInfo, error) `perm:"read"`
StateExpertFileInfo func(context.Context, cid.Cid, types.TipSetKey) (*api.ExpertFileInfo, error) `perm:"read"`
StateVoteTally func(context.Context, types.TipSetKey) (*vote.Tally, error) `perm:"read"`
StateVoterInfo func(context.Context, address.Address, types.TipSetKey) (*vote.VoterInfo, error) `perm:"read"`
StateKnowledgeInfo func(context.Context, types.TipSetKey) (*knowledge.Info, error) `perm:"read"`
StateGovernSupervisor func(context.Context, types.TipSetKey) (address.Address, error) `perm:"read"`
StateGovernorList func(context.Context, types.TipSetKey) ([]*govern.GovernorInfo, error) `perm:"read"`
StateGovernParams func(context.Context, types.TipSetKey) (*govern.GovParams, error) `perm:"read"`
StateRetrievalInfo func(context.Context, types.TipSetKey) (*api.RetrievalInfo, error) `perm:"read"`
StateRetrievalPledge func(context.Context, address.Address, types.TipSetKey) (*api.RetrievalState, error) `perm:"read"`
StateRetrievalPledgeFrom func(context.Context, address.Address, types.TipSetKey) (*api.RetrievalPledgeInfo, error) `perm:"read"`
StateRetrievalPledgeList func(context.Context, types.TipSetKey) (map[address.Address]*api.RetrievalState, error) `perm:"read"`
StateDataIndex func(context.Context, abi.ChainEpoch, types.TipSetKey) ([]*api.DataIndex, error) `perm:"read"`
StateMinerStoredAnyPiece func(context.Context, address.Address, []cid.Cid, types.TipSetKey) (bool, error) `perm:"read"`
MsigGetAvailableBalance func(context.Context, address.Address, types.TipSetKey) (types.BigInt, error) `perm:"read"`
MsigGetVestingSchedule func(context.Context, address.Address, types.TipSetKey) (api.MsigVesting, error) `perm:"read"`
MsigGetVested func(context.Context, address.Address, types.TipSetKey, types.TipSetKey) (types.BigInt, error) `perm:"read"`
MsigGetPending func(context.Context, address.Address, types.TipSetKey) ([]*api.MsigTransaction, error) `perm:"read"`
MsigCreate func(context.Context, uint64, []address.Address, abi.ChainEpoch, types.BigInt, address.Address, types.BigInt) (cid.Cid, error) `perm:"sign"`
MsigPropose func(context.Context, address.Address, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error) `perm:"sign"`
MsigApprove func(context.Context, address.Address, uint64, address.Address) (cid.Cid, error) `perm:"sign"`
MsigApproveTxnHash func(context.Context, address.Address, uint64, address.Address, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error) `perm:"sign"`
MsigCancel func(context.Context, address.Address, uint64, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error) `perm:"sign"`
MsigAddPropose func(context.Context, address.Address, address.Address, address.Address, bool) (cid.Cid, error) `perm:"sign"`
MsigAddApprove func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address, bool) (cid.Cid, error) `perm:"sign"`
MsigAddCancel func(context.Context, address.Address, address.Address, uint64, address.Address, bool) (cid.Cid, error) `perm:"sign"`
MsigSwapPropose func(context.Context, address.Address, address.Address, address.Address, address.Address) (cid.Cid, error) `perm:"sign"`
MsigSwapApprove func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address, address.Address) (cid.Cid, error) `perm:"sign"`
MsigSwapCancel func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address) (cid.Cid, error) `perm:"sign"`
MsigRemoveSigner func(ctx context.Context, msig address.Address, proposer address.Address, toRemove address.Address, decrease bool) (cid.Cid, error) `perm:"sign"`
PaychGet func(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error) `perm:"sign"`
PaychGetWaitReady func(context.Context, cid.Cid) (address.Address, error) `perm:"sign"`
PaychAvailableFunds func(context.Context, address.Address) (*api.ChannelAvailableFunds, error) `perm:"sign"`
PaychAvailableFundsByFromTo func(context.Context, address.Address, address.Address) (*api.ChannelAvailableFunds, error) `perm:"sign"`
PaychList func(context.Context) ([]address.Address, error) `perm:"read"`
PaychStatus func(context.Context, address.Address) (*api.PaychStatus, error) `perm:"read"`
PaychSettle func(context.Context, address.Address) (cid.Cid, error) `perm:"sign"`
PaychCollect func(context.Context, address.Address) (cid.Cid, error) `perm:"sign"`
PaychAllocateLane func(context.Context, address.Address) (uint64, error) `perm:"sign"`
PaychNewPayment func(ctx context.Context, from, to address.Address, vouchers []api.VoucherSpec) (*api.PaymentInfo, error) `perm:"sign"`
PaychVoucherCheck func(context.Context, *paych.SignedVoucher) error `perm:"read"`
PaychVoucherCheckValid func(context.Context, address.Address, *paych.SignedVoucher) error `perm:"read"`
PaychVoucherCheckSpendable func(context.Context, address.Address, *paych.SignedVoucher, []byte, []byte) (bool, error) `perm:"read"`
PaychVoucherAdd func(context.Context, address.Address, *paych.SignedVoucher, []byte, types.BigInt) (types.BigInt, error) `perm:"write"`
PaychVoucherCreate func(context.Context, address.Address, big.Int, uint64) (*api.VoucherCreateResult, error) `perm:"sign"`
PaychVoucherList func(context.Context, address.Address) ([]*paych.SignedVoucher, error) `perm:"write"`
PaychVoucherSubmit func(context.Context, address.Address, *paych.SignedVoucher, []byte, []byte) (cid.Cid, error) `perm:"sign"`
FlowchGet func(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error) `perm:"sign"`
FlowchGetWaitReady func(context.Context, cid.Cid) (address.Address, error) `perm:"sign"`
FlowchAvailableFunds func(context.Context, address.Address) (*api.ChannelAvailableFunds, error) `perm:"sign"`
FlowchAvailableFundsByFromTo func(context.Context, address.Address, address.Address) (*api.ChannelAvailableFunds, error) `perm:"sign"`
FlowchList func(context.Context) ([]address.Address, error) `perm:"read"`
FlowchStatus func(context.Context, address.Address) (*api.FlowchStatus, error) `perm:"read"`
FlowchSettle func(context.Context, address.Address) (cid.Cid, error) `perm:"sign"`
FlowchCollect func(context.Context, address.Address) (cid.Cid, error) `perm:"sign"`
FlowchAllocateLane func(context.Context, address.Address) (uint64, error) `perm:"sign"`
FlowchNewPayment func(ctx context.Context, from, to address.Address, vouchers []api.FlowVoucherSpec) (*api.FlowInfo, error) `perm:"sign"`
FlowchVoucherCheck func(context.Context, *flowch.SignedVoucher) error `perm:"read"`
FlowchVoucherCheckValid func(context.Context, address.Address, *flowch.SignedVoucher) error `perm:"read"`
FlowchVoucherCheckSpendable func(context.Context, address.Address, *flowch.SignedVoucher, []byte, []byte) (bool, error) `perm:"read"`
FlowchVoucherAdd func(context.Context, address.Address, *flowch.SignedVoucher, []byte, types.BigInt) (types.BigInt, error) `perm:"write"`
FlowchVoucherCreate func(context.Context, address.Address, big.Int, uint64) (*api.FlowVoucherCreateResult, error) `perm:"sign"`
FlowchVoucherList func(context.Context, address.Address) ([]*flowch.SignedVoucher, error) `perm:"write"`
FlowchVoucherSubmit func(context.Context, address.Address, *flowch.SignedVoucher, []byte, []byte) (cid.Cid, error) `perm:"sign"`
CreateBackup func(ctx context.Context, fpath string) error `perm:"admin"`
}
}
FullNodeStruct implements API passing calls to user-provided function values.
func (*FullNodeStruct) BeaconGetEntry ¶
func (c *FullNodeStruct) BeaconGetEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)
func (*FullNodeStruct) ChainAllowNoWindowPoSt ¶
func (c *FullNodeStruct) ChainAllowNoWindowPoSt(ctx context.Context, tsk types.TipSetKey, challenge abi.ChainEpoch, rand abi.Randomness) (bool, error)
func (*FullNodeStruct) ChainDeleteObj ¶
func (*FullNodeStruct) ChainExport ¶
func (c *FullNodeStruct) ChainExport(ctx context.Context, nroots abi.ChainEpoch, iom bool, tsk types.TipSetKey) (<-chan []byte, error)
func (*FullNodeStruct) ChainGetBlock ¶
func (c *FullNodeStruct) ChainGetBlock(ctx context.Context, b cid.Cid) (*types.BlockHeader, error)
func (*FullNodeStruct) ChainGetBlockMessages ¶
func (c *FullNodeStruct) ChainGetBlockMessages(ctx context.Context, b cid.Cid) (*api.BlockMessages, error)
func (*FullNodeStruct) ChainGetGenesis ¶
func (*FullNodeStruct) ChainGetMessage ¶
func (*FullNodeStruct) ChainGetNode ¶
func (c *FullNodeStruct) ChainGetNode(ctx context.Context, p string) (*api.IpldObject, error)
func (*FullNodeStruct) ChainGetParentMessages ¶
func (*FullNodeStruct) ChainGetParentReceipts ¶
func (c *FullNodeStruct) ChainGetParentReceipts(ctx context.Context, b cid.Cid) ([]*types.MessageReceipt, error)
func (*FullNodeStruct) ChainGetPath ¶
func (c *FullNodeStruct) ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)
func (*FullNodeStruct) ChainGetRandomnessFromBeacon ¶
func (c *FullNodeStruct) ChainGetRandomnessFromBeacon(ctx context.Context, tsk types.TipSetKey, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)
func (*FullNodeStruct) ChainGetRandomnessFromTickets ¶
func (c *FullNodeStruct) ChainGetRandomnessFromTickets(ctx context.Context, tsk types.TipSetKey, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)
func (*FullNodeStruct) ChainGetTipSet ¶
func (*FullNodeStruct) ChainGetTipSetByHeight ¶
func (c *FullNodeStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
func (*FullNodeStruct) ChainHasObj ¶
func (*FullNodeStruct) ChainNotify ¶
func (c *FullNodeStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
func (*FullNodeStruct) ChainReadObj ¶
func (*FullNodeStruct) ChainSetHead ¶
func (*FullNodeStruct) ChainStatObj ¶
func (*FullNodeStruct) ChainTipSetWeight ¶
func (*FullNodeStruct) ClientCalcCommP ¶
func (*FullNodeStruct) ClientCancelDataTransfer ¶
func (c *FullNodeStruct) ClientCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*FullNodeStruct) ClientDataTransferUpdates ¶
func (c *FullNodeStruct) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*FullNodeStruct) ClientDealPieceCID ¶
func (c *FullNodeStruct) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCIDSize, error)
func (*FullNodeStruct) ClientDealSize ¶
func (*FullNodeStruct) ClientExpertNominate ¶
func (*FullNodeStruct) ClientExpertRegisterFile ¶
func (c *FullNodeStruct) ClientExpertRegisterFile(ctx context.Context, params *api.ExpertRegisterFileParams) (*cid.Cid, error)
func (*FullNodeStruct) ClientFindData ¶
func (c *FullNodeStruct) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)
func (*FullNodeStruct) ClientGenCar ¶
func (*FullNodeStruct) ClientGetDealInfo ¶
func (*FullNodeStruct) ClientGetDealStatus ¶
func (*FullNodeStruct) ClientGetDealUpdates ¶
func (*FullNodeStruct) ClientHasLocal ¶
func (*FullNodeStruct) ClientImport ¶
func (*FullNodeStruct) ClientImportAndDeal ¶
func (c *FullNodeStruct) ClientImportAndDeal(ctx context.Context, params *api.ImportAndDealParams) (*api.ImportRes, error)
func (*FullNodeStruct) ClientListDataTransfers ¶
func (c *FullNodeStruct) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*FullNodeStruct) ClientListDeals ¶
func (*FullNodeStruct) ClientListImports ¶
func (*FullNodeStruct) ClientMinerQueryOffer ¶
func (*FullNodeStruct) ClientQueryAsk ¶
func (c *FullNodeStruct) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)
func (*FullNodeStruct) ClientRemove ¶
func (*FullNodeStruct) ClientRemoveImport ¶
func (c *FullNodeStruct) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error
func (*FullNodeStruct) ClientRestartDataTransfer ¶
func (c *FullNodeStruct) ClientRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*FullNodeStruct) ClientRetrieve ¶
func (c *FullNodeStruct) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error
func (*FullNodeStruct) ClientRetrieveApplyForWithdraw ¶
func (*FullNodeStruct) ClientRetrieveBind ¶
func (*FullNodeStruct) ClientRetrieveGetDeal ¶
func (c *FullNodeStruct) ClientRetrieveGetDeal(ctx context.Context, dealID retrievalmarket.DealID) (*api.RetrievalDeal, error)
func (*FullNodeStruct) ClientRetrieveListDeals ¶
func (c *FullNodeStruct) ClientRetrieveListDeals(ctx context.Context) (map[retrievalmarket.DealID]*api.RetrievalDeal, error)
func (*FullNodeStruct) ClientRetrievePledge ¶
func (*FullNodeStruct) ClientRetrieveQuery ¶
func (*FullNodeStruct) ClientRetrieveTryRestartInsufficientFunds ¶
func (*FullNodeStruct) ClientRetrieveWithEvents ¶
func (c *FullNodeStruct) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)
func (*FullNodeStruct) ClientRetrieveWithdraw ¶
func (c *FullNodeStruct) ClientRetrieveWithdraw(ctx context.Context, wallet address.Address, amount abi.TokenAmount) (cid.Cid, error)
func (*FullNodeStruct) ClientStartDeal ¶
func (c *FullNodeStruct) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
func (*FullNodeStruct) CreateBackup ¶
func (c *FullNodeStruct) CreateBackup(ctx context.Context, fpath string) error
func (*FullNodeStruct) FlowchAllocateLane ¶
func (*FullNodeStruct) FlowchAvailableFunds ¶
func (c *FullNodeStruct) FlowchAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) FlowchAvailableFundsByFromTo ¶
func (c *FullNodeStruct) FlowchAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) FlowchCollect ¶
func (*FullNodeStruct) FlowchGet ¶
func (c *FullNodeStruct) FlowchGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)
func (*FullNodeStruct) FlowchGetWaitReady ¶
func (*FullNodeStruct) FlowchList ¶
func (*FullNodeStruct) FlowchNewPayment ¶
func (c *FullNodeStruct) FlowchNewPayment(ctx context.Context, from, to address.Address, vouchers []api.FlowVoucherSpec) (*api.FlowInfo, error)
func (*FullNodeStruct) FlowchSettle ¶
func (*FullNodeStruct) FlowchStatus ¶
func (c *FullNodeStruct) FlowchStatus(ctx context.Context, pch address.Address) (*api.FlowchStatus, error)
func (*FullNodeStruct) FlowchVoucherAdd ¶
func (*FullNodeStruct) FlowchVoucherCheckSpendable ¶
func (*FullNodeStruct) FlowchVoucherCheckValid ¶
func (c *FullNodeStruct) FlowchVoucherCheckValid(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher) error
func (*FullNodeStruct) FlowchVoucherCreate ¶
func (*FullNodeStruct) FlowchVoucherList ¶
func (c *FullNodeStruct) FlowchVoucherList(ctx context.Context, pch address.Address) ([]*flowch.SignedVoucher, error)
func (*FullNodeStruct) FlowchVoucherSubmit ¶
func (*FullNodeStruct) GasEstimateFeeCap ¶
func (*FullNodeStruct) GasEstimateGasLimit ¶
func (*FullNodeStruct) GasEstimateGasPremium ¶
func (*FullNodeStruct) GasEstimateMessageGas ¶
func (*FullNodeStruct) MinerCreateBlock ¶
func (c *FullNodeStruct) MinerCreateBlock(ctx context.Context, bt *api.BlockTemplate) (*types.BlockMsg, error)
func (*FullNodeStruct) MinerGetBaseInfo ¶
func (c *FullNodeStruct) MinerGetBaseInfo(ctx context.Context, maddr address.Address, epoch abi.ChainEpoch, tsk types.TipSetKey) (*api.MiningBaseInfo, error)
func (*FullNodeStruct) MpoolBatchPush ¶
func (c *FullNodeStruct) MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
func (*FullNodeStruct) MpoolBatchPushMessage ¶
func (c *FullNodeStruct) MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error)
func (*FullNodeStruct) MpoolBatchPushUntrusted ¶
func (c *FullNodeStruct) MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
func (*FullNodeStruct) MpoolClear ¶
func (c *FullNodeStruct) MpoolClear(ctx context.Context, local bool) error
func (*FullNodeStruct) MpoolGetConfig ¶
func (c *FullNodeStruct) MpoolGetConfig(ctx context.Context) (*types.MpoolConfig, error)
func (*FullNodeStruct) MpoolGetNonce ¶
func (*FullNodeStruct) MpoolPending ¶
func (c *FullNodeStruct) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)
func (*FullNodeStruct) MpoolPush ¶
func (c *FullNodeStruct) MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
func (*FullNodeStruct) MpoolPushMessage ¶
func (c *FullNodeStruct) MpoolPushMessage(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec) (*types.SignedMessage, error)
func (*FullNodeStruct) MpoolPushUntrusted ¶
func (c *FullNodeStruct) MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
func (*FullNodeStruct) MpoolSelect ¶
func (c *FullNodeStruct) MpoolSelect(ctx context.Context, tsk types.TipSetKey, tq float64) ([]*types.SignedMessage, error)
func (*FullNodeStruct) MpoolSetConfig ¶
func (c *FullNodeStruct) MpoolSetConfig(ctx context.Context, cfg *types.MpoolConfig) error
func (*FullNodeStruct) MpoolSub ¶
func (c *FullNodeStruct) MpoolSub(ctx context.Context) (<-chan api.MpoolUpdate, error)
func (*FullNodeStruct) MsigAddApprove ¶
func (*FullNodeStruct) MsigAddCancel ¶
func (*FullNodeStruct) MsigAddPropose ¶
func (*FullNodeStruct) MsigApprove ¶
func (*FullNodeStruct) MsigApproveTxnHash ¶
func (*FullNodeStruct) MsigCancel ¶
func (*FullNodeStruct) MsigCreate ¶
func (*FullNodeStruct) MsigGetAvailableBalance ¶
func (*FullNodeStruct) MsigGetPending ¶
func (c *FullNodeStruct) MsigGetPending(ctx context.Context, a address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
func (*FullNodeStruct) MsigGetVested ¶
func (*FullNodeStruct) MsigGetVestingSchedule ¶
func (c *FullNodeStruct) MsigGetVestingSchedule(ctx context.Context, a address.Address, tsk types.TipSetKey) (api.MsigVesting, error)
func (*FullNodeStruct) MsigPropose ¶
func (*FullNodeStruct) MsigRemoveSigner ¶
func (*FullNodeStruct) MsigSwapApprove ¶
func (*FullNodeStruct) MsigSwapCancel ¶
func (*FullNodeStruct) MsigSwapPropose ¶
func (*FullNodeStruct) PaychAllocateLane ¶
func (*FullNodeStruct) PaychAvailableFunds ¶
func (c *FullNodeStruct) PaychAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) PaychAvailableFundsByFromTo ¶
func (c *FullNodeStruct) PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) PaychCollect ¶
func (*FullNodeStruct) PaychGet ¶
func (c *FullNodeStruct) PaychGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)
func (*FullNodeStruct) PaychGetWaitReady ¶
func (*FullNodeStruct) PaychNewPayment ¶
func (c *FullNodeStruct) PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []api.VoucherSpec) (*api.PaymentInfo, error)
func (*FullNodeStruct) PaychSettle ¶
func (*FullNodeStruct) PaychStatus ¶
func (c *FullNodeStruct) PaychStatus(ctx context.Context, pch address.Address) (*api.PaychStatus, error)
func (*FullNodeStruct) PaychVoucherAdd ¶
func (*FullNodeStruct) PaychVoucherCheckSpendable ¶
func (*FullNodeStruct) PaychVoucherCheckValid ¶
func (c *FullNodeStruct) PaychVoucherCheckValid(ctx context.Context, addr address.Address, sv *paych.SignedVoucher) error
func (*FullNodeStruct) PaychVoucherCreate ¶
func (*FullNodeStruct) PaychVoucherList ¶
func (c *FullNodeStruct) PaychVoucherList(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error)
func (*FullNodeStruct) PaychVoucherSubmit ¶
func (*FullNodeStruct) StateAccountKey ¶
func (*FullNodeStruct) StateAllMinerFaults ¶
func (c *FullNodeStruct) StateAllMinerFaults(ctx context.Context, cutoff abi.ChainEpoch, endTsk types.TipSetKey) ([]*api.Fault, error)
func (*FullNodeStruct) StateBlockReward ¶
func (c *FullNodeStruct) StateBlockReward(ctx context.Context, bid cid.Cid, tsk types.TipSetKey) (*api.BlockReward, error)
func (*FullNodeStruct) StateCall ¶
func (c *FullNodeStruct) StateCall(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*api.InvocResult, error)
func (*FullNodeStruct) StateChangedActors ¶
func (*FullNodeStruct) StateCirculatingSupply ¶
func (c *FullNodeStruct) StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)
func (*FullNodeStruct) StateCoinbase ¶
func (c *FullNodeStruct) StateCoinbase(ctx context.Context, caddr address.Address, tsk types.TipSetKey) (*vesting.CoinbaseInfo, error)
func (*FullNodeStruct) StateCompute ¶
func (c *FullNodeStruct) StateCompute(ctx context.Context, height abi.ChainEpoch, msgs []*types.Message, tsk types.TipSetKey) (*api.ComputeStateOutput, error)
func (*FullNodeStruct) StateDataIndex ¶
func (c *FullNodeStruct) StateDataIndex(ctx context.Context, epoch abi.ChainEpoch, tsk types.TipSetKey) ([]*api.DataIndex, error)
func (*FullNodeStruct) StateDecodeParams ¶
func (*FullNodeStruct) StateExpertDatas ¶
func (*FullNodeStruct) StateExpertFileInfo ¶
func (c *FullNodeStruct) StateExpertFileInfo(ctx context.Context, pieceCID cid.Cid, tsk types.TipSetKey) (*api.ExpertFileInfo, error)
func (*FullNodeStruct) StateExpertInfo ¶
func (c *FullNodeStruct) StateExpertInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ExpertInfo, error)
func (*FullNodeStruct) StateGetActor ¶
func (*FullNodeStruct) StateGetReceipt ¶
func (c *FullNodeStruct) StateGetReceipt(ctx context.Context, msg cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
func (*FullNodeStruct) StateGovernParams ¶
func (*FullNodeStruct) StateGovernSupervisor ¶
func (*FullNodeStruct) StateGovernorList ¶
func (c *FullNodeStruct) StateGovernorList(ctx context.Context, tsk types.TipSetKey) ([]*govern.GovernorInfo, error)
func (*FullNodeStruct) StateKnowledgeInfo ¶
func (*FullNodeStruct) StateListActors ¶
func (*FullNodeStruct) StateListExperts ¶
func (*FullNodeStruct) StateListMessages ¶
func (c *FullNodeStruct) StateListMessages(ctx context.Context, match *api.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error)
func (*FullNodeStruct) StateListMiners ¶
func (*FullNodeStruct) StateLookupID ¶
func (*FullNodeStruct) StateMarketDeals ¶
func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)
func (*FullNodeStruct) StateMarketRemainingQuota ¶
func (*FullNodeStruct) StateMarketStorageDeal ¶
func (c *FullNodeStruct) StateMarketStorageDeal(ctx context.Context, dealid abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
func (*FullNodeStruct) StateMinerActiveSectors ¶
func (c *FullNodeStruct) StateMinerActiveSectors(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
func (*FullNodeStruct) StateMinerActives ¶
func (*FullNodeStruct) StateMinerDeadlines ¶
func (*FullNodeStruct) StateMinerFaults ¶
func (*FullNodeStruct) StateMinerFunds ¶
func (*FullNodeStruct) StateMinerInfo ¶
func (*FullNodeStruct) StateMinerPartitions ¶
func (*FullNodeStruct) StateMinerPower ¶
func (c *FullNodeStruct) StateMinerPower(ctx context.Context, a address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
func (*FullNodeStruct) StateMinerProvingDeadline ¶
func (*FullNodeStruct) StateMinerRecoveries ¶
func (*FullNodeStruct) StateMinerSectorAllocated ¶
func (*FullNodeStruct) StateMinerSectorCount ¶
func (c *FullNodeStruct) StateMinerSectorCount(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MinerSectors, error)
func (*FullNodeStruct) StateMinerSectors ¶
func (*FullNodeStruct) StateMinerStoredAnyPiece ¶
func (*FullNodeStruct) StateNetworkName ¶
func (c *FullNodeStruct) StateNetworkName(ctx context.Context) (dtypes.NetworkName, error)
func (*FullNodeStruct) StateNetworkVersion ¶
func (*FullNodeStruct) StateReadState ¶
func (c *FullNodeStruct) StateReadState(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ActorState, error)
func (*FullNodeStruct) StateReplay ¶
func (c *FullNodeStruct) StateReplay(ctx context.Context, tsk types.TipSetKey, mc cid.Cid) (*api.InvocResult, error)
func (*FullNodeStruct) StateRetrievalInfo ¶
func (c *FullNodeStruct) StateRetrievalInfo(ctx context.Context, tsk types.TipSetKey) (*api.RetrievalInfo, error)
func (*FullNodeStruct) StateRetrievalPledge ¶
func (c *FullNodeStruct) StateRetrievalPledge(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalState, error)
func (*FullNodeStruct) StateRetrievalPledgeFrom ¶
func (c *FullNodeStruct) StateRetrievalPledgeFrom(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalPledgeInfo, error)
func (*FullNodeStruct) StateRetrievalPledgeList ¶
func (c *FullNodeStruct) StateRetrievalPledgeList(ctx context.Context, tsk types.TipSetKey) (map[address.Address]*api.RetrievalState, error)
func (*FullNodeStruct) StateSearchMsg ¶
func (*FullNodeStruct) StateSearchMsgLimited ¶
func (c *FullNodeStruct) StateSearchMsgLimited(ctx context.Context, msgc cid.Cid, limit abi.ChainEpoch) (*api.MsgLookup, error)
func (*FullNodeStruct) StateSectorExpiration ¶
func (c *FullNodeStruct) StateSectorExpiration(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorExpiration, error)
func (*FullNodeStruct) StateSectorGetInfo ¶
func (c *FullNodeStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
func (*FullNodeStruct) StateSectorPartition ¶
func (c *FullNodeStruct) StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok types.TipSetKey) (*miner.SectorLocation, error)
func (*FullNodeStruct) StateSectorPreCommitInfo ¶
func (c *FullNodeStruct) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error)
func (*FullNodeStruct) StateTotalMinedDetail ¶
func (c *FullNodeStruct) StateTotalMinedDetail(ctx context.Context, tsk types.TipSetKey) (*reward.TotalMinedDetail, error)
func (*FullNodeStruct) StateVMCirculatingSupplyInternal ¶
func (c *FullNodeStruct) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)
func (*FullNodeStruct) StateVoteTally ¶
func (*FullNodeStruct) StateVoterInfo ¶
func (*FullNodeStruct) StateWaitMsg ¶
func (*FullNodeStruct) StateWaitMsgLimited ¶
func (*FullNodeStruct) SyncCheckBad ¶
func (*FullNodeStruct) SyncCheckpoint ¶
func (*FullNodeStruct) SyncIncomingBlocks ¶
func (c *FullNodeStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error)
func (*FullNodeStruct) SyncMarkBad ¶
func (*FullNodeStruct) SyncSubmitBlock ¶
func (*FullNodeStruct) SyncUnmarkAllBad ¶
func (c *FullNodeStruct) SyncUnmarkAllBad(ctx context.Context) error
func (*FullNodeStruct) SyncUnmarkBad ¶
func (*FullNodeStruct) SyncValidateTipset ¶
func (*FullNodeStruct) WalletBalance ¶
func (*FullNodeStruct) WalletDefaultAddress ¶
func (*FullNodeStruct) WalletDelete ¶
func (*FullNodeStruct) WalletExport ¶
func (*FullNodeStruct) WalletImport ¶
func (*FullNodeStruct) WalletList ¶
func (*FullNodeStruct) WalletSetDefault ¶
func (*FullNodeStruct) WalletSign ¶
func (*FullNodeStruct) WalletSignMessage ¶
func (c *FullNodeStruct) WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error)
func (*FullNodeStruct) WalletValidateAddress ¶
type GatewayStruct ¶
type GatewayStruct struct {
Internal struct {
ChainGetBlockMessages func(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)
ChainGetMessage func(ctx context.Context, mc cid.Cid) (*types.Message, error)
ChainGetTipSet func(ctx context.Context, tsk types.TipSetKey) (*types.TipSet, error)
ChainGetTipSetByHeight func(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
ChainHasObj func(context.Context, cid.Cid) (bool, error)
ChainHead func(ctx context.Context) (*types.TipSet, error)
ChainNotify func(ctx context.Context) (<-chan []*api.HeadChange, error)
ChainReadObj func(context.Context, cid.Cid) ([]byte, error)
GasEstimateMessageGas func(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)
MpoolPush func(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)
MsigGetAvailableBalance func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.BigInt, error)
MsigGetVested func(ctx context.Context, addr address.Address, start types.TipSetKey, end types.TipSetKey) (types.BigInt, error)
MsigGetPending func(context.Context, address.Address, types.TipSetKey) ([]*api.MsigTransaction, error)
StateAccountKey func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
// StateDealProviderCollateralBounds func(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (api.DealCollateralBounds, error)
StateGetActor func(ctx context.Context, actor address.Address, ts types.TipSetKey) (*types.Actor, error)
StateGetReceipt func(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
StateLookupID func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
StateListMiners func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
StateMinerInfo func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)
StateMinerProvingDeadline func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)
StateMinerPower func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error)
// StateMarketBalance func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, error)
StateMarketStorageDeal func(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
StateReadState func(context.Context, address.Address, types.TipSetKey) (*api.ActorState, error)
StateNetworkVersion func(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)
StateSearchMsg func(ctx context.Context, msg cid.Cid) (*api.MsgLookup, error)
StateSectorGetInfo func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
// StateVerifiedClientStatus func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
StateWaitMsg func(ctx context.Context, msg cid.Cid, confidence uint64) (*api.MsgLookup, error)
}
}
func (GatewayStruct) ChainGetBlockMessages ¶
func (g GatewayStruct) ChainGetBlockMessages(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)
func (GatewayStruct) ChainGetMessage ¶
func (GatewayStruct) ChainGetTipSet ¶
func (GatewayStruct) ChainGetTipSetByHeight ¶
func (g GatewayStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
func (GatewayStruct) ChainHasObj ¶
func (GatewayStruct) ChainNotify ¶
func (g GatewayStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
func (GatewayStruct) ChainReadObj ¶
func (GatewayStruct) GasEstimateMessageGas ¶
func (GatewayStruct) MpoolPush ¶
func (g GatewayStruct) MpoolPush(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)
func (GatewayStruct) MsigGetAvailableBalance ¶
func (GatewayStruct) MsigGetPending ¶
func (g GatewayStruct) MsigGetPending(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
func (GatewayStruct) MsigGetVested ¶
func (GatewayStruct) StateAccountKey ¶
func (GatewayStruct) StateGetActor ¶
func (GatewayStruct) StateGetReceipt ¶
func (g GatewayStruct) StateGetReceipt(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
func (GatewayStruct) StateListMiners ¶
func (GatewayStruct) StateLookupID ¶
func (GatewayStruct) StateMarketStorageDeal ¶
func (g GatewayStruct) StateMarketStorageDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
func (GatewayStruct) StateMinerInfo ¶
func (GatewayStruct) StateMinerPower ¶
func (g GatewayStruct) StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
func (GatewayStruct) StateMinerProvingDeadline ¶
func (GatewayStruct) StateNetworkVersion ¶
func (GatewayStruct) StateReadState ¶
func (g GatewayStruct) StateReadState(ctx context.Context, addr address.Address, ts types.TipSetKey) (*api.ActorState, error)
func (GatewayStruct) StateSectorGetInfo ¶
func (g GatewayStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
type StorageMinerStruct ¶
type StorageMinerStruct struct {
CommonStruct
Internal struct {
ActorAddress func(context.Context) (address.Address, error) `perm:"read"`
ActorSectorSize func(context.Context, address.Address) (abi.SectorSize, error) `perm:"read"`
ActorAddressConfig func(ctx context.Context) (api.AddressConfig, error) `perm:"read"`
MiningBase func(context.Context) (*types.TipSet, error) `perm:"read"`
MarketImportDealData func(context.Context, cid.Cid, string) error `perm:"write"`
MarketListDeals func(ctx context.Context) ([]api.MarketDeal, error) `perm:"read"`
MarketListRetrievalDeals func(ctx context.Context) ([]retrievalmarket.ProviderDealState, error) `perm:"read"`
MarketGetDealUpdates func(ctx context.Context) (<-chan storagemarket.MinerDeal, error) `perm:"read"`
MarketListIncompleteDeals func(ctx context.Context) ([]storagemarket.MinerDeal, error) `perm:"read"`
MarketSetAsk func(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error `perm:"admin"`
MarketGetAsk func(ctx context.Context) (*storagemarket.SignedStorageAsk, error) `perm:"read"`
MarketSetRetrievalAsk func(ctx context.Context, rask *retrievalmarket.Ask) error `perm:"admin"`
MarketGetRetrievalAsk func(ctx context.Context) (*retrievalmarket.Ask, error) `perm:"read"`
MarketListDataTransfers func(ctx context.Context) ([]api.DataTransferChannel, error) `perm:"write"`
MarketDataTransferUpdates func(ctx context.Context) (<-chan api.DataTransferChannel, error) `perm:"write"`
MarketRestartDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error `perm:"write"`
MarketCancelDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error `perm:"write"`
MarketPendingDeals func(ctx context.Context) (api.PendingDealInfo, error) `perm:"write"`
MarketPublishPendingDeals func(ctx context.Context) error `perm:"admin"`
PledgeSector func(context.Context) (abi.SectorID, error) `perm:"write"`
SectorsStatus func(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error) `perm:"read"`
SectorsList func(context.Context) ([]abi.SectorNumber, error) `perm:"read"`
SectorsListInStates func(context.Context, []api.SectorState) ([]abi.SectorNumber, error) `perm:"read"`
SectorsSummary func(ctx context.Context) (map[api.SectorState]int, error) `perm:"read"`
SectorsRefs func(context.Context) (map[string][]api.SealedRef, error) `perm:"read"`
SectorStartSealing func(context.Context, abi.SectorNumber) error `perm:"write"`
SectorSetSealDelay func(context.Context, time.Duration) error `perm:"write"`
SectorGetSealDelay func(context.Context) (time.Duration, error) `perm:"read"`
SectorSetExpectedSealDuration func(context.Context, time.Duration) error `perm:"write"`
SectorGetExpectedSealDuration func(context.Context) (time.Duration, error) `perm:"read"`
SectorsUpdate func(context.Context, abi.SectorNumber, api.SectorState) error `perm:"admin"`
SectorRemove func(context.Context, abi.SectorNumber) error `perm:"admin"`
SectorTerminate func(context.Context, abi.SectorNumber) error `perm:"admin"`
SectorTerminateFlush func(ctx context.Context) (*cid.Cid, error) `perm:"admin"`
SectorTerminatePending func(ctx context.Context) ([]abi.SectorID, error) `perm:"admin"`
WorkerConnect func(context.Context, string) error `perm:"admin" retry:"true"` // TODO: worker perm
WorkerStats func(context.Context) (map[uuid.UUID]storiface.WorkerStats, error) `perm:"admin"`
WorkerJobs func(context.Context) (map[uuid.UUID][]storiface.WorkerJob, error) `perm:"admin"`
ReturnAddPiece func(ctx context.Context, callID storiface.CallID, pi abi.PieceInfo, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnSealPreCommit1 func(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnSealPreCommit2 func(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnSealCommit1 func(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnSealCommit2 func(ctx context.Context, callID storiface.CallID, proof storage.Proof, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnFinalizeSector func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnReleaseUnsealed func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnMoveStorage func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnUnsealPiece func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnReadPiece func(ctx context.Context, callID storiface.CallID, ok bool, err *storiface.CallError) error `perm:"admin" retry:"true"`
ReturnFetch func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error `perm:"admin" retry:"true"`
SealingSchedDiag func(context.Context, bool) (interface{}, error) `perm:"admin"`
SealingAbort func(ctx context.Context, call storiface.CallID) error `perm:"admin"`
StorageList func(context.Context) (map[stores.ID][]stores.Decl, error) `perm:"admin"`
StorageLocal func(context.Context) (map[stores.ID]string, error) `perm:"admin"`
StorageStat func(context.Context, stores.ID) (fsutil.FsStat, error) `perm:"admin"`
StorageAttach func(context.Context, stores.StorageInfo, fsutil.FsStat) error `perm:"admin"`
StorageDeclareSector func(context.Context, stores.ID, abi.SectorID, storiface.SectorFileType, bool) error `perm:"admin"`
StorageDropSector func(context.Context, stores.ID, abi.SectorID, storiface.SectorFileType) error `perm:"admin"`
StorageFindSector func(context.Context, abi.SectorID, storiface.SectorFileType, abi.SectorSize, bool) ([]stores.SectorStorageInfo, error) `perm:"admin"`
StorageInfo func(context.Context, stores.ID) (stores.StorageInfo, error) `perm:"admin"`
StorageBestAlloc func(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, sealing storiface.PathType) ([]stores.StorageInfo, error) `perm:"admin"`
StorageReportHealth func(ctx context.Context, id stores.ID, report stores.HealthReport) error `perm:"admin"`
StorageLock func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) error `perm:"admin"`
StorageTryLock func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) (bool, error) `perm:"admin"`
DealsImportData func(ctx context.Context, dealPropCid cid.Cid, file string) error `perm:"write"`
DealsList func(ctx context.Context) ([]api.MarketDeal, error) `perm:"read"`
DealsConsiderOnlineStorageDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderOnlineStorageDeals func(context.Context, bool) error `perm:"admin"`
DealsConsiderOnlineRetrievalDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderOnlineRetrievalDeals func(context.Context, bool) error `perm:"admin"`
DealsConsiderOfflineStorageDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderOfflineStorageDeals func(context.Context, bool) error `perm:"admin"`
DealsConsiderOfflineRetrievalDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderOfflineRetrievalDeals func(context.Context, bool) error `perm:"admin"`
DealsPieceCidBlocklist func(context.Context) ([]cid.Cid, error) `perm:"read"`
DealsSetPieceCidBlocklist func(context.Context, []cid.Cid) error `perm:"admin"`
StorageAddLocal func(ctx context.Context, path string) error `perm:"admin"`
PiecesListPieces func(ctx context.Context) ([]cid.Cid, error) `perm:"read"`
PiecesListCidInfos func(ctx context.Context) ([]cid.Cid, error) `perm:"read"`
PiecesGetPieceInfo func(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error) `perm:"read"`
PiecesGetCIDInfo func(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error) `perm:"read"`
CreateBackup func(ctx context.Context, fpath string) error `perm:"admin"`
CheckProvable func(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, expensive bool) (map[abi.SectorNumber]string, error) `perm:"admin"`
}
}
func (*StorageMinerStruct) ActorAddress ¶
func (*StorageMinerStruct) ActorAddressConfig ¶
func (c *StorageMinerStruct) ActorAddressConfig(ctx context.Context) (api.AddressConfig, error)
func (*StorageMinerStruct) ActorSectorSize ¶
func (c *StorageMinerStruct) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)
func (*StorageMinerStruct) CheckProvable ¶
func (c *StorageMinerStruct) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, expensive bool) (map[abi.SectorNumber]string, error)
func (*StorageMinerStruct) CreateBackup ¶
func (c *StorageMinerStruct) CreateBackup(ctx context.Context, fpath string) error
func (*StorageMinerStruct) DealsConsiderOfflineRetrievalDeals ¶
func (c *StorageMinerStruct) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOfflineStorageDeals ¶
func (c *StorageMinerStruct) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOnlineRetrievalDeals ¶
func (c *StorageMinerStruct) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOnlineStorageDeals ¶
func (c *StorageMinerStruct) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsImportData ¶
func (*StorageMinerStruct) DealsList ¶
func (c *StorageMinerStruct) DealsList(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerStruct) DealsPieceCidBlocklist ¶
func (*StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals ¶
func (c *StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOfflineStorageDeals ¶
func (c *StorageMinerStruct) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals ¶
func (c *StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOnlineStorageDeals ¶
func (c *StorageMinerStruct) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetPieceCidBlocklist ¶
func (*StorageMinerStruct) MarketCancelDataTransfer ¶
func (c *StorageMinerStruct) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerStruct) MarketDataTransferUpdates ¶
func (c *StorageMinerStruct) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*StorageMinerStruct) MarketGetAsk ¶
func (c *StorageMinerStruct) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
func (*StorageMinerStruct) MarketGetDealUpdates ¶
func (c *StorageMinerStruct) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
func (*StorageMinerStruct) MarketGetRetrievalAsk ¶
func (c *StorageMinerStruct) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
func (*StorageMinerStruct) MarketImportDealData ¶
func (*StorageMinerStruct) MarketListDataTransfers ¶
func (c *StorageMinerStruct) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*StorageMinerStruct) MarketListDeals ¶
func (c *StorageMinerStruct) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerStruct) MarketListIncompleteDeals ¶
func (c *StorageMinerStruct) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
func (*StorageMinerStruct) MarketListRetrievalDeals ¶
func (c *StorageMinerStruct) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
func (*StorageMinerStruct) MarketPendingDeals ¶
func (c *StorageMinerStruct) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
func (*StorageMinerStruct) MarketPublishPendingDeals ¶
func (c *StorageMinerStruct) MarketPublishPendingDeals(ctx context.Context) error
func (*StorageMinerStruct) MarketRestartDataTransfer ¶
func (c *StorageMinerStruct) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerStruct) MarketSetAsk ¶
func (c *StorageMinerStruct) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error
func (*StorageMinerStruct) MarketSetRetrievalAsk ¶
func (c *StorageMinerStruct) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
func (*StorageMinerStruct) MiningBase ¶
func (*StorageMinerStruct) PiecesGetCIDInfo ¶
func (c *StorageMinerStruct) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
func (*StorageMinerStruct) PiecesGetPieceInfo ¶
func (c *StorageMinerStruct) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
func (*StorageMinerStruct) PiecesListCidInfos ¶
func (*StorageMinerStruct) PiecesListPieces ¶
func (*StorageMinerStruct) PledgeSector ¶
func (*StorageMinerStruct) ReturnAddPiece ¶
func (*StorageMinerStruct) ReturnFetch ¶
func (*StorageMinerStruct) ReturnFinalizeSector ¶
func (*StorageMinerStruct) ReturnMoveStorage ¶
func (*StorageMinerStruct) ReturnReadPiece ¶
func (*StorageMinerStruct) ReturnReleaseUnsealed ¶
func (*StorageMinerStruct) ReturnSealCommit1 ¶
func (c *StorageMinerStruct) ReturnSealCommit1(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnSealCommit2 ¶
func (*StorageMinerStruct) ReturnSealPreCommit1 ¶
func (c *StorageMinerStruct) ReturnSealPreCommit1(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnSealPreCommit2 ¶
func (c *StorageMinerStruct) ReturnSealPreCommit2(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnUnsealPiece ¶
func (*StorageMinerStruct) SealingAbort ¶
func (*StorageMinerStruct) SealingSchedDiag ¶
func (c *StorageMinerStruct) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
func (*StorageMinerStruct) SectorGetExpectedSealDuration ¶
func (*StorageMinerStruct) SectorGetSealDelay ¶
func (*StorageMinerStruct) SectorRemove ¶
func (c *StorageMinerStruct) SectorRemove(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorSetExpectedSealDuration ¶
func (*StorageMinerStruct) SectorSetSealDelay ¶
func (*StorageMinerStruct) SectorStartSealing ¶
func (c *StorageMinerStruct) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorTerminate ¶
func (c *StorageMinerStruct) SectorTerminate(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorTerminateFlush ¶
func (*StorageMinerStruct) SectorTerminatePending ¶
func (*StorageMinerStruct) SectorsList ¶
func (c *StorageMinerStruct) SectorsList(ctx context.Context) ([]abi.SectorNumber, error)
List all staged sectors
func (*StorageMinerStruct) SectorsListInStates ¶
func (c *StorageMinerStruct) SectorsListInStates(ctx context.Context, states []api.SectorState) ([]abi.SectorNumber, error)
func (*StorageMinerStruct) SectorsRefs ¶
func (*StorageMinerStruct) SectorsStatus ¶
func (c *StorageMinerStruct) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
Get the status of a given sector by ID
func (*StorageMinerStruct) SectorsSummary ¶
func (c *StorageMinerStruct) SectorsSummary(ctx context.Context) (map[api.SectorState]int, error)
func (*StorageMinerStruct) SectorsUpdate ¶
func (c *StorageMinerStruct) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error
func (*StorageMinerStruct) StorageAddLocal ¶
func (c *StorageMinerStruct) StorageAddLocal(ctx context.Context, path string) error
func (*StorageMinerStruct) StorageAttach ¶
func (c *StorageMinerStruct) StorageAttach(ctx context.Context, si stores.StorageInfo, st fsutil.FsStat) error
func (*StorageMinerStruct) StorageBestAlloc ¶
func (c *StorageMinerStruct) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, pt storiface.PathType) ([]stores.StorageInfo, error)
func (*StorageMinerStruct) StorageDeclareSector ¶
func (*StorageMinerStruct) StorageDropSector ¶
func (c *StorageMinerStruct) StorageDropSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ft storiface.SectorFileType) error
func (*StorageMinerStruct) StorageFindSector ¶
func (c *StorageMinerStruct) StorageFindSector(ctx context.Context, si abi.SectorID, types storiface.SectorFileType, ssize abi.SectorSize, allowFetch bool) ([]stores.SectorStorageInfo, error)
func (*StorageMinerStruct) StorageInfo ¶
func (c *StorageMinerStruct) StorageInfo(ctx context.Context, id stores.ID) (stores.StorageInfo, error)
func (*StorageMinerStruct) StorageList ¶
func (*StorageMinerStruct) StorageLocal ¶
func (*StorageMinerStruct) StorageLock ¶
func (c *StorageMinerStruct) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) error
func (*StorageMinerStruct) StorageReportHealth ¶
func (c *StorageMinerStruct) StorageReportHealth(ctx context.Context, id stores.ID, report stores.HealthReport) error
func (*StorageMinerStruct) StorageStat ¶
func (*StorageMinerStruct) StorageTryLock ¶
func (c *StorageMinerStruct) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) (bool, error)
func (*StorageMinerStruct) WorkerConnect ¶
func (c *StorageMinerStruct) WorkerConnect(ctx context.Context, url string) error
func (*StorageMinerStruct) WorkerJobs ¶
func (*StorageMinerStruct) WorkerStats ¶
func (c *StorageMinerStruct) WorkerStats(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
type WalletStruct ¶
type WalletStruct struct {
Internal struct {
WalletNew func(context.Context, types.KeyType) (address.Address, error) `perm:"write"`
WalletHas func(context.Context, address.Address) (bool, error) `perm:"write"`
WalletList func(context.Context) ([]address.Address, error) `perm:"write"`
WalletSign func(context.Context, address.Address, []byte, api.MsgMeta) (*crypto.Signature, error) `perm:"sign"`
WalletExport func(context.Context, address.Address) (*types.KeyInfo, error) `perm:"admin"`
WalletImport func(context.Context, *types.KeyInfo) (address.Address, error) `perm:"admin"`
WalletDelete func(context.Context, address.Address) error `perm:"write"`
}
}
func (*WalletStruct) WalletDelete ¶
func (*WalletStruct) WalletExport ¶
func (*WalletStruct) WalletImport ¶
func (*WalletStruct) WalletList ¶
type WorkerStruct ¶
type WorkerStruct struct {
Internal struct {
Version func(context.Context) (api.Version, error) `perm:"admin"`
TaskTypes func(context.Context) (map[sealtasks.TaskType]struct{}, error) `perm:"admin"`
Paths func(context.Context) ([]stores.StoragePath, error) `perm:"admin"`
Info func(context.Context) (storiface.WorkerInfo, error) `perm:"admin"`
AddPiece func(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (storiface.CallID, error) `perm:"admin"`
SealPreCommit1 func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, pieces []abi.PieceInfo) (storiface.CallID, error) `perm:"admin"`
SealPreCommit2 func(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error) `perm:"admin"`
SealCommit1 func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (storiface.CallID, error) `perm:"admin"`
SealCommit2 func(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error) `perm:"admin"`
FinalizeSector func(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (storiface.CallID, error) `perm:"admin"`
ReleaseUnsealed func(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (storiface.CallID, error) `perm:"admin"`
MoveStorage func(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error) `perm:"admin"`
UnsealPiece func(context.Context, storage.SectorRef, storiface.UnpaddedByteIndex, abi.UnpaddedPieceSize, abi.SealRandomness, cid.Cid) (storiface.CallID, error) `perm:"admin"`
ReadPiece func(context.Context, io.Writer, storage.SectorRef, storiface.UnpaddedByteIndex, abi.UnpaddedPieceSize) (storiface.CallID, error) `perm:"admin"`
Fetch func(context.Context, storage.SectorRef, storiface.SectorFileType, storiface.PathType, storiface.AcquireMode) (storiface.CallID, error) `perm:"admin"`
TaskDisable func(ctx context.Context, tt sealtasks.TaskType) error `perm:"admin"`
TaskEnable func(ctx context.Context, tt sealtasks.TaskType) error `perm:"admin"`
Remove func(ctx context.Context, sector abi.SectorID) error `perm:"admin"`
StorageAddLocal func(ctx context.Context, path string) error `perm:"admin"`
SetEnabled func(ctx context.Context, enabled bool) error `perm:"admin"`
Enabled func(ctx context.Context) (bool, error) `perm:"admin"`
WaitQuiet func(ctx context.Context) error `perm:"admin"`
ProcessSession func(context.Context) (uuid.UUID, error) `perm:"admin"`
Session func(context.Context) (uuid.UUID, error) `perm:"admin"`
}
}
func (*WorkerStruct) AddPiece ¶
func (w *WorkerStruct) AddPiece(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (storiface.CallID, error)
func (*WorkerStruct) Fetch ¶
func (w *WorkerStruct) Fetch(ctx context.Context, id storage.SectorRef, fileType storiface.SectorFileType, ptype storiface.PathType, am storiface.AcquireMode) (storiface.CallID, error)
func (*WorkerStruct) FinalizeSector ¶
func (*WorkerStruct) Info ¶
func (w *WorkerStruct) Info(ctx context.Context) (storiface.WorkerInfo, error)
func (*WorkerStruct) MoveStorage ¶
func (w *WorkerStruct) MoveStorage(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error)
func (*WorkerStruct) Paths ¶
func (w *WorkerStruct) Paths(ctx context.Context) ([]stores.StoragePath, error)
func (*WorkerStruct) ProcessSession ¶
func (*WorkerStruct) ReadPiece ¶
func (w *WorkerStruct) ReadPiece(ctx context.Context, sink io.Writer, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) (storiface.CallID, error)
func (*WorkerStruct) ReleaseUnsealed ¶
func (*WorkerStruct) SealCommit1 ¶
func (w *WorkerStruct) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (storiface.CallID, error)
func (*WorkerStruct) SealCommit2 ¶
func (w *WorkerStruct) SealCommit2(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error)
func (*WorkerStruct) SealPreCommit1 ¶
func (*WorkerStruct) SealPreCommit2 ¶
func (w *WorkerStruct) SealPreCommit2(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error)
func (*WorkerStruct) SetEnabled ¶
func (w *WorkerStruct) SetEnabled(ctx context.Context, enabled bool) error
func (*WorkerStruct) StorageAddLocal ¶
func (w *WorkerStruct) StorageAddLocal(ctx context.Context, path string) error
func (*WorkerStruct) TaskDisable ¶
func (*WorkerStruct) TaskEnable ¶
func (*WorkerStruct) UnsealPiece ¶
func (w *WorkerStruct) UnsealPiece(ctx context.Context, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize, ticket abi.SealRandomness, c cid.Cid) (storiface.CallID, error)
Click to show internal directories.
Click to hide internal directories.