rawpeer

Documentation

Overview

Package rawpeer provides low level access to a bitcoin p2p node. It provides connect/handshake/disconnect and read/write commands.

Most implementations should not use this package directly.

Index

• Variables
• type RawPeer
  • func New(network wire.BitcoinNet, id int, address string) (*RawPeer, error)
  • func NewFromConn(conn net.Conn, network wire.BitcoinNet, protocolVersion uint32, id int) (*RawPeer, error)
  • func (r *RawPeer) Close() error
  • func (r *RawPeer) Connect(ctx context.Context) error
  • func (r *RawPeer) HasService(f wire.ServiceFlag) bool
  • func (r *RawPeer) Id() int
  • func (r *RawPeer) IsConnected() bool
  • func (r *RawPeer) Read(timeout time.Duration) (wire.Message, []byte, error)
  • func (r *RawPeer) RemoteVersion() (*wire.MsgVersion, error)
  • func (r *RawPeer) String() string
  • func (r *RawPeer) Write(timeout time.Duration, msg wire.Message) error

Variables

var (
	ErrHandshakeNotComplete = errors.New("handshake not complete")
)

Types

type RawPeer

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

func New

func New(network wire.BitcoinNet, id int, address string) (*RawPeer, error)

func NewFromConn

func NewFromConn(conn net.Conn, network wire.BitcoinNet, protocolVersion uint32, id int) (*RawPeer, error)

func (*RawPeer) Close

func (r *RawPeer) Close() error

func (*RawPeer) Connect

func (r *RawPeer) Connect(ctx context.Context) error

func (*RawPeer) HasService

func (r *RawPeer) HasService(f wire.ServiceFlag) bool

func (*RawPeer) Id

func (r *RawPeer) Id() int

func (*RawPeer) IsConnected

func (r *RawPeer) IsConnected() bool

func (*RawPeer) Read

func (r *RawPeer) Read(timeout time.Duration) (wire.Message, []byte, error)

func (*RawPeer) RemoteVersion

func (r *RawPeer) RemoteVersion() (*wire.MsgVersion, error)

func (*RawPeer) String

func (r *RawPeer) String() string

func (*RawPeer) Write

func (r *RawPeer) Write(timeout time.Duration, msg wire.Message) error