v1

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Nov 14, 2024 License: Apache-2.0, MIT Imports: 26 Imported by: 59

Documentation

Overview

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Index

Constants

View Source
const APINamespace = "v1.FullNode"
View Source
const MajorVersion = 1
View Source
const MethodNamespace = "Filecoin"

Variables

This section is empty.

Functions

This section is empty.

Types

type EthSubscriber added in v1.10.0

type EthSubscriber interface {
	// note: the parameter is types.EthSubscriptionResponse serialized as json object
	EthSubscription(ctx context.Context, params jsonrpc.RawParams) error //rpc_method:eth_subscription notify:true
}

reverse interface to the client, called after EthSubscribe

type EthSubscriberMethods added in v1.10.0

type EthSubscriberMethods struct {
	EthSubscription func(p0 context.Context, p1 jsonrpc.RawParams) error `notify:"true" rpc_method:"eth_subscription"`
}

type EthSubscriberStruct added in v1.10.0

type EthSubscriberStruct struct {
	EthSubscriberMethods
}

todo: generate by venus-devtool

type FullETH added in v1.10.0

type FullETH interface {
	IETH
	IETHEvent
}

type FullETHStruct added in v1.10.0

type FullETHStruct struct {
	IETHStruct
	IETHEventStruct
}

type FullNode

func DialFullNodeRPC added in v1.2.2

func DialFullNodeRPC(ctx context.Context, addr string, token string, requestHeader http.Header, opts ...FullNodeOption) (FullNode, jsonrpc.ClientCloser, error)

DialFullNodeRPC is a more convinient way of building client, as it resolves any format (url, multiaddr) of addr string.

func NewFullNodeRPC

func NewFullNodeRPC(ctx context.Context, addr string, requestHeader http.Header, opts ...FullNodeOption) (FullNode, jsonrpc.ClientCloser, error)

NewFullNodeRPC creates a new httpparse jsonrpc remotecli.

type FullNodeOption added in v1.10.0

type FullNodeOption func(*FullNodeOptions)

func FullNodeWithEthSubscribtionHandler added in v1.10.0

func FullNodeWithEthSubscribtionHandler(sh EthSubscriber) FullNodeOption

func FullNodeWithRPCOtpions added in v1.10.0

func FullNodeWithRPCOtpions(rpcOpts ...jsonrpc.Option) FullNodeOption

type FullNodeOptions added in v1.10.0

type FullNodeOptions struct {
	// contains filtered or unexported fields
}

type IAccount

type IAccount interface {
	StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error) //perm:read
}

type IAccountStruct

type IAccountStruct struct {
	Internal struct {
		StateAccountKey func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error) `perm:"read"`
	}
}

func (*IAccountStruct) StateAccountKey

func (s *IAccountStruct) StateAccountKey(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)

type IActor

type IActor interface {
	StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error) //perm:read
	ListActor(ctx context.Context) (map[address.Address]*types.Actor, error)                             //perm:read
}

type IActorEvent added in v1.15.0

type IActorEvent interface {

	// GetActorEventsRaw returns all user-programmed and built-in actor events that match the given
	// filter.
	// This is a request/response API.
	// Results available from this API may be limited by the MaxFilterResults and MaxFilterHeightRange
	// configuration options and also the amount of historical data available in the node.
	//
	// This is an EXPERIMENTAL API and may be subject to change.
	GetActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error) //perm:read

	// SubscribeActorEventsRaw returns a long-lived stream of all user-programmed and built-in actor
	// events that match the given filter.
	// Events that match the given filter are written to the stream in real-time as they are emitted
	// from the FVM.
	// The response stream is closed when the client disconnects, when a ToHeight is specified and is
	// reached, or if there is an error while writing an event to the stream.
	// This API also allows clients to read all historical events matching the given filter before any
	// real-time events are written to the response stream if the filter specifies an earlier
	// FromHeight.
	// Results available from this API may be limited by the MaxFilterResults and MaxFilterHeightRange
	// configuration options and also the amount of historical data available in the node.
	//
	// Note: this API is only available via websocket connections.
	// This is an EXPERIMENTAL API and may be subject to change.
	SubscribeActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error) //perm:read
}

type IActorEventStruct added in v1.15.0

type IActorEventStruct struct {
	Internal struct {
		GetActorEventsRaw       func(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)      `perm:"read"`
		SubscribeActorEventsRaw func(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error) `perm:"read"`
	}
}

func (*IActorEventStruct) GetActorEventsRaw added in v1.15.0

func (s *IActorEventStruct) GetActorEventsRaw(p0 context.Context, p1 *types.ActorEventFilter) ([]*types.ActorEvent, error)

func (*IActorEventStruct) SubscribeActorEventsRaw added in v1.15.0

func (s *IActorEventStruct) SubscribeActorEventsRaw(p0 context.Context, p1 *types.ActorEventFilter) (<-chan *types.ActorEvent, error)

type IActorStruct

type IActorStruct struct {
	Internal struct {
		ListActor     func(ctx context.Context) (map[address.Address]*types.Actor, error)                         `perm:"read"`
		StateGetActor func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error) `perm:"read"`
	}
}

func (*IActorStruct) ListActor

func (s *IActorStruct) ListActor(p0 context.Context) (map[address.Address]*types.Actor, error)

func (*IActorStruct) StateGetActor

func (s *IActorStruct) StateGetActor(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.Actor, error)

type IBlockStore

type IBlockStore interface {
	ChainReadObj(ctx context.Context, cid cid.Cid) ([]byte, error)                      //perm:read
	ChainDeleteObj(ctx context.Context, obj cid.Cid) error                              //perm:admin
	ChainHasObj(ctx context.Context, obj cid.Cid) (bool, error)                         //perm:read
	ChainStatObj(ctx context.Context, obj cid.Cid, base cid.Cid) (types.ObjStat, error) //perm:read
	// ChainPutObj puts a given object into the block store
	ChainPutObj(context.Context, blocks.Block) error //perm:admin
}

type IBlockStoreStruct

type IBlockStoreStruct struct {
	Internal struct {
		ChainDeleteObj func(ctx context.Context, obj cid.Cid) error                                `perm:"admin"`
		ChainHasObj    func(ctx context.Context, obj cid.Cid) (bool, error)                        `perm:"read"`
		ChainPutObj    func(context.Context, blocks.Block) error                                   `perm:"admin"`
		ChainReadObj   func(ctx context.Context, cid cid.Cid) ([]byte, error)                      `perm:"read"`
		ChainStatObj   func(ctx context.Context, obj cid.Cid, base cid.Cid) (types.ObjStat, error) `perm:"read"`
	}
}

func (*IBlockStoreStruct) ChainDeleteObj

func (s *IBlockStoreStruct) ChainDeleteObj(p0 context.Context, p1 cid.Cid) error

func (*IBlockStoreStruct) ChainHasObj

func (s *IBlockStoreStruct) ChainHasObj(p0 context.Context, p1 cid.Cid) (bool, error)

func (*IBlockStoreStruct) ChainPutObj added in v1.6.0

func (s *IBlockStoreStruct) ChainPutObj(p0 context.Context, p1 blocks.Block) error

func (*IBlockStoreStruct) ChainReadObj

func (s *IBlockStoreStruct) ChainReadObj(p0 context.Context, p1 cid.Cid) ([]byte, error)

func (*IBlockStoreStruct) ChainStatObj

func (s *IBlockStoreStruct) ChainStatObj(p0 context.Context, p1 cid.Cid, p2 cid.Cid) (types.ObjStat, error)

type IChain

type IChain interface {
	IAccount
	IActor
	IMinerState
	IChainInfo
}

type IChainInfo

type IChainInfo interface {
	BlockTime(ctx context.Context) time.Duration                                                                                                                                          //perm:read
	ChainList(ctx context.Context, tsKey types.TipSetKey, count int) ([]types.TipSetKey, error)                                                                                           //perm:read
	ChainHead(ctx context.Context) (*types.TipSet, error)                                                                                                                                 //perm:read
	ChainSetHead(ctx context.Context, key types.TipSetKey) error                                                                                                                          //perm:admin
	ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error)                                                                                                       //perm:read
	ChainGetTipSetByHeight(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)                                                                        //perm:read
	ChainGetTipSetAfterHeight(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)                                                                     //perm:read
	StateGetRandomnessFromTickets(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
	StateGetRandomnessFromBeacon(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error)  //perm:read
	// StateGetRandomnessDigestFromTickets is used to sample the chain for randomness.
	StateGetRandomnessDigestFromTickets(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
	// StateGetRandomnessDigestFromBeacon is used to sample the beacon for randomness.
	StateGetRandomnessDigestFromBeacon(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error) //perm:read
	// StateGetBeaconEntry returns the beacon entry for the given filecoin epoch
	// by using the recorded entries on the chain. If the entry for the requested
	// epoch has not yet been produced, the call will block until the entry
	// becomes available.
	StateGetBeaconEntry(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)                     //perm:read
	ChainGetBlock(ctx context.Context, id cid.Cid) (*types.BlockHeader, error)                                     //perm:read
	ChainGetMessage(ctx context.Context, msgID cid.Cid) (*types.Message, error)                                    //perm:read
	ChainGetBlockMessages(ctx context.Context, bid cid.Cid) (*types.BlockMessages, error)                          //perm:read
	ChainGetMessagesInTipset(ctx context.Context, key types.TipSetKey) ([]types.MessageCID, error)                 //perm:read
	ChainGetReceipts(ctx context.Context, id cid.Cid) ([]types.MessageReceipt, error)                              //perm:read
	ChainGetParentMessages(ctx context.Context, bcid cid.Cid) ([]types.MessageCID, error)                          //perm:read
	ChainGetParentReceipts(ctx context.Context, bcid cid.Cid) ([]*types.MessageReceipt, error)                     //perm:read
	StateVerifiedRegistryRootKey(ctx context.Context, tsk types.TipSetKey) (address.Address, error)                //perm:read
	StateVerifierStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error) //perm:read
	ChainNotify(ctx context.Context) (<-chan []*types.HeadChange, error)                                           //perm:read
	GetFullBlock(ctx context.Context, id cid.Cid) (*types.FullBlock, error)                                        //perm:read
	GetActor(ctx context.Context, addr address.Address) (*types.Actor, error)                                      //perm:read
	GetParentStateRootActor(ctx context.Context, ts *types.TipSet, addr address.Address) (*types.Actor, error)     //perm:read
	GetEntry(ctx context.Context, height abi.ChainEpoch, round uint64) (*types.BeaconEntry, error)                 //perm:read
	ProtocolParameters(ctx context.Context) (*types.ProtocolParams, error)                                         //perm:read
	ResolveToKeyAddr(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error)         //perm:read
	StateNetworkName(ctx context.Context) (types.NetworkName, error)                                               //perm:read
	// StateSearchMsg looks back up to limit epochs in the chain for a message, and returns its receipt and the tipset where it was executed
	//
	// NOTE: If a replacing message is found on chain, this method will return
	// a MsgLookup for the replacing message - the MsgLookup.Message will be a different
	// CID than the one provided in the 'cid' param, MsgLookup.Receipt will contain the
	// result of the execution of the replacing message.
	//
	// If the caller wants to ensure that exactly the requested message was executed,
	// they must check that MsgLookup.Message is equal to the provided 'cid', or set the
	// `allowReplaced` parameter to false. Without this check, and with `allowReplaced`
	// set to true, both the requested and original message may appear as
	// successfully executed on-chain, which may look like a double-spend.
	//
	// A replacing message is a message with a different CID, any of Gas values, and
	// different signature, but with all other parameters matching (source/destination,
	// nonce, params, etc.)
	StateSearchMsg(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) //perm:read
	// StateWaitMsg looks back up to limit epochs in the chain for a message.
	// If not found, it blocks until the message arrives on chain, and gets to the
	// indicated confidence depth.
	//
	// NOTE: If a replacing message is found on chain, this method will return
	// a MsgLookup for the replacing message - the MsgLookup.Message will be a different
	// CID than the one provided in the 'cid' param, MsgLookup.Receipt will contain the
	// result of the execution of the replacing message.
	//
	// If the caller wants to ensure that exactly the requested message was executed,
	// they must check that MsgLookup.Message is equal to the provided 'cid', or set the
	// `allowReplaced` parameter to false. Without this check, and with `allowReplaced`
	// set to true, both the requested and original message may appear as
	// successfully executed on-chain, which may look like a double-spend.
	//
	// A replacing message is a message with a different CID, any of Gas values, and
	// different signature, but with all other parameters matching (source/destination,
	// nonce, params, etc.)
	StateWaitMsg(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error) //perm:read
	StateNetworkVersion(ctx context.Context, tsk types.TipSetKey) (network.Version, error)                                                //perm:read
	VerifyEntry(parent, child *types.BeaconEntry, height abi.ChainEpoch) bool                                                             //perm:read
	ChainExport(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error)                                            //perm:read
	ChainGetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*types.HeadChange, error)                              //perm:read
	// StateGetNetworkParams return current network params
	StateGetNetworkParams(ctx context.Context) (*types.NetworkParams, error) //perm:read
	// StateActorCodeCIDs returns the CIDs of all the builtin actors for the given network version
	StateActorCodeCIDs(context.Context, network.Version) (map[string]cid.Cid, error) //perm:read
	// ChainGetGenesis returns the genesis tipset.
	ChainGetGenesis(context.Context) (*types.TipSet, error) //perm:read
	// StateActorManifestCID returns the CID of the builtin actors manifest for the given network version
	StateActorManifestCID(context.Context, network.Version) (cid.Cid, error)                            //perm:read
	StateCall(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*types.InvocResult, error) //perm:read
	StateReplay(context.Context, types.TipSetKey, cid.Cid) (*types.InvocResult, error)                  //perm:read
	// ChainGetEvents returns the events under an event AMT root CID.
	ChainGetEvents(context.Context, cid.Cid) ([]types.Event, error) //perm:read
	// StateCompute is a flexible command that applies the given messages on the given tipset.
	// The messages are run as though the VM were at the provided height.
	//
	// When called, StateCompute will:
	// - Load the provided tipset, or use the current chain head if not provided
	// - Compute the tipset state of the provided tipset on top of the parent state
	//   - (note that this step runs before vmheight is applied to the execution)
	//   - Execute state upgrade if any were scheduled at the epoch, or in null
	//     blocks preceding the tipset
	//   - Call the cron actor on null blocks preceding the tipset
	//   - For each block in the tipset
	//     - Apply messages in blocks in the specified
	//     - Award block reward by calling the reward actor
	//   - Call the cron actor for the current epoch
	// - If the specified vmheight is higher than the current epoch, apply any
	//   needed state upgrades to the state
	// - Apply the specified messages to the state
	//
	// The vmheight parameter sets VM execution epoch, and can be used to simulate
	// message execution in different network versions. If the specified vmheight
	// epoch is higher than the epoch of the specified tipset, any state upgrades
	// until the vmheight will be executed on the state before applying messages
	// specified by the user.
	//
	// Note that the initial tipset state computation is not affected by the
	// vmheight parameter - only the messages in the `apply` set are
	//
	// If the caller wants to simply compute the state, vmheight should be set to
	// the epoch of the specified tipset.
	//
	// Messages in the `apply` parameter must have the correct nonces, and gas
	// values set.
	StateCompute(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*types.ComputeStateOutput, error) //perm:read
}

