rpcclient

Documentation

Index

• type NotificationOptions
  • func WithRpcGetUserName() NotificationOptions
• type NotificationSender
  • 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 WithLocalSendMsg(...) NotificationSenderOptions
  • func WithQueue(queue *memamq.MemoryQueue) NotificationSenderOptions
  • func WithRpcClient(...) NotificationSenderOptions
  • func WithUserRpcClient(getUserInfo func(ctx context.Context, userID string) (*sdkws.UserInfo, error)) NotificationSenderOptions

Types

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(conf *config.Notification, opts ...NotificationSenderOptions) *NotificationSender

func (*NotificationSender) Notification

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

func (*NotificationSender) NotificationWithSessionType

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

func (*NotificationSender) SetOptionsByContentType

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 WithQueue

func WithQueue(queue *memamq.MemoryQueue) NotificationSenderOptions

func WithRpcClient

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

func WithUserRpcClient

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