Documentation
¶
Index ¶
- Constants
- Variables
- func Broadcast(msg string)
- func BroadcastToGroup(gid discover.NodeID, msg string, p2pType int, myself bool) (string, error)
- func CC_startTest()
- func CheckAddPeer(threshold string, enodes []string, subGroup bool) (bool, error)
- func CreateSDKGroup(threshold string, enodes []string, subGroup bool) (string, int, string)
- func GetEnode() string
- func GetEnodeStatus(enode string) (string, error)
- func GetEnodes() (int, string)
- func GetGIDFromEnodes(enodes []string) (string, error)
- func GetGroup() (int, string)
- func GetGroupList() map[discover.NodeID]*discover.Group
- func GetGroupSDKAll() []*discover.Group
- func GetSelfDir() string
- func GetSelfID() string
- func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error
- func HexID(gID string) (discover.NodeID, error)
- func InitIPPort(port int)
- func InitP2pDir()
- func InitSelfNodeID(nodeid string)
- func InitServer(nodeserv interface{})
- func ParseNodeID(enode string) string
- func RegisterCallback(recvFunc func(interface{}, string))
- func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))
- func RegisterSendCallback(callbackfunc func(interface{}))
- func RegisterSmpcCallback(smpccallback func(interface{}) <-chan string)
- func RegisterSmpcRetCallback(smpccallback func(interface{}))
- func SdkProtocol_SendToGroupAllNodes(gID, msg string) (string, error)
- func SdkProtocol_broadcastInGroupAll(gID, msg string) (string, error)
- func SdkProtocol_broadcastInGroupOthers(gID, msg string) (string, error)
- func SdkProtocol_getGroup(gID string) (int, string)
- func SdkProtocol_registerBroadcastInGroupCallback(recvSdkFunc func(interface{}, string))
- func SdkProtocol_registerSendToGroupCallback(sdkcallback func(interface{}, string) <-chan string)
- func SdkProtocol_registerSendToGroupReturnCallback(sdkcallback func(interface{}, string))
- func SdkProtocol_sendToGroupOneNode(gID, msg string) (string, error)
- func Sdk_callEvent(msg string, fromID string)
- func SendMsg(msg string)
- func SendMsgToPeer(enode string, msg string) error
- func SendToMyself(enode, msg string, p2pType int) error
- func SendToPeer(enode string, msg string)
- func SendToSmpcGroupAllNodes(msg string) (string, error)
- func SmpcProtocol_broadcastInGroupAll(msg string)
- func SmpcProtocol_broadcastInGroupOthers(msg string)
- func SmpcProtocol_getEnodes() (int, string)
- func SmpcProtocol_getGroup() (int, string)
- func SmpcProtocol_registerMsgRecvCallback(smpccallback func(interface{}) <-chan string)
- func SmpcProtocol_registerMsgRetCallback(smpccallback func(interface{}))
- func SmpcProtocol_registerPriKeyCallback(recvPrivkeyFunc func(interface{}))
- func SmpcProtocol_registerRecvCallback(recvSmpcFunc func(interface{}) <-chan string)
- func SmpcProtocol_sendMsgToNode(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error
- func SmpcProtocol_sendMsgToPeer(enode string, msg string) error
- func SmpcProtocol_sendToGroupOneNode(msg string) (string, error)
- func Smpc_callEvent(msg string)
- func Xp_callEvent(msg string)
- func Xprotocol_broadcastInGroupAll(msg string)
- func Xprotocol_broadcastInGroupOthers(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, error)
- func Xprotocol_startTest()
- type Config
- type Emitter
- type Group
- type Smpc
- type SmpcAPI
- type Transaction
- type Xp
- type XpAPI
Constants ¶
View Source
const ( SmpcProtocol_type = discover.Smpcprotocol_type Xprotocol_type = discover.Xprotocol_type Sdkprotocol_type = discover.Sdkprotocol_type ProtocolName = "smpc" Xp_ProtocolName = "xp" Smpc_msgCode Sdk_msgCode Xp_msgCode ProtocolVersion = 1 ProtocolVersionStr = "1" NumberOfMessageCodes = 8 + iota // msgLength )
TODO
Variables ¶
View Source
var ( Smpc_callback func(interface{}) <-chan string Sdk_callback func(interface{}, string) Xp_callback func(interface{}) SdkGroup map[discover.NodeID]*discover.Group = make(map[discover.NodeID]*discover.Group) )
View Source
var DefaultConfig = Config{ Nodes: make([]*discover.Node, 0), }
Functions ¶
func BroadcastToGroup ¶
func CC_startTest ¶
func CC_startTest()
func CheckAddPeer ¶
func CreateSDKGroup ¶
1 + 1 + 1
func GetEnodeStatus ¶
func GetGIDFromEnodes ¶
func GetGroupSDKAll ¶
func GetSelfDir ¶
func GetSelfDir() string
func HandlePeer ¶
func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error
func InitIPPort ¶
func InitIPPort(port int)
func InitP2pDir ¶
func InitP2pDir()
func InitSelfNodeID ¶
func InitSelfNodeID(nodeid string)
func InitServer ¶
func InitServer(nodeserv interface{})
func ParseNodeID ¶
func RegisterCallback ¶
func RegisterCallback(recvFunc func(interface{}, string))
receive message form peers
func RegisterRecvCallback ¶
func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))
func RegisterSendCallback ¶
func RegisterSendCallback(callbackfunc func(interface{}))
func RegisterSmpcCallback ¶
func RegisterSmpcCallback(smpccallback func(interface{}) <-chan string)
func RegisterSmpcRetCallback ¶
func RegisterSmpcRetCallback(smpccallback func(interface{}))
func SdkProtocol_getGroup ¶
func SdkProtocol_registerBroadcastInGroupCallback ¶
func SdkProtocol_registerBroadcastInGroupCallback(recvSdkFunc func(interface{}, string))
--------------------- API callback ----------------------
recv from broadcastInGroup...
func SdkProtocol_registerSendToGroupCallback ¶
recv from sendToGroup...
func SdkProtocol_registerSendToGroupReturnCallback ¶
func SdkProtocol_registerSendToGroupReturnCallback(sdkcallback func(interface{}, string))
recv return from sendToGroup...
func SdkProtocol_sendToGroupOneNode ¶
================ API SDK =====================
func Sdk_callEvent ¶
func SendMsg ¶
func SendMsg(msg string)
=============================== SMPC =================================
func SendMsgToPeer ¶
func SendToMyself ¶
func SendToPeer ¶
func SendToSmpcGroupAllNodes ¶
func SmpcProtocol_broadcastInGroupAll ¶
func SmpcProtocol_broadcastInGroupAll(msg string)
broadcast to group's nodes
func SmpcProtocol_broadcastInGroupOthers ¶
func SmpcProtocol_broadcastInGroupOthers(msg string)
func SmpcProtocol_getEnodes ¶
func SmpcProtocol_registerMsgRecvCallback ¶
func SmpcProtocol_registerMsgRecvCallback(smpccallback func(interface{}) <-chan string)
receive message from dccp
func SmpcProtocol_registerMsgRetCallback ¶
func SmpcProtocol_registerMsgRetCallback(smpccallback func(interface{}))
receive message from dccp result
func SmpcProtocol_registerPriKeyCallback ¶
func SmpcProtocol_registerPriKeyCallback(recvPrivkeyFunc func(interface{}))
callback receive private key
func SmpcProtocol_registerRecvCallback ¶
func SmpcProtocol_registerRecvCallback(recvSmpcFunc func(interface{}) <-chan string)
receive message form peers
func SmpcProtocol_sendMsgToNode ¶
unicast to anyone
func SmpcProtocol_sendMsgToPeer ¶
to peers
func SmpcProtocol_sendToGroupOneNode ¶
txs start
func Smpc_callEvent ¶
func Smpc_callEvent(msg string)
func Xp_callEvent ¶
func Xp_callEvent(msg string)
func Xprotocol_broadcastInGroupAll ¶
func Xprotocol_broadcastInGroupAll(msg string)
func Xprotocol_broadcastInGroupOthers ¶
func Xprotocol_broadcastInGroupOthers(msg string)
broadcast to group's nodes
func Xprotocol_getEnodes ¶
func Xprotocol_getGroup ¶
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 ¶
unicast to anyone
func Xprotocol_sendMsgToPeer ¶
to peers
func Xprotocol_sendToGroupOneNode ¶
txs start
func Xprotocol_startTest ¶
func Xprotocol_startTest()
Types ¶
type Emitter ¶
func NewEmitter ¶
func NewEmitter() *Emitter
type Smpc ¶
type Smpc struct {
// contains filtered or unexported fields
}
func SmpcNew ¶
p2p layer 2 New creates a Whisper client ready to communicate through the Ethereum P2P network.
type Transaction ¶
type Xp ¶
type Xp struct {
// contains filtered or unexported fields
}
func XpNew ¶
p2p layer 2 New creates a Whisper client ready to communicate through the Ethereum P2P network.
Source Files
Click to show internal directories.
Click to hide internal directories.