rpc

Documentation

Index

• func RPCServerInit(rpcClient *RPCClient)
• type RPCClient
  • func NewRPCClient() (c *RPCClient, err error)
• type RPCServer
  • func (s *RPCServer) Auth(ctx context.Context, in *rpc.RGAuthReq) (res *rpc.RGAuthRes, err error)
  • func (s *RPCServer) CreateGroup(ctx context.Context, in *rpc.RGCreateGroupReq) (res *rpc.RGCreateGroupRes, err error)
  • func (s *RPCServer) GetUsersByGroupID(ctx context.Context, in *rpc.RGGetUsersByGroupIDReq) (res *rpc.RGGetUsersByGroupIDRes, err error)
  • func (s *RPCServer) JoinGroup(ctx context.Context, in *rpc.RGJoinGroupReq) (res *rpc.RGJoinGroupRes, err error)
  • func (s *RPCServer) Login(ctx context.Context, in *rpc.RGLoginReq) (res *rpc.RGLoginRes, err error)
  • func (s *RPCServer) Online(ctx context.Context, in *rpc.RGOnlineReq) (res *rpc.RGOnlineRes, err error)
  • func (s *RPCServer) Ping(ctx context.Context, in *rpc.RGPingReq) (res *rpc.RGPingRes, err error)
  • func (s *RPCServer) QuitGroup(ctx context.Context, in *rpc.RGQuitGroupReq) (res *rpc.RGQuitGroupRes, err error)
  • func (s *RPCServer) Register(ctx context.Context, in *rpc.RGRegisterReq) (res *rpc.RGRegisterRes, err error)
  • func (s *RPCServer) RouterAccess(ctx context.Context, in *rpc.RGAccessReq) (res *rpc.RGAccessRes, err error)

Functions

func RPCServerInit

func RPCServerInit(rpcClient *RPCClient)

Types

type RPCClient

type RPCClient struct {
	Idgen *client.IdgenRPCCli
}

func NewRPCClient

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

type RPCServer

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

func (*RPCServer) Auth

func (s *RPCServer) Auth(ctx context.Context, in *rpc.RGAuthReq) (res *rpc.RGAuthRes, err error)

func (*RPCServer) CreateGroup

func (s *RPCServer) CreateGroup(ctx context.Context, in *rpc.RGCreateGroupReq) (res *rpc.RGCreateGroupRes, err error)

func (*RPCServer) GetUsersByGroupID

func (s *RPCServer) GetUsersByGroupID(ctx context.Context, in *rpc.RGGetUsersByGroupIDReq) (res *rpc.RGGetUsersByGroupIDRes, err error)

func (*RPCServer) JoinGroup

func (s *RPCServer) JoinGroup(ctx context.Context, in *rpc.RGJoinGroupReq) (res *rpc.RGJoinGroupRes, err error)

func (*RPCServer) Login

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

func (*RPCServer) Online

func (s *RPCServer) Online(ctx context.Context, in *rpc.RGOnlineReq) (res *rpc.RGOnlineRes, err error)

func (*RPCServer) Ping

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

func (*RPCServer) QuitGroup

func (s *RPCServer) QuitGroup(ctx context.Context, in *rpc.RGQuitGroupReq) (res *rpc.RGQuitGroupRes, err error)

func (*RPCServer) Register

func (s *RPCServer) Register(ctx context.Context, in *rpc.RGRegisterReq) (res *rpc.RGRegisterRes, err error)

func (*RPCServer) RouterAccess

func (s *RPCServer) RouterAccess(ctx context.Context, in *rpc.RGAccessReq) (res *rpc.RGAccessRes, err error)