add service register

main.go

@@ -21,6 +21,7 @@ import (
 	gogoPbProto "github.com/gogo/protobuf/proto"
 	"github.com/odysseus/go-kafka/version"
 	pbUpstream "github.com/odysseus/odysseus-protocol/gen/proto/go/base/v1"
+	"github.com/odysseus/service-registry/registry"
 	qdb "github.com/questdb/go-questdb-client/v2"
 
 	"github.com/odysseus/cache/cachedata"
@@ -720,6 +721,37 @@ func main() {
 
 	flag.Parse()
 
+	detailVar.KafkaBroker = kafkaBroker
+	detailVar.QuestAddr = questAddr
+
+	detailVar.CallbackAddr = callbackAddr
+	detailVar.CallbackPort = callbackAddrP
+	detailVar.ListenIpPort = listenIpPort
+	detailVar.AigcProduceTopic = aigcProduceTopic
+	detailVar.TaskreceiptTopic = aigcTaskreceiptTopic
+	detailVar.TaskProof = aigcTaskProof
+	detailVar.Logserver = logserver
+	detailVar.LogLevel = logLevel
+
+	detailVar.RedisAddr = redisAddr
+	detailVar.RedisPassWd = redisPassWd
+	detailVar.MysqlAddr = mysqlAddr
+	detailVar.MysqlDbName = mysqlDbName
+	detailVar.MysqlPassWd = mysqlPassWd
+	detailVar.MysqlUser = mysqlUser
+	detailVar.MysqlPort = mysqlPort
+
+	go func() {
+
+		r := registry.NewRegistry(registry.RedisConnParam{
+			Addr:     redisAddr,
+			Password: redisPassWd,
+			DbIndex:  0,
+		}, demoService{})
+		r.Start()
+
+	}()
+
 	levelVar := &slog.LevelVar{}
 	levelVar.Set(slog.Level(logLevel))
 

service-register.go

 package main
 
+import (
+	"encoding/json"
+	"os"
+
+	"github.com/odysseus/service-registry/common"
+)
+
+type demoService struct {
+}
+
+func (d demoService) Instance() string {
+	hname, _ := os.Hostname()
+	return "demo" + hname
+}
+
+func (d demoService) Status() string {
+	return "running"
+}
+
+func (d demoService) ServiceType() common.ServiceType {
+	return common.SERVICE_API_GATEWAY
+}
+
+type Detail struct {
+	QuestAddr        string `json:"quest_addr"`
+	KafkaBroker      string `json:"kafka_broker"`
+	CallbackAddr     string `json:"callback_addr"`
+	CallbackPort     string `json:"callback_port"`
+	ListenIpPort     string `json:"listen_ip_port"`
+	AigcProduceTopic string `json:"aigc_produce_topic"`
+	TaskreceiptTopic string `json:"task_receipt_topic"`
+	TaskProof        string `json:"task_proof"`
+	Logserver        string `json:"log_server"`
+	RedisAddr        string `json:"redis_addr"`
+	RedisPassWd      string `json:"redis_passwd"`
+	MysqlAddr        string `json:"mysql_addr"`
+	MysqlPort        int    `json:"mysql_port"`
+	MysqlDbName      string `json:"mysql_db_name"`
+	MysqlUser        string `json:"mysql_user"`
+	MysqlPassWd      string `json:"mysql_passwd"`
+	LogLevel         int    `json:"log_level"`
+
+	/////////////////////////////////////////
+	IP          string `json:"ip"`
+	WorkerCount int    `json:"worker_count"`
+}
+
+var detailVar = Detail{}
+
+func (d demoService) DetailInfo() (json.RawMessage, error) {
+	// detail := struct {
+	// 	IP          string `json:"ip"`
+	// 	WorkerCount int    `json:"worker_count"`
+	// }{}
+	// detail.IP = ""
+	// detail.WorkerCount = 10
+	return json.Marshal(detailVar)
+}
+
+// func TestRegistry(t *testing.T) {
+// 	r := NewRegistry(RedisConnParam{
+// 		Addr:     "localhost:6379",
+// 		Password: "",
+// 		DbIndex:  0,
+// 	}, demoService{})
+// 	r.Start()
+// 	time.Sleep(time.Second * 5)
+// 	r.Stop()
+// }
+
+// package main
+
 // import (
 // 	"encoding/json"
 // 	"time"