di

package

v0.5.0 Latest Latest Go to latest Published: Oct 19, 2025 License: MIT Imports: 36 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dysodeng/app

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ProvideConfig() (*config.Config, error)
func ProvideDB(ctx context.Context, cfg *config.Config) (transactions.TransactionManager, error)
func ProvideEventConsumerService(mq contract.MQ, logger *zap.Logger) *event.ConsumerService
func ProvideEventServer(cfg *config.Config, eventConsumer *event.ConsumerService, ...) *eventServer.Server
func ProvideGRPCServer(ctx context.Context, cfg *config.Config, serviceRegistry *GRPC.ServiceRegistry) *grpc.Server
func ProvideHTTPServer(cfg *config.Config, handlerRegistry *HTTP.HandlerRegistry) *http.Server
func ProvideHealthServer(cfg *config.Config) *health.Server
func ProvideLogger(ctx context.Context, cfg *config.Config) (*zap.Logger, error)
func ProvideMessageQueue(cfg *config.Config) (contract.MQ, error)
func ProvideMonitor(cfg *config.Config) (*telemetry.Monitor, error)
func ProvideRedis(cfg *config.Config) (redis.Client, error)
func ProvideStorage(cfg *config.Config) (*storage.Storage, error)
func ProvideTypedEventBus(mq contract.MQ) event.Bus
func ProvideWebSocketServer(cfg *config.Config, ws *webSocket.WebSocket) *websocket.Server
type App
- func InitApp(ctx context.Context) (*App, error)
- func NewApp(config *config.Config, monitor *telemetry.Monitor, logger *zap.Logger, ...) *App
- func (app *App) Stop(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

View Source

var AllModulesSet = wire.NewSet(

	modules.SharedModuleSet,
	modules.PassportModuleSet,
	modules.FileModuleSet,
)

AllModulesSet 所有业务模块的聚合Wire Set

View Source

var InfrastructureSet = wire.NewSet(
	ProvideConfig,
	ProvideMonitor,
	ProvideLogger,
	ProvideDB,
	ProvideRedis,
	ProvideMessageQueue,
	ProvideStorage,
	ProvideTypedEventBus,
	ProvideEventConsumerService,
)

InfrastructureSet 基础设施

View Source

var WebSocketSet = wire.NewSet(
	websocket.NewTextMessageHandler,
	websocket.NewBinaryMessageHandler,
	websocket.NewWebSocket,
)

WebSocketSet WebSocket聚合依赖

Functions ¶

func ProvideConfig ¶ added in v0.5.0

func ProvideConfig() (*config.Config, error)

ProvideConfig 提供配置

func ProvideDB ¶ added in v0.5.0

func ProvideDB(ctx context.Context, cfg *config.Config) (transactions.TransactionManager, error)

ProvideDB 提供数据库

func ProvideEventConsumerService ¶ added in v0.5.0

func ProvideEventConsumerService(mq contract.MQ, logger *zap.Logger) *event.ConsumerService

ProvideEventConsumerService 提供事件消费者服务

func ProvideEventServer ¶ added in v0.5.0

func ProvideEventServer(
	cfg *config.Config,
	eventConsumer *event.ConsumerService,
	registry *diEvent.HandlerRegistry,
) *eventServer.Server

ProvideEventServer 提供Event服务器

func ProvideGRPCServer ¶ added in v0.5.0

func ProvideGRPCServer(ctx context.Context, cfg *config.Config, serviceRegistry *GRPC.ServiceRegistry) *grpc.Server

ProvideGRPCServer 提供gRPC服务器

func ProvideHTTPServer ¶ added in v0.5.0

func ProvideHTTPServer(cfg *config.Config, handlerRegistry *HTTP.HandlerRegistry) *http.Server

ProvideHTTPServer 提供HTTP服务器

func ProvideHealthServer ¶ added in v0.5.0

func ProvideHealthServer(cfg *config.Config) *health.Server

ProvideHealthServer 提供容器环境健康检查服务

func ProvideLogger ¶ added in v0.5.0

func ProvideLogger(ctx context.Context, cfg *config.Config) (*zap.Logger, error)

ProvideLogger 提供日志

func ProvideMessageQueue ¶ added in v0.5.0

func ProvideMessageQueue(cfg *config.Config) (contract.MQ, error)

ProvideMessageQueue 提供消息队列

func ProvideMonitor ¶ added in v0.5.0

func ProvideMonitor(cfg *config.Config) (*telemetry.Monitor, error)

ProvideMonitor 提供可观测性配置

func ProvideRedis ¶ added in v0.5.0

func ProvideRedis(cfg *config.Config) (redis.Client, error)

ProvideRedis 提供redis

func ProvideStorage ¶ added in v0.5.0

func ProvideStorage(cfg *config.Config) (*storage.Storage, error)

ProvideStorage 提供文件存储

func ProvideTypedEventBus ¶ added in v0.5.0

func ProvideTypedEventBus(mq contract.MQ) event.Bus

ProvideTypedEventBus 提供类型化事件总线

func ProvideWebSocketServer ¶ added in v0.5.0

func ProvideWebSocketServer(cfg *config.Config, ws *webSocket.WebSocket) *websocket.Server

ProvideWebSocketServer 提供WebSocket服务器

Types ¶

type App ¶ added in v0.5.0

type App struct {
	Config               *config.Config
	Monitor              *telemetry.Monitor
	Logger               *zap.Logger
	TxManager            transactions.TransactionManager
	RedisClient          redis.Client
	MessageQueue         contract.MQ
	Storage              *storage.Storage
	HandlerRegistry      *HTTP.HandlerRegistry
	WebSocketRegistry    *webSocket.WebSocket
	EventHandlerRegistry *diEvent.HandlerRegistry
	GRPCServiceRegistry  *GRPC.ServiceRegistry
	HTTPServer           *http.Server
	GRPCServer           *grpc.Server
	WSServer             *websocket.Server
	HealthServer         *health.Server
	EventBus             event.Bus
	EventConsumer        *event.ConsumerService
	EventServer          *eventServer.Server
}

App 应用程序

func InitApp ¶ added in v0.5.0

func InitApp(ctx context.Context) (*App, error)

InitApp 初始化应用程序

func NewApp ¶ added in v0.5.0

func NewApp(
	config *config.Config,
	monitor *telemetry.Monitor,
	logger *zap.Logger,
	txManager transactions.TransactionManager,
	redisClient redis.Client,
	messageQueue contract.MQ,
	storage *storage.Storage,
	handlerRegistry *HTTP.HandlerRegistry,
	webSocketRegistry *webSocket.WebSocket,
	eventHandlerRegistry *diEvent.HandlerRegistry,
	gRPCServiceRegistry *GRPC.ServiceRegistry,
	httpServer *http.Server,
	grpcServer *grpc.Server,
	wsServer *websocket.Server,
	healthServer *health.Server,
	eventBus event.Bus,
	eventConsumer *event.ConsumerService,
	eventServer *eventServer.Server,
) *App

NewApp 创建应用程序

func (*App) Stop ¶ added in v0.5.0

func (app *App) Stop(ctx context.Context) error

Stop 停止应用相关服务

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
event
modules

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL