peer

package

Go to main page

Versions in this module

v1

v1.2.0

Mar 30, 2018

Changes in this version

type MessageListeners

+ OnCFHeaders func(p *Peer, msg *wire.MsgCFHeaders)

+ OnCFTypes func(p *Peer, msg *wire.MsgCFTypes)

+ OnCFilter func(p *Peer, msg *wire.MsgCFilter)

+ OnGetCFHeaders func(p *Peer, msg *wire.MsgGetCFHeaders)

+ OnGetCFTypes func(p *Peer, msg *wire.MsgGetCFTypes)

+ OnGetCFilter func(p *Peer, msg *wire.MsgGetCFilter)

v1.2.0-rc2

Mar 30, 2018

v1.2.0-rc1

Mar 7, 2018

v1.1.2

Dec 12, 2017

Changes in this version

type Peer

+ func (p *Peer) LocalAddr() net.Addr

v1.1.0

Sep 22, 2017

v1.0.8

Aug 25, 2017

v1.0.7

Aug 17, 2017

Changes in this version

type MessageListeners

+ OnFeeFilter func(p *Peer, msg *wire.MsgFeeFilter)

v1.0.5

Jun 20, 2017

v1.0.3

Jun 7, 2017

v1.0.1

Apr 28, 2017

v1.0.0

Apr 26, 2017

Changes in this version

type Config

+ DisableRelayTx bool

+ type HashFunc func() (hash *chainhash.Hash, height int64, err error)

type MessageListeners

+ OnSendHeaders func(p *Peer, msg *wire.MsgSendHeaders)

type Peer

+ func (p *Peer) AssociateConnection(conn net.Conn)

+ func (p *Peer) WaitForDisconnect()

+ func (p *Peer) WantsHeaders() bool

v0

v0.1.4

May 25, 2016

Changes in this version

+ const MaxProtocolVersion

+ func DisableLog()

+ func SetLogWriter(w io.Writer, level string) error

+ func UseLogger(logger btclog.Logger)

+ type AddrFunc func(remoteAddr *wire.NetAddress) *wire.NetAddress

+ type Config struct

+ BestLocalAddress AddrFunc

+ ChainParams *chaincfg.Params

+ HostToNetAddress HostToNetAddrFunc

+ Listeners MessageListeners

+ NewestBlock ShaFunc

+ ProtocolVersion uint32

+ Proxy string

+ Services wire.ServiceFlag

+ UserAgentName string

+ UserAgentVersion string

+ type HostToNetAddrFunc func(host string, port uint16, services wire.ServiceFlag) (*wire.NetAddress, error)

+ type MessageListeners struct

+ OnAddr func(p *Peer, msg *wire.MsgAddr)

+ OnAlert func(p *Peer, msg *wire.MsgAlert)

+ OnBlock func(p *Peer, msg *wire.MsgBlock, buf []byte)

+ OnFilterAdd func(p *Peer, msg *wire.MsgFilterAdd)

+ OnFilterClear func(p *Peer, msg *wire.MsgFilterClear)

+ OnFilterLoad func(p *Peer, msg *wire.MsgFilterLoad)

+ OnGetAddr func(p *Peer, msg *wire.MsgGetAddr)

+ OnGetBlocks func(p *Peer, msg *wire.MsgGetBlocks)

+ OnGetData func(p *Peer, msg *wire.MsgGetData)

+ OnGetHeaders func(p *Peer, msg *wire.MsgGetHeaders)

+ OnGetMiningState func(p *Peer, msg *wire.MsgGetMiningState)

+ OnHeaders func(p *Peer, msg *wire.MsgHeaders)

+ OnInv func(p *Peer, msg *wire.MsgInv)

+ OnMemPool func(p *Peer, msg *wire.MsgMemPool)

+ OnMerkleBlock func(p *Peer, msg *wire.MsgMerkleBlock)

+ OnMiningState func(p *Peer, msg *wire.MsgMiningState)

+ OnNotFound func(p *Peer, msg *wire.MsgNotFound)

+ OnPing func(p *Peer, msg *wire.MsgPing)

