Documentation ¶
Index ¶
- type Group
- type GroupHttp
- func (g *GroupHttp) Create(app string, req *rpc.CreateGroupReq) (*rpc.CreateGroupResp, error)
- func (g *GroupHttp) Detail(app string, req *rpc.GetGroupReq) (*rpc.GetGroupResp, error)
- func (g *GroupHttp) Join(app string, req *rpc.JoinGroupReq) error
- func (g *GroupHttp) Members(app string, req *rpc.GroupMembersReq) (*rpc.GroupMembersResp, error)
- func (g *GroupHttp) Quit(app string, req *rpc.QuitGroupReq) error
- func (g *GroupHttp) Req() *resty.Request
- type Message
- type MessageHttp
- func (m *MessageHttp) GetMessageContent(app string, req *rpc.GetOfflineMessageContentReq) (*rpc.GetOfflineMessageContentResp, error)
- func (m *MessageHttp) GetMessageIndex(app string, req *rpc.GetOfflineMessageIndexReq) (*rpc.GetOfflineMessageIndexResp, error)
- func (m *MessageHttp) InsertGroup(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error)
- func (m *MessageHttp) InsertUser(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error)
- func (m *MessageHttp) Req() *resty.Request
- func (m *MessageHttp) SetAck(app string, req *rpc.AckMessageReq) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Group ¶
type Group interface { Create(app string, req *rpc.CreateGroupReq) (*rpc.CreateGroupResp, error) Members(app string, req *rpc.GroupMembersReq) (*rpc.GroupMembersResp, error) Join(app string, req *rpc.JoinGroupReq) error Quit(app string, req *rpc.QuitGroupReq) error Detail(app string, req *rpc.GetGroupReq) (*rpc.GetGroupResp, error) }
func NewGroupService ¶
func NewGroupServiceWithSRV ¶
type GroupHttp ¶
type GroupHttp struct {
// contains filtered or unexported fields
}
func (*GroupHttp) Create ¶
func (g *GroupHttp) Create(app string, req *rpc.CreateGroupReq) (*rpc.CreateGroupResp, error)
func (*GroupHttp) Detail ¶
func (g *GroupHttp) Detail(app string, req *rpc.GetGroupReq) (*rpc.GetGroupResp, error)
func (*GroupHttp) Members ¶
func (g *GroupHttp) Members(app string, req *rpc.GroupMembersReq) (*rpc.GroupMembersResp, error)
type Message ¶
type Message interface { InsertUser(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error) InsertGroup(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error) SetAck(app string, req *rpc.AckMessageReq) error GetMessageIndex(app string, req *rpc.GetOfflineMessageIndexReq) (*rpc.GetOfflineMessageIndexResp, error) GetMessageContent(app string, req *rpc.GetOfflineMessageContentReq) (*rpc.GetOfflineMessageContentResp, error) }
func NewMessageService ¶
type MessageHttp ¶
type MessageHttp struct {
// contains filtered or unexported fields
}
func (*MessageHttp) GetMessageContent ¶
func (m *MessageHttp) GetMessageContent(app string, req *rpc.GetOfflineMessageContentReq) (*rpc.GetOfflineMessageContentResp, error)
func (*MessageHttp) GetMessageIndex ¶
func (m *MessageHttp) GetMessageIndex(app string, req *rpc.GetOfflineMessageIndexReq) (*rpc.GetOfflineMessageIndexResp, error)
func (*MessageHttp) InsertGroup ¶
func (m *MessageHttp) InsertGroup(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error)
func (*MessageHttp) InsertUser ¶
func (m *MessageHttp) InsertUser(app string, req *rpc.InsertMessageReq) (*rpc.InsertMessageResp, error)
func (*MessageHttp) Req ¶
func (m *MessageHttp) Req() *resty.Request
func (*MessageHttp) SetAck ¶
func (m *MessageHttp) SetAck(app string, req *rpc.AckMessageReq) error
Click to show internal directories.
Click to hide internal directories.