|
18 | 18 | package service |
19 | 19 |
|
20 | 20 | import ( |
21 | | - "encoding/json" |
22 | 21 | "strconv" |
23 | 22 | "strings" |
24 | 23 |
|
@@ -673,65 +672,6 @@ func SearchServiceAsCrossLinkedList(ctx consolectx.Context, req *model.ServiceGr |
673 | 672 | }, nil |
674 | 673 | } |
675 | 674 |
|
676 | | -// GetServiceDetail get service detail information including version groups and metrics |
677 | | -func GetServiceDetail(ctx consolectx.Context, req *model.ServiceDetailReq) (*model.ServiceDetailResp, error) { |
678 | | - // Query all service provider metadata resources for the given service name |
679 | | - indexes := map[string]string{ |
680 | | - index.ByServiceProviderServiceName: req.ServiceName, |
681 | | - } |
682 | | - if strutil.IsNotBlank(req.Mesh) { |
683 | | - indexes[index.ByMeshIndex] = req.Mesh |
684 | | - } |
685 | | - |
686 | | - serviceResources, err := manager.ListByIndexes[*meshresource.ServiceProviderMetadataResource]( |
687 | | - ctx.ResourceManager(), |
688 | | - meshresource.ServiceProviderMetadataKind, |
689 | | - indexes, |
690 | | - ) |
691 | | - byteJsonStr, err := json.Marshal(serviceResources) |
692 | | - logger.Infof("service resources for service %s: %s", req.ServiceName, string(byteJsonStr)) |
693 | | - if err != nil { |
694 | | - logger.Errorf("get service provider metadata for %s failed, cause: %v", req.ServiceName, err) |
695 | | - return nil, bizerror.New(bizerror.InternalError, "get service provider failed") |
696 | | - } |
697 | | - |
698 | | - if len(serviceResources) == 0 { |
699 | | - logger.Warnf("service %s not found", req.ServiceName) |
700 | | - return nil, bizerror.New(bizerror.NotFoundError, "service not found") |
701 | | - } |
702 | | - |
703 | | - // Collect unique version and group combinations |
704 | | - versionGroupMap := make(map[string]*model.VersionGroup) |
705 | | - for _, res := range serviceResources { |
706 | | - if res.Spec == nil { |
707 | | - continue |
708 | | - } |
709 | | - key := res.Spec.Version + "|" + res.Spec.Group |
710 | | - if _, exists := versionGroupMap[key]; !exists { |
711 | | - versionGroupMap[key] = &model.VersionGroup{ |
712 | | - Version: res.Spec.Version, |
713 | | - Group: res.Spec.Group, |
714 | | - } |
715 | | - } |
716 | | - } |
717 | | - |
718 | | - versionGroups := make([]*model.VersionGroup, 0) |
719 | | - for _, vg := range versionGroupMap { |
720 | | - versionGroups = append(versionGroups, vg) |
721 | | - } |
722 | | - |
723 | | - // Return service detail response with mock metrics data |
724 | | - // In production, metrics would come from Prometheus or a metrics store |
725 | | - resp := &model.ServiceDetailResp{ |
726 | | - VersionGroups: versionGroups, |
727 | | - AvgRT: "96ms", |
728 | | - AvgQPS: "12.5", |
729 | | - RequestTotal: "1386", |
730 | | - } |
731 | | - |
732 | | - return resp, nil |
733 | | -} |
734 | | - |
735 | 675 | // GetServiceInterfaces get service interfaces |
736 | 676 | func GetServiceInterfaces(ctx consolectx.Context, req *model.ServiceInterfacesReq) (*model.ServiceInterfacesResp, error) { |
737 | 677 | // Query all service provider metadata resources for the given service name |
|
0 commit comments