soa

SOA

Default health check is using TTL, if you want to add custom health check for a service, you can provide a health check handler by setting HealthCheck option, or if you want to use HTTP health check, you can add a health endpoint by setting HealthCheckPath in AppConfig.

Usage:

import "github.com/lalamove/gokit/soa"

s, err := soa.New(
    soa.WithApp(soa.AppConfig{
        ID: "my-demo-svc",
    }),
    soa.WithConsul(soa.ConsulConfig{
        Host:  "127.0.0.1",
        Port:  8500,
        Token: "my-token",
    }),
)

if err != nil {
    log.Fatal("fail to create soa object")
}

// register service to consul
if err := s.Register(); err != nil {
    log.Fatal("fail to register service")
}

// resolve dependency service's address
host, err := s.Resolve("my-dependency-svc")
// resolve dependency service's address by version
host2, err2 := s.ResolveWithVersion("my-dependency-svc", "v123")

if err != nil {
    log.Println("fail to resolve my-dependency-svc")
}

fmt.Println(host.Addr)

// deregister service for graceful shutdown
s.Deregister()