relay

Documentation

Index

• type TxnRelayer
  • func MustNewTxnRelayerFromViper() *TxnRelayer
  • func NewTxnRelayer(relayConf *TxnRelayerConfig) (*TxnRelayer, error)
  • func NewTxnRelayerFromViper() (*TxnRelayer, error)
  • func (relayer *TxnRelayer) AsyncRelay(signedTx hexutil.Bytes) bool
• type TxnRelayerConfig

Types

type TxnRelayer

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

TxnRelayer relays raw transaction by broadcasting to node pool of different regions to accelerate P2P diffusion.

func MustNewTxnRelayerFromViper

func MustNewTxnRelayerFromViper() *TxnRelayer

func NewTxnRelayer

func NewTxnRelayer(relayConf *TxnRelayerConfig) (*TxnRelayer, error)

func NewTxnRelayerFromViper

func NewTxnRelayerFromViper() (*TxnRelayer, error)

func (*TxnRelayer) AsyncRelay

func (relayer *TxnRelayer) AsyncRelay(signedTx hexutil.Bytes) bool

AsyncRelay relays raw transaction broadcasting asynchronously.

type TxnRelayerConfig

type TxnRelayerConfig struct {
	BufferSize     int           `default:"2000"`
	Concurrency    int           `default:"1"`
	Retry          int           `default:"3"`
	RetryInterval  time.Duration `default:"1s"`
	RequestTimeout time.Duration `default:"3s"`
	NodeUrls       []string
}