package main import ( "fmt" di "github.com/janmbaco/go-infrastructure/v2/dependencyinjection" cfgioc "github.com/janmbaco/go-infrastructure/v2/configuration/fileconfig/ioc" cfgresolver "github.com/janmbaco/go-infrastructure/v2/configuration/fileconfig/ioc/resolver" logsioc "github.com/janmbaco/go-infrastructure/v2/logs/ioc" errsioc "github.com/janmbaco/go-infrastructure/v2/errors/ioc" eventsioc "github.com/janmbaco/go-infrastructure/v2/eventsmanager/ioc" diskioc "github.com/janmbaco/go-infrastructure/v2/disk/ioc" ) type Config struct { Database string `json:"database"` Port int `json:"port"` } func main() { container := di.NewBuilder(). AddModule(logsioc.NewLogsModule()). AddModule(errsioc.NewErrorsModule()). AddModule(eventsioc.NewEventsModule()). AddModule(diskioc.NewDiskModule()). AddModule(cfgioc.NewConfigurationModule()). MustBuild() resolver := container.Resolver() handler := cfgresolver.GetFileConfigHandler( resolver, "config.json", &Config{Port: 8080}, // defaults if file is missing ) cfg := handler.GetConfig().(*Config) fmt.Printf("App running on port %d\n", cfg.Port) // The process keeps running and picks up changes to config.json automatically. select {} }

container := di.NewBuilder(). Register(func(r di.Register) { // Context-aware provider r.AsScope(new(*Service), func(ctx context.Context, logger logs.Logger) *Service { return &Service{ Logger: logger, RequestID: ctx.Value("requestID").(string), } }, nil) }). MustBuild() // Resolve with context ctx := context.WithValue(context.Background(), "requestID", "req-123") service := di.ResolveCtx[*Service](ctx, container.Resolver())

type Config struct { Database string `json:"database"` Port int `json:"port"` } handler := cfgresolver.GetFileConfigHandler(resolver, "config.json", &Config{Port: 8080}) cfg := handler.GetConfig().(*Config) // Changes to config.json are automatically detected and applied

logger := logs.NewLogger() logger.SetConsoleLevel(logs.InfoLevel) logger.SetFileLogLevel(logs.TraceLevel) logger.Info("Application started", "version", "2.0.0") logger.WithFields(map[string]interface{}{ "userID": "123", "action": "login", }).Info("User action")

errorCatcher := errors.NewErrorCatcher(logger) err := errorCatcher.TryCatchError( func() error { return riskyOperation() }, func(err error) error { logger.Error("Operation failed", err) return fmt.Errorf("wrapped: %w", err) }, )

type UserCreatedEvent struct { UserID string Email string } eventManager := eventsmanager.NewEventManager() publisher := eventsmanager.NewPublisher[UserCreatedEvent](eventManager) subscriptions := eventsmanager.NewSubscriptions[UserCreatedEvent](errorHandler) subscriptions.Subscribe(func(event UserCreatedEvent) { fmt.Printf("User created: %s\n", event.Email) }) publisher.Publish(UserCreatedEvent{UserID: "123", Email: "user@example.com"})

listener := server.NewListenerBuilder(). SetPort(":8080"). SetTLSConfig(tlsConfig). SetHandler(myHandler). Build() if err := listener.ListenAndServe(); err != nil { log.Fatal(err) }

db := persistence.NewDB(dbInfo, errorCatcher) dataAccess := dataaccess.NewDataAccess[User](db) users, err := dataAccess.SelectRows(&User{Active: true}) err = dataAccess.InsertRow(&User{Name: "John"}) err = dataAccess.UpdateRow(&User{ID: 1}, map[string]interface{}{"Name": "Jane"})