Documentation
¶
Index ¶
- func ProvideConfig() (*config.Config, error)
- func ProvideDB(ctx context.Context, cfg *config.Config) (transactions.TransactionManager, error)
- func ProvideEventBus(mq contract.MQ) event.Bus
- func ProvideEventConsumerService(mq contract.MQ, logger *zap.Logger) *event.ConsumerService
- func ProvideEventPublisherPort(bus event.Bus) domainSharedPort.EventPublisher
- func ProvideEventServer(cfg *config.Config, eventConsumer *event.ConsumerService, ...) *eventServer.Server
- func ProvideFilePolicyPort(cfg *config.Config) domainFilePort.FilePolicy
- func ProvideFileStoragePort(st *storage.Storage) domainFilePort.FileStorage
- 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 ProvideTransactionManagerPort(tx transactions.TransactionManager) domainSharedPort.TransactionManager
- func ProvideWebSocketServer(cfg *config.Config, ws *webSocket.WebSocket) *websocket.Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ProvideDB ¶
func ProvideDB(ctx context.Context, cfg *config.Config) (transactions.TransactionManager, error)
ProvideDB 提供数据库
func ProvideEventConsumerService ¶
ProvideEventConsumerService 提供事件消费者服务
func ProvideEventPublisherPort ¶
func ProvideEventPublisherPort(bus event.Bus) domainSharedPort.EventPublisher
ProvideEventPublisherPort 提供端口适配器:事件发布
func ProvideEventServer ¶
func ProvideEventServer( cfg *config.Config, eventConsumer *event.ConsumerService, registry *diEvent.HandlerRegistry, ) *eventServer.Server
ProvideEventServer 提供Event服务器
func ProvideFilePolicyPort ¶
func ProvideFilePolicyPort(cfg *config.Config) domainFilePort.FilePolicy
ProvideFilePolicyPort 提供端口适配器:文件策略
func ProvideFileStoragePort ¶
func ProvideFileStoragePort(st *storage.Storage) domainFilePort.FileStorage
ProvideFileStoragePort 提供端口适配器:文件存储
func ProvideGRPCServer ¶
func ProvideGRPCServer(ctx context.Context, cfg *config.Config, serviceRegistry *GRPC.ServiceRegistry) *grpc.Server
ProvideGRPCServer 提供gRPC服务器
func ProvideHTTPServer ¶
ProvideHTTPServer 提供HTTP服务器
func ProvideHealthServer ¶
ProvideHealthServer 提供容器环境健康检查服务
func ProvideLogger ¶
ProvideLogger 提供日志
func ProvideMessageQueue ¶
ProvideMessageQueue 提供消息队列
func ProvideMonitor ¶
ProvideMonitor 提供可观测性配置
func ProvideRedis ¶
ProvideRedis 提供redis
func ProvideStorage ¶
ProvideStorage 提供文件存储
func ProvideTransactionManagerPort ¶
func ProvideTransactionManagerPort(tx transactions.TransactionManager) domainSharedPort.TransactionManager
ProvideTransactionManagerPort 提供端口适配器:事务管理
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.