p2p

Documentation

Index

• type Service
  • func NewSocketP2PLayer(config *config.HostConfig, serviceLocator p2pServiceLocator, ...) *Service
  • func (p *Service) BroadcastBatches(batches []*common.ExtBatch) error
  • func (p *Service) HealthStatus() host.HealthStatus
  • func (p *Service) RefreshPeerList()
  • func (p *Service) RequestBatchesFromSequencer(fromSeqNo *big.Int) error
  • func (p *Service) RespondToBatchRequest(requestID string, batches []*common.ExtBatch) error
  • func (p *Service) SendTxToSequencer(tx common.EncryptedTx) error
  • func (p *Service) Start() error
  • func (p *Service) Stop() error
  • func (p *Service) SubscribeForBatchRequests(handler host.P2PBatchRequestHandler) func()
  • func (p *Service) SubscribeForBatches(handler host.P2PBatchHandler) func()
  • func (p *Service) SubscribeForTx(handler host.P2PTxHandler) func()

Types

type Service

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

func NewSocketP2PLayer

func NewSocketP2PLayer(config *config.HostConfig, serviceLocator p2pServiceLocator, logger gethlog.Logger, metricReg gethmetrics.Registry) *Service

NewSocketP2PLayer - returns the Socket implementation of the P2P

func (*Service) BroadcastBatches

func (p *Service) BroadcastBatches(batches []*common.ExtBatch) error

func (*Service) HealthStatus

func (p *Service) HealthStatus() host.HealthStatus

func (*Service) RefreshPeerList

func (p *Service) RefreshPeerList()

RefreshPeerList - fetches the latest peer list from L1 and updates the peerAddresses. Note: this is designed to be run in a separate goroutine, it will retry a few times before giving up.

func (*Service) RequestBatchesFromSequencer

func (p *Service) RequestBatchesFromSequencer(fromSeqNo *big.Int) error

func (*Service) RespondToBatchRequest

func (p *Service) RespondToBatchRequest(requestID string, batches []*common.ExtBatch) error

func (*Service) SendTxToSequencer

func (p *Service) SendTxToSequencer(tx common.EncryptedTx) error

func (*Service) Start

func (p *Service) Start() error

func (*Service) Stop

func (p *Service) Stop() error

func (*Service) SubscribeForBatchRequests

func (p *Service) SubscribeForBatchRequests(handler host.P2PBatchRequestHandler) func()

func (*Service) SubscribeForBatches

func (p *Service) SubscribeForBatches(handler host.P2PBatchHandler) func()

func (*Service) SubscribeForTx

func (p *Service) SubscribeForTx(handler host.P2PTxHandler) func()