chat_rpc

package
v0.0.0-...-48d44df Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_chat_rpc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BaseResp

type BaseResp struct {
	StatusCode    int32  `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage string `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	ServiceTime   int64  `protobuf:"varint,3,opt,name=service_time,json=serviceTime,proto3" json:"service_time,omitempty"`
	// contains filtered or unexported fields
}

func (*BaseResp) Descriptor deprecated

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

Deprecated: Use BaseResp.ProtoReflect.Descriptor instead.

func (*BaseResp) FastRead

func (x *BaseResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*BaseResp) FastWrite

func (x *BaseResp) FastWrite(buf []byte) (offset int)

func (*BaseResp) GetServiceTime

func (x *BaseResp) GetServiceTime() int64

func (*BaseResp) GetStatusCode

func (x *BaseResp) GetStatusCode() int32

func (*BaseResp) GetStatusMessage

func (x *BaseResp) GetStatusMessage() string

func (*BaseResp) ProtoMessage

func (*BaseResp) ProtoMessage()

func (*BaseResp) ProtoReflect

func (x *BaseResp) ProtoReflect() protoreflect.Message

func (*BaseResp) Reset

func (x *BaseResp) Reset()

func (*BaseResp) Size

func (x *BaseResp) Size() (n int)

func (*BaseResp) String

func (x *BaseResp) String() string

type ChatService

type ChatService interface {
	FriendList(ctx context.Context, req *RPCFriendListReq) (res *RPCFriendListResp, err error)
	CreateMessage(ctx context.Context, req *RPCMessageCreateReq) (res *RPCMessageCreateResp, err error)
	MessageList(ctx context.Context, req *RPCMessageChatReq) (res *RPCMessageChatResp, err error)
}

type RPCFriendListReq

type RPCFriendListReq struct {
	UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCFriendListReq) Descriptor deprecated

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

Deprecated: Use RPCFriendListReq.ProtoReflect.Descriptor instead.

func (*RPCFriendListReq) FastRead

func (x *RPCFriendListReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCFriendListReq) FastWrite

func (x *RPCFriendListReq) FastWrite(buf []byte) (offset int)

func (*RPCFriendListReq) GetUserId

func (x *RPCFriendListReq) GetUserId() int64

func (*RPCFriendListReq) ProtoMessage

func (*RPCFriendListReq) ProtoMessage()

func (*RPCFriendListReq) ProtoReflect

func (x *RPCFriendListReq) ProtoReflect() protoreflect.Message

func (*RPCFriendListReq) Reset

func (x *RPCFriendListReq) Reset()

func (*RPCFriendListReq) Size

func (x *RPCFriendListReq) Size() (n int)

func (*RPCFriendListReq) String

func (x *RPCFriendListReq) String() string

type RPCFriendListResp

