module

Documentation

Index

• Constants
• func WithRecvPushMsgCallback(callback func(msg *sdkws.MsgData)) func(core *SendMsgUser)
• type ApiMsgSender
  • func (a *ApiMsgSender) SendMsg(sendID, recvID string, index int) error
• type ConnListner
  • func (c *ConnListner) OnConnectFailed(errCode int32, errMsg string)
  • func (c *ConnListner) OnConnectSuccess()
  • func (c *ConnListner) OnConnecting()
  • func (c *ConnListner) OnKickedOffline()
  • func (c *ConnListner) OnUserTokenExpired()
• type MetaManager
  • func NewMetaManager(apiAddr, secret, managerUserID string) *MetaManager
  • func (m *MetaManager) GetServerTime() (int64, error)
  • func (m *MetaManager) NewApiMsgSender() *ApiMsgSender
  • func (m *MetaManager) NewFriendManager() *TestFriendManager
  • func (m *MetaManager) NewGroupMananger() *TestGroupManager
  • func (m *MetaManager) NewUserManager() *TestUserManager
• type SendMsg
• type SendMsgReq
• type SendMsgUser
  • func NewUser(userID, token string, imConfig sdk_struct.IMConfig, ...) *SendMsgUser
  • func (b *SendMsgUser) BatchSendGroupMsg(ctx context.Context, groupID string, index int) error
  • func (b *SendMsgUser) BatchSendSingleMsg(ctx context.Context, userID string, index int) error
  • func (b *SendMsgUser) Close(ctx context.Context)
  • func (b SendMsgUser) GetUserID() string
  • func (b *SendMsgUser) SendGroupMsg(ctx context.Context, groupID string, index int) error
  • func (b *SendMsgUser) SendGroupMsgWithContext(groupID string, index int) error
  • func (b *SendMsgUser) SendMsgWithContext(userID string, index int) error
  • func (b *SendMsgUser) SendSingleMsg(ctx context.Context, userID string, index int) error
• type TestFriendManager
  • func (t *TestFriendManager) ImportFriends(ownerUserID string, friendUserIDs []string) error
• type TestGroupManager
  • func (t *TestGroupManager) CreateGroup(groupID string, groupName string, ownerUserID string, userIDs []string) error
  • func (t *TestGroupManager) GenGroupID(prefix string) string
  • func (t *TestGroupManager) InviteUserToGroup(ctx context.Context, groupID string, invitedUserIDs []string) error
• type TestUserManager
  • func (t *TestUserManager) GenUserIDs(num int) (userIDs []string)
  • func (t *TestUserManager) GenUserIDsWithPrefix(num int, prefix string) (userIDs []string)
  • func (t *TestUserManager) GetToken(userID string, platformID int32) (string, error)
  • func (t *TestUserManager) RegisterUsers(userIDs ...string) error

Constants

const (
	ManagerUserID = "openIMAdmin"
)

Functions

func WithRecvPushMsgCallback

func WithRecvPushMsgCallback(callback func(msg *sdkws.MsgData)) func(core *SendMsgUser)

Types

type ApiMsgSender

type ApiMsgSender struct {
	*MetaManager
}

func (*ApiMsgSender) SendMsg

func (a *ApiMsgSender) SendMsg(sendID, recvID string, index int) error

type ConnListner

type ConnListner struct {
}

func (*ConnListner) OnConnectFailed

func (c *ConnListner) OnConnectFailed(errCode int32, errMsg string)

func (*ConnListner) OnConnectSuccess

func (c *ConnListner) OnConnectSuccess()

func (*ConnListner) OnConnecting

func (c *ConnListner) OnConnecting()

func (*ConnListner) OnKickedOffline

func (c *ConnListner) OnKickedOffline()

func (*ConnListner) OnUserTokenExpired

func (c *ConnListner) OnUserTokenExpired()

type MetaManager

type MetaManager struct {
	// contains filtered or unexported fields
}

func NewMetaManager

func NewMetaManager(apiAddr, secret, managerUserID string) *MetaManager

func (*MetaManager) GetServerTime

func (m *MetaManager) GetServerTime() (int64, error)

func (*MetaManager) NewApiMsgSender

