app

Documentation

Index

• Variables
• func InvokeBackgroundHealthChecker(lc fx.Lifecycle, mtconnectSvc interfaces.Usecases, logger *logging.Logger)
• func InvokeGracefulShutdown(lc fx.Lifecycle, mtconnectSvc interfaces.MTConnectService, ...)
• func InvokeHttpServer(lc fx.Lifecycle, cfg *config.AppConfig, h http.Handler, logger *logging.Logger)
• func InvokeRestoreConnections(lc fx.Lifecycle, mtconnectSvc interfaces.Usecases, ...)
• func New() *fx.App
• func NewSwaggerConfig() *swagger.Config
• func ProvideLogger(cfg *config.AppConfig) *logging.Logger

Variables

var ConfigModule = fx.Module("config_module",
	fx.Provide(config.LoadConfiguration),
)

var HttpServerModule = fx.Module("http_server_module",
	fx.Provide(
		NewSwaggerConfig,
		handlers.NewHandler,
		handlers.ProvideRouter,
	),
	fx.Invoke(InvokeHttpServer, InvokeGracefulShutdown),
)

var LoggingModule = fx.Module("logging_module",
	fx.Provide(ProvideLogger),
)

var ProducerModule = fx.Module("producer_module",
	fx.Provide(kafka.NewKafkaProducer),
)

var RepositoryModule = fx.Module("repository_module",
	fx.Provide(
		postgres.NewRepository,
	),
)

var ServiceModule = fx.Module("service_module",
	fx.Provide(mtconnect_service.NewMTConnectService),
)

var UsecaseModule = fx.Module("usecases_module",
	fx.Provide(usecases.NewUsecases),
)

Functions

func InvokeBackgroundHealthChecker

func InvokeBackgroundHealthChecker(lc fx.Lifecycle, mtconnectSvc interfaces.Usecases, logger *logging.Logger)

InvokeBackgroundHealthChecker запускает фоновую задачу для периодической проверки состояния всех подключений.

func InvokeGracefulShutdown

func InvokeGracefulShutdown(lc fx.Lifecycle, mtconnectSvc interfaces.MTConnectService, producer interfaces.KafkaService, logger *logging.Logger)

InvokeGracefulShutdown обеспечивает корректное завершение работы сервисов.

func InvokeHttpServer

func InvokeHttpServer(lc fx.Lifecycle, cfg *config.AppConfig, h http.Handler, logger *logging.Logger)

InvokeHttpServer запускает HTTP-сервер.

func InvokeRestoreConnections

func InvokeRestoreConnections(lc fx.Lifecycle, mtconnectSvc interfaces.Usecases, dbRepo interfaces.CncMachineRepository, logger *logging.Logger)

InvokeRestoreConnections восстанавливает подключения и опросы при старте приложения.

func New

func New() *fx.App

New создает новый экземпляр fx.App

func NewSwaggerConfig

func NewSwaggerConfig() *swagger.Config

Конфигуратор Swagger

func ProvideLogger

func ProvideLogger(cfg *config.AppConfig) *logging.Logger

Модуль логгера