MCPcopy Create free account

hub / github.com/GoSimplicity/LinkMe / functions

Functions1,482 in github.com/GoSimplicity/LinkMe

⨍ Functions 1,482◇ Types & classes 383
↓ 1 callersMethodWrapProducer
WrapProducer 为 Sarama 同步生产者包装一个带有指标记录的生产者
pkg/samarap/prometheus/prometheus.go:23
↓ 1 callersMethodaddSubNode
(char rune, node *TrieNode)
utils/contentfilter/contentfilter.go:143
↓ 1 callersMethodaddToBlacklist
addToBlacklist 将 token 加入 Redis 黑名单
utils/jwt/jwt.go:234
↓ 1 callersMethodapiFromDAO
apiFromDAO 将API DAO模型转换为领域模型
internal/repository/role.go:169
↓ 1 callersMethodapisFromDAO
apisFromDAO 将DAO层的API对象列表转换为domain层对象列表
internal/repository/api.go:122
↓ 1 callersMethodapisFromDAO
apisFromDAO 批量将API DAO模型转换为领域模型
internal/repository/role.go:155
↓ 1 callersMethodautoFlush
自动刷新缓冲区的协程
internal/domain/events/es/process_util.go:62
↓ 1 callersMethodautoFlush
自动刷新缓冲区的协程
internal/domain/events/es/process_util.go:112
↓ 1 callersMethodbuildResults
buildResults 构建结果列表
internal/service/ranking.go:262
↓ 1 callersMethodbulkInsertPost
(ctx context.Context, posts []Post)
internal/domain/events/es/consumer.go:387
↓ 1 callersMethodbulkInsertUser
(ctx context.Context, users []User)
internal/domain/events/es/consumer.go:372
↓ 1 callersMethodcomputeTopN
computeTopN 计算排名前 N 的帖子
internal/service/ranking.go:134
↓ 1 callersFunctionconvertToDAOLotteryDraw
convertToDAOLotteryDraw 将 domain.LotteryDraw 转换为 dao.LotteryDraw
internal/repository/lotteryDraw.go:260
↓ 1 callersFunctionconvertToDAOSecondKillEvent
convertToDAOSecondKillEvent 将 domain.SecondKillEvent 转换为 dao.SecondKillEvent
internal/repository/lotteryDraw.go:297
↓ 1 callersFunctionconvertToDomainParticipant
convertToDomainParticipant 将 dao.Participant 转换为 domain.Participant
internal/repository/lotteryDraw.go:359
↓ 1 callersFunctioncreateContentSummary
createContentSummary 创建内容摘要,限制为28个汉字
internal/repository/history.go:57
↓ 1 callersMethodcurrentTime
()
internal/repository/dao/user.go:77
↓ 1 callersMethoddeleteCommentIndex
deleteCommentIndex 删除评论索引
internal/domain/events/es/consumer.go:312
↓ 1 callersMethoddeletePostIndex
deletePostIndex 删除文章索引
internal/domain/events/es/consumer.go:403
↓ 1 callersMethoddeleteUserIndex
(ctx context.Context, user User)
internal/domain/events/es/consumer.go:422
↓ 1 callersMethodenqueueScore
enqueueScore 将分数加入优先队列
internal/service/ranking.go:233
↓ 1 callersMethodextractBearerToken
extractBearerToken 提取 Bearer Token
utils/jwt/jwt.go:219
↓ 1 callersMethodfetchInteractions
fetchInteractions 获取帖子的交互数据
internal/service/ranking.go:209
↓ 1 callersMethodfetchPosts
fetchPosts 获取分页后的已发布帖子
internal/service/ranking.go:199
↓ 1 callersFunctionfromDomainActivity
将领域层对象转为dao层对象
internal/repository/activity.go:42
↓ 1 callersFunctionfromDomainSlicePlate
将dao层对象转为领域层对象
internal/repository/plate.go:51
↓ 1 callersFunctionfromDomainUser
fromDomainUser 将领域层对象转为dao层对象
internal/repository/user.go:195
↓ 1 callersFunctiongetClient
获取单例 client
utils/aicheck/doubao.go:43
↓ 1 callersFunctiongetTime
()
ioc/snowflake.go:19
↓ 1 callersMethodhandleAsyncTasks
handleAsyncTasks 处理异步任务
internal/domain/events/check/consumer.go:241
↓ 1 callersMethodhandleDeadLetterMessage
handleDeadLetterMessage 处理死信消息的具体业务逻辑
internal/domain/events/post/dlq_processor.go:155
↓ 1 callersMethodhandleDeadLetterMessage
(ctx context.Context, evt *CheckEvent)
internal/domain/events/check/dlq_processor.go:144
↓ 1 callersMethodhandleDeadLetterMessage
handleDeadLetterMessage 处理死信消息的具体业务逻辑
internal/domain/events/publish/dlq_process.go:150
↓ 1 callersMethodhandleEsPost
handleEsPost 处理文章的ES操作，发布或删除索引
internal/domain/events/es/consumer.go:239
↓ 1 callersMethodhandleEsUser
handleEsUser 处理用户的ES操作，创建或删除用户索引
internal/domain/events/es/consumer.go:255
↓ 1 callersFunctionhandleEvent
(event ChangeEvent)
internal/domain/events/canal/consumer_test.go:133
↓ 1 callersMethodhandleEvent
handleEvent 处理发布事件
internal/domain/events/comment/consumer.go:170
↓ 1 callersMethodhandleEvent
handleEvent 处理阅读事件
internal/domain/events/post/consumer.go:189
↓ 1 callersMethodhandleEvent
handleEvent 处理审核事件
internal/domain/events/check/consumer.go:197
↓ 1 callersMethodhandleEvent
handleEvent 处理发布事件
internal/domain/events/publish/consumer.go:198
↓ 1 callersFunctioninitEsClient
(t *testing.T)
internal/domain/events/es/consumer_test.go:39
↓ 1 callersFunctioninitKafka
(t *testing.T)
internal/domain/events/canal/consumer_test.go:96
↓ 1 callersFunctioninitKafka
(t *testing.T)
internal/domain/events/es/consumer_test.go:18
↓ 1 callersFunctioninitLogger
()
internal/domain/events/es/consumer_test.go:33
↓ 1 callersMethodinvalidateSession
(ctx *gin.Context, ssid string)
utils/jwt/jwt.go:245
↓ 1 callersFunctionisSymbol
(char rune)
utils/contentfilter/contentfilter.go:124
↓ 1 callersMethodmenuFromDAO
menuFromDAO 将菜单DAO模型转换为领域模型
internal/repository/role.go:189
↓ 1 callersFunctionnewClient
newClient 创建腾讯云短信客户端
ioc/sms.go:13
↓ 1 callersMethodprocessBatch
processBatch 处理一批帖子
internal/service/ranking.go:164
↓ 1 callersMethodprocessDLQMessage
processDLQMessage 处理死信队列中的消息
internal/domain/events/post/dlq_processor.go:115
↓ 1 callersMethodprocessDLQMessage
(msg *sarama.ConsumerMessage)
internal/domain/events/check/dlq_processor.go:108
↓ 1 callersMethodprocessDLQMessage
processDLQMessage 处理死信队列中的消息
internal/domain/events/publish/dlq_process.go:110
↓ 1 callersMethodprocessLotteryParticipation
processLotteryParticipation 处理抽奖参与逻辑
internal/service/lotteryDraw.go:242
↓ 1 callersMethodprocessMessage
processMessage 处理从 Kafka 消费的消息
internal/domain/events/comment/consumer.go:91
↓ 1 callersMethodprocessMessage
processMessage 处理从 Kafka 消费的消息
internal/domain/events/post/consumer.go:120
↓ 1 callersMethodprocessMessage
processMessage 处理从 Kafka 消费的消息
internal/domain/events/check/consumer.go:128
↓ 1 callersMethodprocessMessage
processMessage 处理从 Kafka 消费的消息
internal/domain/events/publish/consumer.go:118
↓ 1 callersMethodprocessSecondKillParticipation
processSecondKillParticipation 处理秒杀参与逻辑
internal/service/lotteryDraw.go:300
↓ 1 callersMethodpushOrUpdateCommentIndex
pushOrUpdateCommentIndex 创建或更新评论索引
internal/domain/events/es/consumer.go:289
↓ 1 callersMethodpushOrUpdatePostIndex
pushOrUpdatePostIndex 创建或更新文章索引
internal/domain/events/es/consumer.go:263
↓ 1 callersMethodpushOrUpdateUserIndex
pushOrUpdateUserIndex 创建或更新用户索引
internal/domain/events/es/consumer.go:345
↓ 1 callersMethodrefresh
refresh 更新任务的更新时间
internal/service/sql_job.go:71
↓ 1 callersMethodrefreshAllCache
刷新所有类型缓存
internal/job/refresh_cache.go:101
↓ 1 callersMethodrefreshNormalCache
刷新普通帖子缓存
internal/job/refresh_cache.go:85
↓ 1 callersMethodrefreshPubCache
刷新发布的帖子缓存
internal/job/refresh_cache.go:69
↓ 1 callersMethodregisterTask
(taskName, cronSpec string)
internal/job/scheduler.go:36
↓ 1 callersMethodrolesFromDAO
rolesFromDAO 批量将DAO模型转换为领域模型
internal/repository/role.go:127
↓ 1 callersMethodrunStatusUpdater
runStatusUpdater 启动后台定时任务，每10秒更新一次活动状态
internal/service/lotteryDraw.go:76
↓ 1 callersMethodsendToDLQ
sendToDLQ 发送消息到死信队列
internal/domain/events/post/consumer.go:99
↓ 1 callersMethodsendToDLQ
sendToDLQ 发送消息到死信队列
internal/domain/events/check/consumer.go:107
↓ 1 callersMethodsendToDLQ
sendToDLQ 发送消息到死信队列
internal/domain/events/publish/consumer.go:97
↓ 1 callersFunctionsetDefaults
()
config/viper.go:31
↓ 1 callersMethodsetRefreshToken
setRefreshToken 设置长Token
utils/jwt/jwt.go:139
↓ 1 callersFunctionstartMetricsServer
startMetricsServer 启动 Prometheus 监控服务器
cmd/main.go:87
↓ 1 callersFunctionstringToTimeHookFunc
stringToTimeHookFunc 转换字符串到时间类型
internal/domain/events/es/process_util.go:181
↓ 1 callersMethodtoDaoCommentSearch
(domainComments domain.CommentSearch)
internal/repository/search.go:119
↓ 1 callersFunctiontoDaoRankingParameter
(rankingParameter domain.RankingParameter)
internal/repository/rankingparameters.go:51
↓ 1 callersMethodtoDaoReadEvent
(events []domain.ReadEvent)
internal/repository/search.go:138
↓ 1 callersFunctiontoDomainActivities
将dao层对象转为领域层对象
internal/repository/activity.go:52
↓ 1 callersFunctiontoDomainChecks
toDomainChecks 将 []dao.Check 转换为 []domain.Check
internal/repository/check.go:109
↓ 1 callersMethodtoDomainCommentSearch
(daoComments []dao.CommentSearch)
internal/repository/search.go:179
↓ 1 callersFunctiontoDomainHistory
toDomainHistory 将帖子转换为历史记录
internal/repository/history.go:69
↓ 1 callersMethodtoDomainPostSearch
(daoPosts []dao.PostSearch)
internal/repository/search.go:151
↓ 1 callersFunctiontoDomainRankingParameter
(rankingParameter dao.RankingParameter)
internal/repository/rankingparameters.go:42
↓ 1 callersMethodtoDomainRelation
(relation dao.Relation)
internal/repository/relation.go:136
↓ 1 callersMethodtoDomainUserSearch
(daoUsers []dao.UserSearch)
internal/repository/search.go:165
↓ 1 callersMethodupdateEventStatuses
updateEventStatuses 更新所有活动的状态
internal/service/lotteryDraw.go:93
↓ 1 callersMethodupdateLotteryDrawStatuses
updateLotteryDrawStatuses 更新所有抽奖活动的状态
internal/service/lotteryDraw.go:108
↓ 1 callersMethodupdateSecondKillEventStatuses
updateSecondKillEventStatuses 更新所有秒杀活动的状态
internal/service/lotteryDraw.go:155
↓ 1 callersMethodupdateSingleLotteryDrawStatus
updateSingleLotteryDrawStatus 确保单个抽奖活动的状态是最新的
internal/service/lotteryDraw.go:358
↓ 1 callersMethodupdateSingleSecondKillEventStatus
updateSingleSecondKillEventStatus 确保单个秒杀活动的状态是最新的
internal/service/lotteryDraw.go:387
↓ 1 callersMethodvalidateCache
()
internal/repository/cache/local.go:85
↓ 1 callersMethodvalidateEvent
validateEvent 验证事件参数是否有效
internal/domain/events/comment/consumer.go:151
↓ 1 callersMethodvalidateEvent
validateEvent 验证事件参数是否有效
internal/domain/events/post/consumer.go:173
↓ 1 callersMethodvalidateEvent
validateEvent 验证事件参数是否有效
internal/domain/events/check/consumer.go:181
↓ 1 callersMethodvalidateEvent
validateEvent 验证事件参数是否有效
internal/domain/events/publish/consumer.go:178
↓ 1 callersMethodvalidateLotteryDraw
validateLotteryDraw 验证抽奖活动的状态和时间
internal/service/lotteryDraw.go:416
↓ 1 callersFunctionvalidateLotteryDrawInput
validateLotteryDrawInput 验证创建抽奖活动的输入
internal/service/lotteryDraw.go:604
↓ 1 callersMethodvalidateMessage
validateMessage 验证消息是否有效
internal/domain/events/comment/consumer.go:136
↓ 1 callersMethodvalidateMessage
validateMessage 验证消息是否有效
internal/domain/events/post/consumer.go:158
← previousnext →601–700 of 1,482, ranked by callers