p2p

Documentation

Index

• func MakeHost(port int, prvKey crypto.PrivKey) host.Host
• func PackMultiaddr(port int, addr string, pubKey string) string
• type MsgWithSigandSrc
• type NetworkDealer
  • func NewnetworkDealer(port int, prvkey crypto.PrivKey, reflectedTypesMap map[uint8]reflect.Type) (*NetworkDealer, error)
  • func Startpeer(port int, prvkey crypto.PrivKey, reflectedTypesMap map[uint8]reflect.Type) (*NetworkDealer, error)
  • func (n *NetworkDealer) Broadcast(messagetype uint8, msg interface{}, sig []byte, simlatency float64) error
  • func (n *NetworkDealer) Connect(port int, addr string, pubKey string) (*bufio.Writer, error)
  • func (n *NetworkDealer) ConnectWithMultiaddr(multi string) (*bufio.Writer, error)
  • func (n *NetworkDealer) Connectpeers(peerid int, idaddrmap map[int]string, idportmap map[int]int, ...) error
  • func (n *NetworkDealer) ExtractMsg() chan MsgWithSigandSrc
  • func (n *NetworkDealer) HandleConn(r *bufio.Reader)
  • func (n *NetworkDealer) Listen()
  • func (n *NetworkDealer) SendMsg(messagetype uint8, msg interface{}, sig []byte, dest string) error

Functions

func MakeHost

func MakeHost(port int, prvKey crypto.PrivKey) host.Host

func PackMultiaddr

func PackMultiaddr(port int, addr string, pubKey string) string

Types

type MsgWithSigandSrc

type MsgWithSigandSrc struct {
	Msg      interface{}
	Sig      []byte
	Msgbytes []byte
}

type NetworkDealer

type NetworkDealer struct {
	H host.Host

	BroadcastSyncLock sync.Mutex
	// contains filtered or unexported fields
}

func NewnetworkDealer

func NewnetworkDealer(port int, prvkey crypto.PrivKey, reflectedTypesMap map[uint8]reflect.Type) (*NetworkDealer, error)

func Startpeer

func Startpeer(port int, prvkey crypto.PrivKey, reflectedTypesMap map[uint8]reflect.Type) (*NetworkDealer, error)

func (*NetworkDealer) Broadcast

func (n *NetworkDealer) Broadcast(messagetype uint8, msg interface{}, sig []byte, simlatency float64) error

func (*NetworkDealer) Connect

func (n *NetworkDealer) Connect(port int, addr string, pubKey string) (*bufio.Writer, error)

func (*NetworkDealer) ConnectWithMultiaddr

func (n *NetworkDealer) ConnectWithMultiaddr(multi string) (*bufio.Writer, error)

func (*NetworkDealer) Connectpeers

func (n *NetworkDealer) Connectpeers(peerid int, idaddrmap map[int]string, idportmap map[int]int, pubstringsmap map[int]string) error

func (*NetworkDealer) ExtractMsg

func (n *NetworkDealer) ExtractMsg() chan MsgWithSigandSrc

func (*NetworkDealer) HandleConn

func (n *NetworkDealer) HandleConn(r *bufio.Reader)

func (*NetworkDealer) Listen

func (n *NetworkDealer) Listen()

func (*NetworkDealer) SendMsg

func (n *NetworkDealer) SendMsg(messagetype uint8, msg interface{}, sig []byte, dest string) error