nng

Documentation

Index

• func InitPairClientSock(url string) (sock mangos.Socket, err error)
• func InitPairServerSock(url string) (sock mangos.Socket, err error)
• func InitPipelinePullSock(url string) (sock mangos.Socket, err error)
• func InitPipelinePushSock(url string) (sock mangos.Socket, err error)
• func InitPubSock(url string) (sock mangos.Socket, err error)
• func InitRepSock(url string) (sock mangos.Socket, err error)
• func InitReqSock(url string) (sock mangos.Socket, err error)
• func InitSubSock(url string) (sock mangos.Socket, err error)
• func SendAndReceive(sock mangos.Socket, reqData []byte) (respData []byte, err error)
• type NngRPCClient
  • func NewRPCClient(rpcAddr string) *NngRPCClient
  • func (nc *NngRPCClient) Call1(rpcCmd string, params map[string]interface{}) (result map[string]interface{}, err error)
  • func (nc *NngRPCClient) Call2(rpcCmd string, params interface{}, result interface{}) (err error)
• type NngRPCServer
  • func NewRPCServer(rpcAddr string) *NngRPCServer
  • func (nr *NngRPCServer) HandleRequest()
  • func (nr *NngRPCServer) Register(rpcCmd string, handler RpcHandler)
• type Publisher
  • func NewPublisher(addr string) *Publisher
  • func (p *Publisher) SendPub(msg []byte) error
• type RpcHandler
• type RpcReq
• type RpcResp

Functions

func InitPairClientSock

func InitPairClientSock(url string) (sock mangos.Socket, err error)

初始化pair的客户端套接字

func InitPairServerSock

func InitPairServerSock(url string) (sock mangos.Socket, err error)

初始化pair的服务端套接字

func InitPipelinePullSock

func InitPipelinePullSock(url string) (sock mangos.Socket, err error)

初始化pipeline的拉取端套接字

func InitPipelinePushSock

func InitPipelinePushSock(url string) (sock mangos.Socket, err error)

初始化pipeline的推送端套接字

func InitPubSock

func InitPubSock(url string) (sock mangos.Socket, err error)

初始化订阅服务端套接字

func InitRepSock

func InitRepSock(url string) (sock mangos.Socket, err error)

初始化命令服务端套接字

func InitReqSock

func InitReqSock(url string) (sock mangos.Socket, err error)

初始化命令套接字

func InitSubSock

func InitSubSock(url string) (sock mangos.Socket, err error)

初始化订阅套接字

func SendAndReceive

func SendAndReceive(sock mangos.Socket, reqData []byte) (respData []byte, err error)

发送和读取数据

Types

type NngRPCClient

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

func NewRPCClient

func NewRPCClient(rpcAddr string) *NngRPCClient

func (*NngRPCClient) Call1

func (nc *NngRPCClient) Call1(rpcCmd string, params map[string]interface{}) (result map[string]interface{}, err error)

func (*NngRPCClient) Call2

func (nc *NngRPCClient) Call2(rpcCmd string, params interface{}, result interface{}) (err error)

type NngRPCServer

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

func NewRPCServer

func NewRPCServer(rpcAddr string) *NngRPCServer

func (*NngRPCServer) HandleRequest

func (nr *NngRPCServer) HandleRequest()

处理命令

func (*NngRPCServer) Register

func (nr *NngRPCServer) Register(rpcCmd string, handler RpcHandler)

注册命令

type Publisher

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

func NewPublisher

func NewPublisher(addr string) *Publisher

func (*Publisher) SendPub

func (p *Publisher) SendPub(msg []byte) error

发布数据

type RpcHandler

type RpcHandler func(map[string]interface{}) interface{}

type RpcReq

type RpcReq struct {
	ID     string                 `json:"id"`
	CMD    string                 `json:"cmd"`
	Params map[string]interface{} `json:"params"`
}

type RpcResp

type RpcResp struct {
	ID   string      `json:"id"`
	CMD  string      `json:"cmd"`
	Code int         `json:"code"`
	Msg  string      `json:"msg"` // msg 和 data互斥，只会存在一个
	Data interface{} `json:"data"`
}