infrakit

infrakit

Infrastructure toolkit providing a series of packages for building Go applications.

See docs/usage.md for full documentation: project layout, optimal usage, and component interactions.

Package Overview

cyconf - Configuration System

cyconf is a flexible configuration management system that supports loading configurations from various sources, including single files, directories, and multiple search paths.

Key Features:

• Support for multiple configuration sources (files, environment variables, command-line arguments)
• Support for multiple configuration formats (YAML, JSON, etc.)
• Configuration merging and overriding
• Environment variable override for configuration values

Usage Example:

type Config struct {
    Database struct {
        Host     string
        Port     int
        Username string
        Password string
    }
    Server struct {
        Port    int
        Timeout int
    }
}

// Load configuration using default options (from ./config.yml)
config, err := cyconf.LoadConfig[Config]()
if err != nil {
    log.Fatalf("Failed to load config: %v", err)
}

// Using a custom path
config, err := cyconf.LoadConfig[Config](
    cyconf.WithPath("/path/to/config.yaml")
)

// Using multiple configuration files (merged)
config, err := cyconf.LoadConfig[Config](
    cyconf.WithFiles("", "./config.json", "./settings.yaml")
)

cydb - Database Operations

cydb provides an abstraction layer for database operations, supporting multiple database types (MySQL, PostgreSQL, Oracle, SQLite).

Key Features:

• Unified database connection configuration
• Support for multiple database types
• SQL dialect conversion
• Data formatting and conversion

Usage Example:

// Configure database connection
dbConfig := cydb.DBConnection{
    Key:    "primary_db",
    Type:   "mysql",
    Host:   "localhost",
    Port:   3306,
    Un:     "user",
    Pw:     "password",
    DBName: "mydb",
}

// Use database client (DBMgr manages connections)
mgr := &cydb.DBMgr{}
cli, _ := mgr.GetOrCreateCli(dbConfig)
rows, err := cli.Query("SELECT * FROM users WHERE id = ?", 1)

cydist - Distributed System Tools

cydist package provides tools related to distributed systems, including a Redis-based memory record system.

Key Features:

• Redis-based memory record system
• Support for setting record timeout and maximum record count
• Namespace isolation
• Local caching mechanism

Usage Example:

// Create Redis client
client := cydist.New(cydist.WithAddr("localhost:6379"))

// Create MemoryStore instance
ms := cydist.NewMemoryStore(client, "myservice")

// Configure key
key := "user_actions"
expire := 10 * time.Minute
maxRecords := int64(100)
err := ms.CreateKey(context.Background(), key, expire, maxRecords)

// Add record
data := map[string]interface{}{
    "user_id": 12345,
    "action": "login",
    "timestamp": time.Now(),
}
err = ms.WriteRecord(context.Background(), key, data)

// Get records
records, err := ms.GetLatestRecords(context.Background(), key, 10)

cyfct - Factory Pattern Tools

cyfct package provides implementations of singleton and factory patterns for managing object instances in applications.

Key Features:

• Singleton pattern implementation
• Support for registering and retrieving instances by type
• Support for group management of instances

Usage Example:

// Register factory function
cyfct.Register(func() (MyService, error) {
    return &myServiceImpl{}, nil
})

// Get instance
service, err := cyfct.Get[MyService]()

// Register factory function with group
cyfct.RegisterGroup("services", func() (MyService, error) {
    return &myServiceImpl{}, nil
})

// Get all instances in a group
services, err := cyfct.GetGroup[MyService]("services")

cygin - Web Framework

cygin package is a wrapper around the Gin framework, providing more convenient API definition and route management.

Key Features:

• Gin-based web server
• Support for API grouping and route management
• Swagger documentation generation
• Static file serving
• Middleware support (CORS, health check, etc.)

Usage Example:

// Create server
server := cygin.NewServer(
    cygin.WithPort(8080),
    cygin.WithCORS(),
    cygin.WithHealthCheck(),
    cygin.WithVersionInfo(),
    cygin.WithSwagger(),
)

// Add API group
server.AddApiGroup(cygin.ApiGroup{
    BasePath: "/api/v1",
    Endpoints: []cygin.ApiEndpoint{
        {
            Path:    "/users",
            Method:  cygin.Get,
            Summary: "Get user list",
            Handler: GetUsers,
        },
    },
})

// Start server
server.Run(context.Background())

cylog - Logging System

cylog package provides a logging system based on Go's standard slog library, supporting multiple output formats and log levels.

Key Features:

• Structured logging based on slog
• Support for multiple output formats (text, JSON, Apache format)
• Log rotation
• Caller information recording

Usage Example:

// Initialize default logger
cylog.InitDefault(
    cylog.WithLevel(slog.LevelInfo),
    cylog.WithFormat("json"),
    cylog.WithFilename("app.log"),
    cylog.WithMaxSize(10), // MB
)

