代码拉取完成,页面将自动刷新
//
// Copyright 2022 SkyAPM org
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
package go2sky
import common "skywalking.apache.org/repo/goapi/collect/common/v3"
type AgentConfigEventType int32
const (
MODIFY AgentConfigEventType = iota
DELETED
)
func NewConfigDiscoveryService() *ConfigDiscoveryService {
return &ConfigDiscoveryService{}
}
type ConfigDiscoveryService struct {
UUID string
watchers map[string]AgentConfigChangeWatcher
}
func (s *ConfigDiscoveryService) BindWatchers(watchers []AgentConfigChangeWatcher) {
// bind watchers
s.watchers = make(map[string]AgentConfigChangeWatcher)
for _, watcher := range watchers {
s.watchers[watcher.Key()] = watcher
}
}
func (s *ConfigDiscoveryService) HandleCommand(command *common.Command) {
var uuid string
var newConfigs = make(map[string]*common.KeyStringValuePair)
for _, pair := range command.GetArgs() {
if pair.Key == "SerialNumber" {
} else if pair.Key == "UUID" {
uuid = pair.Value
} else {
newConfigs[pair.Key] = pair
}
}
// check same uuid
if s.UUID == uuid {
return
}
// notify to all watchers
for key, watcher := range s.watchers {
pair := newConfigs[key]
if pair == nil || pair.Value == "" {
watcher.Notify(DELETED, "")
} else if pair.Value != watcher.Value() {
watcher.Notify(MODIFY, pair.Value)
}
}
// update uuid
s.UUID = uuid
}
type AgentConfigChangeWatcher interface {
Key() string
Notify(eventType AgentConfigEventType, newValue string)
Value() string
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。