common

package
v0.0.0-...-84fc14a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 3, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterContentSvrServer 

func RegisterContentSvrServer(s *grpc.Server, srv ContentSvrServer)

func RegisterDbSvrServer 

func RegisterDbSvrServer(s *grpc.Server, srv DbSvrServer)

func RegisterFollowSvrServer 

func RegisterFollowSvrServer(s *grpc.Server, srv FollowSvrServer)

func RegisterFollowedSvrServer 

func RegisterFollowedSvrServer(s *grpc.Server, srv FollowedSvrServer)

func RegisterFrontNotifySvrMngServer 

func RegisterFrontNotifySvrMngServer(s *grpc.Server, srv FrontNotifySvrMngServer)

func RegisterFrontNotifySvrServer 

func RegisterFrontNotifySvrServer(s *grpc.Server, srv FrontNotifySvrServer)

func RegisterFrontSvrMngServer 

func RegisterFrontSvrMngServer(s *grpc.Server, srv FrontSvrMngServer)

func RegisterFrontSvrServer 

func RegisterFrontSvrServer(s *grpc.Server, srv FrontSvrServer)

func RegisterMsgIdGeneratorServer 

func RegisterMsgIdGeneratorServer(s *grpc.Server, srv MsgIdGeneratorServer)

func RegisterPostSvrServer 

func RegisterPostSvrServer(s *grpc.Server, srv PostSvrServer)

func RegisterPullSvrServer 

func RegisterPullSvrServer(s *grpc.Server, srv PullSvrServer)

func RegisterPushSvrServer 

func RegisterPushSvrServer(s *grpc.Server, srv PushSvrServer)

func RegisterRelationChangeSvrServer 

func RegisterRelationChangeSvrServer(s *grpc.Server, srv RelationChangeSvrServer)

func RegisterUserMsgIdSvrMngServer 

func RegisterUserMsgIdSvrMngServer(s *grpc.Server, srv UserMsgIdSvrMngServer)

func RegisterUserMsgIdSvrServer 

func RegisterUserMsgIdSvrServer(s *grpc.Server, srv UserMsgIdSvrServer)

Types

type CClientAuthInfo 

type CClientAuthInfo struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

用户信息。现在没有认证流程，所以未认证相关信息

func (*CClientAuthInfo) Descriptor 

func (*CClientAuthInfo) Descriptor() ([]byte, []int)

func (*CClientAuthInfo) GetUserId 

func (m *CClientAuthInfo) GetUserId() int64

func (*CClientAuthInfo) ProtoMessage 

func (*CClientAuthInfo) ProtoMessage()

func (*CClientAuthInfo) Reset 

func (m *CClientAuthInfo) Reset()

func (*CClientAuthInfo) String 

func (m *CClientAuthInfo) String() string

func (*CClientAuthInfo) XXX_DiscardUnknown 

func (m *CClientAuthInfo) XXX_DiscardUnknown()

func (*CClientAuthInfo) XXX_Marshal 

func (m *CClientAuthInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CClientAuthInfo) XXX_Merge 

func (m *CClientAuthInfo) XXX_Merge(src proto.Message)

func (*CClientAuthInfo) XXX_Size 

func (m *CClientAuthInfo) XXX_Size() int

func (*CClientAuthInfo) XXX_Unmarshal 

func (m *CClientAuthInfo) XXX_Unmarshal(b []byte) error

type CCreateNotifyStreamReq 

type CCreateNotifyStreamReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CCreateNotifyStreamReq) Descriptor 

func (*CCreateNotifyStreamReq) Descriptor() ([]byte, []int)

func (*CCreateNotifyStreamReq) GetUserId 

func (m *CCreateNotifyStreamReq) GetUserId() int64

func (*CCreateNotifyStreamReq) ProtoMessage 

func (*CCreateNotifyStreamReq) ProtoMessage()

func (*CCreateNotifyStreamReq) Reset 

func (m *CCreateNotifyStreamReq) Reset()

func (*CCreateNotifyStreamReq) String 

func (m *CCreateNotifyStreamReq) String() string

func (*CCreateNotifyStreamReq) XXX_DiscardUnknown 

func (m *CCreateNotifyStreamReq) XXX_DiscardUnknown()

func (*CCreateNotifyStreamReq) XXX_Marshal 

func (m *CCreateNotifyStreamReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CCreateNotifyStreamReq) XXX_Merge 

func (m *CCreateNotifyStreamReq) XXX_Merge(src proto.Message)

func (*CCreateNotifyStreamReq) XXX_Size 

func (m *CCreateNotifyStreamReq) XXX_Size() int

func (*CCreateNotifyStreamReq) XXX_Unmarshal 

func (m *CCreateNotifyStreamReq) XXX_Unmarshal(b []byte) error

type CFollowReq 

type CFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FollowedUserId       int64    `protobuf:"varint,2,opt,name=FollowedUserId,proto3" json:"FollowedUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

关注

func (*CFollowReq) Descriptor 

func (*CFollowReq) Descriptor() ([]byte, []int)

func (*CFollowReq) GetFollowedUserId 

func (m *CFollowReq) GetFollowedUserId() int64

func (*CFollowReq) GetUserId 

func (m *CFollowReq) GetUserId() int64

func (*CFollowReq) ProtoMessage 

func (*CFollowReq) ProtoMessage()

func (*CFollowReq) Reset 

func (m *CFollowReq) Reset()

func (*CFollowReq) String 

func (m *CFollowReq) String() string

func (*CFollowReq) XXX_DiscardUnknown 

func (m *CFollowReq) XXX_DiscardUnknown()

func (*CFollowReq) XXX_Marshal 

func (m *CFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CFollowReq) XXX_Merge 

func (m *CFollowReq) XXX_Merge(src proto.Message)

func (*CFollowReq) XXX_Size 

func (m *CFollowReq) XXX_Size() int

func (*CFollowReq) XXX_Unmarshal 

func (m *CFollowReq) XXX_Unmarshal(b []byte) error

type CFollowRsp 

type CFollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CFollowRsp) Descriptor 

func (*CFollowRsp) Descriptor() ([]byte, []int)

func (*CFollowRsp) ProtoMessage 

func (*CFollowRsp) ProtoMessage()

func (*CFollowRsp) Reset 

func (m *CFollowRsp) Reset()

func (*CFollowRsp) String 

func (m *CFollowRsp) String() string

func (*CFollowRsp) XXX_DiscardUnknown 

func (m *CFollowRsp) XXX_DiscardUnknown()

func (*CFollowRsp) XXX_Marshal 

func (m *CFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CFollowRsp) XXX_Merge 

func (m *CFollowRsp) XXX_Merge(src proto.Message)

func (*CFollowRsp) XXX_Size 

func (m *CFollowRsp) XXX_Size() int

func (*CFollowRsp) XXX_Unmarshal 

func (m *CFollowRsp) XXX_Unmarshal(b []byte) error

type CFrontNotifySvrAddr 

type CFrontNotifySvrAddr struct {
	//
	Addr                 string   `protobuf:"bytes,1,opt,name=Addr,proto3" json:"Addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

本次归宿frontNotifySvr地址"ip:port"

func (*CFrontNotifySvrAddr) Descriptor 

func (*CFrontNotifySvrAddr) Descriptor() ([]byte, []int)

func (*CFrontNotifySvrAddr) GetAddr 

func (m *CFrontNotifySvrAddr) GetAddr() string

func (*CFrontNotifySvrAddr) ProtoMessage 

func (*CFrontNotifySvrAddr) ProtoMessage()

func (*CFrontNotifySvrAddr) Reset 

func (m *CFrontNotifySvrAddr) Reset()

func (*CFrontNotifySvrAddr) String 

func (m *CFrontNotifySvrAddr) String() string

func (*CFrontNotifySvrAddr) XXX_DiscardUnknown 

func (m *CFrontNotifySvrAddr) XXX_DiscardUnknown()

func (*CFrontNotifySvrAddr) XXX_Marshal 

func (m *CFrontNotifySvrAddr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CFrontNotifySvrAddr) XXX_Merge 

func (m *CFrontNotifySvrAddr) XXX_Merge(src proto.Message)

func (*CFrontNotifySvrAddr) XXX_Size 

func (m *CFrontNotifySvrAddr) XXX_Size() int

func (*CFrontNotifySvrAddr) XXX_Unmarshal 

func (m *CFrontNotifySvrAddr) XXX_Unmarshal(b []byte) error

type CFrontSvrAddr 

type CFrontSvrAddr struct {
	//
	Addr                 string   `protobuf:"bytes,1,opt,name=Addr,proto3" json:"Addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

本次归宿frontSvr地址"ip:port"

func (*CFrontSvrAddr) Descriptor 

func (*CFrontSvrAddr) Descriptor() ([]byte, []int)

func (*CFrontSvrAddr) GetAddr 

func (m *CFrontSvrAddr) GetAddr() string

func (*CFrontSvrAddr) ProtoMessage 

func (*CFrontSvrAddr) ProtoMessage()

func (*CFrontSvrAddr) Reset 

func (m *CFrontSvrAddr) Reset()

func (*CFrontSvrAddr) String 

func (m *CFrontSvrAddr) String() string

func (*CFrontSvrAddr) XXX_DiscardUnknown 

func (m *CFrontSvrAddr) XXX_DiscardUnknown()

func (*CFrontSvrAddr) XXX_Marshal 

func (m *CFrontSvrAddr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CFrontSvrAddr) XXX_Merge 

func (m *CFrontSvrAddr) XXX_Merge(src proto.Message)

func (*CFrontSvrAddr) XXX_Size 

func (m *CFrontSvrAddr) XXX_Size() int

func (*CFrontSvrAddr) XXX_Unmarshal 

func (m *CFrontSvrAddr) XXX_Unmarshal(b []byte) error

type CHeartBeatReq 

type CHeartBeatReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CHeartBeatReq) Descriptor 

func (*CHeartBeatReq) Descriptor() ([]byte, []int)

func (*CHeartBeatReq) GetUserId 

func (m *CHeartBeatReq) GetUserId() int64

func (*CHeartBeatReq) ProtoMessage 

func (*CHeartBeatReq) ProtoMessage()

func (*CHeartBeatReq) Reset 

func (m *CHeartBeatReq) Reset()

func (*CHeartBeatReq) String 

func (m *CHeartBeatReq) String() string

func (*CHeartBeatReq) XXX_DiscardUnknown 

func (m *CHeartBeatReq) XXX_DiscardUnknown()

func (*CHeartBeatReq) XXX_Marshal 

func (m *CHeartBeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CHeartBeatReq) XXX_Merge 

func (m *CHeartBeatReq) XXX_Merge(src proto.Message)

func (*CHeartBeatReq) XXX_Size 

func (m *CHeartBeatReq) XXX_Size() int

func (*CHeartBeatReq) XXX_Unmarshal 

func (m *CHeartBeatReq) XXX_Unmarshal(b []byte) error

type CHeartBeatRsp 

type CHeartBeatRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CHeartBeatRsp) Descriptor 

func (*CHeartBeatRsp) Descriptor() ([]byte, []int)

func (*CHeartBeatRsp) ProtoMessage 

func (*CHeartBeatRsp) ProtoMessage()

func (*CHeartBeatRsp) Reset 

func (m *CHeartBeatRsp) Reset()

func (*CHeartBeatRsp) String 

func (m *CHeartBeatRsp) String() string

func (*CHeartBeatRsp) XXX_DiscardUnknown 

func (m *CHeartBeatRsp) XXX_DiscardUnknown()

func (*CHeartBeatRsp) XXX_Marshal 

func (m *CHeartBeatRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CHeartBeatRsp) XXX_Merge 

func (m *CHeartBeatRsp) XXX_Merge(src proto.Message)

func (*CHeartBeatRsp) XXX_Size 

func (m *CHeartBeatRsp) XXX_Size() int

func (*CHeartBeatRsp) XXX_Unmarshal 

func (m *CHeartBeatRsp) XXX_Unmarshal(b []byte) error

type CLikeReq 

type CLikeReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	MsgId                int64    `protobuf:"varint,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

点赞

func (*CLikeReq) Descriptor 

func (*CLikeReq) Descriptor() ([]byte, []int)

func (*CLikeReq) GetMsgId 

func (m *CLikeReq) GetMsgId() int64

func (*CLikeReq) GetUserId 

func (m *CLikeReq) GetUserId() int64

func (*CLikeReq) ProtoMessage 

func (*CLikeReq) ProtoMessage()

func (*CLikeReq) Reset 

func (m *CLikeReq) Reset()

func (*CLikeReq) String 

func (m *CLikeReq) String() string

func (*CLikeReq) XXX_DiscardUnknown 

func (m *CLikeReq) XXX_DiscardUnknown()

func (*CLikeReq) XXX_Marshal 

func (m *CLikeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CLikeReq) XXX_Merge 

func (m *CLikeReq) XXX_Merge(src proto.Message)

func (*CLikeReq) XXX_Size 

func (m *CLikeReq) XXX_Size() int

func (*CLikeReq) XXX_Unmarshal 

func (m *CLikeReq) XXX_Unmarshal(b []byte) error

type CLikeRsp 

type CLikeRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CLikeRsp) Descriptor 

func (*CLikeRsp) Descriptor() ([]byte, []int)

func (*CLikeRsp) ProtoMessage 

func (*CLikeRsp) ProtoMessage()

func (*CLikeRsp) Reset 

func (m *CLikeRsp) Reset()

func (*CLikeRsp) String 

func (m *CLikeRsp) String() string

func (*CLikeRsp) XXX_DiscardUnknown 

func (m *CLikeRsp) XXX_DiscardUnknown()

func (*CLikeRsp) XXX_Marshal 

func (m *CLikeRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CLikeRsp) XXX_Merge 

func (m *CLikeRsp) XXX_Merge(src proto.Message)

func (*CLikeRsp) XXX_Size 

func (m *CLikeRsp) XXX_Size() int

func (*CLikeRsp) XXX_Unmarshal 

func (m *CLikeRsp) XXX_Unmarshal(b []byte) error

type CNotify 

