config

package

Go to main page

Versions in this module

v1

v1.0.8

Sep 27, 2024

Changes in this version

+ type ChannelDeleteReq struct

+ ChannelID string

+ ChannelType uint8

+ type ChannelMaxSeqResp struct

+ MessageSeq uint32

type Config

+ Friend struct{ ... }

+ Group struct{ ... }

+ Organization struct{ ... }

+ Qiniu QiniuConfig

+ ZincSearch struct{ ... }

+ func (c *Config) GetOrganizationLogoFilePath(orgId string) string

type Context

+ func (c *Context) IMDelChannel(req *ChannelDeleteReq) error

+ func (c *Context) IMGetChannelMaxSeq(channelID string, channelType uint8) (*ChannelMaxSeqResp, error)

+ func (c *Context) IMGetWithChannelAndSeqs(channelID string, channelType uint8, loginUID string, seqs []uint32) (*SyncChannelMessageResp, error)

+ func (c *Context) IMSearchMessages(req *MsgSearchReq) (*SyncChannelMessageResp, error)

+ type FIREBASEPush struct

+ JsonPath string

+ PackageName string

+ ProjectId string

type FileService

+ const FileServiceQiniu

+ type MsgGroupDisband struct

+ GroupNo string

+ Operator string

+ OperatorName string

type MsgOrgOrDeptCreateReq

+ Members []*OrgOrDeptEmployeeVO

+ type MsgSearchReq struct

+ ChannelID string

+ ChannelType uint8

+ ClientMsgNos []string

+ LoginUID string

+ MessageIds []int64

+ MessageSeqs []uint32

+ type QiniuConfig struct

+ AccessKey string

+ BucketName string

+ SecretKey string

+ URL string

+ type UpdateSearchMessageReq struct

+ ChannelID string

+ MessageIDs []string

v1.0.7

Dec 8, 2023

Changes in this version

type MinioConfig

+ DownloadURL string

+ UploadURL string

+ type MsgOrgOrDeptCreateReq struct

+ GroupCategory string

+ GroupNo string

+ Name string

+ Operator string

+ OperatorName string

+ type MsgOrgOrDeptEmployeeAddReq struct

+ GroupNo string

+ Members []*UserBaseVo

+ Name string

+ type MsgOrgOrDeptEmployeeUpdateReq struct

+ Members []*OrgOrDeptEmployeeVO

+ type OrgEmployeeExitReq struct

+ GroupNos []string

+ Operator string

+ type OrgOrDeptEmployeeVO struct

+ Action string

+ EmployeeName string

+ EmployeeUid string

+ GroupNo string

+ Operator string

+ OperatorName string

v1.0.6

Oct 10, 2023

Changes in this version

type Config

+ AdminPwd string

+ Message struct{ ... }

type Context

+ SetupTask bool

type MessageResp

+ Expire uint32

type UnismsConfig

+ AccessKeySecret string

+ TemplateId string

v1.0.5

Aug 6, 2023

v1.0.4

Aug 4, 2023

v1.0.3

Aug 3, 2023

v1.0.2

Aug 3, 2023

v1.0.1

Aug 1, 2023

Changes in this version

type OSSConfig

+ BucketName string

v1.0.0

Aug 1, 2023

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 ChannelInfoCreateReq struct

+ Ban int

+ ChannelID string

+ ChannelType uint8

+ Large int

+ 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

+ 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

+ GRPCAddr string

+ Gitee struct{ ... }

+ Github struct{ ... }

+ GroupUpgradeWhenMemberCount int

+ Logger struct{ ... }

+ MessageSaveAcrossDevice bool

+ Minio MinioConfig

+ Mode Mode

+ OSS OSSConfig

+ OWT struct{ ... }

+ OnlineStatusOn bool

+ PhoneSearchOff bool

+ Push struct{ ... }

+ QRCodeInfoURL string

+ 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{ ... }

+ 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) 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

+ 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) IMDeleteConversation(req DeleteConversationReq) error

+ func (c *Context) IMGetConversations(uid string) ([]*ConversationResp, 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) 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 FileService string

+ const FileServiceAliyunOSS

+ const FileServiceMinio

+ 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

+ 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

+ SecretAccessKey string

+ URL 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 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 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

+ 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 P2pRtcMessageReq struct

+ CallType common.RTCCallType

+ FromUID string

+ ResultType common.RTCResultType

+ Second int

+ ToUID string

+ type PullMode int

+ const PullModeDown

+ const PullModeUp

+ 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

+ Signature string

+ type UpdateIMTokenReq struct

+ DeviceFlag DeviceFlag

+ DeviceLevel DeviceLevel

+ Token string

+ UID string

+ type UpdateIMTokenResp struct

+ Status UpdateTokenStatus

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL