节点级别变更
(rpcClient *rpc.RPCClient)
| 151 | |
| 152 | // 节点级别变更 |
| 153 | func (this *Node) execNodeLevelChangedTask(rpcClient *rpc.RPCClient) error { |
| 154 | levelInfoResp, err := rpcClient.NodeRPC.FindNodeLevelInfo(rpcClient.Context(), &pb.FindNodeLevelInfoRequest{}) |
| 155 | if err != nil { |
| 156 | return err |
| 157 | } |
| 158 | |
| 159 | if sharedNodeConfig != nil { |
| 160 | sharedNodeConfig.Level = levelInfoResp.Level |
| 161 | } |
| 162 | |
| 163 | var parentNodes = map[int64][]*nodeconfigs.ParentNodeConfig{} |
| 164 | if len(levelInfoResp.ParentNodesMapJSON) > 0 { |
| 165 | err = json.Unmarshal(levelInfoResp.ParentNodesMapJSON, &parentNodes) |
| 166 | if err != nil { |
| 167 | return fmt.Errorf("decode level info failed: %w", err) |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | if sharedNodeConfig != nil { |
| 172 | sharedNodeConfig.ParentNodes = parentNodes |
| 173 | } |
| 174 | |
| 175 | return nil |
| 176 | } |
| 177 | |
| 178 | // DDoS配置变更 |
| 179 | func (this *Node) execDDoSProtectionChangedTask(rpcClient *rpc.RPCClient) error { |