type CNotify struct {
	NotifyUserId         int64    `protobuf:"varint,1,opt,name=NotifyUserId,proto3" json:"NotifyUserId,omitempty"`
	PostUserId           int64    `protobuf:"varint,2,opt,name=PostUserId,proto3" json:"PostUserId,omitempty"`
	MsgId                int64    `protobuf:"varint,3,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CNotify) Descriptor 

func (*CNotify) Descriptor() ([]byte, []int)

func (*CNotify) GetMsgId 

func (m *CNotify) GetMsgId() int64

func (*CNotify) GetNotifyUserId 

func (m *CNotify) GetNotifyUserId() int64

func (*CNotify) GetPostUserId 

func (m *CNotify) GetPostUserId() int64

func (*CNotify) ProtoMessage 

func (*CNotify) ProtoMessage()

func (*CNotify) Reset 

func (m *CNotify) Reset()

func (*CNotify) String 

func (m *CNotify) String() string

func (*CNotify) XXX_DiscardUnknown 

func (m *CNotify) XXX_DiscardUnknown()

func (*CNotify) XXX_Marshal 

func (m *CNotify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CNotify) XXX_Merge 

func (m *CNotify) XXX_Merge(src proto.Message)

func (*CNotify) XXX_Size 

func (m *CNotify) XXX_Size() int

func (*CNotify) XXX_Unmarshal 

func (m *CNotify) XXX_Unmarshal(b []byte) error

type COfflineReq 

type COfflineReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*COfflineReq) Descriptor 

func (*COfflineReq) Descriptor() ([]byte, []int)

func (*COfflineReq) GetUserId 

func (m *COfflineReq) GetUserId() int64

func (*COfflineReq) ProtoMessage 

func (*COfflineReq) ProtoMessage()

func (*COfflineReq) Reset 

func (m *COfflineReq) Reset()

func (*COfflineReq) String 

func (m *COfflineReq) String() string

func (*COfflineReq) XXX_DiscardUnknown 

func (m *COfflineReq) XXX_DiscardUnknown()

func (*COfflineReq) XXX_Marshal 

func (m *COfflineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*COfflineReq) XXX_Merge 

func (m *COfflineReq) XXX_Merge(src proto.Message)

func (*COfflineReq) XXX_Size 

func (m *COfflineReq) XXX_Size() int

func (*COfflineReq) XXX_Unmarshal 

func (m *COfflineReq) XXX_Unmarshal(b []byte) error

type COfflineRsp 

type COfflineRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*COfflineRsp) Descriptor 

func (*COfflineRsp) Descriptor() ([]byte, []int)

func (*COfflineRsp) ProtoMessage 

func (*COfflineRsp) ProtoMessage()

func (*COfflineRsp) Reset 

func (m *COfflineRsp) Reset()

func (*COfflineRsp) String 

func (m *COfflineRsp) String() string

func (*COfflineRsp) XXX_DiscardUnknown 

func (m *COfflineRsp) XXX_DiscardUnknown()

func (*COfflineRsp) XXX_Marshal 

func (m *COfflineRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*COfflineRsp) XXX_Merge 

func (m *COfflineRsp) XXX_Merge(src proto.Message)

func (*COfflineRsp) XXX_Size 

func (m *COfflineRsp) XXX_Size() int

func (*COfflineRsp) XXX_Unmarshal 

func (m *COfflineRsp) XXX_Unmarshal(b []byte) error

type COnlineReq 

type COnlineReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*COnlineReq) Descriptor 

func (*COnlineReq) Descriptor() ([]byte, []int)

func (*COnlineReq) GetUserId 

func (m *COnlineReq) GetUserId() int64

func (*COnlineReq) ProtoMessage 

func (*COnlineReq) ProtoMessage()

func (*COnlineReq) Reset 

func (m *COnlineReq) Reset()

func (*COnlineReq) String 

func (m *COnlineReq) String() string

func (*COnlineReq) XXX_DiscardUnknown 

func (m *COnlineReq) XXX_DiscardUnknown()

func (*COnlineReq) XXX_Marshal 

func (m *COnlineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*COnlineReq) XXX_Merge 

func (m *COnlineReq) XXX_Merge(src proto.Message)

func (*COnlineReq) XXX_Size 

func (m *COnlineReq) XXX_Size() int

func (*COnlineReq) XXX_Unmarshal 

func (m *COnlineReq) XXX_Unmarshal(b []byte) error

type COnlineRsp 

type COnlineRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*COnlineRsp) Descriptor 

func (*COnlineRsp) Descriptor() ([]byte, []int)

func (*COnlineRsp) ProtoMessage 

func (*COnlineRsp) ProtoMessage()

func (*COnlineRsp) Reset 

func (m *COnlineRsp) Reset()

func (*COnlineRsp) String 

func (m *COnlineRsp) String() string

func (*COnlineRsp) XXX_DiscardUnknown 

func (m *COnlineRsp) XXX_DiscardUnknown()

func (*COnlineRsp) XXX_Marshal 

func (m *COnlineRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*COnlineRsp) XXX_Merge 

func (m *COnlineRsp) XXX_Merge(src proto.Message)

func (*COnlineRsp) XXX_Size 

func (m *COnlineRsp) XXX_Size() int

func (*COnlineRsp) XXX_Unmarshal 

func (m *COnlineRsp) XXX_Unmarshal(b []byte) error

type CPostReq 

type CPostReq struct {
	UserId int64 `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	//
	Msg                  *MsgData `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

发布

func (*CPostReq) Descriptor 

func (*CPostReq) Descriptor() ([]byte, []int)

func (*CPostReq) GetMsg 

func (m *CPostReq) GetMsg() *MsgData

func (*CPostReq) GetUserId 

func (m *CPostReq) GetUserId() int64

func (*CPostReq) ProtoMessage 

func (*CPostReq) ProtoMessage()

func (*CPostReq) Reset 

func (m *CPostReq) Reset()

func (*CPostReq) String 

func (m *CPostReq) String() string

func (*CPostReq) XXX_DiscardUnknown 

func (m *CPostReq) XXX_DiscardUnknown()

func (*CPostReq) XXX_Marshal 

func (m *CPostReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CPostReq) XXX_Merge 

func (m *CPostReq) XXX_Merge(src proto.Message)

func (*CPostReq) XXX_Size 

func (m *CPostReq) XXX_Size() int

func (*CPostReq) XXX_Unmarshal 

func (m *CPostReq) XXX_Unmarshal(b []byte) error

type CPostRsp 

type CPostRsp struct {
	MsgId                int64    `protobuf:"varint,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CPostRsp) Descriptor 

func (*CPostRsp) Descriptor() ([]byte, []int)

func (*CPostRsp) GetMsgId 

func (m *CPostRsp) GetMsgId() int64

func (*CPostRsp) ProtoMessage 

func (*CPostRsp) ProtoMessage()

func (*CPostRsp) Reset 

func (m *CPostRsp) Reset()

func (*CPostRsp) String 

func (m *CPostRsp) String() string

func (*CPostRsp) XXX_DiscardUnknown 

func (m *CPostRsp) XXX_DiscardUnknown()

func (*CPostRsp) XXX_Marshal 

func (m *CPostRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CPostRsp) XXX_Merge 

func (m *CPostRsp) XXX_Merge(src proto.Message)

func (*CPostRsp) XXX_Size 

func (m *CPostRsp) XXX_Size() int

func (*CPostRsp) XXX_Unmarshal 

func (m *CPostRsp) XXX_Unmarshal(b []byte) error

type CPullReq 

type CPullReq struct {
	UserId int64 `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	//上次获取到的最后一条微博的msgId，本次获取LastMsgId之前的。为0表示获取最新
	LastMsgId            int64    `protobuf:"varint,2,opt,name=LastMsgId,proto3" json:"LastMsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

拉取请求

func (*CPullReq) Descriptor 

func (*CPullReq) Descriptor() ([]byte, []int)

func (*CPullReq) GetLastMsgId 

func (m *CPullReq) GetLastMsgId() int64

func (*CPullReq) GetUserId 

func (m *CPullReq) GetUserId() int64

func (*CPullReq) ProtoMessage 

func (*CPullReq) ProtoMessage()

func (*CPullReq) Reset 

func (m *CPullReq) Reset()

func (*CPullReq) String 

func (m *CPullReq) String() string

func (*CPullReq) XXX_DiscardUnknown 

func (m *CPullReq) XXX_DiscardUnknown()

func (*CPullReq) XXX_Marshal 

func (m *CPullReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CPullReq) XXX_Merge 

func (m *CPullReq) XXX_Merge(src proto.Message)

func (*CPullReq) XXX_Size 

func (m *CPullReq) XXX_Size() int

func (*CPullReq) XXX_Unmarshal 

func (m *CPullReq) XXX_Unmarshal(b []byte) error

type CPullRsp 

type CPullRsp struct {
	MsgArr               []*MsgData `protobuf:"bytes,1,rep,name=MsgArr,proto3" json:"MsgArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CPullRsp) Descriptor 

func (*CPullRsp) Descriptor() ([]byte, []int)

func (*CPullRsp) GetMsgArr 

func (m *CPullRsp) GetMsgArr() []*MsgData

func (*CPullRsp) ProtoMessage 

func (*CPullRsp) ProtoMessage()

func (*CPullRsp) Reset 

func (m *CPullRsp) Reset()

func (*CPullRsp) String 

func (m *CPullRsp) String() string

func (*CPullRsp) XXX_DiscardUnknown 

func (m *CPullRsp) XXX_DiscardUnknown()

func (*CPullRsp) XXX_Marshal 

func (m *CPullRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CPullRsp) XXX_Merge 

func (m *CPullRsp) XXX_Merge(src proto.Message)

func (*CPullRsp) XXX_Size 

func (m *CPullRsp) XXX_Size() int

func (*CPullRsp) XXX_Unmarshal 

func (m *CPullRsp) XXX_Unmarshal(b []byte) error

type CUnFollowReq 

type CUnFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	UnFollowedUserId     int64    `protobuf:"varint,2,opt,name=UnFollowedUserId,proto3" json:"UnFollowedUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

取关

func (*CUnFollowReq) Descriptor 

func (*CUnFollowReq) Descriptor() ([]byte, []int)

func (*CUnFollowReq) GetUnFollowedUserId 

func (m *CUnFollowReq) GetUnFollowedUserId() int64

func (*CUnFollowReq) GetUserId 

func (m *CUnFollowReq) GetUserId() int64

func (*CUnFollowReq) ProtoMessage 

func (*CUnFollowReq) ProtoMessage()

func (*CUnFollowReq) Reset 

func (m *CUnFollowReq) Reset()

func (*CUnFollowReq) String 

func (m *CUnFollowReq) String() string

func (*CUnFollowReq) XXX_DiscardUnknown 

func (m *CUnFollowReq) XXX_DiscardUnknown()

func (*CUnFollowReq) XXX_Marshal 

func (m *CUnFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CUnFollowReq) XXX_Merge 

func (m *CUnFollowReq) XXX_Merge(src proto.Message)

func (*CUnFollowReq) XXX_Size 

func (m *CUnFollowReq) XXX_Size() int

func (*CUnFollowReq) XXX_Unmarshal 

func (m *CUnFollowReq) XXX_Unmarshal(b []byte) error

type CUnFollowRsp 

type CUnFollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CUnFollowRsp) Descriptor 

func (*CUnFollowRsp) Descriptor() ([]byte, []int)

func (*CUnFollowRsp) ProtoMessage 

func (*CUnFollowRsp) ProtoMessage()

func (*CUnFollowRsp) Reset 

func (m *CUnFollowRsp) Reset()

func (*CUnFollowRsp) String 

func (m *CUnFollowRsp) String() string

func (*CUnFollowRsp) XXX_DiscardUnknown 

func (m *CUnFollowRsp) XXX_DiscardUnknown()

func (*CUnFollowRsp) XXX_Marshal 

func (m *CUnFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CUnFollowRsp) XXX_Merge 

func (m *CUnFollowRsp) XXX_Merge(src proto.Message)

func (*CUnFollowRsp) XXX_Size 

func (m *CUnFollowRsp) XXX_Size() int

func (*CUnFollowRsp) XXX_Unmarshal 

func (m *CUnFollowRsp) XXX_Unmarshal(b []byte) error

type CheckAvailReq 

type CheckAvailReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckAvailReq) Descriptor 

func (*CheckAvailReq) Descriptor() ([]byte, []int)

func (*CheckAvailReq) ProtoMessage 

func (*CheckAvailReq) ProtoMessage()

func (*CheckAvailReq) Reset 

func (m *CheckAvailReq) Reset()

func (*CheckAvailReq) String 

func (m *CheckAvailReq) String() string

func (*CheckAvailReq) XXX_DiscardUnknown 

func (m *CheckAvailReq) XXX_DiscardUnknown()

func (*CheckAvailReq) XXX_Marshal 

func (m *CheckAvailReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckAvailReq) XXX_Merge 

func (m *CheckAvailReq) XXX_Merge(src proto.Message)

func (*CheckAvailReq) XXX_Size 

func (m *CheckAvailReq) XXX_Size() int

func (*CheckAvailReq) XXX_Unmarshal 

func (m *CheckAvailReq) XXX_Unmarshal(b []byte) error

type CheckAvailRsp 

type CheckAvailRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckAvailRsp) Descriptor 

func (*CheckAvailRsp) Descriptor() ([]byte, []int)

func (*CheckAvailRsp) ProtoMessage 

func (*CheckAvailRsp) ProtoMessage()

func (*CheckAvailRsp) Reset 

func (m *CheckAvailRsp) Reset()

func (*CheckAvailRsp) String 

func (m *CheckAvailRsp) String() string

func (*CheckAvailRsp) XXX_DiscardUnknown 

func (m *CheckAvailRsp) XXX_DiscardUnknown()

func (*CheckAvailRsp) XXX_Marshal 

func (m *CheckAvailRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckAvailRsp) XXX_Merge 

func (m *CheckAvailRsp) XXX_Merge(src proto.Message)

func (*CheckAvailRsp) XXX_Size 

func (m *CheckAvailRsp) XXX_Size() int

func (*CheckAvailRsp) XXX_Unmarshal 

func (m *CheckAvailRsp) XXX_Unmarshal(b []byte) error

type ContentSvrClient 

type ContentSvrClient interface {
	PullMsg(ctx context.Context, in *PullMsgContentReq, opts ...grpc.CallOption) (*PullMsgContentRsp, error)
	PostMsg(ctx context.Context, in *PostMsgContentReq, opts ...grpc.CallOption) (*PostMsgContentRsp, error)
	DeleteMsg(ctx context.Context, in *DeleteMsgReq, opts ...grpc.CallOption) (*DeleteMsgRsp, error)
}

ContentSvrClient is the client API for ContentSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewContentSvrClient 

func NewContentSvrClient(cc *grpc.ClientConn) ContentSvrClient

type ContentSvrServer 

type ContentSvrServer interface {
	PullMsg(context.Context, *PullMsgContentReq) (*PullMsgContentRsp, error)
	PostMsg(context.Context, *PostMsgContentReq) (*PostMsgContentRsp, error)
	DeleteMsg(context.Context, *DeleteMsgReq) (*DeleteMsgRsp, error)
}

ContentSvrServer is the server API for ContentSvr service.

type CreateNotifyStreamReq 

type CreateNotifyStreamReq struct {
	FrontNotifySvrId     int32    `protobuf:"varint,1,opt,name=FrontNotifySvrId,proto3" json:"FrontNotifySvrId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateNotifyStreamReq) Descriptor 

func (*CreateNotifyStreamReq) Descriptor() ([]byte, []int)

func (*CreateNotifyStreamReq) GetFrontNotifySvrId 

func (m *CreateNotifyStreamReq) GetFrontNotifySvrId() int32

func (*CreateNotifyStreamReq) ProtoMessage 

func (*CreateNotifyStreamReq) ProtoMessage()

func (*CreateNotifyStreamReq) Reset 

func (m *CreateNotifyStreamReq) Reset()

func (*CreateNotifyStreamReq) String 

func (m *CreateNotifyStreamReq) String() string

func (*CreateNotifyStreamReq) XXX_DiscardUnknown 

func (m *CreateNotifyStreamReq) XXX_DiscardUnknown()

func (*CreateNotifyStreamReq) XXX_Marshal 

func (m *CreateNotifyStreamReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateNotifyStreamReq) XXX_Merge 

func (m *CreateNotifyStreamReq) XXX_Merge(src proto.Message)

func (*CreateNotifyStreamReq) XXX_Size 

func (m *CreateNotifyStreamReq) XXX_Size() int

func (*CreateNotifyStreamReq) XXX_Unmarshal 

func (m *CreateNotifyStreamReq) XXX_Unmarshal(b []byte) error

type DBFollowReq 

type DBFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FollowId             int64    `protobuf:"varint,2,opt,name=FollowId,proto3" json:"FollowId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBFollowReq) Descriptor 

func (*DBFollowReq) Descriptor() ([]byte, []int)

func (*DBFollowReq) GetFollowId 

func (m *DBFollowReq) GetFollowId() int64

func (*DBFollowReq) GetUserId 

func (m *DBFollowReq) GetUserId() int64

func (*DBFollowReq) ProtoMessage 

func (*DBFollowReq) ProtoMessage()

func (*DBFollowReq) Reset 

func (m *DBFollowReq) Reset()

func (*DBFollowReq) String 

func (m *DBFollowReq) String() string

func (*DBFollowReq) XXX_DiscardUnknown 

func (m *DBFollowReq) XXX_DiscardUnknown()

func (*DBFollowReq) XXX_Marshal 

func (m *DBFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBFollowReq) XXX_Merge 

func (m *DBFollowReq) XXX_Merge(src proto.Message)

func (*DBFollowReq) XXX_Size 

func (m *DBFollowReq) XXX_Size() int

func (*DBFollowReq) XXX_Unmarshal 

func (m *DBFollowReq) XXX_Unmarshal(b []byte) error

type DBFollowRsp 

type DBFollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBFollowRsp) Descriptor 

func (*DBFollowRsp) Descriptor() ([]byte, []int)

func (*DBFollowRsp) ProtoMessage 

func (*DBFollowRsp) ProtoMessage()

func (*DBFollowRsp) Reset 

func (m *DBFollowRsp) Reset()

func (*DBFollowRsp) String 

func (m *DBFollowRsp) String() string

func (*DBFollowRsp) XXX_DiscardUnknown 

func (m *DBFollowRsp) XXX_DiscardUnknown()

func (*DBFollowRsp) XXX_Marshal 

func (m *DBFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBFollowRsp) XXX_Merge 

func (m *DBFollowRsp) XXX_Merge(src proto.Message)

func (*DBFollowRsp) XXX_Size 

func (m *DBFollowRsp) XXX_Size() int

func (*DBFollowRsp) XXX_Unmarshal 

func (m *DBFollowRsp) XXX_Unmarshal(b []byte) error

type DBPostReq 

