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
↓ 2 callers
Method
countResTypeAndDistinctFromDB
(Long clusterPhyId, ResourceType resourceType)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/KafkaAclService.java:15
↓ 2 callers
Function
cr
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Method
create
(Properties props)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:265
↓ 2 callers
Method
createConfigChangeNotificationVersionOne
创建config-change节点，使用的是v1版本的结构 @param clusterPhyId 集群ID @param entityType 实体类型 @param entityName 实体名称 @throws NotExistException 异常信息，除了这个异常之外，ZK还会有自己的异
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/KafkaZKDAO.java:86
↓ 2 callers
Method
createTopic
创建Topic
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/OpTopicManager.java:11
↓ 2 callers
Function
cs
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
ct
(n,e,t,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
cw
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
cx
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
d
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 2 callers
Function
d
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 2 callers
Function
d
()
km-console/packages/layout-clusters-fe/static/js/system.min.js:4
↓ 2 callers
Function
dC
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
dG
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
dI
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
dP
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
dR
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
d_
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
da
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
db
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
dealResponse
(error: any)
km-console/packages/config-manager-fe/src/constants/axiosConfig.ts:70
↓ 2 callers
Function
dealResponse
(error: any)
km-console/packages/layout-clusters-fe/src/constants/axiosConfig.ts:76
↓ 2 callers
Method
deleteGroupMemberInDB
(Long clusterPhyId, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:256
↓ 2 callers
Method
destroy
实现DisposableBean接口，在Context关闭时清理静态变量
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/SpringTool.java:67
↓ 2 callers
Function
dg
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:37
↓ 2 callers
Function
dh
(a,b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:69
↓ 2 callers
Function
di
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:66
↓ 2 callers
Function
di
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:172
↓ 2 callers
Function
dt
(t,n)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 2 callers
Function
du
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:48
↓ 2 callers
Function
du
(e,t,n,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
dw
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eC
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eI
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eM
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eO
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
e_
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
ea
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
ed
(t,e,n,i,r,o,a)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eg
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
eg
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:40
↓ 2 callers
Function
eh
(a,b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:70
↓ 2 callers
Method
enableAuth
(Integer authType)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/cluster/ClusterAuthTypeEnum.java:60
↓ 2 callers
Method
encrypt
(String sSrc)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/AESUtils.java:21
↓ 2 callers
Function
eo
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:74
↓ 2 callers
Function
eo
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
ep
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
es
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
ew
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
ex
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
ex
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Method
existServerDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerService.java:73
↓ 2 callers
Method
expandTopic
扩分区
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/OpTopicManager.java:21
↓ 2 callers
Function
f
(e,t)
km-console/packages/layout-clusters-fe/static/js/promise-polyfill.min.js:1
↓ 2 callers
Function
f
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:10
↓ 2 callers
Function
fA
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
fC
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
fP
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
fb
(t,e,n,i,r,o)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
fb
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
ff
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
fileReaderReady
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 2 callers
Method
filterAndConvertReassignmentMap
(Map<TopicPartition, Seq<Object>> rowScalaReassignmentMap, List<Integer> partitionIdList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:348
↓ 2 callers
Function
findTargetCheckbox
(checkboxData: CheckboxStatus, keyTrace: (string | number)[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:123
↓ 2 callers
Function
fk
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
fo
(e,t,n,r,o,a,i)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Method
forTimestamp
Used to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition @param timestamp i
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/offset/KSOffsetSpec.java:44
↓ 2 callers
Function
forbidenPaths
(path: string)
km-console/packages/layout-clusters-fe/src/pages/index.tsx:39
↓ 2 callers
Function
formattedBytes
(v: number)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Replicator.tsx:12
↓ 2 callers
Function
formattedMinBytesInOut
(v: number)
km-console/packages/layout-clusters-fe/src/pages/TopicList/ExpandPartition.tsx:90
↓ 2 callers
Function
fv
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
fx
(e,o,a)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
fy
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
gA
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
gC
(t,e,n,i,r)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
gS
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
gV
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
ga
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Function
gb
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 2 callers
Function
gb
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 2 callers
Method
genCheckpointName
(String sourceName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MirrorMakerUtil.java:4
↓ 2 callers
Method
genClusterTopicMetricKey
(Long clusterPhyId, String topicName, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:99
↓ 2 callers
Function
genData
({ pageNo, pageSize, filters = null, sorter = null }: any)
km-console/packages/layout-clusters-fe/src/pages/GroupList/index.tsx:23
↓ 2 callers
Function
genData
({ pageNo, pageSize, filters = null, sorter = null }: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ACLs.tsx:33
↓ 2 callers
Function
genData
({ pageNo, pageSize }: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Configuration.tsx:32
↓ 2 callers
Function
genData
({ pageNo, pageSize, filters = null, sorter = null }: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroups.tsx:67
↓ 2 callers
Function
genData
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Replicator.tsx:104
↓ 2 callers
Function
genData
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Messages.tsx:49
↓ 2 callers
Function
genData
({ pageNo, pageSize }: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/NodeTraffic.tsx:26
↓ 2 callers
Function
genData
({ pageNo, pageSize }: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/Configuration.tsx:32
↓ 2 callers
Function
genData
({ pageNo, pageSize }: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/DataLogs.tsx:27
↓ 2 callers
Function
genData
()
km-console/packages/layout-clusters-fe/src/pages/Connect/Detail.tsx:24
↓ 2 callers
Method
genHeartbeatName
(String sourceName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MirrorMakerUtil.java:8
↓ 2 callers
Method
genIndexNameWithVersion
(String indexName, Integer version)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:50
↓ 2 callers
Method
generateNewPartitionAssignment
新增分区的分配策略 @param brokerRackMap broker-rack信息 @param partitionMap 当前partition分布信息 @param incPartitionNum 新增分区数 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KafkaReplicaAssignUtil.java:18
↓ 2 callers
Function
getAdditionChartData
( needRender: boolean, leftBoundaryTimestamp: number, rightBoundaryTimestamp: number, sliderPo
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:319
↓ 2 callers
Method
getAfterDays
(Date time, int after)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:118
↓ 2 callers
Method
getAllDimensionHealthResult
获取集群健康检查结果
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:26
↓ 2 callers
Method
getAllPartitionOffsetFromKafka
获取分区Offset信息
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionService.java:41
↓ 2 callers
Method
getApplicationContext
去的存储在静态变量中的ApplicationContext
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/SpringTool.java:27
← previous
next →
2,301–2,400 of 6,956, ranked by callers