msg

Documentation

Index

• Variables
• func GetContent(msg *sdkws.MsgData) string
• func GetMsgID(sendID string) string
• func IsNotFound(err error) bool
• func MessageHasReadEnabled(_ context.Context, req *msg.SendMsgReq) (*sdkws.MsgData, error)
• func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error
• type MessageInterceptorChain
• type MessageInterceptorFunc
• type MessageRevoked
• 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 MessageHasReadEnabled

func MessageHasReadEnabled(_ context.Context, req *msg.SendMsgReq) (*sdkws.MsgData, error)

func Start

func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error

Types

type MessageInterceptorChain

type MessageInterceptorChain []MessageInterceptorFunc

type MessageInterceptorFunc

type MessageInterceptorFunc func(ctx context.Context, 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 Validator

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