chain-dci/cmd/app.go

51 lines
1.2 KiB
Go
Raw Normal View History

2023-11-23 12:06:14 +00:00
package main
import (
dciConfig "chain-dci/config"
_ "chain-dci/internal/handler"
"chain-dci/pkg/app"
"chain-dci/pkg/tracing"
"dubbo.apache.org/dubbo-go/v3/config"
_ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
_ "dubbo.apache.org/dubbo-go/v3/imports"
bccrClient "github.com/antchain-openapi-sdk-go/bccr/client"
"github.com/bwmarrin/snowflake"
"go.uber.org/zap"
)
2023-11-24 07:55:11 +00:00
func NewApp(Lg *zap.Logger, JaegerTracer *tracing.JaegerProvider, BccrClient *bccrClient.Client, SfNode *snowflake.Node) *app.App {
2023-11-23 12:06:14 +00:00
return &app.App{
2023-11-24 07:55:11 +00:00
Lg: Lg,
2023-11-23 12:06:14 +00:00
JaegerTracer: JaegerTracer,
BccrClient: BccrClient,
SfNode: SfNode,
}
}
func main() {
var err error
dciConfig.GetOptions()
app.ModuleClients, err = InitApp()
if err != nil {
panic(err)
}
2023-12-05 07:31:26 +00:00
2023-12-05 07:53:22 +00:00
/* l, err := net.Listen("tcp", ":8883")
if err != nil {
fmt.Printf("failed to listen: %v", err)
return
}
2023-12-05 07:31:26 +00:00
2023-12-05 07:53:22 +00:00
s := grpc.NewServer() // 创建gRPC服务器
dci.RegisterDciServer(s, &controller.DciProvider{}) // 在gRPC服务端注册服务
// 启动服务
err = s.Serve(l)*/
2023-12-05 07:31:26 +00:00
////注册服务
//config.SetProviderService(&controller.DciProvider{})
//common.Init()
2023-11-23 12:06:14 +00:00
if err = config.Load(); err != nil {
panic(err)
}
select {}
}