Documentation ¶
Index ¶
- func OpenFilesystemJournal(lr repo.Repo) (journal.Journal, error)
- type IMessagePool
- type MessagePoolAPI
- func (a *MessagePoolAPI) DeleteByAdress(ctx context.Context, addr address.Address) 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)
- func (a *MessagePoolAPI) WalletHas(ctx context.Context, addr address.Address) (bool, error)
- func (a *MessagePoolAPI) WalletSign(ctx context.Context, k address.Address, msg []byte) (*crypto.Signature, error)
- type MessagePoolSubmodule
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type IMessagePool ¶ added in v0.9.1
type IMessagePool interface { DeleteByAdress(ctx context.Context, addr address.Address) error MpoolPublishByAddr(context.Context, address.Address) error MpoolPublishMessage(ctx context.Context, smsg *types.SignedMessage) 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 (*MessagePoolAPI) GasEstimateGasLimit ¶ added in v0.9.6
func (a *MessagePoolAPI) GasEstimateGasLimit(ctx context.Context, msgIn *types.UnsignedMessage, tsk types.TipSetKey) (int64, error)
func (*MessagePoolAPI) GasEstimateGasPremium ¶
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 ¶ added in v0.9.6
func (a *MessagePoolAPI) MpoolPublishByAddr(ctx context.Context, addr address.Address) error
func (*MessagePoolAPI) MpoolPublishMessage ¶ added in v0.9.6
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 ¶ 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 ¶
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)
Click to show internal directories.
Click to hide internal directories.