(id string, nodes []*admin.Node)
| 188 | return FromEntity(en), nil |
| 189 | } |
| 190 | func (s *imlClusterService) genNodeEntity(id string, nodes []*admin.Node) ([]*cluster.Node, []*cluster.NodeAddr) { |
| 191 | nodeEn := make([]*cluster.Node, 0, len(nodes)) |
| 192 | addrAllTemp := make([][]*cluster.NodeAddr, 0, len(nodes)) |
| 193 | now := time.Now() |
| 194 | for _, node := range nodes { |
| 195 | nodeEn = append(nodeEn, &cluster.Node{ |
| 196 | Id: 0, |
| 197 | UUID: node.Id, |
| 198 | Name: node.Name, |
| 199 | Cluster: id, |
| 200 | UpdateTime: now, |
| 201 | }) |
| 202 | aden := make([]*cluster.NodeAddr, 0, len(node.Peer)+len(node.Admin)+len(node.Server)) |
| 203 | for _, addr := range node.Peer { |
| 204 | aden = append(aden, &cluster.NodeAddr{ |
| 205 | Id: 0, |
| 206 | Cluster: id, |
| 207 | Node: node.Id, |
| 208 | Type: "peer", |
| 209 | Addr: addr, |
| 210 | UpdateTime: now, |
| 211 | }) |
| 212 | } |
| 213 | for _, addr := range node.Admin { |
| 214 | aden = append(aden, &cluster.NodeAddr{ |
| 215 | Id: 0, |
| 216 | Cluster: id, |
| 217 | Node: node.Id, |
| 218 | Type: "admin", |
| 219 | Addr: addr, |
| 220 | UpdateTime: now, |
| 221 | }) |
| 222 | } |
| 223 | for _, addr := range node.Server { |
| 224 | aden = append(aden, &cluster.NodeAddr{ |
| 225 | Id: 0, |
| 226 | Cluster: id, |
| 227 | Node: node.Id, |
| 228 | Type: "server", |
| 229 | Addr: addr, |
| 230 | UpdateTime: now, |
| 231 | }) |
| 232 | } |
| 233 | addrAllTemp = append(addrAllTemp, aden) |
| 234 | } |
| 235 | |
| 236 | return nodeEn, utils.SliceMerge(addrAllTemp) |
| 237 | |
| 238 | } |
| 239 | func (s *imlClusterService) UpdateInfo(ctx context.Context, id string, name *string, resume *string) (c *Cluster, errOut error) { |
| 240 | operator := utils.UserId(ctx) |
| 241 | if name == nil && resume == nil { |
no outgoing calls
no test coverage detected