type IChainInfoStruct

type IChainInfoStruct struct {
	Internal struct {
		BlockTime                           func(ctx context.Context) time.Duration                                                                                                                      `perm:"read"`
		ChainExport                         func(context.Context, abi.ChainEpoch, bool, types.TipSetKey) (<-chan []byte, error)                                                                          `perm:"read"`
		ChainGetBlock                       func(ctx context.Context, id cid.Cid) (*types.BlockHeader, error)                                                                                            `perm:"read"`
		ChainGetBlockMessages               func(ctx context.Context, bid cid.Cid) (*types.BlockMessages, error)                                                                                         `perm:"read"`
		ChainGetEvents                      func(context.Context, cid.Cid) ([]types.Event, error)                                                                                                        `perm:"read"`
		ChainGetGenesis                     func(context.Context) (*types.TipSet, error)                                                                                                                 `perm:"read"`
		ChainGetMessage                     func(ctx context.Context, msgID cid.Cid) (*types.Message, error)                                                                                             `perm:"read"`
		ChainGetMessagesInTipset            func(ctx context.Context, key types.TipSetKey) ([]types.MessageCID, error)                                                                                   `perm:"read"`
		ChainGetParentMessages              func(ctx context.Context, bcid cid.Cid) ([]types.MessageCID, error)                                                                                          `perm:"read"`
		ChainGetParentReceipts              func(ctx context.Context, bcid cid.Cid) ([]*types.MessageReceipt, error)                                                                                     `perm:"read"`
		ChainGetPath                        func(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*types.HeadChange, error)                                                             `perm:"read"`
		ChainGetReceipts                    func(ctx context.Context, id cid.Cid) ([]types.MessageReceipt, error)                                                                                        `perm:"read"`
		ChainGetTipSet                      func(ctx context.Context, key types.TipSetKey) (*types.TipSet, error)                                                                                        `perm:"read"`
		ChainGetTipSetAfterHeight           func(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)                                                                 `perm:"read"`
		ChainGetTipSetByHeight              func(ctx context.Context, height abi.ChainEpoch, tsk types.TipSetKey) (*types.TipSet, error)                                                                 `perm:"read"`
		ChainHead                           func(ctx context.Context) (*types.TipSet, error)                                                                                                             `perm:"read"`
		ChainList                           func(ctx context.Context, tsKey types.TipSetKey, count int) ([]types.TipSetKey, error)                                                                       `perm:"read"`
		ChainNotify                         func(ctx context.Context) (<-chan []*types.HeadChange, error)                                                                                                `perm:"read"`
		ChainSetHead                        func(ctx context.Context, key types.TipSetKey) error                                                                                                         `perm:"admin"`
		GetActor                            func(ctx context.Context, addr address.Address) (*types.Actor, error)                                                                                        `perm:"read"`
		GetEntry                            func(ctx context.Context, height abi.ChainEpoch, round uint64) (*types.BeaconEntry, error)                                                                   `perm:"read"`
		GetFullBlock                        func(ctx context.Context, id cid.Cid) (*types.FullBlock, error)                                                                                              `perm:"read"`
		GetParentStateRootActor             func(ctx context.Context, ts *types.TipSet, addr address.Address) (*types.Actor, error)                                                                      `perm:"read"`
		ProtocolParameters                  func(ctx context.Context) (*types.ProtocolParams, error)                                                                                                     `perm:"read"`
		ResolveToKeyAddr                    func(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error)                                                                   `perm:"read"`
		StateActorCodeCIDs                  func(context.Context, network.Version) (map[string]cid.Cid, error)                                                                                           `perm:"read"`
		StateActorManifestCID               func(context.Context, network.Version) (cid.Cid, error)                                                                                                      `perm:"read"`
		StateCall                           func(ctx context.Context, msg *types.Message, tsk types.TipSetKey) (*types.InvocResult, error)                                                               `perm:"read"`
		StateCompute                        func(context.Context, abi.ChainEpoch, []*types.Message, types.TipSetKey) (*types.ComputeStateOutput, error)                                                  `perm:"read"`
		StateGetBeaconEntry                 func(ctx context.Context, epoch abi.ChainEpoch) (*types.BeaconEntry, error)                                                                                  `perm:"read"`
		StateGetNetworkParams               func(ctx context.Context) (*types.NetworkParams, error)                                                                                                      `perm:"read"`
		StateGetRandomnessDigestFromBeacon  func(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error)                                                             `perm:"read"`
		StateGetRandomnessDigestFromTickets func(ctx context.Context, randEpoch abi.ChainEpoch, tsk types.TipSetKey) (abi.Randomness, error)                                                             `perm:"read"`
		StateGetRandomnessFromBeacon        func(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
		StateGetRandomnessFromTickets       func(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error) `perm:"read"`
		StateNetworkName                    func(ctx context.Context) (types.NetworkName, error)                                                                                                         `perm:"read"`
		StateNetworkVersion                 func(ctx context.Context, tsk types.TipSetKey) (network.Version, error)                                                                                      `perm:"read"`
		StateReplay                         func(context.Context, types.TipSetKey, cid.Cid) (*types.InvocResult, error)                                                                                  `perm:"read"`
		StateSearchMsg                      func(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error)                             `perm:"read"`
		StateVerifiedRegistryRootKey        func(ctx context.Context, tsk types.TipSetKey) (address.Address, error)                                                                                      `perm:"read"`
		StateVerifierStatus                 func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)                                                              `perm:"read"`
		StateWaitMsg                        func(ctx context.Context, cid cid.Cid, confidence uint64, limit abi.ChainEpoch, allowReplaced bool) (*types.MsgLookup, error)                                `perm:"read"`
		VerifyEntry                         func(parent, child *types.BeaconEntry, height abi.ChainEpoch) bool                                                                                           `perm:"read"`
	}
}

func (*IChainInfoStruct) BlockTime

func (s *IChainInfoStruct) BlockTime(p0 context.Context) time.Duration

func (*IChainInfoStruct) ChainExport

func (s *IChainInfoStruct) ChainExport(p0 context.Context, p1 abi.ChainEpoch, p2 bool, p3 types.TipSetKey) (<-chan []byte, error)

func (*IChainInfoStruct) ChainGetBlock

func (s *IChainInfoStruct) ChainGetBlock(p0 context.Context, p1 cid.Cid) (*types.BlockHeader, error)

func (*IChainInfoStruct) ChainGetBlockMessages

func (s *IChainInfoStruct) ChainGetBlockMessages(p0 context.Context, p1 cid.Cid) (*types.BlockMessages, error)

func (*IChainInfoStruct) ChainGetEvents added in v1.10.0

func (s *IChainInfoStruct) ChainGetEvents(p0 context.Context, p1 cid.Cid) ([]types.Event, error)

func (*IChainInfoStruct) ChainGetGenesis added in v1.8.0

func (s *IChainInfoStruct) ChainGetGenesis(p0 context.Context) (*types.TipSet, error)

func (*IChainInfoStruct) ChainGetMessage

func (s *IChainInfoStruct) ChainGetMessage(p0 context.Context, p1 cid.Cid) (*types.Message, error)

func (*IChainInfoStruct) ChainGetMessagesInTipset

func (s *IChainInfoStruct) ChainGetMessagesInTipset(p0 context.Context, p1 types.TipSetKey) ([]types.MessageCID, error)

func (*IChainInfoStruct) ChainGetParentMessages

func (s *IChainInfoStruct) ChainGetParentMessages(p0 context.Context, p1 cid.Cid) ([]types.MessageCID, error)

func (*IChainInfoStruct) ChainGetParentReceipts

func (s *IChainInfoStruct) ChainGetParentReceipts(p0 context.Context, p1 cid.Cid) ([]*types.MessageReceipt, error)

func (*IChainInfoStruct) ChainGetPath

func (s *IChainInfoStruct) ChainGetPath(p0 context.Context, p1 types.TipSetKey, p2 types.TipSetKey) ([]*types.HeadChange, error)

func (*IChainInfoStruct) ChainGetReceipts

func (s *IChainInfoStruct) ChainGetReceipts(p0 context.Context, p1 cid.Cid) ([]types.MessageReceipt, error)

func (*IChainInfoStruct) ChainGetTipSet

func (s *IChainInfoStruct) ChainGetTipSet(p0 context.Context, p1 types.TipSetKey) (*types.TipSet, error)

func (*IChainInfoStruct) ChainGetTipSetAfterHeight

func (s *IChainInfoStruct) ChainGetTipSetAfterHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)

func (*IChainInfoStruct) ChainGetTipSetByHeight

func (s *IChainInfoStruct) ChainGetTipSetByHeight(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (*types.TipSet, error)

func (*IChainInfoStruct) ChainHead

func (s *IChainInfoStruct) ChainHead(p0 context.Context) (*types.TipSet, error)

func (*IChainInfoStruct) ChainList

func (s *IChainInfoStruct) ChainList(p0 context.Context, p1 types.TipSetKey, p2 int) ([]types.TipSetKey, error)

func (*IChainInfoStruct) ChainNotify

func (s *IChainInfoStruct) ChainNotify(p0 context.Context) (<-chan []*types.HeadChange, error)

func (*IChainInfoStruct) ChainSetHead

func (s *IChainInfoStruct) ChainSetHead(p0 context.Context, p1 types.TipSetKey) error

func (*IChainInfoStruct) GetActor

func (s *IChainInfoStruct) GetActor(p0 context.Context, p1 address.Address) (*types.Actor, error)

func (*IChainInfoStruct) GetEntry

func (*IChainInfoStruct) GetFullBlock

func (s *IChainInfoStruct) GetFullBlock(p0 context.Context, p1 cid.Cid) (*types.FullBlock, error)

func (*IChainInfoStruct) GetParentStateRootActor

func (s *IChainInfoStruct) GetParentStateRootActor(p0 context.Context, p1 *types.TipSet, p2 address.Address) (*types.Actor, error)

func (*IChainInfoStruct) ProtocolParameters

func (s *IChainInfoStruct) ProtocolParameters(p0 context.Context) (*types.ProtocolParams, error)

func (*IChainInfoStruct) ResolveToKeyAddr

func (s *IChainInfoStruct) ResolveToKeyAddr(p0 context.Context, p1 address.Address, p2 *types.TipSet) (address.Address, error)

func (*IChainInfoStruct) StateActorCodeCIDs added in v1.6.0

func (s *IChainInfoStruct) StateActorCodeCIDs(p0 context.Context, p1 network.Version) (map[string]cid.Cid, error)

func (*IChainInfoStruct) StateActorManifestCID added in v1.8.0

func (s *IChainInfoStruct) StateActorManifestCID(p0 context.Context, p1 network.Version) (cid.Cid, error)

func (*IChainInfoStruct) StateCall added in v1.8.0

func (*IChainInfoStruct) StateCompute added in v1.10.1

func (*IChainInfoStruct) StateGetBeaconEntry added in v1.6.0

func (s *IChainInfoStruct) StateGetBeaconEntry(p0 context.Context, p1 abi.ChainEpoch) (*types.BeaconEntry, error)

func (*IChainInfoStruct) StateGetNetworkParams added in v1.6.0

func (s *IChainInfoStruct) StateGetNetworkParams(p0 context.Context) (*types.NetworkParams, error)

func (*IChainInfoStruct) StateGetRandomnessDigestFromBeacon added in v1.14.0

func (s *IChainInfoStruct) StateGetRandomnessDigestFromBeacon(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)

func (*IChainInfoStruct) StateGetRandomnessDigestFromTickets added in v1.14.0

func (s *IChainInfoStruct) StateGetRandomnessDigestFromTickets(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) (abi.Randomness, error)

func (*IChainInfoStruct) StateGetRandomnessFromBeacon

func (s *IChainInfoStruct) StateGetRandomnessFromBeacon(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, p3 []byte, p4 types.TipSetKey) (abi.Randomness, error)

func (*IChainInfoStruct) StateGetRandomnessFromTickets

func (s *IChainInfoStruct) StateGetRandomnessFromTickets(p0 context.Context, p1 crypto.DomainSeparationTag, p2 abi.ChainEpoch, p3 []byte, p4 types.TipSetKey) (abi.Randomness, error)

func (*IChainInfoStruct) StateNetworkName

func (s *IChainInfoStruct) StateNetworkName(p0 context.Context) (types.NetworkName, error)

func (*IChainInfoStruct) StateNetworkVersion

func (s *IChainInfoStruct) StateNetworkVersion(p0 context.Context, p1 types.TipSetKey) (network.Version, error)

func (*IChainInfoStruct) StateReplay added in v1.10.0

func (s *IChainInfoStruct) StateReplay(p0 context.Context, p1 types.TipSetKey, p2 cid.Cid) (*types.InvocResult, error)

func (*IChainInfoStruct) StateSearchMsg

func (s *IChainInfoStruct) StateSearchMsg(p0 context.Context, p1 types.TipSetKey, p2 cid.Cid, p3 abi.ChainEpoch, p4 bool) (*types.MsgLookup, error)

func (*IChainInfoStruct) StateVerifiedRegistryRootKey

func (s *IChainInfoStruct) StateVerifiedRegistryRootKey(p0 context.Context, p1 types.TipSetKey) (address.Address, error)

func (*IChainInfoStruct) StateVerifierStatus

func (s *IChainInfoStruct) StateVerifierStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)

func (*IChainInfoStruct) StateWaitMsg

func (s *IChainInfoStruct) StateWaitMsg(p0 context.Context, p1 cid.Cid, p2 uint64, p3 abi.ChainEpoch, p4 bool) (*types.MsgLookup, error)

func (*IChainInfoStruct) VerifyEntry

func (s *IChainInfoStruct) VerifyEntry(p0, p1 *types.BeaconEntry, p2 abi.ChainEpoch) bool

type ICommon added in v1.7.0

type ICommon interface {
	api.Version

	NodeStatus(ctx context.Context, inclChainStatus bool) (types.NodeStatus, error) //perm:read
	// StartTime returns node start time
	StartTime(context.Context) (time.Time, error) //perm:read
}

type ICommonStruct added in v1.7.0

type ICommonStruct struct {
	Internal struct {
		NodeStatus func(ctx context.Context, inclChainStatus bool) (types.NodeStatus, error) `perm:"read"`
		StartTime  func(context.Context) (time.Time, error)                                  `perm:"read"`
		Version    func(ctx context.Context) (types.Version, error)                          `perm:"read"`
	}
}

func (*ICommonStruct) NodeStatus added in v1.9.0

func (s *ICommonStruct) NodeStatus(p0 context.Context, p1 bool) (types.NodeStatus, error)

func (*ICommonStruct) StartTime added in v1.9.0

func (s *ICommonStruct) StartTime(p0 context.Context) (time.Time, error)

