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) 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) 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) 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) 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) 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) 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) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
- func (c *FullNodeStruct) CreateBackup(ctx context.Context, fpath string) 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) MarketAddBalance(ctx context.Context, wallet address.Address, addr address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MarketGetReserved(ctx context.Context, addr address.Address) (types.BigInt, error)
- func (c *FullNodeStruct) MarketReleaseFunds(ctx context.Context, addr address.Address, amt types.BigInt) error
- func (c *FullNodeStruct) MarketReserveFunds(ctx context.Context, wallet address.Address, addr address.Address, ...) (cid.Cid, error)
- func (c *FullNodeStruct) MarketWithdraw(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, 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) 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) StateCompute(ctx context.Context, height abi.ChainEpoch, msgs []*types.Message, ...) (*api.ComputeStateOutput, error)
- func (c *FullNodeStruct) StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, ...) (api.DealCollateralBounds, error)
- func (c *FullNodeStruct) StateDecodeParams(ctx context.Context, toAddr address.Address, method abi.MethodNum, ...) (interface{}, 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) StateListActors(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) StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, error)
- func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)
- func (c *FullNodeStruct) StateMarketParticipants(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketBalance, 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) StateMinerAvailableBalance(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (types.BigInt, 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) StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)
- func (c *FullNodeStruct) StateMinerInitialPledgeCollateral(ctx context.Context, maddr address.Address, pci miner.SectorPreCommitInfo, ...) (types.BigInt, 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) StateMinerPreCommitDepositForPower(ctx context.Context, maddr address.Address, pci miner.SectorPreCommitInfo, ...) (types.BigInt, 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) 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) 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) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)
- func (c *FullNodeStruct) StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
- func (c *FullNodeStruct) StateVerifiedRegistryRootKey(ctx context.Context, tsk types.TipSetKey) (address.Address, error)
- func (c *FullNodeStruct) StateVerifierStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, 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) StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, ...) (api.DealCollateralBounds, 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) StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, 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) StateSearchMsg(ctx context.Context, msg cid.Cid) (*api.MsgLookup, error)
- func (g GatewayStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error)
- func (g GatewayStruct) StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, 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) DealsConsiderUnverifiedStorageDeals(ctx context.Context) (bool, error)
- func (c *StorageMinerStruct) DealsConsiderVerifiedStorageDeals(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) DealsSetConsiderUnverifiedStorageDeals(ctx context.Context, b bool) error
- func (c *StorageMinerStruct) DealsSetConsiderVerifiedStorageDeals(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) SectorMarkForUpgrade(ctx context.Context, number abi.SectorNumber) 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
func PermissionedWalletAPI ¶ added in v0.9.1
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"`
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 ¶ added in v0.4.0
func (c *CommonStruct) Closing(ctx context.Context) (<-chan struct{}, error)
func (*CommonStruct) LogList ¶ added in v0.2.8
func (c *CommonStruct) LogList(ctx context.Context) ([]string, error)
func (*CommonStruct) LogSetLevel ¶ added in v0.2.8
func (c *CommonStruct) LogSetLevel(ctx context.Context, group, level string) error
func (*CommonStruct) NetAddrsListen ¶
func (*CommonStruct) NetAgentVersion ¶ added in v0.6.0
func (*CommonStruct) NetAutoNatStatus ¶ added in v0.5.0
func (*CommonStruct) NetBandwidthStats ¶ added in v0.5.9
func (*CommonStruct) NetBandwidthStatsByPeer ¶ added in v0.5.9
func (*CommonStruct) NetBandwidthStatsByProtocol ¶ added in v0.5.9
func (*CommonStruct) NetBlockAdd ¶ added in v1.2.2
func (c *CommonStruct) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error
func (*CommonStruct) NetBlockList ¶ added in v1.2.2
func (c *CommonStruct) NetBlockList(ctx context.Context) (api.NetBlockList, error)
func (*CommonStruct) NetBlockRemove ¶ added in v1.2.2
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 ¶ added in v0.2.9
func (*CommonStruct) NetPeerInfo ¶ added in v1.5.1
func (c *CommonStruct) NetPeerInfo(ctx context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)
func (*CommonStruct) NetPubsubScores ¶ added in v0.3.1
func (c *CommonStruct) NetPubsubScores(ctx context.Context) ([]api.PubsubScore, error)
func (*CommonStruct) Shutdown ¶ added in v0.3.2
func (c *CommonStruct) Shutdown(ctx context.Context) 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"`
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"`
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"`
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"`
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"`
StateMinerAvailableBalance func(context.Context, address.Address, types.TipSetKey) (types.BigInt, 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"`
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"`
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"`
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"`
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"`
MarketAddBalance func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (cid.Cid, error) `perm:"sign"`
MarketGetReserved func(ctx context.Context, addr address.Address) (types.BigInt, error) `perm:"sign"`
MarketReserveFunds func(ctx context.Context, wallet address.Address, addr address.Address, amt types.BigInt) (cid.Cid, error) `perm:"sign"`
MarketReleaseFunds func(ctx context.Context, addr address.Address, amt types.BigInt) error `perm:"sign"`
MarketWithdraw func(ctx context.Context, wallet, addr address.Address, amt types.BigInt) (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"`
CreateBackup func(ctx context.Context, fpath string) error `perm:"admin"`
}
}
FullNodeStruct implements API passing calls to user-provided function values.
func (*FullNodeStruct) BeaconGetEntry ¶ added in v0.5.0
func (c *FullNodeStruct) BeaconGetEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)
func (*FullNodeStruct) ChainDeleteObj ¶ added in v0.7.2
func (c *FullNodeStruct) ChainDeleteObj(ctx context.Context, obj cid.Cid) error
func (*FullNodeStruct) ChainExport ¶ added in v0.2.6
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 ¶ added in v0.1.6
func (*FullNodeStruct) ChainGetNode ¶ added in v0.1.5
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 ¶ added in v0.2.5
func (c *FullNodeStruct) ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)
func (*FullNodeStruct) ChainGetRandomnessFromBeacon ¶ added in v0.5.0
func (c *FullNodeStruct) ChainGetRandomnessFromBeacon(ctx context.Context, tsk types.TipSetKey, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)
func (*FullNodeStruct) ChainGetRandomnessFromTickets ¶ added in v0.5.0
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 ¶ added in v0.2.8
func (c *FullNodeStruct) ChainHasObj(ctx context.Context, o cid.Cid) (bool, error)
func (*FullNodeStruct) ChainNotify ¶
func (c *FullNodeStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
func (*FullNodeStruct) ChainReadObj ¶
func (c *FullNodeStruct) ChainReadObj(ctx context.Context, obj cid.Cid) ([]byte, error)
func (*FullNodeStruct) ChainSetHead ¶
func (*FullNodeStruct) ChainStatObj ¶ added in v0.3.0
func (*FullNodeStruct) ChainTipSetWeight ¶
func (*FullNodeStruct) ClientCalcCommP ¶ added in v0.3.0
func (*FullNodeStruct) ClientCancelDataTransfer ¶ added in v1.1.3
func (c *FullNodeStruct) ClientCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*FullNodeStruct) ClientDataTransferUpdates ¶ added in v0.5.0
func (c *FullNodeStruct) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*FullNodeStruct) ClientDealPieceCID ¶ added in v1.1.3
func (c *FullNodeStruct) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCIDSize, error)
func (*FullNodeStruct) ClientDealSize ¶ added in v0.5.0
func (*FullNodeStruct) ClientFindData ¶
func (c *FullNodeStruct) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)
func (*FullNodeStruct) ClientGenCar ¶ added in v0.3.0
func (*FullNodeStruct) ClientGetDealInfo ¶
func (*FullNodeStruct) ClientGetDealStatus ¶ added in v1.1.1
func (*FullNodeStruct) ClientGetDealUpdates ¶ added in v0.5.5
func (*FullNodeStruct) ClientHasLocal ¶
func (c *FullNodeStruct) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error)
func (*FullNodeStruct) ClientImport ¶
func (*FullNodeStruct) ClientListDataTransfers ¶ added in v0.5.0
func (c *FullNodeStruct) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*FullNodeStruct) ClientListDeals ¶
func (*FullNodeStruct) ClientListImports ¶
func (*FullNodeStruct) ClientMinerQueryOffer ¶ added in v0.4.0
func (c *FullNodeStruct) ClientMinerQueryOffer(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)
func (*FullNodeStruct) ClientQueryAsk ¶
func (c *FullNodeStruct) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)
func (*FullNodeStruct) ClientRemoveImport ¶ added in v0.5.0
func (c *FullNodeStruct) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error
func (*FullNodeStruct) ClientRestartDataTransfer ¶ added in v0.10.1
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) ClientRetrieveTryRestartInsufficientFunds ¶ added in v0.6.0
func (c *FullNodeStruct) ClientRetrieveTryRestartInsufficientFunds(ctx context.Context, paymentChannel address.Address) error
func (*FullNodeStruct) ClientRetrieveWithEvents ¶ added in v0.5.0
func (c *FullNodeStruct) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)
func (*FullNodeStruct) ClientStartDeal ¶
func (c *FullNodeStruct) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
func (*FullNodeStruct) CreateBackup ¶ added in v0.9.0
func (c *FullNodeStruct) CreateBackup(ctx context.Context, fpath string) error
func (*FullNodeStruct) GasEstimateFeeCap ¶ added in v0.5.0
func (*FullNodeStruct) GasEstimateGasLimit ¶ added in v0.5.0
func (*FullNodeStruct) GasEstimateGasPremium ¶ added in v0.5.0
func (*FullNodeStruct) GasEstimateMessageGas ¶ added in v0.5.0
func (*FullNodeStruct) MarketAddBalance ¶ added in v1.4.1
func (*FullNodeStruct) MarketGetReserved ¶ added in v1.4.1
func (*FullNodeStruct) MarketReleaseFunds ¶ added in v1.1.3
func (*FullNodeStruct) MarketReserveFunds ¶ added in v1.1.3
func (*FullNodeStruct) MarketWithdraw ¶ added in v1.2.3
func (*FullNodeStruct) MinerCreateBlock ¶
func (c *FullNodeStruct) MinerCreateBlock(ctx context.Context, bt *api.BlockTemplate) (*types.BlockMsg, error)
func (*FullNodeStruct) MinerGetBaseInfo ¶ added in v0.3.0
func (c *FullNodeStruct) MinerGetBaseInfo(ctx context.Context, maddr address.Address, epoch abi.ChainEpoch, tsk types.TipSetKey) (*api.MiningBaseInfo, error)
func (*FullNodeStruct) MpoolBatchPush ¶ added in v1.1.1
func (c *FullNodeStruct) MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
func (*FullNodeStruct) MpoolBatchPushMessage ¶ added in v1.1.1
func (c *FullNodeStruct) MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error)
func (*FullNodeStruct) MpoolBatchPushUntrusted ¶ added in v1.1.1
func (c *FullNodeStruct) MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
func (*FullNodeStruct) MpoolClear ¶ added in v0.5.0
func (c *FullNodeStruct) MpoolClear(ctx context.Context, local bool) error
func (*FullNodeStruct) MpoolGetConfig ¶ added in v0.5.0
func (c *FullNodeStruct) MpoolGetConfig(ctx context.Context) (*types.MpoolConfig, error)
func (*FullNodeStruct) MpoolGetNonce ¶
func (c *FullNodeStruct) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)
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 ¶ added in v0.9.0
func (c *FullNodeStruct) MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
func (*FullNodeStruct) MpoolSelect ¶ added in v0.5.0
func (c *FullNodeStruct) MpoolSelect(ctx context.Context, tsk types.TipSetKey, tq float64) ([]*types.SignedMessage, error)
func (*FullNodeStruct) MpoolSetConfig ¶ added in v0.5.0
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 ¶ added in v0.7.0
func (*FullNodeStruct) MsigAddCancel ¶ added in v0.7.0
func (*FullNodeStruct) MsigAddPropose ¶ added in v0.7.0
func (c *FullNodeStruct) MsigAddPropose(ctx context.Context, msig address.Address, src address.Address, newAdd address.Address, inc bool) (cid.Cid, error)
func (*FullNodeStruct) MsigApprove ¶ added in v0.3.0
func (c *FullNodeStruct) MsigApprove(ctx context.Context, msig address.Address, txID uint64, signer address.Address) (cid.Cid, error)
func (*FullNodeStruct) MsigApproveTxnHash ¶ added in v0.10.0
func (*FullNodeStruct) MsigCancel ¶ added in v0.3.0
func (*FullNodeStruct) MsigCreate ¶ added in v0.3.0
func (*FullNodeStruct) MsigGetAvailableBalance ¶ added in v0.2.8
func (*FullNodeStruct) MsigGetPending ¶ added in v1.4.2
func (c *FullNodeStruct) MsigGetPending(ctx context.Context, a address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
func (*FullNodeStruct) MsigGetVested ¶ added in v0.7.0
func (*FullNodeStruct) MsigGetVestingSchedule ¶ added in v0.9.1
func (c *FullNodeStruct) MsigGetVestingSchedule(ctx context.Context, a address.Address, tsk types.TipSetKey) (api.MsigVesting, error)
func (*FullNodeStruct) MsigPropose ¶ added in v0.3.0
func (*FullNodeStruct) MsigRemoveSigner ¶ added in v0.10.0
func (c *FullNodeStruct) MsigRemoveSigner(ctx context.Context, msig address.Address, proposer address.Address, toRemove address.Address, decrease bool) (cid.Cid, error)
func (*FullNodeStruct) MsigSwapApprove ¶ added in v0.5.0
func (c *FullNodeStruct) MsigSwapApprove(ctx context.Context, msig address.Address, src address.Address, txID uint64, proposer address.Address, oldAdd address.Address, newAdd address.Address) (cid.Cid, error)
func (*FullNodeStruct) MsigSwapCancel ¶ added in v0.5.0
func (c *FullNodeStruct) MsigSwapCancel(ctx context.Context, msig address.Address, src address.Address, txID uint64, oldAdd address.Address, newAdd address.Address) (cid.Cid, error)
func (*FullNodeStruct) MsigSwapPropose ¶ added in v0.5.0
func (c *FullNodeStruct) MsigSwapPropose(ctx context.Context, msig address.Address, src address.Address, oldAdd address.Address, newAdd address.Address) (cid.Cid, error)
func (*FullNodeStruct) PaychAllocateLane ¶
func (c *FullNodeStruct) PaychAllocateLane(ctx context.Context, ch address.Address) (uint64, error)
func (*FullNodeStruct) PaychAvailableFunds ¶ added in v0.6.0
func (c *FullNodeStruct) PaychAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) PaychAvailableFundsByFromTo ¶ added in v0.6.0
func (c *FullNodeStruct) PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)
func (*FullNodeStruct) PaychCollect ¶ added in v0.5.0
func (c *FullNodeStruct) PaychCollect(ctx context.Context, a address.Address) (cid.Cid, error)
func (*FullNodeStruct) PaychGet ¶
func (c *FullNodeStruct) PaychGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)
func (*FullNodeStruct) PaychGetWaitReady ¶ added in v0.5.0
func (c *FullNodeStruct) PaychGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error)
func (*FullNodeStruct) PaychList ¶
func (c *FullNodeStruct) PaychList(ctx context.Context) ([]address.Address, error)
func (*FullNodeStruct) PaychNewPayment ¶
func (c *FullNodeStruct) PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []api.VoucherSpec) (*api.PaymentInfo, error)
func (*FullNodeStruct) PaychSettle ¶ added in v0.5.0
func (c *FullNodeStruct) PaychSettle(ctx context.Context, a address.Address) (cid.Cid, error)
func (*FullNodeStruct) PaychStatus ¶
func (c *FullNodeStruct) PaychStatus(ctx context.Context, pch address.Address) (*api.PaychStatus, error)
func (*FullNodeStruct) PaychVoucherAdd ¶
func (*FullNodeStruct) PaychVoucherCheckSpendable ¶
func (c *FullNodeStruct) PaychVoucherCheckSpendable(ctx context.Context, addr address.Address, sv *paych.SignedVoucher, secret []byte, proof []byte) (bool, error)
func (*FullNodeStruct) PaychVoucherCheckValid ¶
func (c *FullNodeStruct) PaychVoucherCheckValid(ctx context.Context, addr address.Address, sv *paych.SignedVoucher) error
func (*FullNodeStruct) PaychVoucherCreate ¶
func (c *FullNodeStruct) PaychVoucherCreate(ctx context.Context, pch address.Address, amt types.BigInt, lane uint64) (*api.VoucherCreateResult, error)
func (*FullNodeStruct) PaychVoucherList ¶
func (c *FullNodeStruct) PaychVoucherList(ctx context.Context, pch address.Address) ([]*paych.SignedVoucher, error)
func (*FullNodeStruct) PaychVoucherSubmit ¶
func (c *FullNodeStruct) PaychVoucherSubmit(ctx context.Context, ch address.Address, sv *paych.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error)
func (*FullNodeStruct) StateAccountKey ¶ added in v0.3.0
func (*FullNodeStruct) StateAllMinerFaults ¶ added in v0.3.1
func (c *FullNodeStruct) StateAllMinerFaults(ctx context.Context, cutoff abi.ChainEpoch, endTsk types.TipSetKey) ([]*api.Fault, 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 ¶ added in v0.5.0
func (c *FullNodeStruct) StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)
func (*FullNodeStruct) StateCompute ¶ added in v0.2.5
func (c *FullNodeStruct) StateCompute(ctx context.Context, height abi.ChainEpoch, msgs []*types.Message, tsk types.TipSetKey) (*api.ComputeStateOutput, error)
func (*FullNodeStruct) StateDealProviderCollateralBounds ¶ added in v0.5.0
func (c *FullNodeStruct) StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (api.DealCollateralBounds, error)
func (*FullNodeStruct) StateDecodeParams ¶ added in v1.1.3
func (*FullNodeStruct) StateGetActor ¶
func (*FullNodeStruct) StateGetReceipt ¶
func (c *FullNodeStruct) StateGetReceipt(ctx context.Context, msg cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
func (*FullNodeStruct) StateListActors ¶
func (*FullNodeStruct) StateListMessages ¶ added in v0.1.6
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) StateMarketBalance ¶
func (c *FullNodeStruct) StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, error)
func (*FullNodeStruct) StateMarketDeals ¶
func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)
func (*FullNodeStruct) StateMarketParticipants ¶
func (c *FullNodeStruct) StateMarketParticipants(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketBalance, error)
func (*FullNodeStruct) StateMarketStorageDeal ¶
func (c *FullNodeStruct) StateMarketStorageDeal(ctx context.Context, dealid abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
func (*FullNodeStruct) StateMinerActiveSectors ¶ added in v0.5.0
func (c *FullNodeStruct) StateMinerActiveSectors(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
func (*FullNodeStruct) StateMinerAvailableBalance ¶ added in v0.3.0
func (*FullNodeStruct) StateMinerDeadlines ¶ added in v0.3.0
func (*FullNodeStruct) StateMinerFaults ¶ added in v0.2.8
func (*FullNodeStruct) StateMinerInfo ¶ added in v0.3.0
func (*FullNodeStruct) StateMinerInitialPledgeCollateral ¶ added in v0.3.0
func (c *FullNodeStruct) StateMinerInitialPledgeCollateral(ctx context.Context, maddr address.Address, pci miner.SectorPreCommitInfo, tsk types.TipSetKey) (types.BigInt, error)
func (*FullNodeStruct) StateMinerPartitions ¶ added in v0.5.0
func (*FullNodeStruct) StateMinerPower ¶
func (c *FullNodeStruct) StateMinerPower(ctx context.Context, a address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
func (*FullNodeStruct) StateMinerPreCommitDepositForPower ¶ added in v0.5.0
func (c *FullNodeStruct) StateMinerPreCommitDepositForPower(ctx context.Context, maddr address.Address, pci miner.SectorPreCommitInfo, tsk types.TipSetKey) (types.BigInt, error)
func (*FullNodeStruct) StateMinerProvingDeadline ¶ added in v0.3.0
func (*FullNodeStruct) StateMinerRecoveries ¶ added in v0.3.1
func (*FullNodeStruct) StateMinerSectorAllocated ¶ added in v1.1.3
func (c *FullNodeStruct) StateMinerSectorAllocated(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error)
func (*FullNodeStruct) StateMinerSectorCount ¶ added in v0.1.5
func (c *FullNodeStruct) StateMinerSectorCount(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MinerSectors, error)
func (*FullNodeStruct) StateMinerSectors ¶
func (c *FullNodeStruct) StateMinerSectors(ctx context.Context, addr address.Address, sectorNos *bitfield.BitField, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
func (*FullNodeStruct) StateNetworkName ¶ added in v0.3.0
func (c *FullNodeStruct) StateNetworkName(ctx context.Context) (dtypes.NetworkName, error)
func (*FullNodeStruct) StateNetworkVersion ¶ added in v0.7.2
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) StateSearchMsg ¶ added in v0.3.0
func (*FullNodeStruct) StateSearchMsgLimited ¶ added in v1.4.1
func (c *FullNodeStruct) StateSearchMsgLimited(ctx context.Context, msgc cid.Cid, limit abi.ChainEpoch) (*api.MsgLookup, error)
func (*FullNodeStruct) StateSectorExpiration ¶ added in v0.5.0
func (c *FullNodeStruct) StateSectorExpiration(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorExpiration, error)
func (*FullNodeStruct) StateSectorGetInfo ¶ added in v0.3.1
func (c *FullNodeStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
func (*FullNodeStruct) StateSectorPartition ¶ added in v0.5.0
func (c *FullNodeStruct) StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok types.TipSetKey) (*miner.SectorLocation, error)
func (*FullNodeStruct) StateSectorPreCommitInfo ¶ added in v0.3.0
func (c *FullNodeStruct) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error)
func (*FullNodeStruct) StateVMCirculatingSupplyInternal ¶ added in v0.10.1
func (c *FullNodeStruct) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)
func (*FullNodeStruct) StateVerifiedClientStatus ¶ added in v0.5.0
func (c *FullNodeStruct) StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
func (*FullNodeStruct) StateVerifiedRegistryRootKey ¶ added in v0.9.0
func (*FullNodeStruct) StateVerifierStatus ¶ added in v0.9.0
func (c *FullNodeStruct) StateVerifierStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
func (*FullNodeStruct) StateWaitMsg ¶
func (*FullNodeStruct) StateWaitMsgLimited ¶ added in v0.9.1
func (c *FullNodeStruct) StateWaitMsgLimited(ctx context.Context, msgc cid.Cid, confidence uint64, limit abi.ChainEpoch) (*api.MsgLookup, error)
func (*FullNodeStruct) SyncCheckBad ¶ added in v0.2.8
func (c *FullNodeStruct) SyncCheckBad(ctx context.Context, bcid cid.Cid) (string, error)
func (*FullNodeStruct) SyncCheckpoint ¶ added in v0.6.2
func (*FullNodeStruct) SyncIncomingBlocks ¶
func (c *FullNodeStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error)
func (*FullNodeStruct) SyncMarkBad ¶ added in v0.1.6
func (c *FullNodeStruct) SyncMarkBad(ctx context.Context, bcid cid.Cid) error
func (*FullNodeStruct) SyncSubmitBlock ¶
func (*FullNodeStruct) SyncUnmarkAllBad ¶ added in v0.10.0
func (c *FullNodeStruct) SyncUnmarkAllBad(ctx context.Context) error
func (*FullNodeStruct) SyncUnmarkBad ¶ added in v0.6.2
func (c *FullNodeStruct) SyncUnmarkBad(ctx context.Context, bcid cid.Cid) error
func (*FullNodeStruct) SyncValidateTipset ¶ added in v0.8.1
func (*FullNodeStruct) WalletBalance ¶
func (*FullNodeStruct) WalletDefaultAddress ¶
func (c *FullNodeStruct) WalletDefaultAddress(ctx context.Context) (address.Address, error)
func (*FullNodeStruct) WalletDelete ¶ added in v0.4.0
func (c *FullNodeStruct) WalletDelete(ctx context.Context, addr address.Address) error
func (*FullNodeStruct) WalletExport ¶
func (*FullNodeStruct) WalletHas ¶
func (c *FullNodeStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)
func (*FullNodeStruct) WalletImport ¶
func (*FullNodeStruct) WalletList ¶
func (c *FullNodeStruct) WalletList(ctx context.Context) ([]address.Address, error)
func (*FullNodeStruct) WalletSetDefault ¶
func (c *FullNodeStruct) WalletSetDefault(ctx context.Context, a address.Address) error
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 ¶ added in v0.8.1
func (c *FullNodeStruct) WalletValidateAddress(ctx context.Context, str string) (address.Address, error)
func (*FullNodeStruct) WalletVerify ¶ added in v0.2.10
type GatewayStruct ¶ added in v0.9.1
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 ¶ added in v1.1.1
func (g GatewayStruct) ChainGetBlockMessages(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)
func (GatewayStruct) ChainGetMessage ¶ added in v1.1.1
func (GatewayStruct) ChainGetTipSet ¶ added in v0.9.1
func (GatewayStruct) ChainGetTipSetByHeight ¶ added in v0.9.1
func (g GatewayStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
func (GatewayStruct) ChainHasObj ¶ added in v1.0.0
func (g GatewayStruct) ChainHasObj(ctx context.Context, c cid.Cid) (bool, error)
func (GatewayStruct) ChainNotify ¶ added in v1.1.1
func (g GatewayStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)
func (GatewayStruct) ChainReadObj ¶ added in v1.0.0
func (g GatewayStruct) ChainReadObj(ctx context.Context, c cid.Cid) ([]byte, error)
func (GatewayStruct) GasEstimateMessageGas ¶ added in v0.9.1
func (GatewayStruct) MpoolPush ¶ added in v0.9.1
func (g GatewayStruct) MpoolPush(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)
func (GatewayStruct) MsigGetAvailableBalance ¶ added in v0.9.1
func (GatewayStruct) MsigGetPending ¶ added in v1.4.2
func (g GatewayStruct) MsigGetPending(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)
func (GatewayStruct) MsigGetVested ¶ added in v0.9.1
func (GatewayStruct) StateAccountKey ¶ added in v0.9.1
func (GatewayStruct) StateDealProviderCollateralBounds ¶ added in v1.1.1
func (g GatewayStruct) StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (api.DealCollateralBounds, error)
func (GatewayStruct) StateGetActor ¶ added in v0.9.1
func (GatewayStruct) StateGetReceipt ¶ added in v1.1.1
func (g GatewayStruct) StateGetReceipt(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
func (GatewayStruct) StateListMiners ¶ added in v1.1.1
func (GatewayStruct) StateLookupID ¶ added in v0.9.1
func (GatewayStruct) StateMarketBalance ¶ added in v1.1.1
func (g GatewayStruct) StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, error)
func (GatewayStruct) StateMarketStorageDeal ¶ added in v1.1.1
func (g GatewayStruct) StateMarketStorageDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
func (GatewayStruct) StateMinerInfo ¶ added in v1.1.1
func (GatewayStruct) StateMinerPower ¶ added in v1.1.1
func (g GatewayStruct) StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.MinerPower, error)
func (GatewayStruct) StateMinerProvingDeadline ¶ added in v1.1.1
func (GatewayStruct) StateNetworkVersion ¶ added in v1.1.1
func (GatewayStruct) StateReadState ¶ added in v1.4.2
func (g GatewayStruct) StateReadState(ctx context.Context, addr address.Address, ts types.TipSetKey) (*api.ActorState, error)
func (GatewayStruct) StateSearchMsg ¶ added in v1.4.1
func (GatewayStruct) StateSectorGetInfo ¶ added in v1.2.2
func (g GatewayStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
func (GatewayStruct) StateVerifiedClientStatus ¶ added in v1.1.1
func (g GatewayStruct) StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
func (GatewayStruct) StateWaitMsg ¶ added in v0.9.1
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"`
SectorMarkForUpgrade func(ctx context.Context, id abi.SectorNumber) 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"`
DealsConsiderVerifiedStorageDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderVerifiedStorageDeals func(context.Context, bool) error `perm:"admin"`
DealsConsiderUnverifiedStorageDeals func(context.Context) (bool, error) `perm:"read"`
DealsSetConsiderUnverifiedStorageDeals 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 (c *StorageMinerStruct) ActorAddress(ctx context.Context) (address.Address, error)
func (*StorageMinerStruct) ActorAddressConfig ¶ added in v1.2.3
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 ¶ added in v1.2.2
func (c *StorageMinerStruct) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, expensive bool) (map[abi.SectorNumber]string, error)
func (*StorageMinerStruct) CreateBackup ¶ added in v0.9.0
func (c *StorageMinerStruct) CreateBackup(ctx context.Context, fpath string) error
func (*StorageMinerStruct) DealsConsiderOfflineRetrievalDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOfflineStorageDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOnlineRetrievalDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderOnlineStorageDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderUnverifiedStorageDeals ¶ added in v1.2.3
func (c *StorageMinerStruct) DealsConsiderUnverifiedStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsConsiderVerifiedStorageDeals ¶ added in v1.2.3
func (c *StorageMinerStruct) DealsConsiderVerifiedStorageDeals(ctx context.Context) (bool, error)
func (*StorageMinerStruct) DealsImportData ¶ added in v0.3.0
func (c *StorageMinerStruct) DealsImportData(ctx context.Context, dealPropCid cid.Cid, file string) error
func (*StorageMinerStruct) DealsList ¶ added in v0.3.0
func (c *StorageMinerStruct) DealsList(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerStruct) DealsPieceCidBlocklist ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOfflineStorageDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderOnlineStorageDeals ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderUnverifiedStorageDeals ¶ added in v1.2.3
func (c *StorageMinerStruct) DealsSetConsiderUnverifiedStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetConsiderVerifiedStorageDeals ¶ added in v1.2.3
func (c *StorageMinerStruct) DealsSetConsiderVerifiedStorageDeals(ctx context.Context, b bool) error
func (*StorageMinerStruct) DealsSetPieceCidBlocklist ¶ added in v0.4.1
func (c *StorageMinerStruct) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error
func (*StorageMinerStruct) MarketCancelDataTransfer ¶ added in v1.1.3
func (c *StorageMinerStruct) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerStruct) MarketDataTransferUpdates ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
func (*StorageMinerStruct) MarketGetAsk ¶ added in v0.4.0
func (c *StorageMinerStruct) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)
func (*StorageMinerStruct) MarketGetDealUpdates ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)
func (*StorageMinerStruct) MarketGetRetrievalAsk ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)
func (*StorageMinerStruct) MarketImportDealData ¶ added in v0.3.0
func (c *StorageMinerStruct) MarketImportDealData(ctx context.Context, propcid cid.Cid, path string) error
func (*StorageMinerStruct) MarketListDataTransfers ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
func (*StorageMinerStruct) MarketListDeals ¶ added in v0.3.0
func (c *StorageMinerStruct) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)
func (*StorageMinerStruct) MarketListIncompleteDeals ¶ added in v0.3.0
func (c *StorageMinerStruct) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)
func (*StorageMinerStruct) MarketListRetrievalDeals ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)
func (*StorageMinerStruct) MarketPendingDeals ¶ added in v1.4.2
func (c *StorageMinerStruct) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)
func (*StorageMinerStruct) MarketPublishPendingDeals ¶ added in v1.4.2
func (c *StorageMinerStruct) MarketPublishPendingDeals(ctx context.Context) error
func (*StorageMinerStruct) MarketRestartDataTransfer ¶ added in v1.1.3
func (c *StorageMinerStruct) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error
func (*StorageMinerStruct) MarketSetAsk ¶ added in v0.4.0
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 ¶ added in v0.5.0
func (c *StorageMinerStruct) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error
func (*StorageMinerStruct) MiningBase ¶ added in v0.3.0
func (*StorageMinerStruct) PiecesGetCIDInfo ¶ added in v0.5.0
func (c *StorageMinerStruct) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)
func (*StorageMinerStruct) PiecesGetPieceInfo ¶ added in v0.5.0
func (c *StorageMinerStruct) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)
func (*StorageMinerStruct) PiecesListCidInfos ¶ added in v0.5.0
func (c *StorageMinerStruct) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerStruct) PiecesListPieces ¶ added in v0.5.0
func (c *StorageMinerStruct) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)
func (*StorageMinerStruct) PledgeSector ¶
func (*StorageMinerStruct) ReturnAddPiece ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnFetch ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnFinalizeSector ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnMoveStorage ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnReadPiece ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnReleaseUnsealed ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnSealCommit1 ¶ added in v1.1.3
func (c *StorageMinerStruct) ReturnSealCommit1(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnSealCommit2 ¶ added in v1.1.3
func (*StorageMinerStruct) ReturnSealPreCommit1 ¶ added in v1.1.3
func (c *StorageMinerStruct) ReturnSealPreCommit1(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnSealPreCommit2 ¶ added in v1.1.3
func (c *StorageMinerStruct) ReturnSealPreCommit2(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, err *storiface.CallError) error
func (*StorageMinerStruct) ReturnUnsealPiece ¶ added in v1.1.3
func (*StorageMinerStruct) SealingAbort ¶ added in v1.1.3
func (*StorageMinerStruct) SealingSchedDiag ¶ added in v0.5.0
func (c *StorageMinerStruct) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)
func (*StorageMinerStruct) SectorGetExpectedSealDuration ¶ added in v0.5.0
func (*StorageMinerStruct) SectorGetSealDelay ¶ added in v0.5.0
func (*StorageMinerStruct) SectorMarkForUpgrade ¶ added in v0.5.0
func (c *StorageMinerStruct) SectorMarkForUpgrade(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorRemove ¶ added in v0.4.1
func (c *StorageMinerStruct) SectorRemove(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorSetExpectedSealDuration ¶ added in v0.5.0
func (*StorageMinerStruct) SectorSetSealDelay ¶ added in v0.5.0
func (*StorageMinerStruct) SectorStartSealing ¶ added in v0.5.0
func (c *StorageMinerStruct) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorTerminate ¶ added in v1.4.1
func (c *StorageMinerStruct) SectorTerminate(ctx context.Context, number abi.SectorNumber) error
func (*StorageMinerStruct) SectorTerminateFlush ¶ added in v1.4.1
func (c *StorageMinerStruct) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)
func (*StorageMinerStruct) SectorTerminatePending ¶ added in v1.4.1
func (*StorageMinerStruct) SectorsList ¶
func (c *StorageMinerStruct) SectorsList(ctx context.Context) ([]abi.SectorNumber, error)
List all staged sectors
func (*StorageMinerStruct) SectorsListInStates ¶ added in v1.2.3
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 ¶ added in v1.2.3
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 ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageAddLocal(ctx context.Context, path string) error
func (*StorageMinerStruct) StorageAttach ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageAttach(ctx context.Context, si stores.StorageInfo, st fsutil.FsStat) error
func (*StorageMinerStruct) StorageBestAlloc ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, pt storiface.PathType) ([]stores.StorageInfo, error)
func (*StorageMinerStruct) StorageDeclareSector ¶ added in v0.3.0
func (*StorageMinerStruct) StorageDropSector ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageDropSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ft storiface.SectorFileType) error
func (*StorageMinerStruct) StorageFindSector ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageFindSector(ctx context.Context, si abi.SectorID, types storiface.SectorFileType, ssize abi.SectorSize, allowFetch bool) ([]stores.SectorStorageInfo, error)
func (*StorageMinerStruct) StorageInfo ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageInfo(ctx context.Context, id stores.ID) (stores.StorageInfo, error)
func (*StorageMinerStruct) StorageList ¶ added in v0.3.0
func (*StorageMinerStruct) StorageLocal ¶ added in v0.3.0
func (*StorageMinerStruct) StorageLock ¶ added in v0.4.0
func (c *StorageMinerStruct) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) error
func (*StorageMinerStruct) StorageReportHealth ¶ added in v0.3.0
func (c *StorageMinerStruct) StorageReportHealth(ctx context.Context, id stores.ID, report stores.HealthReport) error
func (*StorageMinerStruct) StorageStat ¶ added in v0.3.0
func (*StorageMinerStruct) StorageTryLock ¶ added in v0.4.0
func (c *StorageMinerStruct) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) (bool, error)
func (*StorageMinerStruct) WorkerConnect ¶ added in v0.3.0
func (c *StorageMinerStruct) WorkerConnect(ctx context.Context, url string) error
func (*StorageMinerStruct) WorkerJobs ¶ added in v0.5.0
func (*StorageMinerStruct) WorkerStats ¶
func (c *StorageMinerStruct) WorkerStats(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)
type WalletStruct ¶ added in v0.9.1
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 ¶ added in v0.9.1
func (c *WalletStruct) WalletDelete(ctx context.Context, addr address.Address) error
func (*WalletStruct) WalletExport ¶ added in v0.9.1
func (*WalletStruct) WalletHas ¶ added in v0.9.1
func (c *WalletStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)
func (*WalletStruct) WalletImport ¶ added in v0.9.1
func (*WalletStruct) WalletList ¶ added in v0.9.1
func (c *WalletStruct) WalletList(ctx context.Context) ([]address.Address, error)
type WorkerStruct ¶ added in v0.3.0
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 ¶ added in v0.5.0
func (w *WorkerStruct) AddPiece(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (storiface.CallID, error)
func (*WorkerStruct) Enabled ¶ added in v1.1.3
func (w *WorkerStruct) Enabled(ctx context.Context) (bool, error)
func (*WorkerStruct) Fetch ¶ added in v0.3.0
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 ¶ added in v0.3.0
func (*WorkerStruct) Info ¶ added in v0.3.0
func (w *WorkerStruct) Info(ctx context.Context) (storiface.WorkerInfo, error)
func (*WorkerStruct) MoveStorage ¶ added in v0.4.0
func (w *WorkerStruct) MoveStorage(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error)
func (*WorkerStruct) Paths ¶ added in v0.3.0
func (w *WorkerStruct) Paths(ctx context.Context) ([]stores.StoragePath, error)
func (*WorkerStruct) ProcessSession ¶ added in v1.1.3
func (*WorkerStruct) ReadPiece ¶ added in v0.3.1
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 ¶ added in v0.4.1
func (*WorkerStruct) SealCommit1 ¶ added in v0.3.0
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 ¶ added in v0.3.0
func (w *WorkerStruct) SealCommit2(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error)
func (*WorkerStruct) SealPreCommit1 ¶ added in v0.3.0
func (*WorkerStruct) SealPreCommit2 ¶ added in v0.3.0
func (w *WorkerStruct) SealPreCommit2(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error)
func (*WorkerStruct) SetEnabled ¶ added in v1.1.3
func (w *WorkerStruct) SetEnabled(ctx context.Context, enabled bool) error
func (*WorkerStruct) StorageAddLocal ¶ added in v0.5.7
func (w *WorkerStruct) StorageAddLocal(ctx context.Context, path string) error
func (*WorkerStruct) TaskDisable ¶ added in v1.2.2
func (*WorkerStruct) TaskEnable ¶ added in v1.2.2
func (*WorkerStruct) UnsealPiece ¶ added in v0.3.1
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.