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) GasEstimateFeeCap(ctx context.Context, msg *types.UnsignedMessage, maxqueueblks int64, ...) (big.Int, 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 block.TipSetKey) ([]*types.SignedMessage, error)
- func (a *MessagePoolAPI) MpoolPublish(ctx context.Context, addr address.Address) 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 block.TipSetKey, ticketQuality 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) 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 MessagePoolAPI ¶
type MessagePoolAPI struct {
// contains filtered or unexported fields
}
func (*MessagePoolAPI) DeleteByAdress ¶
func (*MessagePoolAPI) GasEstimateFeeCap ¶
func (*MessagePoolAPI) GasEstimateGasPremium ¶
func (*MessagePoolAPI) GasEstimateMessageGas ¶
func (a *MessagePoolAPI) GasEstimateMessageGas(ctx context.Context, msg *types.UnsignedMessage, spec *types.MessageSendSpec, tsk block.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 (*MessagePoolAPI) MpoolPending ¶
func (a *MessagePoolAPI) MpoolPending(ctx context.Context, tsk block.TipSetKey) ([]*types.SignedMessage, error)
func (*MessagePoolAPI) MpoolPublish ¶
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 block.TipSetKey, ticketQuality 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)
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, ) (*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
Click to show internal directories.
Click to hide internal directories.