Documentation
¶
Index ¶
- func Close()
- func Entry(method string, peer *signal.Peer, msg json.RawMessage, ...)
- func Init(dcID, nodeID, rpcID, eventID string, natsURL string)
- func ParseProtoo(msg json.RawMessage, msgType interface{}) *nprotoo.Error
- func WatchServiceNodes(service string, state discovery.NodeStateType, node discovery.Node)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Entry ¶
func Entry(method string, peer *signal.Peer, msg json.RawMessage, accept signal.RespondFunc, reject signal.RejectFunc)
Entry is the biz entry
func ParseProtoo ¶ added in v0.3.10
func ParseProtoo(msg json.RawMessage, msgType interface{}) *nprotoo.Error
ParseProtoo Unmarshals a protoo payload.
func WatchServiceNodes ¶
func WatchServiceNodes(service string, state discovery.NodeStateType, node discovery.Node)
WatchServiceNodes .
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.