ayo/houston
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

서버와 클라이언트 동시에 구동하는 옵션 추가

Browse Source
This commit is contained in:
mountain
2023-06-22 17:16:09 +09:00
parent 3278bca32f
commit c98023cc8b
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/server.go
View File

@ -5,8 +5,10 @@ import (
"fmt" "fmt"
"net" "net"
"os" "os"
"time"
"repositories.action2quare.com/ayo/gocommon/logger" "repositories.action2quare.com/ayo/gocommon/logger"
"repositories.action2quare.com/ayo/houston/client"
"repositories.action2quare.com/ayo/houston/shared" "repositories.action2quare.com/ayo/houston/shared"
"repositories.action2quare.com/ayo/houston/shared/protos" "repositories.action2quare.com/ayo/houston/shared/protos"
@ -23,6 +25,7 @@ type HoustonServer interface {
type serverConfig struct { type serverConfig struct {
GrpcPort int `json:"grpc_port"` GrpcPort int `json:"grpc_port"`
StorageRoot string `json:"storage_path"` StorageRoot string `json:"storage_path"`
RunAsClient bool `json:"run_as_client"`
} }
type DeployRequest struct { type DeployRequest struct {
@ -173,6 +176,18 @@ func (hs *houstonServer) Start() error {
return err 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 { if err := hs.rpcServer.Serve(lis); err != nil {
return err return err
} }