func (*ICommonStruct) Version added in v1.7.0

func (s *ICommonStruct) Version(p0 context.Context) (types.Version, error)

type IETH added in v1.10.0

type IETH interface {
	// These methods are used for Ethereum-compatible JSON-RPC calls
	//
	// EthAccounts will always return [] since we don't expect Lotus to manage private keys
	EthAccounts(ctx context.Context) ([]types.EthAddress, error) //perm:read
	// EthAddressToFilecoinAddress converts an EthAddress into an f410 Filecoin Address
	EthAddressToFilecoinAddress(ctx context.Context, ethAddress types.EthAddress) (address.Address, error) //perm:read
	// FilecoinAddressToEthAddress converts an f410 or f0 Filecoin Address to an EthAddress
	FilecoinAddressToEthAddress(ctx context.Context, filecoinAddress address.Address) (types.EthAddress, error) //perm:read
	// EthBlockNumber returns the height of the latest (heaviest) TipSet
	EthBlockNumber(ctx context.Context) (types.EthUint64, error) //perm:read
	// EthGetBlockTransactionCountByNumber returns the number of messages in the TipSet
	EthGetBlockTransactionCountByNumber(ctx context.Context, blkNum types.EthUint64) (types.EthUint64, error) //perm:read
	// EthGetBlockTransactionCountByHash returns the number of messages in the TipSet
	EthGetBlockTransactionCountByHash(ctx context.Context, blkHash types.EthHash) (types.EthUint64, error) //perm:read

	EthGetBlockByHash(ctx context.Context, blkHash types.EthHash, fullTxInfo bool) (types.EthBlock, error)                                    //perm:read
	EthGetBlockByNumber(ctx context.Context, blkNum string, fullTxInfo bool) (types.EthBlock, error)                                          //perm:read
	EthGetTransactionByHash(ctx context.Context, txHash *types.EthHash) (*types.EthTx, error)                                                 //perm:read
	EthGetTransactionByHashLimited(ctx context.Context, txHash *types.EthHash, limit abi.ChainEpoch) (*types.EthTx, error)                    //perm:read
	EthGetTransactionHashByCid(ctx context.Context, cid cid.Cid) (*types.EthHash, error)                                                      //perm:read
	EthGetMessageCidByTransactionHash(ctx context.Context, txHash *types.EthHash) (*cid.Cid, error)                                           //perm:read
	EthGetTransactionCount(ctx context.Context, sender types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthUint64, error)        //perm:read
	EthGetBlockReceipts(ctx context.Context, blkParam types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error)                              //perm:read
	EthGetBlockReceiptsLimited(ctx context.Context, blkParam types.EthBlockNumberOrHash, limit abi.ChainEpoch) ([]*types.EthTxReceipt, error) //perm:read
	EthGetTransactionReceipt(ctx context.Context, txHash types.EthHash) (*types.EthTxReceipt, error)                                          //perm:read
	EthGetTransactionReceiptLimited(ctx context.Context, txHash types.EthHash, limit abi.ChainEpoch) (*types.EthTxReceipt, error)             //perm:read
	EthGetTransactionByBlockHashAndIndex(ctx context.Context, blkHash types.EthHash, txIndex types.EthUint64) (types.EthTx, error)            //perm:read
	EthGetTransactionByBlockNumberAndIndex(ctx context.Context, blkNum types.EthUint64, txIndex types.EthUint64) (types.EthTx, error)         //perm:read

	EthGetCode(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error)                               //perm:read
	EthGetStorageAt(ctx context.Context, address types.EthAddress, position types.EthBytes, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) //perm:read
	EthGetBalance(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBigInt, error)                           //perm:read
	EthChainId(ctx context.Context) (types.EthUint64, error)                                                                                             //perm:read
	EthSyncing(ctx context.Context) (types.EthSyncingResult, error)                                                                                      //perm:read
	NetVersion(ctx context.Context) (string, error)                                                                                                      //perm:read
	NetListening(ctx context.Context) (bool, error)                                                                                                      //perm:read
	EthProtocolVersion(ctx context.Context) (types.EthUint64, error)                                                                                     //perm:read
	EthGasPrice(ctx context.Context) (types.EthBigInt, error)                                                                                            //perm:read
	EthFeeHistory(ctx context.Context, p jsonrpc.RawParams) (types.EthFeeHistory, error)                                                                 //perm:read

	EthMaxPriorityFeePerGas(ctx context.Context) (types.EthBigInt, error)                                       //perm:read
	EthEstimateGas(ctx context.Context, p jsonrpc.RawParams) (types.EthUint64, error)                           //perm:read
	EthCall(ctx context.Context, tx types.EthCall, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) //perm:read

	EthSendRawTransaction(ctx context.Context, rawTx types.EthBytes) (types.EthHash, error) //perm:read

	// Returns the client version
	Web3ClientVersion(ctx context.Context) (string, error) //perm:read

	// Returns an OpenEthereum-compatible trace of the given block (implementing `trace_block`),
	// translating Filecoin semantics into Ethereum semantics and tracing both EVM and FVM calls.
	//
	// Features:
	//
	// - FVM actor create events, calls, etc. show up as if they were EVM smart contract events.
	// - Native FVM call inputs are ABI-encoded (Solidity ABI) as if they were calls to a
	//   `handle_filecoin_method(uint64 method, uint64 codec, bytes params)` function
	//   (where `codec` is the IPLD codec of `params`).
	// - Native FVM call outputs (return values) are ABI-encoded as `(uint32 exit_code, uint64
	//   codec, bytes output)` where `codec` is the IPLD codec of `output`.
	//
	// Limitations (for now):
	//
	// 1. Block rewards are not included in the trace.
	// 2. SELFDESTRUCT operations are not included in the trace.
	// 3. EVM smart contract "create" events always specify `0xfe` as the "code" for newly created EVM smart contracts.
	EthTraceBlock(ctx context.Context, blkNum string) ([]*types.EthTraceBlock, error) //perm:read
	// Replays all transactions in a block returning the requested traces for each transaction
	EthTraceReplayBlockTransactions(ctx context.Context, blkNum string, traceTypes []string) ([]*types.EthTraceReplayBlockTransaction, error) //perm:read
	// Implmements OpenEthereum-compatible API method trace_transaction
	EthTraceTransaction(ctx context.Context, txHash string) ([]*types.EthTraceTransaction, error) //perm:read
	// Implements OpenEthereum-compatible API method trace_filter
	EthTraceFilter(ctx context.Context, filter types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error) //perm:read
}

type IETHEvent added in v1.10.0

type IETHEvent interface {
	// Returns event logs matching given filter spec.
	EthGetLogs(ctx context.Context, filter *types.EthFilterSpec) (*types.EthFilterResult, error) //perm:read

	// Polling method for a filter, returns event logs which occurred since last poll.
	// (requires write perm since timestamp of last filter execution will be written)
	EthGetFilterChanges(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) //perm:read

	// Returns event logs matching filter with given id.
	// (requires write perm since timestamp of last filter execution will be written)
	EthGetFilterLogs(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error) //perm:read

	// Installs a persistent filter based on given filter spec.
	EthNewFilter(ctx context.Context, filter *types.EthFilterSpec) (types.EthFilterID, error) //perm:read

	// Installs a persistent filter to notify when a new block arrives.
	EthNewBlockFilter(ctx context.Context) (types.EthFilterID, error) //perm:read

	// Installs a persistent filter to notify when new messages arrive in the message pool.
	EthNewPendingTransactionFilter(ctx context.Context) (types.EthFilterID, error) //perm:read

	// Uninstalls a filter with given id.
	EthUninstallFilter(ctx context.Context, id types.EthFilterID) (bool, error) //perm:read

	// Subscribe to different event types using websockets
	// eventTypes is one or more of:
	//  - newHeads: notify when new blocks arrive.
	//  - pendingTransactions: notify when new messages arrive in the message pool.
	//  - logs: notify new event logs that match a criteria
	// params contains additional parameters used with the log event type
	// The client will receive a stream of EthSubscriptionResponse values until EthUnsubscribe is called.
	EthSubscribe(ctx context.Context, params jsonrpc.RawParams) (types.EthSubscriptionID, error) //perm:read

	// Unsubscribe from a websocket subscription
	EthUnsubscribe(ctx context.Context, id types.EthSubscriptionID) (bool, error) //perm:read
}

type IETHEventStruct added in v1.10.0

type IETHEventStruct struct {
	Internal struct {
		EthGetFilterChanges            func(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error)        `perm:"read"`
		EthGetFilterLogs               func(ctx context.Context, id types.EthFilterID) (*types.EthFilterResult, error)        `perm:"read"`
		EthGetLogs                     func(ctx context.Context, filter *types.EthFilterSpec) (*types.EthFilterResult, error) `perm:"read"`
		EthNewBlockFilter              func(ctx context.Context) (types.EthFilterID, error)                                   `perm:"read"`
		EthNewFilter                   func(ctx context.Context, filter *types.EthFilterSpec) (types.EthFilterID, error)      `perm:"read"`
		EthNewPendingTransactionFilter func(ctx context.Context) (types.EthFilterID, error)                                   `perm:"read"`
		EthSubscribe                   func(ctx context.Context, params jsonrpc.RawParams) (types.EthSubscriptionID, error)   `perm:"read"`
		EthUninstallFilter             func(ctx context.Context, id types.EthFilterID) (bool, error)                          `perm:"read"`
		EthUnsubscribe                 func(ctx context.Context, id types.EthSubscriptionID) (bool, error)                    `perm:"read"`
	}
}

func (*IETHEventStruct) EthGetFilterChanges added in v1.10.0

func (s *IETHEventStruct) EthGetFilterChanges(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)

func (*IETHEventStruct) EthGetFilterLogs added in v1.10.0

func (s *IETHEventStruct) EthGetFilterLogs(p0 context.Context, p1 types.EthFilterID) (*types.EthFilterResult, error)

func (*IETHEventStruct) EthGetLogs added in v1.10.0

func (*IETHEventStruct) EthNewBlockFilter added in v1.10.0

func (s *IETHEventStruct) EthNewBlockFilter(p0 context.Context) (types.EthFilterID, error)

func (*IETHEventStruct) EthNewFilter added in v1.10.0

func (*IETHEventStruct) EthNewPendingTransactionFilter added in v1.10.0

func (s *IETHEventStruct) EthNewPendingTransactionFilter(p0 context.Context) (types.EthFilterID, error)

func (*IETHEventStruct) EthSubscribe added in v1.10.0

func (*IETHEventStruct) EthUninstallFilter added in v1.10.0

func (s *IETHEventStruct) EthUninstallFilter(p0 context.Context, p1 types.EthFilterID) (bool, error)

func (*IETHEventStruct) EthUnsubscribe added in v1.10.0

func (s *IETHEventStruct) EthUnsubscribe(p0 context.Context, p1 types.EthSubscriptionID) (bool, error)

type IETHStruct added in v1.10.0

type IETHStruct struct {
	Internal struct {
		EthAccounts                            func(ctx context.Context) ([]types.EthAddress, error)                                                                                     `perm:"read"`
		EthAddressToFilecoinAddress            func(ctx context.Context, ethAddress types.EthAddress) (address.Address, error)                                                           `perm:"read"`
		EthBlockNumber                         func(ctx context.Context) (types.EthUint64, error)                                                                                        `perm:"read"`
		EthCall                                func(ctx context.Context, tx types.EthCall, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error)                                  `perm:"read"`
		EthChainId                             func(ctx context.Context) (types.EthUint64, error)                                                                                        `perm:"read"`
		EthEstimateGas                         func(ctx context.Context, p jsonrpc.RawParams) (types.EthUint64, error)                                                                   `perm:"read"`
		EthFeeHistory                          func(ctx context.Context, p jsonrpc.RawParams) (types.EthFeeHistory, error)                                                               `perm:"read"`
		EthGasPrice                            func(ctx context.Context) (types.EthBigInt, error)                                                                                        `perm:"read"`
		EthGetBalance                          func(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBigInt, error)                         `perm:"read"`
		EthGetBlockByHash                      func(ctx context.Context, blkHash types.EthHash, fullTxInfo bool) (types.EthBlock, error)                                                 `perm:"read"`
		EthGetBlockByNumber                    func(ctx context.Context, blkNum string, fullTxInfo bool) (types.EthBlock, error)                                                         `perm:"read"`
		EthGetBlockReceipts                    func(ctx context.Context, blkParam types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error)                                             `perm:"read"`
		EthGetBlockReceiptsLimited             func(ctx context.Context, blkParam types.EthBlockNumberOrHash, limit abi.ChainEpoch) ([]*types.EthTxReceipt, error)                       `perm:"read"`
		EthGetBlockTransactionCountByHash      func(ctx context.Context, blkHash types.EthHash) (types.EthUint64, error)                                                                 `perm:"read"`
		EthGetBlockTransactionCountByNumber    func(ctx context.Context, blkNum types.EthUint64) (types.EthUint64, error)                                                                `perm:"read"`
		EthGetCode                             func(ctx context.Context, address types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error)                          `perm:"read"`
		EthGetMessageCidByTransactionHash      func(ctx context.Context, txHash *types.EthHash) (*cid.Cid, error)                                                                        `perm:"read"`
		EthGetStorageAt                        func(ctx context.Context, address types.EthAddress, position types.EthBytes, blkParam types.EthBlockNumberOrHash) (types.EthBytes, error) `perm:"read"`
		EthGetTransactionByBlockHashAndIndex   func(ctx context.Context, blkHash types.EthHash, txIndex types.EthUint64) (types.EthTx, error)                                            `perm:"read"`
		EthGetTransactionByBlockNumberAndIndex func(ctx context.Context, blkNum types.EthUint64, txIndex types.EthUint64) (types.EthTx, error)                                           `perm:"read"`
		EthGetTransactionByHash                func(ctx context.Context, txHash *types.EthHash) (*types.EthTx, error)                                                                    `perm:"read"`
		EthGetTransactionByHashLimited         func(ctx context.Context, txHash *types.EthHash, limit abi.ChainEpoch) (*types.EthTx, error)                                              `perm:"read"`
		EthGetTransactionCount                 func(ctx context.Context, sender types.EthAddress, blkParam types.EthBlockNumberOrHash) (types.EthUint64, error)                          `perm:"read"`
		EthGetTransactionHashByCid             func(ctx context.Context, cid cid.Cid) (*types.EthHash, error)                                                                            `perm:"read"`
		EthGetTransactionReceipt               func(ctx context.Context, txHash types.EthHash) (*types.EthTxReceipt, error)                                                              `perm:"read"`
		EthGetTransactionReceiptLimited        func(ctx context.Context, txHash types.EthHash, limit abi.ChainEpoch) (*types.EthTxReceipt, error)                                        `perm:"read"`
		EthMaxPriorityFeePerGas                func(ctx context.Context) (types.EthBigInt, error)                                                                                        `perm:"read"`
		EthProtocolVersion                     func(ctx context.Context) (types.EthUint64, error)                                                                                        `perm:"read"`
		EthSendRawTransaction                  func(ctx context.Context, rawTx types.EthBytes) (types.EthHash, error)                                                                    `perm:"read"`
		EthSyncing                             func(ctx context.Context) (types.EthSyncingResult, error)                                                                                 `perm:"read"`
		EthTraceBlock                          func(ctx context.Context, blkNum string) ([]*types.EthTraceBlock, error)                                                                  `perm:"read"`
		EthTraceFilter                         func(ctx context.Context, filter types.EthTraceFilterCriteria) ([]*types.EthTraceFilterResult, error)                                     `perm:"read"`
		EthTraceReplayBlockTransactions        func(ctx context.Context, blkNum string, traceTypes []string) ([]*types.EthTraceReplayBlockTransaction, error)                            `perm:"read"`
		EthTraceTransaction                    func(ctx context.Context, txHash string) ([]*types.EthTraceTransaction, error)                                                            `perm:"read"`
		FilecoinAddressToEthAddress            func(ctx context.Context, filecoinAddress address.Address) (types.EthAddress, error)                                                      `perm:"read"`
		NetListening                           func(ctx context.Context) (bool, error)                                                                                                   `perm:"read"`
		NetVersion                             func(ctx context.Context) (string, error)                                                                                                 `perm:"read"`
		Web3ClientVersion                      func(ctx context.Context) (string, error)                                                                                                 `perm:"read"`
	}
}

