friend

Documentation

Index

• func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryRegistry, ...) error
• func WithDBFunc(...) friendNotificationSenderOptions
• func WithFriendDB(db controller.FriendDatabase) friendNotificationSenderOptions
• func WithRpcFunc(fn func(ctx context.Context, userIDs []string) ([]*sdkws.UserInfo, error)) friendNotificationSenderOptions
• type Config
• type FriendNotificationSender
  • func NewFriendNotificationSender(conf *config.Notification, msgRpcClient *rpcclient.MessageRpcClient, ...) *FriendNotificationSender
  • func (f *FriendNotificationSender) BlackAddedNotification(ctx context.Context, req *pbfriend.AddBlackReq)
  • func (f *FriendNotificationSender) BlackDeletedNotification(ctx context.Context, req *pbfriend.RemoveBlackReq)
  • func (f *FriendNotificationSender) FriendAddedNotification(ctx context.Context, operationID, opUserID, fromUserID, toUserID string) error
  • func (f *FriendNotificationSender) FriendApplicationAddNotification(ctx context.Context, req *pbfriend.ApplyToAddFriendReq)
  • func (f *FriendNotificationSender) FriendApplicationAgreedNotification(ctx context.Context, req *pbfriend.RespondFriendApplyReq)
  • func (f *FriendNotificationSender) FriendApplicationRefusedNotification(ctx context.Context, req *pbfriend.RespondFriendApplyReq)
  • func (f *FriendNotificationSender) FriendDeletedNotification(ctx context.Context, req *pbfriend.DeleteFriendReq)
  • func (f *FriendNotificationSender) FriendInfoUpdatedNotification(ctx context.Context, changedUserID string, needNotifiedUserID string)
  • func (f *FriendNotificationSender) FriendRemarkSetNotification(ctx context.Context, fromUserID, toUserID string)
  • func (f *FriendNotificationSender) FriendsInfoUpdateNotification(ctx context.Context, toUserID string, friendIDs []string)
  • func (f *FriendNotificationSender) UserInfoUpdatedNotification(ctx context.Context, changedUserID string)

Functions

func Start

func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryRegistry, server *grpc.Server) error

func WithDBFunc

func WithDBFunc(
	fn func(ctx context.Context, userIDs []string) (users []*relationtb.UserModel, err error),
) friendNotificationSenderOptions

func WithFriendDB

func WithFriendDB(db controller.FriendDatabase) friendNotificationSenderOptions

func WithRpcFunc

func WithRpcFunc(
	fn func(ctx context.Context, userIDs []string) ([]*sdkws.UserInfo, error),
) friendNotificationSenderOptions

Types

type Config

type Config struct {
	RpcConfig          config.Friend
	RedisConfig        config.Redis
	MongodbConfig      config.Mongo
	ZookeeperConfig    config.ZooKeeper
	NotificationConfig config.Notification
	Share              config.Share
	WebhooksConfig     config.Webhooks
	LocalCacheConfig   config.LocalCache
}

type FriendNotificationSender

type FriendNotificationSender struct {
	*rpcclient.NotificationSender
	// contains filtered or unexported fields
}

func NewFriendNotificationSender

func NewFriendNotificationSender(
	conf *config.Notification,
	msgRpcClient *rpcclient.MessageRpcClient,
	opts ...friendNotificationSenderOptions,
) *FriendNotificationSender

func (*FriendNotificationSender) BlackAddedNotification

func (f *FriendNotificationSender) BlackAddedNotification(ctx context.Context, req *pbfriend.AddBlackReq)

func (*FriendNotificationSender) BlackDeletedNotification

func (f *FriendNotificationSender) BlackDeletedNotification(ctx context.Context, req *pbfriend.RemoveBlackReq)

func (*FriendNotificationSender) FriendAddedNotification

func (f *FriendNotificationSender) FriendAddedNotification(
	ctx context.Context,
	operationID, opUserID, fromUserID, toUserID string,
) error

func (*FriendNotificationSender) FriendApplicationAddNotification

func (f *FriendNotificationSender) FriendApplicationAddNotification(ctx context.Context, req *pbfriend.ApplyToAddFriendReq)

func (*FriendNotificationSender) FriendApplicationAgreedNotification

func (f *FriendNotificationSender) FriendApplicationAgreedNotification(
	ctx context.Context,
	req *pbfriend.RespondFriendApplyReq,
)

func (*FriendNotificationSender) FriendApplicationRefusedNotification

func (f *FriendNotificationSender) FriendApplicationRefusedNotification(
	ctx context.Context,
	req *pbfriend.RespondFriendApplyReq,
)

func (*FriendNotificationSender) FriendDeletedNotification

func (f *FriendNotificationSender) FriendDeletedNotification(ctx context.Context, req *pbfriend.DeleteFriendReq)

func (*FriendNotificationSender) FriendInfoUpdatedNotification

func (f *FriendNotificationSender) FriendInfoUpdatedNotification(ctx context.Context, changedUserID string, needNotifiedUserID string)

func (*FriendNotificationSender) FriendRemarkSetNotification

func (f *FriendNotificationSender) FriendRemarkSetNotification(ctx context.Context, fromUserID, toUserID string)

func (*FriendNotificationSender) FriendsInfoUpdateNotification

func (f *FriendNotificationSender) FriendsInfoUpdateNotification(ctx context.Context, toUserID string, friendIDs []string)

func (*FriendNotificationSender) UserInfoUpdatedNotification

func (f *FriendNotificationSender) UserInfoUpdatedNotification(ctx context.Context, changedUserID string)