@@ -48,6 +48,7 @@ import (
48
48
"github.com/polarismesh/polaris-controller/common"
49
49
"github.com/polarismesh/polaris-controller/common/log"
50
50
polarisController "github.com/polarismesh/polaris-controller/pkg/controller"
51
+ "github.com/polarismesh/polaris-controller/pkg/inject/pkg/config"
51
52
"github.com/polarismesh/polaris-controller/pkg/inject/pkg/kube/inject"
52
53
_ "github.com/polarismesh/polaris-controller/pkg/inject/pkg/kube/inject/apply/javaagent"
53
54
_ "github.com/polarismesh/polaris-controller/pkg/inject/pkg/kube/inject/apply/mesh"
@@ -68,7 +69,7 @@ const (
68
69
DnsConfigFile = "/etc/polaris-inject/inject/dns-config"
69
70
JavaAgentConfigFile = "/etc/polaris-inject/inject/java-agent-config"
70
71
ValuesFile = "/etc/polaris-inject/inject/values"
71
- MeshFile = "/etc/polaris-inject/config/mesh"
72
+ BootstrapConfigFile = "/etc/polaris-inject/config/mesh"
72
73
CertFile = "/etc/polaris-inject/certs/cert.pem"
73
74
KeyFile = "/etc/polaris-inject/certs/key.pem"
74
75
)
@@ -186,8 +187,7 @@ func initControllerConfig(s *options.KubeControllerManagerOptions) {
186
187
if flags .polarisServerAddress != "" {
187
188
polarisServerAddress = flags .polarisServerAddress
188
189
} else {
189
- // 启动参数没有指定,取 mesh config 中的地址
190
- polarisServerAddress = config .ServiceSync .ServerAddress
190
+ polarisServerAddress = config .getPolarisServerAddress ()
191
191
}
192
192
// 去除前后的空格字符
193
193
polarisServerAddress = strings .TrimSpace (polarisServerAddress )
@@ -196,9 +196,8 @@ func initControllerConfig(s *options.KubeControllerManagerOptions) {
196
196
polarisapi .PolarisConfigGrpc = polarisServerAddress + ":8093"
197
197
log .Infof ("[Manager] polaris http address %s, discover grpc address %s, config grpc address %s" ,
198
198
polarisapi .PolarisHttpURL , polarisapi .PolarisGrpc , polarisapi .PolarisConfigGrpc )
199
- // 设置北极星开启鉴权之后,需要使用的访问token
200
- polarisapi .PolarisAccessToken = config .ServiceSync .PolarisAccessToken
201
- polarisapi .PolarisOperator = config .ServiceSync .Operator
199
+ polarisapi .PolarisAccessToken = config .getPolarisAccessToken ()
200
+ polarisapi .PolarisOperator = config .getPolarisOperator ()
202
201
203
202
// 2. 配置 polaris 同步模式
204
203
if s .PolarisController .SyncMode == "" {
@@ -247,15 +246,18 @@ func closeGrpcLog() {
247
246
}
248
247
249
248
func initPolarisSidecarInjector (c * options.CompletedConfig ) error {
250
- parameters := inject.WebhookParameters {
251
- DefaultSidecarMode : util .ParseSidecarMode (c .ComponentConfig .PolarisController .SidecarMode ),
249
+ templateFilePath := config.TemplateFileConfig {
252
250
MeshConfigFile : MeshConfigFile ,
253
251
DnsConfigFile : DnsConfigFile ,
254
252
JavaAgentConfigFile : JavaAgentConfigFile ,
255
253
ValuesFile : ValuesFile ,
256
- MeshFile : MeshFile ,
254
+ BootstrapConfigFile : BootstrapConfigFile ,
257
255
CertFile : CertFile ,
258
256
KeyFile : KeyFile ,
257
+ }
258
+ parameters := inject.WebhookParameters {
259
+ DefaultSidecarMode : util .ParseSidecarMode (c .ComponentConfig .PolarisController .SidecarMode ),
260
+ TemplateFileConfig : templateFilePath ,
259
261
Port : flags .injectPort ,
260
262
HealthCheckInterval : 3 * time .Second ,
261
263
HealthCheckFile : "/tmp/health" ,
0 commit comments