func (*IETHStruct) EthAccounts added in v1.10.0

func (s *IETHStruct) EthAccounts(p0 context.Context) ([]types.EthAddress, error)

func (*IETHStruct) EthAddressToFilecoinAddress added in v1.10.0

func (s *IETHStruct) EthAddressToFilecoinAddress(p0 context.Context, p1 types.EthAddress) (address.Address, error)

func (*IETHStruct) EthBlockNumber added in v1.10.0

func (s *IETHStruct) EthBlockNumber(p0 context.Context) (types.EthUint64, error)

func (*IETHStruct) EthCall added in v1.10.0

func (*IETHStruct) EthChainId added in v1.10.0

func (s *IETHStruct) EthChainId(p0 context.Context) (types.EthUint64, error)

func (*IETHStruct) EthEstimateGas added in v1.10.0

func (s *IETHStruct) EthEstimateGas(p0 context.Context, p1 jsonrpc.RawParams) (types.EthUint64, error)

func (*IETHStruct) EthFeeHistory added in v1.10.0

func (s *IETHStruct) EthFeeHistory(p0 context.Context, p1 jsonrpc.RawParams) (types.EthFeeHistory, error)

func (*IETHStruct) EthGasPrice added in v1.10.0

func (s *IETHStruct) EthGasPrice(p0 context.Context) (types.EthBigInt, error)

func (*IETHStruct) EthGetBalance added in v1.10.0

func (*IETHStruct) EthGetBlockByHash added in v1.10.0

func (s *IETHStruct) EthGetBlockByHash(p0 context.Context, p1 types.EthHash, p2 bool) (types.EthBlock, error)

func (*IETHStruct) EthGetBlockByNumber added in v1.10.0

func (s *IETHStruct) EthGetBlockByNumber(p0 context.Context, p1 string, p2 bool) (types.EthBlock, error)

func (*IETHStruct) EthGetBlockReceipts added in v1.17.0

func (s *IETHStruct) EthGetBlockReceipts(p0 context.Context, p1 types.EthBlockNumberOrHash) ([]*types.EthTxReceipt, error)

func (*IETHStruct) EthGetBlockReceiptsLimited added in v1.17.0

func (s *IETHStruct) EthGetBlockReceiptsLimited(p0 context.Context, p1 types.EthBlockNumberOrHash, p2 abi.ChainEpoch) ([]*types.EthTxReceipt, error)

func (*IETHStruct) EthGetBlockTransactionCountByHash added in v1.10.0

func (s *IETHStruct) EthGetBlockTransactionCountByHash(p0 context.Context, p1 types.EthHash) (types.EthUint64, error)

func (*IETHStruct) EthGetBlockTransactionCountByNumber added in v1.10.0

func (s *IETHStruct) EthGetBlockTransactionCountByNumber(p0 context.Context, p1 types.EthUint64) (types.EthUint64, error)

func (*IETHStruct) EthGetCode added in v1.10.0

func (*IETHStruct) EthGetMessageCidByTransactionHash added in v1.10.0

func (s *IETHStruct) EthGetMessageCidByTransactionHash(p0 context.Context, p1 *types.EthHash) (*cid.Cid, error)

func (*IETHStruct) EthGetStorageAt added in v1.10.0

func (*IETHStruct) EthGetTransactionByBlockHashAndIndex added in v1.10.0

func (s *IETHStruct) EthGetTransactionByBlockHashAndIndex(p0 context.Context, p1 types.EthHash, p2 types.EthUint64) (types.EthTx, error)

func (*IETHStruct) EthGetTransactionByBlockNumberAndIndex added in v1.10.0

func (s *IETHStruct) EthGetTransactionByBlockNumberAndIndex(p0 context.Context, p1 types.EthUint64, p2 types.EthUint64) (types.EthTx, error)

func (*IETHStruct) EthGetTransactionByHash added in v1.10.0

func (s *IETHStruct) EthGetTransactionByHash(p0 context.Context, p1 *types.EthHash) (*types.EthTx, error)

func (*IETHStruct) EthGetTransactionByHashLimited added in v1.12.0

func (s *IETHStruct) EthGetTransactionByHashLimited(p0 context.Context, p1 *types.EthHash, p2 abi.ChainEpoch) (*types.EthTx, error)

func (*IETHStruct) EthGetTransactionCount added in v1.10.0

func (s *IETHStruct) EthGetTransactionCount(p0 context.Context, p1 types.EthAddress, p2 types.EthBlockNumberOrHash) (types.EthUint64, error)

func (*IETHStruct) EthGetTransactionHashByCid added in v1.10.0

func (s *IETHStruct) EthGetTransactionHashByCid(p0 context.Context, p1 cid.Cid) (*types.EthHash, error)

func (*IETHStruct) EthGetTransactionReceipt added in v1.10.0

func (s *IETHStruct) EthGetTransactionReceipt(p0 context.Context, p1 types.EthHash) (*types.EthTxReceipt, error)

func (*IETHStruct) EthGetTransactionReceiptLimited added in v1.12.0

func (s *IETHStruct) EthGetTransactionReceiptLimited(p0 context.Context, p1 types.EthHash, p2 abi.ChainEpoch) (*types.EthTxReceipt, error)

func (*IETHStruct) EthMaxPriorityFeePerGas added in v1.10.0

func (s *IETHStruct) EthMaxPriorityFeePerGas(p0 context.Context) (types.EthBigInt, error)

func (*IETHStruct) EthProtocolVersion added in v1.10.0

func (s *IETHStruct) EthProtocolVersion(p0 context.Context) (types.EthUint64, error)

func (*IETHStruct) EthSendRawTransaction added in v1.10.0

func (s *IETHStruct) EthSendRawTransaction(p0 context.Context, p1 types.EthBytes) (types.EthHash, error)

func (*IETHStruct) EthSyncing added in v1.14.0

func (s *IETHStruct) EthSyncing(p0 context.Context) (types.EthSyncingResult, error)

func (*IETHStruct) EthTraceBlock added in v1.14.0

func (s *IETHStruct) EthTraceBlock(p0 context.Context, p1 string) ([]*types.EthTraceBlock, error)

func (*IETHStruct) EthTraceFilter added in v1.17.0

func (*IETHStruct) EthTraceReplayBlockTransactions added in v1.14.0

func (s *IETHStruct) EthTraceReplayBlockTransactions(p0 context.Context, p1 string, p2 []string) ([]*types.EthTraceReplayBlockTransaction, error)

func (*IETHStruct) EthTraceTransaction added in v1.16.0

func (s *IETHStruct) EthTraceTransaction(p0 context.Context, p1 string) ([]*types.EthTraceTransaction, error)

func (*IETHStruct) FilecoinAddressToEthAddress added in v1.10.0

func (s *IETHStruct) FilecoinAddressToEthAddress(p0 context.Context, p1 address.Address) (types.EthAddress, error)

func (*IETHStruct) NetListening added in v1.10.0

func (s *IETHStruct) NetListening(p0 context.Context) (bool, error)

func (*IETHStruct) NetVersion added in v1.10.0

func (s *IETHStruct) NetVersion(p0 context.Context) (string, error)

func (*IETHStruct) Web3ClientVersion added in v1.10.0

func (s *IETHStruct) Web3ClientVersion(p0 context.Context) (string, error)

type IF3 added in v1.16.0

type IF3 interface {

	// F3GetOrRenewParticipationTicket retrieves or renews a participation ticket
	// necessary for a miner to engage in the F3 consensus process for the given
	// number of instances.
	//
	// This function accepts an optional previous ticket. If provided, a new ticket
	// will be issued only under one the following conditions:
	//   1. The previous ticket has expired.
	//   2. The issuer of the previous ticket matches the node processing this
	//      request.
	//
	// If there is an issuer mismatch (ErrF3ParticipationIssuerMismatch), the miner
	// must retry obtaining a new ticket to ensure it is only participating in one F3
	// instance at any time. If the number of instances is beyond the maximum leasable
	// participation instances accepted by the node ErrF3ParticipationTooManyInstances
	// is returned.
	//
	// Note: Successfully acquiring a ticket alone does not constitute participation.
	// The retrieved ticket must be used to invoke F3Participate to actively engage
	// in the F3 consensus process.
	F3GetOrRenewParticipationTicket(ctx context.Context, minerID address.Address, previous types.F3ParticipationTicket, instances uint64) (types.F3ParticipationTicket, error) //perm:sign
	// F3Participate enrolls a storage provider in the F3 consensus process using a
	// provided participation ticket. This ticket grants a temporary lease that enables
	// the provider to sign transactions as part of the F3 consensus.
	//
	// The function verifies the ticket's validity and checks if the ticket's issuer
	// aligns with the current node. If there is an issuer mismatch
	// (ErrF3ParticipationIssuerMismatch), the provider should retry with the same
	// ticket, assuming the issue is due to transient network problems or operational
	// deployment conditions. If the ticket is invalid
	// (ErrF3ParticipationTicketInvalid) or has expired
	// (ErrF3ParticipationTicketExpired), the provider must obtain a new ticket by
	// calling F3GetOrRenewParticipationTicket.
	//
	// The start instance associated to the given ticket cannot be less than the
	// start instance of any existing lease held by the miner. Otherwise,
	// ErrF3ParticipationTicketStartBeforeExisting is returned. In this case, the
	// miner should acquire a new ticket before attempting to participate again.
	//
	// For details on obtaining or renewing a ticket, see F3GetOrRenewParticipationTicket.
	F3Participate(ctx context.Context, ticket types.F3ParticipationTicket) (types.F3ParticipationLease, error) //perm:sign
	// F3GetCertificate returns a finality certificate at given instance number
	F3GetCertificate(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error) //perm:read
	// F3GetLatestCertificate returns the latest finality certificate
	F3GetLatestCertificate(ctx context.Context) (*certs.FinalityCertificate, error) //perm:read
	// F3GetECPowerTable returns a F3 specific power table for use in standalone F3 nodes.
	F3GetECPowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) //perm:read
	// F3GetF3PowerTable returns a F3 specific power table.
	F3GetF3PowerTable(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error) //perm:read
	// F3GetManifest returns the current manifest being used for F3
	F3GetManifest(ctx context.Context) (*manifest.Manifest, error) //perm:read
	// F3IsRunning returns true if the F3 instance is running, false if it's not running but
	// it's enabled, and an error when disabled entirely.
	F3IsRunning(ctx context.Context) (bool, error) //perm:read
	// F3GetProgress returns the progress of the current F3 instance in terms of instance ID, round and phase.
	F3GetProgress(ctx context.Context) (gpbft.Instant, error) //perm:read

	// F3ListParticipants returns the list of miners that are currently participating in F3 via this node.
	F3ListParticipants(ctx context.Context) ([]types.F3Participant, error) //perm:read
}

type IF3Struct added in v1.16.0

type IF3Struct struct {
	Internal struct {
		F3GetCertificate                func(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error)                                                                  `perm:"read"`
		F3GetECPowerTable               func(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error)                                                                      `perm:"read"`
		F3GetF3PowerTable               func(ctx context.Context, tsk types.TipSetKey) (gpbft.PowerEntries, error)                                                                      `perm:"read"`
		F3GetLatestCertificate          func(ctx context.Context) (*certs.FinalityCertificate, error)                                                                                   `perm:"read"`
		F3GetManifest                   func(ctx context.Context) (*manifest.Manifest, error)                                                                                           `perm:"read"`
		F3GetOrRenewParticipationTicket func(ctx context.Context, minerID address.Address, previous types.F3ParticipationTicket, instances uint64) (types.F3ParticipationTicket, error) `perm:"sign"`
		F3GetProgress                   func(ctx context.Context) (gpbft.Instant, error)                                                                                                `perm:"read"`
		F3IsRunning                     func(ctx context.Context) (bool, error)                                                                                                         `perm:"read"`
		F3ListParticipants              func(ctx context.Context) ([]types.F3Participant, error)                                                                                        `perm:"read"`
		F3Participate                   func(ctx context.Context, ticket types.F3ParticipationTicket) (types.F3ParticipationLease, error)                                               `perm:"sign"`
	}
}

func (*IF3Struct) F3GetCertificate added in v1.16.0

func (s *IF3Struct) F3GetCertificate(p0 context.Context, p1 uint64) (*certs.FinalityCertificate, error)

func (*IF3Struct) F3GetECPowerTable added in v1.16.0

func (s *IF3Struct) F3GetECPowerTable(p0 context.Context, p1 types.TipSetKey) (gpbft.PowerEntries, error)

func (*IF3Struct) F3GetF3PowerTable added in v1.16.0

func (s *IF3Struct) F3GetF3PowerTable(p0 context.Context, p1 types.TipSetKey) (gpbft.PowerEntries, error)

func (*IF3Struct) F3GetLatestCertificate added in v1.16.0

func (s *IF3Struct) F3GetLatestCertificate(p0 context.Context) (*certs.FinalityCertificate, error)

func (*IF3Struct) F3GetManifest added in v1.17.0

func (s *IF3Struct) F3GetManifest(p0 context.Context) (*manifest.Manifest, error)

func (*IF3Struct) F3GetOrRenewParticipationTicket added in v1.17.0

func (s *IF3Struct) F3GetOrRenewParticipationTicket(p0 context.Context, p1 address.Address, p2 types.F3ParticipationTicket, p3 uint64) (types.F3ParticipationTicket, error)

func (*IF3Struct) F3GetProgress added in v1.17.0

func (s *IF3Struct) F3GetProgress(p0 context.Context) (gpbft.Instant, error)

func (*IF3Struct) F3IsRunning added in v1.17.0

func (s *IF3Struct) F3IsRunning(p0 context.Context) (bool, error)