type RPCFriendListResp struct {
	BaseResp *BaseResp        `protobuf:"bytes,1,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	UserList []*RPCFriendUser `protobuf:"bytes,2,rep,name=user_list,json=userList,proto3" json:"user_list,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCFriendListResp) Descriptor deprecated

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

Deprecated: Use RPCFriendListResp.ProtoReflect.Descriptor instead.

func (*RPCFriendListResp) FastRead

func (x *RPCFriendListResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCFriendListResp) FastWrite

func (x *RPCFriendListResp) FastWrite(buf []byte) (offset int)

func (*RPCFriendListResp) GetBaseResp

func (x *RPCFriendListResp) GetBaseResp() *BaseResp

func (*RPCFriendListResp) GetUserList

func (x *RPCFriendListResp) GetUserList() []*RPCFriendUser

func (*RPCFriendListResp) ProtoMessage

func (*RPCFriendListResp) ProtoMessage()

func (*RPCFriendListResp) ProtoReflect

func (x *RPCFriendListResp) ProtoReflect() protoreflect.Message

func (*RPCFriendListResp) Reset

func (x *RPCFriendListResp) Reset()

func (*RPCFriendListResp) Size

func (x *RPCFriendListResp) Size() (n int)

func (*RPCFriendListResp) String

func (x *RPCFriendListResp) String() string

type RPCFriendUser

type RPCFriendUser struct {
	Id            int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                            // 用户id
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                         // 用户名称
	FollowCount   int64  `protobuf:"varint,3,opt,name=follow_count,json=followCount,proto3" json:"follow_count,omitempty"`       // 关注总数
	FollowerCount int64  `protobuf:"varint,4,opt,name=follower_count,json=followerCount,proto3" json:"follower_count,omitempty"` // 粉丝总数
	IsFollow      bool   `protobuf:"varint,5,opt,name=is_follow,json=isFollow,proto3" json:"is_follow,omitempty"`                // true-已关注,false-未关注
	Avatar        string `protobuf:"bytes,6,opt,name=avatar,proto3" json:"avatar,omitempty"`                                     // 用户头像Url
	Message       string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`                                   // 和该好友的最新聊天消息
	MsgType       int64  `protobuf:"varint,8,opt,name=msgType,proto3" json:"msgType,omitempty"`                                  // message消息的类型,0 => 当前请求用户接收的消息, 1 => 当前请求用户发送的消息
	// contains filtered or unexported fields
}

func (*RPCFriendUser) Descriptor deprecated

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

Deprecated: Use RPCFriendUser.ProtoReflect.Descriptor instead.

func (*RPCFriendUser) FastRead

func (x *RPCFriendUser) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCFriendUser) FastWrite

func (x *RPCFriendUser) FastWrite(buf []byte) (offset int)

func (*RPCFriendUser) GetAvatar

func (x *RPCFriendUser) GetAvatar() string

func (*RPCFriendUser) GetFollowCount

func (x *RPCFriendUser) GetFollowCount() int64

func (*RPCFriendUser) GetFollowerCount

func (x *RPCFriendUser) GetFollowerCount() int64

func (*RPCFriendUser) GetId

func (x *RPCFriendUser) GetId() int64

func (*RPCFriendUser) GetIsFollow

func (x *RPCFriendUser) GetIsFollow() bool

func (*RPCFriendUser) GetMessage

func (x *RPCFriendUser) GetMessage() string

func (*RPCFriendUser) GetMsgType

func (x *RPCFriendUser) GetMsgType() int64

func (*RPCFriendUser) GetName

func (x *RPCFriendUser) GetName() string

func (*RPCFriendUser) ProtoMessage

func (*RPCFriendUser) ProtoMessage()

func (*RPCFriendUser) ProtoReflect

func (x *RPCFriendUser) ProtoReflect() protoreflect.Message

func (*RPCFriendUser) Reset

func (x *RPCFriendUser) Reset()

func (*RPCFriendUser) Size

func (x *RPCFriendUser) Size() (n int)

func (*RPCFriendUser) String

func (x *RPCFriendUser) String() string

type RPCMessage

type RPCMessage struct {
	Id         int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                     // 消息id
	ToUserId   int64  `protobuf:"varint,2,opt,name=to_user_id,json=toUserId,proto3" json:"to_user_id,omitempty"`       // 该消息接收者的id
	FromUserId int64  `protobuf:"varint,3,opt,name=from_user_id,json=fromUserId,proto3" json:"from_user_id,omitempty"` // 该消息发送者的id
	Content    string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`                            // 消息内容
	CreateTime int64  `protobuf:"varint,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`   // 消息创建时间
	// contains filtered or unexported fields
}

func (*RPCMessage) Descriptor deprecated

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

Deprecated: Use RPCMessage.ProtoReflect.Descriptor instead.

func (*RPCMessage) FastRead

func (x *RPCMessage) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCMessage) FastWrite

func (x *RPCMessage) FastWrite(buf []byte) (offset int)

func (*RPCMessage) GetContent

func (x *RPCMessage) GetContent() string

func (*RPCMessage) GetCreateTime

func (x *RPCMessage) GetCreateTime() int64

func (*RPCMessage) GetFromUserId

func (x *RPCMessage) GetFromUserId() int64

func (*RPCMessage) GetId

func (x *RPCMessage) GetId() int64

func (*RPCMessage) GetToUserId

func (x *RPCMessage) GetToUserId() int64

func (*RPCMessage) ProtoMessage

func (*RPCMessage) ProtoMessage()

func (*RPCMessage) ProtoReflect

func (x *RPCMessage) ProtoReflect() protoreflect.Message

func (*RPCMessage) Reset

func (x *RPCMessage) Reset()

func (*RPCMessage) Size

func (x *RPCMessage) Size() (n int)

func (*RPCMessage) String

func (x *RPCMessage) String() string

type RPCMessageChatReq

type RPCMessageChatReq struct {
	ToUserId int64 `protobuf:"varint,1,opt,name=to_user_id,json=toUserId,proto3" json:"to_user_id,omitempty"`
	UserId   int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMessageChatReq) Descriptor deprecated

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

Deprecated: Use RPCMessageChatReq.ProtoReflect.Descriptor instead.

func (*RPCMessageChatReq) FastRead

func (x *RPCMessageChatReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCMessageChatReq) FastWrite

func (x *RPCMessageChatReq) FastWrite(buf []byte) (offset int)

func (*RPCMessageChatReq) GetToUserId

func (x *RPCMessageChatReq) GetToUserId() int64

func (*RPCMessageChatReq) GetUserId

func (x *RPCMessageChatReq) GetUserId() int64

func (*RPCMessageChatReq) ProtoMessage

func (*RPCMessageChatReq) ProtoMessage()

func (*RPCMessageChatReq) ProtoReflect

func (x *RPCMessageChatReq) ProtoReflect() protoreflect.Message

