rpc

Documentation

Index

• func RPCServerInit(rpcClient *RPCClient)
• type RPCClient
  • func NewRPCClient() (c *RPCClient, err error)
• type RPCServer
  • func (s *RPCServer) AcceptP2PMsgAck(ctx context.Context, in *rpc.AcceptP2PMsgAckReq) (res *rpc.AcceptP2PMsgAckRes, err error)
  • func (s *RPCServer) Login(ctx context.Context, in *rpc.LoginReq) (res *rpc.LoginRes, err error)
  • func (s *RPCServer) Ping(ctx context.Context, in *rpc.PingReq) (res *rpc.PingRes, err error)
  • func (s *RPCServer) SendGroupMsg(ctx context.Context, in *rpc.SendGroupMsgReq) (res *rpc.SendGroupMsgRes, err error)
  • func (s *RPCServer) SendP2PMsg(ctx context.Context, in *rpc.SendP2PMsgReq) (res *rpc.SendP2PMsgRes, err error)
  • func (s *RPCServer) SyncMsg(ctx context.Context, in *rpc.SyncMsgReq) (res *rpc.SyncMsgRes, err error)

Functions

func RPCServerInit

func RPCServerInit(rpcClient *RPCClient)

Types

type RPCClient

type RPCClient struct {
	Register *client.RegisterRPCCli
	Manager  *client.ManagerRPCCli
	Idgen    *client.IdgenRPCCli
	Notify   *client.NotifyRPCCli
}

func NewRPCClient

func NewRPCClient() (c *RPCClient, err error)

type RPCServer

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

func (*RPCServer) AcceptP2PMsgAck

func (s *RPCServer) AcceptP2PMsgAck(ctx context.Context, in *rpc.AcceptP2PMsgAckReq) (res *rpc.AcceptP2PMsgAckRes, err error)

func (*RPCServer) Login

func (s *RPCServer) Login(ctx context.Context, in *rpc.LoginReq) (res *rpc.LoginRes, err error)

func (*RPCServer) Ping

func (s *RPCServer) Ping(ctx context.Context, in *rpc.PingReq) (res *rpc.PingRes, err error)

func (*RPCServer) SendGroupMsg

func (s *RPCServer) SendGroupMsg(ctx context.Context, in *rpc.SendGroupMsgReq) (res *rpc.SendGroupMsgRes, err error)

func (*RPCServer) SendP2PMsg

func (s *RPCServer) SendP2PMsg(ctx context.Context, in *rpc.SendP2PMsgReq) (res *rpc.SendP2PMsgRes, err error)

func (*RPCServer) SyncMsg

func (s *RPCServer) SyncMsg(ctx context.Context, in *rpc.SyncMsgReq) (res *rpc.SyncMsgRes, err error)