func (m *MetaManager) NewApiMsgSender() *ApiMsgSender

func (*MetaManager) NewFriendManager

func (m *MetaManager) NewFriendManager() *TestFriendManager

func (*MetaManager) NewGroupMananger

func (m *MetaManager) NewGroupMananger() *TestGroupManager

func (*MetaManager) NewUserManager

func (m *MetaManager) NewUserManager() *TestUserManager

type SendMsg

type SendMsg struct {
	SendID           string                 `json:"sendID"           binding:"required"`
	GroupID          string                 `json:"groupID"          binding:"required_if=SessionType 2|required_if=SessionType 3"`
	SenderNickname   string                 `json:"senderNickname"`
	SenderFaceURL    string                 `json:"senderFaceURL"`
	SenderPlatformID int32                  `json:"senderPlatformID"`
	Content          map[string]interface{} `json:"content"          binding:"required"                                            swaggerignore:"true"`
	ContentType      int32                  `json:"contentType"      binding:"required"`
	SessionType      int32                  `json:"sessionType"      binding:"required"`
	IsOnlineOnly     bool                   `json:"isOnlineOnly"`
	NotOfflinePush   bool                   `json:"notOfflinePush"`
	OfflinePushInfo  *sdkws.OfflinePushInfo `json:"offlinePushInfo"`
}

type SendMsgReq

type SendMsgReq struct {
	RecvID string `json:"recvID" binding:"required_if" message:"recvID is required if sessionType is SingleChatType or NotificationChatType"`
	SendMsg
}

type SendMsgUser

type SendMsgUser struct {
	// contains filtered or unexported fields
}

func NewUser

func NewUser(userID, token string, imConfig sdk_struct.IMConfig, opts ...func(core *SendMsgUser)) *SendMsgUser

func (*SendMsgUser) BatchSendGroupMsg

func (b *SendMsgUser) BatchSendGroupMsg(ctx context.Context, groupID string, index int) error

func (*SendMsgUser) BatchSendSingleMsg

func (b *SendMsgUser) BatchSendSingleMsg(ctx context.Context, userID string, index int) error

func (*SendMsgUser) Close

func (b *SendMsgUser) Close(ctx context.Context)

func (SendMsgUser) GetUserID

func (b SendMsgUser) GetUserID() string

func (*SendMsgUser) SendGroupMsg

func (b *SendMsgUser) SendGroupMsg(ctx context.Context, groupID string, index int) error

func (*SendMsgUser) SendGroupMsgWithContext

func (b *SendMsgUser) SendGroupMsgWithContext(groupID string, index int) error

func (*SendMsgUser) SendMsgWithContext

func (b *SendMsgUser) SendMsgWithContext(userID string, index int) error

func (*SendMsgUser) SendSingleMsg

func (b *SendMsgUser) SendSingleMsg(ctx context.Context, userID string, index int) error

type TestFriendManager

type TestFriendManager struct {
	*MetaManager
}

func (*TestFriendManager) ImportFriends

func (t *TestFriendManager) ImportFriends(ownerUserID string, friendUserIDs []string) error

type TestGroupManager

type TestGroupManager struct {
	*MetaManager
}

func (*TestGroupManager) CreateGroup

func (t *TestGroupManager) CreateGroup(groupID string, groupName string, ownerUserID string, userIDs []string) error

func (*TestGroupManager) GenGroupID

func (t *TestGroupManager) GenGroupID(prefix string) string

func (*TestGroupManager) InviteUserToGroup

func (t *TestGroupManager) InviteUserToGroup(ctx context.Context, groupID string, invitedUserIDs []string) error

type TestUserManager

type TestUserManager struct {
	*MetaManager
}

func (*TestUserManager) GenUserIDs

func (t *TestUserManager) GenUserIDs(num int) (userIDs []string)

func (*TestUserManager) GenUserIDsWithPrefix

func (t *TestUserManager) GenUserIDsWithPrefix(num int, prefix string) (userIDs []string)

func (*TestUserManager) GetToken

func (t *TestUserManager) GetToken(userID string, platformID int32) (string, error)

func (*TestUserManager) RegisterUsers

func (t *TestUserManager) RegisterUsers(userIDs ...string) error