Compare commits

..

1 Commits
main ... dev

Author SHA1 Message Date
yoyofx a16a88e3c9 print namespace and gourpname by nacos 3 years ago

19
.gitignore vendored

@ -1,19 +0,0 @@
### Go template
# Binaries for programs and plugins
*.exe
*.exe~
*.dll
*.so
*.dylib
# Test binary, built with `go test -c`
*.test
# Output of the go coverage tool, specifically when used with LiteIDE
*.out
# Dependency directories (remove the comment below to include it)
.idea
vendor/
logs
go.sum

@ -35,7 +35,9 @@ func (provider *ViperRemoteProvider) GetProvider(runtimeViper *viper.Viper) *vip
if err == nil {
//err = remote_viper.WatchRemoteConfigOnChannel()
if err == nil {
fmt.Println("used remote viper")
fmt.Println("config center ..........")
fmt.Println("used remote viper by Nacos")
fmt.Printf("Nacos config: namespace: %s , group: %s", option.NamespaceId, option.GroupName)
return remote_viper
}
} else {

@ -2,8 +2,8 @@ package main
import (
"fmt"
remote "github.com/Echo7659/nacos-viper-remote"
"github.com/spf13/viper"
remote "github.com/yoyofxteam/nacos-viper-remote"
"os"
"os/signal"
"syscall"

@ -1,8 +1,8 @@
module git.echol.cn/loser/nacos-viper-remote
module github.com/yoyofxteam/nacos-viper-remote
go 1.14
require (
github.com/nacos-group/nacos-sdk-go/v2 v2.0.0
github.com/spf13/viper v1.10.1
github.com/nacos-group/nacos-sdk-go v1.0.7
github.com/spf13/viper v1.8.1
)

@ -2,11 +2,11 @@ package nacos_viper_remote
import (
"fmt"
"github.com/nacos-group/nacos-sdk-go/v2/clients"
"github.com/nacos-group/nacos-sdk-go/v2/clients/config_client"
"github.com/nacos-group/nacos-sdk-go/v2/common/constant"
"github.com/nacos-group/nacos-sdk-go/v2/common/logger"
"github.com/nacos-group/nacos-sdk-go/v2/vo"
"github.com/nacos-group/nacos-sdk-go/clients"
"github.com/nacos-group/nacos-sdk-go/clients/config_client"
"github.com/nacos-group/nacos-sdk-go/common/constant"
"github.com/nacos-group/nacos-sdk-go/common/logger"
"github.com/nacos-group/nacos-sdk-go/vo"
"github.com/spf13/viper"
"strings"
)
@ -30,8 +30,8 @@ func NewNacosConfigManager(option *Option) (*nacosConfigManager, error) {
NamespaceId: option.NamespaceId,
TimeoutMs: 5000,
NotLoadCacheAtStart: true,
LogDir: "logs/nacos/log",
CacheDir: "logs/nacos/cache",
RotateTime: "1h",
MaxAge: 3,
LogLevel: "info",
}
@ -44,7 +44,10 @@ func NewNacosConfigManager(option *Option) (*nacosConfigManager, error) {
clientConfig.SecretKey = option.Auth.SecretKey
clientConfig.OpenKMS = option.Auth.OpenKMS
}
client, err := clients.NewConfigClient(vo.NacosClientParam{ClientConfig: &clientConfig, ServerConfigs: serverConfigs})
client, err := clients.CreateConfigClient(map[string]interface{}{
"serverConfigs": serverConfigs,
"clientConfig": clientConfig,
})
if err != nil {
logger.Error(err.Error())
return nil, err

Loading…
Cancel
Save