p2p

Documentation

Index

• Constants
• Variables
• func AddPeer(ip, port string)
• func BroadcastMinedBlock(minedBlock *blockchain.Block)
• func BroadcastNewTx(newTx *blockchain.Tx)
• func GetPeersList() []string
• func PingForever()
• func UpgradePeer(rw http.ResponseWriter, r *http.Request)
• type Msg
  • func (m *Msg) KindToString() string
  • func (m Msg) String() string
• type MsgKind

Constants

const (
	WSURLformat = "ws://%s:%s/peers/upgrade?senderPort=%s"
)

Variables

var (
	Peers = &peers{
		v: make(map[string]*peer),
	}
)

Functions

func AddPeer

func AddPeer(ip, port string)

func BroadcastMinedBlock

func BroadcastMinedBlock(minedBlock *blockchain.Block)

func BroadcastNewTx

func BroadcastNewTx(newTx *blockchain.Tx)

func GetPeersList

func GetPeersList() []string

func PingForever

func PingForever()

func UpgradePeer

func UpgradePeer(rw http.ResponseWriter, r *http.Request)

Types

type Msg

type Msg struct {
	Kind    MsgKind
	Payload []byte
}

func (*Msg) KindToString

func (m *Msg) KindToString() string

func (Msg) String

func (m Msg) String() string

type MsgKind

type MsgKind int

const (
	MsgLastBlock MsgKind = iota
	MsgAllBlocksReq
	MsgAllBlocksResp
	MsgMinedBlock
	MsgNewTx
	MsgNewPeer
)