network

import "github.com/luxfi/node/vms/xvm/network"

func NewAtomic(h warp.Handler) Atomic

func NewLockedTxVerifier(lock sync.Locker, txVerifier TxVerifier) *LockedTxVerifier

func (l *LockedTxVerifier) VerifyTx(tx *txs.Tx) error

func New(
	log log.Logger,
	nodeID ids.NodeID,
	netID ids.ID,
	vdrs consensusvalidator.State,
	parser txs.Parser,
	txVerifier TxVerifier,
	mempool mempool.Mempool[*txs.Tx],
	sender warp.Sender,
	registerer metric.Registerer,
	config Config,
) (*Network, error)

func (n *Network) Gossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error

func (n *Network) IssueTxFromRPC(tx *txs.Tx) error

func (n *Network) IssueTxFromRPCWithoutVerification(tx *txs.Tx) error

func (n *Network) PullGossip(ctx context.Context)

func (n *Network) PushGossip(ctx context.Context)

func (n *Network) Request(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, msg []byte) ([]byte, *p2p.Error)

func (n *Network) RequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32, err *p2p.Error) error

func (n *Network) Response(ctx context.Context, nodeID ids.NodeID, requestID uint32, msg []byte) error