Documentation
¶
Index ¶
- func InitAsynqClient() *asynq.Client
- func InitAsynqServer() *asynq.Server
- func InitCasbin(db *gorm.DB) *casbin.Enforcer
- func InitConsumers(postConsumer *post.EventConsumer, smsConsumer *sms.SMSConsumer, ...) []events.Consumer
- func InitDB() *gorm.DB
- func InitES() *elasticsearch.TypedClient
- func InitLimiter(redis redis.Cmdable) Limiter
- func InitLogger() *zap.Logger
- func InitMiddlewares(ih ijwt.Handler, l *zap.Logger) []gin.HandlerFunc
- func InitMongoDB() *mongo.Client
- func InitRankingService(svc service.RankingService) interfaces.RankingService
- func InitRedis() redis.Cmdable
- func InitSaramaClient() sarama.Client
- func InitScheduler() *asynq.Scheduler
- func InitSms() *sms.TencentSms
- func InitSyncProducer(c sarama.Client) sarama.SyncProducer
- func InitWeb(userHdl *api.UserHandler, postHdl *api.PostHandler, ...) *gin.Engine
- func InitializeSnowflakeNode() *sf.Node
- type Cmd
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitAsynqClient ¶
func InitAsynqServer ¶
func InitConsumers ¶
func InitConsumers( postConsumer *post.EventConsumer, smsConsumer *sms.SMSConsumer, commentConsumer *comment.PublishCommentEventConsumer, emailConsumer *email.EmailConsumer, publishConsumer *publish.PublishPostEventConsumer, esConsumer *es.EsConsumer, checkConsumer *check.CheckEventConsumer, postDLQConsumer *post.PostDeadLetterConsumer, publishDLQConsumer *publish.PublishDeadLetterConsumer, checkDLQConsumer *check.CheckDeadLetterConsumer, ) []events.Consumer
InitConsumers 初始化并返回一个事件消费者
func InitLimiter ¶
func InitLimiter(redis redis.Cmdable) Limiter
func InitLogger ¶
func InitMiddlewares ¶
InitMiddlewares 初始化中间件
func InitMongoDB ¶
func InitRankingService ¶
func InitRankingService(svc service.RankingService) interfaces.RankingService
func InitSaramaClient ¶
InitSaramaClient 初始化Sarama客户端,用于连接到Kafka集群
func InitScheduler ¶
func InitSyncProducer ¶
func InitSyncProducer(c sarama.Client) sarama.SyncProducer
InitSyncProducer 使用已有的Sarama客户端初始化同步生产者
func InitWeb ¶
func InitWeb(userHdl *api.UserHandler, postHdl *api.PostHandler, historyHdl *api.HistoryHandler, checkHdl *api.CheckHandler, m []gin.HandlerFunc, permHdl *api.PermissionHandler, rankingHdl *api.RankingHandler, plateHdl *api.PlateHandler, activityHdl *api.ActivityHandler, commentHdl *api.CommentHandler, searchHdl *api.SearchHandler, relationHdl *api.RelationHandler, lotteryDrawHdl *api.LotteryDrawHandler, roleHdl *api.RoleHandler, menuHdl *api.MenuHandler, apiHdl *api.ApiHandler, ) *gin.Engine
InitWeb 初始化web服务
func InitializeSnowflakeNode ¶
InitializeSnowflakeNode 初始化雪花节点
Types ¶
Click to show internal directories.
Click to hide internal directories.