msg

Documentation

Index

• Variables
• func GetContent(msg *sdkws.MsgData) string
• func GetMsgID(sendID string) string
• func IsNotFound(err error) bool
• func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryRegistry, ...) error
• type Config
• type MessageInterceptorChain
• type MessageInterceptorFunc
• type MessageRevoked
• type MsgNotificationSender
  • func NewMsgNotificationSender(config *Config, opts ...rpcclient.NotificationSenderOptions) *MsgNotificationSender
  • func (m *MsgNotificationSender) MarkAsReadNotification(ctx context.Context, conversationID string, sessionType int32, ...)
  • func (m *MsgNotificationSender) UserDeleteMsgsNotification(ctx context.Context, userID, conversationID string, seqs []int64)
• type Validator

Variables

var ExcludeContentType = []int{constant.HasReadReceipt}

Functions

func GetContent

func GetContent(msg *sdkws.MsgData) string

func GetMsgID

func GetMsgID(sendID string) string

func IsNotFound

func IsNotFound(err error) bool

func Start

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

Types

type Config

type Config struct {
	RpcConfig          config.Msg
	RedisConfig        config.Redis
	MongodbConfig      config.Mongo
	KafkaConfig        config.Kafka
	NotificationConfig config.Notification
	Share              config.Share
	WebhooksConfig     config.Webhooks
	LocalCacheConfig   config.LocalCache
	Discovery          config.Discovery
}

type MessageInterceptorChain

type MessageInterceptorChain []MessageInterceptorFunc

MessageInterceptorChain defines a chain of message interceptor functions.

type MessageInterceptorFunc

type MessageInterceptorFunc func(ctx context.Context, globalConfig *Config, req *msg.SendMsgReq) (*sdkws.MsgData, error)

type MessageRevoked

type MessageRevoked struct {
	RevokerID                   string `json:"revokerID"`
	RevokerRole                 int32  `json:"revokerRole"`
	ClientMsgID                 string `json:"clientMsgID"`
	RevokerNickname             string `json:"revokerNickname"`
	RevokeTime                  int64  `json:"revokeTime"`
	SourceMessageSendTime       int64  `json:"sourceMessageSendTime"`
	SourceMessageSendID         string `json:"sourceMessageSendID"`
	SourceMessageSenderNickname string `json:"sourceMessageSenderNickname"`
	SessionType                 int32  `json:"sessionType"`
	Seq                         uint32 `json:"seq"`
}

type MsgNotificationSender

type MsgNotificationSender struct {
	*rpcclient.NotificationSender
}

func NewMsgNotificationSender

func NewMsgNotificationSender(config *Config, opts ...rpcclient.NotificationSenderOptions) *MsgNotificationSender

func (*MsgNotificationSender) MarkAsReadNotification

func (m *MsgNotificationSender) MarkAsReadNotification(ctx context.Context, conversationID string, sessionType int32, sendID, recvID string, seqs []int64, hasReadSeq int64)

func (*MsgNotificationSender) UserDeleteMsgsNotification

func (m *MsgNotificationSender) UserDeleteMsgsNotification(ctx context.Context, userID, conversationID string, seqs []int64)

type Validator

type Validator interface {
	// contains filtered or unexported methods
}