func (*IF3Struct) F3ListParticipants added in v1.17.0

func (s *IF3Struct) F3ListParticipants(p0 context.Context) ([]types.F3Participant, error)

func (*IF3Struct) F3Participate added in v1.16.0

type IMarket

type IMarket interface {
	StateMarketParticipants(ctx context.Context, tsk types.TipSetKey) (map[string]types.MarketBalance, error) //perm:read
}

type IMarketStruct

type IMarketStruct struct {
	Internal struct {
		StateMarketParticipants func(ctx context.Context, tsk types.TipSetKey) (map[string]types.MarketBalance, error) `perm:"read"`
	}
}

func (*IMarketStruct) StateMarketParticipants

func (s *IMarketStruct) StateMarketParticipants(p0 context.Context, p1 types.TipSetKey) (map[string]types.MarketBalance, error)

type IMessagePool

type IMessagePool interface {
	MpoolDeleteByAdress(ctx context.Context, addr address.Address) error                                                                                               //perm:admin
	MpoolPublishByAddr(context.Context, address.Address) error                                                                                                         //perm:write
	MpoolPublishMessage(ctx context.Context, smsg *types.SignedMessage) error                                                                                          //perm:write
	MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)                                                                                         //perm:write
	MpoolGetConfig(context.Context) (*types.MpoolConfig, error)                                                                                                        //perm:read
	MpoolSetConfig(ctx context.Context, cfg *types.MpoolConfig) error                                                                                                  //perm:admin
	MpoolSelect(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)                                                                             //perm:read
	MpoolSelects(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error)                                                                        //perm:read
	MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)                                                                             //perm:read
	MpoolClear(ctx context.Context, local bool) error                                                                                                                  //perm:write
	MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)                                                                                //perm:write
	MpoolPushMessage(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec) (*types.SignedMessage, error)                                               //perm:sign
	MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                                                               //perm:write
	MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                                                      //perm:write
	MpoolBatchPushMessage(ctx context.Context, msgs []*types.Message, spec *types.MessageSendSpec) ([]*types.SignedMessage, error)                                     //perm:sign
	MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)                                                                                           //perm:read
	MpoolSub(ctx context.Context) (<-chan types.MpoolUpdate, error)                                                                                                    //perm:read
	GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)                           //perm:read
	GasBatchEstimateMessageGas(ctx context.Context, estimateMessages []*types.EstimateMessage, fromNonce uint64, tsk types.TipSetKey) ([]*types.EstimateResult, error) //perm:read
	GasEstimateFeeCap(ctx context.Context, msg *types.Message, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error)                                               //perm:read
	GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error)                       //perm:read
	GasEstimateGasLimit(ctx context.Context, msgIn *types.Message, tsk types.TipSetKey) (int64, error)                                                                 //perm:read
	// MpoolCheckMessages performs logical checks on a batch of messages
	MpoolCheckMessages(ctx context.Context, protos []*types.MessagePrototype) ([][]types.MessageCheckStatus, error) //perm:read
	// MpoolCheckPendingMessages performs logical checks for all pending messages from a given address
	MpoolCheckPendingMessages(ctx context.Context, addr address.Address) ([][]types.MessageCheckStatus, error) //perm:read
	// MpoolCheckReplaceMessages performs logical checks on pending messages with replacement
	MpoolCheckReplaceMessages(ctx context.Context, msg []*types.Message) ([][]types.MessageCheckStatus, error) //perm:read
}

type IMessagePoolStruct

type IMessagePoolStruct struct {
	Internal struct {
		GasBatchEstimateMessageGas func(ctx context.Context, estimateMessages []*types.EstimateMessage, fromNonce uint64, tsk types.TipSetKey) ([]*types.EstimateResult, error) `perm:"read"`
		GasEstimateFeeCap          func(ctx context.Context, msg *types.Message, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error)                                      `perm:"read"`
		GasEstimateGasLimit        func(ctx context.Context, msgIn *types.Message, tsk types.TipSetKey) (int64, error)                                                          `perm:"read"`
		GasEstimateGasPremium      func(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error)                  `perm:"read"`
		GasEstimateMessageGas      func(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)                      `perm:"read"`
		MpoolBatchPush             func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                                                   `perm:"write"`
		MpoolBatchPushMessage      func(ctx context.Context, msgs []*types.Message, spec *types.MessageSendSpec) ([]*types.SignedMessage, error)                                `perm:"sign"`
		MpoolBatchPushUntrusted    func(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)                                                                   `perm:"write"`
		MpoolCheckMessages         func(ctx context.Context, protos []*types.MessagePrototype) ([][]types.MessageCheckStatus, error)                                            `perm:"read"`
		MpoolCheckPendingMessages  func(ctx context.Context, addr address.Address) ([][]types.MessageCheckStatus, error)                                                        `perm:"read"`
		MpoolCheckReplaceMessages  func(ctx context.Context, msg []*types.Message) ([][]types.MessageCheckStatus, error)                                                        `perm:"read"`
		MpoolClear                 func(ctx context.Context, local bool) error                                                                                                  `perm:"write"`
		MpoolDeleteByAdress        func(ctx context.Context, addr address.Address) error                                                                                        `perm:"admin"`
		MpoolGetConfig             func(context.Context) (*types.MpoolConfig, error)                                                                                            `perm:"read"`
		MpoolGetNonce              func(ctx context.Context, addr address.Address) (uint64, error)                                                                              `perm:"read"`
		MpoolPending               func(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)                                                               `perm:"read"`
		MpoolPublishByAddr         func(context.Context, address.Address) error                                                                                                 `perm:"write"`
		MpoolPublishMessage        func(ctx context.Context, smsg *types.SignedMessage) error                                                                                   `perm:"write"`
		MpoolPush                  func(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)                                                                        `perm:"write"`
		MpoolPushMessage           func(ctx context.Context, msg *types.Message, spec *types.MessageSendSpec) (*types.SignedMessage, error)                                     `perm:"sign"`
		MpoolPushUntrusted         func(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)                                                                        `perm:"write"`
		MpoolSelect                func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)                                                              `perm:"read"`
		MpoolSelects               func(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error)                                                          `perm:"read"`
		MpoolSetConfig             func(ctx context.Context, cfg *types.MpoolConfig) error                                                                                      `perm:"admin"`
		MpoolSub                   func(ctx context.Context) (<-chan types.MpoolUpdate, error)                                                                                  `perm:"read"`
	}
}

func (*IMessagePoolStruct) GasBatchEstimateMessageGas

func (s *IMessagePoolStruct) GasBatchEstimateMessageGas(p0 context.Context, p1 []*types.EstimateMessage, p2 uint64, p3 types.TipSetKey) ([]*types.EstimateResult, error)

func (*IMessagePoolStruct) GasEstimateFeeCap

func (s *IMessagePoolStruct) GasEstimateFeeCap(p0 context.Context, p1 *types.Message, p2 int64, p3 types.TipSetKey) (big.Int, error)

func (*IMessagePoolStruct) GasEstimateGasLimit

func (s *IMessagePoolStruct) GasEstimateGasLimit(p0 context.Context, p1 *types.Message, p2 types.TipSetKey) (int64, error)

func (*IMessagePoolStruct) GasEstimateGasPremium

func (s *IMessagePoolStruct) GasEstimateGasPremium(p0 context.Context, p1 uint64, p2 address.Address, p3 int64, p4 types.TipSetKey) (big.Int, error)

func (*IMessagePoolStruct) GasEstimateMessageGas

func (s *IMessagePoolStruct) GasEstimateMessageGas(p0 context.Context, p1 *types.Message, p2 *types.MessageSendSpec, p3 types.TipSetKey) (*types.Message, error)

func (*IMessagePoolStruct) MpoolBatchPush

func (s *IMessagePoolStruct) MpoolBatchPush(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)

func (*IMessagePoolStruct) MpoolBatchPushMessage

func (s *IMessagePoolStruct) MpoolBatchPushMessage(p0 context.Context, p1 []*types.Message, p2 *types.MessageSendSpec) ([]*types.SignedMessage, error)

func (*IMessagePoolStruct) MpoolBatchPushUntrusted

func (s *IMessagePoolStruct) MpoolBatchPushUntrusted(p0 context.Context, p1 []*types.SignedMessage) ([]cid.Cid, error)

func (*IMessagePoolStruct) MpoolCheckMessages

func (s *IMessagePoolStruct) MpoolCheckMessages(p0 context.Context, p1 []*types.MessagePrototype) ([][]types.MessageCheckStatus, error)

func (*IMessagePoolStruct) MpoolCheckPendingMessages

func (s *IMessagePoolStruct) MpoolCheckPendingMessages(p0 context.Context, p1 address.Address) ([][]types.MessageCheckStatus, error)

func (*IMessagePoolStruct) MpoolCheckReplaceMessages

func (s *IMessagePoolStruct) MpoolCheckReplaceMessages(p0 context.Context, p1 []*types.Message) ([][]types.MessageCheckStatus, error)

func (*IMessagePoolStruct) MpoolClear

func (s *IMessagePoolStruct) MpoolClear(p0 context.Context, p1 bool) error

func (*IMessagePoolStruct) MpoolDeleteByAdress

func (s *IMessagePoolStruct) MpoolDeleteByAdress(p0 context.Context, p1 address.Address) error

func (*IMessagePoolStruct) MpoolGetConfig

func (s *IMessagePoolStruct) MpoolGetConfig(p0 context.Context) (*types.MpoolConfig, error)

func (*IMessagePoolStruct) MpoolGetNonce

func (s *IMessagePoolStruct) MpoolGetNonce(p0 context.Context, p1 address.Address) (uint64, error)

func (*IMessagePoolStruct) MpoolPending

func (s *IMessagePoolStruct) MpoolPending(p0 context.Context, p1 types.TipSetKey) ([]*types.SignedMessage, error)

func (*IMessagePoolStruct) MpoolPublishByAddr

func (s *IMessagePoolStruct) MpoolPublishByAddr(p0 context.Context, p1 address.Address) error

func (*IMessagePoolStruct) MpoolPublishMessage

func (s *IMessagePoolStruct) MpoolPublishMessage(p0 context.Context, p1 *types.SignedMessage) error

func (*IMessagePoolStruct) MpoolPush

func (s *IMessagePoolStruct) MpoolPush(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)

func (*IMessagePoolStruct) MpoolPushMessage

func (*IMessagePoolStruct) MpoolPushUntrusted

func (s *IMessagePoolStruct) MpoolPushUntrusted(p0 context.Context, p1 *types.SignedMessage) (cid.Cid, error)

func (*IMessagePoolStruct) MpoolSelect

func (*IMessagePoolStruct) MpoolSelects

func (s *IMessagePoolStruct) MpoolSelects(p0 context.Context, p1 types.TipSetKey, p2 []float64) ([][]*types.SignedMessage, error)

func (*IMessagePoolStruct) MpoolSetConfig

func (s *IMessagePoolStruct) MpoolSetConfig(p0 context.Context, p1 *types.MpoolConfig) error

func (*IMessagePoolStruct) MpoolSub

func (s *IMessagePoolStruct) MpoolSub(p0 context.Context) (<-chan types.MpoolUpdate, error)

type IMinerState