// Use logger
cylog.Info("Server started", "port", 8080)
cylog.Debug("Debug information")
cylog.Warn("Warning message")
err := cylog.Error("Error message", "code", 500)

// Create custom logger
logger := cylog.New(
    cylog.WithLevel(slog.LevelDebug),
    cylog.WithAddSource(true),
)
logger.Info("Custom logger")

cyswag - Swagger Documentation Generation

cyswag package provides tools for generating Swagger documentation automatically.

Key Features:

• Automatic Swagger documentation generation
• Support for API grouping and tagging
• Support for request and response model definition

Usage Example:

// Register API endpoint
cyswag.Register(
    cyswag.WithTitle("My API"),
    cyswag.WithVersion("1.0.0"),
    cyswag.WithDescription("API Documentation"),
    cyswag.WithApiEndpoint(
        cyswag.APIEndpoint{
            Path:        "/api/users",
            Method:      "GET",
            Summary:     "Get user list",
            Description: "Get all users in the system",
            Tags:        []string{"User Management"},
        },
    ),
)

cyutil - General Utilities

cyutil package provides various general utility functions.

Key Features:

• String processing
• Time formatting
• Type conversion
• Other utility tools

Usage Example:

// String conversion
str := cyutil.ToStr(123)

// Time formatting
duration := cyutil.FormatDuration(5 * time.Second)

// User agent parsing
uaInfo := cyutil.ParseUserAgent(userAgentString)

Usage Example

Here's an example of building a web application using multiple packages:

package main

import (
    "context"
    "log"
    "log/slog"

    "github.com/fj1981/infrakit/pkg/cyconf"
    "github.com/fj1981/infrakit/pkg/cydb"
    "github.com/fj1981/infrakit/pkg/cygin"
    "github.com/fj1981/infrakit/pkg/cylog"
)

type Config struct {
    Server struct {
        Port int
    }
    Database cydb.DBConnection
}

func main() {
    // Initialize logging
    cylog.InitDefault(
        cylog.WithLevel(slog.LevelInfo),
        cylog.WithFilename("app.log"),
    )

    // Load configuration
    config, err := cyconf.LoadConfig[Config](
        cyconf.WithFile("./config/app.yml"),
    )
    if err != nil {
        log.Fatalf("Failed to load config: %v", err)
    }

    // Create database client
    mgr := &cydb.DBMgr{}
    dbClient, _ := mgr.GetOrCreateCli(config.Database)

    // Create web server
    server := cygin.NewServer(
        cygin.WithPort(config.Server.Port),
        cygin.WithCORS(),
        cygin.WithHealthCheck(),
        cygin.WithVersionInfo(),
        cygin.WithSwagger(),
    )

    // Add API routes
    server.AddApiGroup(cygin.ApiGroup{
        BasePath: "/api/v1",
        Endpoints: []cygin.ApiEndpoint{
            {
                Path:    "/users",
                Method:  cygin.Get,
                Summary: "Get user list",
                Handler: func() ([]User, error) {
                    // Use dbClient to query database
                    return getUsers(dbClient)
                },
            },
        },
    })

    // Start server
    if err := server.Run(context.Background()); err != nil {
        cylog.Error("Server failed", "error", err)
    }
}

Contributing

We welcome issues and pull requests! Here's how to contribute:

Bug Reports & Feature Requests

• Search existing issues first to avoid duplicates.
• Open an issue with a clear title and description. For bugs, include the minimal reproduction steps and the expected vs. actual behavior.
• For major changes, please open an issue first to discuss what you would like to change.

Submitting a Pull Request

1. Fork the repository and create your branch from main:

   git checkout -b feat/my-new-feature
   

2. Make your changes and keep them focused — one PR should address one concern.
3. Run the test suite and make sure everything passes:

   go build ./...
   go vet ./...
   go test ./pkg/...
   

4. Commit with a clear message following the Conventional Commits convention, e.g.:

   feat(cydb): add support for query result paging
   fix(cylog): correct log rotation size calculation
   docs(cygin): update swagger usage examples
   

5. Push to your fork and open a pull request against main.

Merge Guidelines

• The main branch is always kept stable and releasable.
• All pull requests must pass CI checks and review before merging.
• Use Squash and merge to keep the commit history clean.
• After merging, a maintainer may cut a new release tag (e.g. v1.0.1) as needed.

Acknowledgements

This project would not exist without the excellent open source ecosystem it builds upon. Special thanks to:

• Gin — high performance HTTP web framework
• Viper — configuration management
• go-redis — Redis client
• sqlx — database extensions
• go-sql-driver/mysql, lib/pq, go-ora, logoove/sqlite — database drivers for MySQL, PostgreSQL, Oracle, and SQLite
• gocron, jetcache-go, bubbletea and all other libraries in our dependency tree

And thanks to everyone who has contributed code, reported bugs, or shared feedback — your support matters!

License

This project is licensed under the MIT License.