MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

↓ 6 callersFunctionWE
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionYr
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:34
↓ 6 callersFunction_n
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunction_s
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionae
(t,e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionan
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 6 callersMethodbuildTermsDsl
{ "term": { "clusterPhyId": { "value": 2 } } }, { "term": { "timestamp": { "value": 1649845260000 } } } @param terms
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:244
↓ 6 callersFunctionbv
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionc
()
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
↓ 6 callersFunctioncG
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersMethodcollectMetricsFromZookeeper
ZK指标获取 @param param 参数,因为ZK 四字命令在使用时,是短连接,所以参数内容会复杂一些,后续可以考虑优化为长连接 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/ZookeeperMetricService.java:17
↓ 6 callersMethodcreateConnector
(ConnectorCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/ConnectorManager.java:12
↓ 6 callersFunctiondb
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:14
↓ 6 callersFunctiondh
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctiondn
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunctiondr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28
↓ 6 callersFunctiondr
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunctioneh
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionf
(b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:74
↓ 6 callersFunctionfc
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersMethodflush
检查并触发任务执行 @param clusterPhy 物理集群信息
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/AbstractZKWatcher.java:36
↓ 6 callersFunctionfo
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionft
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionfw
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersMethodgetCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:35
↓ 6 callersFunctiongetConfigList
(query = {})
km-console/packages/config-manager-fe/src/pages/ConfigManage/index.tsx:220
↓ 6 callersMethodgetConnectorBizStr
(Long clusterPhyId, String topicName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:110
↓ 6 callersMethodgetHealthCheckDimensionEnum
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/AbstractHealthCheckService.java:29
↓ 6 callersMethodgetKafkaControllerFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/KafkaControllerService.java:19
↓ 6 callersFunctiongetList
(query = {})
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:247
↓ 6 callersMethodgetPartitions
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:89
↓ 6 callersMethodgetReassignJobBizStr
reassign
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:87
↓ 6 callersFunctiongetSizeAndUnit
(value: any, unitSuffix?: any, num = 2)
km-console/packages/layout-clusters-fe/src/constants/common.ts:53
↓ 6 callersMethodgetTopicMetadata
获取Topic元信息 @param clusterPhyId 物理集群ID @param topicName Topic名称 @return @throws NotExistException 不存在异常 @throws KeeperException ZK异常 @throws AdminOpera
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/KafkaZKDAO.java:50
↓ 6 callersFunctiongetVal
(val: string | number | undefined | null)
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectCard.tsx:22
↓ 6 callersFunctiongetVal
(val: string | number | undefined | null)
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerCard.tsx:22
↓ 6 callersFunctiongg
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctiongt
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunctionhb
(a,b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:27
↓ 6 callersFunctionhh
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:83
↓ 6 callersMethodhost
The host where the group member is running.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberDescription.java:74
↓ 6 callersFunctioniG
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionjm
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionkb
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:50
↓ 6 callersFunctionke
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionl
()
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 6 callersMethodlatest
Used to retrieve the latest offset of a partition
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/offset/KSOffsetSpec.java:28
↓ 6 callersMethodlist2String
(List<?> list, String separator)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:67
↓ 6 callersMethodlistPartitionFromCacheFirst
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:131
↓ 6 callersMethodlistTopicsFromCacheFirst
优先从缓存获取数据
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:32
↓ 6 callersFunctionlt
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 6 callersFunctionmy
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionnl
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionob
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:57
↓ 6 callersFunctionof
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionpb
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:59
↓ 6 callersFunctionpm
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionpo
(c)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersMethodpublish
发布一个事件
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/SpringTool.java:75
↓ 6 callersFunctionrM
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionrb
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:61
↓ 6 callersFunctionre
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunctionrenderIcon
(type: string)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:95
↓ 6 callersFunctionsM
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionsi
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 6 callersFunctiontO
(t,e,n,i,r,o)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctiontb
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:83
↓ 6 callersFunctionts
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionua
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:17
↓ 6 callersFunctionuk
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersMethodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchTerm.java:35
↓ 6 callersMethodversionItemType
versionItemType @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/VersionControlMetricService.java:19
↓ 6 callersFunctionvy
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionw
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionwM
(t,e,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionwi
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:66
↓ 6 callersFunctionwp
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionxb
()
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:86
↓ 6 callersFunctionxu
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 6 callersFunctionyl
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 6 callersFunctionz
(t,n)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 6 callersFunctionzb
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:110
↓ 6 callersFunctionze
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionAb
()
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:161
↓ 5 callersFunctionAd
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionAe
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 5 callersFunctionAe
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionAg
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 5 callersFunctionAo
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 5 callersFunctionAr
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionBo
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionCg
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 5 callersFunctionD
()
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 5 callersFunctionDC
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 5 callersFunctionDd
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 5 callersFunctionDn
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 5 callersFunctionE
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 5 callersFunctionE
(t)
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
↓ 5 callersFunctionEb
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:16
↓ 5 callersFunctionFD
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
← previousnext →701–800 of 6,956, ranked by callers