Versions in this module Expand all Collapse all v1 v1.1.0 Jul 5, 2024 Changes in this version type QiniuConfig + AccessKeyID string + AccessKeySecret string v1.0.5 Jul 4, 2024 v1.0.4 Jul 4, 2024 v1.0.3 Jul 4, 2024 v1.0.2 Jul 4, 2024 Changes in this version + func BoolEnv(b *bool, key string) + func GetEnv(key string, defaultValue string) string + func GetEnvBool(key string, defaultValue bool) bool + func GetEnvFloat64(key string, defaultValue float64) float64 + func GetEnvInt(key string, defaultValue int) int + func GetEnvInt64(key string, defaultValue int64) int64 + func StringEnv(v *string, key string) + type APNSPush struct + Cert string + Dev bool + Password string + Topic string + type AliyunInternationalSMSConfig struct + AccessKeyID string + AccessSecret string + SignName string + type AliyunSMSConfig struct + AccessKeyID string + AccessSecret string + SignName string + TemplateCode string + type AsyncTask struct + func NewAsyncTask(cfg *Config) *AsyncTask + func (a *AsyncTask) LaunchWorker(consumerTag string, concurrency int) error + func (a *AsyncTask) RegisterTask(name string, taskFunc interface{}) error + func (a *AsyncTask) RegisterTasks(namedTaskFuncs map[string]interface{}) error + func (a *AsyncTask) SendTask(task *tasks.Signature) (*result.AsyncResult, error) + func (a *AsyncTask) SendTaskWithContext(ctx context.Context, task *tasks.Signature) (*result.AsyncResult, error) + type CMDGroupAvatarUpdateReq struct + GroupNo string + Members []string + type CMDResp struct + CMD string + Param interface{} + type Channel struct + ChannelID string + ChannelType uint8 + type ChannelBlacklistReq struct + UIDs []string + type ChannelCreateReq struct + Ban int + ChannelID string + ChannelType uint8 + Large int + Subscribers []string + type ChannelDeleteReq struct + ChannelID string + ChannelType uint8 + type ChannelInfoCreateReq struct + Ban int + ChannelID string + ChannelType uint8 + Large int + type ChannelMaxSeqResp struct + MessageSeq uint32 + type ChannelReq struct + ChannelID string + ChannelType uint8 + type ChannelWhitelistReq struct + UIDs []string + type ClearConversationUnreadReq struct + ChannelID string + ChannelType uint8 + MessageSeq uint32 + UID string + Unread int + type Config struct + Account struct{ ... } + Addr string + AdminPwd string + AliyunInternationalSMS AliyunInternationalSMSConfig + AliyunSMS AliyunSMSConfig + AppID string + AppName string + AppRSAPrivateKey string + AppRSAPubKey string + Avatar struct{ ... } + Cache struct{ ... } + Cluster struct{ ... } + DB struct{ ... } + ElasticsearchURL string + EventPoolSize int64 + External struct{ ... } + FileService FileService + Friend struct{ ... } + GRPCAddr string + Gitee struct{ ... } + Github struct{ ... } + Group struct{ ... } + GroupUpgradeWhenMemberCount int + Logger struct{ ... } + Message struct{ ... } + MessageSaveAcrossDevice bool + Minio MinioConfig + Mode Mode + OSS OSSConfig + OWT struct{ ... } + OnlineStatusOn bool + Organization struct{ ... } + PhoneSearchOff bool + Push struct{ ... } + QRCodeInfoURL string + Qiniu QiniuConfig + Register struct{ ... } + Robot struct{ ... } + RootDir string + SMSCode string + SMSProvider SMSProvider + SSLAddr string + Seaweed SeaweedConfig + ShortNo struct{ ... } + Support struct{ ... } + TablePartitionConfig TablePartitionConfig + Test bool + TimingWheelSize int64 + TimingWheelTick duration + Tracing struct{ ... } + UniSMS UnismsConfig + Version string + VisitorUIDPrefix string + Wechat struct{ ... } + WelcomeMessage string + WuKongIM struct{ ... } + ZincSearch struct{ ... } + func New() *Config + func (c *Config) ComposeCustomerServiceChannelID(vid string, channelID string) string + func (c *Config) ConfigFileUsed() string + func (c *Config) ConfigureWithViper(vp *viper.Viper) + func (c *Config) GetAvatarPath(uid string) string + func (c *Config) GetCommunityAvatarFilePath(communityNo string) string + func (c *Config) GetCommunityCoverFilePath(communityNo string) string + func (c *Config) GetCustomerServiceChannelID(channelID string) (string, bool) + func (c *Config) GetCustomerServiceVisitorUID(channelID string) (string, bool) + func (c *Config) GetGroupAvatarFilePath(groupNo string) string + func (c *Config) GetOrganizationLogoFilePath(orgId string) string + func (c *Config) IsVisitor(uid string) bool + func (c *Config) IsVisitorChannel(uid string) bool + type Context struct + Event wkevent.Event + EventPool pool.Collector + PushPool pool.Collector + RobotEventPool pool.Collector + SetupTask bool + UserIDGen *snowflake.Node + func NewContext(cfg *Config) *Context + func (c *Context) AddEventListener(event string, listener EventListener) + func (c *Context) AddMessagesListener(listener MessagesListener) + func (c *Context) AddOnlineStatusListener(listener OnlineStatusListener) + func (c *Context) AsyncTask() *AsyncTask + func (c *Context) AuthMiddleware(r *wkhttp.WKHttp) wkhttp.HandlerFunc + func (c *Context) Cache() cache.Cache + func (c *Context) DB() *dbr.Session + func (c *Context) EventBegin(data *wkevent.Data, tx *dbr.Tx) (int64, error) + func (c *Context) EventCommit(eventID int64) + func (c *Context) GenSeq(flag string) int64 + func (c *Context) GetAllOnlineStatusListeners() []OnlineStatusListener + func (c *Context) GetConfig() *Config + func (c *Context) GetElasticsearch() *elastic.Client + func (c *Context) GetEventListeners(event string) []EventListener + func (c *Context) GetHttpRoute() *wkhttp.WKHttp + func (c *Context) GetRedisConn() *redis.Conn + func (c *Context) IMAddSubscriber(req *SubscriberAddReq) error + func (c *Context) IMBlacklistAdd(req ChannelBlacklistReq) error + func (c *Context) IMBlacklistRemove(req ChannelBlacklistReq) error + func (c *Context) IMBlacklistSet(req ChannelBlacklistReq) error + func (c *Context) IMClearConversationUnread(req ClearConversationUnreadReq) error + func (c *Context) IMCreateOrUpdateChannel(req *ChannelCreateReq) error + func (c *Context) IMCreateOrUpdateChannelInfo(req *ChannelInfoCreateReq) error + func (c *Context) IMDelChannel(req *ChannelDeleteReq) error + func (c *Context) IMDeleteConversation(req DeleteConversationReq) error + func (c *Context) IMGetChannelMaxSeq(channelID string, channelType uint8) (*ChannelMaxSeqResp, error) + func (c *Context) IMGetConversations(uid string) ([]*ConversationResp, error) + func (c *Context) IMGetWithChannelAndSeqs(channelID string, channelType uint8, loginUID string, seqs []uint32) (*SyncChannelMessageResp, error) + func (c *Context) IMRemoveSubscriber(req *SubscriberRemoveReq) error + func (c *Context) IMRevokeMessage(req *MessageRevokeReq) error + func (c *Context) IMSOnlineStatus(uids []string) ([]*OnlinestatusResp, error) + func (c *Context) IMStreamEnd(req MessageStreamEndReq) error + func (c *Context) IMStreamStart(req MessageStreamStartReq) (string, error) + func (c *Context) IMSyncChannelMessage(req SyncChannelMessageReq) (*SyncChannelMessageResp, error) + func (c *Context) IMSyncMessage(req *MsgSyncReq) ([]*MessageResp, error) + func (c *Context) IMSyncMessageAck(req *SyncackReq) error + func (c *Context) IMSyncUserConversation(uid string, version int64, msgCount int64, lastMsgSeqs string, ...) ([]*SyncUserConversationResp, error) + func (c *Context) IMWhitelistAdd(req ChannelWhitelistReq) error + func (c *Context) IMWhitelistRemove(req ChannelWhitelistReq) error + func (c *Context) IMWhitelistSet(req ChannelWhitelistReq) error + func (c *Context) NewMemoryCache() cache.Cache + func (c *Context) NewMySQL() *dbr.Session + func (c *Context) NewRedisCache() *common.RedisCache + func (c *Context) NotifyMessagesListeners(messages []*MessageResp) + func (c *Context) QuitUserDevice(uid string, deviceFlag int) error + func (c *Context) Schedule(interval time.Duration, f func()) *timingwheel.Timer + func (c *Context) SendCMD(req MsgCMDReq) error + func (c *Context) SendChannelUpdate(channel ChannelReq, updateChannel ChannelReq) error + func (c *Context) SendChannelUpdateToGroup(groupNo string) error + func (c *Context) SendChannelUpdateToUser(uid string, channel ChannelReq) error + func (c *Context) SendChannelUpdateWithFromUID(channel ChannelReq, updateChannel ChannelReq, fromUID string) error + func (c *Context) SendFriendApply(req *MsgFriendApplyReq) error + func (c *Context) SendFriendDelete(req *MsgFriendDeleteReq) error + func (c *Context) SendFriendSure(req *MsgFriendSureReq) error + func (c *Context) SendGroupCreate(req *MsgGroupCreateReq) error + func (c *Context) SendGroupExit(groupNo string, uid string, name string, visibleUids []string) error + func (c *Context) SendGroupMemberAdd(req *MsgGroupMemberAddReq) error + func (c *Context) SendGroupMemberBeRemove(req *MsgGroupMemberRemoveReq) error + func (c *Context) SendGroupMemberInviteReq(req MsgGroupMemberInviteReq) error + func (c *Context) SendGroupMemberRemove(req *MsgGroupMemberRemoveReq) error + func (c *Context) SendGroupMemberScanJoin(req MsgGroupMemberScanJoin) error + func (c *Context) SendGroupMemberUpdate(groupNo string) error + func (c *Context) SendGroupTransferGrouper(req MsgGroupTransferGrouper) error + func (c *Context) SendGroupUpdate(req *MsgGroupUpdateReq) error + func (c *Context) SendGroupUpgrade(groupNo string) error + func (c *Context) SendMessage(req *MsgSendReq) error + func (c *Context) SendMessageBatch(req *MsgSendBatch) error + func (c *Context) SendMessageWithResult(req *MsgSendReq) (*MsgSendResp, error) + func (c *Context) SendRTCCallResult(req P2pRtcMessageReq) error + func (c *Context) SendRevoke(req *MsgRevokeReq) error + func (c *Context) SendTyping(channelID string, channelType uint8, fromUID string) error + func (c *Context) SendUnableAddDestoryAccountInGroup(req *MsgGroupCreateReq) error + func (c *Context) SetHttpRoute(r *wkhttp.WKHttp) + func (c *Context) SetValue(value interface{}, key string) + func (c *Context) Tracer() *Tracer + func (c *Context) UpdateIMToken(req UpdateIMTokenReq) (*UpdateIMTokenResp, error) + func (c *Context) Value(key string) any + type ConversationResp struct + ChannelID string + ChannelType uint8 + LastMessage *MessageResp + Timestamp int64 + Unread int64 + type DeleteConversationReq struct + ChannelID string + ChannelType uint8 + UID string + type DeviceFlag uint8 + const APP + const PC + const Web + func (d DeviceFlag) Uint8() uint8 + type DeviceLevel uint8 + const DeviceLevelMaster + const DeviceLevelSlave + type EmptySpan struct + func (e *EmptySpan) BaggageItem(restrictedKey string) string + func (e *EmptySpan) Context() opentracing.SpanContext + func (e *EmptySpan) Finish() + func (e *EmptySpan) FinishWithOptions(opts opentracing.FinishOptions) + func (e *EmptySpan) Log(data opentracing.LogData) + func (e *EmptySpan) LogEvent(event string) + func (e *EmptySpan) LogEventWithPayload(event string, payload interface{}) + func (e *EmptySpan) LogFields(fields ...log.Field) + func (e *EmptySpan) LogKV(alternatingKeyValues ...interface{}) + func (e *EmptySpan) SetBaggageItem(restrictedKey, value string) opentracing.Span + func (e *EmptySpan) SetOperationName(operationName string) opentracing.Span + func (e *EmptySpan) SetTag(key string, value interface{}) opentracing.Span + func (e *EmptySpan) Tracer() opentracing.Tracer + type EmptySpanContext struct + func (e *EmptySpanContext) ForeachBaggageItem(handler func(k, v string) bool) + type EventCommit func(err error) + type EventListener func(data []byte, commit EventCommit) + type FIREBASEPush struct + JsonPath string + PackageName string + ProjectId string + type FileService string + const FileServiceAliyunOSS + const FileServiceMinio + const FileServiceQiniu + const FileServiceSeaweedFS + func (u FileService) String() string + type HMSPush struct + AppID string + AppSecret string + PackageName string + type MIPush struct + AppID string + AppSecret string + ChannelID string + PackageName string + type MessageDeleteReq struct + ChannelID string + ChannelType uint8 + MessageIDs []uint64 + UID string + type MessageResp struct + ChannelID string + ChannelType uint8 + ClientMsgNo string + Expire uint32 + FromUID string + Header MsgHeader + IsDeleted int + MessageID int64 + MessageSeq uint32 + Payload []byte + Setting uint8 + StreamNo string + Streams []*StreamItemResp + Timestamp int32 + ToUID string + VoiceStatus int + func (m *MessageResp) GetContentType() int + func (m *MessageResp) GetPayloadMap() (map[string]interface{}, error) + type MessageRevokeReq struct + ChannelID string + ChannelType uint8 + MessageIDs []uint64 + type MessageStreamEndReq struct + ChannelID string + ChannelType uint8 + StreamNo string + type MessageStreamStartReq struct + ChannelID string + ChannelType uint8 + ClientMsgNo string + FromUID string + Header MsgHeader + Payload []byte + type MessagesListener func(messages []*MessageResp) + type MinioConfig struct + AccessKeyID string + DownloadURL string + SecretAccessKey string + URL string + UploadURL string + type Mode string + const BenchMode + const DebugMode + const ReleaseMode + type MsgCMDReq struct + CMD string + ChannelID string + ChannelType uint8 + FromUID string + NoPersist bool + Param map[string]interface{} + Subscribers []string + type MsgFriendApplyReq struct + ApplyName string + ApplyUID string + Remark string + ToUID string + Token string + type MsgFriendDeleteReq struct + FromUID string + ToUID string + type MsgFriendSureReq struct + FromName string + FromUID string + ToUID string + type MsgGroupCreateReq struct + Creator string + CreatorName string + GroupNo string + Members []*UserBaseVo + Version int64 + type MsgGroupDisband struct + GroupNo string + Operator string + OperatorName string + type MsgGroupMemberAddReq struct + GroupNo string + Members []*UserBaseVo + Operator string + OperatorName string + type MsgGroupMemberInviteReq struct + GroupNo string + InviteNo string + Inviter string + InviterName string + Num int + Subscribers []string + type MsgGroupMemberRemoveReq struct + GroupNo string + Members []*UserBaseVo + Operator string + OperatorName string + type MsgGroupMemberScanJoin struct + Generator string + GeneratorName string + GroupNo string + Scaner string + ScanerName string + type MsgGroupTransferGrouper struct + GroupNo string + NewGrouper string + NewGrouperName string + OldGrouper string + OldGrouperName string + type MsgGroupUpdateReq struct + Attr string + Data map[string]string + GroupNo string + Operator string + OperatorName string + type MsgHeader struct + NoPersist int + RedDot int + SyncOnce int + func (h MsgHeader) String() string + type MsgOrgOrDeptCreateReq struct + GroupCategory string + GroupNo string + Members []*OrgOrDeptEmployeeVO + Name string + Operator string + OperatorName string + type MsgOrgOrDeptEmployeeAddReq struct + GroupNo string + Members []*UserBaseVo + Name string + type MsgOrgOrDeptEmployeeUpdateReq struct + Members []*OrgOrDeptEmployeeVO + type MsgRevokeReq struct + ChannelID string + ChannelType uint8 + FromUID string + MessageID int64 + Operator string + OperatorName string + type MsgSendBatch struct + FromUID string + Header MsgHeader + Payload []byte + Subscribers []string + type MsgSendReq struct + ChannelID string + ChannelType uint8 + FromUID string + Header MsgHeader + Payload []byte + Setting uint8 + StreamNo string + Subscribers []string + func (m *MsgSendReq) String() string + type MsgSendResp struct + ClientMsgNo string + MessageID int64 + MessageSeq uint32 + type MsgSyncReq struct + Limit int + MessageSeq uint32 + UID string + type OPPOPush struct + AppID string + AppKey string + AppSecret string + MasterSecret string + PackageName string + type OSSConfig struct + AccessKeyID string + AccessKeySecret string + BucketName string + BucketURL string + Endpoint string + type OnlineStatus struct + DeviceFlag uint8 + Online bool + OnlineCount int + SocketID int64 + TotalOnlineCount int + UID string + type OnlineStatusListener func(onlineStatusList []OnlineStatus) + type OnlinestatusResp struct + DeviceFlag uint8 + LastOffline int + Online int + UID string + type OrgEmployeeExitReq struct + GroupNos []string + Operator string + type OrgOrDeptEmployeeVO struct + Action string + EmployeeName string + EmployeeUid string + GroupNo string + Operator string + OperatorName string + type P2pRtcMessageReq struct + CallType common.RTCCallType + FromUID string + ResultType common.RTCResultType + Second int + ToUID string + type PullMode int + const PullModeDown + const PullModeUp + type QiniuConfig struct + AccessKey string + BucketName string + SecretKey string + URL string + type ReactionResp struct + Count int + Emoji string + Seq string + Users []UserResp + type SMSProvider string + const SMSProviderAliyun + const SMSProviderUnisms + type SeaweedConfig struct + URL string + type Seq struct + CurSeq int64 + MaxSeq int64 + type Setting struct + NoUpdateConversation bool + Receipt bool + Signal bool + func SettingFromUint8(v uint8) Setting + func (s Setting) ToUint8() uint8 + type StreamItemResp struct + Blob []byte + ClientMsgNo string + StreamSeq uint32 + type SubscriberAddReq struct + ChannelID string + ChannelType uint8 + Reset int + Subscribers []string + type SubscriberRemoveReq struct + ChannelID string + ChannelType uint8 + Subscribers []string + type SyncChannelMessageReq struct + ChannelID string + ChannelType uint8 + DeviceUUID string + EndMessageSeq uint32 + Limit int + LoginUID string + PullMode PullMode + StartMessageSeq uint32 + type SyncChannelMessageResp struct + EndMessageSeq uint32 + Messages []*MessageResp + PullMode PullMode + StartMessageSeq uint32 + type SyncUserConversationResp struct + ChannelID string + ChannelType uint8 + LastClientMsgNo string + LastMsgSeq int64 + OffsetMsgSeq int64 + Recents []*MessageResp + Timestamp int64 + Unread int + Version int64 + type SyncUserConversationRespWrap struct + CMDVersion int64 + CMDs []*CMDResp + Conversations []*SyncUserConversationResp + type SyncackReq struct + LastMessageSeq uint32 + UID string + func (s SyncackReq) Check() error + func (s SyncackReq) String() string + type TablePartitionConfig struct + ChannelOffsetTableCount int + MessageTableCount int + MessageUserEditTableCount int + type Tracer struct + func NewTracer(cfg *Config) (*Tracer, error) + func (t *Tracer) Close() error + func (t *Tracer) ContextWithSpan(ctx context.Context, span opentracing.Span) context.Context + func (t *Tracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error) + func (t *Tracer) ExtractHTTPHeader(header http.Header) (opentracing.SpanContext, error) + func (t *Tracer) GinMiddle() gin.HandlerFunc + func (t *Tracer) Inject(sm opentracing.SpanContext, format interface{}, carrier interface{}) error + func (t *Tracer) InjectHTTPHeader(sm opentracing.SpanContext, header http.Header) error + func (t *Tracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span + func (t *Tracer) StartSpanFromContext(ctx context.Context, operationName string, opts ...opentracing.StartSpanOption) (opentracing.Span, context.Context) + type UnismsConfig struct + AccessKeyID string + AccessKeySecret string + Signature string + TemplateId string + type UpdateIMTokenReq struct + DeviceFlag DeviceFlag + DeviceLevel DeviceLevel + Token string + UID string + type UpdateIMTokenResp struct + Status UpdateTokenStatus + type UpdateSearchMessageReq struct + ChannelID string + MessageIDs []string + type UpdateTokenStatus int + const UpdateTokenStatusBan + const UpdateTokenStatusSuccess + type UserBaseVo struct + Name string + UID string + type UserResp struct + Name string + UID string + type VIVOPush struct + AppID string + AppKey string + AppSecret string + PackageName string
Go to main page