type DBPostReq struct {
	Content              *MsgData `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBPostReq) Descriptor 

func (*DBPostReq) Descriptor() ([]byte, []int)

func (*DBPostReq) GetContent 

func (m *DBPostReq) GetContent() *MsgData

func (*DBPostReq) ProtoMessage 

func (*DBPostReq) ProtoMessage()

func (*DBPostReq) Reset 

func (m *DBPostReq) Reset()

func (*DBPostReq) String 

func (m *DBPostReq) String() string

func (*DBPostReq) XXX_DiscardUnknown 

func (m *DBPostReq) XXX_DiscardUnknown()

func (*DBPostReq) XXX_Marshal 

func (m *DBPostReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBPostReq) XXX_Merge 

func (m *DBPostReq) XXX_Merge(src proto.Message)

func (*DBPostReq) XXX_Size 

func (m *DBPostReq) XXX_Size() int

func (*DBPostReq) XXX_Unmarshal 

func (m *DBPostReq) XXX_Unmarshal(b []byte) error

type DBPostRsp 

type DBPostRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBPostRsp) Descriptor 

func (*DBPostRsp) Descriptor() ([]byte, []int)

func (*DBPostRsp) ProtoMessage 

func (*DBPostRsp) ProtoMessage()

func (*DBPostRsp) Reset 

func (m *DBPostRsp) Reset()

func (*DBPostRsp) String 

func (m *DBPostRsp) String() string

func (*DBPostRsp) XXX_DiscardUnknown 

func (m *DBPostRsp) XXX_DiscardUnknown()

func (*DBPostRsp) XXX_Marshal 

func (m *DBPostRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBPostRsp) XXX_Merge 

func (m *DBPostRsp) XXX_Merge(src proto.Message)

func (*DBPostRsp) XXX_Size 

func (m *DBPostRsp) XXX_Size() int

func (*DBPostRsp) XXX_Unmarshal 

func (m *DBPostRsp) XXX_Unmarshal(b []byte) error

type DBQueryFollowReq 

type DBQueryFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryFollowReq) Descriptor 

func (*DBQueryFollowReq) Descriptor() ([]byte, []int)

func (*DBQueryFollowReq) GetUserId 

func (m *DBQueryFollowReq) GetUserId() int64

func (*DBQueryFollowReq) ProtoMessage 

func (*DBQueryFollowReq) ProtoMessage()

func (*DBQueryFollowReq) Reset 

func (m *DBQueryFollowReq) Reset()

func (*DBQueryFollowReq) String 

func (m *DBQueryFollowReq) String() string

func (*DBQueryFollowReq) XXX_DiscardUnknown 

func (m *DBQueryFollowReq) XXX_DiscardUnknown()

func (*DBQueryFollowReq) XXX_Marshal 

func (m *DBQueryFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryFollowReq) XXX_Merge 

func (m *DBQueryFollowReq) XXX_Merge(src proto.Message)

func (*DBQueryFollowReq) XXX_Size 

func (m *DBQueryFollowReq) XXX_Size() int

func (*DBQueryFollowReq) XXX_Unmarshal 

func (m *DBQueryFollowReq) XXX_Unmarshal(b []byte) error

type DBQueryFollowRsp 

type DBQueryFollowRsp struct {
	FollowIdArr          []int64  `protobuf:"varint,1,rep,packed,name=FollowIdArr,proto3" json:"FollowIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryFollowRsp) Descriptor 

func (*DBQueryFollowRsp) Descriptor() ([]byte, []int)

func (*DBQueryFollowRsp) GetFollowIdArr 

func (m *DBQueryFollowRsp) GetFollowIdArr() []int64

func (*DBQueryFollowRsp) ProtoMessage 

func (*DBQueryFollowRsp) ProtoMessage()

func (*DBQueryFollowRsp) Reset 

func (m *DBQueryFollowRsp) Reset()

func (*DBQueryFollowRsp) String 

func (m *DBQueryFollowRsp) String() string

func (*DBQueryFollowRsp) XXX_DiscardUnknown 

func (m *DBQueryFollowRsp) XXX_DiscardUnknown()

func (*DBQueryFollowRsp) XXX_Marshal 

func (m *DBQueryFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryFollowRsp) XXX_Merge 

func (m *DBQueryFollowRsp) XXX_Merge(src proto.Message)

func (*DBQueryFollowRsp) XXX_Size 

func (m *DBQueryFollowRsp) XXX_Size() int

func (*DBQueryFollowRsp) XXX_Unmarshal 

func (m *DBQueryFollowRsp) XXX_Unmarshal(b []byte) error

type DBQueryFollowerReq 

type DBQueryFollowerReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryFollowerReq) Descriptor 

func (*DBQueryFollowerReq) Descriptor() ([]byte, []int)

func (*DBQueryFollowerReq) GetUserId 

func (m *DBQueryFollowerReq) GetUserId() int64

func (*DBQueryFollowerReq) ProtoMessage 

func (*DBQueryFollowerReq) ProtoMessage()

func (*DBQueryFollowerReq) Reset 

func (m *DBQueryFollowerReq) Reset()

func (*DBQueryFollowerReq) String 

func (m *DBQueryFollowerReq) String() string

func (*DBQueryFollowerReq) XXX_DiscardUnknown 

func (m *DBQueryFollowerReq) XXX_DiscardUnknown()

func (*DBQueryFollowerReq) XXX_Marshal 

func (m *DBQueryFollowerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryFollowerReq) XXX_Merge 

func (m *DBQueryFollowerReq) XXX_Merge(src proto.Message)

func (*DBQueryFollowerReq) XXX_Size 

func (m *DBQueryFollowerReq) XXX_Size() int

func (*DBQueryFollowerReq) XXX_Unmarshal 

func (m *DBQueryFollowerReq) XXX_Unmarshal(b []byte) error

type DBQueryFollowerRsp 

