MCPcopy Create free account
hub / github.com/APIParkLab/APIPark / genNodeEntity

Method genNodeEntity

service/cluster/cluster.go:190–238  ·  view source on GitHub ↗
(id string, nodes []*admin.Node)

Source from the content-addressed store, hash-verified

188 return FromEntity(en), nil
189}
190func (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}
239func (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 {

Callers 2

CreateMethod · 0.95
UpdateAddressMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected