Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

conversation_msg

package

Go to main page

Versions in this module

v1

v1.0.3

Oct 31, 2024

v1.0.2

Oct 31, 2024

v1.0.1

Oct 31, 2024

v1.0.0

Oct 31, 2024

Changes in this version

+ var SearchContentType = []int

+ func DeleteUserReactionElem(a []*sdk_struct.UserReactionElem, userID string) []*sdk_struct.UserReactionElem

+ func LocalConversationToServer(conversation *model_struct.LocalConversation) *pbConversation.Conversation

+ func NewUploadFileCallback(ctx context.Context, progress func(progress int), msg *sdk_struct.MsgStruct, ...) file.UploadFileCallback

+ func ServerConversationToLocal(conversation *pbConversation.Conversation) *model_struct.LocalConversation

+ type Conversation struct

+ ConversationListener func() open_im_sdk_callback.OnConversationListener

+ DataDir string

+ IsExternalExtensions bool

+ func NewConversation(ctx context.Context, longConnMgr *interaction.LongConnMgr, ...) *Conversation

+ func (c *Conversation) AddMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) ChangeInputStates(ctx context.Context, conversationID string, focus bool) error

+ func (c *Conversation) ClearConversationAndDeleteAllMsg(ctx context.Context, conversationID string) error

+ func (c *Conversation) CreateAdvancedQuoteMessage(ctx context.Context, text string, qs *sdk_struct.MsgStruct, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateAdvancedTextMessage(ctx context.Context, text string, messageEntities []*sdk_struct.MessageEntity) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateCardMessage(ctx context.Context, card *sdk_struct.CardElem) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateCustomMessage(ctx context.Context, data, extension string, description string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFaceMessage(ctx context.Context, index int, data string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessage(ctx context.Context, filePath string, fileName string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessageByURL(ctx context.Context, fileElem sdk_struct.FileBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessageFromFullPath(ctx context.Context, fileFullPath string, fileName string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateForwardMessage(ctx context.Context, s *sdk_struct.MsgStruct) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessage(ctx context.Context, imagePath string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessageByURL(ctx context.Context, sourcePath string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessageFromFullPath(ctx context.Context, imageFullPath string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateLocationMessage(ctx context.Context, description string, longitude, latitude float64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateMergerMessage(ctx context.Context, messages []*sdk_struct.MsgStruct, title string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateQuoteMessage(ctx context.Context, text string, qs *sdk_struct.MsgStruct) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessage(ctx context.Context, soundPath string, duration int64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessageByURL(ctx context.Context, soundElem *sdk_struct.SoundBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessageFromFullPath(ctx context.Context, soundPath string, duration int64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateTextAtMessage(ctx context.Context, text string, userIDList []string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateTextMessage(ctx context.Context, text string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessage(ctx context.Context, videoPath string, videoType string, duration int64, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessageByURL(ctx context.Context, videoElem sdk_struct.VideoBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessageFromFullPath(ctx context.Context, videoFullPath string, videoType string, duration int64, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) DeleteAllMessageFromLocalStorage(ctx context.Context) error

+ func (c *Conversation) DeleteAllMsgFromLocalAndSvr(ctx context.Context) error

+ func (c *Conversation) DeleteConversationAndDeleteAllMsg(ctx context.Context, conversationID string) error

+ func (c *Conversation) DeleteMessage(ctx context.Context, conversationID string, clientMsgID string) error

+ func (c *Conversation) DeleteMessageFromLocalStorage(ctx context.Context, conversationID string, clientMsgID string) error

+ func (c *Conversation) DeleteMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) DoConversationChangedNotification(ctx context.Context, msg *sdkws.MsgData)

+ func (c *Conversation) DoConversationIsPrivateChangedNotification(ctx context.Context, msg *sdkws.MsgData)

+ func (c *Conversation) DoMsgReaction(msgReactionList []*sdk_struct.MsgStruct)

+ func (c *Conversation) FindMessageList(ctx context.Context, req []*sdk_params_callback.ConversationArgs) (*sdk_params_callback.FindMessageListCallback, error)

+ func (c *Conversation) GetAdvancedHistoryMessageList(ctx context.Context, ...) (*sdk_params_callback.GetAdvancedHistoryMessageListCallback, error)

+ func (c *Conversation) GetAdvancedHistoryMessageListReverse(ctx context.Context, ...) (*sdk_params_callback.GetAdvancedHistoryMessageListCallback, error)

+ func (c *Conversation) GetAllConversationList(ctx context.Context) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetAtAllTag(_ context.Context) string

+ func (c *Conversation) GetCh() chan common.Cmd2Value

+ func (c *Conversation) GetConversationIDBySessionType(_ context.Context, sourceID string, sessionType int) string

+ func (c *Conversation) GetConversationListSplit(ctx context.Context, offset, count int) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetConversationRecvMessageOpt(ctx context.Context, conversationIDs []string) (resp []*server_api_params.GetConversationRecvMessageOptResp, err error)

+ func (c *Conversation) GetInputStates(ctx context.Context, conversationID string, userID string) ([]int32, error)

+ func (c *Conversation) GetMessageListReactionExtensions(ctx context.Context, conversationID string, ...) ([]*server_api_params.SingleMessageExtensionResult, error)

+ func (c *Conversation) GetMultipleConversation(ctx context.Context, conversationIDList []string) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetOneConversation(ctx context.Context, sessionType int32, sourceID string) (*model_struct.LocalConversation, error)

+ func (c *Conversation) GetTotalUnreadMsgCount(ctx context.Context) (totalUnreadCount int32, err error)

+ func (c *Conversation) HideAllConversations(ctx context.Context) error

+ func (c *Conversation) HideConversation(ctx context.Context, conversationID string) error

+ func (c *Conversation) InsertGroupMessageToLocalStorage(ctx context.Context, s *sdk_struct.MsgStruct, groupID, sendID string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) InsertSingleMessageToLocalStorage(ctx context.Context, s *sdk_struct.MsgStruct, recvID, sendID string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) MarkConversationMessageAsRead(ctx context.Context, conversationID string) error

+ func (c *Conversation) MarkMessagesAsReadByMsgID(ctx context.Context, conversationID string, clientMsgIDs []string) error

+ func (c *Conversation) PinConversation(ctx context.Context, conversationID string, isPinned bool) error

+ func (c *Conversation) PullMessageBySeqs(ctx context.Context, seqs []*sdkws.SeqRange) (*sdkws.PullMessageBySeqsResp, error)

+ func (c *Conversation) ResetConversationGroupAtType(ctx context.Context, conversationID string) error

+ func (c *Conversation) RevokeMessage(ctx context.Context, conversationID, clientMsgID string) error

+ func (c *Conversation) SearchConversation(ctx context.Context, searchParam string) ([]*server_api_params.Conversation, error)

+ func (c *Conversation) SearchLocalMessages(ctx context.Context, ...) (*sdk_params_callback.SearchLocalMessagesCallback, error)

+ func (c *Conversation) SendMessage(ctx context.Context, s *sdk_struct.MsgStruct, recvID, groupID string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) SendMessageNotOss(ctx context.Context, s *sdk_struct.MsgStruct, recvID, groupID string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) SetBatchMsgListener(batchMsgListener func() open_im_sdk_callback.OnBatchMsgListener)

+ func (c *Conversation) SetConversationDraft(ctx context.Context, conversationID, draftText string) error

+ func (c *Conversation) SetConversationIsMsgDestruct(ctx context.Context, conversationID string, isMsgDestruct bool) error

+ func (c *Conversation) SetConversationListener(listener func() open_im_sdk_callback.OnConversationListener)

+ func (c *Conversation) SetConversationMsgDestructTime(ctx context.Context, conversationID string, msgDestructTime int64) error

+ func (c *Conversation) SetMessageLocalEx(ctx context.Context, conversationID string, clientMsgID string, localEx string) error

+ func (c *Conversation) SetMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) SetMsgKvListener(msgKvListener func() open_im_sdk_callback.OnMessageKvInfoListener)

+ func (c *Conversation) SetMsgListener(msgListener func() open_im_sdk_callback.OnAdvancedMsgListener)

+ func (c *Conversation) SetOneConversationBurnDuration(ctx context.Context, conversationID string, burnDuration int32) error

+ func (c *Conversation) SetOneConversationEx(ctx context.Context, conversationID string, ex string) error

+ func (c *Conversation) SetOneConversationPrivateChat(ctx context.Context, conversationID string, isPrivate bool) error

+ func (c *Conversation) SetOneConversationRecvMessageOpt(ctx context.Context, conversationID string, opt int) error

+ func (c *Conversation) SyncAllConversationHashReadSeqs(ctx context.Context) error

+ func (c *Conversation) SyncAllConversations(ctx context.Context) error

+ func (c *Conversation) SyncConversations(ctx context.Context, conversationIDs []string) error

+ func (c *Conversation) SyncConversationsAndTriggerCallback(ctx context.Context, conversationsOnServer []*model_struct.LocalConversation) error

+ func (c *Conversation) TypingStatusUpdate(ctx context.Context, recvID, msgTip string) error

+ func (c *Conversation) Work(c2v common.Cmd2Value)

+ type InputStatesChangedData struct

+ ConversationID string

+ PlatformIDs []int32

+ UserID string

+ type MaxSeqRecorder struct

+ func NewMaxSeqRecorder() MaxSeqRecorder

+ func (m *MaxSeqRecorder) Get(conversationID string) int64

+ func (m *MaxSeqRecorder) Incr(conversationID string, num int64)

+ func (m *MaxSeqRecorder) IsNewMsg(conversationID string, seq int64) bool

+ func (m *MaxSeqRecorder) Set(conversationID string, seq int64)

+ type MessageController struct

+ func NewMessageController(db db_interface.DataBase, ch chan common.Cmd2Value) *MessageController

+ func (m *MessageController) BatchInsertMessageList(ctx context.Context, insertMsg map[string][]*model_struct.LocalChatLog) error

+ func (m *MessageController) BatchUpdateMessageList(ctx context.Context, updateMsg map[string][]*model_struct.LocalChatLog) error

+ func (m *MessageController) SearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, keywordList []string, ...) (result []*model_struct.LocalChatLog, err error)