message

package
v1.25.1 Latest Latest
Warning

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

 Go to latest Published: May 20, 2025 License: Apache-2.0, MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const MinConfidence = 6

Variables

View Source 
var SendLockedWait = 100 * time.Millisecond

Functions

func NewSender 

func NewSender(api SenderAPI, signer SignerAPI, db *harmonydb.DB) (*Sender, *SendTask)

NewSender creates a new Sender.

func NewSenderETH added in v1.25.1 

func NewSenderETH(client *ethclient.Client, db *harmonydb.DB) (*SenderETH, *SendTaskETH)

NewSenderETH creates a new SenderETH.

Types

type MessageWaiterApi 

type MessageWaiterApi interface {
	StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)
	ChainGetTipSetByHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)
	ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)
	StateSearchMsg(ctx context.Context, from types.TipSetKey, msg cid.Cid, limit abi.ChainEpoch, allowReplaced bool) (*api.MsgLookup, error)
	ChainGetMessage(ctx context.Context, mc cid.Cid) (*types.Message, error)
}

type MessageWatcher 

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

func NewMessageWatcher 

func NewMessageWatcher(db *harmonydb.DB, ht *harmonytask.TaskEngine, pcs *chainsched.CurioChainSched, api MessageWaiterApi) (*MessageWatcher, error)

func (*MessageWatcher) Stop 

func (mw *MessageWatcher) Stop(ctx context.Context) error

type MessageWatcherEth added in v1.25.1 

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

func NewMessageWatcherEth added in v1.25.1 

func NewMessageWatcherEth(db *harmonydb.DB, ht *harmonytask.TaskEngine, pcs *chainsched.CurioChainSched, api *ethclient.Client) (*MessageWatcherEth, error)

func (*MessageWatcherEth) Stop added in v1.25.1 

func (mw *MessageWatcherEth) Stop(ctx context.Context) error

type SendTask 

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

func (*SendTask) Adder 

func (s *SendTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*SendTask) CanAccept 

func (s *SendTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*SendTask) Do 

func (s *SendTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*SendTask) TypeDetails 

func (s *SendTask) TypeDetails() harmonytask.TaskTypeDetails

type SendTaskETH added in v1.25.1 

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

func (*SendTaskETH) Adder added in v1.25.1 

func (s *SendTaskETH) Adder(taskFunc harmonytask.AddTaskFunc)

func (*SendTaskETH) CanAccept added in v1.25.1 

func (s *SendTaskETH) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*SendTaskETH) Do added in v1.25.1 

func (s *SendTaskETH) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*SendTaskETH) TypeDetails added in v1.25.1 

func (s *SendTaskETH) TypeDetails() harmonytask.TaskTypeDetails

type Sender 

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

Sender abstracts away highly-available message sending with coordination through HarmonyDB. It make sure that nonces are assigned transactionally, and that messages are correctly broadcasted to the network. It ensures that messages are sent serially, and that failures to send don't cause nonce gaps.

func (*Sender) Send 

func (s *Sender) Send(ctx context.Context, msg *types.Message, mss *api.MessageSendSpec, reason string) (cid.Cid, error)

Send atomically assigns a nonce, signs, and pushes a message to mempool. maxFee is only used when GasFeeCap/GasPremium fields aren't specified

When maxFee is set to 0, Send will guess appropriate fee based on current chain conditions

Send behaves much like fullnodeApi.MpoolPushMessage, but it coordinates through HarmonyDB, making it safe to broadcast messages from multiple independent API nodes

Send is also currently more strict about required parameters than MpoolPushMessage

type SenderAPI 

type SenderAPI interface {
	StateAccountKey(ctx context.Context, addr address.Address, tsk types.TipSetKey) (address.Address, error)
	GasEstimateMessageGas(ctx context.Context, msg *types.Message, spec *api.MessageSendSpec, tsk types.TipSetKey) (*types.Message, error)
	WalletBalance(ctx context.Context, addr address.Address) (big.Int, error)
	MpoolGetNonce(context.Context, address.Address) (uint64, error)
	MpoolPush(context.Context, *types.SignedMessage) (cid.Cid, error)
}

type SenderETH added in v1.25.1 

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

func (*SenderETH) Send added in v1.25.1 

func (s *SenderETH) Send(ctx context.Context, fromAddress common.Address, tx *types.Transaction, reason string) (common.Hash, error)

Send sends an Ethereum transaction, coordinating nonce assignment, signing, and broadcasting.

type SignerAPI 

type SignerAPI interface {
	WalletSignMessage(context.Context, address.Address, *types.Message) (*types.SignedMessage, error)
}

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.