Database and Cache Plugins

import (
    "github.com/tx7do/go-utils/mapper"
    "github.com/tx7do/go-wind-plugins/crud/gorm"
)

// Create a Mapper (DTO <-> Entity)
m := mapper.NewCopierMapper[User, UserEntity]()

// Create a Repository
repo := gorm.NewRepository[User, UserEntity](m,
    gorm.WithDriverName("mysql"),
    gorm.WithDSN("user:pass@tcp(localhost:3306)/mydb?parseTime=true"),
    gorm.WithReplicaDsns([]string{ /* read-replica DSNs */ }),
    gorm.WithEnableTrace(true),
    gorm.WithEnableMigrate(true),
    gorm.WithAutoMigrate(&UserEntity{}),
)

import "github.com/tx7do/go-wind-plugins/crud/vector"

q := &vector.Query{
    Field:  "embedding",
    Vector: []float32{0.1, 0.2, 0.3},
    TopK:   10,
    Metric: vector.DistanceMetricCosine,
}

res, _ := repo.SearchByVector(ctx, q) // Hit.Score is always "higher is more similar"

import consulPlugin "github.com/tx7do/go-wind-plugins/registry/consul"

reg := consulPlugin.New(
    consulPlugin.WithAddr("localhost:8500"),
    consulPlugin.WithServiceName("my-service"),
    consulPlugin.WithServiceAddr("10.0.0.1"),
    consulPlugin.WithServicePort(8080),
    consulPlugin.WithHealthCheck("http://10.0.0.1:8080/health", 10*time.Second),
    consulPlugin.WithTags("v1", "primary"),
)

// Get the list of service instances
instances, _ := reg.GetService(ctx, "my-service")
for _, ins := range instances {
    fmt.Printf("%s:%d (weight=%d, healthy=%v)\n",
        ins.Address, ins.Port, ins.Weight, ins.Healthy)
}

// Load balancing
lb := registry.NewRoundRobin(instances)
instance := lb.Select()

import nacosConfigPlugin "github.com/tx7do/go-wind-plugins/config/nacos"

source := nacosConfigPlugin.New(
    nacosConfigPlugin.WithAddr("localhost:8848"),
    nacosConfigPlugin.WithNamespace("production"),
    nacosConfigPlugin.WithDataID("my-service.yaml"),
    nacosConfigPlugin.WithGroup("DEFAULT_GROUP"),
    nacosConfigPlugin.WithWatch(true),     // watch for config changes
)

source.Watch(func(event config.Event) {
    fmt.Println("config changed:", event.Key)
    // reload the configuration
    reloadConfig(event.Value)
})