ioc

package
v0.0.0-...-f48fc76 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 15, 2025 License: MIT Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitAsynqClient

func InitAsynqClient() *asynq.Client

func InitAsynqServer

func InitAsynqServer() *asynq.Server

func InitCasbin

func InitCasbin(db *gorm.DB) *casbin.Enforcer

InitCasbin 初始化casbin权限管理器

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 InitDB

func InitDB() *gorm.DB

InitDB 初始化数据库

func InitES

func InitES() *elasticsearch.TypedClient

InitES 初始化elasticsearch

func InitLimiter

func InitLimiter(redis redis.Cmdable) Limiter

func InitLogger

func InitLogger() *zap.Logger

func InitMiddlewares

func InitMiddlewares(ih ijwt.Handler, l *zap.Logger) []gin.HandlerFunc

InitMiddlewares 初始化中间件

func InitMongoDB

func InitMongoDB() *mongo.Client

func InitRedis

func InitRedis() redis.Cmdable

func InitSaramaClient

func InitSaramaClient() sarama.Client

InitSaramaClient 初始化Sarama客户端,用于连接到Kafka集群

func InitScheduler

func InitScheduler() *asynq.Scheduler

func InitSms

func InitSms() *sms.TencentSms

InitSms 初始化腾讯云短信实例

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

func InitializeSnowflakeNode() *sf.Node

InitializeSnowflakeNode 初始化雪花节点

Types

type Cmd

type Cmd struct {
	Server    *gin.Engine
	Consumer  []events.Consumer
	Mock      mock.MockUserRepository
	Routes    *job.Routes
	Asynq     *asynq.Server
	Scheduler *job.TimedScheduler
}

func InitWebServer

func InitWebServer() *Cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