mpool

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2021 License: Apache-2.0, MIT Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func OpenFilesystemJournal 

func OpenFilesystemJournal(lr repo.Repo) (journal.Journal, error)

Types

type IMessagePool added in v0.9.1 

type IMessagePool interface {
	DeleteByAdress(ctx context.Context, addr address.Address) error
	MpoolPublish(ctx context.Context, addr address.Address) error
	MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
	MpoolGetConfig(context.Context) (*messagepool.MpoolConfig, error)
	MpoolSetConfig(ctx context.Context, cfg *messagepool.MpoolConfig) error
	MpoolSelect(context.Context, types.TipSetKey, float64) ([]*types.SignedMessage, error)
	MpoolSelects(context.Context, types.TipSetKey, []float64) ([][]*types.SignedMessage, error)
	MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)
	MpoolClear(ctx context.Context, local bool) error
	MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
	MpoolPushMessage(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec) (*types.SignedMessage, error)
	MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
	MpoolBatchPushMessage(ctx context.Context, msgs []*types.UnsignedMessage, spec *types.MessageSendSpec) ([]*types.SignedMessage, error)
	MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)
	MpoolSub(ctx context.Context) (<-chan messagepool.MpoolUpdate, error)
	SendMsg(ctx context.Context, from, to address.Address, method abi.MethodNum, value, maxFee abi.TokenAmount, params []byte) (cid.Cid, error)
	GasEstimateMessageGas(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.UnsignedMessage, error)
	GasEstimateFeeCap(ctx context.Context, msg *types.UnsignedMessage, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error)
	GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error)
	WalletSign(ctx context.Context, k address.Address, msg []byte) (*crypto.Signature, error)
	WalletHas(ctx context.Context, addr address.Address) (bool, error)
}

type MessagePoolAPI 

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

func (*MessagePoolAPI) DeleteByAdress 

func (a *MessagePoolAPI) DeleteByAdress(ctx context.Context, addr address.Address) error

func (*MessagePoolAPI) GasEstimateFeeCap 

func (a *MessagePoolAPI) GasEstimateFeeCap(ctx context.Context, msg *types.UnsignedMessage, maxqueueblks int64, tsk types.TipSetKey) (big.Int, error)

func (*MessagePoolAPI) GasEstimateGasPremium 

func (a *MessagePoolAPI) GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (big.Int, error)

func (*MessagePoolAPI) GasEstimateMessageGas 

func (a *MessagePoolAPI) GasEstimateMessageGas(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec, tsk types.TipSetKey) (*types.UnsignedMessage, error)

func (*MessagePoolAPI) MpoolBatchPush 

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

func (*MessagePoolAPI) MpoolBatchPushMessage 

func (a *MessagePoolAPI) MpoolBatchPushMessage(ctx context.Context, msgs []*types.UnsignedMessage, spec *types.MessageSendSpec) ([]*types.SignedMessage, error)

func (*MessagePoolAPI) MpoolBatchPushUntrusted 

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

func (*MessagePoolAPI) MpoolClear 

func (a *MessagePoolAPI) MpoolClear(ctx context.Context, local bool) error

func (*MessagePoolAPI) MpoolGetConfig 

func (a *MessagePoolAPI) MpoolGetConfig(context.Context) (*messagepool.MpoolConfig, error)

func (*MessagePoolAPI) MpoolGetNonce 

func (a *MessagePoolAPI) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)

func (*MessagePoolAPI) MpoolPending 

func (a *MessagePoolAPI) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)

func (*MessagePoolAPI) MpoolPublish 

func (a *MessagePoolAPI) MpoolPublish(ctx context.Context, addr address.Address) error

func (*MessagePoolAPI) MpoolPush 

func (a *MessagePoolAPI) MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)

func (*MessagePoolAPI) MpoolPushMessage 

func (a *MessagePoolAPI) MpoolPushMessage(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec) (*types.SignedMessage, error)

func (*MessagePoolAPI) MpoolPushUntrusted 

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

func (*MessagePoolAPI) MpoolSelect 

func (a *MessagePoolAPI) MpoolSelect(ctx context.Context, tsk types.TipSetKey, ticketQuality float64) ([]*types.SignedMessage, error)

func (*MessagePoolAPI) MpoolSelects added in v0.9.4 

func (a *MessagePoolAPI) MpoolSelects(ctx context.Context, tsk types.TipSetKey, ticketQualitys []float64) ([][]*types.SignedMessage, error)

func (*MessagePoolAPI) MpoolSetConfig 

func (a *MessagePoolAPI) MpoolSetConfig(ctx context.Context, cfg *messagepool.MpoolConfig) error

func (*MessagePoolAPI) MpoolSub 

func (a *MessagePoolAPI) MpoolSub(ctx context.Context) (<-chan messagepool.MpoolUpdate, error)

func (*MessagePoolAPI) SendMsg 

func (a *MessagePoolAPI) SendMsg(ctx context.Context, from, to address.Address, method abi.MethodNum, value, maxFee abi.TokenAmount, params []byte) (cid.Cid, error)

func (*MessagePoolAPI) WalletHas added in v0.9.1 

func (a *MessagePoolAPI) WalletHas(ctx context.Context, addr address.Address) (bool, error)

func (*MessagePoolAPI) WalletSign 

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

type MessagePoolSubmodule 

type MessagePoolSubmodule struct {
	// Network Fields
	MessageTopic *pubsub.Topic
	MessageSub   pubsub.Subscription

	MPool *messagepool.MessagePool
	// contains filtered or unexported fields
}

MessagingSubmodule enhances the `Node` with internal messaging capabilities.

func NewMpoolSubmodule 

func NewMpoolSubmodule(cfg messagepoolConfig,
	network *network.NetworkSubmodule,
	chain *chain.ChainSubmodule,
	syncer *syncer.SyncerSubmodule,
	wallet *wallet.WalletSubmodule,
	networkCfg *config.NetworkParamsConfig,
) (*MessagePoolSubmodule, error)

func (*MessagePoolSubmodule) API 

func (mp *MessagePoolSubmodule) API() *MessagePoolAPI

func (*MessagePoolSubmodule) Start 

func (mp *MessagePoolSubmodule) Start(ctx context.Context) error

Start to the message pubsub topic to learn about messages to mine into blocks.

func (*MessagePoolSubmodule) Stop 

func (mp *MessagePoolSubmodule) Stop(ctx context.Context)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.