type DBQueryFollowerRsp struct {
	FollowerIdArr        []int64  `protobuf:"varint,1,rep,packed,name=FollowerIdArr,proto3" json:"FollowerIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryFollowerRsp) Descriptor 

func (*DBQueryFollowerRsp) Descriptor() ([]byte, []int)

func (*DBQueryFollowerRsp) GetFollowerIdArr 

func (m *DBQueryFollowerRsp) GetFollowerIdArr() []int64

func (*DBQueryFollowerRsp) ProtoMessage 

func (*DBQueryFollowerRsp) ProtoMessage()

func (*DBQueryFollowerRsp) Reset 

func (m *DBQueryFollowerRsp) Reset()

func (*DBQueryFollowerRsp) String 

func (m *DBQueryFollowerRsp) String() string

func (*DBQueryFollowerRsp) XXX_DiscardUnknown 

func (m *DBQueryFollowerRsp) XXX_DiscardUnknown()

func (*DBQueryFollowerRsp) XXX_Marshal 

func (m *DBQueryFollowerRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryFollowerRsp) XXX_Merge 

func (m *DBQueryFollowerRsp) XXX_Merge(src proto.Message)

func (*DBQueryFollowerRsp) XXX_Size 

func (m *DBQueryFollowerRsp) XXX_Size() int

func (*DBQueryFollowerRsp) XXX_Unmarshal 

func (m *DBQueryFollowerRsp) XXX_Unmarshal(b []byte) error

type DBQueryMsgContentReq 

type DBQueryMsgContentReq struct {
	MsgId                int64    `protobuf:"varint,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryMsgContentReq) Descriptor 

func (*DBQueryMsgContentReq) Descriptor() ([]byte, []int)

func (*DBQueryMsgContentReq) GetMsgId 

func (m *DBQueryMsgContentReq) GetMsgId() int64

func (*DBQueryMsgContentReq) ProtoMessage 

func (*DBQueryMsgContentReq) ProtoMessage()

func (*DBQueryMsgContentReq) Reset 

func (m *DBQueryMsgContentReq) Reset()

func (*DBQueryMsgContentReq) String 

func (m *DBQueryMsgContentReq) String() string

func (*DBQueryMsgContentReq) XXX_DiscardUnknown 

func (m *DBQueryMsgContentReq) XXX_DiscardUnknown()

func (*DBQueryMsgContentReq) XXX_Marshal 

func (m *DBQueryMsgContentReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryMsgContentReq) XXX_Merge 

func (m *DBQueryMsgContentReq) XXX_Merge(src proto.Message)

func (*DBQueryMsgContentReq) XXX_Size 

func (m *DBQueryMsgContentReq) XXX_Size() int

func (*DBQueryMsgContentReq) XXX_Unmarshal 

func (m *DBQueryMsgContentReq) XXX_Unmarshal(b []byte) error

type DBQueryMsgContentRsp 

type DBQueryMsgContentRsp struct {
	Msg                  *MsgData `protobuf:"bytes,1,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryMsgContentRsp) Descriptor 

func (*DBQueryMsgContentRsp) Descriptor() ([]byte, []int)

func (*DBQueryMsgContentRsp) GetMsg 

func (m *DBQueryMsgContentRsp) GetMsg() *MsgData

func (*DBQueryMsgContentRsp) ProtoMessage 

func (*DBQueryMsgContentRsp) ProtoMessage()

func (*DBQueryMsgContentRsp) Reset 

func (m *DBQueryMsgContentRsp) Reset()

func (*DBQueryMsgContentRsp) String 

func (m *DBQueryMsgContentRsp) String() string

func (*DBQueryMsgContentRsp) XXX_DiscardUnknown 

func (m *DBQueryMsgContentRsp) XXX_DiscardUnknown()

func (*DBQueryMsgContentRsp) XXX_Marshal 

func (m *DBQueryMsgContentRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryMsgContentRsp) XXX_Merge 

func (m *DBQueryMsgContentRsp) XXX_Merge(src proto.Message)

func (*DBQueryMsgContentRsp) XXX_Size 

func (m *DBQueryMsgContentRsp) XXX_Size() int

func (*DBQueryMsgContentRsp) XXX_Unmarshal 

func (m *DBQueryMsgContentRsp) XXX_Unmarshal(b []byte) error

type DBQueryUserMsgIdReq 

type DBQueryUserMsgIdReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryUserMsgIdReq) Descriptor 

func (*DBQueryUserMsgIdReq) Descriptor() ([]byte, []int)

func (*DBQueryUserMsgIdReq) GetUserId 

func (m *DBQueryUserMsgIdReq) GetUserId() int64

func (*DBQueryUserMsgIdReq) ProtoMessage 

func (*DBQueryUserMsgIdReq) ProtoMessage()

func (*DBQueryUserMsgIdReq) Reset 

func (m *DBQueryUserMsgIdReq) Reset()

func (*DBQueryUserMsgIdReq) String 

func (m *DBQueryUserMsgIdReq) String() string

func (*DBQueryUserMsgIdReq) XXX_DiscardUnknown 

func (m *DBQueryUserMsgIdReq) XXX_DiscardUnknown()

func (*DBQueryUserMsgIdReq) XXX_Marshal 

func (m *DBQueryUserMsgIdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryUserMsgIdReq) XXX_Merge 

func (m *DBQueryUserMsgIdReq) XXX_Merge(src proto.Message)

func (*DBQueryUserMsgIdReq) XXX_Size 

func (m *DBQueryUserMsgIdReq) XXX_Size() int

func (*DBQueryUserMsgIdReq) XXX_Unmarshal 

func (m *DBQueryUserMsgIdReq) XXX_Unmarshal(b []byte) error

type DBQueryUserMsgIdRsp 

type DBQueryUserMsgIdRsp struct {
	MsgIdArr             []int64  `protobuf:"varint,1,rep,packed,name=MsgIdArr,proto3" json:"MsgIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueryUserMsgIdRsp) Descriptor 

func (*DBQueryUserMsgIdRsp) Descriptor() ([]byte, []int)

func (*DBQueryUserMsgIdRsp) GetMsgIdArr 

func (m *DBQueryUserMsgIdRsp) GetMsgIdArr() []int64

func (*DBQueryUserMsgIdRsp) ProtoMessage 

func (*DBQueryUserMsgIdRsp) ProtoMessage()

func (*DBQueryUserMsgIdRsp) Reset 

func (m *DBQueryUserMsgIdRsp) Reset()

func (*DBQueryUserMsgIdRsp) String 

func (m *DBQueryUserMsgIdRsp) String() string

func (*DBQueryUserMsgIdRsp) XXX_DiscardUnknown 

func (m *DBQueryUserMsgIdRsp) XXX_DiscardUnknown()

func (*DBQueryUserMsgIdRsp) XXX_Marshal 

func (m *DBQueryUserMsgIdRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBQueryUserMsgIdRsp) XXX_Merge 

func (m *DBQueryUserMsgIdRsp) XXX_Merge(src proto.Message)

func (*DBQueryUserMsgIdRsp) XXX_Size 

func (m *DBQueryUserMsgIdRsp) XXX_Size() int

func (*DBQueryUserMsgIdRsp) XXX_Unmarshal 

func (m *DBQueryUserMsgIdRsp) XXX_Unmarshal(b []byte) error

type DBUnFollowReq 

type DBUnFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FollowId             int64    `protobuf:"varint,2,opt,name=FollowId,proto3" json:"FollowId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBUnFollowReq) Descriptor 

func (*DBUnFollowReq) Descriptor() ([]byte, []int)

func (*DBUnFollowReq) GetFollowId 

func (m *DBUnFollowReq) GetFollowId() int64

func (*DBUnFollowReq) GetUserId 

func (m *DBUnFollowReq) GetUserId() int64

func (*DBUnFollowReq) ProtoMessage 

func (*DBUnFollowReq) ProtoMessage()

func (*DBUnFollowReq) Reset 

func (m *DBUnFollowReq) Reset()

func (*DBUnFollowReq) String 

func (m *DBUnFollowReq) String() string

func (*DBUnFollowReq) XXX_DiscardUnknown 

func (m *DBUnFollowReq) XXX_DiscardUnknown()

func (*DBUnFollowReq) XXX_Marshal 

func (m *DBUnFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBUnFollowReq) XXX_Merge 

func (m *DBUnFollowReq) XXX_Merge(src proto.Message)

func (*DBUnFollowReq) XXX_Size 

func (m *DBUnFollowReq) XXX_Size() int

func (*DBUnFollowReq) XXX_Unmarshal 

func (m *DBUnFollowReq) XXX_Unmarshal(b []byte) error

type DBUnFollowRsp 

type DBUnFollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBUnFollowRsp) Descriptor 

func (*DBUnFollowRsp) Descriptor() ([]byte, []int)

func (*DBUnFollowRsp) ProtoMessage 

func (*DBUnFollowRsp) ProtoMessage()

func (*DBUnFollowRsp) Reset 

func (m *DBUnFollowRsp) Reset()

func (*DBUnFollowRsp) String 

func (m *DBUnFollowRsp) String() string

func (*DBUnFollowRsp) XXX_DiscardUnknown 

func (m *DBUnFollowRsp) XXX_DiscardUnknown()

func (*DBUnFollowRsp) XXX_Marshal 

func (m *DBUnFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBUnFollowRsp) XXX_Merge 

func (m *DBUnFollowRsp) XXX_Merge(src proto.Message)

func (*DBUnFollowRsp) XXX_Size 

func (m *DBUnFollowRsp) XXX_Size() int

func (*DBUnFollowRsp) XXX_Unmarshal 

func (m *DBUnFollowRsp) XXX_Unmarshal(b []byte) error

type DbSvrClient 

type DbSvrClient interface {
	QueryFollow(ctx context.Context, in *DBQueryFollowReq, opts ...grpc.CallOption) (*DBQueryFollowRsp, error)
	QueryFollower(ctx context.Context, in *DBQueryFollowerReq, opts ...grpc.CallOption) (*DBQueryFollowerRsp, error)
	QueryUserMsgId(ctx context.Context, in *DBQueryUserMsgIdReq, opts ...grpc.CallOption) (*DBQueryUserMsgIdRsp, error)
	QueryMsgContent(ctx context.Context, in *DBQueryMsgContentReq, opts ...grpc.CallOption) (*DBQueryMsgContentRsp, error)
	Follow(ctx context.Context, in *DBFollowReq, opts ...grpc.CallOption) (*DBFollowRsp, error)
	UnFollow(ctx context.Context, in *DBUnFollowReq, opts ...grpc.CallOption) (*DBUnFollowRsp, error)
	Post(ctx context.Context, in *DBPostReq, opts ...grpc.CallOption) (*DBPostRsp, error)
}

DbSvrClient is the client API for DbSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDbSvrClient 

func NewDbSvrClient(cc *grpc.ClientConn) DbSvrClient

type DbSvrServer 

type DbSvrServer interface {
	QueryFollow(context.Context, *DBQueryFollowReq) (*DBQueryFollowRsp, error)
	QueryFollower(context.Context, *DBQueryFollowerReq) (*DBQueryFollowerRsp, error)
	QueryUserMsgId(context.Context, *DBQueryUserMsgIdReq) (*DBQueryUserMsgIdRsp, error)
	QueryMsgContent(context.Context, *DBQueryMsgContentReq) (*DBQueryMsgContentRsp, error)
	Follow(context.Context, *DBFollowReq) (*DBFollowRsp, error)
	UnFollow(context.Context, *DBUnFollowReq) (*DBUnFollowRsp, error)
	Post(context.Context, *DBPostReq) (*DBPostRsp, error)
}

DbSvrServer is the server API for DbSvr service.

type DeleteMsgReq 

type DeleteMsgReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	MsgId                int64    `protobuf:"varint,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteMsgReq) Descriptor 

func (*DeleteMsgReq) Descriptor() ([]byte, []int)

func (*DeleteMsgReq) GetMsgId 

func (m *DeleteMsgReq) GetMsgId() int64

func (*DeleteMsgReq) GetUserId 

func (m *DeleteMsgReq) GetUserId() int64

func (*DeleteMsgReq) ProtoMessage 

func (*DeleteMsgReq) ProtoMessage()

func (*DeleteMsgReq) Reset 

func (m *DeleteMsgReq) Reset()

func (*DeleteMsgReq) String 

func (m *DeleteMsgReq) String() string

func (*DeleteMsgReq) XXX_DiscardUnknown 

func (m *DeleteMsgReq) XXX_DiscardUnknown()

func (*DeleteMsgReq) XXX_Marshal 

func (m *DeleteMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteMsgReq) XXX_Merge 

func (m *DeleteMsgReq) XXX_Merge(src proto.Message)

func (*DeleteMsgReq) XXX_Size 

func (m *DeleteMsgReq) XXX_Size() int

func (*DeleteMsgReq) XXX_Unmarshal 

func (m *DeleteMsgReq) XXX_Unmarshal(b []byte) error

type DeleteMsgRsp 

type DeleteMsgRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteMsgRsp) Descriptor 

func (*DeleteMsgRsp) Descriptor() ([]byte, []int)

func (*DeleteMsgRsp) ProtoMessage 

func (*DeleteMsgRsp) ProtoMessage()

func (*DeleteMsgRsp) Reset 

func (m *DeleteMsgRsp) Reset()

func (*DeleteMsgRsp) String 

func (m *DeleteMsgRsp) String() string

func (*DeleteMsgRsp) XXX_DiscardUnknown 

func (m *DeleteMsgRsp) XXX_DiscardUnknown()

func (*DeleteMsgRsp) XXX_Marshal 

func (m *DeleteMsgRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteMsgRsp) XXX_Merge 

func (m *DeleteMsgRsp) XXX_Merge(src proto.Message)

func (*DeleteMsgRsp) XXX_Size 

func (m *DeleteMsgRsp) XXX_Size() int

func (*DeleteMsgRsp) XXX_Unmarshal 

func (m *DeleteMsgRsp) XXX_Unmarshal(b []byte) error

type FollowReq 

type FollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FollowedUserId       int64    `protobuf:"varint,2,opt,name=FollowedUserId,proto3" json:"FollowedUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FollowReq) Descriptor 

func (*FollowReq) Descriptor() ([]byte, []int)

func (*FollowReq) GetFollowedUserId 

func (m *FollowReq) GetFollowedUserId() int64

func (*FollowReq) GetUserId 

func (m *FollowReq) GetUserId() int64

func (*FollowReq) ProtoMessage 

func (*FollowReq) ProtoMessage()

func (*FollowReq) Reset 

func (m *FollowReq) Reset()

func (*FollowReq) String 

func (m *FollowReq) String() string

func (*FollowReq) XXX_DiscardUnknown 

func (m *FollowReq) XXX_DiscardUnknown()

func (*FollowReq) XXX_Marshal 

func (m *FollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FollowReq) XXX_Merge 

func (m *FollowReq) XXX_Merge(src proto.Message)

func (*FollowReq) XXX_Size 

func (m *FollowReq) XXX_Size() int

func (*FollowReq) XXX_Unmarshal 

func (m *FollowReq) XXX_Unmarshal(b []byte) error

type FollowRsp 

type FollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FollowRsp) Descriptor 

func (*FollowRsp) Descriptor() ([]byte, []int)

func (*FollowRsp) ProtoMessage 

func (*FollowRsp) ProtoMessage()

func (*FollowRsp) Reset 

func (m *FollowRsp) Reset()

func (*FollowRsp) String 

func (m *FollowRsp) String() string

func (*FollowRsp) XXX_DiscardUnknown 

func (m *FollowRsp) XXX_DiscardUnknown()

func (*FollowRsp) XXX_Marshal 

func (m *FollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FollowRsp) XXX_Merge 

func (m *FollowRsp) XXX_Merge(src proto.Message)

func (*FollowRsp) XXX_Size 

func (m *FollowRsp) XXX_Size() int

func (*FollowRsp) XXX_Unmarshal 

func (m *FollowRsp) XXX_Unmarshal(b []byte) error

type FollowSvrClient 

type FollowSvrClient interface {
	QueryFollowList(ctx context.Context, in *QueryFollowListReq, opts ...grpc.CallOption) (*QueryFollowListRsp, error)
	//关注
	Follow(ctx context.Context, in *FollowReq, opts ...grpc.CallOption) (*FollowRsp, error)
	//取关
	UnFollow(ctx context.Context, in *UnFollowReq, opts ...grpc.CallOption) (*UnFollowRsp, error)
}

FollowSvrClient is the client API for FollowSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFollowSvrClient 

func NewFollowSvrClient(cc *grpc.ClientConn) FollowSvrClient

type FollowSvrServer 

type FollowSvrServer interface {
	QueryFollowList(context.Context, *QueryFollowListReq) (*QueryFollowListRsp, error)
	//关注
	Follow(context.Context, *FollowReq) (*FollowRsp, error)
	//取关
	UnFollow(context.Context, *UnFollowReq) (*UnFollowRsp, error)
}

FollowSvrServer is the server API for FollowSvr service.

type FollowedSvrClient 

type FollowedSvrClient interface {
	QueryFollowedList(ctx context.Context, in *QueryFollowedListReq, opts ...grpc.CallOption) (*QueryFollowedListRsp, error)
	QueryOnlineFollowedList(ctx context.Context, in *QueryFollowedListReq, opts ...grpc.CallOption) (*QueryFollowedListRsp, error)
	//userId上线
	Online(ctx context.Context, in *OnlineReq, opts ...grpc.CallOption) (*OnlineRsp, error)
	//userId下线
	Offline(ctx context.Context, in *OfflineReq, opts ...grpc.CallOption) (*OfflineRsp, error)
	//关注
	Follow(ctx context.Context, in *FollowReq, opts ...grpc.CallOption) (*FollowRsp, error)
	//取关
	UnFollow(ctx context.Context, in *UnFollowReq, opts ...grpc.CallOption) (*UnFollowRsp, error)
}

FollowedSvrClient is the client API for FollowedSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFollowedSvrClient 

func NewFollowedSvrClient(cc *grpc.ClientConn) FollowedSvrClient

type FollowedSvrServer 

type FollowedSvrServer interface {
	QueryFollowedList(context.Context, *QueryFollowedListReq) (*QueryFollowedListRsp, error)
	QueryOnlineFollowedList(context.Context, *QueryFollowedListReq) (*QueryFollowedListRsp, error)
	//userId上线
	Online(context.Context, *OnlineReq) (*OnlineRsp, error)
	//userId下线
	Offline(context.Context, *OfflineReq) (*OfflineRsp, error)
	//关注
	Follow(context.Context, *FollowReq) (*FollowRsp, error)
	//取关
	UnFollow(context.Context, *UnFollowReq) (*UnFollowRsp, error)
}

FollowedSvrServer is the server API for FollowedSvr service.

type FrontCheckAvailReq 

type FrontCheckAvailReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrontCheckAvailReq) Descriptor 

func (*FrontCheckAvailReq) Descriptor() ([]byte, []int)

func (*FrontCheckAvailReq) ProtoMessage 

func (*FrontCheckAvailReq) ProtoMessage()

func (*FrontCheckAvailReq) Reset 

func (m *FrontCheckAvailReq) Reset()

func (*FrontCheckAvailReq) String 

func (m *FrontCheckAvailReq) String() string

func (*FrontCheckAvailReq) XXX_DiscardUnknown 

func (m *FrontCheckAvailReq) XXX_DiscardUnknown()

func (*FrontCheckAvailReq) XXX_Marshal 

func (m *FrontCheckAvailReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrontCheckAvailReq) XXX_Merge 

func (m *FrontCheckAvailReq) XXX_Merge(src proto.Message)

func (*FrontCheckAvailReq) XXX_Size 

func (m *FrontCheckAvailReq) XXX_Size() int

func (*FrontCheckAvailReq) XXX_Unmarshal 

func (m *FrontCheckAvailReq) XXX_Unmarshal(b []byte) error

type FrontCheckAvailRsp 

type FrontCheckAvailRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrontCheckAvailRsp) Descriptor 

func (*FrontCheckAvailRsp) Descriptor() ([]byte, []int)

func (*FrontCheckAvailRsp) ProtoMessage 

func (*FrontCheckAvailRsp) ProtoMessage()

func (*FrontCheckAvailRsp) Reset 

func (m *FrontCheckAvailRsp) Reset()

func (*FrontCheckAvailRsp) String 

func (m *FrontCheckAvailRsp) String() string

func (*FrontCheckAvailRsp) XXX_DiscardUnknown 

func (m *FrontCheckAvailRsp) XXX_DiscardUnknown()

func (*FrontCheckAvailRsp) XXX_Marshal 

func (m *FrontCheckAvailRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrontCheckAvailRsp) XXX_Merge 

func (m *FrontCheckAvailRsp) XXX_Merge(src proto.Message)

func (*FrontCheckAvailRsp) XXX_Size 

func (m *FrontCheckAvailRsp) XXX_Size() int

func (*FrontCheckAvailRsp) XXX_Unmarshal 

func (m *FrontCheckAvailRsp) XXX_Unmarshal(b []byte) error

type FrontNotifyCheckAvailReq 

type FrontNotifyCheckAvailReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrontNotifyCheckAvailReq) Descriptor 

func (*FrontNotifyCheckAvailReq) Descriptor() ([]byte, []int)

func (*FrontNotifyCheckAvailReq) ProtoMessage 

func (*FrontNotifyCheckAvailReq) ProtoMessage()

func (*FrontNotifyCheckAvailReq) Reset 

func (m *FrontNotifyCheckAvailReq) Reset()

func (*FrontNotifyCheckAvailReq) String 

func (m *FrontNotifyCheckAvailReq) String() string

func (*FrontNotifyCheckAvailReq) XXX_DiscardUnknown 

func (m *FrontNotifyCheckAvailReq) XXX_DiscardUnknown()

func (*FrontNotifyCheckAvailReq) XXX_Marshal 

func (m *FrontNotifyCheckAvailReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrontNotifyCheckAvailReq) XXX_Merge 

func (m *FrontNotifyCheckAvailReq) XXX_Merge(src proto.Message)

func (*FrontNotifyCheckAvailReq) XXX_Size 

func (m *FrontNotifyCheckAvailReq) XXX_Size() int

func (*FrontNotifyCheckAvailReq) XXX_Unmarshal 

func (m *FrontNotifyCheckAvailReq) XXX_Unmarshal(b []byte) error

type FrontNotifyCheckAvailRsp 

type FrontNotifyCheckAvailRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrontNotifyCheckAvailRsp) Descriptor 

func (*FrontNotifyCheckAvailRsp) Descriptor() ([]byte, []int)

func (*FrontNotifyCheckAvailRsp) ProtoMessage 

func (*FrontNotifyCheckAvailRsp) ProtoMessage()

func (*FrontNotifyCheckAvailRsp) Reset 

func (m *FrontNotifyCheckAvailRsp) Reset()

func (*FrontNotifyCheckAvailRsp) String 

func (m *FrontNotifyCheckAvailRsp) String() string

func (*FrontNotifyCheckAvailRsp) XXX_DiscardUnknown 

func (m *FrontNotifyCheckAvailRsp) XXX_DiscardUnknown()

func (*FrontNotifyCheckAvailRsp) XXX_Marshal 

func (m *FrontNotifyCheckAvailRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrontNotifyCheckAvailRsp) XXX_Merge 

func (m *FrontNotifyCheckAvailRsp) XXX_Merge(src proto.Message)

func (*FrontNotifyCheckAvailRsp) XXX_Size 

func (m *FrontNotifyCheckAvailRsp) XXX_Size() int

func (*FrontNotifyCheckAvailRsp) XXX_Unmarshal 

func (m *FrontNotifyCheckAvailRsp) XXX_Unmarshal(b []byte) error

type FrontNotifySvrClient 

type FrontNotifySvrClient interface {
	//for Client////////////
	//客户端建立服务端流式stream，接收notify。接收失败时重新选择frontNotifySvr重新发起链接创建新的stream
	CreateNotifyStream(ctx context.Context, in *CCreateNotifyStreamReq, opts ...grpc.CallOption) (FrontNotifySvr_CreateNotifyStreamClient, error)
	//userId下线
	Offline(ctx context.Context, in *COfflineReq, opts ...grpc.CallOption) (*COfflineRsp, error)
	HeartBeat(ctx context.Context, in *CHeartBeatReq, opts ...grpc.CallOption) (*CHeartBeatRsp, error)
	//for frontNotifySvrMng////////////
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(ctx context.Context, in *FrontNotifyCheckAvailReq, opts ...grpc.CallOption) (*FrontNotifyCheckAvailRsp, error)
}

FrontNotifySvrClient is the client API for FrontNotifySvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFrontNotifySvrClient 

func NewFrontNotifySvrClient(cc *grpc.ClientConn) FrontNotifySvrClient

type FrontNotifySvrMngClient 

type FrontNotifySvrMngClient interface {
	//for Client////////////
	//查询本次归宿frontNotifySvr
	QueryMyFrontNotifySvr(ctx context.Context, in *CClientAuthInfo, opts ...grpc.CallOption) (*CFrontNotifySvrAddr, error)
}

FrontNotifySvrMngClient is the client API for FrontNotifySvrMng service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFrontNotifySvrMngClient 

func NewFrontNotifySvrMngClient(cc *grpc.ClientConn) FrontNotifySvrMngClient

type FrontNotifySvrMngServer 

type FrontNotifySvrMngServer interface {
	//for Client////////////
	//查询本次归宿frontNotifySvr
	QueryMyFrontNotifySvr(context.Context, *CClientAuthInfo) (*CFrontNotifySvrAddr, error)
}

FrontNotifySvrMngServer is the server API for FrontNotifySvrMng service.

type FrontNotifySvrServer 

type FrontNotifySvrServer interface {
	//for Client////////////
	//客户端建立服务端流式stream，接收notify。接收失败时重新选择frontNotifySvr重新发起链接创建新的stream
	CreateNotifyStream(*CCreateNotifyStreamReq, FrontNotifySvr_CreateNotifyStreamServer) error
	//userId下线
	Offline(context.Context, *COfflineReq) (*COfflineRsp, error)
	HeartBeat(context.Context, *CHeartBeatReq) (*CHeartBeatRsp, error)
	//for frontNotifySvrMng////////////
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(context.Context, *FrontNotifyCheckAvailReq) (*FrontNotifyCheckAvailRsp, error)
}

FrontNotifySvrServer is the server API for FrontNotifySvr service.

type FrontNotifySvr_CreateNotifyStreamClient 

type FrontNotifySvr_CreateNotifyStreamClient interface {
	Recv() (*CNotify, error)
	grpc.ClientStream
}

type FrontNotifySvr_CreateNotifyStreamServer 

type FrontNotifySvr_CreateNotifyStreamServer interface {
	Send(*CNotify) error
	grpc.ServerStream
}

type FrontSvrClient 

type FrontSvrClient interface {
	//for Client////////////
	//拉取若干条微博消息
	Pull(ctx context.Context, in *CPullReq, opts ...grpc.CallOption) (*CPullRsp, error)
	//发布一条微博消息
	Post(ctx context.Context, in *CPostReq, opts ...grpc.CallOption) (*CPostRsp, error)
	//关注
	Follow(ctx context.Context, in *CFollowReq, opts ...grpc.CallOption) (*CFollowRsp, error)
	//取关
	UnFollow(ctx context.Context, in *CUnFollowReq, opts ...grpc.CallOption) (*CUnFollowRsp, error)
	//点赞
	Like(ctx context.Context, in *CLikeReq, opts ...grpc.CallOption) (*CLikeRsp, error)
	//for frontSvrMng////////////
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(ctx context.Context, in *FrontCheckAvailReq, opts ...grpc.CallOption) (*FrontCheckAvailRsp, error)
}

FrontSvrClient is the client API for FrontSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFrontSvrClient 

func NewFrontSvrClient(cc *grpc.ClientConn) FrontSvrClient

type FrontSvrMngClient 

type FrontSvrMngClient interface {
	//for Client////////////
	//查询本次归宿frontSvr
	QueryMyFrontSvr(ctx context.Context, in *CClientAuthInfo, opts ...grpc.CallOption) (*CFrontSvrAddr, error)
}

FrontSvrMngClient is the client API for FrontSvrMng service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFrontSvrMngClient 

func NewFrontSvrMngClient(cc *grpc.ClientConn) FrontSvrMngClient

type FrontSvrMngServer 

type FrontSvrMngServer interface {
	//for Client////////////
	//查询本次归宿frontSvr
	QueryMyFrontSvr(context.Context, *CClientAuthInfo) (*CFrontSvrAddr, error)
}

FrontSvrMngServer is the server API for FrontSvrMng service.

type FrontSvrServer 

type FrontSvrServer interface {
	//for Client////////////
	//拉取若干条微博消息
	Pull(context.Context, *CPullReq) (*CPullRsp, error)
	//发布一条微博消息
	Post(context.Context, *CPostReq) (*CPostRsp, error)
	//关注
	Follow(context.Context, *CFollowReq) (*CFollowRsp, error)
	//取关
	UnFollow(context.Context, *CUnFollowReq) (*CUnFollowRsp, error)
	//点赞
	Like(context.Context, *CLikeReq) (*CLikeRsp, error)
	//for frontSvrMng////////////
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(context.Context, *FrontCheckAvailReq) (*FrontCheckAvailRsp, error)
}

FrontSvrServer is the server API for FrontSvr service.

type GenMsgIdReq 

type GenMsgIdReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenMsgIdReq) Descriptor 

func (*GenMsgIdReq) Descriptor() ([]byte, []int)

func (*GenMsgIdReq) ProtoMessage 

func (*GenMsgIdReq) ProtoMessage()

func (*GenMsgIdReq) Reset 

func (m *GenMsgIdReq) Reset()

func (*GenMsgIdReq) String 

func (m *GenMsgIdReq) String() string

func (*GenMsgIdReq) XXX_DiscardUnknown 

func (m *GenMsgIdReq) XXX_DiscardUnknown()

func (*GenMsgIdReq) XXX_Marshal 

func (m *GenMsgIdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenMsgIdReq) XXX_Merge 

func (m *GenMsgIdReq) XXX_Merge(src proto.Message)

func (*GenMsgIdReq) XXX_Size 

func (m *GenMsgIdReq) XXX_Size() int

func (*GenMsgIdReq) XXX_Unmarshal 

func (m *GenMsgIdReq) XXX_Unmarshal(b []byte) error

type GenMsgIdRsp 

type GenMsgIdRsp struct {
	MsgId                int64    `protobuf:"varint,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenMsgIdRsp) Descriptor 

func (*GenMsgIdRsp) Descriptor() ([]byte, []int)

func (*GenMsgIdRsp) GetMsgId 

func (m *GenMsgIdRsp) GetMsgId() int64

func (*GenMsgIdRsp) ProtoMessage 

func (*GenMsgIdRsp) ProtoMessage()

func (*GenMsgIdRsp) Reset 

func (m *GenMsgIdRsp) Reset()

func (*GenMsgIdRsp) String 

func (m *GenMsgIdRsp) String() string

func (*GenMsgIdRsp) XXX_DiscardUnknown 

func (m *GenMsgIdRsp) XXX_DiscardUnknown()

func (*GenMsgIdRsp) XXX_Marshal 

func (m *GenMsgIdRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenMsgIdRsp) XXX_Merge 

func (m *GenMsgIdRsp) XXX_Merge(src proto.Message)

func (*GenMsgIdRsp) XXX_Size 

func (m *GenMsgIdRsp) XXX_Size() int

func (*GenMsgIdRsp) XXX_Unmarshal 

func (m *GenMsgIdRsp) XXX_Unmarshal(b []byte) error

type MsgData 

type MsgData struct {
	MsgId  int64 `protobuf:"varint,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=UserId,proto3" json:"UserId,omitempty"`
	//
	Text                 string   `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	ImgUrlArr            []string `protobuf:"bytes,4,rep,name=imgUrlArr,proto3" json:"imgUrlArr,omitempty"`
	VideoUrl             string   `protobuf:"bytes,5,opt,name=videoUrl,proto3" json:"videoUrl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MsgData) Descriptor 

func (*MsgData) Descriptor() ([]byte, []int)

func (*MsgData) GetImgUrlArr 

func (m *MsgData) GetImgUrlArr() []string

func (*MsgData) GetMsgId 

func (m *MsgData) GetMsgId() int64

func (*MsgData) GetText 

func (m *MsgData) GetText() string

func (*MsgData) GetUserId 

func (m *MsgData) GetUserId() int64

func (*MsgData) GetVideoUrl 

func (m *MsgData) GetVideoUrl() string

func (*MsgData) ProtoMessage 

func (*MsgData) ProtoMessage()

func (*MsgData) Reset 

func (m *MsgData) Reset()

func (*MsgData) String 

func (m *MsgData) String() string

func (*MsgData) XXX_DiscardUnknown 

func (m *MsgData) XXX_DiscardUnknown()

func (*MsgData) XXX_Marshal 

func (m *MsgData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgData) XXX_Merge 

func (m *MsgData) XXX_Merge(src proto.Message)

func (*MsgData) XXX_Size 

func (m *MsgData) XXX_Size() int

func (*MsgData) XXX_Unmarshal 

func (m *MsgData) XXX_Unmarshal(b []byte) error

type MsgIdGeneratorClient 

type MsgIdGeneratorClient interface {
	//获取一个msgId
	GenMsgId(ctx context.Context, in *GenMsgIdReq, opts ...grpc.CallOption) (*GenMsgIdRsp, error)
}

MsgIdGeneratorClient is the client API for MsgIdGenerator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgIdGeneratorClient 

func NewMsgIdGeneratorClient(cc *grpc.ClientConn) MsgIdGeneratorClient

type MsgIdGeneratorServer 

type MsgIdGeneratorServer interface {
	//获取一个msgId
	GenMsgId(context.Context, *GenMsgIdReq) (*GenMsgIdRsp, error)
}

MsgIdGeneratorServer is the server API for MsgIdGenerator service.

type MsgIdSvrAddrAndUserId 

type MsgIdSvrAddrAndUserId struct {
	Addr                 string   `protobuf:"bytes,1,opt,name=Addr,proto3" json:"Addr,omitempty"`
	UserIdArr            []int64  `protobuf:"varint,2,rep,packed,name=UserIdArr,proto3" json:"UserIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MsgIdSvrAddrAndUserId) Descriptor 

func (*MsgIdSvrAddrAndUserId) Descriptor() ([]byte, []int)

func (*MsgIdSvrAddrAndUserId) GetAddr 

func (m *MsgIdSvrAddrAndUserId) GetAddr() string

func (*MsgIdSvrAddrAndUserId) GetUserIdArr 

func (m *MsgIdSvrAddrAndUserId) GetUserIdArr() []int64

func (*MsgIdSvrAddrAndUserId) ProtoMessage 

func (*MsgIdSvrAddrAndUserId) ProtoMessage()

func (*MsgIdSvrAddrAndUserId) Reset 

func (m *MsgIdSvrAddrAndUserId) Reset()

func (*MsgIdSvrAddrAndUserId) String 

func (m *MsgIdSvrAddrAndUserId) String() string

func (*MsgIdSvrAddrAndUserId) XXX_DiscardUnknown 

func (m *MsgIdSvrAddrAndUserId) XXX_DiscardUnknown()

func (*MsgIdSvrAddrAndUserId) XXX_Marshal 

func (m *MsgIdSvrAddrAndUserId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgIdSvrAddrAndUserId) XXX_Merge 

func (m *MsgIdSvrAddrAndUserId) XXX_Merge(src proto.Message)

func (*MsgIdSvrAddrAndUserId) XXX_Size 

func (m *MsgIdSvrAddrAndUserId) XXX_Size() int

func (*MsgIdSvrAddrAndUserId) XXX_Unmarshal 

func (m *MsgIdSvrAddrAndUserId) XXX_Unmarshal(b []byte) error

type Notify 

type Notify struct {
	PostUserId           int64    `protobuf:"varint,1,opt,name=PostUserId,proto3" json:"PostUserId,omitempty"`
	MsgId                int64    `protobuf:"varint,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	NotifyUserId         []int64  `protobuf:"varint,3,rep,packed,name=NotifyUserId,proto3" json:"NotifyUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Notify) Descriptor 

func (*Notify) Descriptor() ([]byte, []int)

func (*Notify) GetMsgId 

func (m *Notify) GetMsgId() int64

func (*Notify) GetNotifyUserId 

func (m *Notify) GetNotifyUserId() []int64

func (*Notify) GetPostUserId 

func (m *Notify) GetPostUserId() int64

func (*Notify) ProtoMessage 

func (*Notify) ProtoMessage()

func (*Notify) Reset 

func (m *Notify) Reset()

func (*Notify) String 

func (m *Notify) String() string

func (*Notify) XXX_DiscardUnknown 

func (m *Notify) XXX_DiscardUnknown()

func (*Notify) XXX_Marshal 

func (m *Notify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Notify) XXX_Merge 

func (m *Notify) XXX_Merge(src proto.Message)

func (*Notify) XXX_Size 

func (m *Notify) XXX_Size() int

func (*Notify) XXX_Unmarshal 

func (m *Notify) XXX_Unmarshal(b []byte) error

type OfflineReq 

type OfflineReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OfflineReq) Descriptor 

func (*OfflineReq) Descriptor() ([]byte, []int)

func (*OfflineReq) GetUserId 

func (m *OfflineReq) GetUserId() int64

func (*OfflineReq) ProtoMessage 

func (*OfflineReq) ProtoMessage()

func (*OfflineReq) Reset 

func (m *OfflineReq) Reset()

func (*OfflineReq) String 

func (m *OfflineReq) String() string

func (*OfflineReq) XXX_DiscardUnknown 

func (m *OfflineReq) XXX_DiscardUnknown()

func (*OfflineReq) XXX_Marshal 

func (m *OfflineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OfflineReq) XXX_Merge 

func (m *OfflineReq) XXX_Merge(src proto.Message)

func (*OfflineReq) XXX_Size 

func (m *OfflineReq) XXX_Size() int

func (*OfflineReq) XXX_Unmarshal 

func (m *OfflineReq) XXX_Unmarshal(b []byte) error

type OfflineRsp 

type OfflineRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OfflineRsp) Descriptor 