type IMinerState interface {
	StateReadState(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.ActorState, error)                                    //perm:read
	StateListMessages(ctx context.Context, match *types.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error)                //perm:read
	StateDecodeParams(ctx context.Context, toAddr address.Address, method abi.MethodNum, params []byte, tsk types.TipSetKey) (interface{}, error) //perm:read
	StateEncodeParams(ctx context.Context, toActCode cid.Cid, method abi.MethodNum, params json.RawMessage) ([]byte, error)                       //perm:read
	StateMinerSectorAllocated(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error)                  //perm:read
	// StateSectorPreCommitInfo returns the PreCommit info for the specified miner's sector.
	// Returns nil and no error if the sector isn't precommitted.
	//
	// Note that the sector number may be allocated while PreCommitInfo is nil. This means that either allocated sector
	// numbers were compacted, and the sector number was marked as allocated in order to reduce size of the allocated
	// sectors bitfield, or that the sector was precommitted, but the precommit has expired.
	StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*types.SectorPreCommitOnChainInfo, error) //perm:read
	StateSectorGetInfo(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorOnChainInfo, error)               //perm:read
	StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error)     //perm:read
	StateMinerSectorSize(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (abi.SectorSize, error)                                            //perm:read
	StateMinerInfo(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (types.MinerInfo, error)                                                 //perm:read
	StateMinerWorkerAddress(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (address.Address, error)                                        //perm:read
	StateMinerFaults(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error)                                             //perm:read
	StateAllMinerFaults(ctx context.Context, lookback abi.ChainEpoch, ts types.TipSetKey) ([]*types.Fault, error)                                            //perm:read
	StateMinerRecoveries(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error)                                         //perm:read
	StateMinerProvingDeadline(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (*dline.Info, error)                                          //perm:read
	StateMinerPartitions(ctx context.Context, maddr address.Address, dlIdx uint64, tsk types.TipSetKey) ([]types.Partition, error)                           //perm:read
	StateMinerDeadlines(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]types.Deadline, error)                                           //perm:read
	StateMinerSectors(ctx context.Context, maddr address.Address, sectorNos *bitfield.BitField, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)    //perm:read
	StateMarketStorageDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*types.MarketDeal, error)                                           //perm:read
	// StateGetAllocationForPendingDeal returns the allocation for a given deal ID of a pending deal. Returns nil if
	// pending allocation is not found.
	StateGetAllocationForPendingDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*verifreg.Allocation, error) //perm:read
	// StateGetAllocationIdForPendingDeal is like StateGetAllocationForPendingDeal except it returns the allocation ID
	StateGetAllocationIdForPendingDeal(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (verifreg.AllocationId, error) //perm:read
	// StateGetAllocation returns the allocation for a given address and allocation ID.
	StateGetAllocation(ctx context.Context, clientAddr address.Address, allocationID verifreg.AllocationId, tsk types.TipSetKey) (*verifreg.Allocation, error) //perm:read
	// StateGetAllAllocations returns the all the allocations available in verified registry actor.
	StateGetAllAllocations(ctx context.Context, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) //perm:read
	// StateGetAllocations returns the all the allocations for a given client.
	StateGetAllocations(ctx context.Context, clientAddr address.Address, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error) //perm:read
	// StateGetClaim returns the claim for a given address and claim ID.
	StateGetClaim(ctx context.Context, providerAddr address.Address, claimID verifreg.ClaimId, tsk types.TipSetKey) (*verifreg.Claim, error) //perm:read
	// StateGetClaims returns the all the claims for a given provider.
	StateGetClaims(ctx context.Context, providerAddr address.Address, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) //perm:read
	// StateGetAllClaims returns the all the claims available in verified registry actor.
	StateGetAllClaims(ctx context.Context, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error) //perm:read
	// StateComputeDataCID computes DataCID from a set of on-chain deals
	StateComputeDataCID(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, deals []abi.DealID, tsk types.TipSetKey) (cid.Cid, error) //perm:read
	StateMinerPreCommitDepositForPower(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error)           //perm:read
	// StateMinerInitialPledgeCollateral attempts to calculate the initial pledge collateral based on a SectorPreCommitInfo.
	// This method uses the DealIDs field in SectorPreCommitInfo to determine the amount of verified
	// deal space in the sector in order to perform a QAP calculation. Since network version 22 and
	// the introduction of DDO, the DealIDs field can no longer be used to reliably determine verified
	// deal space; therefore, this method is deprecated. Use StateMinerInitialPledgeForSector instead
	// and pass in the verified deal space directly.
	//
	// Deprecated: Use StateMinerInitialPledgeForSector instead.
	StateMinerInitialPledgeCollateral(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error) //perm:read
	// StateMinerInitialPledgeForSector returns the initial pledge collateral for a given sector
	// duration, size, and combined size of any verified pieces within the sector. This calculation
	// depends on current network conditions (total power, total pledge and current rewards) at the
	// given tipset.
	StateMinerInitialPledgeForSector(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, verifiedSize uint64, tsk types.TipSetKey) (types.BigInt, error) //perm:read
	StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (types.CirculatingSupply, error)                                                                     //perm:read
	StateCirculatingSupply(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)                                                                                       //perm:read
	StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]*types.MarketDeal, error)                                                                                //perm:read
	StateMinerActiveSectors(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)                                                   //perm:read
	StateLookupID(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)                                                                          //perm:read
	// StateLookupRobustAddress returns the public key address of the given ID address for non-account addresses (multisig, miners etc)
	StateLookupRobustAddress(context.Context, address.Address, types.TipSetKey) (address.Address, error)                                                     //perm:read
	StateListMiners(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                                                                     //perm:read
	StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                                                                     //perm:read
	StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.MinerPower, error)                                               //perm:read
	StateMinerAvailableBalance(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (big.Int, error)                                             //perm:read
	StateSectorExpiration(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorExpiration, error)  //perm:read
	StateChangedActors(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error)                                                                    //perm:read
	StateMinerSectorCount(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MinerSectors, error)                                        //perm:read
	StateMarketBalance(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MarketBalance, error)                                          //perm:read
	StateDealProviderCollateralBounds(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (types.DealCollateralBounds, error) //perm:read
	StateVerifiedClientStatus(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)                                     //perm:read
	// StateMinerAllocated returns a bitfield containing all sector numbers marked as allocated in miner state
	StateMinerAllocated(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error) //perm:read
}

type IMinerStateStruct

type IMinerStateStruct struct {
	Internal struct {
		StateAllMinerFaults                func(ctx context.Context, lookback abi.ChainEpoch, ts types.TipSetKey) ([]*types.Fault, error)                                                      `perm:"read"`
		StateChangedActors                 func(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error)                                                                             `perm:"read"`
		StateCirculatingSupply             func(ctx context.Context, tsk types.TipSetKey) (abi.TokenAmount, error)                                                                             `perm:"read"`
		StateComputeDataCID                func(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, deals []abi.DealID, tsk types.TipSetKey) (cid.Cid, error)      `perm:"read"`
		StateDealProviderCollateralBounds  func(ctx context.Context, size abi.PaddedPieceSize, verified bool, tsk types.TipSetKey) (types.DealCollateralBounds, error)                         `perm:"read"`
		StateDecodeParams                  func(ctx context.Context, toAddr address.Address, method abi.MethodNum, params []byte, tsk types.TipSetKey) (interface{}, error)                    `perm:"read"`
		StateEncodeParams                  func(ctx context.Context, toActCode cid.Cid, method abi.MethodNum, params json.RawMessage) ([]byte, error)                                          `perm:"read"`
		StateGetAllAllocations             func(ctx context.Context, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)                                               `perm:"read"`
		StateGetAllClaims                  func(ctx context.Context, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error)                                                         `perm:"read"`
		StateGetAllocation                 func(ctx context.Context, clientAddr address.Address, allocationID verifreg.AllocationId, tsk types.TipSetKey) (*verifreg.Allocation, error)        `perm:"read"`
		StateGetAllocationForPendingDeal   func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*verifreg.Allocation, error)                                                     `perm:"read"`
		StateGetAllocationIdForPendingDeal func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (verifreg.AllocationId, error)                                                    `perm:"read"`
		StateGetAllocations                func(ctx context.Context, clientAddr address.Address, tsk types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)                   `perm:"read"`
		StateGetClaim                      func(ctx context.Context, providerAddr address.Address, claimID verifreg.ClaimId, tsk types.TipSetKey) (*verifreg.Claim, error)                     `perm:"read"`
		StateGetClaims                     func(ctx context.Context, providerAddr address.Address, tsk types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error)                           `perm:"read"`
		StateListActors                    func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                                                                           `perm:"read"`
		StateListMessages                  func(ctx context.Context, match *types.MessageMatch, tsk types.TipSetKey, toht abi.ChainEpoch) ([]cid.Cid, error)                                   `perm:"read"`
		StateListMiners                    func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                                                                           `perm:"read"`
		StateLookupID                      func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)                                                       `perm:"read"`
		StateLookupRobustAddress           func(context.Context, address.Address, types.TipSetKey) (address.Address, error)                                                                    `perm:"read"`
		StateMarketBalance                 func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MarketBalance, error)                                                   `perm:"read"`
		StateMarketDeals                   func(ctx context.Context, tsk types.TipSetKey) (map[string]*types.MarketDeal, error)                                                                `perm:"read"`
		StateMarketStorageDeal             func(ctx context.Context, dealID abi.DealID, tsk types.TipSetKey) (*types.MarketDeal, error)                                                        `perm:"read"`
		StateMinerActiveSectors            func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)                                          `perm:"read"`
		StateMinerAllocated                func(context.Context, address.Address, types.TipSetKey) (*bitfield.BitField, error)                                                                 `perm:"read"`
		StateMinerAvailableBalance         func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (big.Int, error)                                                              `perm:"read"`
		StateMinerDeadlines                func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) ([]types.Deadline, error)                                                     `perm:"read"`
		StateMinerFaults                   func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error)                                                    `perm:"read"`
		StateMinerInfo                     func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (types.MinerInfo, error)                                                      `perm:"read"`
		StateMinerInitialPledgeCollateral  func(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error)                               `perm:"read"`
		StateMinerInitialPledgeForSector   func(ctx context.Context, sectorDuration abi.ChainEpoch, sectorSize abi.SectorSize, verifiedSize uint64, tsk types.TipSetKey) (types.BigInt, error) `perm:"read"`
		StateMinerPartitions               func(ctx context.Context, maddr address.Address, dlIdx uint64, tsk types.TipSetKey) ([]types.Partition, error)                                      `perm:"read"`
		StateMinerPower                    func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.MinerPower, error)                                                     `perm:"read"`
		StateMinerPreCommitDepositForPower func(ctx context.Context, maddr address.Address, pci types.SectorPreCommitInfo, tsk types.TipSetKey) (big.Int, error)                               `perm:"read"`
		StateMinerProvingDeadline          func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (*dline.Info, error)                                                          `perm:"read"`
		StateMinerRecoveries               func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (bitfield.BitField, error)                                                    `perm:"read"`
		StateMinerSectorAllocated          func(ctx context.Context, maddr address.Address, s abi.SectorNumber, tsk types.TipSetKey) (bool, error)                                             `perm:"read"`
		StateMinerSectorCount              func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (types.MinerSectors, error)                                                    `perm:"read"`
		StateMinerSectorSize               func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (abi.SectorSize, error)                                                       `perm:"read"`
		StateMinerSectors                  func(ctx context.Context, maddr address.Address, sectorNos *bitfield.BitField, tsk types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)            `perm:"read"`
		StateMinerWorkerAddress            func(ctx context.Context, maddr address.Address, tsk types.TipSetKey) (address.Address, error)                                                      `perm:"read"`
		StateReadState                     func(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.ActorState, error)                                                    `perm:"read"`
		StateSectorExpiration              func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorExpiration, error)              `perm:"read"`
		StateSectorGetInfo                 func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorOnChainInfo, error)                        `perm:"read"`
		StateSectorPartition               func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tsk types.TipSetKey) (*lminer.SectorLocation, error)                `perm:"read"`
		StateSectorPreCommitInfo           func(ctx context.Context, maddr address.Address, n abi.SectorNumber, tsk types.TipSetKey) (*types.SectorPreCommitOnChainInfo, error)                `perm:"read"`
		StateVMCirculatingSupplyInternal   func(ctx context.Context, tsk types.TipSetKey) (types.CirculatingSupply, error)                                                                     `perm:"read"`
		StateVerifiedClientStatus          func(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*abi.StoragePower, error)                                                     `perm:"read"`
	}
}

func (*IMinerStateStruct) StateAllMinerFaults added in v1.7.0

func (s *IMinerStateStruct) StateAllMinerFaults(p0 context.Context, p1 abi.ChainEpoch, p2 types.TipSetKey) ([]*types.Fault, error)

func (*IMinerStateStruct) StateChangedActors added in v1.7.0

func (s *IMinerStateStruct) StateChangedActors(p0 context.Context, p1 cid.Cid, p2 cid.Cid) (map[string]types.Actor, error)

func (*IMinerStateStruct) StateCirculatingSupply

func (s *IMinerStateStruct) StateCirculatingSupply(p0 context.Context, p1 types.TipSetKey) (abi.TokenAmount, error)

func (*IMinerStateStruct) StateComputeDataCID added in v1.8.0

func (s *IMinerStateStruct) StateComputeDataCID(p0 context.Context, p1 address.Address, p2 abi.RegisteredSealProof, p3 []abi.DealID, p4 types.TipSetKey) (cid.Cid, error)

func (*IMinerStateStruct) StateDealProviderCollateralBounds

func (s *IMinerStateStruct) StateDealProviderCollateralBounds(p0 context.Context, p1 abi.PaddedPieceSize, p2 bool, p3 types.TipSetKey) (types.DealCollateralBounds, error)

func (*IMinerStateStruct) StateDecodeParams added in v1.7.0

func (s *IMinerStateStruct) StateDecodeParams(p0 context.Context, p1 address.Address, p2 abi.MethodNum, p3 []byte, p4 types.TipSetKey) (interface{}, error)

func (*IMinerStateStruct) StateEncodeParams added in v1.7.0

func (s *IMinerStateStruct) StateEncodeParams(p0 context.Context, p1 cid.Cid, p2 abi.MethodNum, p3 json.RawMessage) ([]byte, error)

func (*IMinerStateStruct) StateGetAllAllocations added in v1.15.0

func (s *IMinerStateStruct) StateGetAllAllocations(p0 context.Context, p1 types.TipSetKey) (map[verifreg.AllocationId]verifreg.Allocation, error)

func (*IMinerStateStruct) StateGetAllClaims added in v1.15.0

func (s *IMinerStateStruct) StateGetAllClaims(p0 context.Context, p1 types.TipSetKey) (map[verifreg.ClaimId]verifreg.Claim, error)

func (*IMinerStateStruct) StateGetAllocation added in v1.8.0

func (*IMinerStateStruct) StateGetAllocationForPendingDeal added in v1.8.0

func (s *IMinerStateStruct) StateGetAllocationForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*verifreg.Allocation, error)

func (*IMinerStateStruct) StateGetAllocationIdForPendingDeal added in v1.15.0

func (s *IMinerStateStruct) StateGetAllocationIdForPendingDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (verifreg.AllocationId, error)

func (*IMinerStateStruct) StateGetAllocations added in v1.8.0

func (*IMinerStateStruct) StateGetClaim added in v1.8.0

func (*IMinerStateStruct) StateGetClaims added in v1.8.0

func (*IMinerStateStruct) StateListActors

func (s *IMinerStateStruct) StateListActors(p0 context.Context, p1 types.TipSetKey) ([]address.Address, error)

func (*IMinerStateStruct) StateListMessages added in v1.7.0

func (s *IMinerStateStruct) StateListMessages(p0 context.Context, p1 *types.MessageMatch, p2 types.TipSetKey, p3 abi.ChainEpoch) ([]cid.Cid, error)

func (*IMinerStateStruct) StateListMiners

func (s *IMinerStateStruct) StateListMiners(p0 context.Context, p1 types.TipSetKey) ([]address.Address, error)

func (*IMinerStateStruct) StateLookupID

func (*IMinerStateStruct) StateLookupRobustAddress added in v1.6.0

func (s *IMinerStateStruct) StateLookupRobustAddress(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)

func (*IMinerStateStruct) StateMarketBalance

func (s *IMinerStateStruct) StateMarketBalance(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MarketBalance, error)

func (*IMinerStateStruct) StateMarketDeals

func (s *IMinerStateStruct) StateMarketDeals(p0 context.Context, p1 types.TipSetKey) (map[string]*types.MarketDeal, error)

func (*IMinerStateStruct) StateMarketStorageDeal

func (s *IMinerStateStruct) StateMarketStorageDeal(p0 context.Context, p1 abi.DealID, p2 types.TipSetKey) (*types.MarketDeal, error)

func (*IMinerStateStruct) StateMinerActiveSectors

func (s *IMinerStateStruct) StateMinerActiveSectors(p0 context.Context, p1 address.Address, p2 types.TipSetKey) ([]*lminer.SectorOnChainInfo, error)

func (*IMinerStateStruct) StateMinerAllocated added in v1.8.0

func (s *IMinerStateStruct) StateMinerAllocated(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*bitfield.BitField, error)

func (*IMinerStateStruct) StateMinerAvailableBalance

