onlinemessagerelayservice

Documentation

Index

• type GetUsersOnlineStatusReq
• type GetUsersOnlineStatusResp
• type GetUsersOnlineStatusResp_FailedDetail
• type GetUsersOnlineStatusResp_SuccessDetail
• type GetUsersOnlineStatusResp_SuccessResult
• type KickUserConnsReq
• type KickUserConnsResp
• type OnlineMessageRelayService
  • func GetAllByEtcd(ctx context.Context, etcdConf discov.EtcdConf, msggatewayRpcEtcdKey string) (services []OnlineMessageRelayService, err error)
  • func GetAllByK8s(msggatewayRpcTarget string) (services []OnlineMessageRelayService, err error)
  • func NewOnlineMessageRelayService(cli zrpc.Client) OnlineMessageRelayService
• type OnlinePushMsgReq
• type OnlinePushMsgResp
• type SingleMsgToUser

Types

type GetUsersOnlineStatusReq

type GetUsersOnlineStatusReq = pb.GetUsersOnlineStatusReq

type GetUsersOnlineStatusResp

type GetUsersOnlineStatusResp = pb.GetUsersOnlineStatusResp

type GetUsersOnlineStatusResp_FailedDetail

type GetUsersOnlineStatusResp_FailedDetail = pb.GetUsersOnlineStatusResp_FailedDetail

type GetUsersOnlineStatusResp_SuccessDetail

type GetUsersOnlineStatusResp_SuccessDetail = pb.GetUsersOnlineStatusResp_SuccessDetail

type GetUsersOnlineStatusResp_SuccessResult

type GetUsersOnlineStatusResp_SuccessResult = pb.GetUsersOnlineStatusResp_SuccessResult

type KickUserConnsReq

type KickUserConnsReq = pb.KickUserConnsReq

type KickUserConnsResp

type KickUserConnsResp = pb.KickUserConnsResp

type OnlineMessageRelayService

type OnlineMessageRelayService interface {
	OnlinePushMsg(ctx context.Context, in *OnlinePushMsgReq, opts ...grpc.CallOption) (*OnlinePushMsgResp, error)
	GetUsersOnlineStatus(ctx context.Context, in *GetUsersOnlineStatusReq, opts ...grpc.CallOption) (*GetUsersOnlineStatusResp, error)
	KickUserConns(ctx context.Context, in *KickUserConnsReq, opts ...grpc.CallOption) (*KickUserConnsResp, error)
}

func GetAllByEtcd

func GetAllByEtcd(
	ctx context.Context,
	etcdConf discov.EtcdConf,
	msggatewayRpcEtcdKey string,
) (services []OnlineMessageRelayService, err error)

GetAllByEtcd 获取所有 service @param msggatewayRpcEtcdKey msggateway-rpc 的 etcd key

func GetAllByK8s

func GetAllByK8s(
	msggatewayRpcTarget string,
) (services []OnlineMessageRelayService, err error)

GetAllByK8s k8s里获取所有 service @param msggatewayRpcEtcdKey msggateway-rpc 的 etcd key

func NewOnlineMessageRelayService

func NewOnlineMessageRelayService(cli zrpc.Client) OnlineMessageRelayService

type OnlinePushMsgReq

type OnlinePushMsgReq = pb.OnlinePushMsgReq

type OnlinePushMsgResp

type OnlinePushMsgResp = pb.OnlinePushMsgResp

type SingleMsgToUser

type SingleMsgToUser = pb.SingleMsgToUser