func (*OfflineRsp) Descriptor() ([]byte, []int)

func (*OfflineRsp) ProtoMessage 

func (*OfflineRsp) ProtoMessage()

func (*OfflineRsp) Reset 

func (m *OfflineRsp) Reset()

func (*OfflineRsp) String 

func (m *OfflineRsp) String() string

func (*OfflineRsp) XXX_DiscardUnknown 

func (m *OfflineRsp) XXX_DiscardUnknown()

func (*OfflineRsp) XXX_Marshal 

func (m *OfflineRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OfflineRsp) XXX_Merge 

func (m *OfflineRsp) XXX_Merge(src proto.Message)

func (*OfflineRsp) XXX_Size 

func (m *OfflineRsp) XXX_Size() int

func (*OfflineRsp) XXX_Unmarshal 

func (m *OfflineRsp) XXX_Unmarshal(b []byte) error

type OnlineReq 

type OnlineReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FrontNotifySvrId     int32    `protobuf:"varint,2,opt,name=FrontNotifySvrId,proto3" json:"FrontNotifySvrId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OnlineReq) Descriptor 

func (*OnlineReq) Descriptor() ([]byte, []int)

func (*OnlineReq) GetFrontNotifySvrId 

func (m *OnlineReq) GetFrontNotifySvrId() int32

func (*OnlineReq) GetUserId 

func (m *OnlineReq) GetUserId() int64

func (*OnlineReq) ProtoMessage 

func (*OnlineReq) ProtoMessage()

func (*OnlineReq) Reset 

func (m *OnlineReq) Reset()

func (*OnlineReq) String 

func (m *OnlineReq) String() string

func (*OnlineReq) XXX_DiscardUnknown 

func (m *OnlineReq) XXX_DiscardUnknown()

func (*OnlineReq) XXX_Marshal 

func (m *OnlineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OnlineReq) XXX_Merge 

func (m *OnlineReq) XXX_Merge(src proto.Message)

func (*OnlineReq) XXX_Size 

func (m *OnlineReq) XXX_Size() int

func (*OnlineReq) XXX_Unmarshal 

func (m *OnlineReq) XXX_Unmarshal(b []byte) error

type OnlineRsp 

type OnlineRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OnlineRsp) Descriptor 

func (*OnlineRsp) Descriptor() ([]byte, []int)

func (*OnlineRsp) ProtoMessage 

func (*OnlineRsp) ProtoMessage()

func (*OnlineRsp) Reset 

func (m *OnlineRsp) Reset()

func (*OnlineRsp) String 

func (m *OnlineRsp) String() string

func (*OnlineRsp) XXX_DiscardUnknown 

func (m *OnlineRsp) XXX_DiscardUnknown()

func (*OnlineRsp) XXX_Marshal 

func (m *OnlineRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OnlineRsp) XXX_Merge 

func (m *OnlineRsp) XXX_Merge(src proto.Message)

func (*OnlineRsp) XXX_Size 

func (m *OnlineRsp) XXX_Size() int

func (*OnlineRsp) XXX_Unmarshal 

func (m *OnlineRsp) XXX_Unmarshal(b []byte) error

type PostMsgContentReq 

type PostMsgContentReq struct {
	Content              *MsgData `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostMsgContentReq) Descriptor 

func (*PostMsgContentReq) Descriptor() ([]byte, []int)

func (*PostMsgContentReq) GetContent 

func (m *PostMsgContentReq) GetContent() *MsgData

func (*PostMsgContentReq) ProtoMessage 

func (*PostMsgContentReq) ProtoMessage()

func (*PostMsgContentReq) Reset 

func (m *PostMsgContentReq) Reset()

func (*PostMsgContentReq) String 

func (m *PostMsgContentReq) String() string

func (*PostMsgContentReq) XXX_DiscardUnknown 

func (m *PostMsgContentReq) XXX_DiscardUnknown()

func (*PostMsgContentReq) XXX_Marshal 

func (m *PostMsgContentReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostMsgContentReq) XXX_Merge 

func (m *PostMsgContentReq) XXX_Merge(src proto.Message)

func (*PostMsgContentReq) XXX_Size 

func (m *PostMsgContentReq) XXX_Size() int

func (*PostMsgContentReq) XXX_Unmarshal 

func (m *PostMsgContentReq) XXX_Unmarshal(b []byte) error

type PostMsgContentRsp 

type PostMsgContentRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostMsgContentRsp) Descriptor 

func (*PostMsgContentRsp) Descriptor() ([]byte, []int)

func (*PostMsgContentRsp) ProtoMessage 

func (*PostMsgContentRsp) ProtoMessage()

func (*PostMsgContentRsp) Reset 

func (m *PostMsgContentRsp) Reset()

func (*PostMsgContentRsp) String 

func (m *PostMsgContentRsp) String() string

func (*PostMsgContentRsp) XXX_DiscardUnknown 

func (m *PostMsgContentRsp) XXX_DiscardUnknown()

func (*PostMsgContentRsp) XXX_Marshal 

func (m *PostMsgContentRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostMsgContentRsp) XXX_Merge 

func (m *PostMsgContentRsp) XXX_Merge(src proto.Message)

func (*PostMsgContentRsp) XXX_Size 

func (m *PostMsgContentRsp) XXX_Size() int

func (*PostMsgContentRsp) XXX_Unmarshal 

func (m *PostMsgContentRsp) XXX_Unmarshal(b []byte) error

type PostMsgIdReq 

type PostMsgIdReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	MsgId                int64    `protobuf:"varint,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostMsgIdReq) Descriptor 

func (*PostMsgIdReq) Descriptor() ([]byte, []int)

func (*PostMsgIdReq) GetMsgId 

func (m *PostMsgIdReq) GetMsgId() int64

func (*PostMsgIdReq) GetUserId 

func (m *PostMsgIdReq) GetUserId() int64

func (*PostMsgIdReq) ProtoMessage 

func (*PostMsgIdReq) ProtoMessage()

func (*PostMsgIdReq) Reset 

func (m *PostMsgIdReq) Reset()

func (*PostMsgIdReq) String 

func (m *PostMsgIdReq) String() string

func (*PostMsgIdReq) XXX_DiscardUnknown 

func (m *PostMsgIdReq) XXX_DiscardUnknown()

func (*PostMsgIdReq) XXX_Marshal 

func (m *PostMsgIdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostMsgIdReq) XXX_Merge 

func (m *PostMsgIdReq) XXX_Merge(src proto.Message)

func (*PostMsgIdReq) XXX_Size 

func (m *PostMsgIdReq) XXX_Size() int

func (*PostMsgIdReq) XXX_Unmarshal 

func (m *PostMsgIdReq) XXX_Unmarshal(b []byte) error

type PostMsgIdRsp 

type PostMsgIdRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostMsgIdRsp) Descriptor 

func (*PostMsgIdRsp) Descriptor() ([]byte, []int)

func (*PostMsgIdRsp) ProtoMessage 

func (*PostMsgIdRsp) ProtoMessage()

func (*PostMsgIdRsp) Reset 

func (m *PostMsgIdRsp) Reset()

func (*PostMsgIdRsp) String 

func (m *PostMsgIdRsp) String() string

func (*PostMsgIdRsp) XXX_DiscardUnknown 

func (m *PostMsgIdRsp) XXX_DiscardUnknown()

func (*PostMsgIdRsp) XXX_Marshal 

func (m *PostMsgIdRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostMsgIdRsp) XXX_Merge 

func (m *PostMsgIdRsp) XXX_Merge(src proto.Message)

func (*PostMsgIdRsp) XXX_Size 

func (m *PostMsgIdRsp) XXX_Size() int

func (*PostMsgIdRsp) XXX_Unmarshal 

func (m *PostMsgIdRsp) XXX_Unmarshal(b []byte) error

type PostReq 

type PostReq struct {
	FrontReqId           int64    `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	Content              *MsgData `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostReq) Descriptor 

func (*PostReq) Descriptor() ([]byte, []int)

func (*PostReq) GetContent 

func (m *PostReq) GetContent() *MsgData

func (*PostReq) GetFrontReqId 

func (m *PostReq) GetFrontReqId() int64

func (*PostReq) ProtoMessage 

func (*PostReq) ProtoMessage()

func (*PostReq) Reset 

func (m *PostReq) Reset()

func (*PostReq) String 

func (m *PostReq) String() string

func (*PostReq) XXX_DiscardUnknown 

func (m *PostReq) XXX_DiscardUnknown()

func (*PostReq) XXX_Marshal 

func (m *PostReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostReq) XXX_Merge 

func (m *PostReq) XXX_Merge(src proto.Message)

func (*PostReq) XXX_Size 

func (m *PostReq) XXX_Size() int

func (*PostReq) XXX_Unmarshal 

func (m *PostReq) XXX_Unmarshal(b []byte) error

type PostRsp 

type PostRsp struct {
	FrontReqId           int64    `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	UserId               int64    `protobuf:"varint,2,opt,name=UserId,proto3" json:"UserId,omitempty"`
	MsgId                int64    `protobuf:"varint,3,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostRsp) Descriptor 

func (*PostRsp) Descriptor() ([]byte, []int)

func (*PostRsp) GetFrontReqId 

func (m *PostRsp) GetFrontReqId() int64

func (*PostRsp) GetMsgId 

func (m *PostRsp) GetMsgId() int64

func (*PostRsp) GetUserId 

func (m *PostRsp) GetUserId() int64

func (*PostRsp) ProtoMessage 

func (*PostRsp) ProtoMessage()

func (*PostRsp) Reset 

func (m *PostRsp) Reset()

func (*PostRsp) String 

func (m *PostRsp) String() string

func (*PostRsp) XXX_DiscardUnknown 

func (m *PostRsp) XXX_DiscardUnknown()

func (*PostRsp) XXX_Marshal 

func (m *PostRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostRsp) XXX_Merge 

func (m *PostRsp) XXX_Merge(src proto.Message)

func (*PostRsp) XXX_Size 

func (m *PostRsp) XXX_Size() int

func (*PostRsp) XXX_Unmarshal 

func (m *PostRsp) XXX_Unmarshal(b []byte) error

type PostSvrClient 

type PostSvrClient interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(ctx context.Context, opts ...grpc.CallOption) (PostSvr_CreateStreamClient, error)
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(ctx context.Context, in *CheckAvailReq, opts ...grpc.CallOption) (*CheckAvailRsp, error)
}

PostSvrClient is the client API for PostSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPostSvrClient 

func NewPostSvrClient(cc *grpc.ClientConn) PostSvrClient

type PostSvrServer 

type PostSvrServer interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(PostSvr_CreateStreamServer) error
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(context.Context, *CheckAvailReq) (*CheckAvailRsp, error)
}

PostSvrServer is the server API for PostSvr service.

type PostSvr_CreateStreamClient 

type PostSvr_CreateStreamClient interface {
	Send(*PostReq) error
	Recv() (*PostRsp, error)
	grpc.ClientStream
}

type PostSvr_CreateStreamServer 

type PostSvr_CreateStreamServer interface {
	Send(*PostRsp) error
	Recv() (*PostReq, error)
	grpc.ServerStream
}

type PullMsgContentReq 

type PullMsgContentReq struct {
	MsgIdArr             []int64  `protobuf:"varint,1,rep,packed,name=msgIdArr,proto3" json:"msgIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullMsgContentReq) Descriptor 