func (s *IMinerStateStruct) StateMinerAvailableBalance(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (big.Int, error)

func (*IMinerStateStruct) StateMinerDeadlines

func (s *IMinerStateStruct) StateMinerDeadlines(p0 context.Context, p1 address.Address, p2 types.TipSetKey) ([]types.Deadline, error)

func (*IMinerStateStruct) StateMinerFaults

func (*IMinerStateStruct) StateMinerInfo

func (*IMinerStateStruct) StateMinerInitialPledgeCollateral

func (s *IMinerStateStruct) StateMinerInitialPledgeCollateral(p0 context.Context, p1 address.Address, p2 types.SectorPreCommitInfo, p3 types.TipSetKey) (big.Int, error)

func (*IMinerStateStruct) StateMinerInitialPledgeForSector added in v1.17.0

func (s *IMinerStateStruct) StateMinerInitialPledgeForSector(p0 context.Context, p1 abi.ChainEpoch, p2 abi.SectorSize, p3 uint64, p4 types.TipSetKey) (types.BigInt, error)

func (*IMinerStateStruct) StateMinerPartitions

func (s *IMinerStateStruct) StateMinerPartitions(p0 context.Context, p1 address.Address, p2 uint64, p3 types.TipSetKey) ([]types.Partition, error)

func (*IMinerStateStruct) StateMinerPower

func (s *IMinerStateStruct) StateMinerPower(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*types.MinerPower, error)

func (*IMinerStateStruct) StateMinerPreCommitDepositForPower

func (s *IMinerStateStruct) StateMinerPreCommitDepositForPower(p0 context.Context, p1 address.Address, p2 types.SectorPreCommitInfo, p3 types.TipSetKey) (big.Int, error)

func (*IMinerStateStruct) StateMinerProvingDeadline

func (s *IMinerStateStruct) StateMinerProvingDeadline(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*dline.Info, error)

func (*IMinerStateStruct) StateMinerRecoveries

func (s *IMinerStateStruct) StateMinerRecoveries(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (bitfield.BitField, error)

func (*IMinerStateStruct) StateMinerSectorAllocated

func (s *IMinerStateStruct) StateMinerSectorAllocated(p0 context.Context, p1 address.Address, p2 abi.SectorNumber, p3 types.TipSetKey) (bool, error)

func (*IMinerStateStruct) StateMinerSectorCount

func (s *IMinerStateStruct) StateMinerSectorCount(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (types.MinerSectors, error)

func (*IMinerStateStruct) StateMinerSectorSize

func (s *IMinerStateStruct) StateMinerSectorSize(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (abi.SectorSize, error)

func (*IMinerStateStruct) StateMinerSectors

func (*IMinerStateStruct) StateMinerWorkerAddress

func (s *IMinerStateStruct) StateMinerWorkerAddress(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (address.Address, error)

func (*IMinerStateStruct) StateReadState added in v1.7.0

func (*IMinerStateStruct) StateSectorExpiration

func (*IMinerStateStruct) StateSectorGetInfo

func (*IMinerStateStruct) StateSectorPartition

func (*IMinerStateStruct) StateSectorPreCommitInfo

func (*IMinerStateStruct) StateVMCirculatingSupplyInternal

func (s *IMinerStateStruct) StateVMCirculatingSupplyInternal(p0 context.Context, p1 types.TipSetKey) (types.CirculatingSupply, error)

func (*IMinerStateStruct) StateVerifiedClientStatus

func (s *IMinerStateStruct) StateVerifiedClientStatus(p0 context.Context, p1 address.Address, p2 types.TipSetKey) (*abi.StoragePower, error)

type IMining

type IMining interface {
	MinerGetBaseInfo(ctx context.Context, maddr address.Address, round abi.ChainEpoch, tsk types.TipSetKey) (*types.MiningBaseInfo, error) //perm:read
	MinerCreateBlock(ctx context.Context, bt *types.BlockTemplate) (*types.BlockMsg, error)                                                //perm:write
}

type IMiningStruct

type IMiningStruct struct {
	Internal struct {
		MinerCreateBlock func(ctx context.Context, bt *types.BlockTemplate) (*types.BlockMsg, error)                                                `perm:"write"`
		MinerGetBaseInfo func(ctx context.Context, maddr address.Address, round abi.ChainEpoch, tsk types.TipSetKey) (*types.MiningBaseInfo, error) `perm:"read"`
	}
}

func (*IMiningStruct) MinerCreateBlock

func (s *IMiningStruct) MinerCreateBlock(p0 context.Context, p1 *types.BlockTemplate) (*types.BlockMsg, error)

func (*IMiningStruct) MinerGetBaseInfo

type INetwork

type INetwork interface {
	NetFindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo //perm:read
	NetGetClosestPeers(ctx context.Context, key string) ([]peer.ID, error)                  //perm:read
	NetConnectedness(context.Context, peer.ID) (network2.Connectedness, error)              //perm:read
	NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)                      //perm:read
	NetConnect(ctx context.Context, pi peer.AddrInfo) error                                 //perm:admin
	NetPeers(ctx context.Context) ([]peer.AddrInfo, error)                                  //perm:read
	NetPeerInfo(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error)            //perm:read
	NetAgentVersion(ctx context.Context, p peer.ID) (string, error)                         //perm:read
	NetPing(ctx context.Context, p peer.ID) (time.Duration, error)                          //perm:read
	NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)                              //perm:read
	NetDisconnect(ctx context.Context, p peer.ID) error                                     //perm:admin
	NetAutoNatStatus(context.Context) (types.NatInfo, error)                                //perm:read
	NetPubsubScores(context.Context) ([]types.PubsubScore, error)                           //perm:read
	ID(ctx context.Context) (peer.ID, error)                                                //perm:read

	// NetBandwidthStats returns statistics about the nodes total bandwidth
	// usage and current rate across all peers and protocols.
	NetBandwidthStats(ctx context.Context) (metrics.Stats, error) //perm:read

	// NetBandwidthStatsByPeer returns statistics about the nodes bandwidth
	// usage and current rate per peer
	NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error) //perm:read

	// NetBandwidthStatsByProtocol returns statistics about the nodes bandwidth
	// usage and current rate per protocol
	NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error) //perm:read

	NetProtectAdd(ctx context.Context, acl []peer.ID) error    //perm:admin
	NetProtectRemove(ctx context.Context, acl []peer.ID) error //perm:admin
	NetProtectList(ctx context.Context) ([]peer.ID, error)     //perm:read
}

type INetworkStruct

type INetworkStruct struct {
	Internal struct {
		ID                          func(ctx context.Context) (peer.ID, error)                             `perm:"read"`
		NetAddrsListen              func(ctx context.Context) (peer.AddrInfo, error)                       `perm:"read"`
		NetAgentVersion             func(ctx context.Context, p peer.ID) (string, error)                   `perm:"read"`
		NetAutoNatStatus            func(context.Context) (types.NatInfo, error)                           `perm:"read"`
		NetBandwidthStats           func(ctx context.Context) (metrics.Stats, error)                       `perm:"read"`
		NetBandwidthStatsByPeer     func(ctx context.Context) (map[string]metrics.Stats, error)            `perm:"read"`
		NetBandwidthStatsByProtocol func(ctx context.Context) (map[protocol.ID]metrics.Stats, error)       `perm:"read"`
		NetConnect                  func(ctx context.Context, pi peer.AddrInfo) error                      `perm:"admin"`
		NetConnectedness            func(context.Context, peer.ID) (network2.Connectedness, error)         `perm:"read"`
		NetDisconnect               func(ctx context.Context, p peer.ID) error                             `perm:"admin"`
		NetFindPeer                 func(ctx context.Context, p peer.ID) (peer.AddrInfo, error)            `perm:"read"`
		NetFindProvidersAsync       func(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo `perm:"read"`
		NetGetClosestPeers          func(ctx context.Context, key string) ([]peer.ID, error)               `perm:"read"`
		NetPeerInfo                 func(ctx context.Context, p peer.ID) (*types.ExtendedPeerInfo, error)  `perm:"read"`
		NetPeers                    func(ctx context.Context) ([]peer.AddrInfo, error)                     `perm:"read"`
		NetPing                     func(ctx context.Context, p peer.ID) (time.Duration, error)            `perm:"read"`
		NetProtectAdd               func(ctx context.Context, acl []peer.ID) error                         `perm:"admin"`
		NetProtectList              func(ctx context.Context) ([]peer.ID, error)                           `perm:"read"`
		NetProtectRemove            func(ctx context.Context, acl []peer.ID) error                         `perm:"admin"`
		NetPubsubScores             func(context.Context) ([]types.PubsubScore, error)                     `perm:"read"`
	}
}

func (*INetworkStruct) ID added in v1.6.1

func (s *INetworkStruct) ID(p0 context.Context) (peer.ID, error)

func (*INetworkStruct) NetAddrsListen

func (s *INetworkStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)

func (*INetworkStruct) NetAgentVersion added in v1.6.1

func (s *INetworkStruct) NetAgentVersion(p0 context.Context, p1 peer.ID) (string, error)

func (*INetworkStruct) NetAutoNatStatus added in v1.6.1

func (s *INetworkStruct) NetAutoNatStatus(p0 context.Context) (types.NatInfo, error)

func (*INetworkStruct) NetBandwidthStats added in v1.6.1

func (s *INetworkStruct) NetBandwidthStats(p0 context.Context) (metrics.Stats, error)

func (*INetworkStruct) NetBandwidthStatsByPeer added in v1.6.1

func (s *INetworkStruct) NetBandwidthStatsByPeer(p0 context.Context) (map[string]metrics.Stats, error)

func (*INetworkStruct) NetBandwidthStatsByProtocol added in v1.6.1

func (s *INetworkStruct) NetBandwidthStatsByProtocol(p0 context.Context) (map[protocol.ID]metrics.Stats, error)

func (*INetworkStruct) NetConnect added in v1.6.1

func (s *INetworkStruct) NetConnect(p0 context.Context, p1 peer.AddrInfo) error

func (*INetworkStruct) NetConnectedness added in v1.6.1

func (s *INetworkStruct) NetConnectedness(p0 context.Context, p1 peer.ID) (network2.Connectedness, error)

func (*INetworkStruct) NetDisconnect added in v1.6.1

func (s *INetworkStruct) NetDisconnect(p0 context.Context, p1 peer.ID) error

func (*INetworkStruct) NetFindPeer added in v1.6.1

func (s *INetworkStruct) NetFindPeer(p0 context.Context, p1 peer.ID) (peer.AddrInfo, error)

func (*INetworkStruct) NetFindProvidersAsync added in v1.6.1

func (s *INetworkStruct) NetFindProvidersAsync(p0 context.Context, p1 cid.Cid, p2 int) <-chan peer.AddrInfo

func (*INetworkStruct) NetGetClosestPeers added in v1.6.1

func (s *INetworkStruct) NetGetClosestPeers(p0 context.Context, p1 string) ([]peer.ID, error)

func (*INetworkStruct) NetPeerInfo added in v1.6.1

func (s *INetworkStruct) NetPeerInfo(p0 context.Context, p1 peer.ID) (*types.ExtendedPeerInfo, error)

func (*INetworkStruct) NetPeers added in v1.6.1

func (s *INetworkStruct) NetPeers(p0 context.Context) ([]peer.AddrInfo, error)

func (*INetworkStruct) NetPing added in v1.6.1

func (s *INetworkStruct) NetPing(p0 context.Context, p1 peer.ID) (time.Duration, error)

func (*INetworkStruct) NetProtectAdd added in v1.6.1

func (s *INetworkStruct) NetProtectAdd(p0 context.Context, p1 []peer.ID) error

func (*INetworkStruct) NetProtectList added in v1.6.1

func (s *INetworkStruct) NetProtectList(p0 context.Context) ([]peer.ID, error)

func (*INetworkStruct) NetProtectRemove added in v1.6.1

func (s *INetworkStruct) NetProtectRemove(p0 context.Context, p1 []peer.ID) error

func (*INetworkStruct) NetPubsubScores added in v1.8.0

func (s *INetworkStruct) NetPubsubScores(p0 context.Context) ([]types.PubsubScore, error)

type IPaychan

type IPaychan interface {
	// PaychGet gets or creates a payment channel between address pair
	//  The specified amount will be reserved for use. If there aren't enough non-reserved funds
	//    available, funds will be added through an on-chain message.
	//  - When opts.OffChain is true, this call will not cause any messages to be sent to the chain (no automatic
	//    channel creation/funds adding). If the operation can't be performed without sending a message an error will be
	//    returned. Note that even when this option is specified, this call can be blocked by previous operations on the
	//    channel waiting for on-chain operations.
	PaychGet(ctx context.Context, from, to address.Address, amt types.BigInt, opts types.PaychGetOpts) (*types.ChannelInfo, error) //perm:sign
	// PaychFund gets or creates a payment channel between address pair.
	// The specified amount will be added to the channel through on-chain send for future use
	PaychFund(ctx context.Context, from, to address.Address, amt types.BigInt) (*types.ChannelInfo, error) //perm:sign
	// PaychAvailableFunds get the status of an outbound payment channel
	// @pch: payment channel address
	PaychAvailableFunds(ctx context.Context, ch address.Address) (*types.ChannelAvailableFunds, error) //perm:sign
	// PaychAvailableFundsByFromTo  get the status of an outbound payment channel
	// @from: the payment channel sender
	// @to: he payment channel recipient
	PaychAvailableFundsByFromTo(ctx context.Context, from, to address.Address) (*types.ChannelAvailableFunds, error) //perm:sign
	// PaychGetWaitReady waits until the create channel / add funds message with the sentinel
	// @sentinel: given message CID arrives.
	// @ch: the returned channel address can safely be used against the Manager methods.
	PaychGetWaitReady(ctx context.Context, sentinel cid.Cid) (address.Address, error) //perm:sign
	// PaychAllocateLane Allocate late creates a lane within a payment channel so that calls to
	// CreatePaymentVoucher will automatically make vouchers only for the difference in total
	PaychAllocateLane(ctx context.Context, ch address.Address) (uint64, error) //perm:sign
	// PaychNewPayment aggregate vouchers into a new lane
	// @from: the payment channel sender
	// @to: the payment channel recipient
	// @vouchers: the outstanding (non-redeemed) vouchers
	PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []types.VoucherSpec) (*types.PaymentInfo, error) //perm:sign
	// PaychList list the addresses of all channels that have been created
	PaychList(ctx context.Context) ([]address.Address, error) //perm:read
	// PaychStatus get the payment channel status
	// @pch: payment channel address
	PaychStatus(ctx context.Context, pch address.Address) (*types.Status, error) //perm:read
	// PaychSettle update payment channel status to settle
	// After a settlement period (currently 12 hours) either party to the payment channel can call collect on chain
	// @pch: payment channel address
	PaychSettle(ctx context.Context, addr address.Address) (cid.Cid, error) //perm:sign
	// PaychCollect update payment channel status to collect
	// Collect sends the value of submitted vouchers to the channel recipient (the provider),
	// and refunds the remaining channel balance to the channel creator (the client).
	// @pch: payment channel address
	PaychCollect(ctx context.Context, addr address.Address) (cid.Cid, error) //perm:sign

	// PaychVoucherCheckValid checks if the given voucher is valid (is or could become spendable at some point).
	// If the channel is not in the store, fetches the channel from state (and checks that
	// the channel To address is owned by the wallet).
	// @pch: payment channel address
	// @sv: voucher
	PaychVoucherCheckValid(ctx context.Context, ch address.Address, sv *types.SignedVoucher) error //perm:read
	// PaychVoucherCheckSpendable checks if the given voucher is currently spendable
	// @pch: payment channel address
	// @sv: voucher
	PaychVoucherCheckSpendable(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (bool, error) //perm:read
	// PaychVoucherAdd adds a voucher for an inbound channel.
	// If the channel is not in the store, fetches the channel from state (and checks that
	// the channel To address is owned by the wallet).
	PaychVoucherAdd(ctx context.Context, ch address.Address, sv *types.SignedVoucher, proof []byte, minDelta big.Int) (big.Int, error) //perm:write
	// PaychVoucherCreate creates a new signed voucher on the given payment channel
	// with the given lane and amount.  The value passed in is exactly the value
	// that will be used to create the voucher, so if previous vouchers exist, the
	// actual additional value of this voucher will only be the difference between
	// the two.
	// If there are insufficient funds in the channel to create the voucher,
	// returns a nil voucher and the shortfall.
	PaychVoucherCreate(ctx context.Context, pch address.Address, amt big.Int, lane uint64) (*types.VoucherCreateResult, error) //perm:sign
	// PaychVoucherList list vouchers in payment channel
	// @pch: payment channel address
	PaychVoucherList(ctx context.Context, pch address.Address) ([]*types.SignedVoucher, error) //perm:write
	// PaychVoucherSubmit Submit voucher to chain to update payment channel state
	// @pch: payment channel address
	// @sv: voucher in payment channel
	PaychVoucherSubmit(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error) //perm:sign
}

type IPaychanStruct

type IPaychanStruct struct {
	Internal struct {
		PaychAllocateLane           func(ctx context.Context, ch address.Address) (uint64, error)                                                              `perm:"sign"`
		PaychAvailableFunds         func(ctx context.Context, ch address.Address) (*types.ChannelAvailableFunds, error)                                        `perm:"sign"`
		PaychAvailableFundsByFromTo func(ctx context.Context, from, to address.Address) (*types.ChannelAvailableFunds, error)                                  `perm:"sign"`
		PaychCollect                func(ctx context.Context, addr address.Address) (cid.Cid, error)                                                           `perm:"sign"`
		PaychFund                   func(ctx context.Context, from, to address.Address, amt types.BigInt) (*types.ChannelInfo, error)                          `perm:"sign"`
		PaychGet                    func(ctx context.Context, from, to address.Address, amt types.BigInt, opts types.PaychGetOpts) (*types.ChannelInfo, error) `perm:"sign"`
		PaychGetWaitReady           func(ctx context.Context, sentinel cid.Cid) (address.Address, error)                                                       `perm:"sign"`
		PaychList                   func(ctx context.Context) ([]address.Address, error)                                                                       `perm:"read"`
		PaychNewPayment             func(ctx context.Context, from, to address.Address, vouchers []types.VoucherSpec) (*types.PaymentInfo, error)              `perm:"sign"`
		PaychSettle                 func(ctx context.Context, addr address.Address) (cid.Cid, error)                                                           `perm:"sign"`
		PaychStatus                 func(ctx context.Context, pch address.Address) (*types.Status, error)                                                      `perm:"read"`
		PaychVoucherAdd             func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, proof []byte, minDelta big.Int) (big.Int, error)    `perm:"write"`
		PaychVoucherCheckSpendable  func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (bool, error)          `perm:"read"`
		PaychVoucherCheckValid      func(ctx context.Context, ch address.Address, sv *types.SignedVoucher) error                                               `perm:"read"`
		PaychVoucherCreate          func(ctx context.Context, pch address.Address, amt big.Int, lane uint64) (*types.VoucherCreateResult, error)               `perm:"sign"`
		PaychVoucherList            func(ctx context.Context, pch address.Address) ([]*types.SignedVoucher, error)                                             `perm:"write"`
		PaychVoucherSubmit          func(ctx context.Context, ch address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (cid.Cid, error)       `perm:"sign"`
	}
}

func (*IPaychanStruct) PaychAllocateLane

func (s *IPaychanStruct) PaychAllocateLane(p0 context.Context, p1 address.Address) (uint64, error)

func (*IPaychanStruct) PaychAvailableFunds

func (s *IPaychanStruct) PaychAvailableFunds(p0 context.Context, p1 address.Address) (*types.ChannelAvailableFunds, error)

func (*IPaychanStruct) PaychAvailableFundsByFromTo

func (s *IPaychanStruct) PaychAvailableFundsByFromTo(p0 context.Context, p1, p2 address.Address) (*types.ChannelAvailableFunds, error)

func (*IPaychanStruct) PaychCollect

func (s *IPaychanStruct) PaychCollect(p0 context.Context, p1 address.Address) (cid.Cid, error)

func (*IPaychanStruct) PaychFund added in v1.6.0

func (s *IPaychanStruct) PaychFund(p0 context.Context, p1, p2 address.Address, p3 types.BigInt) (*types.ChannelInfo, error)

func (*IPaychanStruct) PaychGet

func (*IPaychanStruct) PaychGetWaitReady

func (s *IPaychanStruct) PaychGetWaitReady(p0 context.Context, p1 cid.Cid) (address.Address, error)

func (*IPaychanStruct) PaychList

func (s *IPaychanStruct) PaychList(p0 context.Context) ([]address.Address, error)

func (*IPaychanStruct) PaychNewPayment

func (s *IPaychanStruct) PaychNewPayment(p0 context.Context, p1, p2 address.Address, p3 []types.VoucherSpec) (*types.PaymentInfo, error)

func (*IPaychanStruct) PaychSettle

func (s *IPaychanStruct) PaychSettle(p0 context.Context, p1 address.Address) (cid.Cid, error)

func (*IPaychanStruct) PaychStatus

func (s *IPaychanStruct) PaychStatus(p0 context.Context, p1 address.Address) (*types.Status, error)

func (*IPaychanStruct) PaychVoucherAdd

func (s *IPaychanStruct) PaychVoucherAdd(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, p4 big.Int) (big.Int, error)

func (*IPaychanStruct) PaychVoucherCheckSpendable

func (s *IPaychanStruct) PaychVoucherCheckSpendable(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, p4 []byte) (bool, error)

func (*IPaychanStruct) PaychVoucherCheckValid

func (s *IPaychanStruct) PaychVoucherCheckValid(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher) error

func (*IPaychanStruct) PaychVoucherCreate

func (s *IPaychanStruct) PaychVoucherCreate(p0 context.Context, p1 address.Address, p2 big.Int, p3 uint64) (*types.VoucherCreateResult, error)

func (*IPaychanStruct) PaychVoucherList

func (s *IPaychanStruct) PaychVoucherList(p0 context.Context, p1 address.Address) ([]*types.SignedVoucher, error)

func (*IPaychanStruct) PaychVoucherSubmit

func (s *IPaychanStruct) PaychVoucherSubmit(p0 context.Context, p1 address.Address, p2 *types.SignedVoucher, p3 []byte, p4 []byte) (cid.Cid, error)

type ISyncer

type ISyncer interface {
	ChainSyncHandleNewTipSet(ctx context.Context, ci *types.ChainInfo) error     //perm:write
	SetConcurrent(ctx context.Context, concurrent int64) error                   //perm:admin
	SyncerTracker(ctx context.Context) *types.TargetTracker                      //perm:read
	Concurrent(ctx context.Context) int64                                        //perm:read
	ChainTipSetWeight(ctx context.Context, tsk types.TipSetKey) (big.Int, error) //perm:read
	SyncSubmitBlock(ctx context.Context, blk *types.BlockMsg) error              //perm:write
	SyncState(ctx context.Context) (*types.SyncState, error)                     //perm:read
	// SyncIncomingBlocks returns a channel streaming incoming, potentially not
	// yet synced block headers.
	SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error) //perm:read
	// SyncCheckpoint marks a blocks as checkpointed, meaning that it won't ever fork away from it.
	SyncCheckpoint(ctx context.Context, tsk types.TipSetKey) error //perm:admin
}

type ISyncerStruct

type ISyncerStruct struct {
	Internal struct {
		ChainSyncHandleNewTipSet func(ctx context.Context, ci *types.ChainInfo) error            `perm:"write"`
		ChainTipSetWeight        func(ctx context.Context, tsk types.TipSetKey) (big.Int, error) `perm:"read"`
		Concurrent               func(ctx context.Context) int64                                 `perm:"read"`
		SetConcurrent            func(ctx context.Context, concurrent int64) error               `perm:"admin"`
		SyncCheckpoint           func(ctx context.Context, tsk types.TipSetKey) error            `perm:"admin"`
		SyncIncomingBlocks       func(ctx context.Context) (<-chan *types.BlockHeader, error)    `perm:"read"`
		SyncState                func(ctx context.Context) (*types.SyncState, error)             `perm:"read"`
		SyncSubmitBlock          func(ctx context.Context, blk *types.BlockMsg) error            `perm:"write"`
		SyncerTracker            func(ctx context.Context) *types.TargetTracker                  `perm:"read"`
	}
}

func (*ISyncerStruct) ChainSyncHandleNewTipSet

func (s *ISyncerStruct) ChainSyncHandleNewTipSet(p0 context.Context, p1 *types.ChainInfo) error

func (*ISyncerStruct) ChainTipSetWeight

func (s *ISyncerStruct) ChainTipSetWeight(p0 context.Context, p1 types.TipSetKey) (big.Int, error)

func (*ISyncerStruct) Concurrent

func (s *ISyncerStruct) Concurrent(p0 context.Context) int64

func (*ISyncerStruct) SetConcurrent

func (s *ISyncerStruct) SetConcurrent(p0 context.Context, p1 int64) error

func (*ISyncerStruct) SyncCheckpoint added in v1.17.0

func (s *ISyncerStruct) SyncCheckpoint(p0 context.Context, p1 types.TipSetKey) error

func (*ISyncerStruct) SyncIncomingBlocks added in v1.14.0

func (s *ISyncerStruct) SyncIncomingBlocks(p0 context.Context) (<-chan *types.BlockHeader, error)

func (*ISyncerStruct) SyncState

func (s *ISyncerStruct) SyncState(p0 context.Context) (*types.SyncState, error)

func (*ISyncerStruct) SyncSubmitBlock

func (s *ISyncerStruct) SyncSubmitBlock(p0 context.Context, p1 *types.BlockMsg) error

func (*ISyncerStruct) SyncerTracker

func (s *ISyncerStruct) SyncerTracker(p0 context.Context) *types.TargetTracker

type IWallet

type IWallet interface {
	WalletSign(ctx context.Context, k address.Address, msg []byte, meta types.MsgMeta) (*crypto.Signature, error) //perm:sign
	WalletExport(ctx context.Context, addr address.Address, password string) (*types.KeyInfo, error)              //perm:admin
	WalletImport(ctx context.Context, key *types.KeyInfo) (address.Address, error)                                //perm:admin
	WalletDelete(ctx context.Context, addr address.Address) error                                                 //perm:admin
	WalletHas(ctx context.Context, addr address.Address) (bool, error)                                            //perm:write
	WalletNewAddress(ctx context.Context, protocol address.Protocol) (address.Address, error)                     //perm:write
	WalletBalance(ctx context.Context, addr address.Address) (abi.TokenAmount, error)                             //perm:read
	WalletDefaultAddress(ctx context.Context) (address.Address, error)                                            //perm:write
	WalletAddresses(ctx context.Context) []address.Address                                                        //perm:admin
	WalletSetDefault(ctx context.Context, addr address.Address) error                                             //perm:write
	WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error)   //perm:sign
	LockWallet(ctx context.Context) error                                                                         //perm:admin
	UnLockWallet(ctx context.Context, password []byte) error                                                      //perm:admin
	SetPassword(ctx context.Context, password []byte) error                                                       //perm:admin
	HasPassword(ctx context.Context) bool                                                                         //perm:admin
	WalletState(ctx context.Context) int                                                                          //perm:admin
}

