layer2

package

v0.0.0-...-872243e Latest Latest Go to latest Published: Sep 27, 2019 License: GPL-3.0, LGPL-3.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gaozhengxin/dcrm5-dex-mongo

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Broadcast(msg string)
func BroadcastToGroup(msg string, p2pType int)
func CC_startTest()
func DcrmProtocol_broadcastInGroup(msg string)
func DcrmProtocol_getEnodes() (int, string)
func DcrmProtocol_getGroup() (int, string)
func DcrmProtocol_registerMsgRecvCallback(dcrmcallback func(interface{}) <-chan string)
func DcrmProtocol_registerMsgRetCallback(dcrmcallback func(interface{}))
func DcrmProtocol_registerPriKeyCallback(recvPrivkeyFunc func(interface{}))
func DcrmProtocol_registerRecvCallback(recvDcrmFunc func(interface{}) <-chan string)
func DcrmProtocol_sendMsgToNode(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error
func DcrmProtocol_sendMsgToPeer(enode string, msg string) error
func DcrmProtocol_sendToGroupOneNode(msg string) string
func DcrmProtocol_startTest()
func Dcrm_callEvent(msg string)
func GetEnodes() (int, string)
func GetGroup() (int, string)
func GetSelfID() discover.NodeID
func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error
func RegisterCallback(recvFunc func(interface{}))
func RegisterDcrmCallback(dcrmcallback func(interface{}) <-chan string)
func RegisterDcrmRetCallback(dcrmcallback func(interface{}))
func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))
func RegisterUpdateOrderCacheCallback(recvDcrmFunc func(interface{}))
func SendMsg(msg string)
func SendMsgToPeer(enode string, msg string) error
func SendToDcrmGroupAllNodes(msg string) string
func SendToPeer(enode string, msg string)
func Xp_callEvent(msg string)
func Xprotocol_broadcastInGroup(msg string)
func Xprotocol_getEnodes() (int, string)
func Xprotocol_getGroup() (int, string)
func Xprotocol_registerMsgRecvCallback(xpcallback func(interface{}) <-chan string)
func Xprotocol_registerMsgRetCallback(xpcallback func(interface{}))
func Xprotocol_registerRecvCallback(recvXpFunc func(interface{}))
func Xprotocol_sendMsgToNode(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error
func Xprotocol_sendMsgToPeer(enode string, msg string) error
func Xprotocol_sendToGroupOneNode(msg string) string
func Xprotocol_startTest()
type Config
type Dcrm
- func DcrmNew(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
- func (dcrm *DcrmAPI) Peers(ctx context.Context) []*p2p.PeerInfo
- func (dcrm *DcrmAPI) Version(ctx context.Context) (v string)
type Emitter
- func NewEmitter() *Emitter
type Group
- func NewGroup() *Group
type Transaction
type Xp
- func XpNew(cfg *Config) *Xp
- func (xp *Xp) APIs() []rpc.API
- func (xp *Xp) Protocols() []p2p.Protocol
- func (xp *Xp) Start(server *p2p.Server) error
- func (xp *Xp) Stop() error
type XpAPI
- func (xp *XpAPI) Peers(ctx context.Context) []*p2p.PeerInfo
- func (xp *XpAPI) Version(ctx context.Context) (v string)

Constants ¶

View Source

const (
	DcrmProtocol_type = discover.Dcrmprotocol_type
	Xprotocol_type    = discover.Xprotocol_type
	ProtocolName      = "dcrm"
	Xp_ProtocolName   = "xp"

	Dcrm_msgCode
	Xp_msgCode

	ProtocolVersion      = 1
	ProtocolVersionStr   = "1"
	NumberOfMessageCodes = 8 + iota // msgLength

)

TODO

Variables ¶

View Source

var (
	Dcrm_callback func(interface{}) <-chan string
	Xp_callback   func(interface{})
)

View Source

var DefaultConfig = Config{
	Nodes: make([]*discover.Node, 0),
}

Functions ¶

func Broadcast ¶

func Broadcast(msg string)

func BroadcastToGroup ¶

func BroadcastToGroup(msg string, p2pType int)

func CC_startTest ¶

func CC_startTest()

func DcrmProtocol_broadcastInGroup ¶

func DcrmProtocol_broadcastInGroup(msg string)

broadcast to group's nodes

func DcrmProtocol_getEnodes ¶

func DcrmProtocol_getEnodes() (int, string)

func DcrmProtocol_getGroup ¶

func DcrmProtocol_getGroup() (int, string)

get info

func DcrmProtocol_registerMsgRecvCallback ¶

func DcrmProtocol_registerMsgRecvCallback(dcrmcallback func(interface{}) <-chan string)

receive message from dccp

func DcrmProtocol_registerMsgRetCallback ¶

func DcrmProtocol_registerMsgRetCallback(dcrmcallback func(interface{}))

receive message from dccp result

func DcrmProtocol_registerPriKeyCallback ¶

func DcrmProtocol_registerPriKeyCallback(recvPrivkeyFunc func(interface{}))

callback receive private key

func DcrmProtocol_registerRecvCallback ¶

func DcrmProtocol_registerRecvCallback(recvDcrmFunc func(interface{}) <-chan string)

receive message form peers

func DcrmProtocol_sendMsgToNode ¶

func DcrmProtocol_sendMsgToNode(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error

unicast to anyone

func DcrmProtocol_sendMsgToPeer ¶

func DcrmProtocol_sendMsgToPeer(enode string, msg string) error

to peers

func DcrmProtocol_sendToGroupOneNode ¶

func DcrmProtocol_sendToGroupOneNode(msg string) string

txs start

func DcrmProtocol_startTest ¶

func DcrmProtocol_startTest()

func Dcrm_callEvent ¶

func Dcrm_callEvent(msg string)

func GetEnodes ¶

func GetEnodes() (int, string)

func GetGroup ¶

func GetGroup() (int, string)

func GetSelfID ¶

func GetSelfID() discover.NodeID

func HandlePeer ¶

func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error

func RegisterCallback ¶

func RegisterCallback(recvFunc func(interface{}))

receive message form peers

func RegisterDcrmCallback ¶

func RegisterDcrmCallback(dcrmcallback func(interface{}) <-chan string)

func RegisterDcrmRetCallback ¶

func RegisterDcrmRetCallback(dcrmcallback func(interface{}))

func RegisterRecvCallback ¶

func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))

func RegisterUpdateOrderCacheCallback ¶

func RegisterUpdateOrderCacheCallback(recvDcrmFunc func(interface{}))

func SendMsg ¶

func SendMsg(msg string)

TODO

func SendMsgToPeer ¶

func SendMsgToPeer(enode string, msg string) error

func SendToDcrmGroupAllNodes ¶

func SendToDcrmGroupAllNodes(msg string) string

func SendToPeer ¶

func SendToPeer(enode string, msg string)

func Xp_callEvent ¶

func Xp_callEvent(msg string)

func Xprotocol_broadcastInGroup ¶

func Xprotocol_broadcastInGroup(msg string)

broadcast to group's nodes

func Xprotocol_getEnodes ¶

func Xprotocol_getEnodes() (int, string)

func Xprotocol_getGroup ¶

func Xprotocol_getGroup() (int, string)

func Xprotocol_registerMsgRecvCallback ¶

func Xprotocol_registerMsgRecvCallback(xpcallback func(interface{}) <-chan string)

receive message from xp

func Xprotocol_registerMsgRetCallback ¶

func Xprotocol_registerMsgRetCallback(xpcallback func(interface{}))

receive message from dccp result

func Xprotocol_registerRecvCallback ¶

func Xprotocol_registerRecvCallback(recvXpFunc func(interface{}))

receive message form peers

func Xprotocol_sendMsgToNode ¶

func Xprotocol_sendMsgToNode(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error

unicast to anyone

func Xprotocol_sendMsgToPeer ¶

func Xprotocol_sendMsgToPeer(enode string, msg string) error

to peers

func Xprotocol_sendToGroupOneNode ¶

func Xprotocol_sendToGroupOneNode(msg string) string

txs start

func Xprotocol_startTest ¶

func Xprotocol_startTest()

Types ¶

type Config ¶

type Config struct {
	Nodes    []*discover.Node
	DataPath string
}

type Dcrm ¶

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

func DcrmNew ¶

func DcrmNew(cfg *Config) *Dcrm

p2p layer 2 New creates a Whisper client ready to communicate through the Ethereum P2P network.

func (*Dcrm) APIs ¶

func (dcrm *Dcrm) APIs() []rpc.API

APIs returns the RPC descriptors the Whisper implementation offers

func (*Dcrm) Protocols ¶

func (dcrm *Dcrm) Protocols() []p2p.Protocol

Protocols returns the whisper sub-protocols ran by this particular client.

func (*Dcrm) Start ¶

func (dcrm *Dcrm) Start(server *p2p.Server) error

other Start implements node.Service, starting the background data propagation thread of the Whisper protocol.

func (*Dcrm) Stop ¶

func (dcrm *Dcrm) Stop() error

Stop implements node.Service, stopping the background data propagation thread of the Whisper protocol.

type DcrmAPI ¶

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

func (*DcrmAPI) Peers ¶

func (dcrm *DcrmAPI) Peers(ctx context.Context) []*p2p.PeerInfo

func (*DcrmAPI) Version ¶

func (dcrm *DcrmAPI) Version(ctx context.Context) (v string)

type Emitter ¶

type Emitter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEmitter ¶

func NewEmitter() *Emitter

type Group ¶

type Group struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewGroup ¶

func NewGroup() *Group

type Transaction ¶

type Transaction struct {
	Payload []byte
	Hash    atomic.Value
}

type Xp ¶

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

func XpNew ¶

func XpNew(cfg *Config) *Xp

p2p layer 2 New creates a Whisper client ready to communicate through the Ethereum P2P network.

func (*Xp) APIs ¶

func (xp *Xp) APIs() []rpc.API

APIs returns the RPC descriptors the Whisper implementation offers

func (*Xp) Protocols ¶

func (xp *Xp) Protocols() []p2p.Protocol

Protocols returns the whisper sub-protocols ran by this particular client.

func (*Xp) Start ¶

func (xp *Xp) Start(server *p2p.Server) error

other Start implements node.Service, starting the background data propagation thread of the Whisper protocol.

func (*Xp) Stop ¶

func (xp *Xp) Stop() error

Stop implements node.Service, stopping the background data propagation thread of the Whisper protocol.

type XpAPI ¶

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

func (*XpAPI) Peers ¶

func (xp *XpAPI) Peers(ctx context.Context) []*p2p.PeerInfo

func (*XpAPI) Version ¶

func (xp *XpAPI) Version(ctx context.Context) (v string)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL