Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/didi/KnowStreaming
/ functions
Functions
6,956 in github.com/didi/KnowStreaming
⨍
Functions
6,956
◇
Types & classes
1,070
↓ 3 callers
Method
calcDeadlineMs
Get the deadline for a particular call. @param now The current time in milliseconds. @param optionTimeoutMs The timeout option given
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:243
↓ 3 callers
Function
calculateUnit
(map: { [unit: string]: number }, targetValue: number)
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:86
↓ 3 callers
Function
cb
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
cb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
ce
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:47
↓ 3 callers
Method
checkExistKafkaUserFromDB
(Long clusterPhyId, String kafkaUser)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:393
↓ 3 callers
Method
checkMetricNameExist
(List<? extends BaseMetrics> baseMetrics, String metricName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:347
↓ 3 callers
Method
checkZKLegalAndTryGetInfo
(String zookeeper)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterValidateServiceImpl.java:147
↓ 3 callers
Method
cleanup
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/es/ESTestContainer.java:31
↓ 3 callers
Method
collectGroupMetricsFromKafka
从Kafka查询指标 @param clusterId 集群ID @param metric @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupMetricService.java:20
↓ 3 callers
Method
collectTopicMetricsFromKafka
从 kafka 中获取相应的指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:20
↓ 3 callers
Method
collectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/GroupMetricCollector.java:77
↓ 3 callers
Method
collectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/mm2/MirrorMakerMetricCollector.java:51
↓ 3 callers
Function
connectTest
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/AccessCluster.tsx:79
↓ 3 callers
Function
consumed
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 3 callers
Method
convert2ClusterPhyPO
(ClusterPhyAddDTO dto)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ClusterConverter.java:18
↓ 3 callers
Method
convert2HealthCheckConfigVO
(String groupName, BaseClusterHealthConfig config)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/HealthScoreVOConverter.java:64
↓ 3 callers
Method
convert2KafkaAclPO
(Long clusterPhyId, AclBinding aclBinding, Long updateTime)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaAclConverter.java:42
↓ 3 callers
Method
convert2Topic
(TopicPO po)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicConverter.java:21
↓ 3 callers
Function
ct
(t)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 3 callers
Function
ct
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 3 callers
Function
cz
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
dc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:95
↓ 3 callers
Function
de
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:49
↓ 3 callers
Method
deleteGroupOffset
删除Offset
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/OpGroupService.java:12
↓ 3 callers
Function
dg
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
dk
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
dy
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
eL
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
ee
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:49
↓ 3 callers
Function
ef
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
el
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
en
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 3 callers
Method
enqueue
Queue a call for sending. If the AdminClient thread has exited, this will fail. Otherwise, it will succeed (even if the AdminClient is shutting down)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1112
↓ 3 callers
Method
equals
(Object o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/metric/UserMetricConfig.java:37
↓ 3 callers
Function
eu
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:44
↓ 3 callers
Method
executeFourLetterCmd
(Long clusterPhyId, String host,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java:37
↓ 3 callers
Method
failWithTimeout
(long now, Throwable cause)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:570
↓ 3 callers
Function
fetch
(e,t)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 3 callers
Function
ff
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:172
↓ 3 callers
Function
fi
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:61
↓ 3 callers
Function
fm
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
fn
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 3 callers
Function
g
(t,e)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 3 callers
Function
g
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 3 callers
Function
gR
(t,e,n,i,r,o,a)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
genData
({ pageNo, pageSize, filters, sorter }: any)
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/index.tsx:23
↓ 3 callers
Function
genData
({ pageNo, pageSize, filters, sorter }: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerList/index.tsx:33
↓ 3 callers
Function
genData
({ pageNo, pageSize, filters, sorter }: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/Workers.tsx:22
↓ 3 callers
Function
genData
({ pageNo, pageSize, filters = null, sorter = null }: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerControllerChangeLog/index.tsx:34
↓ 3 callers
Function
genData
({ pageNo, pageSize, groupName }: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Detail.tsx:69
↓ 3 callers
Method
getBrokerConfigDetailFromKafka
获取Broker配置
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:20
↓ 3 callers
Method
getBrokerMetrics
(String brokerMetricKey)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:38
↓ 3 callers
Method
getByClusterAndGroupWithoutDefault
(Long clusterPhyId, String group)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/PlatformClusterConfigService.java:18
↓ 3 callers
Method
getByCode
(Integer dimension)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/health/HealthCheckDimensionEnum.java:45
↓ 3 callers
Method
getByName
(Long clusterPhyId, String connectClusterName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:25
↓ 3 callers
Method
getByRawState
(ConsumerGroupState rawGroupState)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/group/GroupStateEnum.java:35
↓ 3 callers
Method
getByState
(String state)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/group/GroupStateEnum.java:49
↓ 3 callers
Function
getCardInfo
(tabSelectTypeName: string)
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerDetailCard.tsx:42
↓ 3 callers
Method
getClusterBizStr
Cluster
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:14
↓ 3 callers
Function
getConfigItemDetailDesc
(item: keyof typeof CONFIG_ITEM_DETAIL_DESC, valueGroup: any)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/config.tsx:116
↓ 3 callers
Function
getConnectClustersList
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/AccessCluster.tsx:668
↓ 3 callers
Method
getConnectorTaskMetricList
(Long connectClusterId, String connectorName, String metricName, ConnectorTypeEnum connectorType)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:352
↓ 3 callers
Method
getDataFromKafka
从Kafka中获取数据 @param connectCluster connect集群 @return 全部资源列表, 成功的资源列表
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/meta/MetaDataService.java:22
↓ 3 callers
Function
getExistFormItems
(type: 'source' | 'sink')
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:108
↓ 3 callers
Function
getExistKafkaVersion
(isReloadAll = false)
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/HomePage.tsx:188
↓ 3 callers
Method
getHealthCheckCacheKey
(Long clusterId, Integer dimensionCode)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:109
↓ 3 callers
Method
getKafkaController
获取KafkaController信息 @param clusterPhyId 物理集群ID @return @throws NotExistException 不存在异常 @throws KeeperException ZK异常 @throws AdminOperateException 操作异常
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/KafkaZKDAO.java:70
↓ 3 callers
Method
getKafkaUserBizStr
KafkaUser
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:73
↓ 3 callers
Method
getKafkaUserNotExist
(Long clusterPhyId, String kafkaUser)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:77
↓ 3 callers
Function
getMM2Config
(connectClusterId: string | number)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:205
↓ 3 callers
Function
getMetricList
()
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:387
↓ 3 callers
Function
getMetricList
()
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:102
↓ 3 callers
Method
getMetricPointsFromES
@param clusterId @param topicName @param dto @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:66
↓ 3 callers
Method
getPartitionNotExist
(Long clusterPhyId, String topicName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:63
↓ 3 callers
Function
getPhyClusterState
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/HomePage.tsx:130
↓ 3 callers
Method
getQueryValue
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchTerm.java:19
↓ 3 callers
Method
getTaskName
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:143
↓ 3 callers
Function
getTaskPlanData
(params: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:159
↓ 3 callers
Method
getTopicFromCacheFirst
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:33
↓ 3 callers
Function
getTopicGroupMetric
({ hashData, pagination = { current: 1, pageSize: 10 }, sorter = {}, }: { hashData: HashData
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroupDetail.tsx:170
↓ 3 callers
Method
getTopicGroupMetric
(@PathVariable Long clusterId, @Pa
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/group/GroupController.java:50
↓ 3 callers
Method
getTopicMetrics
(String topicMetricKey)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:50
↓ 3 callers
Method
getTopicTypeCode
(String topicName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/topic/TopicTypeEnum.java:28
↓ 3 callers
Function
getTopicsList
()
km-console/packages/layout-clusters-fe/src/pages/TopicList/index.tsx:67
↓ 3 callers
Function
getVal
(val: string | number | undefined | null)
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerDetailCard.tsx:12
↓ 3 callers
Function
getVal
(val: string | number | undefined | null)
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectDetailCard.tsx:12
↓ 3 callers
Function
gf
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
↓ 3 callers
Function
gf
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:172
↓ 3 callers
Function
gg
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
goLogin
()
km-console/packages/config-manager-fe/src/constants/axiosConfig.ts:7
↓ 3 callers
Function
goLogin
()
km-console/packages/layout-clusters-fe/src/constants/axiosConfig.ts:7
↓ 3 callers
Function
h
(a,b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:74
↓ 3 callers
Function
hR
(t,e,n,i,r,o,a)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
hs
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
ht
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Function
hu
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:46
↓ 3 callers
Function
iC
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 3 callers
Function
im
(t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 3 callers
Method
init
(String threadPoolName, int corePoolSize, int maxPoolSize, int queueSize)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureNoWaitUtil.java:26
← previous
next →
1,501–1,600 of 6,956, ranked by callers