client

package
v0.9.6 Latest Latest
Warning

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

Go to latest
Published: May 10, 2021 License: Apache-2.0, MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountAPI

type AccountAPI struct {
	StateAccountKey func(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type ActorAPI

type ActorAPI struct {
	StateGetActor     func(context.Context, address.Address, types.TipSetKey) (*types.Actor, error)
	ActorGetSignature func(context.Context, address.Address, abi.MethodNum) (vm.ActorMethodSignature, error)
	ListActor         func(context.Context) (map[address.Address]*types.Actor, error)
}

type BeaconAPI

type BeaconAPI struct {
	BeaconGetEntry func(context.Context, abi.ChainEpoch) (*types.BeaconEntry, error)
}

type BlockServiceAPI

type BlockServiceAPI struct {
	DAGGetNode     func(context.Context, string) (interface{}, error)
	DAGGetFileSize func(context.Context, cid.Cid) (uint64, error)
	DAGCat         func(context.Context, cid.Cid) (io.Reader, error)
	DAGImportData  func(context.Context, io.Reader) (ipld.Node, error)
}

type ChainInfoAPI

type ChainInfoAPI struct {
	BlockTime                     func() time.Duration
	ChainList                     func(context.Context, types.TipSetKey, int) ([]types.TipSetKey, error)
	ProtocolParameters            func(context.Context) (*chainApiTypes.ProtocolParams, error)
	ChainHead                     func(context.Context) (*types.TipSet, error)
	ChainSetHead                  func(context.Context, types.TipSetKey) error
	ChainGetTipSet                func(types.TipSetKey) (*types.TipSet, error)
	ChainGetTipSetByHeight        func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)
	GetActor                      func(context.Context, address.Address) (*types.Actor, error)
	ChainGetBlock                 func(context.Context, cid.Cid) (*types.BlockHeader, error)
	ChainGetMessage               func(context.Context, cid.Cid) (*types.UnsignedMessage, error)
	ChainGetBlockMessages         func(context.Context, cid.Cid) (*chainApiTypes.BlockMessages, error)
	ChainGetReceipts              func(context.Context, cid.Cid) ([]types.MessageReceipt, error)
	GetFullBlock                  func(context.Context, cid.Cid) (*types.FullBlock, error)
	ResolveToKeyAddr              func(context.Context, address.Address, *types.TipSet) (address.Address, error)
	ChainNotify                   func(context.Context) chan []*chain.HeadChange
	GetEntry                      func(context.Context, abi.ChainEpoch, uint64) (*types.BeaconEntry, error)
	VerifyEntry                   func(*types.BeaconEntry, abi.ChainEpoch) bool
	StateNetworkName              func(context.Context) (chainApiTypes.NetworkName, error)
	ChainGetRandomnessFromBeacon  func(context.Context, types.TipSetKey, acrypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error)
	ChainGetRandomnessFromTickets func(context.Context, types.TipSetKey, acrypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error)
	StateNetworkVersion           func(context.Context, types.TipSetKey) (network.Version, error)
	MessageWait                   func(context.Context, cid.Cid, abi.ChainEpoch) (*chain.ChainMessage, error)
	StateSearchMsg                func(context.Context, cid.Cid) (*chain.MsgLookup, error)
	StateWaitMsg                  func(context.Context, cid.Cid, abi.ChainEpoch) (*chain.MsgLookup, error)
	StateGetReceipt               func(context.Context, cid.Cid, types.TipSetKey) (*types.MessageReceipt, error)
}

type ConfigAPI

type ConfigAPI struct {
	ConfigSet func(string, string) error
	ConfigGet func(string) (interface{}, error)
}

type DbAPI

type DbAPI struct {
	ChainReadObj func(context.Context, cid.Cid) ([]byte, error)
	ChainHasObj  func(context.Context, cid.Cid) (bool, error)
	ChainExport  func(context.Context, types.TipSetKey, io.Writer) error
}

type FullNode

type FullNode struct {
	DAGGetNode     func(context.Context, string) (interface{}, error)
	DAGGetFileSize func(context.Context, cid.Cid) (uint64, error)
	DAGCat         func(context.Context, cid.Cid) (io.Reader, error)
	DAGImportData  func(context.Context, io.Reader) (ipld.Node, error)

	BlockTime                     func() time.Duration
	ChainList                     func(context.Context, types.TipSetKey, int) ([]types.TipSetKey, error)
	ProtocolParameters            func(context.Context) (*chainApiTypes.ProtocolParams, error)
	ChainHead                     func(context.Context) (*types.TipSet, error)
	ChainSetHead                  func(context.Context, types.TipSetKey) error
	ChainGetTipSet                func(types.TipSetKey) (*types.TipSet, error)
	ChainGetTipSetByHeight        func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)
	GetActor                      func(context.Context, address.Address) (*types.Actor, error)
	ChainGetBlock                 func(context.Context, cid.Cid) (*types.BlockHeader, error)
	ChainGetMessage               func(context.Context, cid.Cid) (*types.UnsignedMessage, error)
	ChainGetBlockMessages         func(context.Context, cid.Cid) (*chainApiTypes.BlockMessages, error)
	ChainGetReceipts              func(context.Context, cid.Cid) ([]types.MessageReceipt, error)
	GetFullBlock                  func(context.Context, cid.Cid) (*types.FullBlock, error)
	ResolveToKeyAddr              func(context.Context, address.Address, *types.TipSet) (address.Address, error)
	ChainNotify                   func(context.Context) chan []*chain.HeadChange
	GetEntry                      func(context.Context, abi.ChainEpoch, uint64) (*types.BeaconEntry, error)
	VerifyEntry                   func(*types.BeaconEntry, abi.ChainEpoch) bool
	StateNetworkName              func(context.Context) (chainApiTypes.NetworkName, error)
	ChainGetRandomnessFromBeacon  func(context.Context, types.TipSetKey, acrypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error)
	ChainGetRandomnessFromTickets func(context.Context, types.TipSetKey, acrypto.DomainSeparationTag, abi.ChainEpoch, []byte) (abi.Randomness, error)
	StateNetworkVersion           func(context.Context, types.TipSetKey) (network.Version, error)
	MessageWait                   func(context.Context, cid.Cid, abi.ChainEpoch) (*chain.ChainMessage, error)
	StateSearchMsg                func(context.Context, cid.Cid) (*chain.MsgLookup, error)
	StateWaitMsg                  func(context.Context, cid.Cid, abi.ChainEpoch) (*chain.MsgLookup, error)
	StateGetReceipt               func(context.Context, cid.Cid, types.TipSetKey) (*types.MessageReceipt, error)

	StateMinerSectorAllocated          func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (bool, error)
	StateSectorPreCommitInfo           func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error)
	StateSectorGetInfo                 func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorOnChainInfo, error)
	StateSectorPartition               func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorLocation, error)
	StateMinerSectorSize               func(context.Context, address.Address, types.TipSetKey) (abi.SectorSize, error)
	StateMinerInfo                     func(context.Context, address.Address, types.TipSetKey) (miner.MinerInfo, error)
	StateMinerWorkerAddress            func(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateMinerRecoveries               func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)
	StateMinerFaults                   func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)
	StateMinerProvingDeadline          func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerPartitions               func(context.Context, address.Address, uint64, types.TipSetKey) ([]chainApiTypes.Partition, error)
	StateMinerDeadlines                func(context.Context, address.Address, types.TipSetKey) ([]chainApiTypes.Deadline, error)
	StateMinerSectors                  func(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
	StateMarketStorageDeal             func(context.Context, abi.DealID, types.TipSetKey) (*chainApiTypes.MarketDeal, error)
	StateMinerPreCommitDepositForPower func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateMinerInitialPledgeCollateral  func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateVMCirculatingSupplyInternal   func(context.Context, types.TipSetKey) (chain.CirculatingSupply, error)
	StateCirculatingSupply             func(context.Context, types.TipSetKey) (abi.TokenAmount, error)
	StateMarketDeals                   func(context.Context, types.TipSetKey) (map[string]pstate.MarketDeal, error)
	StateMinerActiveSectors            func(context.Context, address.Address, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
	StateLookupID                      func(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateListMiners                    func(context.Context, types.TipSetKey) ([]address.Address, error)
	StateListActors                    func(context.Context, types.TipSetKey) ([]address.Address, error)
	StateMinerPower                    func(context.Context, address.Address, types.TipSetKey) (*power.MinerPower, error)
	StateMinerAvailableBalance         func(context.Context, address.Address, types.TipSetKey) (big.Int, error)
	StateSectorExpiration              func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorExpiration, error)
	StateMinerSectorCount              func(context.Context, address.Address, types.TipSetKey) (chainApiTypes.MinerSectors, error)
	StateMarketBalance                 func(context.Context, address.Address, types.TipSetKey) (chainApiTypes.MarketBalance, error)
	StateMarketParticipants            func(ctx context.Context, tsk types.TipSetKey) (map[string]chainApiTypes.MarketBalance, error)

	ConfigSet func(string, string) error
	ConfigGet func(string) (interface{}, error)

	SyncerTracker            func() *syncTypes.TargetTracker
	ChainTipSetWeight        func(context.Context, types.TipSetKey) (big.Int, error)
	ChainSyncHandleNewTipSet func(*types.ChainInfo) error
	SyncSubmitBlock          func(context.Context, *types.BlockMsg) error
	StateCall                func(context.Context, *types.UnsignedMessage, types.TipSetKey) (*syncApiTypes.InvocResult, error)
	SyncState                func(context.Context) (*syncApiTypes.SyncState, error)

	DeleteByAdress          func(context.Context, address.Address) error
	MpoolPublishByAddr      func(context.Context, address.Address) error
	MpoolPublishMessage     func(ctx context.Context, smsg *types.SignedMessage) error
	MpoolPush               func(context.Context, *types.SignedMessage) (cid.Cid, error)
	MpoolGetConfig          func(context.Context) (*messagepool.MpoolConfig, error)
	MpoolSetConfig          func(context.Context, *messagepool.MpoolConfig) error
	MpoolSelect             func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)
	MpoolSelects            func(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error)
	MpoolPending            func(context.Context, types.TipSetKey) ([]*types.SignedMessage, error)
	MpoolClear              func(context.Context, bool) error
	MpoolPushUntrusted      func(context.Context, *types.SignedMessage) (cid.Cid, error)
	MpoolPushMessage        func(context.Context, *types.UnsignedMessage, *types.MessageSendSpec) (*types.SignedMessage, error)
	MpoolBatchPush          func(context.Context, []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushUntrusted func(context.Context, []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushMessage   func(context.Context, []*types.UnsignedMessage, *types.MessageSendSpec) ([]*types.SignedMessage, error)
	MpoolGetNonce           func(context.Context, address.Address) (uint64, error)
	MpoolSub                func(context.Context) (chan messagepool.MpoolUpdate, error)
	SendMsg                 func(context.Context, address.Address, abi.MethodNum, abi.TokenAmount, []byte) (cid.Cid, error)
	GasEstimateMessageGas   func(context.Context, *types.UnsignedMessage, *types.MessageSendSpec, types.TipSetKey) (*types.UnsignedMessage, error)
	GasEstimateFeeCap       func(context.Context, *types.UnsignedMessage, int64, types.TipSetKey) (big.Int, error)
	GasEstimateGasPremium   func(context.Context, uint64, address.Address, int64, types.TipSetKey) (big.Int, error)
	GasEstimateGasLimit     func(ctx context.Context, msgIn *types.UnsignedMessage, tsk types.TipSetKey) (int64, error)
	WalletSign              func(context.Context, address.Address, []byte) (*crypto.Signature, error)

	NetworkGetBandwidthStats  func() metrics.Stats
	NetworkGetPeerAddresses   func() []ma.Multiaddr
	NetworkGetPeerID          func() peer.ID
	NetworkFindProvidersAsync func(context.Context, cid.Cid, int) chan peer.AddrInfo
	NetworkGetClosestPeers    func(context.Context, string) (chan peer.ID, error)
	NetworkFindPeer           func(context.Context, peer.ID) (peer.AddrInfo, error)
	NetworkConnect            func(context.Context, []string) (chan net.ConnectionResult, error)
	NetworkPeers              func(context.Context, bool) (*net.SwarmConnInfos, error)
	Version                   func(context.Context) (network.Version, error)
	NetAddrsListen            func(context.Context) (peer.AddrInfo, error)

	WalletBalance        func(context.Context, address.Address) (abi.TokenAmount, error)
	WalletHas            func(context.Context, address.Address) (bool, error)
	WalletDefaultAddress func() (address.Address, error)
	WalletAddresses      func() []address.Address
	WalletSetDefault     func(context.Context, address.Address) error
	WalletNewAddress     func(address.Protocol) (address.Address, error)
	WalletImport         func(*crypto.KeyInfo) (address.Address, error)
	WalletExport         func([]address.Address) ([]*crypto.KeyInfo, error)
	WalletSignMessage    func(context.Context, address.Address, *types.UnsignedMessage) (*types.SignedMessage, error)

	ChainReadObj func(context.Context, cid.Cid) ([]byte, error)
	ChainHasObj  func(context.Context, cid.Cid) (bool, error)
	ChainExport  func(context.Context, types.TipSetKey, io.Writer) error

	StateAccountKey func(context.Context, address.Address, types.TipSetKey) (address.Address, error)

	StateGetActor     func(context.Context, address.Address, types.TipSetKey) (*types.Actor, error)
	ActorGetSignature func(context.Context, address.Address, abi.MethodNum) (vm.ActorMethodSignature, error)
	ListActor         func(context.Context) (map[address.Address]*types.Actor, error)

	BeaconGetEntry func(context.Context, abi.ChainEpoch) (*types.BeaconEntry, error)

	MinerGetBaseInfo func(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*mineApiTypes.MiningBaseInfo, error)
	MinerCreateBlock func(context.Context, *mineApiTypes.BlockTemplate) (*types.BlockMsg, error)
}

func NewFullNode

func NewFullNode(ctx context.Context) (FullNode, jsonrpc.ClientCloser, error)

type MessagePoolAPI

type MessagePoolAPI struct {
	DeleteByAdress          func(context.Context, address.Address) error
	MpoolPublishByAddr      func(context.Context, address.Address) error
	MpoolPublishMessage     func(ctx context.Context, smsg *types.SignedMessage) error
	MpoolPush               func(context.Context, *types.SignedMessage) (cid.Cid, error)
	MpoolGetConfig          func(context.Context) (*messagepool.MpoolConfig, error)
	MpoolSetConfig          func(context.Context, *messagepool.MpoolConfig) error
	MpoolSelect             func(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)
	MpoolSelects            func(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error)
	MpoolPending            func(context.Context, types.TipSetKey) ([]*types.SignedMessage, error)
	MpoolClear              func(context.Context, bool) error
	MpoolPushUntrusted      func(context.Context, *types.SignedMessage) (cid.Cid, error)
	MpoolPushMessage        func(context.Context, *types.UnsignedMessage, *types.MessageSendSpec) (*types.SignedMessage, error)
	MpoolBatchPush          func(context.Context, []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushUntrusted func(context.Context, []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushMessage   func(context.Context, []*types.UnsignedMessage, *types.MessageSendSpec) ([]*types.SignedMessage, error)
	MpoolGetNonce           func(context.Context, address.Address) (uint64, error)
	MpoolSub                func(context.Context) (chan messagepool.MpoolUpdate, error)
	SendMsg                 func(context.Context, address.Address, abi.MethodNum, abi.TokenAmount, []byte) (cid.Cid, error)
	GasEstimateMessageGas   func(context.Context, *types.UnsignedMessage, *types.MessageSendSpec, types.TipSetKey) (*types.UnsignedMessage, error)
	GasEstimateFeeCap       func(context.Context, *types.UnsignedMessage, int64, types.TipSetKey) (big.Int, error)
	GasEstimateGasPremium   func(context.Context, uint64, address.Address, int64, types.TipSetKey) (big.Int, error)
	WalletSign              func(context.Context, address.Address, []byte) (*crypto.Signature, error)
}

type MinerStateAPI

type MinerStateAPI struct {
	StateMinerSectorAllocated          func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (bool, error)
	StateSectorPreCommitInfo           func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (miner.SectorPreCommitOnChainInfo, error)
	StateSectorGetInfo                 func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorOnChainInfo, error)
	StateSectorPartition               func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorLocation, error)
	StateMinerSectorSize               func(context.Context, address.Address, types.TipSetKey) (abi.SectorSize, error)
	StateMinerInfo                     func(context.Context, address.Address, types.TipSetKey) (miner.MinerInfo, error)
	StateMinerWorkerAddress            func(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateMinerRecoveries               func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)
	StateMinerFaults                   func(context.Context, address.Address, types.TipSetKey) (bitfield.BitField, error)
	StateMinerProvingDeadline          func(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerPartitions               func(context.Context, address.Address, uint64, types.TipSetKey) ([]chainApiTypes.Partition, error)
	StateMinerDeadlines                func(context.Context, address.Address, types.TipSetKey) ([]chainApiTypes.Deadline, error)
	StateMinerSectors                  func(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
	StateMarketStorageDeal             func(context.Context, abi.DealID, types.TipSetKey) (*chainApiTypes.MarketDeal, error)
	StateMinerPreCommitDepositForPower func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateMinerInitialPledgeCollateral  func(context.Context, address.Address, miner.SectorPreCommitInfo, types.TipSetKey) (big.Int, error)
	StateVMCirculatingSupplyInternal   func(context.Context, types.TipSetKey) (chain.CirculatingSupply, error)
	StateCirculatingSupply             func(context.Context, types.TipSetKey) (abi.TokenAmount, error)
	StateMarketDeals                   func(context.Context, types.TipSetKey) (map[string]pstate.MarketDeal, error)
	StateMinerActiveSectors            func(context.Context, address.Address, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
	StateLookupID                      func(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateListMiners                    func(context.Context, types.TipSetKey) ([]address.Address, error)
	StateListActors                    func(context.Context, types.TipSetKey) ([]address.Address, error)
	StateMinerPower                    func(context.Context, address.Address, types.TipSetKey) (*power.MinerPower, error)
	StateMinerAvailableBalance         func(context.Context, address.Address, types.TipSetKey) (big.Int, error)
	StateSectorExpiration              func(context.Context, address.Address, abi.SectorNumber, types.TipSetKey) (*miner.SectorExpiration, error)
	StateMinerSectorCount              func(context.Context, address.Address, types.TipSetKey) (chainApiTypes.MinerSectors, error)
	StateMarketBalance                 func(context.Context, address.Address, types.TipSetKey) (chainApiTypes.MarketBalance, error)
	StateMarketParticipants            func(ctx context.Context, tsk types.TipSetKey) (map[string]chainApiTypes.MarketBalance, error)
}

type MiningAPI

type MiningAPI struct {
	MinerGetBaseInfo func(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*mineApiTypes.MiningBaseInfo, error)
	MinerCreateBlock func(context.Context, *mineApiTypes.BlockTemplate) (*types.BlockMsg, error)
}

func NewMiningAPINode

func NewMiningAPINode(ctx context.Context) (MiningAPI, jsonrpc.ClientCloser, error)

type NetworkAPI

type NetworkAPI struct {
	NetworkGetBandwidthStats  func() metrics.Stats
	NetworkGetPeerAddresses   func() []ma.Multiaddr
	NetworkGetPeerID          func() peer.ID
	NetworkFindProvidersAsync func(context.Context, cid.Cid, int) chan peer.AddrInfo
	NetworkGetClosestPeers    func(context.Context, string) (chan peer.ID, error)
	NetworkFindPeer           func(context.Context, peer.ID) (peer.AddrInfo, error)
	NetworkConnect            func(context.Context, []string) (chan net.ConnectionResult, error)
	NetworkPeers              func(context.Context, bool) (*net.SwarmConnInfos, error)
	Version                   func(context.Context) (network.Version, error)
	NetAddrsListen            func(context.Context) (peer.AddrInfo, error)
}

type SyncerAPI

type SyncerAPI struct {
	SyncerTracker            func() *syncTypes.TargetTracker
	ChainTipSetWeight        func(context.Context, types.TipSetKey) (big.Int, error)
	ChainSyncHandleNewTipSet func(*types.ChainInfo) error
	SyncSubmitBlock          func(context.Context, *types.BlockMsg) error
	StateCall                func(context.Context, *types.UnsignedMessage, types.TipSetKey) (*syncApiTypes.InvocResult, error)
	SyncState                func(context.Context) (*syncApiTypes.SyncState, error)
}

type WalletAPI

type WalletAPI struct {
	WalletBalance        func(context.Context, address.Address) (abi.TokenAmount, error)
	WalletHas            func(context.Context, address.Address) (bool, error)
	WalletDefaultAddress func() (address.Address, error)
	WalletAddresses      func() []address.Address
	WalletSetDefault     func(context.Context, address.Address) error
	WalletNewAddress     func(address.Protocol) (address.Address, error)
	WalletImport         func(*crypto.KeyInfo) (address.Address, error)
	WalletExport         func([]address.Address) ([]*crypto.KeyInfo, error)
	WalletSign           func(context.Context, address.Address, []byte, wallet.MsgMeta) (*crypto.Signature, error)
	WalletSignMessage    func(context.Context, address.Address, *types.UnsignedMessage) (*types.SignedMessage, error)
}

Jump to

Keyboard shortcuts

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