func (*PullMsgContentReq) Descriptor() ([]byte, []int)

func (*PullMsgContentReq) GetMsgIdArr 

func (m *PullMsgContentReq) GetMsgIdArr() []int64

func (*PullMsgContentReq) ProtoMessage 

func (*PullMsgContentReq) ProtoMessage()

func (*PullMsgContentReq) Reset 

func (m *PullMsgContentReq) Reset()

func (*PullMsgContentReq) String 

func (m *PullMsgContentReq) String() string

func (*PullMsgContentReq) XXX_DiscardUnknown 

func (m *PullMsgContentReq) XXX_DiscardUnknown()

func (*PullMsgContentReq) XXX_Marshal 

func (m *PullMsgContentReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgContentReq) XXX_Merge 

func (m *PullMsgContentReq) XXX_Merge(src proto.Message)

func (*PullMsgContentReq) XXX_Size 

func (m *PullMsgContentReq) XXX_Size() int

func (*PullMsgContentReq) XXX_Unmarshal 

func (m *PullMsgContentReq) XXX_Unmarshal(b []byte) error

type PullMsgContentRsp 

type PullMsgContentRsp struct {
	MsgArr               []*MsgData `protobuf:"bytes,1,rep,name=MsgArr,proto3" json:"MsgArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PullMsgContentRsp) Descriptor 

func (*PullMsgContentRsp) Descriptor() ([]byte, []int)

func (*PullMsgContentRsp) GetMsgArr 

func (m *PullMsgContentRsp) GetMsgArr() []*MsgData

func (*PullMsgContentRsp) ProtoMessage 

func (*PullMsgContentRsp) ProtoMessage()

func (*PullMsgContentRsp) Reset 

func (m *PullMsgContentRsp) Reset()

func (*PullMsgContentRsp) String 

func (m *PullMsgContentRsp) String() string

func (*PullMsgContentRsp) XXX_DiscardUnknown 

func (m *PullMsgContentRsp) XXX_DiscardUnknown()

func (*PullMsgContentRsp) XXX_Marshal 

func (m *PullMsgContentRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgContentRsp) XXX_Merge 

func (m *PullMsgContentRsp) XXX_Merge(src proto.Message)

func (*PullMsgContentRsp) XXX_Size 

func (m *PullMsgContentRsp) XXX_Size() int

func (*PullMsgContentRsp) XXX_Unmarshal 

func (m *PullMsgContentRsp) XXX_Unmarshal(b []byte) error

type PullMsgIdReq 

type PullMsgIdReq struct {
	UserIdArr            []int64  `protobuf:"varint,1,rep,packed,name=UserIdArr,proto3" json:"UserIdArr,omitempty"`
	LastMsgId            int64    `protobuf:"varint,2,opt,name=LastMsgId,proto3" json:"LastMsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullMsgIdReq) Descriptor 

func (*PullMsgIdReq) Descriptor() ([]byte, []int)

func (*PullMsgIdReq) GetLastMsgId 

func (m *PullMsgIdReq) GetLastMsgId() int64

func (*PullMsgIdReq) GetUserIdArr 

func (m *PullMsgIdReq) GetUserIdArr() []int64

func (*PullMsgIdReq) ProtoMessage 

func (*PullMsgIdReq) ProtoMessage()

func (*PullMsgIdReq) Reset 

func (m *PullMsgIdReq) Reset()

func (*PullMsgIdReq) String 

func (m *PullMsgIdReq) String() string

func (*PullMsgIdReq) XXX_DiscardUnknown 

func (m *PullMsgIdReq) XXX_DiscardUnknown()

func (*PullMsgIdReq) XXX_Marshal 

func (m *PullMsgIdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgIdReq) XXX_Merge 

func (m *PullMsgIdReq) XXX_Merge(src proto.Message)

func (*PullMsgIdReq) XXX_Size 

func (m *PullMsgIdReq) XXX_Size() int

func (*PullMsgIdReq) XXX_Unmarshal 

func (m *PullMsgIdReq) XXX_Unmarshal(b []byte) error

type PullMsgIdRsp 

type PullMsgIdRsp struct {
	MsgIdArr             []int64  `protobuf:"varint,1,rep,packed,name=MsgIdArr,proto3" json:"MsgIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullMsgIdRsp) Descriptor 

func (*PullMsgIdRsp) Descriptor() ([]byte, []int)

func (*PullMsgIdRsp) GetMsgIdArr 

func (m *PullMsgIdRsp) GetMsgIdArr() []int64

func (*PullMsgIdRsp) ProtoMessage 

func (*PullMsgIdRsp) ProtoMessage()

func (*PullMsgIdRsp) Reset 

func (m *PullMsgIdRsp) Reset()

func (*PullMsgIdRsp) String 

func (m *PullMsgIdRsp) String() string

func (*PullMsgIdRsp) XXX_DiscardUnknown 

func (m *PullMsgIdRsp) XXX_DiscardUnknown()

func (*PullMsgIdRsp) XXX_Marshal 

func (m *PullMsgIdRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgIdRsp) XXX_Merge 

func (m *PullMsgIdRsp) XXX_Merge(src proto.Message)

func (*PullMsgIdRsp) XXX_Size 

func (m *PullMsgIdRsp) XXX_Size() int

func (*PullMsgIdRsp) XXX_Unmarshal 

func (m *PullMsgIdRsp) XXX_Unmarshal(b []byte) error

type PullMsgReq 

type PullMsgReq struct {
	UserIdArr            []int64  `protobuf:"varint,1,rep,packed,name=UserIdArr,proto3" json:"UserIdArr,omitempty"`
	LastMsgId            int64    `protobuf:"varint,2,opt,name=LastMsgId,proto3" json:"LastMsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullMsgReq) Descriptor 

func (*PullMsgReq) Descriptor() ([]byte, []int)

func (*PullMsgReq) GetLastMsgId 

func (m *PullMsgReq) GetLastMsgId() int64

func (*PullMsgReq) GetUserIdArr 

func (m *PullMsgReq) GetUserIdArr() []int64

func (*PullMsgReq) ProtoMessage 

func (*PullMsgReq) ProtoMessage()

func (*PullMsgReq) Reset 

func (m *PullMsgReq) Reset()

func (*PullMsgReq) String 

func (m *PullMsgReq) String() string

func (*PullMsgReq) XXX_DiscardUnknown 

func (m *PullMsgReq) XXX_DiscardUnknown()

func (*PullMsgReq) XXX_Marshal 

func (m *PullMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgReq) XXX_Merge 

func (m *PullMsgReq) XXX_Merge(src proto.Message)

func (*PullMsgReq) XXX_Size 

func (m *PullMsgReq) XXX_Size() int

func (*PullMsgReq) XXX_Unmarshal 

func (m *PullMsgReq) XXX_Unmarshal(b []byte) error

type PullMsgRsp 

type PullMsgRsp struct {
	MsgArr               []*MsgData `protobuf:"bytes,1,rep,name=MsgArr,proto3" json:"MsgArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PullMsgRsp) Descriptor 

func (*PullMsgRsp) Descriptor() ([]byte, []int)

func (*PullMsgRsp) GetMsgArr 

func (m *PullMsgRsp) GetMsgArr() []*MsgData

func (*PullMsgRsp) ProtoMessage 

func (*PullMsgRsp) ProtoMessage()

func (*PullMsgRsp) Reset 

func (m *PullMsgRsp) Reset()

func (*PullMsgRsp) String 

func (m *PullMsgRsp) String() string

func (*PullMsgRsp) XXX_DiscardUnknown 

func (m *PullMsgRsp) XXX_DiscardUnknown()

func (*PullMsgRsp) XXX_Marshal 

func (m *PullMsgRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullMsgRsp) XXX_Merge 

func (m *PullMsgRsp) XXX_Merge(src proto.Message)

func (*PullMsgRsp) XXX_Size 

func (m *PullMsgRsp) XXX_Size() int

func (*PullMsgRsp) XXX_Unmarshal 

func (m *PullMsgRsp) XXX_Unmarshal(b []byte) error

type PullReq 

type PullReq struct {
	FrontReqId int64 `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	UserId     int64 `protobuf:"varint,2,opt,name=UserId,proto3" json:"UserId,omitempty"`
	//上次获取到的最后一条微博的msgId，本次获取LastMsgId之前的。为0表示获取最新
	LastMsgId            int64    `protobuf:"varint,3,opt,name=LastMsgId,proto3" json:"LastMsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

拉取请求

func (*PullReq) Descriptor 

func (*PullReq) Descriptor() ([]byte, []int)

func (*PullReq) GetFrontReqId 

func (m *PullReq) GetFrontReqId() int64

func (*PullReq) GetLastMsgId 

func (m *PullReq) GetLastMsgId() int64

func (*PullReq) GetUserId 

func (m *PullReq) GetUserId() int64

func (*PullReq) ProtoMessage 

func (*PullReq) ProtoMessage()

func (*PullReq) Reset 

func (m *PullReq) Reset()

func (*PullReq) String 

func (m *PullReq) String() string

func (*PullReq) XXX_DiscardUnknown 

func (m *PullReq) XXX_DiscardUnknown()

func (*PullReq) XXX_Marshal 

func (m *PullReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullReq) XXX_Merge 

func (m *PullReq) XXX_Merge(src proto.Message)

func (*PullReq) XXX_Size 

func (m *PullReq) XXX_Size() int

func (*PullReq) XXX_Unmarshal 

func (m *PullReq) XXX_Unmarshal(b []byte) error

type PullRsp 

type PullRsp struct {
	FrontReqId           int64      `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	MsgArr               []*MsgData `protobuf:"bytes,2,rep,name=MsgArr,proto3" json:"MsgArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PullRsp) Descriptor 

func (*PullRsp) Descriptor() ([]byte, []int)

func (*PullRsp) GetFrontReqId 

func (m *PullRsp) GetFrontReqId() int64

func (*PullRsp) GetMsgArr 

func (m *PullRsp) GetMsgArr() []*MsgData

func (*PullRsp) ProtoMessage 

func (*PullRsp) ProtoMessage()

func (*PullRsp) Reset 

func (m *PullRsp) Reset()

func (*PullRsp) String 

func (m *PullRsp) String() string

func (*PullRsp) XXX_DiscardUnknown 

func (m *PullRsp) XXX_DiscardUnknown()

func (*PullRsp) XXX_Marshal 

func (m *PullRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullRsp) XXX_Merge 

func (m *PullRsp) XXX_Merge(src proto.Message)

func (*PullRsp) XXX_Size 

func (m *PullRsp) XXX_Size() int

func (*PullRsp) XXX_Unmarshal 

func (m *PullRsp) XXX_Unmarshal(b []byte) error

type PullSvrClient 

type PullSvrClient interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(ctx context.Context, opts ...grpc.CallOption) (PullSvr_CreateStreamClient, error)
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(ctx context.Context, in *CheckAvailReq, opts ...grpc.CallOption) (*CheckAvailRsp, error)
}

PullSvrClient is the client API for PullSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPullSvrClient 

func NewPullSvrClient(cc *grpc.ClientConn) PullSvrClient

type PullSvrServer 

type PullSvrServer interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(PullSvr_CreateStreamServer) error
	//探测Svr是否正常。SvrMng用，客户端无需调用
	CheckAvail(context.Context, *CheckAvailReq) (*CheckAvailRsp, error)
}

PullSvrServer is the server API for PullSvr service.

type PullSvr_CreateStreamClient 

type PullSvr_CreateStreamClient interface {
	Send(*PullReq) error
	Recv() (*PullRsp, error)
	grpc.ClientStream
}

type PullSvr_CreateStreamServer 

type PullSvr_CreateStreamServer interface {
	Send(*PullRsp) error
	Recv() (*PullReq, error)
	grpc.ServerStream
}

type PushByeRsp 

type PushByeRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushByeRsp) Descriptor 

func (*PushByeRsp) Descriptor() ([]byte, []int)

func (*PushByeRsp) ProtoMessage 

func (*PushByeRsp) ProtoMessage()

func (*PushByeRsp) Reset 

func (m *PushByeRsp) Reset()

func (*PushByeRsp) String 

func (m *PushByeRsp) String() string

func (*PushByeRsp) XXX_DiscardUnknown 

func (m *PushByeRsp) XXX_DiscardUnknown()

func (*PushByeRsp) XXX_Marshal 

func (m *PushByeRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushByeRsp) XXX_Merge 

func (m *PushByeRsp) XXX_Merge(src proto.Message)

func (*PushByeRsp) XXX_Size 

func (m *PushByeRsp) XXX_Size() int

func (*PushByeRsp) XXX_Unmarshal 

func (m *PushByeRsp) XXX_Unmarshal(b []byte) error

type PushReq 

type PushReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	MsgId                int64    `protobuf:"varint,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushReq) Descriptor 

func (*PushReq) Descriptor() ([]byte, []int)

func (*PushReq) GetMsgId 

func (m *PushReq) GetMsgId() int64

func (*PushReq) GetUserId 

func (m *PushReq) GetUserId() int64

func (*PushReq) ProtoMessage 

func (*PushReq) ProtoMessage()

func (*PushReq) Reset 

func (m *PushReq) Reset()

func (*PushReq) String 

func (m *PushReq) String() string

func (*PushReq) XXX_DiscardUnknown 

func (m *PushReq) XXX_DiscardUnknown()

func (*PushReq) XXX_Marshal 

func (m *PushReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushReq) XXX_Merge 

func (m *PushReq) XXX_Merge(src proto.Message)

func (*PushReq) XXX_Size 

func (m *PushReq) XXX_Size() int

func (*PushReq) XXX_Unmarshal 

func (m *PushReq) XXX_Unmarshal(b []byte) error

type PushRsp 

type PushRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushRsp) Descriptor 

func (*PushRsp) Descriptor() ([]byte, []int)

func (*PushRsp) ProtoMessage 

func (*PushRsp) ProtoMessage()

func (*PushRsp) Reset 

func (m *PushRsp) Reset()

func (*PushRsp) String 

func (m *PushRsp) String() string

func (*PushRsp) XXX_DiscardUnknown 

func (m *PushRsp) XXX_DiscardUnknown()

func (*PushRsp) XXX_Marshal 

func (m *PushRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushRsp) XXX_Merge 

func (m *PushRsp) XXX_Merge(src proto.Message)

func (*PushRsp) XXX_Size 

func (m *PushRsp) XXX_Size() int

func (*PushRsp) XXX_Unmarshal 

func (m *PushRsp) XXX_Unmarshal(b []byte) error

type PushSvrClient 

type PushSvrClient interface {
	//for PostSvr
	//    //PostSvr建立客户端流式stream，发送push
	//    rpc CreatePushStream(stream PushReq) returns (PushByeRsp) {}
	Push(ctx context.Context, in *PushReq, opts ...grpc.CallOption) (*PushRsp, error)
	//for frontNotifySvr
	//userId上线
	Online(ctx context.Context, in *OnlineReq, opts ...grpc.CallOption) (*OnlineRsp, error)
	//userId下线
	Offline(ctx context.Context, in *OfflineReq, opts ...grpc.CallOption) (*OfflineRsp, error)
	//frontNotifySvr建立服务端流式stream，接收notify
	CreateNotifyStream(ctx context.Context, in *CreateNotifyStreamReq, opts ...grpc.CallOption) (PushSvr_CreateNotifyStreamClient, error)
}

PushSvrClient is the client API for PushSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPushSvrClient 

func NewPushSvrClient(cc *grpc.ClientConn) PushSvrClient

type PushSvrServer 

type PushSvrServer interface {
	//for PostSvr
	//    //PostSvr建立客户端流式stream，发送push
	//    rpc CreatePushStream(stream PushReq) returns (PushByeRsp) {}
	Push(context.Context, *PushReq) (*PushRsp, error)
	//for frontNotifySvr
	//userId上线
	Online(context.Context, *OnlineReq) (*OnlineRsp, error)
	//userId下线
	Offline(context.Context, *OfflineReq) (*OfflineRsp, error)
	//frontNotifySvr建立服务端流式stream，接收notify
	CreateNotifyStream(*CreateNotifyStreamReq, PushSvr_CreateNotifyStreamServer) error
}

PushSvrServer is the server API for PushSvr service.

type PushSvr_CreateNotifyStreamClient 

type PushSvr_CreateNotifyStreamClient interface {
	Recv() (*Notify, error)
	grpc.ClientStream
}

type PushSvr_CreateNotifyStreamServer 

type PushSvr_CreateNotifyStreamServer interface {
	Send(*Notify) error
	grpc.ServerStream
}

type QueryFollowListReq 

type QueryFollowListReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFollowListReq) Descriptor 

func (*QueryFollowListReq) Descriptor() ([]byte, []int)

func (*QueryFollowListReq) GetUserId 

func (m *QueryFollowListReq) GetUserId() int64

func (*QueryFollowListReq) ProtoMessage 

func (*QueryFollowListReq) ProtoMessage()

func (*QueryFollowListReq) Reset 

func (m *QueryFollowListReq) Reset()

func (*QueryFollowListReq) String 

func (m *QueryFollowListReq) String() string

func (*QueryFollowListReq) XXX_DiscardUnknown 

func (m *QueryFollowListReq) XXX_DiscardUnknown()

func (*QueryFollowListReq) XXX_Marshal 

func (m *QueryFollowListReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFollowListReq) XXX_Merge 

func (m *QueryFollowListReq) XXX_Merge(src proto.Message)

func (*QueryFollowListReq) XXX_Size 

func (m *QueryFollowListReq) XXX_Size() int

func (*QueryFollowListReq) XXX_Unmarshal 

func (m *QueryFollowListReq) XXX_Unmarshal(b []byte) error

type QueryFollowListRsp 

type QueryFollowListRsp struct {
	FollowIdArr          []int64  `protobuf:"varint,1,rep,packed,name=FollowIdArr,proto3" json:"FollowIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFollowListRsp) Descriptor 

func (*QueryFollowListRsp) Descriptor() ([]byte, []int)

func (*QueryFollowListRsp) GetFollowIdArr 

func (m *QueryFollowListRsp) GetFollowIdArr() []int64

func (*QueryFollowListRsp) ProtoMessage 

func (*QueryFollowListRsp) ProtoMessage()

func (*QueryFollowListRsp) Reset 

func (m *QueryFollowListRsp) Reset()

func (*QueryFollowListRsp) String 

func (m *QueryFollowListRsp) String() string

func (*QueryFollowListRsp) XXX_DiscardUnknown 

func (m *QueryFollowListRsp) XXX_DiscardUnknown()

func (*QueryFollowListRsp) XXX_Marshal 

func (m *QueryFollowListRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFollowListRsp) XXX_Merge 

func (m *QueryFollowListRsp) XXX_Merge(src proto.Message)

func (*QueryFollowListRsp) XXX_Size 

func (m *QueryFollowListRsp) XXX_Size() int

func (*QueryFollowListRsp) XXX_Unmarshal 

func (m *QueryFollowListRsp) XXX_Unmarshal(b []byte) error

type QueryFollowedListReq 

type QueryFollowedListReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFollowedListReq) Descriptor 

func (*QueryFollowedListReq) Descriptor() ([]byte, []int)

func (*QueryFollowedListReq) GetUserId 

func (m *QueryFollowedListReq) GetUserId() int64

func (*QueryFollowedListReq) ProtoMessage 

func (*QueryFollowedListReq) ProtoMessage()

func (*QueryFollowedListReq) Reset 

func (m *QueryFollowedListReq) Reset()

func (*QueryFollowedListReq) String 

func (m *QueryFollowedListReq) String() string

func (*QueryFollowedListReq) XXX_DiscardUnknown 

func (m *QueryFollowedListReq) XXX_DiscardUnknown()

func (*QueryFollowedListReq) XXX_Marshal 

func (m *QueryFollowedListReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFollowedListReq) XXX_Merge 

func (m *QueryFollowedListReq) XXX_Merge(src proto.Message)

func (*QueryFollowedListReq) XXX_Size 

func (m *QueryFollowedListReq) XXX_Size() int

func (*QueryFollowedListReq) XXX_Unmarshal 

func (m *QueryFollowedListReq) XXX_Unmarshal(b []byte) error

type QueryFollowedListRsp 

type QueryFollowedListRsp struct {
	FollowedIdArr        []int64  `protobuf:"varint,1,rep,packed,name=FollowedIdArr,proto3" json:"FollowedIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFollowedListRsp) Descriptor 

func (*QueryFollowedListRsp) Descriptor() ([]byte, []int)

func (*QueryFollowedListRsp) GetFollowedIdArr 

func (m *QueryFollowedListRsp) GetFollowedIdArr() []int64

func (*QueryFollowedListRsp) ProtoMessage 

func (*QueryFollowedListRsp) ProtoMessage()

func (*QueryFollowedListRsp) Reset 

func (m *QueryFollowedListRsp) Reset()

func (*QueryFollowedListRsp) String 

func (m *QueryFollowedListRsp) String() string

func (*QueryFollowedListRsp) XXX_DiscardUnknown 

func (m *QueryFollowedListRsp) XXX_DiscardUnknown()

func (*QueryFollowedListRsp) XXX_Marshal 

func (m *QueryFollowedListRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFollowedListRsp) XXX_Merge 

func (m *QueryFollowedListRsp) XXX_Merge(src proto.Message)

func (*QueryFollowedListRsp) XXX_Size 

func (m *QueryFollowedListRsp) XXX_Size() int

func (*QueryFollowedListRsp) XXX_Unmarshal 

func (m *QueryFollowedListRsp) XXX_Unmarshal(b []byte) error

type QuerySvrAddrReq 

type QuerySvrAddrReq struct {
	LastRefreshTime      int64    `protobuf:"varint,1,opt,name=LastRefreshTime,proto3" json:"LastRefreshTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QuerySvrAddrReq) Descriptor 

func (*QuerySvrAddrReq) Descriptor() ([]byte, []int)

func (*QuerySvrAddrReq) GetLastRefreshTime 

func (m *QuerySvrAddrReq) GetLastRefreshTime() int64

func (*QuerySvrAddrReq) ProtoMessage 

func (*QuerySvrAddrReq) ProtoMessage()

func (*QuerySvrAddrReq) Reset 

func (m *QuerySvrAddrReq) Reset()

func (*QuerySvrAddrReq) String 

func (m *QuerySvrAddrReq) String() string

func (*QuerySvrAddrReq) XXX_DiscardUnknown 

func (m *QuerySvrAddrReq) XXX_DiscardUnknown()

func (*QuerySvrAddrReq) XXX_Marshal 

func (m *QuerySvrAddrReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySvrAddrReq) XXX_Merge 

func (m *QuerySvrAddrReq) XXX_Merge(src proto.Message)

func (*QuerySvrAddrReq) XXX_Size 

func (m *QuerySvrAddrReq) XXX_Size() int

func (*QuerySvrAddrReq) XXX_Unmarshal 

func (m *QuerySvrAddrReq) XXX_Unmarshal(b []byte) error

type QuerySvrAddrRsp 

type QuerySvrAddrRsp struct {
	AnsTime              int64    `protobuf:"varint,1,opt,name=AnsTime,proto3" json:"AnsTime,omitempty"`
	NeedRefresh          bool     `protobuf:"varint,2,opt,name=NeedRefresh,proto3" json:"NeedRefresh,omitempty"`
	Addr                 string   `protobuf:"bytes,3,opt,name=Addr,proto3" json:"Addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QuerySvrAddrRsp) Descriptor 

func (*QuerySvrAddrRsp) Descriptor() ([]byte, []int)

func (*QuerySvrAddrRsp) GetAddr 

func (m *QuerySvrAddrRsp) GetAddr() string

func (*QuerySvrAddrRsp) GetAnsTime 

func (m *QuerySvrAddrRsp) GetAnsTime() int64

func (*QuerySvrAddrRsp) GetNeedRefresh 

func (m *QuerySvrAddrRsp) GetNeedRefresh() bool

func (*QuerySvrAddrRsp) ProtoMessage 

func (*QuerySvrAddrRsp) ProtoMessage()

func (*QuerySvrAddrRsp) Reset 

func (m *QuerySvrAddrRsp) Reset()

func (*QuerySvrAddrRsp) String 

func (m *QuerySvrAddrRsp) String() string

func (*QuerySvrAddrRsp) XXX_DiscardUnknown 

func (m *QuerySvrAddrRsp) XXX_DiscardUnknown()

func (*QuerySvrAddrRsp) XXX_Marshal 

func (m *QuerySvrAddrRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySvrAddrRsp) XXX_Merge 

func (m *QuerySvrAddrRsp) XXX_Merge(src proto.Message)

func (*QuerySvrAddrRsp) XXX_Size 

func (m *QuerySvrAddrRsp) XXX_Size() int

func (*QuerySvrAddrRsp) XXX_Unmarshal 

func (m *QuerySvrAddrRsp) XXX_Unmarshal(b []byte) error

type QueryUserMsgIdSvrAddrReq 

type QueryUserMsgIdSvrAddrReq struct {
	UserIdArr            []int64  `protobuf:"varint,1,rep,packed,name=UserIdArr,proto3" json:"UserIdArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryUserMsgIdSvrAddrReq) Descriptor 

func (*QueryUserMsgIdSvrAddrReq) Descriptor() ([]byte, []int)

func (*QueryUserMsgIdSvrAddrReq) GetUserIdArr 

func (m *QueryUserMsgIdSvrAddrReq) GetUserIdArr() []int64

func (*QueryUserMsgIdSvrAddrReq) ProtoMessage 

func (*QueryUserMsgIdSvrAddrReq) ProtoMessage()

func (*QueryUserMsgIdSvrAddrReq) Reset 

func (m *QueryUserMsgIdSvrAddrReq) Reset()

func (*QueryUserMsgIdSvrAddrReq) String 

func (m *QueryUserMsgIdSvrAddrReq) String() string

func (*QueryUserMsgIdSvrAddrReq) XXX_DiscardUnknown 

func (m *QueryUserMsgIdSvrAddrReq) XXX_DiscardUnknown()

func (*QueryUserMsgIdSvrAddrReq) XXX_Marshal 

func (m *QueryUserMsgIdSvrAddrReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUserMsgIdSvrAddrReq) XXX_Merge 

func (m *QueryUserMsgIdSvrAddrReq) XXX_Merge(src proto.Message)

func (*QueryUserMsgIdSvrAddrReq) XXX_Size 

func (m *QueryUserMsgIdSvrAddrReq) XXX_Size() int

func (*QueryUserMsgIdSvrAddrReq) XXX_Unmarshal 

func (m *QueryUserMsgIdSvrAddrReq) XXX_Unmarshal(b []byte) error

type QueryUserMsgIdSvrAddrRsp 

type QueryUserMsgIdSvrAddrRsp struct {
	DataArr              []*MsgIdSvrAddrAndUserId `protobuf:"bytes,1,rep,name=DataArr,proto3" json:"DataArr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*QueryUserMsgIdSvrAddrRsp) Descriptor 

func (*QueryUserMsgIdSvrAddrRsp) Descriptor() ([]byte, []int)

func (*QueryUserMsgIdSvrAddrRsp) GetDataArr 

func (m *QueryUserMsgIdSvrAddrRsp) GetDataArr() []*MsgIdSvrAddrAndUserId

func (*QueryUserMsgIdSvrAddrRsp) ProtoMessage 

func (*QueryUserMsgIdSvrAddrRsp) ProtoMessage()

func (*QueryUserMsgIdSvrAddrRsp) Reset 

func (m *QueryUserMsgIdSvrAddrRsp) Reset()

func (*QueryUserMsgIdSvrAddrRsp) String 

func (m *QueryUserMsgIdSvrAddrRsp) String() string

func (*QueryUserMsgIdSvrAddrRsp) XXX_DiscardUnknown 

func (m *QueryUserMsgIdSvrAddrRsp) XXX_DiscardUnknown()

func (*QueryUserMsgIdSvrAddrRsp) XXX_Marshal 

func (m *QueryUserMsgIdSvrAddrRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUserMsgIdSvrAddrRsp) XXX_Merge 

func (m *QueryUserMsgIdSvrAddrRsp) XXX_Merge(src proto.Message)

func (*QueryUserMsgIdSvrAddrRsp) XXX_Size 

func (m *QueryUserMsgIdSvrAddrRsp) XXX_Size() int

func (*QueryUserMsgIdSvrAddrRsp) XXX_Unmarshal 

func (m *QueryUserMsgIdSvrAddrRsp) XXX_Unmarshal(b []byte) error

type RelationChangeSvrClient 

type RelationChangeSvrClient interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(ctx context.Context, opts ...grpc.CallOption) (RelationChangeSvr_CreateStreamClient, error)
}

RelationChangeSvrClient is the client API for RelationChangeSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRelationChangeSvrClient 

func NewRelationChangeSvrClient(cc *grpc.ClientConn) RelationChangeSvrClient

type RelationChangeSvrServer 

type RelationChangeSvrServer interface {
	//建立双向stream，后续req和rsp通过此通道传送
	CreateStream(RelationChangeSvr_CreateStreamServer) error
}

RelationChangeSvrServer is the server API for RelationChangeSvr service.

type RelationChangeSvr_CreateStreamClient 

type RelationChangeSvr_CreateStreamClient interface {
	Send(*RelationChgReq) error
	Recv() (*RelationChgRsp, error)
	grpc.ClientStream
}

type RelationChangeSvr_CreateStreamServer 

type RelationChangeSvr_CreateStreamServer interface {
	Send(*RelationChgRsp) error
	Recv() (*RelationChgReq, error)
	grpc.ServerStream
}

type RelationChgReq 

type RelationChgReq struct {
	FrontReqId           int64    `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	Follow               bool     `protobuf:"varint,2,opt,name=Follow,proto3" json:"Follow,omitempty"`
	UserId               int64    `protobuf:"varint,3,opt,name=UserId,proto3" json:"UserId,omitempty"`
	FollowedUserId       int64    `protobuf:"varint,4,opt,name=FollowedUserId,proto3" json:"FollowedUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RelationChgReq) Descriptor 

func (*RelationChgReq) Descriptor() ([]byte, []int)

func (*RelationChgReq) GetFollow 

func (m *RelationChgReq) GetFollow() bool

func (*RelationChgReq) GetFollowedUserId 

func (m *RelationChgReq) GetFollowedUserId() int64

func (*RelationChgReq) GetFrontReqId 

func (m *RelationChgReq) GetFrontReqId() int64

func (*RelationChgReq) GetUserId 

func (m *RelationChgReq) GetUserId() int64

func (*RelationChgReq) ProtoMessage 

func (*RelationChgReq) ProtoMessage()

func (*RelationChgReq) Reset 

func (m *RelationChgReq) Reset()

func (*RelationChgReq) String 

func (m *RelationChgReq) String() string

func (*RelationChgReq) XXX_DiscardUnknown 

func (m *RelationChgReq) XXX_DiscardUnknown()

func (*RelationChgReq) XXX_Marshal 

func (m *RelationChgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelationChgReq) XXX_Merge 

func (m *RelationChgReq) XXX_Merge(src proto.Message)

func (*RelationChgReq) XXX_Size 

func (m *RelationChgReq) XXX_Size() int

func (*RelationChgReq) XXX_Unmarshal 

func (m *RelationChgReq) XXX_Unmarshal(b []byte) error

type RelationChgRsp 

type RelationChgRsp struct {
	FrontReqId           int64    `protobuf:"varint,1,opt,name=frontReqId,proto3" json:"frontReqId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RelationChgRsp) Descriptor 

func (*RelationChgRsp) Descriptor() ([]byte, []int)

func (*RelationChgRsp) GetFrontReqId 

func (m *RelationChgRsp) GetFrontReqId() int64

func (*RelationChgRsp) ProtoMessage 

func (*RelationChgRsp) ProtoMessage()

func (*RelationChgRsp) Reset 

func (m *RelationChgRsp) Reset()

func (*RelationChgRsp) String 

func (m *RelationChgRsp) String() string

func (*RelationChgRsp) XXX_DiscardUnknown 

func (m *RelationChgRsp) XXX_DiscardUnknown()

func (*RelationChgRsp) XXX_Marshal 

func (m *RelationChgRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelationChgRsp) XXX_Merge 

func (m *RelationChgRsp) XXX_Merge(src proto.Message)

func (*RelationChgRsp) XXX_Size 

func (m *RelationChgRsp) XXX_Size() int

func (*RelationChgRsp) XXX_Unmarshal 

func (m *RelationChgRsp) XXX_Unmarshal(b []byte) error

type UnFollowReq 

type UnFollowReq struct {
	UserId               int64    `protobuf:"varint,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	UnFollowedUserId     int64    `protobuf:"varint,2,opt,name=UnFollowedUserId,proto3" json:"UnFollowedUserId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnFollowReq) Descriptor 

func (*UnFollowReq) Descriptor() ([]byte, []int)

func (*UnFollowReq) GetUnFollowedUserId 

func (m *UnFollowReq) GetUnFollowedUserId() int64

func (*UnFollowReq) GetUserId 

func (m *UnFollowReq) GetUserId() int64

func (*UnFollowReq) ProtoMessage 

func (*UnFollowReq) ProtoMessage()

func (*UnFollowReq) Reset 

func (m *UnFollowReq) Reset()

func (*UnFollowReq) String 

func (m *UnFollowReq) String() string

func (*UnFollowReq) XXX_DiscardUnknown 

func (m *UnFollowReq) XXX_DiscardUnknown()

func (*UnFollowReq) XXX_Marshal 

func (m *UnFollowReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnFollowReq) XXX_Merge 

func (m *UnFollowReq) XXX_Merge(src proto.Message)

func (*UnFollowReq) XXX_Size 

func (m *UnFollowReq) XXX_Size() int

func (*UnFollowReq) XXX_Unmarshal 

func (m *UnFollowReq) XXX_Unmarshal(b []byte) error

type UnFollowRsp 

type UnFollowRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnFollowRsp) Descriptor 

func (*UnFollowRsp) Descriptor() ([]byte, []int)

func (*UnFollowRsp) ProtoMessage 

func (*UnFollowRsp) ProtoMessage()

func (*UnFollowRsp) Reset 

func (m *UnFollowRsp) Reset()

func (*UnFollowRsp) String 

func (m *UnFollowRsp) String() string

func (*UnFollowRsp) XXX_DiscardUnknown 

func (m *UnFollowRsp) XXX_DiscardUnknown()

func (*UnFollowRsp) XXX_Marshal 

func (m *UnFollowRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnFollowRsp) XXX_Merge 

func (m *UnFollowRsp) XXX_Merge(src proto.Message)

func (*UnFollowRsp) XXX_Size 

func (m *UnFollowRsp) XXX_Size() int

func (*UnFollowRsp) XXX_Unmarshal 

func (m *UnFollowRsp) XXX_Unmarshal(b []byte) error

type UnimplementedContentSvrServer 

type UnimplementedContentSvrServer struct {
}

UnimplementedContentSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedContentSvrServer) DeleteMsg 

func (*UnimplementedContentSvrServer) DeleteMsg(ctx context.Context, req *DeleteMsgReq) (*DeleteMsgRsp, error)

func (*UnimplementedContentSvrServer) PostMsg 

func (*UnimplementedContentSvrServer) PostMsg(ctx context.Context, req *PostMsgContentReq) (*PostMsgContentRsp, error)

func (*UnimplementedContentSvrServer) PullMsg 

func (*UnimplementedContentSvrServer) PullMsg(ctx context.Context, req *PullMsgContentReq) (*PullMsgContentRsp, error)

type UnimplementedDbSvrServer 

type UnimplementedDbSvrServer struct {
}

UnimplementedDbSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedDbSvrServer) Follow 

func (*UnimplementedDbSvrServer) Follow(ctx context.Context, req *DBFollowReq) (*DBFollowRsp, error)

func (*UnimplementedDbSvrServer) Post 

func (*UnimplementedDbSvrServer) Post(ctx context.Context, req *DBPostReq) (*DBPostRsp, error)

func (*UnimplementedDbSvrServer) QueryFollow 

func (*UnimplementedDbSvrServer) QueryFollow(ctx context.Context, req *DBQueryFollowReq) (*DBQueryFollowRsp, error)

func (*UnimplementedDbSvrServer) QueryFollower 

func (*UnimplementedDbSvrServer) QueryFollower(ctx context.Context, req *DBQueryFollowerReq) (*DBQueryFollowerRsp, error)

func (*UnimplementedDbSvrServer) QueryMsgContent 

func (*UnimplementedDbSvrServer) QueryMsgContent(ctx context.Context, req *DBQueryMsgContentReq) (*DBQueryMsgContentRsp, error)

func (*UnimplementedDbSvrServer) QueryUserMsgId 

func (*UnimplementedDbSvrServer) QueryUserMsgId(ctx context.Context, req *DBQueryUserMsgIdReq) (*DBQueryUserMsgIdRsp, error)

func (*UnimplementedDbSvrServer) UnFollow 

func (*UnimplementedDbSvrServer) UnFollow(ctx context.Context, req *DBUnFollowReq) (*DBUnFollowRsp, error)

type UnimplementedFollowSvrServer 

type UnimplementedFollowSvrServer struct {
}

UnimplementedFollowSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedFollowSvrServer) Follow 