+ OnPong func(p *Peer, msg *wire.MsgPong)

+ OnRead func(p *Peer, bytesRead int, msg wire.Message, err error)

+ OnReject func(p *Peer, msg *wire.MsgReject)

+ OnTx func(p *Peer, msg *wire.MsgTx)

+ OnVerAck func(p *Peer, msg *wire.MsgVerAck)

+ OnVersion func(p *Peer, msg *wire.MsgVersion)

+ OnWrite func(p *Peer, bytesWritten int, msg wire.Message, err error)

+ type MruInventoryMap struct

+ func NewMruInventoryMap(limit uint) *MruInventoryMap

+ func (m *MruInventoryMap) Add(iv *wire.InvVect)

+ func (m *MruInventoryMap) Delete(iv *wire.InvVect)

+ func (m *MruInventoryMap) Exists(iv *wire.InvVect) bool

+ func (m *MruInventoryMap) String() string

+ type Peer struct

+ func NewInboundPeer(cfg *Config, conn net.Conn) *Peer

+ func NewOutboundPeer(cfg *Config, addr string) (*Peer, error)

+ func (p *Peer) AddKnownInventory(invVect *wire.InvVect)

+ func (p *Peer) Addr() string

+ func (p *Peer) BytesReceived() uint64

+ func (p *Peer) BytesSent() uint64

+ func (p *Peer) Connect(conn net.Conn) error

+ func (p *Peer) Connected() bool

+ func (p *Peer) Disconnect()

+ func (p *Peer) ID() int32

+ func (p *Peer) Inbound() bool

+ func (p *Peer) LastAnnouncedBlock() *chainhash.Hash

+ func (p *Peer) LastBlock() int32

+ func (p *Peer) LastPingMicros() int64

+ func (p *Peer) LastPingNonce() uint64

+ func (p *Peer) LastPingTime() time.Time

+ func (p *Peer) LastRecv() time.Time

+ func (p *Peer) LastSend() time.Time

+ func (p *Peer) NA() *wire.NetAddress

+ func (p *Peer) ProtocolVersion() uint32

+ func (p *Peer) PushAddrMsg(addresses []*wire.NetAddress) ([]*wire.NetAddress, error)

+ func (p *Peer) PushGetBlocksMsg(locator blockchain.BlockLocator, stopHash *chainhash.Hash) error

+ func (p *Peer) PushGetHeadersMsg(locator blockchain.BlockLocator, stopHash *chainhash.Hash) error

+ func (p *Peer) PushRejectMsg(command string, code wire.RejectCode, reason string, hash *chainhash.Hash, ...)

+ func (p *Peer) QueueInventory(invVect *wire.InvVect)

+ func (p *Peer) QueueMessage(msg wire.Message, doneChan chan struct{})

+ func (p *Peer) Services() wire.ServiceFlag

+ func (p *Peer) Shutdown()

+ func (p *Peer) Start() error

+ func (p *Peer) StartingHeight() int32

+ func (p *Peer) StatsSnapshot() *StatsSnap

+ func (p *Peer) String() string

+ func (p *Peer) TimeConnected() time.Time

+ func (p *Peer) TimeOffset() int64

+ func (p *Peer) UpdateLastAnnouncedBlock(blkSha *chainhash.Hash)

+ func (p *Peer) UpdateLastBlockHeight(newHeight int32)

+ func (p *Peer) UserAgent() string

+ func (p *Peer) VerAckReceived() bool

+ func (p *Peer) VersionKnown() bool

+ func (p *Peer) WaitForShutdown()

+ type ShaFunc func() (sha *chainhash.Hash, height int64, err error)

+ type StatsSnap struct

+ Addr string

+ BytesRecv uint64

+ BytesSent uint64

+ ConnTime time.Time

+ ID int32

+ Inbound bool

+ LastBlock int32

+ LastPingMicros int64

+ LastPingNonce uint64

+ LastPingTime time.Time

+ LastRecv time.Time

+ LastSend time.Time

+ Services wire.ServiceFlag

+ StartingHeight int32

+ TimeOffset int64

+ UserAgent string

+ Version uint32

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL