rpcclient

Jan 4, 2025

Changes in this version

+ type NotificationOptions func(*notificationOpt)

+ func WithRpcGetUserName() NotificationOptions

+ type NotificationSender struct

+ func NewNotificationSender(conf *config.Notification, opts ...NotificationSenderOptions) *NotificationSender

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

+ func (s *NotificationSender) NotificationWithSessionType(ctx context.Context, sendID, recvID string, contentType, sessionType int32, ...)

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

+ type NotificationSenderOptions func(*NotificationSender)

+ func WithLocalSendMsg(...) NotificationSenderOptions

+ func WithQueue(queue *memamq.MemoryQueue) NotificationSenderOptions

+ func WithRpcClient(...) NotificationSenderOptions

+ func WithUserRpcClient(getUserInfo func(ctx context.Context, userID string) (*sdkws.UserInfo, error)) NotificationSenderOptions