ioc

Documentation

Index

• func InitAuthMiddleware(h jwt.Handler, l logx.Logger) middleware.Authentication
• func InitConsumers(inkRead *interactive.InkViewConsumer, review *review.Consumer, ...) []saramax.Consumer
• func InitDB(l logx.Logger) *gorm.DB
• func InitEs() *elasticsearch.Client
• func InitGeminiClient() []*genai.Client
• func InitGin(handlers []ginx.Handler, l logx.Logger) *gin.Engine
• func InitGorseCli() *gorsex.Client
• func InitJwtHandler(cmd redis.Cmdable) jwt.Handler
• func InitKafka() sarama.Client
• func InitLogger() logx.Logger
• func InitMeiliSearch() meilisearch.ServiceManager
• func InitOtel(l logx.Logger) func(ctx context.Context)
• func InitRedisCmdable(client redis.UniversalClient) redis.Cmdable
• func InitRedisUniversalClient() redis.UniversalClient
• func InitSchedulers(rankInk RankInkScheduler, rankTag RankTagScheduler, ...) []schedulex.Scheduler
• func InitSyncProducer(client sarama.Client) sarama.SyncProducer
• func InitTemporalClient() client.Client
• func InitWorkers(inkPub *InkPubWorker, rankTag *RankTagWorker, rankInk *RankInkWorker, ...) []worker.Worker
• type App
  • func InitApp() *App
• type InkPubWorker
  • func InitInkPubWorker(cli client.Client, activities *inkpub.Activities) *InkPubWorker
• type RankInkScheduler
  • func InitRankInkScheduler(cli client.Client) RankInkScheduler
  • func (r RankInkScheduler) Start() error
• type RankInkWorker
  • func InitRankInkWorker(cli client.Client, activities *schedule.RankActivities) *RankInkWorker
• type RankTagScheduler
  • func InitRankTagScheduler(cli client.Client) RankTagScheduler
  • func (r RankTagScheduler) Start() error
• type RankTagWorker
  • func InitRankTagWorker(cli client.Client, activities *schedule.RankActivities) *RankTagWorker
• type RetryReviewWorker
  • func InitRetryReviewWorker(cli client.Client, activities *schedule.ReviewFailoverActivity) *RetryReviewWorker
• type ReviewFailRetryScheduler
  • func InitReviewRetryScheduler(cli client.Client) ReviewFailRetryScheduler
  • func (r ReviewFailRetryScheduler) Start() error

Functions

func InitAuthMiddleware

func InitAuthMiddleware(h jwt.Handler, l logx.Logger) middleware.Authentication

func InitConsumers

func InitConsumers(inkRead *interactive.InkViewConsumer, review *review.Consumer,
	search *search.SyncConsumer, notification *notification.SyncConsumer,
	recommend *recommend.SyncConsumer) []saramax.Consumer

func InitDB

func InitDB(l logx.Logger) *gorm.DB

func InitEs

func InitEs() *elasticsearch.Client

func InitGeminiClient

func InitGeminiClient() []*genai.Client

func InitGin

func InitGin(handlers []ginx.Handler, l logx.Logger) *gin.Engine

func InitGorseCli

func InitGorseCli() *gorsex.Client

func InitJwtHandler

func InitJwtHandler(cmd redis.Cmdable) jwt.Handler

func InitKafka

func InitKafka() sarama.Client

func InitLogger

func InitLogger() logx.Logger

func InitLogger() logx.Logger {
	l, err := zap.NewDevelopment(zap.AddCallerSkip(1))
	if err != nil {
		panic(err)
	}
	logger := logx.NewZapLogger(l)
	logx.Register(logger)
	return logger
}

func InitMeiliSearch

func InitMeiliSearch() meilisearch.ServiceManager

func InitOtel

func InitOtel(l logx.Logger) func(ctx context.Context)

func InitRedisCmdable

func InitRedisCmdable(client redis.UniversalClient) redis.Cmdable

func InitRedisUniversalClient

func InitRedisUniversalClient() redis.UniversalClient

func InitSchedulers

func InitSchedulers(rankInk RankInkScheduler, rankTag RankTagScheduler, reviewRetry ReviewFailRetryScheduler) []schedulex.Scheduler

func InitSyncProducer

func InitSyncProducer(client sarama.Client) sarama.SyncProducer

func InitTemporalClient

func InitTemporalClient() client.Client

func InitWorkers

func InitWorkers(inkPub *InkPubWorker, rankTag *RankTagWorker, rankInk *RankInkWorker, retryReview *RetryReviewWorker) []worker.Worker

Types

type App

type App struct {
	Server     *gin.Engine
	Consumers  []saramax.Consumer
	Workers    []worker.Worker
	Schedulers []schedulex.Scheduler
}

func InitApp

func InitApp() *App

type InkPubWorker

type InkPubWorker struct {
	worker.Worker
}

func InitInkPubWorker

func InitInkPubWorker(cli client.Client, activities *inkpub.Activities) *InkPubWorker

type RankInkScheduler

type RankInkScheduler func() error

func InitRankInkScheduler

func InitRankInkScheduler(cli client.Client) RankInkScheduler

func (RankInkScheduler) Start

func (r RankInkScheduler) Start() error

type RankInkWorker

type RankInkWorker struct {
	worker.Worker
}

func InitRankInkWorker

func InitRankInkWorker(cli client.Client, activities *schedule.RankActivities) *RankInkWorker

type RankTagScheduler

type RankTagScheduler func() error

func InitRankTagScheduler

func InitRankTagScheduler(cli client.Client) RankTagScheduler

func (RankTagScheduler) Start

func (r RankTagScheduler) Start() error

type RankTagWorker

type RankTagWorker struct {
	worker.Worker
}

func InitRankTagWorker

func InitRankTagWorker(cli client.Client, activities *schedule.RankActivities) *RankTagWorker

type RetryReviewWorker

type RetryReviewWorker struct {
	worker.Worker
}

func InitRetryReviewWorker

func InitRetryReviewWorker(cli client.Client, activities *schedule.ReviewFailoverActivity) *RetryReviewWorker

type ReviewFailRetryScheduler

type ReviewFailRetryScheduler func() error

func InitReviewRetryScheduler

func InitReviewRetryScheduler(cli client.Client) ReviewFailRetryScheduler

func (ReviewFailRetryScheduler) Start

func (r ReviewFailRetryScheduler) Start() error