gdrpc

Documentation

Index

• type Client
  • func NewClient(netAddr string) *Client
  • func (its *Client) Addr() string
  • func (its *Client) Call(serviceMethod string, args, reply interface{}) error
  • func (its *Client) CallNoRet(serviceMethod string, args interface{}) error
  • func (its *Client) Close()
  • func (its *Client) Connect(url string) error
  • func (its *Client) NetAddr() string
• type IServer
• type Server
  • func (its *Server) Close()
  • func (its *Server) Done()
  • func (its *Server) GetAllAPI() []string
  • func (its *Server) NewAgent(conn net.Conn) network.Agent
  • func (its *Server) Regist(rcvr interface{}) (err error)
  • func (its *Server) Start()

Types

type Client

type Client struct {
	sync.WaitGroup

	OnConnected func()
	OnClose     func()
	// contains filtered or unexported fields
}

Client Client

func NewClient

func NewClient(netAddr string) *Client

NewClient NewClient

func (*Client) Addr

func (its *Client) Addr() string

Addr Addr

func (*Client) Call

func (its *Client) Call(serviceMethod string, args, reply interface{}) error

Call Call

func (*Client) CallNoRet

func (its *Client) CallNoRet(serviceMethod string, args interface{}) error

CallNoRet CallNoRet

func (*Client) Close

func (its *Client) Close()

Close Close

func (*Client) Connect

func (its *Client) Connect(url string) error

Connect Connect

func (*Client) NetAddr

func (its *Client) NetAddr() string

NetAddr NetAddr

type IServer

type IServer interface {
	Regist(interface{}) error
	GetAllAPI() []string
	Done()
}

IServer IServer

type Server

type Server struct {
	*rpc.Server

	Gate       *gate.Gate
	Addr       string
	MaxConnNum int
	// contains filtered or unexported fields
}

Server Server

func (*Server) Close

func (its *Server) Close()

Close Close

func (*Server) Done

func (its *Server) Done()

Done Done

func (*Server) GetAllAPI

func (its *Server) GetAllAPI() []string

GetAllAPI GetAllAPI

func (*Server) NewAgent

func (its *Server) NewAgent(conn net.Conn) network.Agent

NewAgent NewAgent

func (*Server) Regist

func (its *Server) Regist(rcvr interface{}) (err error)

Regist Regist

func (*Server) Start

func (its *Server) Start()

Start Start