Documentation
¶
Index ¶
- func CORSMiddleware() gin.HandlerFunc
- func InitDB(l logger.LoggerV1) *gorm.DB
- func InitEtcd() *clientv3.Client
- func InitIntrGRPCClient(svc service.InteractiveService) intrv1.InteractiveServiceClient
- func InitIntrGRPCClientV1(client *clientv3.Client) intrv1.InteractiveServiceClient
- func InitJobs(l logger.LoggerV1, rankingJob *job.RankingJob) *cronv3.Cron
- func InitKafka() sarama.Client
- func InitLogger() logger.LoggerV1
- func InitMiddleware(redisClients redisv9.Cmdable, l logger2.LoggerV1, jwtHdl ijwt.Handler) []gin.HandlerFunc
- func InitMongoDB() *mongo.Database
- func InitOTEL() func(ctx context.Context)
- func InitRLockClient(cmd redisv9.Cmdable) *rlock.Client
- func InitRankingJob(svc service.RankingService, client *rlock.Client, l logger.LoggerV1) *job.RankingJob
- func InitRedis() redisv9.Cmdable
- func InitUserHook(client *redisv9.Client) cache.APICache
- func InitWebServer(middleware []gin.HandlerFunc, aiHandler *web.AIHandler, ...) *gin.Engine
- func NewConsumers(debugLog *events.DebugLogEventConsumer) []saramax.Consumer
- func NewSyncProducer(client sarama.Client) sarama.SyncProducer
- func TestInitKafka(t *testing.T)
- func TestPath(t *testing.T)
- type Callbacks
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CORSMiddleware ¶
func CORSMiddleware() gin.HandlerFunc
func InitIntrGRPCClient ¶
func InitIntrGRPCClient(svc service.InteractiveService) intrv1.InteractiveServiceClient
InitIntrGRPCClient 这是流量控制的客户端
func InitIntrGRPCClientV1 ¶
func InitIntrGRPCClientV1(client *clientv3.Client) intrv1.InteractiveServiceClient
真正的 gRPC的客户端
func InitLogger ¶
func InitMiddleware ¶
func InitMongoDB ¶
func InitRankingJob ¶
func InitRankingJob(svc service.RankingService, client *rlock.Client, l logger.LoggerV1) *job.RankingJob
func InitUserHook ¶
InitUserHook 配合 PrometheusHook 使用
func InitWebServer ¶
func InitWebServer(middleware []gin.HandlerFunc, aiHandler *web.AIHandler, userHandler *web.UserHandler, apiHandler *web.APIHandler, taskHandler *web.TaskHandler, notehandler *web.NoteHandler, cronJobhandler *web.CronJobHandler) *gin.Engine
func NewConsumers ¶
func NewConsumers(debugLog *events.DebugLogEventConsumer) []saramax.Consumer
NewConsumers 注意:所有的 Consumer 在这里注册一下
func NewSyncProducer ¶
func NewSyncProducer(client sarama.Client) sarama.SyncProducer
func TestInitKafka ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.