func (*RPCMessageChatReq) Reset

func (x *RPCMessageChatReq) Reset()

func (*RPCMessageChatReq) Size

func (x *RPCMessageChatReq) Size() (n int)

func (*RPCMessageChatReq) String

func (x *RPCMessageChatReq) String() string

type RPCMessageChatResp

type RPCMessageChatResp struct {
	BaseResp    *BaseResp     `protobuf:"bytes,1,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	MessageList []*RPCMessage `protobuf:"bytes,2,rep,name=message_list,json=messageList,proto3" json:"message_list,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMessageChatResp) Descriptor deprecated

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

Deprecated: Use RPCMessageChatResp.ProtoReflect.Descriptor instead.

func (*RPCMessageChatResp) FastRead

func (x *RPCMessageChatResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCMessageChatResp) FastWrite

func (x *RPCMessageChatResp) FastWrite(buf []byte) (offset int)

func (*RPCMessageChatResp) GetBaseResp

func (x *RPCMessageChatResp) GetBaseResp() *BaseResp

func (*RPCMessageChatResp) GetMessageList

func (x *RPCMessageChatResp) GetMessageList() []*RPCMessage

func (*RPCMessageChatResp) ProtoMessage

func (*RPCMessageChatResp) ProtoMessage()

func (*RPCMessageChatResp) ProtoReflect

func (x *RPCMessageChatResp) ProtoReflect() protoreflect.Message

func (*RPCMessageChatResp) Reset

func (x *RPCMessageChatResp) Reset()

func (*RPCMessageChatResp) Size

func (x *RPCMessageChatResp) Size() (n int)

func (*RPCMessageChatResp) String

func (x *RPCMessageChatResp) String() string

type RPCMessageCreateReq

type RPCMessageCreateReq struct {
	ToUserId   int64  `protobuf:"varint,1,opt,name=to_user_id,json=toUserId,proto3" json:"to_user_id,omitempty"`
	FromUserId int64  `protobuf:"varint,2,opt,name=from_user_id,json=fromUserId,proto3" json:"from_user_id,omitempty"`
	Content    string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMessageCreateReq) Descriptor deprecated

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

Deprecated: Use RPCMessageCreateReq.ProtoReflect.Descriptor instead.

func (*RPCMessageCreateReq) FastRead

func (x *RPCMessageCreateReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCMessageCreateReq) FastWrite

func (x *RPCMessageCreateReq) FastWrite(buf []byte) (offset int)

func (*RPCMessageCreateReq) GetContent

func (x *RPCMessageCreateReq) GetContent() string

func (*RPCMessageCreateReq) GetFromUserId

func (x *RPCMessageCreateReq) GetFromUserId() int64

func (*RPCMessageCreateReq) GetToUserId

func (x *RPCMessageCreateReq) GetToUserId() int64

func (*RPCMessageCreateReq) ProtoMessage

func (*RPCMessageCreateReq) ProtoMessage()

func (*RPCMessageCreateReq) ProtoReflect

func (x *RPCMessageCreateReq) ProtoReflect() protoreflect.Message

func (*RPCMessageCreateReq) Reset

func (x *RPCMessageCreateReq) Reset()

func (*RPCMessageCreateReq) Size

func (x *RPCMessageCreateReq) Size() (n int)

func (*RPCMessageCreateReq) String

func (x *RPCMessageCreateReq) String() string

type RPCMessageCreateResp

type RPCMessageCreateResp struct {
	BaseResp *BaseResp   `protobuf:"bytes,1,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	Message  *RPCMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMessageCreateResp) Descriptor deprecated

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

Deprecated: Use RPCMessageCreateResp.ProtoReflect.Descriptor instead.

func (*RPCMessageCreateResp) FastRead

func (x *RPCMessageCreateResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*RPCMessageCreateResp) FastWrite

func (x *RPCMessageCreateResp) FastWrite(buf []byte) (offset int)

func (*RPCMessageCreateResp) GetBaseResp

func (x *RPCMessageCreateResp) GetBaseResp() *BaseResp

func (*RPCMessageCreateResp) GetMessage

func (x *RPCMessageCreateResp) GetMessage() *RPCMessage

func (*RPCMessageCreateResp) ProtoMessage

func (*RPCMessageCreateResp) ProtoMessage()

func (*RPCMessageCreateResp) ProtoReflect

func (x *RPCMessageCreateResp) ProtoReflect() protoreflect.Message

func (*RPCMessageCreateResp) Reset

func (x *RPCMessageCreateResp) Reset()

func (*RPCMessageCreateResp) Size

func (x *RPCMessageCreateResp) Size() (n int)

func (*RPCMessageCreateResp) String

func (x *RPCMessageCreateResp) String() string

Directories

Path Synopsis
Code generated by Kitex v0.4.4.
Code generated by Kitex v0.4.4.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL