service

package
v0.0.0-...-69995ca Latest Latest
Warning

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

Go to latest
Published: Feb 4, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

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 NewGroupService(url string) Group

func NewGroupServiceWithSRV

func NewGroupServiceWithSRV(scheme string, srv *resty.SRVRecord) Group

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) Join

func (g *GroupHttp) Join(app string, req *rpc.JoinGroupReq) error

func (*GroupHttp) Members

func (g *GroupHttp) Members(app string, req *rpc.GroupMembersReq) (*rpc.GroupMembersResp, error)

func (*GroupHttp) Quit

func (g *GroupHttp) Quit(app string, req *rpc.QuitGroupReq) error

func (*GroupHttp) Req

func (g *GroupHttp) Req() *resty.Request

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

func NewMessageService(url string) Message

func NewMessageServiceWithSRV

func NewMessageServiceWithSRV(scheme string, srv *resty.SRVRecord) Message

type MessageHttp

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

func (*MessageHttp) GetMessageContent

func (*MessageHttp) GetMessageIndex

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

Jump to

Keyboard shortcuts

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