mpool

Documentation

Index

• func OpenFilesystemJournal(lr repo.Repo) (journal.Journal, error)
• type MessagePoolAPI
  • func (a *MessagePoolAPI) DeleteByAdress(ctx context.Context, addr address.Address) error
  • func (a *MessagePoolAPI) GasBatchEstimateMessageGas(ctx context.Context, estimateMessages []*types.EstimateMessage, ...) ([]*types.EstimateResult, error)
  • func (a *MessagePoolAPI) GasEstimateFeeCap(ctx context.Context, msg *types.UnsignedMessage, maxqueueblks int64, ...) (big.Int, error)
  • func (a *MessagePoolAPI) GasEstimateGasLimit(ctx context.Context, msgIn *types.UnsignedMessage, tsk types.TipSetKey) (int64, error)
  • func (a *MessagePoolAPI) GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, ...) (big.Int, error)
  • func (a *MessagePoolAPI) GasEstimateMessageGas(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec, ...) (*types.UnsignedMessage, error)
  • func (a *MessagePoolAPI) MpoolBatchPush(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
  • func (a *MessagePoolAPI) MpoolBatchPushMessage(ctx context.Context, msgs []*types.UnsignedMessage, ...) ([]*types.SignedMessage, error)
  • func (a *MessagePoolAPI) MpoolBatchPushUntrusted(ctx context.Context, smsgs []*types.SignedMessage) ([]cid.Cid, error)
  • func (a *MessagePoolAPI) MpoolClear(ctx context.Context, local bool) error
  • func (a *MessagePoolAPI) MpoolGetConfig(context.Context) (*messagepool.MpoolConfig, error)
  • func (a *MessagePoolAPI) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error)
  • func (a *MessagePoolAPI) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error)
  • func (a *MessagePoolAPI) MpoolPublishByAddr(ctx context.Context, addr address.Address) error
  • func (a *MessagePoolAPI) MpoolPublishMessage(ctx context.Context, smsg *types.SignedMessage) error
  • func (a *MessagePoolAPI) MpoolPush(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
  • func (a *MessagePoolAPI) MpoolPushMessage(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec) (*types.SignedMessage, error)
  • func (a *MessagePoolAPI) MpoolPushUntrusted(ctx context.Context, smsg *types.SignedMessage) (cid.Cid, error)
  • func (a *MessagePoolAPI) MpoolSelect(ctx context.Context, tsk types.TipSetKey, ticketQuality float64) ([]*types.SignedMessage, error)
  • func (a *MessagePoolAPI) MpoolSelects(ctx context.Context, tsk types.TipSetKey, ticketQualitys []float64) ([][]*types.SignedMessage, error)
  • func (a *MessagePoolAPI) MpoolSetConfig(ctx context.Context, cfg *messagepool.MpoolConfig) error
  • func (a *MessagePoolAPI) MpoolSub(ctx context.Context) (<-chan messagepool.MpoolUpdate, error)
  • func (a *MessagePoolAPI) SendMsg(ctx context.Context, from, to address.Address, method abi.MethodNum, ...) (cid.Cid, error)
• type MessagePoolSubmodule
  • func NewMpoolSubmodule(cfg messagepoolConfig, network *network.NetworkSubmodule, ...) (*MessagePoolSubmodule, error)
  • func (mp *MessagePoolSubmodule) API() apiface.IMessagePool
  • func (mp *MessagePoolSubmodule) Start(ctx context.Context) error
  • func (mp *MessagePoolSubmodule) Stop(ctx context.Context)
  • func (mp *MessagePoolSubmodule) V0API() apiface.IMessagePool

Functions

func OpenFilesystemJournal

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

Types

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) GasBatchEstimateMessageGas

func (a *MessagePoolAPI) GasBatchEstimateMessageGas(ctx context.Context, estimateMessages []*types.EstimateMessage, fromNonce uint64, tsk types.TipSetKey) ([]*types.EstimateResult, error)

func (*MessagePoolAPI) GasEstimateFeeCap

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

func (*MessagePoolAPI) GasEstimateGasLimit

func (a *MessagePoolAPI) GasEstimateGasLimit(ctx context.Context, msgIn *types.UnsignedMessage, tsk types.TipSetKey) (int64, 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) MpoolPublishByAddr

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

func (*MessagePoolAPI) MpoolPublishMessage

func (a *MessagePoolAPI) MpoolPublishMessage(ctx context.Context, smsg *types.SignedMessage) 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

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)

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() apiface.IMessagePool

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)

func (*MessagePoolSubmodule) V0API

func (mp *MessagePoolSubmodule) V0API() apiface.IMessagePool