tx7do/kratos-bootstrap
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: global proto name conflict. remove polarismesh support, dont ask me why.

Browse Source
This commit is contained in:
tx7do
2023-10-26 18:27:57 +08:00
parent f736c4d9ea
commit adcd17b3e2
5 changed files with 55 additions and 453 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
config.go
View File

@@ -27,10 +27,6 @@ import (
nacosConstant "github.com/nacos-group/nacos-sdk-go/common/constant"
nacosVo "github.com/nacos-group/nacos-sdk-go/vo"
// polaris
polarisKratos "github.com/go-kratos/kratos/contrib/config/polaris/v2"
polarisApi "github.com/polarismesh/polaris-go"
// apollo
apolloKratos "github.com/go-kratos/kratos/contrib/config/apollo/v2"
@@ -336,20 +332,21 @@ func NewKubernetesConfigSource(c *conf.RemoteConfig) config.Source {
// NewPolarisConfigSource 创建一个远程配置源 - Polaris
func NewPolarisConfigSource(_ *conf.RemoteConfig) config.Source {
configApi, err := polarisApi.NewConfigAPI()
if err != nil {
log.Fatal(err)
}
var opts []polarisKratos.Option
opts = append(opts, polarisKratos.WithNamespace("default"))
opts = append(opts, polarisKratos.WithFileGroup("default"))
opts = append(opts, polarisKratos.WithFileName("default.yaml"))
source, err := polarisKratos.New(configApi, opts...)
if err != nil {
log.Fatal(err)
}
return source
//configApi, err := polarisApi.NewConfigAPI()
//if err != nil {
// log.Fatal(err)
//}
//
//var opts []polarisKratos.Option
//opts = append(opts, polarisKratos.WithNamespace("default"))
//opts = append(opts, polarisKratos.WithFileGroup("default"))
//opts = append(opts, polarisKratos.WithFileName("default.yaml"))
//
//source, err := polarisKratos.New(configApi, opts...)
//if err != nil {
// log.Fatal(err)
//}
//
//return source
return nil
}