func (*UnimplementedFollowSvrServer) Follow(ctx context.Context, req *FollowReq) (*FollowRsp, error)

func (*UnimplementedFollowSvrServer) QueryFollowList 

func (*UnimplementedFollowSvrServer) QueryFollowList(ctx context.Context, req *QueryFollowListReq) (*QueryFollowListRsp, error)

func (*UnimplementedFollowSvrServer) UnFollow 

func (*UnimplementedFollowSvrServer) UnFollow(ctx context.Context, req *UnFollowReq) (*UnFollowRsp, error)

type UnimplementedFollowedSvrServer 

type UnimplementedFollowedSvrServer struct {
}

UnimplementedFollowedSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedFollowedSvrServer) Follow 

func (*UnimplementedFollowedSvrServer) Follow(ctx context.Context, req *FollowReq) (*FollowRsp, error)

func (*UnimplementedFollowedSvrServer) Offline 

func (*UnimplementedFollowedSvrServer) Offline(ctx context.Context, req *OfflineReq) (*OfflineRsp, error)

func (*UnimplementedFollowedSvrServer) Online 

func (*UnimplementedFollowedSvrServer) Online(ctx context.Context, req *OnlineReq) (*OnlineRsp, error)

func (*UnimplementedFollowedSvrServer) QueryFollowedList 

func (*UnimplementedFollowedSvrServer) QueryFollowedList(ctx context.Context, req *QueryFollowedListReq) (*QueryFollowedListRsp, error)

func (*UnimplementedFollowedSvrServer) QueryOnlineFollowedList 

func (*UnimplementedFollowedSvrServer) QueryOnlineFollowedList(ctx context.Context, req *QueryFollowedListReq) (*QueryFollowedListRsp, error)

func (*UnimplementedFollowedSvrServer) UnFollow 

func (*UnimplementedFollowedSvrServer) UnFollow(ctx context.Context, req *UnFollowReq) (*UnFollowRsp, error)

type UnimplementedFrontNotifySvrMngServer 

type UnimplementedFrontNotifySvrMngServer struct {
}

UnimplementedFrontNotifySvrMngServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontNotifySvrMngServer) QueryMyFrontNotifySvr 

func (*UnimplementedFrontNotifySvrMngServer) QueryMyFrontNotifySvr(ctx context.Context, req *CClientAuthInfo) (*CFrontNotifySvrAddr, error)

type UnimplementedFrontNotifySvrServer 

type UnimplementedFrontNotifySvrServer struct {
}

UnimplementedFrontNotifySvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontNotifySvrServer) CheckAvail 

func (*UnimplementedFrontNotifySvrServer) CheckAvail(ctx context.Context, req *FrontNotifyCheckAvailReq) (*FrontNotifyCheckAvailRsp, error)

func (*UnimplementedFrontNotifySvrServer) CreateNotifyStream 

func (*UnimplementedFrontNotifySvrServer) CreateNotifyStream(req *CCreateNotifyStreamReq, srv FrontNotifySvr_CreateNotifyStreamServer) error

func (*UnimplementedFrontNotifySvrServer) HeartBeat 

func (*UnimplementedFrontNotifySvrServer) HeartBeat(ctx context.Context, req *CHeartBeatReq) (*CHeartBeatRsp, error)

func (*UnimplementedFrontNotifySvrServer) Offline 

func (*UnimplementedFrontNotifySvrServer) Offline(ctx context.Context, req *COfflineReq) (*COfflineRsp, error)

type UnimplementedFrontSvrMngServer 

type UnimplementedFrontSvrMngServer struct {
}

UnimplementedFrontSvrMngServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontSvrMngServer) QueryMyFrontSvr 

func (*UnimplementedFrontSvrMngServer) QueryMyFrontSvr(ctx context.Context, req *CClientAuthInfo) (*CFrontSvrAddr, error)

type UnimplementedFrontSvrServer 

type UnimplementedFrontSvrServer struct {
}

UnimplementedFrontSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontSvrServer) CheckAvail 

func (*UnimplementedFrontSvrServer) CheckAvail(ctx context.Context, req *FrontCheckAvailReq) (*FrontCheckAvailRsp, error)

func (*UnimplementedFrontSvrServer) Follow 

func (*UnimplementedFrontSvrServer) Follow(ctx context.Context, req *CFollowReq) (*CFollowRsp, error)

func (*UnimplementedFrontSvrServer) Like 

func (*UnimplementedFrontSvrServer) Like(ctx context.Context, req *CLikeReq) (*CLikeRsp, error)

func (*UnimplementedFrontSvrServer) Post 

func (*UnimplementedFrontSvrServer) Post(ctx context.Context, req *CPostReq) (*CPostRsp, error)

func (*UnimplementedFrontSvrServer) Pull 

func (*UnimplementedFrontSvrServer) Pull(ctx context.Context, req *CPullReq) (*CPullRsp, error)

func (*UnimplementedFrontSvrServer) UnFollow 

func (*UnimplementedFrontSvrServer) UnFollow(ctx context.Context, req *CUnFollowReq) (*CUnFollowRsp, error)

type UnimplementedMsgIdGeneratorServer 

type UnimplementedMsgIdGeneratorServer struct {
}

UnimplementedMsgIdGeneratorServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgIdGeneratorServer) GenMsgId 

func (*UnimplementedMsgIdGeneratorServer) GenMsgId(ctx context.Context, req *GenMsgIdReq) (*GenMsgIdRsp, error)

type UnimplementedPostSvrServer 

type UnimplementedPostSvrServer struct {
}

UnimplementedPostSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedPostSvrServer) CheckAvail 

func (*UnimplementedPostSvrServer) CheckAvail(ctx context.Context, req *CheckAvailReq) (*CheckAvailRsp, error)

func (*UnimplementedPostSvrServer) CreateStream 

func (*UnimplementedPostSvrServer) CreateStream(srv PostSvr_CreateStreamServer) error

type UnimplementedPullSvrServer 

type UnimplementedPullSvrServer struct {
}

UnimplementedPullSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedPullSvrServer) CheckAvail 

func (*UnimplementedPullSvrServer) CheckAvail(ctx context.Context, req *CheckAvailReq) (*CheckAvailRsp, error)

func (*UnimplementedPullSvrServer) CreateStream 

func (*UnimplementedPullSvrServer) CreateStream(srv PullSvr_CreateStreamServer) error

type UnimplementedPushSvrServer 

type UnimplementedPushSvrServer struct {
}

UnimplementedPushSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedPushSvrServer) CreateNotifyStream 

func (*UnimplementedPushSvrServer) CreateNotifyStream(req *CreateNotifyStreamReq, srv PushSvr_CreateNotifyStreamServer) error

func (*UnimplementedPushSvrServer) Offline 

func (*UnimplementedPushSvrServer) Offline(ctx context.Context, req *OfflineReq) (*OfflineRsp, error)

func (*UnimplementedPushSvrServer) Online 

func (*UnimplementedPushSvrServer) Online(ctx context.Context, req *OnlineReq) (*OnlineRsp, error)

func (*UnimplementedPushSvrServer) Push 

func (*UnimplementedPushSvrServer) Push(ctx context.Context, req *PushReq) (*PushRsp, error)

type UnimplementedRelationChangeSvrServer 

type UnimplementedRelationChangeSvrServer struct {
}

UnimplementedRelationChangeSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedRelationChangeSvrServer) CreateStream 

func (*UnimplementedRelationChangeSvrServer) CreateStream(srv RelationChangeSvr_CreateStreamServer) error

type UnimplementedUserMsgIdSvrMngServer 

type UnimplementedUserMsgIdSvrMngServer struct {
}

UnimplementedUserMsgIdSvrMngServer can be embedded to have forward compatible implementations.

func (*UnimplementedUserMsgIdSvrMngServer) QueryUserMsgIdSvrAdd 

func (*UnimplementedUserMsgIdSvrMngServer) QueryUserMsgIdSvrAdd(ctx context.Context, req *QueryUserMsgIdSvrAddrReq) (*QueryUserMsgIdSvrAddrRsp, error)

type UnimplementedUserMsgIdSvrServer 

type UnimplementedUserMsgIdSvrServer struct {
}

UnimplementedUserMsgIdSvrServer can be embedded to have forward compatible implementations.

func (*UnimplementedUserMsgIdSvrServer) DeleteMsg 

func (*UnimplementedUserMsgIdSvrServer) DeleteMsg(ctx context.Context, req *DeleteMsgReq) (*DeleteMsgRsp, error)

func (*UnimplementedUserMsgIdSvrServer) PostMsg 

func (*UnimplementedUserMsgIdSvrServer) PostMsg(ctx context.Context, req *PostMsgIdReq) (*PostMsgIdRsp, error)

func (*UnimplementedUserMsgIdSvrServer) PullMsg 

func (*UnimplementedUserMsgIdSvrServer) PullMsg(ctx context.Context, req *PullMsgIdReq) (*PullMsgIdRsp, error)

type UserMsgIdSvrClient 

type UserMsgIdSvrClient interface {
	PullMsg(ctx context.Context, in *PullMsgIdReq, opts ...grpc.CallOption) (*PullMsgIdRsp, error)
	PostMsg(ctx context.Context, in *PostMsgIdReq, opts ...grpc.CallOption) (*PostMsgIdRsp, error)
	DeleteMsg(ctx context.Context, in *DeleteMsgReq, opts ...grpc.CallOption) (*DeleteMsgRsp, error)
}

UserMsgIdSvrClient is the client API for UserMsgIdSvr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUserMsgIdSvrClient 

func NewUserMsgIdSvrClient(cc *grpc.ClientConn) UserMsgIdSvrClient

type UserMsgIdSvrMngClient 

type UserMsgIdSvrMngClient interface {
	//批量传入userId查询，根据svr分组然后回复
	QueryUserMsgIdSvrAdd(ctx context.Context, in *QueryUserMsgIdSvrAddrReq, opts ...grpc.CallOption) (*QueryUserMsgIdSvrAddrRsp, error)
}

UserMsgIdSvrMngClient is the client API for UserMsgIdSvrMng service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUserMsgIdSvrMngClient 

func NewUserMsgIdSvrMngClient(cc *grpc.ClientConn) UserMsgIdSvrMngClient

type UserMsgIdSvrMngServer 

type UserMsgIdSvrMngServer interface {
	//批量传入userId查询，根据svr分组然后回复
	QueryUserMsgIdSvrAdd(context.Context, *QueryUserMsgIdSvrAddrReq) (*QueryUserMsgIdSvrAddrRsp, error)
}

UserMsgIdSvrMngServer is the server API for UserMsgIdSvrMng service.

type UserMsgIdSvrServer 

type UserMsgIdSvrServer interface {
	PullMsg(context.Context, *PullMsgIdReq) (*PullMsgIdRsp, error)
	PostMsg(context.Context, *PostMsgIdReq) (*PostMsgIdRsp, error)
	DeleteMsg(context.Context, *DeleteMsgReq) (*DeleteMsgRsp, error)
}

UserMsgIdSvrServer is the server API for UserMsgIdSvr service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.