peer

Documentation

Index

• type Peer
  • func Connect(nodeInfo *nodeInfo.NodeInfo, address string) (*Peer, error)
  • func (peer *Peer) AnnounceTransaction(tx xdr.TransactionEnvelope)
  • func (peer *Peer) GetPeerAddresses()
  • func (peer *Peer) GetScpQuorumset(hash xdr.Hash)
  • func (peer *Peer) GetScpState()
  • func (peer *Peer) GetTxSet(hash xdr.Hash)
  • func (peer *Peer) MustRespond()
  • func (peer *Peer) Start()

Types

type Peer

type Peer struct {

	// OnMessage is triggered when the peer receives a message
	OnMessage func(*xdr.StellarMessage)

	// PeerInfo contains information about the connected peer
	PeerInfo *xdr.Hello
	Address  string
	// contains filtered or unexported fields
}

Peer represents a connection to a peer

func Connect

func Connect(nodeInfo *nodeInfo.NodeInfo, address string) (*Peer, error)

Connect returns a peer that manages a connection to a stellar-core node

func (*Peer) AnnounceTransaction

func (peer *Peer) AnnounceTransaction(tx xdr.TransactionEnvelope)

AnnounceTransaction informs peer of a transaction

func (*Peer) GetPeerAddresses

func (peer *Peer) GetPeerAddresses()

GetPeerAddresses gets a list of peers

func (*Peer) GetScpQuorumset

func (peer *Peer) GetScpQuorumset(hash xdr.Hash)

GetScpQuorumset gets scp quorum set

func (*Peer) GetScpState

func (peer *Peer) GetScpState()

GetScpState gets the scp state

func (*Peer) GetTxSet

func (peer *Peer) GetTxSet(hash xdr.Hash)

GetTxSet gets the transaction set

func (*Peer) MustRespond

func (peer *Peer) MustRespond()

MustRespond indicates to the connection that it should expect a response soon or throw an error.

func (*Peer) Start

func (peer *Peer) Start()

Start logs the peer in to the node and starts processing messages