network

Documentation

Index

• Constants
• type TCP
  • func NewTCP(peers ...string) *TCP
  • func (t *TCP) AddPeer(peer string)
  • func (t *TCP) Block(reference *bcgo.Reference) (*bcgo.Block, error)
  • func (t *TCP) Broadcast(channel bcgo.Channel, cache bcgo.Cache, hash []byte, block *bcgo.Block) error
  • func (t *TCP) Connect(peer string, data []byte) error
  • func (t *TCP) Head(channel string) (*bcgo.Reference, error)
  • func (t *TCP) PeerForAddress(address string) string
  • func (t *TCP) Peers() (peers []string)
  • func (t *TCP) SetPeers(peers ...string)

Constants

const (
	MAX_TCP_ERRORS = 10
	TIMEOUT        = 3 * time.Minute
	PORT_CONNECT   = 22022
	PORT_GET_BLOCK = 22222
	PORT_GET_HEAD  = 22322
	PORT_BROADCAST = 23232
)

Types

type TCP

type TCP struct {
	DialTimeout time.Duration
	GetTimeout  time.Duration
	// contains filtered or unexported fields
}

func NewTCP

func NewTCP(peers ...string) *TCP

func (*TCP) AddPeer

func (t *TCP) AddPeer(peer string)

func (*TCP) Block

func (t *TCP) Block(reference *bcgo.Reference) (*bcgo.Block, error)

func (*TCP) Broadcast

func (t *TCP) Broadcast(channel bcgo.Channel, cache bcgo.Cache, hash []byte, block *bcgo.Block) error

func (*TCP) Connect

func (t *TCP) Connect(peer string, data []byte) error

func (*TCP) Head

func (t *TCP) Head(channel string) (*bcgo.Reference, error)

func (*TCP) PeerForAddress

func (t *TCP) PeerForAddress(address string) string

Returns the peer associated with the given address

func (*TCP) Peers

func (t *TCP) Peers() (peers []string)

func (*TCP) SetPeers

func (t *TCP) SetPeers(peers ...string)