MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
↓ 4 callersFunctionfs
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionfu
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:44
↓ 4 callersFunctionfx
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctiong
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:11
↓ 4 callersFunctiong
(b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:74
↓ 4 callersFunctiongc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:94
↓ 4 callersFunctionge
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersMethodgen4lwFailedKey
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/ZookeeperLocalCache.java:40
↓ 4 callersMethodgenDailyIndexName
(String templateName, int offsetDay)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:65
↓ 4 callersFunctiongenData
({ pageNo, pageSize }: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/index.tsx:26
↓ 4 callersMethodgetAggMetricPointFromES
获取聚合指标点 @param clusterPhyId @param topicNames @param metricName @param aggTypeEnum @param startTime @param endTime @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:90
↓ 4 callersMethodgetAllBrokerPOsFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:298
↓ 4 callersMethodgetApiCallLeftTimeUnitMs
(Long costedUnitMs)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/KSConfigUtils.java:21
↓ 4 callersFunctiongetCheckedList
( versionState: { [key: string]: boolean; }, filterFunc: (item: [string, boolean], i: number
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/CustomCheckGroup.tsx:37
↓ 4 callersMethodgetCmd
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/FourLetterWordDataParser.java:7
↓ 4 callersMethodgetConnectClusterMetrics
(String connectClusterMetricKey)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:80
↓ 4 callersMethodgetConnectorLatestMetric
(Long clusterPhyId, List<Tuple<Long, String>> connectClusterIdAndConnectorNameList, List<String> metricsNames)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:68
↓ 4 callersFunctiongetData
(query = {})
km-console/packages/config-manager-fe/src/pages/OperationLog/index.tsx:63
↓ 4 callersMethodgetData
(Long clusterPhyId, String path, Class<T> clazz)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:219
↓ 4 callersMethodgetESLogger
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/LoggerUtil.java:15
↓ 4 callersMethodgetEndpointMap
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/znode/brokers/BrokerMetadata.java:83
↓ 4 callersMethodgetExecutorQueueSize
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:141
↓ 4 callersMethodgetFinallyJmxPort
选取最终的jmx端口 @param serverId 服务ID @param metadataJmxPort ks从元信息中获取到的jmx端口
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/JmxConfig.java:32
↓ 4 callersMethodgetForObject
GET请求 @param url 请求地址 @param headers 请求头 @param resultType 返回类型 @param <T> 泛型T @return T
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:103
↓ 4 callersMethodgetFormatDayByOffset
获取指定偏移日期的格式化结果 @param offset @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:298
↓ 4 callersMethodgetGroupDescriptionFromKafka
(ClusterPhy clusterPhy, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:32
↓ 4 callersMethodgetHealthCompareResult
(Long connectClusterId, String connectorName, String connectorType, Integer dimension, String metricName, Heal
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:109
↓ 4 callersMethodgetLatestMetricsFromCache
优先从本地缓存获取metrics信息
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:26
↓ 4 callersMethodgetMonthInfo
(Date time)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:143
↓ 4 callersMethodgetOpenSecure
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/ZKConfig.java:28
↓ 4 callersMethodgetPartitionOffsetFromKafka
(Long clusterPhyId, String topicName, KSOffsetSpec offsetSpec)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:42
↓ 4 callersMethodgetProps
(String fieldName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/GitPropUtil.java:20
↓ 4 callersMethodgetRequestTimeoutUnitMs
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/ZKConfig.java:44
↓ 4 callersMethodgetTopicPartitionMetricList
(Long connectClusterId, String mirrorMakerName, List<MirrorMakerTopic> mirrorMakerTopicList, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerMetricServiceImpl.java:284
↓ 4 callersMethodgetTopicsAggsMetricsValue
获取集群 clusterPhyId 中多个 topic 的每个 metric 的指定 topic 在指定时间[startTime、endTime]区间内聚合计算(avg、max)之后的统计值 注意：es的(avg、max)聚合计算只能获取值，不能获取值之外的信息，如：时间
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:62
↓ 4 callersMethodhandler
(_compilation, { normalModuleFactory })
km-console/packages/layout-clusters-fe/config/CountComponentWebpackPlugin.js:54
↓ 4 callersFunctionhc
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionhe
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 4 callersFunctionhr
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionhv
(e,t,n,r,o,a,i,c)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctioni
(e,t)
km-console/packages/layout-clusters-fe/static/js/system.min.js:4
↓ 4 callersFunctioniD
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionid
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:125
↓ 4 callersFunctionii
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:60
↓ 4 callersFunctionii
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 4 callersMethodinitWithMetric
(Long connectClusterId, String connectorName, String metricName, Float value)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/mm2/MirrorMakerMetrics.java:36
↓ 4 callersMethodintList2String
(List<Integer> intList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:109
↓ 4 callersFunctionir
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersMethodisNumeric
(String str)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:246
↓ 4 callersFunctionit
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionj
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 4 callersFunctionj_
(t,e,n,i,r,o,a,s)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionjt
(s,t)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 4 callersFunctionkP
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionkd
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:126
↓ 4 callersFunctionkg
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:45
↓ 4 callersFunctionl
()
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 4 callersFunctionlh
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersMethodlistAll
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/LoadedClusterPhyCache.java:37
↓ 4 callersMethodlistAllBrokersAndUpdateCache
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:292
↓ 4 callersMethodlistByConnectClusterIdFromDB
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorService.java:34
↓ 4 callersMethodlistJobByClusterIdAndStatusSortByPlanTime
(Long clusterPhyId, int status)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:435
↓ 4 callersMethodlistMetricsByConnectors
获取每个 metric 指定个 topic 的指标
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:114
↓ 4 callersMethodlistPartitionByTopic
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:27
↓ 4 callersFunctionlr
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionmI
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionmk
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersMethodmodify
修改一个任务 1、校验任务内容是否合法 2、提交任务 @param job 任务数据 @return result
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:49
↓ 4 callersFunctionmt
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionn
(e,n)
km-console/packages/layout-clusters-fe/static/js/system.min.js:4
↓ 4 callersFunctionng
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:47
↓ 4 callersFunctionni
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:58
↓ 4 callersFunctionnt
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctiono
(e,n)
km-console/packages/layout-clusters-fe/static/js/promise-polyfill.min.js:1
↓ 4 callersFunctionoB
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionog
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionol
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctiononChange
(e: any)
km-console/packages/layout-clusters-fe/src/components/DDSearchInput/index.tsx:19
↓ 4 callersFunctiononClose
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceFilter.tsx:111
↓ 4 callersFunctiononExpand
(metricName: string, metricType: MetricType)
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/index.tsx:211
↓ 4 callersFunctionopen
(type: 'info' | 'success' | 'warning' | 'error', content: ArgsProps)
km-console/packages/config-manager-fe/src/components/Notification/index.tsx:11
↓ 4 callersFunctionopen
(type: 'info' | 'success' | 'warning' | 'error', content: ArgsProps)
km-console/packages/layout-clusters-fe/src/components/Notification/index.tsx:11
↓ 4 callersFunctionopenMessage
( type: 'info' | 'success' | 'warning' | 'error', content: JointContent, duration?: ConfigDuration, on
km-console/packages/config-manager-fe/src/components/Message/index.tsx:18
↓ 4 callersFunctionopenMessage
( type: 'info' | 'success' | 'warning' | 'error', content: JointContent, duration?: ConfigDuration, on
km-console/packages/layout-clusters-fe/src/components/Message/index.tsx:18
↓ 4 callersFunctionoy
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionp
(t)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 4 callersFunctionp
(a,b,c,d,f)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:75
↓ 4 callersFunctionpD
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionpF
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersMethodpageByPreciseFilter
精确过滤
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationUtil.java:84
↓ 4 callersFunctionpc
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionpp
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersMethodprettyPrintException
Pretty-print an exception. @param throwable The exception. @return A compact human-readable string.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:256
↓ 4 callersMethodputJsonForObject
PUT请求 header中有application/json @param url 请求地址 @param request 请求内容 @param responseType 期望返回的类型 @param <T> 泛型T @return T
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:288
↓ 4 callersFunctionpx
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionq
(t)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 4 callersFunctionql
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 4 callersFunctionqo
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionqx
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 4 callersFunctionra
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:100
← previousnext →1,101–1,200 of 6,956, ranked by callers