network

Feb 19, 2020

Changes in this version

type Server

+ func (s *Server) IsInSync() bool

Feb 6, 2020

Changes in this version

type DefaultDiscovery

+ func (d *DefaultDiscovery) RegisterConnectedAddr(addr string)

type Discoverer

+ RegisterConnectedAddr func(string)

type Message

+ func (m *Message) Bytes() ([]byte, error)

type Peer

+ EnqueueHPPacket func([]byte) error

+ EnqueueMessage func(*Message) error

+ EnqueueP2PMessage func(*Message) error

+ EnqueueP2PPacket func([]byte) error

+ EnqueuePacket func([]byte) error

+ HandlePong func(pong *payload.Ping) error

+ LastBlockIndex func() uint32

+ SendPing func(*Message) error

+ StartProtocol func()

type Server

+ func (s *Server) MkMsg(cmd CommandType, p payload.Payload) *Message

type ServerConfig

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ TimePerBlock time.Duration

type TCPPeer

+ func (p *TCPPeer) EnqueueHPPacket(msg []byte) error

+ func (p *TCPPeer) EnqueueMessage(msg *Message) error

+ func (p *TCPPeer) EnqueueP2PMessage(msg *Message) error

+ func (p *TCPPeer) EnqueueP2PPacket(msg []byte) error

+ func (p *TCPPeer) EnqueuePacket(msg []byte) error

+ func (p *TCPPeer) HandlePong(pong *payload.Ping) error

+ func (p *TCPPeer) LastBlockIndex() uint32

+ func (p *TCPPeer) SendPing(msg *Message) error

+ func (p *TCPPeer) StartProtocol()

Dec 16, 2019

Changes in this version

type Server

+ func (s *Server) HandshakedPeersCount() int

Nov 29, 2019

Changes in this version

type ServerConfig

+ Wallet *config.WalletConfig

Nov 7, 2019

Changes in this version

type Peer

+ PeerAddr func() net.Addr

+ RemoteAddr func() net.Addr

type ServerConfig

+ Address string

+ AttemptConnPeers int

+ Port uint16

type TCPPeer

+ func (p *TCPPeer) PeerAddr() net.Addr

+ func (p *TCPPeer) RemoteAddr() net.Addr

Nov 1, 2019

Changes in this version

type ServerConfig

+ MinPeers int

Sep 19, 2019

Changes in this version

+ type CommandType string

+ const CMDAddr

+ const CMDBlock

+ const CMDConsensus

+ const CMDFilterAdd

+ const CMDFilterClear

+ const CMDFilterLoad

+ const CMDGetAddr

+ const CMDGetBlocks

+ const CMDGetData

+ const CMDGetHeaders

+ const CMDHeaders

+ const CMDInv

+ const CMDMempool

+ const CMDMerkleBlock

+ const CMDPing

+ const CMDPong

+ const CMDTX

+ const CMDUnknown

+ const CMDVerack

+ const CMDVersion

+ type DefaultDiscovery struct

+ func NewDefaultDiscovery(dt time.Duration, ts Transporter) *DefaultDiscovery

+ func (d *DefaultDiscovery) BackFill(addrs ...string)

+ func (d *DefaultDiscovery) BadPeers() []string

+ func (d *DefaultDiscovery) GoodPeers() []string

+ func (d *DefaultDiscovery) PoolCount() int

+ func (d *DefaultDiscovery) RegisterBadAddr(addr string)

+ func (d *DefaultDiscovery) RegisterGoodAddr(s string)

+ func (d *DefaultDiscovery) RequestRemote(n int)

+ func (d *DefaultDiscovery) UnconnectedPeers() []string

+ func (d *DefaultDiscovery) UnregisterConnectedAddr(s string)

+ type Discoverer interface

+ BackFill func(...string)

+ BadPeers func() []string

+ GoodPeers func() []string

+ PoolCount func() int

+ RegisterBadAddr func(string)

+ RegisterGoodAddr func(string)

+ RequestRemote func(int)

+ UnconnectedPeers func() []string

+ UnregisterConnectedAddr func(string)

+ type Message struct

+ Checksum uint32

+ Command [cmdSize]byte

+ Length uint32

+ Magic config.NetMode

+ Payload payload.Payload

+ func NewMessage(magic config.NetMode, cmd CommandType, p payload.Payload) *Message

+ func (m *Message) CommandType() CommandType

+ func (m *Message) Decode(br *io.BinReader) error

+ func (m *Message) Encode(br *io.BinWriter) error

+ type Peer interface

+ Disconnect func(error)

+ Done func() chan error

+ HandleVersion func(*payload.Version) error

+ HandleVersionAck func() error

+ Handshaked func() bool

+ NetAddr func() *net.TCPAddr

+ SendVersion func(*Message) error

+ SendVersionAck func(*Message) error

+ Version func() *payload.Version

+ WriteMsg func(msg *Message) error

+ type RelayReason uint8

+ const RelayAlreadyExists

+ const RelayInvalid

+ const RelayOutOfMemory

+ const RelayPolicyFail

+ const RelaySucceed

+ const RelayUnableToVerify

+ const RelayUnknown

+ type Server struct

+ func NewServer(config ServerConfig, chain core.Blockchainer) *Server

+ func (s *Server) BadPeers() []string

+ func (s *Server) ID() uint32

+ func (s *Server) PeerCount() int

+ func (s *Server) Peers() map[Peer]bool

+ func (s *Server) RelayDirectly(p Peer, inv *payload.Inventory)

+ func (s *Server) RelayTxn(t *transaction.Transaction) RelayReason

+ func (s *Server) Shutdown()

+ func (s *Server) Start(errChan chan error)

+ func (s *Server) UnconnectedPeers() []string

+ type ServerConfig struct

+ DialTimeout time.Duration

+ ListenTCP uint16

+ LogLevel log.Level

+ MaxPeers int

+ Net config.NetMode

+ ProtoTickInterval time.Duration

+ Relay bool

+ Seeds []string

+ UserAgent string

+ func NewServerConfig(cfg config.Config) ServerConfig

+ type TCPPeer struct

+ func NewTCPPeer(conn net.Conn) *TCPPeer

+ func (p *TCPPeer) Disconnect(err error)

+ func (p *TCPPeer) Done() chan error

+ func (p *TCPPeer) HandleVersion(version *payload.Version) error

+ func (p *TCPPeer) HandleVersionAck() error

+ func (p *TCPPeer) Handshaked() bool

+ func (p *TCPPeer) NetAddr() *net.TCPAddr

+ func (p *TCPPeer) SendVersion(msg *Message) error

+ func (p *TCPPeer) SendVersionAck(msg *Message) error

+ func (p *TCPPeer) Version() *payload.Version

+ func (p *TCPPeer) WriteMsg(msg *Message) error

+ type TCPTransport struct

+ func NewTCPTransport(s *Server, bindAddr string) *TCPTransport

+ func (t *TCPTransport) Accept()

+ func (t *TCPTransport) Close()

+ func (t *TCPTransport) Dial(addr string, timeout time.Duration) error

+ func (t *TCPTransport) Proto() string

+ type Transporter interface

+ Accept func()

+ Close func()

+ Dial func(addr string, timeout time.Duration) error

+ Proto func() string