rpc

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (this *Client) Call(v []interface{}) []interface{}
  • func (this *Client) Close(uint16)
  • func (this *Client) Connect(fd uint16, s *network.Session)
  • func (this *Client) Dial(addr string)
  • func (this *Client) Heartbeat(uint16, uint16)
  • func (this *Client) Message(fd uint16, sessionID uint16, body []byte)
  • func (this *Client) Send(v []interface{})
  • func (this *Client) SendCallBack(v []interface{}, callBack func(callRet interface{}))
• type Server
  • func NewServer(addr string) *Server
  • func (this *Server) Close(fd uint16)
  • func (this *Server) Connect(fd uint16, session *network.Session)
  • func (this *Server) Heartbeat(fd uint16, sessionID uint16)
  • func (this *Server) Message(fd uint16, sessionID uint16, body []byte)
  • func (this *Server) Register(rcvr interface{})
  • func (this *Server) RunFunc(m *methodType, args []reflect.Value) []interface{}
  • func (this *Server) Start()
• type Service

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Call

func (this *Client) Call(v []interface{}) []interface{}

func (*Client) Close

func (this *Client) Close(uint16)

func (*Client) Connect

func (this *Client) Connect(fd uint16, s *network.Session)

func (*Client) Dial

func (this *Client) Dial(addr string)

func (*Client) Heartbeat

func (this *Client) Heartbeat(uint16, uint16)

func (*Client) Message

func (this *Client) Message(fd uint16, sessionID uint16, body []byte)

func (*Client) Send

func (this *Client) Send(v []interface{})

func (*Client) SendCallBack

func (this *Client) SendCallBack(v []interface{}, callBack func(callRet interface{}))

type Server

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

func NewServer

func NewServer(addr string) *Server

func (*Server) Close

func (this *Server) Close(fd uint16)

func (*Server) Connect

func (this *Server) Connect(fd uint16, session *network.Session)

func (*Server) Heartbeat

func (this *Server) Heartbeat(fd uint16, sessionID uint16)

func (*Server) Message

func (this *Server) Message(fd uint16, sessionID uint16, body []byte)

func (*Server) Register

func (this *Server) Register(rcvr interface{})

func (*Server) RunFunc

func (this *Server) RunFunc(m *methodType, args []reflect.Value) []interface{}

func (*Server) Start

func (this *Server) Start()

type Service

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