rpcclient

package
v3.6.1-beta.0 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2024 License: Apache-2.0 Imports: 26 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Auth 

type Auth struct {
	Client auth.AuthClient

	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewAuth 

func NewAuth(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Auth

type Conversation 

type Conversation struct {
	Client pbconversation.ConversationClient

	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewConversation 

func NewConversation(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Conversation

type ConversationRpcClient 

type ConversationRpcClient Conversation

func NewConversationRpcClient 

func NewConversationRpcClient(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) ConversationRpcClient

func (*ConversationRpcClient) GetConversation 

func (c *ConversationRpcClient) GetConversation(ctx context.Context, ownerUserID, conversationID string) (*pbconversation.Conversation, error)

func (*ConversationRpcClient) GetConversationIDs 

func (c *ConversationRpcClient) GetConversationIDs(ctx context.Context, ownerUserID string) ([]string, error)

func (*ConversationRpcClient) GetConversationNotReceiveMessageUserIDs added in v3.7.0 

func (c *ConversationRpcClient) GetConversationNotReceiveMessageUserIDs(ctx context.Context, conversationID string) ([]string, error)

func (*ConversationRpcClient) GetConversationOfflinePushUserIDs added in v3.7.0 

func (c *ConversationRpcClient) GetConversationOfflinePushUserIDs(ctx context.Context, conversationID string, userIDs []string) ([]string, error)

func (*ConversationRpcClient) GetConversations 

func (c *ConversationRpcClient) GetConversations(ctx context.Context, ownerUserID string, conversationIDs []string) ([]*pbconversation.Conversation, error)

func (*ConversationRpcClient) GetConversationsByConversationID 

func (c *ConversationRpcClient) GetConversationsByConversationID(ctx context.Context, conversationIDs []string) ([]*pbconversation.Conversation, error)

func (*ConversationRpcClient) GetSingleConversationRecvMsgOpt 

func (c *ConversationRpcClient) GetSingleConversationRecvMsgOpt(ctx context.Context, userID, conversationID string) (int32, error)

func (*ConversationRpcClient) GroupChatFirstCreateConversation 

func (c *ConversationRpcClient) GroupChatFirstCreateConversation(ctx context.Context, groupID string, userIDs []string) error

func (*ConversationRpcClient) SetConversationMaxSeq 

func (c *ConversationRpcClient) SetConversationMaxSeq(ctx context.Context, ownerUserIDs []string, conversationID string, maxSeq int64) error

func (*ConversationRpcClient) SetConversations 

func (c *ConversationRpcClient) SetConversations(ctx context.Context, userIDs []string, conversation *pbconversation.ConversationReq) error

func (*ConversationRpcClient) SingleChatFirstCreateConversation 

func (c *ConversationRpcClient) SingleChatFirstCreateConversation(ctx context.Context, recvID, sendID,
	conversationID string, conversationType int32) error

type Friend 

type Friend struct {
	Client friend.FriendClient

	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewFriend 

func NewFriend(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Friend

type FriendRpcClient 

type FriendRpcClient Friend

func NewFriendRpcClient 

func NewFriendRpcClient(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) FriendRpcClient

func (*FriendRpcClient) GetFriendIDs 

func (f *FriendRpcClient) GetFriendIDs(ctx context.Context, ownerUserID string) (friendIDs []string, err error)

func (*FriendRpcClient) GetFriendsInfo 

func (f *FriendRpcClient) GetFriendsInfo(
	ctx context.Context,
	ownerUserID, friendUserID string,
) (resp *sdkws.FriendInfo, err error)

func (*FriendRpcClient) IsBlack added in v3.7.0 

func (b *FriendRpcClient) IsBlack(ctx context.Context, possibleBlackUserID, userID string) (bool, error)

func (*FriendRpcClient) IsFriend 

func (f *FriendRpcClient) IsFriend(ctx context.Context, possibleFriendUserID, userID string) (bool, error)

possibleFriendUserID Is PossibleFriendUserId's friends.

type Group 

type Group struct {
	Client group.GroupClient

	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewGroup 

func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Group

type GroupRpcClient 

type GroupRpcClient Group

func NewGroupRpcClient 

func NewGroupRpcClient(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) GroupRpcClient

func (*GroupRpcClient) DismissGroup 

func (g *GroupRpcClient) DismissGroup(ctx context.Context, groupID string) error

func (*GroupRpcClient) GetGroupInfo 

func (g *GroupRpcClient) GetGroupInfo(ctx context.Context, groupID string) (*sdkws.GroupInfo, error)

func (*GroupRpcClient) GetGroupInfoCache 

func (g *GroupRpcClient) GetGroupInfoCache(ctx context.Context, groupID string) (*sdkws.GroupInfo, error)

func (*GroupRpcClient) GetGroupInfoMap 

func (g *GroupRpcClient) GetGroupInfoMap(
	ctx context.Context,
	groupIDs []string,
	complete bool,
) (map[string]*sdkws.GroupInfo, error)

func (*GroupRpcClient) GetGroupInfos 

func (g *GroupRpcClient) GetGroupInfos(ctx context.Context, groupIDs []string, complete bool) ([]*sdkws.GroupInfo, error)

func (*GroupRpcClient) GetGroupMemberCache 

func (g *GroupRpcClient) GetGroupMemberCache(ctx context.Context, groupID string, groupMemberID string) (*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) GetGroupMemberIDs 

func (g *GroupRpcClient) GetGroupMemberIDs(ctx context.Context, groupID string) ([]string, error)

func (*GroupRpcClient) GetGroupMemberInfo 

func (g *GroupRpcClient) GetGroupMemberInfo(
	ctx context.Context,
	groupID string,
	userID string,
) (*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) GetGroupMemberInfoMap 

func (g *GroupRpcClient) GetGroupMemberInfoMap(
	ctx context.Context,
	groupID string,
	userIDs []string,
	complete bool,
) (map[string]*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) GetGroupMemberInfos 

func (g *GroupRpcClient) GetGroupMemberInfos(
	ctx context.Context,
	groupID string,
	userIDs []string,
	complete bool,
) ([]*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) GetOwnerAndAdminInfos 

func (g *GroupRpcClient) GetOwnerAndAdminInfos(
	ctx context.Context,
	groupID string,
) ([]*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) GetOwnerInfo 

func (g *GroupRpcClient) GetOwnerInfo(ctx context.Context, groupID string) (*sdkws.GroupMemberFullInfo, error)

func (*GroupRpcClient) NotificationUserInfoUpdate 

func (g *GroupRpcClient) NotificationUserInfoUpdate(ctx context.Context, userID string) error

type Message 

type Message struct {
	Client msg.MsgClient

	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewMessage 

func NewMessage(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Message

type MessageRpcClient 

type MessageRpcClient Message

func NewMessageRpcClient 

func NewMessageRpcClient(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) MessageRpcClient

func (*MessageRpcClient) GetConversationMaxSeq 

func (m *MessageRpcClient) GetConversationMaxSeq(ctx context.Context, conversationID string) (int64, error)

func (*MessageRpcClient) GetHasReadSeqs added in v3.5.0 

func (m *MessageRpcClient) GetHasReadSeqs(ctx context.Context, userID string, conversationIDs []string) (map[string]int64, error)

func (*MessageRpcClient) GetMaxSeq 

func (m *MessageRpcClient) GetMaxSeq(ctx context.Context, req *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error)

GetMaxSeq retrieves the maximum sequence number from the gRPC client. Errors during the gRPC call are wrapped to provide additional context.

func (*MessageRpcClient) GetMaxSeqs added in v3.5.0 

func (m *MessageRpcClient) GetMaxSeqs(ctx context.Context, conversationIDs []string) (map[string]int64, error)

func (*MessageRpcClient) GetMsgByConversationIDs added in v3.5.0 

func (m *MessageRpcClient) GetMsgByConversationIDs(ctx context.Context, docIDs []string, seqs map[string]int64) (map[string]*sdkws.MsgData, error)

func (*MessageRpcClient) PullMessageBySeqList 

func (m *MessageRpcClient) PullMessageBySeqList(ctx context.Context, req *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error)

PullMessageBySeqList retrieves messages by their sequence numbers using the gRPC client. It directly forwards the request to the gRPC client and returns the response along with any error encountered.

func (*MessageRpcClient) SendMsg 

func (m *MessageRpcClient) SendMsg(ctx context.Context, req *msg.SendMsgReq) (*msg.SendMsgResp, error)

SendMsg sends a message through the gRPC client and returns the response. It wraps any encountered error for better error handling and context understanding.

type NotificationOptions 

type NotificationOptions func(*notificationOpt)

func WithRpcGetUserName 

func WithRpcGetUserName() NotificationOptions

type NotificationSender 

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

func NewNotificationSender 

func NewNotificationSender(config *config.GlobalConfig, opts ...NotificationSenderOptions) *NotificationSender

func (*NotificationSender) Notification 

func (s *NotificationSender) Notification(ctx context.Context, sendID, recvID string, contentType int32, m proto.Message, opts ...NotificationOptions) error

func (*NotificationSender) NotificationWithSesstionType 

func (s *NotificationSender) NotificationWithSesstionType(ctx context.Context, sendID, recvID string, contentType, sesstionType int32, m proto.Message, opts ...NotificationOptions) (err error)

func (*NotificationSender) SetOptionsByContentType added in v3.5.0 

func (s *NotificationSender) SetOptionsByContentType(_ context.Context, options map[string]bool, contentType int32)

type NotificationSenderOptions 

type NotificationSenderOptions func(*NotificationSender)

func WithLocalSendMsg 

func WithLocalSendMsg(sendMsg func(ctx context.Context, req *msg.SendMsgReq) (*msg.SendMsgResp, error)) NotificationSenderOptions

func WithRpcClient 

func WithRpcClient(msgRpcClient *MessageRpcClient) NotificationSenderOptions

func WithUserRpcClient 

func WithUserRpcClient(userRpcClient *UserRpcClient) NotificationSenderOptions

type Push 

type Push struct {
	Client push.PushMsgServiceClient
	// contains filtered or unexported fields
}

func NewPush 

func NewPush(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Push

type PushRpcClient 

type PushRpcClient Push

func NewPushRpcClient 

func NewPushRpcClient(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) PushRpcClient

func (*PushRpcClient) DelUserPushToken 

func (p *PushRpcClient) DelUserPushToken(ctx context.Context, req *push.DelUserPushTokenReq) (*push.DelUserPushTokenResp, error)

type Third 

type Third struct {
	Client third.ThirdClient

	MinioClient *minio.Client
	Config      *config.GlobalConfig
	// contains filtered or unexported fields
}

func NewThird 

func NewThird(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *Third

type User 

type User struct {
	Client user.UserClient
	Discov discoveryregistry.SvcDiscoveryRegistry
	Config *config.GlobalConfig
	// contains filtered or unexported fields
}

User represents a structure holding connection details for the User RPC client.

func NewUser 

func NewUser(discov discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) *User

NewUser initializes and returns a User instance based on the provided service discovery registry.

type UserRpcClient 

type UserRpcClient User

UserRpcClient represents the structure for a User RPC client.

func NewUserRpcClient 

func NewUserRpcClient(client discoveryregistry.SvcDiscoveryRegistry, config *config.GlobalConfig) UserRpcClient

NewUserRpcClient initializes a UserRpcClient based on the provided service discovery registry.

func NewUserRpcClientByUser 

func NewUserRpcClientByUser(user *User) *UserRpcClient

NewUserRpcClientByUser initializes a UserRpcClient based on the provided User instance.

func (*UserRpcClient) Access 

func (u *UserRpcClient) Access(ctx context.Context, ownerUserID string) error

Access verifies the access rights for the provided user ID.

func (*UserRpcClient) GetAllUserIDs 

func (u *UserRpcClient) GetAllUserIDs(ctx context.Context, pageNumber, showNumber int32) ([]string, error)

GetAllUserIDs retrieves all user IDs with pagination options.

func (*UserRpcClient) GetNotificationByID added in v3.5.0 

func (u *UserRpcClient) GetNotificationByID(ctx context.Context, userID string) error

func (*UserRpcClient) GetPublicUserInfo 

func (u *UserRpcClient) GetPublicUserInfo(ctx context.Context, userID string) (*sdkws.PublicUserInfo, error)

GetPublicUserInfo retrieves public information for a single user based on the provided user ID.

func (*UserRpcClient) GetPublicUserInfoMap 

func (u *UserRpcClient) GetPublicUserInfoMap(
	ctx context.Context,
	userIDs []string,
	complete bool,
) (map[string]*sdkws.PublicUserInfo, error)

GetPublicUserInfoMap retrieves a map of public user information indexed by their user IDs.

func (*UserRpcClient) GetPublicUserInfos 

func (u *UserRpcClient) GetPublicUserInfos(
	ctx context.Context,
	userIDs []string,
	complete bool,
) ([]*sdkws.PublicUserInfo, error)

GetPublicUserInfos retrieves public information for multiple users based on their user IDs.

func (*UserRpcClient) GetUserGlobalMsgRecvOpt 

func (u *UserRpcClient) GetUserGlobalMsgRecvOpt(ctx context.Context, userID string) (int32, error)

GetUserGlobalMsgRecvOpt retrieves the global message receive option for a user based on the provided user ID.

func (*UserRpcClient) GetUserInfo 

func (u *UserRpcClient) GetUserInfo(ctx context.Context, userID string) (*sdkws.UserInfo, error)

GetUserInfo retrieves information for a single user based on the provided user ID.

func (*UserRpcClient) GetUsersInfo 

func (u *UserRpcClient) GetUsersInfo(ctx context.Context, userIDs []string) ([]*sdkws.UserInfo, error)

GetUsersInfo retrieves information for multiple users based on their user IDs.

func (*UserRpcClient) GetUsersInfoMap 

func (u *UserRpcClient) GetUsersInfoMap(ctx context.Context, userIDs []string) (map[string]*sdkws.UserInfo, error)

GetUsersInfoMap retrieves a map of user information indexed by their user IDs.

func (*UserRpcClient) SetUserStatus 

func (u *UserRpcClient) SetUserStatus(ctx context.Context, userID string, status int32, platformID int) error

SetUserStatus sets the status for a user based on the provided user ID, status, and platform ID.

Source Files

View all Source files

Directories

Path Synopsis

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.