From c98023cc8bac6b15e5c7fe64eaa3b27ac829a959 Mon Sep 17 00:00:00 2001 From: mountain Date: Thu, 22 Jun 2023 17:16:09 +0900 Subject: [PATCH] =?UTF-8?q?=EC=84=9C=EB=B2=84=EC=99=80=20=ED=81=B4?= =?UTF-8?q?=EB=9D=BC=EC=9D=B4=EC=96=B8=ED=8A=B8=20=EB=8F=99=EC=8B=9C?= =?UTF-8?q?=EC=97=90=20=EA=B5=AC=EB=8F=99=ED=95=98=EB=8A=94=20=EC=98=B5?= =?UTF-8?q?=EC=85=98=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/server.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/server/server.go b/server/server.go index 52157fc..0c92a0c 100644 --- a/server/server.go +++ b/server/server.go @@ -5,8 +5,10 @@ import ( "fmt" "net" "os" + "time" "repositories.action2quare.com/ayo/gocommon/logger" + "repositories.action2quare.com/ayo/houston/client" "repositories.action2quare.com/ayo/houston/shared" "repositories.action2quare.com/ayo/houston/shared/protos" @@ -23,6 +25,7 @@ type HoustonServer interface { type serverConfig struct { GrpcPort int `json:"grpc_port"` StorageRoot string `json:"storage_path"` + RunAsClient bool `json:"run_as_client"` } type DeployRequest struct { @@ -173,6 +176,18 @@ func (hs *houstonServer) Start() error { return err } + if loadServerConfig().RunAsClient { + go func() { + time.Sleep(time.Second) + hc, err := client.NewClient() + if err != nil { + logger.Fatal(err) + return + } + hc.Start() + }() + } + if err := hs.rpcServer.Serve(lis); err != nil { return err }