client

Documentation

Index

• type IdgenRPCCli
  • func NewIdgenRPCCli() (idgenRPCCli *IdgenRPCCli, err error)
  • func (idgenRPCCli *IdgenRPCCli) Next(ctx context.Context, targetUID int64) (res *rpc.Snowflake_Value, err error)
• type ManagerRPCCli
  • func NewManagerRPCCli() (managerRPCCli *ManagerRPCCli, err error)
  • func (managerRPCCli *ManagerRPCCli) SetExceptionMsg(ctx context.Context, sourceUID, targetUID int64, msgID, msg string) (res *rpc.MGExceptionMsgRes, err error)
  • func (managerRPCCli *ManagerRPCCli) SyncMsg(ctx context.Context, uid, currentID, totalID int64) (res *rpc.MGSyncMsgRes, err error)
• type NotifyRPCCli
  • func NewNotifyRPCCli() (notifyRPCCli *NotifyRPCCli, err error)
  • func (notifyRPCCli *NotifyRPCCli) Notify(ctx context.Context, targetUID, totalID int64, accessAddr string) (res *rpc.NFNotifyMsgRes, err error)
• type RegisterRPCCli
  • func NewRegisterRPCCli() (registerRPCCli *RegisterRPCCli, err error)
  • func (registerRPCCli *RegisterRPCCli) Auth(ctx context.Context, uid int64) (res *rpc.RGAuthRes, err error)
  • func (registerRPCCli *RegisterRPCCli) GetUsersByGroupID(ctx context.Context, gid int64) (res *rpc.RGGetUsersByGroupIDRes, err error)
  • func (registerRPCCli *RegisterRPCCli) Login(ctx context.Context, uid int64, token, accessAddr string) (res *rpc.RGLoginRes, err error)
  • func (registerRPCCli *RegisterRPCCli) Online(ctx context.Context, uid int64) (res *rpc.RGOnlineRes, err error)
  • func (registerRPCCli *RegisterRPCCli) Ping(ctx context.Context, uid int64) (res *rpc.RGPingRes, err error)
  • func (registerRPCCli *RegisterRPCCli) RouterAccess(ctx context.Context, uid int64) (res *rpc.RGAccessRes, err error)

Types

type IdgenRPCCli

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

func NewIdgenRPCCli

func NewIdgenRPCCli() (idgenRPCCli *IdgenRPCCli, err error)

func (*IdgenRPCCli) Next

func (idgenRPCCli *IdgenRPCCli) Next(ctx context.Context, targetUID int64) (res *rpc.Snowflake_Value, err error)

type ManagerRPCCli

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

func NewManagerRPCCli

func NewManagerRPCCli() (managerRPCCli *ManagerRPCCli, err error)

func (*ManagerRPCCli) SetExceptionMsg

func (managerRPCCli *ManagerRPCCli) SetExceptionMsg(ctx context.Context, sourceUID, targetUID int64, msgID, msg string) (res *rpc.MGExceptionMsgRes, err error)

func (*ManagerRPCCli) SyncMsg

func (managerRPCCli *ManagerRPCCli) SyncMsg(ctx context.Context, uid, currentID, totalID int64) (res *rpc.MGSyncMsgRes, err error)

type NotifyRPCCli

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

func NewNotifyRPCCli

func NewNotifyRPCCli() (notifyRPCCli *NotifyRPCCli, err error)

func (*NotifyRPCCli) Notify

func (notifyRPCCli *NotifyRPCCli) Notify(ctx context.Context, targetUID, totalID int64, accessAddr string) (res *rpc.NFNotifyMsgRes, err error)

type RegisterRPCCli

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

func NewRegisterRPCCli

func NewRegisterRPCCli() (registerRPCCli *RegisterRPCCli, err error)

func (*RegisterRPCCli) Auth

func (registerRPCCli *RegisterRPCCli) Auth(ctx context.Context, uid int64) (res *rpc.RGAuthRes, err error)

func (*RegisterRPCCli) GetUsersByGroupID

func (registerRPCCli *RegisterRPCCli) GetUsersByGroupID(ctx context.Context, gid int64) (res *rpc.RGGetUsersByGroupIDRes, err error)

func (*RegisterRPCCli) Login

func (registerRPCCli *RegisterRPCCli) Login(ctx context.Context, uid int64, token, accessAddr string) (res *rpc.RGLoginRes, err error)

func (*RegisterRPCCli) Online

func (registerRPCCli *RegisterRPCCli) Online(ctx context.Context, uid int64) (res *rpc.RGOnlineRes, err error)

func (*RegisterRPCCli) Ping

func (registerRPCCli *RegisterRPCCli) Ping(ctx context.Context, uid int64) (res *rpc.RGPingRes, err error)

func (*RegisterRPCCli) RouterAccess

func (registerRPCCli *RegisterRPCCli) RouterAccess(ctx context.Context, uid int64) (res *rpc.RGAccessRes, err error)