func()

in plugin/registry/nacos/nacos.go [144:173]

• 28 lines of code
• 5 McCabe index (conditional complexity)

func (r *Registry) FindAllEventMeshInfo() ([]*registry.EventMeshDataInfo, error) {
	var infos []*registry.EventMeshDataInfo
	meshServerName := config.GlobalConfig().Common.Name

	for _, proto := range protoList {
		ins, err := r.client.SelectInstances(vo.SelectInstancesParam{
			Clusters:    []string{},
			ServiceName: fmt.Sprintf("%v-%v", meshServerName, proto),
			GroupName:   "GROUP",
			HealthyOnly: true,
		})
		if err != nil {
			return nil, err
		}
		if len(ins) == 0 {
			continue
		}
		for _, in := range ins {
			infos = append(infos, &registry.EventMeshDataInfo{
				EventMeshClusterName: in.ClusterName,
				EventMeshName:        in.ServiceName,
				Endpoint:             fmt.Sprintf("%v:%v", in.Ip, in.Port),
				LastUpdateTimestamp:  time.Time{},
				Metadata:             in.Metadata,
			})
		}
	}

	return infos, nil
}