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 callersFunctiononClickPreview
(data?: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:162
↓ 1 callersFunctiononClickSavePreview
(data: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:229
↓ 1 callersFunctiononClose
()
km-console/packages/config-manager-fe/src/pages/UserManage/UserTabContent.tsx:81
↓ 1 callersFunctiononClose
()
km-console/packages/config-manager-fe/src/pages/ConfigManage/index.tsx:83
↓ 1 callersFunctiononClose
()
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:234
↓ 1 callersFunctiononClose
()
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:174
↓ 1 callersFunctiononDelete
(record)
km-console/packages/config-manager-fe/src/pages/UserManage/RoleTabContent.tsx:535
↓ 1 callersFunctiononDelete
(record: ConfigProps)
km-console/packages/config-manager-fe/src/pages/ConfigManage/index.tsx:371
↓ 1 callersFunctiononDelete
(record: ACLsProps)
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/index.tsx:168
↓ 1 callersFunctiononDelete
(record: UsersProps)
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:391
↓ 1 callersFunctiononKeyChange
(keyTrace: (string | number)[], keys: string[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:171
↓ 1 callersFunctiononSubmit
()
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:1043
↓ 1 callersFunctiononSubmit
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:1109
↓ 1 callersFunctionoo
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionor
(r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionot
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 1 callersFunctionot
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 1 callersFunctionov
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionp
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:11
↓ 1 callersFunctionpR
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersMethodpageWorkByKafkaClusterPhy
分页获取 @param kafkaClusterPhyId @param dto @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/WorkerService.java:35
↓ 1 callersMethodpaginationInterceptor
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/DataSourceConfig.java:82
↓ 1 callersMethodpaginationQuery
分页查询 @param clusterPhyId kafka 集群id @param dto 封装分页查询条件的对象 @return 分页查询结果集
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ControllerChangeLogService.java:31
↓ 1 callersMethodpagingBrokers
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:151
↓ 1 callersMethodpagingByCluster
(Long clusterPhyId, PaginationBaseDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/change/record/KafkaChangeRecordService.java:11
↓ 1 callersMethodpagingClusterGroupsOverview
(Long clusterPhyId, ClusterGroupSummaryDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/GroupManager.java:31
↓ 1 callersMethodpagingClusterWithLatestMetrics
获取某个 metric 的排序后的分页集群 ids
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/ClusterMetricESDAO.java:75
↓ 1 callersMethodpagingConnectorInLocal
(List<ClusterConnectorOverviewVO> connectorVOList, ClusterConnectorsOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterConnectorsManagerImpl.java:137
↓ 1 callersMethodpagingControllerHistories
(Long clusterPhyId, Integer pageNo, Integer pageSize, String brokerHostSearchKeyword)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/KafkaControllerService.java:23
↓ 1 callersMethodpagingGroupTopicConsumedMetrics
(Long clusterPhyId, String to
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/GroupManager.java:33
↓ 1 callersMethodpagingGroupTopicMembers
(Long clusterPhyId, String groupName, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/GroupManager.java:29
↓ 1 callersMethodpagingGroupTopicPartitionMetrics
(Long clusterPhyId, String groupNa
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:476
↓ 1 callersMethodpagingJobs
分页查询 @param clusterPhyId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:94
↓ 1 callersMethodpagingKafkaUserFromDB
(Long clusterPhyId, PaginationBaseDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:50
↓ 1 callersMethodpagingMirrorMakerInLocal
(List<ClusterMirrorMakerOverviewVO> mirrorMakerOverviewVOList, ClusterMirrorMakersOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:567
↓ 1 callersMethodpagingTopicGroupsOverview
(Long clusterPhyId, String topicName, String searchGroupName, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/TopicStateManager.java:29
↓ 1 callersMethodpagingTopicInLocal
(List<ClusterPhyTopicsOverviewVO> voList, ClusterTopicsOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterTopicsManagerImpl.java:96
↓ 1 callersMethodpagingTopicWithLatestMetricsFromES
@param clusterId @param metricNameList @param sort @param fuzzy @param searchTermList @param page @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:116
↓ 1 callersMethodparseAndInitData
(Long clusterPhyId, String host, int port, String cmdData)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/FourLetterWordDataParser.java:9
↓ 1 callersFunctionparseHeaders
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 1 callersMethodpartitionAssignor
The consumer group partition assignor.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSGroupDescription.java:88
↓ 1 callersMethodpartitionMetric2SinkPoint
(List<PartitionMetrics> partitionMetrics)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:124
↓ 1 callersMethodpath
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/BrokersNodeChangeHandler.java:46
↓ 1 callersFunctionpb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionpd
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionpg
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionph
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:90
↓ 1 callersMethodpreciseFilterMetricList
private method
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:55
↓ 1 callersMethodpreciseFilterMetrics
(List<? extends BaseMetrics> allDataList, List<PaginationPreciseFilterFieldDTO> preciseFilterFieldDTOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:26
↓ 1 callersMethodpreferredReplicaElection
(Long jobId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:65
↓ 1 callersMethodpreferredReplicaElection
(Long jobId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:490
↓ 1 callersFunctionprefix
(location, ident, matchPath)
km-console/packages/layout-clusters-fe/config/registerApps.js:27
↓ 1 callersMethodprocess
处理任务 @param job 任务 @return result
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:64
↓ 1 callersMethodprocessClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java:16
↓ 1 callersMethodprocessClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java:17
↓ 1 callersMethodprocessClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java:17
↓ 1 callersMethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metrics/AbstractAsyncMetricsDispatchTask.java:17
↓ 1 callersMethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metadata/AbstractAsyncMetadataDispatchTask.java:17
↓ 1 callersMethodprocessRequests
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1044
↓ 1 callersMethodprocessSubTask
执行被分配的任务 @param clusterPhy 任务 @param triggerTimeUnitMs 任务触发时间 @return
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java:25
↓ 1 callersMethodprocessSubTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/AbstractConnectClusterDispatchTask.java:23
↓ 1 callersMethodprocessTask
执行被分配的任务 @param subTaskList 子任务列表 @param triggerTimeUnitMs 任务触发时间 @return
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:45
↓ 1 callersFunctionprocessTitle
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:372
↓ 1 callersMethodprovide
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:440
↓ 1 callersMethodpurgeExecutor
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:137
↓ 1 callersMethodputBrokerMetrics
(String brokerMetricKey, Float value)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:42
↓ 1 callersMethodputConnectClusterMetrics
(String connectClusterMetricKey, Float value)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:73
↓ 1 callersMethodputConnectorMetrics
(String connectClusterMetricKey, Float value)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:84
↓ 1 callersMethodputHaTopic
(Long clusterPhyId, String topicName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:113
↓ 1 callersMethodputHealthCheckResults
(Long cacheKey, Map<String, List<HealthCheckResultPO>> poMap)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:101
↓ 1 callersMethodputPartitionMetricsList
(String partitionMetricsKey, List<PartitionMetrics> metricsList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:66
↓ 1 callersMethodputPartitions
(Long clusterPhyId, Map<String, List<Partition>> partitionMap)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:93
↓ 1 callersMethodputTopicMetrics
(String topicMetricKey, List<TopicMetrics> metricsList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:54
↓ 1 callersMethodputTopicMetrics
(Long clusterPhyId, Map<String, TopicMetrics> metricsMap)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:77
↓ 1 callersFunctionpw
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionpy
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionq
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:15
↓ 1 callersFunctionqC
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionqd
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionqe
(t,e,n,i,r,o,a,s,l)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 1 callersFunctionqi
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:71
↓ 1 callersFunctionqm
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionqr
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionqt
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodqueryCount
分页查询结果条件查询出的结果集总数 @param clusterPhyId kafka 集群id @param dto 封装分页查询条件的对象 @return 分页查询结果条件查询出的结果集总数
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ControllerChangeLogService.java:23
↓ 1 callersFunctionqueryExpandedData
(record: any, key: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/TeskDetails.tsx:31
↓ 1 callersFunctionr
(e)
km-console/packages/layout-clusters-fe/static/js/promise-polyfill.min.js:1
↓ 1 callersFunctionrandomString
(len = 32, chars = 'abcdefghijklmnopqrstuvwxyz1234567890')
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:27
↓ 1 callersMethodrandomWritableChar
随机生成单个随机字符
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:227
↓ 1 callersMethodrangeFilterMetricList
(List<? extends BaseMetrics> allDataList, List<PaginationRangeFilterFieldDTO> rangeFilterDTOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:88
↓ 1 callersMethodrangeFilterMetrics
(List<? extends BaseMetrics> allDataList, List<PaginationRangeFilterFieldDTO> rangeFilterDTOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:30
↓ 1 callersFunctionrb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodreBalancePhysicalClusterShard
(Map<Long, List<Long>> shardIdPhysicalClusterIdListMap)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:123
↓ 1 callersFunctionreadArrayBufferAsText
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 1 callersFunctionreadBlobAsText
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 1 callersMethodreadEsFileInJarFile
从jar包中读取es相关的语句文件 @param fileName @return
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESFileLoader.java:121
↓ 1 callersMethodrecordChangeToDB
(Long clusterPhyId, List<Broker> zkBrokerList, long triggerTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/BrokersNodeChangeHandler.java:79
↓ 1 callersMethodrecordChangeToDB
(Long clusterPhyId, long triggerTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:81
↓ 1 callersMethodrecordChangeToDB
(Long clusterPhyId, List<Topic> zkTopicList, long triggerTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/TopicsNodeChangeHandler.java:79
↓ 1 callersMethodrecordChangeToDB
(Long clusterPhyId, List<String> notificationList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ConfigNotificationNodeChangeHandler.java:71
← previousnext →4,001–4,100 of 6,956, ranked by callers