type IWalletStruct

type IWalletStruct struct {
	Internal struct {
		HasPassword          func(ctx context.Context) bool                                                                          `perm:"admin"`
		LockWallet           func(ctx context.Context) error                                                                         `perm:"admin"`
		SetPassword          func(ctx context.Context, password []byte) error                                                        `perm:"admin"`
		UnLockWallet         func(ctx context.Context, password []byte) error                                                        `perm:"admin"`
		WalletAddresses      func(ctx context.Context) []address.Address                                                             `perm:"admin"`
		WalletBalance        func(ctx context.Context, addr address.Address) (abi.TokenAmount, error)                                `perm:"read"`
		WalletDefaultAddress func(ctx context.Context) (address.Address, error)                                                      `perm:"write"`
		WalletDelete         func(ctx context.Context, addr address.Address) error                                                   `perm:"admin"`
		WalletExport         func(ctx context.Context, addr address.Address, password string) (*types.KeyInfo, error)                `perm:"admin"`
		WalletHas            func(ctx context.Context, addr address.Address) (bool, error)                                           `perm:"write"`
		WalletImport         func(ctx context.Context, key *types.KeyInfo) (address.Address, error)                                  `perm:"admin"`
		WalletNewAddress     func(ctx context.Context, protocol address.Protocol) (address.Address, error)                           `perm:"write"`
		WalletSetDefault     func(ctx context.Context, addr address.Address) error                                                   `perm:"write"`
		WalletSign           func(ctx context.Context, k address.Address, msg []byte, meta types.MsgMeta) (*crypto.Signature, error) `perm:"sign"`
		WalletSignMessage    func(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error)          `perm:"sign"`
		WalletState          func(ctx context.Context) int                                                                           `perm:"admin"`
	}
}

func (*IWalletStruct) HasPassword

func (s *IWalletStruct) HasPassword(p0 context.Context) bool

func (*IWalletStruct) LockWallet

func (s *IWalletStruct) LockWallet(p0 context.Context) error

func (*IWalletStruct) SetPassword

func (s *IWalletStruct) SetPassword(p0 context.Context, p1 []byte) error

func (*IWalletStruct) UnLockWallet

func (s *IWalletStruct) UnLockWallet(p0 context.Context, p1 []byte) error

func (*IWalletStruct) WalletAddresses

func (s *IWalletStruct) WalletAddresses(p0 context.Context) []address.Address

func (*IWalletStruct) WalletBalance

func (s *IWalletStruct) WalletBalance(p0 context.Context, p1 address.Address) (abi.TokenAmount, error)

func (*IWalletStruct) WalletDefaultAddress

func (s *IWalletStruct) WalletDefaultAddress(p0 context.Context) (address.Address, error)

func (*IWalletStruct) WalletDelete added in v1.8.0

func (s *IWalletStruct) WalletDelete(p0 context.Context, p1 address.Address) error

func (*IWalletStruct) WalletExport

func (s *IWalletStruct) WalletExport(p0 context.Context, p1 address.Address, p2 string) (*types.KeyInfo, error)

func (*IWalletStruct) WalletHas

func (s *IWalletStruct) WalletHas(p0 context.Context, p1 address.Address) (bool, error)

func (*IWalletStruct) WalletImport

func (s *IWalletStruct) WalletImport(p0 context.Context, p1 *types.KeyInfo) (address.Address, error)

func (*IWalletStruct) WalletNewAddress

func (s *IWalletStruct) WalletNewAddress(p0 context.Context, p1 address.Protocol) (address.Address, error)

func (*IWalletStruct) WalletSetDefault

func (s *IWalletStruct) WalletSetDefault(p0 context.Context, p1 address.Address) error

func (*IWalletStruct) WalletSign

func (s *IWalletStruct) WalletSign(p0 context.Context, p1 address.Address, p2 []byte, p3 types.MsgMeta) (*crypto.Signature, error)

func (*IWalletStruct) WalletSignMessage

func (s *IWalletStruct) WalletSignMessage(p0 context.Context, p1 address.Address, p2 *types.Message) (*types.SignedMessage, error)

func (*IWalletStruct) WalletState

func (s *IWalletStruct) WalletState(p0 context.Context) int

Directories

Path Synopsis
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

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