Versions in this module Expand all Collapse all v0 v0.4.1 Dec 28, 2018 Changes in this version + const NumberOfMessageCodes + const ProtocolName + const ProtocolVersion + const ProtocolVersionStr + var DefaultConfig = Config + func Broatcast(msg string) + func BroatcastToGroup(msg string) + func GetSelfID() discover.NodeID + func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error + func RegisterDcrmCallback(dcrmcallback func(interface{}) <-chan string) + func RegisterDcrmRetCallback(dcrmcallback func(interface{})) + func RegisterRecvCallback(recvPrivkeyFunc func(interface{})) + func SendMsgToPeer(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error + func SendToDcrmGroup(msg string) string + func SendToPeer(enode string, msg string) + type Config struct + DataPath string + DcrmNodes []*discover.Node + type Dcrm struct + func New(cfg *Config) *Dcrm + func (dcrm *Dcrm) APIs() []rpc.API + func (dcrm *Dcrm) Protocols() []p2p.Protocol + func (dcrm *Dcrm) Start(server *p2p.Server) error + func (dcrm *Dcrm) Stop() error + type DcrmAPI struct + func (dcrm *DcrmAPI) Peers(ctx context.Context) []*p2p.PeerInfo + func (dcrm *DcrmAPI) Version(ctx context.Context) (v string) + type Group struct + func NewDcrmGroup() *Group + type Peer struct + Peer *p2p.Peer + type Transaction struct + Hash atomic.Value + Payload []byte v0.4.0 Oct 11, 2018 Changes in this version + const P2PTEST + const TEST + func GetEnodes() (int, string) + func GetGroup() (int, string) + func Init(id discover.NodeID, ipa *net.UDPAddr) + func P2pInit(port int, bn string, nodekeyfile string, staticnodesfile string) + func RegisterCallback(callbackfunc func(interface{})) + func Send2Node(enode string, msg *string) + func SendMsg(msg string) + func StartTest() + type Emitter struct + func NewEmitter() *Emitter