apistruct

package

v1.0.0 Latest Latest Go to latest Published: Aug 15, 2021 License: Apache-2.0, MIT Imports: 40 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/EpiK-Protocol/go-epik

Links

Open Source Insights

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
type FullNodeStruct
type GatewayStruct
type StorageMinerStruct
type WalletStruct
type WorkerStruct

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 PermissionedFullAPI ¶

func PermissionedFullAPI(a api.FullNode) api.FullNode

func PermissionedStorMinerAPI ¶

func PermissionedStorMinerAPI(a api.StorageMiner) api.StorageMiner

func PermissionedWalletAPI ¶

func PermissionedWalletAPI(a api.WalletAPI) api.WalletAPI

func PermissionedWorkerAPI ¶

func PermissionedWorkerAPI(a api.WorkerAPI) api.WorkerAPI

Types ¶

type CommonStruct ¶

type CommonStruct struct {
	Internal struct {
		AuthVerify func(ctx context.Context, token string) ([]auth.Permission, error) `perm:"read"`
		AuthNew    func(ctx context.Context, perms []auth.Permission) ([]byte, error) `perm:"admin"`

		NetConnectedness            func(context.Context, peer.ID) (network.Connectedness, error)    `perm:"read"`
		NetPeers                    func(context.Context) ([]peer.AddrInfo, error)                   `perm:"read"`
		NetConnect                  func(context.Context, peer.AddrInfo) error                       `perm:"write"`
		NetAddrsListen              func(context.Context) (peer.AddrInfo, error)                     `perm:"read"`
		NetDisconnect               func(context.Context, peer.ID) error                             `perm:"write"`
		NetFindPeer                 func(context.Context, peer.ID) (peer.AddrInfo, error)            `perm:"read"`
		NetPubsubScores             func(context.Context) ([]api.PubsubScore, error)                 `perm:"read"`
		NetAutoNatStatus            func(context.Context) (api.NatInfo, error)                       `perm:"read"`
		NetBandwidthStats           func(ctx context.Context) (metrics.Stats, error)                 `perm:"read"`
		NetBandwidthStatsByPeer     func(ctx context.Context) (map[string]metrics.Stats, error)      `perm:"read"`
		NetBandwidthStatsByProtocol func(ctx context.Context) (map[protocol.ID]metrics.Stats, error) `perm:"read"`
		NetAgentVersion             func(ctx context.Context, p peer.ID) (string, error)             `perm:"read"`
		NetPeerInfo                 func(context.Context, peer.ID) (*api.ExtendedPeerInfo, error)    `perm:"read"`
		NetBlockAdd                 func(ctx context.Context, acl api.NetBlockList) error            `perm:"admin"`
		NetBlockRemove              func(ctx context.Context, acl api.NetBlockList) error            `perm:"admin"`
		NetBlockList                func(ctx context.Context) (api.NetBlockList, error)              `perm:"read"`

		ID      func(context.Context) (peer.ID, error)        `perm:"read"`
		Version func(context.Context) (api.APIVersion, error) `perm:"read"`

		LogList     func(context.Context) ([]string, error)     `perm:"write"`
		LogSetLevel func(context.Context, string, string) error `perm:"write"`

		GC func(context.Context) error `perm:"admin"`

		Shutdown func(context.Context) error                    `perm:"admin"`
		Session  func(context.Context) (uuid.UUID, error)       `perm:"read"`
		Closing  func(context.Context) (<-chan struct{}, error) `perm:"read"`
	}
}

func (*CommonStruct) AuthNew ¶

func (c *CommonStruct) AuthNew(ctx context.Context, perms []auth.Permission) ([]byte, error)

func (*CommonStruct) AuthVerify ¶

func (c *CommonStruct) AuthVerify(ctx context.Context, token string) ([]auth.Permission, error)

func (*CommonStruct) Closing ¶

func (c *CommonStruct) Closing(ctx context.Context) (<-chan struct{}, error)

func (*CommonStruct) GC ¶

func (c *CommonStruct) GC(ctx context.Context) error

func (*CommonStruct) ID ¶

func (c *CommonStruct) ID(ctx context.Context) (peer.ID, error)

ID implements API.ID

func (*CommonStruct) LogList ¶

func (c *CommonStruct) LogList(ctx context.Context) ([]string, error)

func (*CommonStruct) LogSetLevel ¶

func (c *CommonStruct) LogSetLevel(ctx context.Context, group, level string) error

func (*CommonStruct) NetAddrsListen ¶

func (c *CommonStruct) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)

func (*CommonStruct) NetAgentVersion ¶

func (c *CommonStruct) NetAgentVersion(ctx context.Context, p peer.ID) (string, error)

func (*CommonStruct) NetAutoNatStatus ¶

func (c *CommonStruct) NetAutoNatStatus(ctx context.Context) (api.NatInfo, error)

func (*CommonStruct) NetBandwidthStats ¶

func (c *CommonStruct) NetBandwidthStats(ctx context.Context) (metrics.Stats, error)

func (*CommonStruct) NetBandwidthStatsByPeer ¶

func (c *CommonStruct) NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error)

func (*CommonStruct) NetBandwidthStatsByProtocol ¶

func (c *CommonStruct) NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error)

func (*CommonStruct) NetBlockAdd ¶

func (c *CommonStruct) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error

func (*CommonStruct) NetBlockList ¶

func (c *CommonStruct) NetBlockList(ctx context.Context) (api.NetBlockList, error)

func (*CommonStruct) NetBlockRemove ¶

func (c *CommonStruct) NetBlockRemove(ctx context.Context, acl api.NetBlockList) error

func (*CommonStruct) NetConnect ¶

func (c *CommonStruct) NetConnect(ctx context.Context, p peer.AddrInfo) error

func (*CommonStruct) NetConnectedness ¶

func (c *CommonStruct) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)

func (*CommonStruct) NetDisconnect ¶

func (c *CommonStruct) NetDisconnect(ctx context.Context, p peer.ID) error

func (*CommonStruct) NetFindPeer ¶

func (c *CommonStruct) NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)

func (*CommonStruct) NetPeerInfo ¶

func (c *CommonStruct) NetPeerInfo(ctx context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)

func (*CommonStruct) NetPeers ¶

func (c *CommonStruct) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)

func (*CommonStruct) NetPubsubScores ¶

func (c *CommonStruct) NetPubsubScores(ctx context.Context) ([]api.PubsubScore, error)

func (*CommonStruct) Session ¶

func (c *CommonStruct) Session(ctx context.Context) (uuid.UUID, error)

func (*CommonStruct) Shutdown ¶

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"`
		ChainAllowNoWindowPoSt        func(context.Context, types.TipSetKey, abi.ChainEpoch, abi.Randomness) (bool, error)                               `perm:"read"`
		ChainGetBlock                 func(context.Context, cid.Cid) (*types.BlockHeader, error)                                                         `perm:"read"`
		ChainGetTipSet                func(context.Context, types.TipSetKey) (*types.TipSet, error)                                                      `perm:"read"`
		ChainGetBlockMessages         func(context.Context, cid.Cid) (*api.BlockMessages, error)                                                         `perm:"read"`
		ChainGetParentReceipts        func(context.Context, cid.Cid) ([]*types.MessageReceipt, error)                                                    `perm:"read"`
		ChainGetParentMessages        func(context.Context, cid.Cid) ([]api.Message, error)                                                              `perm:"read"`
		ChainGetTipSetByHeight        func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)                                      `perm:"read"`
		ChainReadObj                  func(context.Context, cid.Cid) ([]byte, error)                                                                     `perm:"read"`
		ChainDeleteObj                func(context.Context, cid.Cid) error                                                                               `perm:"admin"`
		ChainHasObj                   func(context.Context, cid.Cid) (bool, error)                                                                       `perm:"read"`
		ChainStatObj                  func(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error)                                                       `perm:"read"`
		ChainSetHead                  func(context.Context, types.TipSetKey) error                                                                       `perm:"admin"`
		ChainGetGenesis               func(context.Context) (*types.TipSet, error)                                                                       `perm:"read"`
		ChainTipSetWeight             func(context.Context, types.TipSetKey) (types.BigInt, error)                                                       `perm:"read"`
		ChainGetNode                  func(ctx context.Context, p string) (*api.IpldObject, error)                                                       `perm:"read"`
		ChainGetMessage               func(context.Context, cid.Cid) (*types.Message, error)                                                             `perm:"read"`
		ChainGetPath                  func(context.Context, types.TipSetKey, types.TipSetKey) ([]*api.HeadChange, error)                                 `perm:"read"`
		ChainExport                   func(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error)                                `perm:"read"`

		BeaconGetEntry func(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error) `perm:"read"`

		GasEstimateGasPremium func(context.Context, uint64, address.Address, int64, types.TipSetKey) (types.BigInt, error)         `perm:"read"`
		GasEstimateGasLimit   func(context.Context, *types.Message, types.TipSetKey) (int64, error)                                `perm:"read"`
		GasEstimateFeeCap     func(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error)                  `perm:"read"`
		GasEstimateMessageGas func(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error) `perm:"read"`

		SyncState          func(context.Context) (*api.SyncState, error)                `perm:"read"`
		SyncSubmitBlock    func(ctx context.Context, blk *types.BlockMsg) error         `perm:"write"`
		SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`
		SyncCheckpoint     func(ctx context.Context, key types.TipSetKey) error         `perm:"admin"`
		SyncMarkBad        func(ctx context.Context, bcid cid.Cid) error                `perm:"admin"`
		SyncUnmarkBad      func(ctx context.Context, bcid cid.Cid) error                `perm:"admin"`
		SyncUnmarkAllBad   func(ctx context.Context) error                              `perm:"admin"`
		SyncCheckBad       func(ctx context.Context, bcid cid.Cid) (string, error)      `perm:"read"`
		SyncValidateTipset func(ctx context.Context, tsk types.TipSetKey) (bool, error) `perm:"read"`

		MpoolGetConfig func(context.Context) (*types.MpoolConfig, error) `perm:"read"`
		MpoolSetConfig func(context.Context, *types.MpoolConfig) error   `perm:"write"`

		MpoolSelect func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error) `perm:"read"`

		MpoolPending func(context.Context, types.TipSetKey) ([]*types.SignedMessage, error) `perm:"read"`
		MpoolClear   func(context.Context, bool) error                                      `perm:"write"`

		MpoolPush          func(context.Context, *types.SignedMessage) (cid.Cid, error) `perm:"write"`
		MpoolPushUntrusted func(context.Context, *types.SignedMessage) (cid.Cid, error) `perm:"write"`

		MpoolPushMessage func(context.Context, *types.Message, *api.MessageSendSpec) (*types.SignedMessage, error) `perm:"sign"`
		MpoolGetNonce    func(context.Context, address.Address) (uint64, error)                                    `perm:"read"`
		MpoolSub         func(context.Context) (<-chan api.MpoolUpdate, error)                                     `perm:"read"`

		MpoolBatchPush          func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                  `perm:"write"`
		MpoolBatchPushUntrusted func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                  `perm:"write"`
		MpoolBatchPushMessage   func(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error) `perm:"sign"`

		MinerGetBaseInfo func(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*api.MiningBaseInfo, error) `perm:"read"`
		MinerCreateBlock func(context.Context, *api.BlockTemplate) (*types.BlockMsg, error)                                   `perm:"write"`

		WalletNew             func(context.Context, types.KeyType) (address.Address, error)                        `perm:"write"`
		WalletHas             func(context.Context, address.Address) (bool, error)                                 `perm:"write"`
		WalletList            func(context.Context) ([]address.Address, error)                                     `perm:"write"`
		WalletBalance         func(context.Context, address.Address) (types.BigInt, error)                         `perm:"read"`
		WalletSign            func(context.Context, address.Address, []byte) (*crypto.Signature, error)            `perm:"sign"`
		WalletSignMessage     func(context.Context, address.Address, *types.Message) (*types.SignedMessage, error) `perm:"sign"`
		WalletVerify          func(context.Context, address.Address, []byte, *crypto.Signature) (bool, error)      `perm:"read"`
		WalletDefaultAddress  func(context.Context) (address.Address, error)                                       `perm:"write"`
		WalletSetDefault      func(context.Context, address.Address) error                                         `perm:"admin"`
		WalletExport          func(context.Context, address.Address) (*types.KeyInfo, error)                       `perm:"admin"`
		WalletImport          func(context.Context, *types.KeyInfo) (address.Address, error)                       `perm:"admin"`
		WalletDelete          func(context.Context, address.Address) error                                         `perm:"write"`
		WalletValidateAddress func(context.Context, string) (address.Address, error)                               `perm:"read"`

		ClientImport                              func(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)                                                                           `perm:"admin"`
		ClientListImports                         func(ctx context.Context) ([]api.Import, error)                                                                                              `perm:"write"`
		ClientRemoveImport                        func(ctx context.Context, importID multistore.StoreID) error                                                                                 `perm:"admin"`
		ClientHasLocal                            func(ctx context.Context, root cid.Cid) (bool, error)                                                                                        `perm:"write"`
		ClientFindData                            func(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)                                                            `perm:"read"`
		ClientMinerQueryOffer                     func(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)                                       `perm:"read"`
		ClientStartDeal                           func(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)                                                                     `perm:"admin"`
		ClientImportAndDeal                       func(ctx context.Context, params *api.ImportAndDealParams) (*api.ImportRes, error)                                                           `perm:"admin"`
		ClientExpertRegisterFile                  func(ctx context.Context, params *api.ExpertRegisterFileParams) (*cid.Cid, error)                                                            `perm:"admin"`
		ClientGetDealInfo                         func(context.Context, cid.Cid) (*api.DealInfo, error)                                                                                        `perm:"read"`
		ClientGetDealStatus                       func(context.Context, uint64) (string, error)                                                                                                `perm:"read"`
		ClientListDeals                           func(ctx context.Context) ([]api.DealInfo, error)                                                                                            `perm:"write"`
		ClientGetDealUpdates                      func(ctx context.Context) (<-chan api.DealInfo, error)                                                                                       `perm:"read"`
		ClientRetrieve                            func(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error                                                                  `perm:"admin"`
		ClientRetrieveWithEvents                  func(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)                            `perm:"admin"`
		ClientQueryAsk                            func(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)                                               `perm:"read"`
		ClientDealPieceCID                        func(ctx context.Context, root cid.Cid) (api.DataCIDSize, error)                                                                             `perm:"read"`
		ClientCalcCommP                           func(ctx context.Context, inpath string) (*api.CommPRet, error)                                                                              `perm:"read"`
		ClientGenCar                              func(ctx context.Context, ref api.FileRef, outpath string) error                                                                             `perm:"write"`
		ClientDealSize                            func(ctx context.Context, root cid.Cid) (api.DataSize, error)                                                                                `perm:"read"`
		ClientListDataTransfers                   func(ctx context.Context) ([]api.DataTransferChannel, error)                                                                                 `perm:"write"`
		ClientDataTransferUpdates                 func(ctx context.Context) (<-chan api.DataTransferChannel, error)                                                                            `perm:"write"`
		ClientRestartDataTransfer                 func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                     `perm:"write"`
		ClientCancelDataTransfer                  func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                     `perm:"write"`
		ClientRetrieveTryRestartInsufficientFunds func(ctx context.Context, paymentChannel address.Address) error                                                                              `perm:"write"`
		ClientRetrieveGetDeal                     func(ctx context.Context, dealID retrievalmarket.DealID) (*api.RetrievalDeal, error)                                                         `perm:"read"`
		ClientRetrieveListDeals                   func(ctx context.Context) (map[retrievalmarket.DealID]*api.RetrievalDeal, error)                                                             `perm:"read"`
		ClientRemove                              func(ctx context.Context, root cid.Cid, wallet address.Address) (cid.Cid, error)                                                             `perm:"admin"`
		ClientRetrieveQuery                       func(ctx context.Context, wallet address.Address, root cid.Cid, piece *cid.Cid, miner address.Address) (*api.RetrievalDeal, error)           `perm:"read"`
		ClientRetrievePledge                      func(ctx context.Context, wallet address.Address, target address.Address, miners []address.Address, amount abi.TokenAmount) (cid.Cid, error) `perm:"admin"`
		ClientRetrieveBind                        func(ctx context.Context, wallet address.Address, miners []address.Address, reverse bool) (cid.Cid, error)                                   `perm:"admin"`
		ClientRetrieveApplyForWithdraw            func(ctx context.Context, wallet address.Address, target address.Address, amount abi.TokenAmount) (cid.Cid, error)                           `perm:"admin"`
		ClientRetrieveWithdraw                    func(ctx context.Context, wallet address.Address, amount abi.TokenAmount) (cid.Cid, error)                                                   `perm:"admin"`
		ClientExpertNominate                      func(ctx context.Context, wallet address.Address, expert address.Address) (cid.Cid, error)                                                   `perm:"admin"`

		StateNetworkName          func(context.Context) (dtypes.NetworkName, error)                                                               `perm:"read"`
		StateMinerSectors         func(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error) `perm:"read"`
		StateMinerActiveSectors   func(context.Context, address.Address, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)                     `perm:"read"`
		StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)                                    `perm:"read"`
		StateMinerPower           func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error)                                `perm:"read"`
		StateMinerInfo            func(context.Context, address.Address, types.TipSetKey) (miner.MinerInfo, error)                                `perm:"read"`
		StateMinerDeadlines       func(context.Context, address.Address, types.TipSetKey) ([]api.Deadline, error)                                 `perm:"read"`
		StateMinerPartitions      func(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error)        `perm:"read"`
		StateMinerFaults          func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)                              `perm:"read"`
		StateMinerActives         func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)                              `perm:"read"`
		StateAllMinerFaults       func(context.Context, abi.ChainEpoch, types.TipSetKey) ([]*api.Fault, error)                                    `perm:"read"`
		StateMinerRecoveries      func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)                              `perm:"read"`
		/* StateMinerPreCommitDepositForPower func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (types.BigInt, error)            `perm:"read"`
		StateMinerInitialPledgeCollateral  func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (types.BigInt, error)            `perm:"read"` */
		StateCoinbase             func(context.Context, address.Address, types.TipSetKey) (*vesting.CoinbaseInfo, error)                              `perm:"read"`
		StateMinerFunds           func(context.Context, address.Address, types.TipSetKey) (miner.Funds, error)                                        `perm:"read"`
		StateMinerSectorAllocated func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (bool, error)                             `perm:"read"`
		StateSectorPreCommitInfo  func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error) `perm:"read"`
		StateSectorGetInfo        func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorOnChainInfo, error)         `perm:"read"`
		StateSectorExpiration     func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorExpiration, error)          `perm:"read"`
		StateSectorPartition      func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorLocation, error)            `perm:"read"`
		StateCall                 func(context.Context, *types.Message, types.TipSetKey) (*api.InvocResult, error)                                    `perm:"read"`
		StateReplay               func(context.Context, types.TipSetKey, cid.Cid) (*api.InvocResult, error)                                           `perm:"read"`
		StateBlockReward          func(ctx context.Context, bid cid.Cid, tsk types.TipSetKey) (*api.BlockReward, error)                               `perm:"read"`
		StateGetActor             func(context.Context, address.Address, types.TipSetKey) (*types.Actor, error)                                       `perm:"read"`
		StateReadState            func(context.Context, address.Address, types.TipSetKey) (*api.ActorState, error)                                    `perm:"read"`
		StateWaitMsg              func(ctx context.Context, cid cid.Cid, confidence uint64) (*api.MsgLookup, error)                                   `perm:"read"`
		StateWaitMsgLimited       func(context.Context, cid.Cid, uint64, abi.ChainEpoch) (*api.MsgLookup, error)                                      `perm:"read"`
		StateSearchMsg            func(context.Context, cid.Cid) (*api.MsgLookup, error)                                                              `perm:"read"`
		StateSearchMsgLimited     func(context.Context, cid.Cid, abi.ChainEpoch) (*api.MsgLookup, error)                                              `perm:"read"`
		StateListMiners           func(context.Context, types.TipSetKey) ([]address.Address, error)                                                   `perm:"read"`
		StateListActors           func(context.Context, types.TipSetKey) ([]address.Address, error)                                                   `perm:"read"`
		// StateMarketBalance        func(context.Context, address.Address, types.TipSetKey) (api.MarketBalance, error)                                  `perm:"read"`
		// StateMarketParticipants   func(context.Context, types.TipSetKey) (map[string]api.MarketBalance, error)                                        `perm:"read"`
		StateMarketDeals          func(context.Context, types.TipSetKey) (map[string]api.MarketDeal, error)                                       `perm:"read"`
		StateMarketStorageDeal    func(context.Context, abi.DealID, types.TipSetKey) (*api.MarketDeal, error)                                     `perm:"read"`
		StateMarketRemainingQuota func(context.Context, cid.Cid, types.TipSetKey) (int64, error)                                                  `perm:"read"`
		StateLookupID             func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)                   `perm:"read"`
		StateAccountKey           func(context.Context, address.Address, types.TipSetKey) (address.Address, error)                                `perm:"read"`
		StateChangedActors        func(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error)                                         `perm:"read"`
		StateGetReceipt           func(context.Context, cid.Cid, types.TipSetKey) (*types.MessageReceipt, error)                                  `perm:"read"`
		StateMinerSectorCount     func(context.Context, address.Address, types.TipSetKey) (api.MinerSectors, error)                               `perm:"read"`
		StateListMessages         func(ctx context.Context, match *api.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error) `perm:"read"`
		StateDecodeParams         func(context.Context, address.Address, abi.MethodNum, []byte, types.TipSetKey) (interface{}, error)             `perm:"read"`
		StateCompute              func(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*api.ComputeStateOutput, error)       `perm:"read"`
		/* StateVerifierStatus                func(context.Context, address.Address, types.TipSetKey) (*abi.StoragePower, error)                                   `perm:"read"`
		StateVerifiedClientStatus         func(context.Context, address.Address, types.TipSetKey) (*abi.StoragePower, error)                                   `perm:"read"`
		StateVerifiedRegistryRootKey      func(ctx context.Context, tsk types.TipSetKey) (address.Address, error)                                              `perm:"read"`
		StateDealProviderCollateralBounds func(context.Context, abi.PaddedPieceSize, bool, types.TipSetKey) (api.DealCollateralBounds, error)                 `perm:"read"`  */
		StateTotalMinedDetail            func(ctx context.Context, tsk types.TipSetKey) (*reward.TotalMinedDetail, error)                                     `perm:"read"`
		StateCirculatingSupply           func(context.Context, types.TipSetKey) (abi.TokenAmount, error)                                                      `perm:"read"`
		StateVMCirculatingSupplyInternal func(context.Context, types.TipSetKey) (api.CirculatingSupply, error)                                                `perm:"read"`
		StateNetworkVersion              func(context.Context, types.TipSetKey) (stnetwork.Version, error)                                                    `perm:"read"`
		StateListExperts                 func(context.Context, types.TipSetKey) ([]address.Address, error)                                                    `perm:"read"`
		StateExpertInfo                  func(context.Context, address.Address, types.TipSetKey) (*api.ExpertInfo, error)                                     `perm:"read"`
		StateExpertDatas                 func(context.Context, address.Address, *bitfield.BitField, bool, types.TipSetKey) ([]*expert.DataOnChainInfo, error) `perm:"read"`
		StateExpertFileInfo              func(context.Context, cid.Cid, types.TipSetKey) (*api.ExpertFileInfo, error)                                         `perm:"read"`
		StateVoteTally                   func(context.Context, types.TipSetKey) (*vote.Tally, error)                                                          `perm:"read"`
		StateVoterInfo                   func(context.Context, address.Address, types.TipSetKey) (*vote.VoterInfo, error)                                     `perm:"read"`
		StateKnowledgeInfo               func(context.Context, types.TipSetKey) (*knowledge.Info, error)                                                      `perm:"read"`
		StateGovernSupervisor            func(context.Context, types.TipSetKey) (address.Address, error)                                                      `perm:"read"`
		StateGovernorList                func(context.Context, types.TipSetKey) ([]*govern.GovernorInfo, error)                                               `perm:"read"`
		StateGovernParams                func(context.Context, types.TipSetKey) (*govern.GovParams, error)                                                    `perm:"read"`
		StateRetrievalInfo               func(context.Context, types.TipSetKey) (*api.RetrievalInfo, error)                                                   `perm:"read"`
		StateRetrievalPledge             func(context.Context, address.Address, types.TipSetKey) (*api.RetrievalState, error)                                 `perm:"read"`
		StateRetrievalPledgeFrom         func(context.Context, address.Address, types.TipSetKey) (*api.RetrievalPledgeInfo, error)                            `perm:"read"`
		StateRetrievalPledgeList         func(context.Context, types.TipSetKey) (map[address.Address]*api.RetrievalState, error)                              `perm:"read"`
		StateDataIndex                   func(context.Context, abi.ChainEpoch, types.TipSetKey) ([]*api.DataIndex, error)                                     `perm:"read"`
		StateMinerStoredAnyPiece         func(context.Context, address.Address, []cid.Cid, types.TipSetKey) (bool, error)                                     `perm:"read"`

		MsigGetAvailableBalance func(context.Context, address.Address, types.TipSetKey) (types.BigInt, error)                                                                    `perm:"read"`
		MsigGetVestingSchedule  func(context.Context, address.Address, types.TipSetKey) (api.MsigVesting, error)                                                                 `perm:"read"`
		MsigGetVested           func(context.Context, address.Address, types.TipSetKey, types.TipSetKey) (types.BigInt, error)                                                   `perm:"read"`
		MsigGetPending          func(context.Context, address.Address, types.TipSetKey) ([]*api.MsigTransaction, error)                                                          `perm:"read"`
		MsigCreate              func(context.Context, uint64, []address.Address, abi.ChainEpoch, types.BigInt, address.Address, types.BigInt) (cid.Cid, error)                   `perm:"sign"`
		MsigPropose             func(context.Context, address.Address, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error)                          `perm:"sign"`
		MsigApprove             func(context.Context, address.Address, uint64, address.Address) (cid.Cid, error)                                                                 `perm:"sign"`
		MsigApproveTxnHash      func(context.Context, address.Address, uint64, address.Address, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error) `perm:"sign"`
		MsigCancel              func(context.Context, address.Address, uint64, address.Address, types.BigInt, address.Address, uint64, []byte) (cid.Cid, error)                  `perm:"sign"`
		MsigAddPropose          func(context.Context, address.Address, address.Address, address.Address, bool) (cid.Cid, error)                                                  `perm:"sign"`
		MsigAddApprove          func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address, bool) (cid.Cid, error)                         `perm:"sign"`
		MsigAddCancel           func(context.Context, address.Address, address.Address, uint64, address.Address, bool) (cid.Cid, error)                                          `perm:"sign"`
		MsigSwapPropose         func(context.Context, address.Address, address.Address, address.Address, address.Address) (cid.Cid, error)                                       `perm:"sign"`
		MsigSwapApprove         func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address, address.Address) (cid.Cid, error)              `perm:"sign"`
		MsigSwapCancel          func(context.Context, address.Address, address.Address, uint64, address.Address, address.Address) (cid.Cid, error)                               `perm:"sign"`
		MsigRemoveSigner        func(ctx context.Context, msig address.Address, proposer address.Address, toRemove address.Address, decrease bool) (cid.Cid, error)              `perm:"sign"`

		PaychGet                    func(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)           `perm:"sign"`
		PaychGetWaitReady           func(context.Context, cid.Cid) (address.Address, error)                                                   `perm:"sign"`
		PaychAvailableFunds         func(context.Context, address.Address) (*api.ChannelAvailableFunds, error)                                `perm:"sign"`
		PaychAvailableFundsByFromTo func(context.Context, address.Address, address.Address) (*api.ChannelAvailableFunds, error)               `perm:"sign"`
		PaychList                   func(context.Context) ([]address.Address, error)                                                          `perm:"read"`
		PaychStatus                 func(context.Context, address.Address) (*api.PaychStatus, error)                                          `perm:"read"`
		PaychSettle                 func(context.Context, address.Address) (cid.Cid, error)                                                   `perm:"sign"`
		PaychCollect                func(context.Context, address.Address) (cid.Cid, error)                                                   `perm:"sign"`
		PaychAllocateLane           func(context.Context, address.Address) (uint64, error)                                                    `perm:"sign"`
		PaychNewPayment             func(ctx context.Context, from, to address.Address, vouchers []api.VoucherSpec) (*api.PaymentInfo, error) `perm:"sign"`
		PaychVoucherCheck           func(context.Context, *paych.SignedVoucher) error                                                         `perm:"read"`
		PaychVoucherCheckValid      func(context.Context, address.Address, *paych.SignedVoucher) error                                        `perm:"read"`
		PaychVoucherCheckSpendable  func(context.Context, address.Address, *paych.SignedVoucher, []byte, []byte) (bool, error)                `perm:"read"`
		PaychVoucherAdd             func(context.Context, address.Address, *paych.SignedVoucher, []byte, types.BigInt) (types.BigInt, error)  `perm:"write"`
		PaychVoucherCreate          func(context.Context, address.Address, big.Int, uint64) (*api.VoucherCreateResult, error)                 `perm:"sign"`
		PaychVoucherList            func(context.Context, address.Address) ([]*paych.SignedVoucher, error)                                    `perm:"write"`
		PaychVoucherSubmit          func(context.Context, address.Address, *paych.SignedVoucher, []byte, []byte) (cid.Cid, error)             `perm:"sign"`

		FlowchGet                    func(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)            `perm:"sign"`
		FlowchGetWaitReady           func(context.Context, cid.Cid) (address.Address, error)                                                    `perm:"sign"`
		FlowchAvailableFunds         func(context.Context, address.Address) (*api.ChannelAvailableFunds, error)                                 `perm:"sign"`
		FlowchAvailableFundsByFromTo func(context.Context, address.Address, address.Address) (*api.ChannelAvailableFunds, error)                `perm:"sign"`
		FlowchList                   func(context.Context) ([]address.Address, error)                                                           `perm:"read"`
		FlowchStatus                 func(context.Context, address.Address) (*api.FlowchStatus, error)                                          `perm:"read"`
		FlowchSettle                 func(context.Context, address.Address) (cid.Cid, error)                                                    `perm:"sign"`
		FlowchCollect                func(context.Context, address.Address) (cid.Cid, error)                                                    `perm:"sign"`
		FlowchAllocateLane           func(context.Context, address.Address) (uint64, error)                                                     `perm:"sign"`
		FlowchNewPayment             func(ctx context.Context, from, to address.Address, vouchers []api.FlowVoucherSpec) (*api.FlowInfo, error) `perm:"sign"`
		FlowchVoucherCheck           func(context.Context, *flowch.SignedVoucher) error                                                         `perm:"read"`
		FlowchVoucherCheckValid      func(context.Context, address.Address, *flowch.SignedVoucher) error                                        `perm:"read"`
		FlowchVoucherCheckSpendable  func(context.Context, address.Address, *flowch.SignedVoucher, []byte, []byte) (bool, error)                `perm:"read"`
		FlowchVoucherAdd             func(context.Context, address.Address, *flowch.SignedVoucher, []byte, types.BigInt) (types.BigInt, error)  `perm:"write"`
		FlowchVoucherCreate          func(context.Context, address.Address, big.Int, uint64) (*api.FlowVoucherCreateResult, error)              `perm:"sign"`
		FlowchVoucherList            func(context.Context, address.Address) ([]*flowch.SignedVoucher, error)                                    `perm:"write"`
		FlowchVoucherSubmit          func(context.Context, address.Address, *flowch.SignedVoucher, []byte, []byte) (cid.Cid, error)             `perm:"sign"`

		CreateBackup func(ctx context.Context, fpath string) error `perm:"admin"`
	}
}

FullNodeStruct implements API passing calls to user-provided function values.

func (*FullNodeStruct) BeaconGetEntry ¶

func (c *FullNodeStruct) BeaconGetEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)

func (*FullNodeStruct) ChainAllowNoWindowPoSt ¶

func (c *FullNodeStruct) ChainAllowNoWindowPoSt(ctx context.Context, tsk types.TipSetKey, challenge abi.ChainEpoch, rand abi.Randomness) (bool, error)

func (*FullNodeStruct) ChainDeleteObj ¶

func (c *FullNodeStruct) ChainDeleteObj(ctx context.Context, obj cid.Cid) error

func (*FullNodeStruct) ChainExport ¶

func (c *FullNodeStruct) ChainExport(ctx context.Context, nroots abi.ChainEpoch, iom bool, tsk types.TipSetKey) (<-chan []byte, error)

func (*FullNodeStruct) ChainGetBlock ¶

func (c *FullNodeStruct) ChainGetBlock(ctx context.Context, b cid.Cid) (*types.BlockHeader, error)

func (*FullNodeStruct) ChainGetBlockMessages ¶

func (c *FullNodeStruct) ChainGetBlockMessages(ctx context.Context, b cid.Cid) (*api.BlockMessages, error)

func (*FullNodeStruct) ChainGetGenesis ¶

func (c *FullNodeStruct) ChainGetGenesis(ctx context.Context) (*types.TipSet, error)

func (*FullNodeStruct) ChainGetMessage ¶

func (c *FullNodeStruct) ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)

func (*FullNodeStruct) ChainGetNode ¶

func (c *FullNodeStruct) ChainGetNode(ctx context.Context, p string) (*api.IpldObject, error)

func (*FullNodeStruct) ChainGetParentMessages ¶

func (c *FullNodeStruct) ChainGetParentMessages(ctx context.Context, b cid.Cid) ([]api.Message, error)

func (*FullNodeStruct) ChainGetParentReceipts ¶

func (c *FullNodeStruct) ChainGetParentReceipts(ctx context.Context, b cid.Cid) ([]*types.MessageReceipt, error)

func (*FullNodeStruct) ChainGetPath ¶

func (c *FullNodeStruct) ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)

func (*FullNodeStruct) ChainGetRandomnessFromBeacon ¶

func (c *FullNodeStruct) ChainGetRandomnessFromBeacon(ctx context.Context, tsk types.TipSetKey, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)

func (*FullNodeStruct) ChainGetRandomnessFromTickets ¶

func (c *FullNodeStruct) ChainGetRandomnessFromTickets(ctx context.Context, tsk types.TipSetKey, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)

func (*FullNodeStruct) ChainGetTipSet ¶

func (c *FullNodeStruct) ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error)

func (*FullNodeStruct) ChainGetTipSetByHeight ¶

func (c *FullNodeStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)

func (*FullNodeStruct) ChainHasObj ¶

func (c *FullNodeStruct) ChainHasObj(ctx context.Context, o cid.Cid) (bool, error)

func (*FullNodeStruct) ChainHead ¶

func (c *FullNodeStruct) ChainHead(ctx context.Context) (*types.TipSet, 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 (c *FullNodeStruct) ChainSetHead(ctx context.Context, tsk types.TipSetKey) error

func (*FullNodeStruct) ChainStatObj ¶

func (c *FullNodeStruct) ChainStatObj(ctx context.Context, obj, base cid.Cid) (api.ObjStat, error)

func (*FullNodeStruct) ChainTipSetWeight ¶

func (c *FullNodeStruct) ChainTipSetWeight(ctx context.Context, tsk types.TipSetKey) (types.BigInt, error)

func (*FullNodeStruct) ClientCalcCommP ¶

func (c *FullNodeStruct) ClientCalcCommP(ctx context.Context, inpath string) (*api.CommPRet, error)

func (*FullNodeStruct) ClientCancelDataTransfer ¶

func (c *FullNodeStruct) ClientCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*FullNodeStruct) ClientDataTransferUpdates ¶

func (c *FullNodeStruct) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)

func (*FullNodeStruct) ClientDealPieceCID ¶

func (c *FullNodeStruct) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCIDSize, error)

func (*FullNodeStruct) ClientDealSize ¶

func (c *FullNodeStruct) ClientDealSize(ctx context.Context, root cid.Cid) (api.DataSize, error)

func (*FullNodeStruct) ClientExpertNominate ¶

func (c *FullNodeStruct) ClientExpertNominate(ctx context.Context, wallet address.Address, expert address.Address) (cid.Cid, error)

func (*FullNodeStruct) ClientExpertRegisterFile ¶

func (c *FullNodeStruct) ClientExpertRegisterFile(ctx context.Context, params *api.ExpertRegisterFileParams) (*cid.Cid, error)

func (*FullNodeStruct) ClientFindData ¶

func (c *FullNodeStruct) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)

func (*FullNodeStruct) ClientGenCar ¶

func (c *FullNodeStruct) ClientGenCar(ctx context.Context, ref api.FileRef, outpath string) error

func (*FullNodeStruct) ClientGetDealInfo ¶

func (c *FullNodeStruct) ClientGetDealInfo(ctx context.Context, deal cid.Cid) (*api.DealInfo, error)

func (*FullNodeStruct) ClientGetDealStatus ¶

func (c *FullNodeStruct) ClientGetDealStatus(ctx context.Context, statusCode uint64) (string, error)

func (*FullNodeStruct) ClientGetDealUpdates ¶

func (c *FullNodeStruct) ClientGetDealUpdates(ctx context.Context) (<-chan api.DealInfo, error)

func (*FullNodeStruct) ClientHasLocal ¶

func (c *FullNodeStruct) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error)

func (*FullNodeStruct) ClientImport ¶

func (c *FullNodeStruct) ClientImport(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)

func (*FullNodeStruct) ClientImportAndDeal ¶

func (c *FullNodeStruct) ClientImportAndDeal(ctx context.Context, params *api.ImportAndDealParams) (*api.ImportRes, error)

func (*FullNodeStruct) ClientListDataTransfers ¶

func (c *FullNodeStruct) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)

func (*FullNodeStruct) ClientListDeals ¶

func (c *FullNodeStruct) ClientListDeals(ctx context.Context) ([]api.DealInfo, error)

func (*FullNodeStruct) ClientListImports ¶

func (c *FullNodeStruct) ClientListImports(ctx context.Context) ([]api.Import, error)

func (*FullNodeStruct) ClientMinerQueryOffer ¶

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) ClientRemove ¶

func (c *FullNodeStruct) ClientRemove(ctx context.Context, root cid.Cid, wallet address.Address) (cid.Cid, error)

func (*FullNodeStruct) ClientRemoveImport ¶

func (c *FullNodeStruct) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error

func (*FullNodeStruct) ClientRestartDataTransfer ¶

func (c *FullNodeStruct) ClientRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*FullNodeStruct) ClientRetrieve ¶

func (c *FullNodeStruct) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error

func (*FullNodeStruct) ClientRetrieveApplyForWithdraw ¶

func (c *FullNodeStruct) ClientRetrieveApplyForWithdraw(ctx context.Context, wallet address.Address, target address.Address, amount abi.TokenAmount) (cid.Cid, error)

func (*FullNodeStruct) ClientRetrieveBind ¶

func (c *FullNodeStruct) ClientRetrieveBind(ctx context.Context, wallet address.Address, miners []address.Address, reverse bool) (cid.Cid, error)

func (*FullNodeStruct) ClientRetrieveGetDeal ¶

func (c *FullNodeStruct) ClientRetrieveGetDeal(ctx context.Context, dealID retrievalmarket.DealID) (*api.RetrievalDeal, error)

func (*FullNodeStruct) ClientRetrieveListDeals ¶

func (c *FullNodeStruct) ClientRetrieveListDeals(ctx context.Context) (map[retrievalmarket.DealID]*api.RetrievalDeal, error)

func (*FullNodeStruct) ClientRetrievePledge ¶

func (c *FullNodeStruct) ClientRetrievePledge(ctx context.Context, wallet address.Address, target address.Address, miners []address.Address, amount abi.TokenAmount) (cid.Cid, error)

func (*FullNodeStruct) ClientRetrieveQuery ¶

func (c *FullNodeStruct) ClientRetrieveQuery(ctx context.Context, wallet address.Address, root cid.Cid, piece *cid.Cid, miner address.Address) (*api.RetrievalDeal, error)

func (*FullNodeStruct) ClientRetrieveTryRestartInsufficientFunds ¶

func (c *FullNodeStruct) ClientRetrieveTryRestartInsufficientFunds(ctx context.Context, paymentChannel address.Address) error

func (*FullNodeStruct) ClientRetrieveWithEvents ¶

func (c *FullNodeStruct) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)

func (*FullNodeStruct) ClientRetrieveWithdraw ¶

func (c *FullNodeStruct) ClientRetrieveWithdraw(ctx context.Context, wallet address.Address, amount abi.TokenAmount) (cid.Cid, error)

func (*FullNodeStruct) ClientStartDeal ¶

func (c *FullNodeStruct) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)

func (*FullNodeStruct) CreateBackup ¶

func (c *FullNodeStruct) CreateBackup(ctx context.Context, fpath string) error

func (*FullNodeStruct) FlowchAllocateLane ¶

func (c *FullNodeStruct) FlowchAllocateLane(ctx context.Context, ch address.Address) (uint64, error)

func (*FullNodeStruct) FlowchAvailableFunds ¶

func (c *FullNodeStruct) FlowchAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)

func (*FullNodeStruct) FlowchAvailableFundsByFromTo ¶

func (c *FullNodeStruct) FlowchAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)

func (*FullNodeStruct) FlowchCollect ¶

func (c *FullNodeStruct) FlowchCollect(ctx context.Context, a address.Address) (cid.Cid, error)

func (*FullNodeStruct) FlowchGet ¶

func (c *FullNodeStruct) FlowchGet(ctx context.Context, from, to address.Address, amt types.BigInt) (*api.ChannelInfo, error)

func (*FullNodeStruct) FlowchGetWaitReady ¶

func (c *FullNodeStruct) FlowchGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error)

func (*FullNodeStruct) FlowchList ¶

func (c *FullNodeStruct) FlowchList(ctx context.Context) ([]address.Address, error)

func (*FullNodeStruct) FlowchNewPayment ¶

func (c *FullNodeStruct) FlowchNewPayment(ctx context.Context, from, to address.Address, vouchers []api.FlowVoucherSpec) (*api.FlowInfo, error)

func (*FullNodeStruct) FlowchSettle ¶

func (c *FullNodeStruct) FlowchSettle(ctx context.Context, a address.Address) (cid.Cid, error)

func (*FullNodeStruct) FlowchStatus ¶

func (c *FullNodeStruct) FlowchStatus(ctx context.Context, pch address.Address) (*api.FlowchStatus, error)

func (*FullNodeStruct) FlowchVoucherAdd ¶

func (c *FullNodeStruct) FlowchVoucherAdd(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher, proof []byte, minDelta types.BigInt) (types.BigInt, error)

func (*FullNodeStruct) FlowchVoucherCheckSpendable ¶

func (c *FullNodeStruct) FlowchVoucherCheckSpendable(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher, secret []byte, proof []byte) (bool, error)

func (*FullNodeStruct) FlowchVoucherCheckValid ¶

func (c *FullNodeStruct) FlowchVoucherCheckValid(ctx context.Context, addr address.Address, sv *flowch.SignedVoucher) error

func (*FullNodeStruct) FlowchVoucherCreate ¶

func (c *FullNodeStruct) FlowchVoucherCreate(ctx context.Context, pch address.Address, amt types.BigInt, lane uint64) (*api.FlowVoucherCreateResult, error)

func (*FullNodeStruct) FlowchVoucherList ¶

func (c *FullNodeStruct) FlowchVoucherList(ctx context.Context, pch address.Address) ([]*flowch.SignedVoucher, error)

func (*FullNodeStruct) FlowchVoucherSubmit ¶

func (c *FullNodeStruct) FlowchVoucherSubmit(ctx context.Context, ch address.Address, sv *flowch.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error)

func (*FullNodeStruct) GasEstimateFeeCap ¶

func (c *FullNodeStruct) GasEstimateFeeCap(ctx context.Context, msg *types.Message, maxqueueblks int64, tsk types.TipSetKey) (types.BigInt, error)

func (*FullNodeStruct) GasEstimateGasLimit ¶

func (c *FullNodeStruct) GasEstimateGasLimit(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (int64, error)

func (*FullNodeStruct) GasEstimateGasPremium ¶

func (c *FullNodeStruct) GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (types.BigInt, error)

func (*FullNodeStruct) GasEstimateMessageGas ¶

func (c *FullNodeStruct) GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)

func (*FullNodeStruct) MinerCreateBlock ¶

func (c *FullNodeStruct) MinerCreateBlock(ctx context.Context, bt *api.BlockTemplate) (*types.BlockMsg, error)

func (*FullNodeStruct) MinerGetBaseInfo ¶

func (c *FullNodeStruct) MinerGetBaseInfo(ctx context.Context, maddr address.Address, epoch abi.ChainEpoch, tsk types.TipSetKey) (*api.MiningBaseInfo, error)

func (*FullNodeStruct) MpoolBatchPush ¶

func (c *FullNodeStruct) MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)

func (*FullNodeStruct) MpoolBatchPushMessage ¶

func (c *FullNodeStruct) MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *api.MessageSendSpec) ([]*types.SignedMessage, error)

func (*FullNodeStruct) MpoolBatchPushUntrusted ¶

func (c *FullNodeStruct) MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)

func (*FullNodeStruct) MpoolClear ¶

func (c *FullNodeStruct) MpoolClear(ctx context.Context, local bool) error

func (*FullNodeStruct) MpoolGetConfig ¶

func (c *FullNodeStruct) MpoolGetConfig(ctx context.Context) (*types.MpoolConfig, error)

func (*FullNodeStruct) MpoolGetNonce ¶

func (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 ¶

func (c *FullNodeStruct) MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)

func (*FullNodeStruct) MpoolSelect ¶

func (c *FullNodeStruct) MpoolSelect(ctx context.Context, tsk types.TipSetKey, tq float64) ([]*types.SignedMessage, error)

func (*FullNodeStruct) MpoolSetConfig ¶

func (c *FullNodeStruct) MpoolSetConfig(ctx context.Context, cfg *types.MpoolConfig) error

func (*FullNodeStruct) MpoolSub ¶

func (c *FullNodeStruct) MpoolSub(ctx context.Context) (<-chan api.MpoolUpdate, error)

func (*FullNodeStruct) MsigAddApprove ¶

func (c *FullNodeStruct) MsigAddApprove(ctx context.Context, msig address.Address, src address.Address, txID uint64, proposer address.Address, newAdd address.Address, inc bool) (cid.Cid, error)

func (*FullNodeStruct) MsigAddCancel ¶

func (c *FullNodeStruct) MsigAddCancel(ctx context.Context, msig address.Address, src address.Address, txID uint64, newAdd address.Address, inc bool) (cid.Cid, error)

func (*FullNodeStruct) MsigAddPropose ¶

func (c *FullNodeStruct) MsigAddPropose(ctx context.Context, msig address.Address, src address.Address, newAdd address.Address, inc bool) (cid.Cid, error)

func (*FullNodeStruct) MsigApprove ¶

func (c *FullNodeStruct) MsigApprove(ctx context.Context, msig address.Address, txID uint64, signer address.Address) (cid.Cid, error)

func (*FullNodeStruct) MsigApproveTxnHash ¶

func (c *FullNodeStruct) MsigApproveTxnHash(ctx context.Context, msig address.Address, txID uint64, proposer address.Address, to address.Address, amt types.BigInt, src address.Address, method uint64, params []byte) (cid.Cid, error)

func (*FullNodeStruct) MsigCancel ¶

func (c *FullNodeStruct) MsigCancel(ctx context.Context, msig address.Address, txID uint64, to address.Address, amt types.BigInt, src address.Address, method uint64, params []byte) (cid.Cid, error)

func (*FullNodeStruct) MsigCreate ¶

func (c *FullNodeStruct) MsigCreate(ctx context.Context, req uint64, addrs []address.Address, duration abi.ChainEpoch, val types.BigInt, src address.Address, gp types.BigInt) (cid.Cid, error)

func (*FullNodeStruct) MsigGetAvailableBalance ¶

func (c *FullNodeStruct) MsigGetAvailableBalance(ctx context.Context, a address.Address, tsk types.TipSetKey) (types.BigInt, error)

func (*FullNodeStruct) MsigGetPending ¶

func (c *FullNodeStruct) MsigGetPending(ctx context.Context, a address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)

func (*FullNodeStruct) MsigGetVested ¶

func (c *FullNodeStruct) MsigGetVested(ctx context.Context, a address.Address, sTsk types.TipSetKey, eTsk types.TipSetKey) (types.BigInt, error)

func (*FullNodeStruct) MsigGetVestingSchedule ¶

func (c *FullNodeStruct) MsigGetVestingSchedule(ctx context.Context, a address.Address, tsk types.TipSetKey) (api.MsigVesting, error)

func (*FullNodeStruct) MsigPropose ¶

func (c *FullNodeStruct) MsigPropose(ctx context.Context, msig address.Address, to address.Address, amt types.BigInt, src address.Address, method uint64, params []byte) (cid.Cid, error)

func (*FullNodeStruct) MsigRemoveSigner ¶

func (c *FullNodeStruct) MsigRemoveSigner(ctx context.Context, msig address.Address, proposer address.Address, toRemove address.Address, decrease bool) (cid.Cid, error)

func (*FullNodeStruct) MsigSwapApprove ¶

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 ¶

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 ¶

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 ¶

func (c *FullNodeStruct) PaychAvailableFunds(ctx context.Context, ch address.Address) (*api.ChannelAvailableFunds, error)

func (*FullNodeStruct) PaychAvailableFundsByFromTo ¶

func (c *FullNodeStruct) PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*api.ChannelAvailableFunds, error)

func (*FullNodeStruct) PaychCollect ¶

func (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 ¶

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 ¶

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 (c *FullNodeStruct) PaychVoucherAdd(ctx context.Context, addr address.Address, sv *paych.SignedVoucher, proof []byte, minDelta types.BigInt) (types.BigInt, error)

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 ¶

func (c *FullNodeStruct) StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)

func (*FullNodeStruct) StateAllMinerFaults ¶

func (c *FullNodeStruct) StateAllMinerFaults(ctx context.Context, cutoff abi.ChainEpoch, endTsk types.TipSetKey) ([]*api.Fault, error)

func (*FullNodeStruct) StateBlockReward ¶

func (c *FullNodeStruct) StateBlockReward(ctx context.Context, bid cid.Cid, tsk types.TipSetKey) (*api.BlockReward, error)

func (*FullNodeStruct) StateCall ¶

func (c *FullNodeStruct) StateCall(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*api.InvocResult, error)

func (*FullNodeStruct) StateChangedActors ¶

func (c *FullNodeStruct) StateChangedActors(ctx context.Context, olnstate cid.Cid, newstate cid.Cid) (map[string]types.Actor, error)

func (*FullNodeStruct) StateCirculatingSupply ¶

func (c *FullNodeStruct) StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)

func (*FullNodeStruct) StateCoinbase ¶

func (c *FullNodeStruct) StateCoinbase(ctx context.Context, caddr address.Address, tsk types.TipSetKey) (*vesting.CoinbaseInfo, error)

func (*FullNodeStruct) StateCompute ¶

func (c *FullNodeStruct) StateCompute(ctx context.Context, height abi.ChainEpoch, msgs []*types.Message, tsk types.TipSetKey) (*api.ComputeStateOutput, error)

func (*FullNodeStruct) StateDataIndex ¶

func (c *FullNodeStruct) StateDataIndex(ctx context.Context, epoch abi.ChainEpoch, tsk types.TipSetKey) ([]*api.DataIndex, error)

func (*FullNodeStruct) StateDecodeParams ¶

func (c *FullNodeStruct) StateDecodeParams(ctx context.Context, toAddr address.Address, method abi.MethodNum, params []byte, tsk types.TipSetKey) (interface{}, error)

func (*FullNodeStruct) StateExpertDatas ¶

func (c *FullNodeStruct) StateExpertDatas(ctx context.Context, addr address.Address, filter *bitfield.BitField, filterOut bool, tsk types.TipSetKey) ([]*expert.DataOnChainInfo, error)

func (*FullNodeStruct) StateExpertFileInfo ¶

func (c *FullNodeStruct) StateExpertFileInfo(ctx context.Context, pieceCID cid.Cid, tsk types.TipSetKey) (*api.ExpertFileInfo, error)

func (*FullNodeStruct) StateExpertInfo ¶

func (c *FullNodeStruct) StateExpertInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ExpertInfo, error)

func (*FullNodeStruct) StateGetActor ¶

func (c *FullNodeStruct) StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)

func (*FullNodeStruct) StateGetReceipt ¶

func (c *FullNodeStruct) StateGetReceipt(ctx context.Context, msg cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)

func (*FullNodeStruct) StateGovernParams ¶

func (c *FullNodeStruct) StateGovernParams(ctx context.Context, tsk types.TipSetKey) (*govern.GovParams, error)

func (*FullNodeStruct) StateGovernSupervisor ¶

func (c *FullNodeStruct) StateGovernSupervisor(ctx context.Context, tsk types.TipSetKey) (address.Address, error)

func (*FullNodeStruct) StateGovernorList ¶

func (c *FullNodeStruct) StateGovernorList(ctx context.Context, tsk types.TipSetKey) ([]*govern.GovernorInfo, error)

func (*FullNodeStruct) StateKnowledgeInfo ¶

func (c *FullNodeStruct) StateKnowledgeInfo(ctx context.Context, tsk types.TipSetKey) (*knowledge.Info, error)

func (*FullNodeStruct) StateListActors ¶

func (c *FullNodeStruct) StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (*FullNodeStruct) StateListExperts ¶

func (c *FullNodeStruct) StateListExperts(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (*FullNodeStruct) StateListMessages ¶

func (c *FullNodeStruct) StateListMessages(ctx context.Context, match *api.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error)

func (*FullNodeStruct) StateListMiners ¶

func (c *FullNodeStruct) StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (*FullNodeStruct) StateLookupID ¶

func (c *FullNodeStruct) StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)

func (*FullNodeStruct) StateMarketDeals ¶

func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)

func (*FullNodeStruct) StateMarketRemainingQuota ¶

func (c *FullNodeStruct) StateMarketRemainingQuota(ctx context.Context, pieceCid cid.Cid, tsk types.TipSetKey) (int64, error)

func (*FullNodeStruct) StateMarketStorageDeal ¶

func (c *FullNodeStruct) StateMarketStorageDeal(ctx context.Context, dealid abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)

func (*FullNodeStruct) StateMinerActiveSectors ¶

func (c *FullNodeStruct) StateMinerActiveSectors(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)

func (*FullNodeStruct) StateMinerActives ¶

func (c *FullNodeStruct) StateMinerActives(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)

func (*FullNodeStruct) StateMinerDeadlines ¶

func (c *FullNodeStruct) StateMinerDeadlines(ctx context.Context, actor address.Address, tsk types.TipSetKey) ([]api.Deadline, error)

func (*FullNodeStruct) StateMinerFaults ¶

func (c *FullNodeStruct) StateMinerFaults(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)

func (*FullNodeStruct) StateMinerFunds ¶

func (c *FullNodeStruct) StateMinerFunds(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (miner.Funds, error)

func (*FullNodeStruct) StateMinerInfo ¶

func (c *FullNodeStruct) StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)

func (*FullNodeStruct) StateMinerPartitions ¶

func (c *FullNodeStruct) StateMinerPartitions(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]api.Partition, error)

func (*FullNodeStruct) StateMinerPower ¶

func (c *FullNodeStruct) StateMinerPower(ctx context.Context, a address.Address, tsk types.TipSetKey) (*api.MinerPower, error)

func (*FullNodeStruct) StateMinerProvingDeadline ¶

func (c *FullNodeStruct) StateMinerProvingDeadline(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)

func (*FullNodeStruct) StateMinerRecoveries ¶

func (c *FullNodeStruct) StateMinerRecoveries(ctx context.Context, actor address.Address, tsk types.TipSetKey) (bitfield.BitField, error)

func (*FullNodeStruct) StateMinerSectorAllocated ¶

func (c *FullNodeStruct) StateMinerSectorAllocated(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error)

func (*FullNodeStruct) StateMinerSectorCount ¶

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) StateMinerStoredAnyPiece ¶

func (c *FullNodeStruct) StateMinerStoredAnyPiece(ctx context.Context, addr address.Address, pieceIDs []cid.Cid, tsk types.TipSetKey) (bool, error)

func (*FullNodeStruct) StateNetworkName ¶

func (c *FullNodeStruct) StateNetworkName(ctx context.Context) (dtypes.NetworkName, error)

func (*FullNodeStruct) StateNetworkVersion ¶

func (c *FullNodeStruct) StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)

func (*FullNodeStruct) StateReadState ¶

func (c *FullNodeStruct) StateReadState(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.ActorState, error)

func (*FullNodeStruct) StateReplay ¶

func (c *FullNodeStruct) StateReplay(ctx context.Context, tsk types.TipSetKey, mc cid.Cid) (*api.InvocResult, error)

func (*FullNodeStruct) StateRetrievalInfo ¶

func (c *FullNodeStruct) StateRetrievalInfo(ctx context.Context, tsk types.TipSetKey) (*api.RetrievalInfo, error)

func (*FullNodeStruct) StateRetrievalPledge ¶

func (c *FullNodeStruct) StateRetrievalPledge(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalState, error)

func (*FullNodeStruct) StateRetrievalPledgeFrom ¶

func (c *FullNodeStruct) StateRetrievalPledgeFrom(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.RetrievalPledgeInfo, error)

func (*FullNodeStruct) StateRetrievalPledgeList ¶

func (c *FullNodeStruct) StateRetrievalPledgeList(ctx context.Context, tsk types.TipSetKey) (map[address.Address]*api.RetrievalState, error)

func (*FullNodeStruct) StateSearchMsg ¶

func (c *FullNodeStruct) StateSearchMsg(ctx context.Context, msgc cid.Cid) (*api.MsgLookup, error)

func (*FullNodeStruct) StateSearchMsgLimited ¶

func (c *FullNodeStruct) StateSearchMsgLimited(ctx context.Context, msgc cid.Cid, limit abi.ChainEpoch) (*api.MsgLookup, error)

func (*FullNodeStruct) StateSectorExpiration ¶

func (c *FullNodeStruct) StateSectorExpiration(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorExpiration, error)

func (*FullNodeStruct) StateSectorGetInfo ¶

func (c *FullNodeStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)

func (*FullNodeStruct) StateSectorPartition ¶

func (c *FullNodeStruct) StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok types.TipSetKey) (*miner.SectorLocation, error)

func (*FullNodeStruct) StateSectorPreCommitInfo ¶

func (c *FullNodeStruct) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error)

func (*FullNodeStruct) StateTotalMinedDetail ¶

func (c *FullNodeStruct) StateTotalMinedDetail(ctx context.Context, tsk types.TipSetKey) (*reward.TotalMinedDetail, error)

func (*FullNodeStruct) StateVMCirculatingSupplyInternal ¶

func (c *FullNodeStruct) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)

func (*FullNodeStruct) StateVoteTally ¶

func (c *FullNodeStruct) StateVoteTally(ctx context.Context, tsk types.TipSetKey) (*vote.Tally, error)

func (*FullNodeStruct) StateVoterInfo ¶

func (c *FullNodeStruct) StateVoterInfo(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*vote.VoterInfo, error)

func (*FullNodeStruct) StateWaitMsg ¶

func (c *FullNodeStruct) StateWaitMsg(ctx context.Context, msgc cid.Cid, confidence uint64) (*api.MsgLookup, error)

func (*FullNodeStruct) StateWaitMsgLimited ¶

func (c *FullNodeStruct) StateWaitMsgLimited(ctx context.Context, msgc cid.Cid, confidence uint64, limit abi.ChainEpoch) (*api.MsgLookup, error)

func (*FullNodeStruct) SyncCheckBad ¶

func (c *FullNodeStruct) SyncCheckBad(ctx context.Context, bcid cid.Cid) (string, error)

func (*FullNodeStruct) SyncCheckpoint ¶

func (c *FullNodeStruct) SyncCheckpoint(ctx context.Context, tsk types.TipSetKey) error

func (*FullNodeStruct) SyncIncomingBlocks ¶

func (c *FullNodeStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error)

func (*FullNodeStruct) SyncMarkBad ¶

func (c *FullNodeStruct) SyncMarkBad(ctx context.Context, bcid cid.Cid) error

func (*FullNodeStruct) SyncState ¶

func (c *FullNodeStruct) SyncState(ctx context.Context) (*api.SyncState, error)

func (*FullNodeStruct) SyncSubmitBlock ¶

func (c *FullNodeStruct) SyncSubmitBlock(ctx context.Context, blk *types.BlockMsg) error

func (*FullNodeStruct) SyncUnmarkAllBad ¶

func (c *FullNodeStruct) SyncUnmarkAllBad(ctx context.Context) error

func (*FullNodeStruct) SyncUnmarkBad ¶

func (c *FullNodeStruct) SyncUnmarkBad(ctx context.Context, bcid cid.Cid) error

func (*FullNodeStruct) SyncValidateTipset ¶

func (c *FullNodeStruct) SyncValidateTipset(ctx context.Context, tsk types.TipSetKey) (bool, error)

func (*FullNodeStruct) WalletBalance ¶

func (c *FullNodeStruct) WalletBalance(ctx context.Context, a address.Address) (types.BigInt, error)

func (*FullNodeStruct) WalletDefaultAddress ¶

func (c *FullNodeStruct) WalletDefaultAddress(ctx context.Context) (address.Address, error)

func (*FullNodeStruct) WalletDelete ¶

func (c *FullNodeStruct) WalletDelete(ctx context.Context, addr address.Address) error

func (*FullNodeStruct) WalletExport ¶

func (c *FullNodeStruct) WalletExport(ctx context.Context, a address.Address) (*types.KeyInfo, error)

func (*FullNodeStruct) WalletHas ¶

func (c *FullNodeStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)

func (*FullNodeStruct) WalletImport ¶

func (c *FullNodeStruct) WalletImport(ctx context.Context, ki *types.KeyInfo) (address.Address, error)

func (*FullNodeStruct) WalletList ¶

func (c *FullNodeStruct) WalletList(ctx context.Context) ([]address.Address, error)

func (*FullNodeStruct) WalletNew ¶

func (c *FullNodeStruct) WalletNew(ctx context.Context, typ types.KeyType) (address.Address, error)

func (*FullNodeStruct) WalletSetDefault ¶

func (c *FullNodeStruct) WalletSetDefault(ctx context.Context, a address.Address) error

func (*FullNodeStruct) WalletSign ¶

func (c *FullNodeStruct) WalletSign(ctx context.Context, k address.Address, msg []byte) (*crypto.Signature, error)

func (*FullNodeStruct) WalletSignMessage ¶

func (c *FullNodeStruct) WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error)

func (*FullNodeStruct) WalletValidateAddress ¶

func (c *FullNodeStruct) WalletValidateAddress(ctx context.Context, str string) (address.Address, error)

func (*FullNodeStruct) WalletVerify ¶

func (c *FullNodeStruct) WalletVerify(ctx context.Context, k address.Address, msg []byte, sig *crypto.Signature) (bool, error)

type GatewayStruct ¶

type GatewayStruct struct {
	Internal struct {
		ChainGetBlockMessages   func(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)
		ChainGetMessage         func(ctx context.Context, mc cid.Cid) (*types.Message, error)
		ChainGetTipSet          func(ctx context.Context, tsk types.TipSetKey) (*types.TipSet, error)
		ChainGetTipSetByHeight  func(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)
		ChainHasObj             func(context.Context, cid.Cid) (bool, error)
		ChainHead               func(ctx context.Context) (*types.TipSet, error)
		ChainNotify             func(ctx context.Context) (<-chan []*api.HeadChange, error)
		ChainReadObj            func(context.Context, cid.Cid) ([]byte, error)
		GasEstimateMessageGas   func(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)
		MpoolPush               func(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)
		MsigGetAvailableBalance func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.BigInt, error)
		MsigGetVested           func(ctx context.Context, addr address.Address, start types.TipSetKey, end types.TipSetKey) (types.BigInt, error)
		MsigGetPending          func(context.Context, address.Address, types.TipSetKey) ([]*api.MsigTransaction, error)
		StateAccountKey         func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
		// StateDealProviderCollateralBounds func(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (api.DealCollateralBounds, error)
		StateGetActor             func(ctx context.Context, actor address.Address, ts types.TipSetKey) (*types.Actor, error)
		StateGetReceipt           func(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)
		StateLookupID             func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
		StateListMiners           func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)
		StateMinerInfo            func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)
		StateMinerProvingDeadline func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)
		StateMinerPower           func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error)
		// StateMarketBalance        func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (api.MarketBalance, error)
		StateMarketStorageDeal func(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)
		StateReadState         func(context.Context, address.Address, types.TipSetKey) (*api.ActorState, error)
		StateNetworkVersion    func(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)
		StateSearchMsg         func(ctx context.Context, msg cid.Cid) (*api.MsgLookup, error)
		StateSectorGetInfo     func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)
		// StateVerifiedClientStatus         func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)
		StateWaitMsg func(ctx context.Context, msg cid.Cid, confidence uint64) (*api.MsgLookup, error)
	}
}

func (GatewayStruct) ChainGetBlockMessages ¶

func (g GatewayStruct) ChainGetBlockMessages(ctx context.Context, c cid.Cid) (*api.BlockMessages, error)

func (GatewayStruct) ChainGetMessage ¶

func (g GatewayStruct) ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)

func (GatewayStruct) ChainGetTipSet ¶

func (g GatewayStruct) ChainGetTipSet(ctx context.Context, tsk types.TipSetKey) (*types.TipSet, error)

func (GatewayStruct) ChainGetTipSetByHeight ¶

func (g GatewayStruct) ChainGetTipSetByHeight(ctx context.Context, h abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)

func (GatewayStruct) ChainHasObj ¶

func (g GatewayStruct) ChainHasObj(ctx context.Context, c cid.Cid) (bool, error)

func (GatewayStruct) ChainHead ¶

func (g GatewayStruct) ChainHead(ctx context.Context) (*types.TipSet, error)

func (GatewayStruct) ChainNotify ¶

func (g GatewayStruct) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)

func (GatewayStruct) ChainReadObj ¶

func (g GatewayStruct) ChainReadObj(ctx context.Context, c cid.Cid) ([]byte, error)

func (GatewayStruct) GasEstimateMessageGas ¶

func (g GatewayStruct) GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)

func (GatewayStruct) MpoolPush ¶

func (g GatewayStruct) MpoolPush(ctx context.Context, sm *types.SignedMessage) (cid.Cid, error)

func (GatewayStruct) MsigGetAvailableBalance ¶

func (g GatewayStruct) MsigGetAvailableBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.BigInt, error)

func (GatewayStruct) MsigGetPending ¶

func (g GatewayStruct) MsigGetPending(ctx context.Context, addr address.Address, tsk types.TipSetKey) ([]*api.MsigTransaction, error)

func (GatewayStruct) MsigGetVested ¶

func (g GatewayStruct) MsigGetVested(ctx context.Context, addr address.Address, start types.TipSetKey, end types.TipSetKey) (types.BigInt, error)

func (GatewayStruct) StateAccountKey ¶

func (g GatewayStruct) StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)

func (GatewayStruct) StateGetActor ¶

func (g GatewayStruct) StateGetActor(ctx context.Context, actor address.Address, ts types.TipSetKey) (*types.Actor, error)

func (GatewayStruct) StateGetReceipt ¶

func (g GatewayStruct) StateGetReceipt(ctx context.Context, c cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)

func (GatewayStruct) StateListMiners ¶

func (g GatewayStruct) StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (GatewayStruct) StateLookupID ¶

func (g GatewayStruct) StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)

func (GatewayStruct) StateMarketStorageDeal ¶

func (g GatewayStruct) StateMarketStorageDeal(ctx context.Context, dealId abi.DealID, tsk types.TipSetKey) (*api.MarketDeal, error)

func (GatewayStruct) StateMinerInfo ¶

func (g GatewayStruct) StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (miner.MinerInfo, error)

func (GatewayStruct) StateMinerPower ¶

func (g GatewayStruct) StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.MinerPower, error)

func (GatewayStruct) StateMinerProvingDeadline ¶

func (g GatewayStruct) StateMinerProvingDeadline(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*dline.Info, error)

func (GatewayStruct) StateNetworkVersion ¶

func (g GatewayStruct) StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (stnetwork.Version, error)

func (GatewayStruct) StateReadState ¶

func (g GatewayStruct) StateReadState(ctx context.Context, addr address.Address, ts types.TipSetKey) (*api.ActorState, error)

func (GatewayStruct) StateSectorGetInfo ¶

func (g GatewayStruct) StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*miner.SectorOnChainInfo, error)

func (GatewayStruct) StateWaitMsg ¶

func (g GatewayStruct) StateWaitMsg(ctx context.Context, msg cid.Cid, confidence uint64) (*api.MsgLookup, error)

type StorageMinerStruct ¶

type StorageMinerStruct struct {
	CommonStruct

	Internal struct {
		ActorAddress       func(context.Context) (address.Address, error)                 `perm:"read"`
		ActorSectorSize    func(context.Context, address.Address) (abi.SectorSize, error) `perm:"read"`
		ActorAddressConfig func(ctx context.Context) (api.AddressConfig, error)           `perm:"read"`

		MiningBase func(context.Context) (*types.TipSet, error) `perm:"read"`

		MarketImportDealData      func(context.Context, cid.Cid, string) error                                                                                                                                 `perm:"write"`
		MarketListDeals           func(ctx context.Context) ([]api.MarketDeal, error)                                                                                                                          `perm:"read"`
		MarketListRetrievalDeals  func(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)                                                                                                       `perm:"read"`
		MarketGetDealUpdates      func(ctx context.Context) (<-chan storagemarket.MinerDeal, error)                                                                                                            `perm:"read"`
		MarketListIncompleteDeals func(ctx context.Context) ([]storagemarket.MinerDeal, error)                                                                                                                 `perm:"read"`
		MarketSetAsk              func(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error `perm:"admin"`
		MarketGetAsk              func(ctx context.Context) (*storagemarket.SignedStorageAsk, error)                                                                                                           `perm:"read"`
		MarketSetRetrievalAsk     func(ctx context.Context, rask *retrievalmarket.Ask) error                                                                                                                   `perm:"admin"`
		MarketGetRetrievalAsk     func(ctx context.Context) (*retrievalmarket.Ask, error)                                                                                                                      `perm:"read"`
		MarketListDataTransfers   func(ctx context.Context) ([]api.DataTransferChannel, error)                                                                                                                 `perm:"write"`
		MarketDataTransferUpdates func(ctx context.Context) (<-chan api.DataTransferChannel, error)                                                                                                            `perm:"write"`
		MarketRestartDataTransfer func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                                                     `perm:"write"`
		MarketCancelDataTransfer  func(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error                                                                     `perm:"write"`
		MarketPendingDeals        func(ctx context.Context) (api.PendingDealInfo, error)                                                                                                                       `perm:"write"`
		MarketPublishPendingDeals func(ctx context.Context) error                                                                                                                                              `perm:"admin"`

		PledgeSector func(context.Context) (abi.SectorID, error) `perm:"write"`

		SectorsStatus                 func(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error) `perm:"read"`
		SectorsList                   func(context.Context) ([]abi.SectorNumber, error)                                             `perm:"read"`
		SectorsListInStates           func(context.Context, []api.SectorState) ([]abi.SectorNumber, error)                          `perm:"read"`
		SectorsSummary                func(ctx context.Context) (map[api.SectorState]int, error)                                    `perm:"read"`
		SectorsRefs                   func(context.Context) (map[string][]api.SealedRef, error)                                     `perm:"read"`
		SectorStartSealing            func(context.Context, abi.SectorNumber) error                                                 `perm:"write"`
		SectorSetSealDelay            func(context.Context, time.Duration) error                                                    `perm:"write"`
		SectorGetSealDelay            func(context.Context) (time.Duration, error)                                                  `perm:"read"`
		SectorSetExpectedSealDuration func(context.Context, time.Duration) error                                                    `perm:"write"`
		SectorGetExpectedSealDuration func(context.Context) (time.Duration, error)                                                  `perm:"read"`
		SectorsUpdate                 func(context.Context, abi.SectorNumber, api.SectorState) error                                `perm:"admin"`
		SectorRemove                  func(context.Context, abi.SectorNumber) error                                                 `perm:"admin"`
		SectorTerminate               func(context.Context, abi.SectorNumber) error                                                 `perm:"admin"`
		SectorTerminateFlush          func(ctx context.Context) (*cid.Cid, error)                                                   `perm:"admin"`
		SectorTerminatePending        func(ctx context.Context) ([]abi.SectorID, error)                                             `perm:"admin"`

		WorkerConnect func(context.Context, string) error                                `perm:"admin" retry:"true"` // TODO: worker perm
		WorkerStats   func(context.Context) (map[uuid.UUID]storiface.WorkerStats, error) `perm:"admin"`
		WorkerJobs    func(context.Context) (map[uuid.UUID][]storiface.WorkerJob, error) `perm:"admin"`

		ReturnAddPiece        func(ctx context.Context, callID storiface.CallID, pi abi.PieceInfo, err *storiface.CallError) error          `perm:"admin" retry:"true"`
		ReturnSealPreCommit1  func(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, err *storiface.CallError) error `perm:"admin" retry:"true"`
		ReturnSealPreCommit2  func(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, err *storiface.CallError) error `perm:"admin" retry:"true"`
		ReturnSealCommit1     func(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, err *storiface.CallError) error    `perm:"admin" retry:"true"`
		ReturnSealCommit2     func(ctx context.Context, callID storiface.CallID, proof storage.Proof, err *storiface.CallError) error       `perm:"admin" retry:"true"`
		ReturnFinalizeSector  func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error                            `perm:"admin" retry:"true"`
		ReturnReleaseUnsealed func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error                            `perm:"admin" retry:"true"`
		ReturnMoveStorage     func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error                            `perm:"admin" retry:"true"`
		ReturnUnsealPiece     func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error                            `perm:"admin" retry:"true"`
		ReturnReadPiece       func(ctx context.Context, callID storiface.CallID, ok bool, err *storiface.CallError) error                   `perm:"admin" retry:"true"`
		ReturnFetch           func(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error                            `perm:"admin" retry:"true"`

		SealingSchedDiag func(context.Context, bool) (interface{}, error)       `perm:"admin"`
		SealingAbort     func(ctx context.Context, call storiface.CallID) error `perm:"admin"`

		StorageList          func(context.Context) (map[stores.ID][]stores.Decl, error)                                                                                   `perm:"admin"`
		StorageLocal         func(context.Context) (map[stores.ID]string, error)                                                                                          `perm:"admin"`
		StorageStat          func(context.Context, stores.ID) (fsutil.FsStat, error)                                                                                      `perm:"admin"`
		StorageAttach        func(context.Context, stores.StorageInfo, fsutil.FsStat) error                                                                               `perm:"admin"`
		StorageDeclareSector func(context.Context, stores.ID, abi.SectorID, storiface.SectorFileType, bool) error                                                         `perm:"admin"`
		StorageDropSector    func(context.Context, stores.ID, abi.SectorID, storiface.SectorFileType) error                                                               `perm:"admin"`
		StorageFindSector    func(context.Context, abi.SectorID, storiface.SectorFileType, abi.SectorSize, bool) ([]stores.SectorStorageInfo, error)                      `perm:"admin"`
		StorageInfo          func(context.Context, stores.ID) (stores.StorageInfo, error)                                                                                 `perm:"admin"`
		StorageBestAlloc     func(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, sealing storiface.PathType) ([]stores.StorageInfo, error) `perm:"admin"`
		StorageReportHealth  func(ctx context.Context, id stores.ID, report stores.HealthReport) error                                                                    `perm:"admin"`
		StorageLock          func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) error                          `perm:"admin"`
		StorageTryLock       func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) (bool, error)                  `perm:"admin"`

		DealsImportData                       func(ctx context.Context, dealPropCid cid.Cid, file string) error `perm:"write"`
		DealsList                             func(ctx context.Context) ([]api.MarketDeal, error)               `perm:"read"`
		DealsConsiderOnlineStorageDeals       func(context.Context) (bool, error)                               `perm:"read"`
		DealsSetConsiderOnlineStorageDeals    func(context.Context, bool) error                                 `perm:"admin"`
		DealsConsiderOnlineRetrievalDeals     func(context.Context) (bool, error)                               `perm:"read"`
		DealsSetConsiderOnlineRetrievalDeals  func(context.Context, bool) error                                 `perm:"admin"`
		DealsConsiderOfflineStorageDeals      func(context.Context) (bool, error)                               `perm:"read"`
		DealsSetConsiderOfflineStorageDeals   func(context.Context, bool) error                                 `perm:"admin"`
		DealsConsiderOfflineRetrievalDeals    func(context.Context) (bool, error)                               `perm:"read"`
		DealsSetConsiderOfflineRetrievalDeals func(context.Context, bool) error                                 `perm:"admin"`
		DealsPieceCidBlocklist                func(context.Context) ([]cid.Cid, error)                          `perm:"read"`
		DealsSetPieceCidBlocklist             func(context.Context, []cid.Cid) error                            `perm:"admin"`

		StorageAddLocal func(ctx context.Context, path string) error `perm:"admin"`

		PiecesListPieces   func(ctx context.Context) ([]cid.Cid, error)                               `perm:"read"`
		PiecesListCidInfos func(ctx context.Context) ([]cid.Cid, error)                               `perm:"read"`
		PiecesGetPieceInfo func(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error) `perm:"read"`
		PiecesGetCIDInfo   func(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error) `perm:"read"`

		CreateBackup func(ctx context.Context, fpath string) error `perm:"admin"`

		CheckProvable func(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, expensive bool) (map[abi.SectorNumber]string, error) `perm:"admin"`
	}
}

func (*StorageMinerStruct) ActorAddress ¶

func (c *StorageMinerStruct) ActorAddress(ctx context.Context) (address.Address, error)

func (*StorageMinerStruct) ActorAddressConfig ¶

func (c *StorageMinerStruct) ActorAddressConfig(ctx context.Context) (api.AddressConfig, error)

func (*StorageMinerStruct) ActorSectorSize ¶

func (c *StorageMinerStruct) ActorSectorSize(ctx context.Context, addr address.Address) (abi.SectorSize, error)

func (*StorageMinerStruct) CheckProvable ¶

func (c *StorageMinerStruct) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, expensive bool) (map[abi.SectorNumber]string, error)

func (*StorageMinerStruct) CreateBackup ¶

func (c *StorageMinerStruct) CreateBackup(ctx context.Context, fpath string) error

func (*StorageMinerStruct) DealsConsiderOfflineRetrievalDeals ¶

func (c *StorageMinerStruct) DealsConsiderOfflineRetrievalDeals(ctx context.Context) (bool, error)

func (*StorageMinerStruct) DealsConsiderOfflineStorageDeals ¶

func (c *StorageMinerStruct) DealsConsiderOfflineStorageDeals(ctx context.Context) (bool, error)

func (*StorageMinerStruct) DealsConsiderOnlineRetrievalDeals ¶

func (c *StorageMinerStruct) DealsConsiderOnlineRetrievalDeals(ctx context.Context) (bool, error)

func (*StorageMinerStruct) DealsConsiderOnlineStorageDeals ¶

func (c *StorageMinerStruct) DealsConsiderOnlineStorageDeals(ctx context.Context) (bool, error)

func (*StorageMinerStruct) DealsImportData ¶

func (c *StorageMinerStruct) DealsImportData(ctx context.Context, dealPropCid cid.Cid, file string) error

func (*StorageMinerStruct) DealsList ¶

func (c *StorageMinerStruct) DealsList(ctx context.Context) ([]api.MarketDeal, error)

func (*StorageMinerStruct) DealsPieceCidBlocklist ¶

func (c *StorageMinerStruct) DealsPieceCidBlocklist(ctx context.Context) ([]cid.Cid, error)

func (*StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals ¶

func (c *StorageMinerStruct) DealsSetConsiderOfflineRetrievalDeals(ctx context.Context, b bool) error

func (*StorageMinerStruct) DealsSetConsiderOfflineStorageDeals ¶

func (c *StorageMinerStruct) DealsSetConsiderOfflineStorageDeals(ctx context.Context, b bool) error

func (*StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals ¶

func (c *StorageMinerStruct) DealsSetConsiderOnlineRetrievalDeals(ctx context.Context, b bool) error

func (*StorageMinerStruct) DealsSetConsiderOnlineStorageDeals ¶

func (c *StorageMinerStruct) DealsSetConsiderOnlineStorageDeals(ctx context.Context, b bool) error

func (*StorageMinerStruct) DealsSetPieceCidBlocklist ¶

func (c *StorageMinerStruct) DealsSetPieceCidBlocklist(ctx context.Context, cids []cid.Cid) error

func (*StorageMinerStruct) MarketCancelDataTransfer ¶

func (c *StorageMinerStruct) MarketCancelDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*StorageMinerStruct) MarketDataTransferUpdates ¶

func (c *StorageMinerStruct) MarketDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)

func (*StorageMinerStruct) MarketGetAsk ¶

func (c *StorageMinerStruct) MarketGetAsk(ctx context.Context) (*storagemarket.SignedStorageAsk, error)

func (*StorageMinerStruct) MarketGetDealUpdates ¶

func (c *StorageMinerStruct) MarketGetDealUpdates(ctx context.Context) (<-chan storagemarket.MinerDeal, error)

func (*StorageMinerStruct) MarketGetRetrievalAsk ¶

func (c *StorageMinerStruct) MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)

func (*StorageMinerStruct) MarketImportDealData ¶

func (c *StorageMinerStruct) MarketImportDealData(ctx context.Context, propcid cid.Cid, path string) error

func (*StorageMinerStruct) MarketListDataTransfers ¶

func (c *StorageMinerStruct) MarketListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)

func (*StorageMinerStruct) MarketListDeals ¶

func (c *StorageMinerStruct) MarketListDeals(ctx context.Context) ([]api.MarketDeal, error)

func (*StorageMinerStruct) MarketListIncompleteDeals ¶

func (c *StorageMinerStruct) MarketListIncompleteDeals(ctx context.Context) ([]storagemarket.MinerDeal, error)

func (*StorageMinerStruct) MarketListRetrievalDeals ¶

func (c *StorageMinerStruct) MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)

func (*StorageMinerStruct) MarketPendingDeals ¶

func (c *StorageMinerStruct) MarketPendingDeals(ctx context.Context) (api.PendingDealInfo, error)

func (*StorageMinerStruct) MarketPublishPendingDeals ¶

func (c *StorageMinerStruct) MarketPublishPendingDeals(ctx context.Context) error

func (*StorageMinerStruct) MarketRestartDataTransfer ¶

func (c *StorageMinerStruct) MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error

func (*StorageMinerStruct) MarketSetAsk ¶

func (c *StorageMinerStruct) MarketSetAsk(ctx context.Context, price types.BigInt, verifiedPrice types.BigInt, duration abi.ChainEpoch, minPieceSize abi.PaddedPieceSize, maxPieceSize abi.PaddedPieceSize) error

func (*StorageMinerStruct) MarketSetRetrievalAsk ¶

func (c *StorageMinerStruct) MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error

func (*StorageMinerStruct) MiningBase ¶

func (c *StorageMinerStruct) MiningBase(ctx context.Context) (*types.TipSet, error)

func (*StorageMinerStruct) PiecesGetCIDInfo ¶

func (c *StorageMinerStruct) PiecesGetCIDInfo(ctx context.Context, payloadCid cid.Cid) (*piecestore.CIDInfo, error)

func (*StorageMinerStruct) PiecesGetPieceInfo ¶

func (c *StorageMinerStruct) PiecesGetPieceInfo(ctx context.Context, pieceCid cid.Cid) (*piecestore.PieceInfo, error)

func (*StorageMinerStruct) PiecesListCidInfos ¶

func (c *StorageMinerStruct) PiecesListCidInfos(ctx context.Context) ([]cid.Cid, error)

func (*StorageMinerStruct) PiecesListPieces ¶

func (c *StorageMinerStruct) PiecesListPieces(ctx context.Context) ([]cid.Cid, error)

func (*StorageMinerStruct) PledgeSector ¶

func (c *StorageMinerStruct) PledgeSector(ctx context.Context) (abi.SectorID, error)

func (*StorageMinerStruct) ReturnAddPiece ¶

func (c *StorageMinerStruct) ReturnAddPiece(ctx context.Context, callID storiface.CallID, pi abi.PieceInfo, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnFetch ¶

func (c *StorageMinerStruct) ReturnFetch(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnFinalizeSector ¶

func (c *StorageMinerStruct) ReturnFinalizeSector(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnMoveStorage ¶

func (c *StorageMinerStruct) ReturnMoveStorage(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnReadPiece ¶

func (c *StorageMinerStruct) ReturnReadPiece(ctx context.Context, callID storiface.CallID, ok bool, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnReleaseUnsealed ¶

func (c *StorageMinerStruct) ReturnReleaseUnsealed(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnSealCommit1 ¶

func (c *StorageMinerStruct) ReturnSealCommit1(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnSealCommit2 ¶

func (c *StorageMinerStruct) ReturnSealCommit2(ctx context.Context, callID storiface.CallID, proof storage.Proof, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnSealPreCommit1 ¶

func (c *StorageMinerStruct) ReturnSealPreCommit1(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnSealPreCommit2 ¶

func (c *StorageMinerStruct) ReturnSealPreCommit2(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, err *storiface.CallError) error

func (*StorageMinerStruct) ReturnUnsealPiece ¶

func (c *StorageMinerStruct) ReturnUnsealPiece(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error

func (*StorageMinerStruct) SealingAbort ¶

func (c *StorageMinerStruct) SealingAbort(ctx context.Context, call storiface.CallID) error

func (*StorageMinerStruct) SealingSchedDiag ¶

func (c *StorageMinerStruct) SealingSchedDiag(ctx context.Context, doSched bool) (interface{}, error)

func (*StorageMinerStruct) SectorGetExpectedSealDuration ¶

func (c *StorageMinerStruct) SectorGetExpectedSealDuration(ctx context.Context) (time.Duration, error)

func (*StorageMinerStruct) SectorGetSealDelay ¶

func (c *StorageMinerStruct) SectorGetSealDelay(ctx context.Context) (time.Duration, error)

func (*StorageMinerStruct) SectorRemove ¶

func (c *StorageMinerStruct) SectorRemove(ctx context.Context, number abi.SectorNumber) error

func (*StorageMinerStruct) SectorSetExpectedSealDuration ¶

func (c *StorageMinerStruct) SectorSetExpectedSealDuration(ctx context.Context, delay time.Duration) error

func (*StorageMinerStruct) SectorSetSealDelay ¶

func (c *StorageMinerStruct) SectorSetSealDelay(ctx context.Context, delay time.Duration) error

func (*StorageMinerStruct) SectorStartSealing ¶

func (c *StorageMinerStruct) SectorStartSealing(ctx context.Context, number abi.SectorNumber) error

func (*StorageMinerStruct) SectorTerminate ¶

func (c *StorageMinerStruct) SectorTerminate(ctx context.Context, number abi.SectorNumber) error

func (*StorageMinerStruct) SectorTerminateFlush ¶

func (c *StorageMinerStruct) SectorTerminateFlush(ctx context.Context) (*cid.Cid, error)

func (*StorageMinerStruct) SectorTerminatePending ¶

func (c *StorageMinerStruct) SectorTerminatePending(ctx context.Context) ([]abi.SectorID, error)

func (*StorageMinerStruct) SectorsList ¶

func (c *StorageMinerStruct) SectorsList(ctx context.Context) ([]abi.SectorNumber, error)

List all staged sectors

func (*StorageMinerStruct) SectorsListInStates ¶

func (c *StorageMinerStruct) SectorsListInStates(ctx context.Context, states []api.SectorState) ([]abi.SectorNumber, error)

func (*StorageMinerStruct) SectorsRefs ¶

func (c *StorageMinerStruct) SectorsRefs(ctx context.Context) (map[string][]api.SealedRef, error)

func (*StorageMinerStruct) SectorsStatus ¶

func (c *StorageMinerStruct) SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)

Get the status of a given sector by ID

func (*StorageMinerStruct) SectorsSummary ¶

func (c *StorageMinerStruct) SectorsSummary(ctx context.Context) (map[api.SectorState]int, error)

func (*StorageMinerStruct) SectorsUpdate ¶

func (c *StorageMinerStruct) SectorsUpdate(ctx context.Context, id abi.SectorNumber, state api.SectorState) error

func (*StorageMinerStruct) StorageAddLocal ¶

func (c *StorageMinerStruct) StorageAddLocal(ctx context.Context, path string) error

func (*StorageMinerStruct) StorageAttach ¶

func (c *StorageMinerStruct) StorageAttach(ctx context.Context, si stores.StorageInfo, st fsutil.FsStat) error

func (*StorageMinerStruct) StorageBestAlloc ¶

func (c *StorageMinerStruct) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, pt storiface.PathType) ([]stores.StorageInfo, error)

func (*StorageMinerStruct) StorageDeclareSector ¶

func (c *StorageMinerStruct) StorageDeclareSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ft storiface.SectorFileType, primary bool) error

func (*StorageMinerStruct) StorageDropSector ¶

func (c *StorageMinerStruct) StorageDropSector(ctx context.Context, storageId stores.ID, s abi.SectorID, ft storiface.SectorFileType) error

func (*StorageMinerStruct) StorageFindSector ¶

func (c *StorageMinerStruct) StorageFindSector(ctx context.Context, si abi.SectorID, types storiface.SectorFileType, ssize abi.SectorSize, allowFetch bool) ([]stores.SectorStorageInfo, error)

func (*StorageMinerStruct) StorageInfo ¶

func (c *StorageMinerStruct) StorageInfo(ctx context.Context, id stores.ID) (stores.StorageInfo, error)

func (*StorageMinerStruct) StorageList ¶

func (c *StorageMinerStruct) StorageList(ctx context.Context) (map[stores.ID][]stores.Decl, error)

func (*StorageMinerStruct) StorageLocal ¶

func (c *StorageMinerStruct) StorageLocal(ctx context.Context) (map[stores.ID]string, error)

func (*StorageMinerStruct) StorageLock ¶

func (c *StorageMinerStruct) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) error

func (*StorageMinerStruct) StorageReportHealth ¶

func (c *StorageMinerStruct) StorageReportHealth(ctx context.Context, id stores.ID, report stores.HealthReport) error

func (*StorageMinerStruct) StorageStat ¶

func (c *StorageMinerStruct) StorageStat(ctx context.Context, id stores.ID) (fsutil.FsStat, error)

func (*StorageMinerStruct) StorageTryLock ¶

func (c *StorageMinerStruct) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, write storiface.SectorFileType) (bool, error)

func (*StorageMinerStruct) WorkerConnect ¶

func (c *StorageMinerStruct) WorkerConnect(ctx context.Context, url string) error

func (*StorageMinerStruct) WorkerJobs ¶

func (c *StorageMinerStruct) WorkerJobs(ctx context.Context) (map[uuid.UUID][]storiface.WorkerJob, error)

func (*StorageMinerStruct) WorkerStats ¶

func (c *StorageMinerStruct) WorkerStats(ctx context.Context) (map[uuid.UUID]storiface.WorkerStats, error)

type WalletStruct ¶

type WalletStruct struct {
	Internal struct {
		WalletNew    func(context.Context, types.KeyType) (address.Address, error)                          `perm:"write"`
		WalletHas    func(context.Context, address.Address) (bool, error)                                   `perm:"write"`
		WalletList   func(context.Context) ([]address.Address, error)                                       `perm:"write"`
		WalletSign   func(context.Context, address.Address, []byte, api.MsgMeta) (*crypto.Signature, error) `perm:"sign"`
		WalletExport func(context.Context, address.Address) (*types.KeyInfo, error)                         `perm:"admin"`
		WalletImport func(context.Context, *types.KeyInfo) (address.Address, error)                         `perm:"admin"`
		WalletDelete func(context.Context, address.Address) error                                           `perm:"write"`
	}
}

func (*WalletStruct) WalletDelete ¶

func (c *WalletStruct) WalletDelete(ctx context.Context, addr address.Address) error

func (*WalletStruct) WalletExport ¶

func (c *WalletStruct) WalletExport(ctx context.Context, a address.Address) (*types.KeyInfo, error)

func (*WalletStruct) WalletHas ¶

func (c *WalletStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error)

func (*WalletStruct) WalletImport ¶

func (c *WalletStruct) WalletImport(ctx context.Context, ki *types.KeyInfo) (address.Address, error)

func (*WalletStruct) WalletList ¶

func (c *WalletStruct) WalletList(ctx context.Context) ([]address.Address, error)

func (*WalletStruct) WalletNew ¶

func (c *WalletStruct) WalletNew(ctx context.Context, typ types.KeyType) (address.Address, error)

func (*WalletStruct) WalletSign ¶

func (c *WalletStruct) WalletSign(ctx context.Context, k address.Address, msg []byte, meta api.MsgMeta) (*crypto.Signature, error)

type WorkerStruct ¶

type WorkerStruct struct {
	Internal struct {
		Version func(context.Context) (api.Version, error) `perm:"admin"`

		TaskTypes func(context.Context) (map[sealtasks.TaskType]struct{}, error) `perm:"admin"`
		Paths     func(context.Context) ([]stores.StoragePath, error)            `perm:"admin"`
		Info      func(context.Context) (storiface.WorkerInfo, error)            `perm:"admin"`

		AddPiece        func(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (storiface.CallID, error)                 `perm:"admin"`
		SealPreCommit1  func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, pieces []abi.PieceInfo) (storiface.CallID, error)                                                              `perm:"admin"`
		SealPreCommit2  func(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error)                                                                                     `perm:"admin"`
		SealCommit1     func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (storiface.CallID, error) `perm:"admin"`
		SealCommit2     func(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error)                                                                                         `perm:"admin"`
		FinalizeSector  func(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (storiface.CallID, error)                                                                                   `perm:"admin"`
		ReleaseUnsealed func(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (storiface.CallID, error)                                                                                     `perm:"admin"`
		MoveStorage     func(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error)                                                                                 `perm:"admin"`
		UnsealPiece     func(context.Context, storage.SectorRef, storiface.UnpaddedByteIndex, abi.UnpaddedPieceSize, abi.SealRandomness, cid.Cid) (storiface.CallID, error)                                           `perm:"admin"`
		ReadPiece       func(context.Context, io.Writer, storage.SectorRef, storiface.UnpaddedByteIndex, abi.UnpaddedPieceSize) (storiface.CallID, error)                                                             `perm:"admin"`
		Fetch           func(context.Context, storage.SectorRef, storiface.SectorFileType, storiface.PathType, storiface.AcquireMode) (storiface.CallID, error)                                                       `perm:"admin"`

		TaskDisable func(ctx context.Context, tt sealtasks.TaskType) error `perm:"admin"`
		TaskEnable  func(ctx context.Context, tt sealtasks.TaskType) error `perm:"admin"`

		Remove          func(ctx context.Context, sector abi.SectorID) error `perm:"admin"`
		StorageAddLocal func(ctx context.Context, path string) error         `perm:"admin"`

		SetEnabled func(ctx context.Context, enabled bool) error `perm:"admin"`
		Enabled    func(ctx context.Context) (bool, error)       `perm:"admin"`

		WaitQuiet func(ctx context.Context) error `perm:"admin"`

		ProcessSession func(context.Context) (uuid.UUID, error) `perm:"admin"`
		Session        func(context.Context) (uuid.UUID, error) `perm:"admin"`
	}
}

func (*WorkerStruct) AddPiece ¶

func (w *WorkerStruct) AddPiece(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (storiface.CallID, error)

func (*WorkerStruct) Enabled ¶

func (w *WorkerStruct) Enabled(ctx context.Context) (bool, error)

func (*WorkerStruct) Fetch ¶

func (w *WorkerStruct) Fetch(ctx context.Context, id storage.SectorRef, fileType storiface.SectorFileType, ptype storiface.PathType, am storiface.AcquireMode) (storiface.CallID, error)

func (*WorkerStruct) FinalizeSector ¶

func (w *WorkerStruct) FinalizeSector(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (storiface.CallID, error)

func (*WorkerStruct) Info ¶

func (w *WorkerStruct) Info(ctx context.Context) (storiface.WorkerInfo, error)

func (*WorkerStruct) MoveStorage ¶

func (w *WorkerStruct) MoveStorage(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error)

func (*WorkerStruct) Paths ¶

func (w *WorkerStruct) Paths(ctx context.Context) ([]stores.StoragePath, error)

func (*WorkerStruct) ProcessSession ¶

func (w *WorkerStruct) ProcessSession(ctx context.Context) (uuid.UUID, error)

func (*WorkerStruct) ReadPiece ¶

func (w *WorkerStruct) ReadPiece(ctx context.Context, sink io.Writer, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) (storiface.CallID, error)

func (*WorkerStruct) ReleaseUnsealed ¶

func (w *WorkerStruct) ReleaseUnsealed(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (storiface.CallID, error)

func (*WorkerStruct) Remove ¶

func (w *WorkerStruct) Remove(ctx context.Context, sector abi.SectorID) error

func (*WorkerStruct) SealCommit1 ¶

func (w *WorkerStruct) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (storiface.CallID, error)

func (*WorkerStruct) SealCommit2 ¶

func (w *WorkerStruct) SealCommit2(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storiface.CallID, error)

func (*WorkerStruct) SealPreCommit1 ¶

func (w *WorkerStruct) SealPreCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, pieces []abi.PieceInfo) (storiface.CallID, error)

func (*WorkerStruct) SealPreCommit2 ¶

func (w *WorkerStruct) SealPreCommit2(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storiface.CallID, error)

func (*WorkerStruct) Session ¶

func (w *WorkerStruct) Session(ctx context.Context) (uuid.UUID, error)

func (*WorkerStruct) SetEnabled ¶

func (w *WorkerStruct) SetEnabled(ctx context.Context, enabled bool) error

func (*WorkerStruct) StorageAddLocal ¶

func (w *WorkerStruct) StorageAddLocal(ctx context.Context, path string) error

func (*WorkerStruct) TaskDisable ¶

func (w *WorkerStruct) TaskDisable(ctx context.Context, tt sealtasks.TaskType) error

func (*WorkerStruct) TaskEnable ¶

func (w *WorkerStruct) TaskEnable(ctx context.Context, tt sealtasks.TaskType) error

func (*WorkerStruct) TaskTypes ¶

func (w *WorkerStruct) TaskTypes(ctx context.Context) (map[sealtasks.TaskType]struct{}, error)

func (*WorkerStruct) UnsealPiece ¶

func (w *WorkerStruct) UnsealPiece(ctx context.Context, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize, ticket abi.SealRandomness, c cid.Cid) (storiface.CallID, error)

func (*WorkerStruct) Version ¶

func (w *WorkerStruct) Version(ctx context.Context) (api.Version, error)

func (*WorkerStruct) WaitQuiet ¶

func (w *WorkerStruct) WaitQuiet(ctx context.Context) error

Source Files ¶

View all Source files

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