peer

package
v0.0.0-...-509fca3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 12, 2019 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Callbacks PeerCallbacks
}

type Peer

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

func NewPeer

func NewPeer(conn net.Conn, config *Config, ingoing bool) *Peer

func (*Peer) Ingoing

func (peer *Peer) Ingoing() bool

func (*Peer) Outgoing

func (peer *Peer) Outgoing() bool

func (*Peer) RemoteAddr

func (peer *Peer) RemoteAddr() net.Addr

func (*Peer) Send

func (peer *Peer) Send(message network.Message) error

func (*Peer) Start

func (peer *Peer) Start() error

func (*Peer) Stop

func (peer *Peer) Stop() error

func (Peer) String

func (peer Peer) String() string

type PeerCallbacks

type PeerCallbacks struct {
	OnReady        func(*Peer)
	OnDisconnected func(*Peer)
	OnWhoami       func(*Peer, *network.WhoamiMessage)
	OnWhoamiAck    func(*Peer, *network.WhoamiAckMessage)
	OnInv          func(*Peer, *network.InvMessage)
	OnGetData      func(*Peer, *network.GetDataMessage)
	OnNotFound     func(*Peer, *network.NotFoundMessage)
	OnBlock        func(*Peer, *network.BlockMessage)
	OnTx           func(*Peer, *network.TxMessage)
	OnGetBlocks    func(*Peer, *network.GetBlocksMessage)
	OnGetMempool   func(*Peer, *network.GetMempoolMessage)
}

Jump to

Keyboard shortcuts

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