MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
↓ 1 callersMethodgetGroupDescriptionFromKafka
(ClusterPhy clusterPhy, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:172
↓ 1 callersFunctiongetGroupListColumns
(arg: any)
km-console/packages/layout-clusters-fe/src/pages/GroupList/config.tsx:6
↓ 1 callersFunctiongetGroupMetaData
()
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:107
↓ 1 callersMethodgetGroupOffsetFromKafka
(Long clusterPhyId, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:152
↓ 1 callersMethodgetGroupStateFromDB
DB-Group相关接口
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:47
↓ 1 callersMethodgetGroupTopicFromDB
(Long clusterPhyId, String groupName, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:72
↓ 1 callersMethodgetGroupTopicOverviewVOList
(Long clusterPhyId, List<GroupMemberPO> groupMemberPOList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/GroupManager.java:45
↓ 1 callersMethodgetGroupsFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:53
↓ 1 callersFunctiongetGtoupTopicColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/config.tsx:88
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/group/HealthCheckGroupService.java:49
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/topic/HealthCheckTopicService.java:60
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/broker/HealthCheckBrokerService.java:55
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:69
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectClusterService.java:59
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:102
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:79
↓ 1 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java:42
↓ 1 callersFunctiongetHealthData
(tabSelectTypeName: string)
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerDetailCard.tsx:28
↓ 1 callersFunctiongetHealthData
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectCard.tsx:38
↓ 1 callersFunctiongetHealthData
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectDetailCard.tsx:28
↓ 1 callersFunctiongetHealthData
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ZookeeperCard.tsx:38
↓ 1 callersFunctiongetHealthData
()
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerCard.tsx:38
↓ 1 callersFunctiongetHealthDetail
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/CheckDetail.tsx:19
↓ 1 callersFunctiongetHealthySettingColumn
(form: any, data: any, clusterId: string)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/config.tsx:250
↓ 1 callersMethodgetInetAddress
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/NetUtils.java:92
↓ 1 callersMethodgetJmxHost
(String endPoint)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java:96
↓ 1 callersMethodgetJmxValue
(String jmxHost, Integer jmxPort, JmxConfig jmxConfig, ObjectName objectName, String attribute)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/jmx/JmxDAO.java:13
↓ 1 callersMethodgetJmxValue
(String jmxHost, Integer jmxPort, JmxConfig jmxConfig, ObjectName objectName, String attribute)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/jmx/impl/JmxDAOImpl.java:20
↓ 1 callersMethodgetJobDetail
(Long clusterPhyId, Long jobId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:164
↓ 1 callersMethodgetJobModifyDetail
获取 job 的详细信息 @param jobId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:73
↓ 1 callersFunctiongetJobsListColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:67
↓ 1 callersFunctiongetJobsTaskData
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:199
↓ 1 callersFunctiongetJobsTaskData
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:152
↓ 1 callersMethodgetKafkaAclFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/KafkaAclService.java:11
↓ 1 callersMethodgetKafkaAclFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:124
↓ 1 callersMethodgetKafkaControllersFromDB
(List<Long> clusterPhyIdList, boolean notIncludeNotAlive)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:98
↓ 1 callersMethodgetKafkaUserByClusterIdFromDB
(Long clusterPhyId, String searchKafkaUserName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:52
↓ 1 callersMethodgetKafkaUserDuplicate
(Long clusterPhyId, String kafkaUser)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:81
↓ 1 callersMethodgetKafkaUserFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:54
↓ 1 callersFunctiongetKafkaUserList
()
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:122
↓ 1 callersMethodgetKafkaUserToken
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/impl/KafkaUserManagerImpl.java:72
↓ 1 callersMethodgetKafkaUserTokenWithEncrypt
查看密码
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/KafkaUserManager.java:22
↓ 1 callersMethodgetLdapAttrsInfo
获取用户信息
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/ldap/remote/LdapAuthentication.java:88
↓ 1 callersMethodgetLdapContext
private method
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/ldap/remote/LdapAuthentication.java:66
↓ 1 callersFunctiongetLeafNodes
(checkboxData: CheckboxStatus, arr: any[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:208
↓ 1 callersMethodgetLength
(Object array)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ValidateUtils.java:68
↓ 1 callersFunctiongetMM2Columns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/config.tsx:96
↓ 1 callersMethodgetMM2Configs
(Long connectClusterId, String connectorName)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:40
↓ 1 callersFunctiongetMM2DetailColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/config.tsx:279
↓ 1 callersMethodgetMessage
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobHandleEnum.java:29
↓ 1 callersFunctiongetMetricChartData
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:186
↓ 1 callersFunctiongetMetricDashboardReq
(clusterId: string, type: MetricType.Broker | MetricType.Topic | MetricType.Zookeeper)
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/config.tsx:11
↓ 1 callersFunctiongetMetricDefine
(type: MetricType, metricName: string)
km-console/packages/layout-clusters-fe/src/pages/CommonConfig.tsx:128
↓ 1 callersMethodgetMetricFromKafkaByTotalTopics
从所有的 Topic 的指标中加总聚合得到集群的指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:734
↓ 1 callersFunctiongetMetricsDefine
()
km-console/packages/layout-clusters-fe/src/pages/CommonConfig.tsx:124
↓ 1 callersMethodgetMirrorMakerStateVO
(Long clusterPhyId)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:32
↓ 1 callersMethodgetMirrorMakerTopicPartitionMetric
(Long connectClusterId, String mirrorMakerName, String clusterAlias, String topicName, Integer partitionId, St
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerMetricServiceImpl.java:298
↓ 1 callersFunctiongetMoveBalanceColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:359
↓ 1 callersMethodgetNamespace
(String zookeeperAddress)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/ZookeeperUtils.java:58
↓ 1 callersMethodgetNoResResult
(Long clusterPhyId, AbstractHealthCheckService healthCheckService, Map<String, BaseClusterHealthConfig> health
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java:78
↓ 1 callersMethodgetNoResResult
(Long connectClusterId, AbstractHealthCheckService healthCheckService, Map<String, BaseClusterHealthConfig> he
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:82
↓ 1 callersFunctiongetNodeList
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/ClusterNorms.tsx:54
↓ 1 callersFunctiongetNodeList
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:306
↓ 1 callersFunctiongetNodeTrafficColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:596
↓ 1 callersFunctiongetNorms
(stateParamArr: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:318
↓ 1 callersMethodgetNotPassedResNameList
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/health/HealthCheckAggResult.java:48
↓ 1 callersFunctiongetNumAndSubTitles
(cardColumnsItemData: any)
km-console/packages/layout-clusters-fe/src/components/CardBar/TopicDetailHealthCheck.tsx:30
↓ 1 callersMethodgetOneRunningJobId
依据任务状态或者其中一个任务ID
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:62
↓ 1 callersMethodgetOtherProps
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/ZKConfig.java:52
↓ 1 callersMethodgetPartitionAssignReplicas
(Integer partitionId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/znode/brokers/PartitionMap.java:34
↓ 1 callersMethodgetPartitionBeginAndEndOffsetFromKafka
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:43
↓ 1 callersMethodgetPartitionByTopicAndPartitionId
(Long clusterPhyId, String topicName, Integer partitionId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:28
↓ 1 callersMethodgetPartitionFromCacheFirst
(Long clusterPhyId, String topicName, Integer partitionId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:36
↓ 1 callersMethodgetPartitionLatestMetrics
(Long clusterPhyId, String topic, Integer brokerId, Int
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/PartitionMetricESDAO.java:26
↓ 1 callersMethodgetPartitionMetricsList
(String partitionMetricKey)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:62
↓ 1 callersMethodgetPartitionOffset
(GroupOffsetResetDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:416
↓ 1 callersMethodgetPartitionOffsetFromKafkaAdminClient
(Long clusterPhyId, String topicName, KSOffsetSpec offsetSpec, List<TopicPartition> tpList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:412
↓ 1 callersMethodgetPartitionOffsetFromKafkaConsumerClient
(Long clusterPhyId, String topicName, KSOffsetSpec offsetSpec, List<TopicPartition> tpList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:469
↓ 1 callersMethodgetPartitionsFromAdminClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:529
↓ 1 callersMethodgetPartitionsFromZKClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:554
↓ 1 callersFunctiongetPathBySuffix
(systemConf, jsonData, suffix)
km-console/packages/layout-clusters-fe/config/registerApps.js:56
↓ 1 callersFunctiongetPermissionTree
(userInfo, userId: number)
km-console/packages/config-manager-fe/src/pages/CommonConfig.tsx:37
↓ 1 callersFunctiongetPermissions
(userId: number)
km-console/packages/layout-clusters-fe/src/pages/CommonConfig.tsx:90
↓ 1 callersFunctiongetPhyClusterInfo
()
km-console/packages/layout-clusters-fe/src/pages/CommonRoute.tsx:40
↓ 1 callersFunctiongetPhyClusterInfo
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:61
↓ 1 callersFunctiongetPhyClusterMetrics
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:40
↓ 1 callersFunctiongetQueryUrl
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:168
↓ 1 callersMethodgetQueryValues
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchShould.java:21
↓ 1 callersFunctiongetRandomStr
(length?: number)
km-console/packages/layout-clusters-fe/src/constants/common.ts:169
↓ 1 callersMethodgetReassignSubJobExtendData
(ReassignSubJobPO subJobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:708
↓ 1 callersFunctiongetReassignmentList
(topiclist?: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:193
↓ 1 callersFunctiongetReassignmentList
(topiclist?: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:146
↓ 1 callersMethodgetReassignmentTopicsOverview
迁移Topic的信息 @param dto @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/ReassignManager.java:32
↓ 1 callersFunctiongetRecent1DayTimeStamp
()
km-console/packages/layout-clusters-fe/src/pages/TopicList/index.tsx:66
↓ 1 callersFunctiongetRecent1DayTimeStamp
()
km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:37
↓ 1 callersFunctiongetRecent1DayTimeStamp
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:36
↓ 1 callersMethodgetReplicaLogSize
(Long clusterPhyId, Integer brokerId, String topicName, Integer partitionId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:150
↓ 1 callersMethodgetReplicaSizeFromCacheFirst
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:35
↓ 1 callersMethodgetResHealthResult
(Long clusterPhyId, Long clusterId, Integer dimension, String resNme)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:28
↓ 1 callersMethodgetResHealthResult
(Long clusterPhyId, Long clusterId, Integer dimension, String resNme)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:305
← previousnext →3,601–3,700 of 6,956, ranked by callers