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 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/TopicMetricCollector.java:80
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/ConnectConnectorMetricCollector.java:70
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/ConnectClusterMetricCollector.java:79
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/index.tsx:108
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/HistoryDrawer.tsx:27
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:66
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/TopicList/index.tsx:156
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/Consumers/index.tsx:74
↓ 1 callersFunctioncolumns
()
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:329
↓ 1 callersMethodcompareFirstNotNullMetricValue
(BaseMetrics a1, BaseMetrics a2, List<String> metricNameList, Field defaultField)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationMetricsUtil.java:199
↓ 1 callersMethodcompareObject
(Object v1, Object v2)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationUtil.java:294
↓ 1 callersMethodcompleteClusterInfo
(List<ClusterMirrorMakerOverviewVO> mirrorMakerVOList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:601
↓ 1 callersMethodcompleteInfo
(ReassignSubJobPO newPO, ReassignSubJobPO dbPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:868
↓ 1 callersMethodconfigure
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:85
↓ 1 callersMethodconfigureDefaultApiTimeoutMs
If a default.api.timeout.ms has been explicitly specified, raise an error if it conflicts with request.timeout.ms. If no default.api.timeout.ms has be
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:375
↓ 1 callersMethodconnectConnectorMetric2SinkPoint
(List<ConnectorMetrics> connectorMetricsList)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:179
↓ 1 callersMethodcontainsByPhyId
(Long connectClusterId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/cache/LoadedConnectClusterCache.java:16
↓ 1 callersMethodconvert2AclBindingVO
(KafkaAclPO po)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaAclConverter.java:30
↓ 1 callersMethodconvert2BasicVO
(ConnectCluster connectCluster, ConnectorPO connectorPO)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:33
↓ 1 callersMethodconvert2BasicVOList
( List<ConnectCluster> clusterList, List<ConnectorPO> poList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:48
↓ 1 callersMethodconvert2BrokerIdPartitionListMap
(List<Partition> partitionList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:381
↓ 1 callersMethodconvert2ClusterBrokersOverviewVO
(Integer brokerId, Broker broker, BrokerMetrics brokerMetrics, Topic groupTopic, Topic transactionTopic, Kafka
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:211
↓ 1 callersMethodconvert2ClusterBrokersOverviewVOList
(ClusterPhy clusterPhy, List<I
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:182
↓ 1 callersMethodconvert2ClusterConnectorOverviewVOList
(List<ConnectCluster> clusterList,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:99
↓ 1 callersMethodconvert2ClusterMirrorMakerOverviewVO
(List<ConnectorPO> mirrorMakerList, List<ConnectCluster> connectClusterList, List<MirrorMakerMetrics> latestMe
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:547
↓ 1 callersMethodconvert2ClusterPhyDashboardVOList
(List<ClusterPhyDashboardVO> rowVOList,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ClusterVOConverter.java:20
↓ 1 callersMethodconvert2ClusterPhyTopicsOverviewVOList
(List<Topic> topicList, Map<String, TopicMetrics> metricsMap, Set<String> haTopicNameSet)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:80
↓ 1 callersMethodconvert2ConnectClusterBasicCombineExistVO
(ConnectCluster connectCluster)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:86
↓ 1 callersMethodconvert2ConnectStateVO
(List<ConnectCluster> connectClusterList, List<ConnectorPO> connectorPOList, List<WorkerConnector> workerConne
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterConnectorsManagerImpl.java:126
↓ 1 callersMethodconvert2ConnectorOverviewVO
(ConnectorPO connectorPO, List<WorkerConnector> workerConnectorList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/impl/ConnectorManagerImpl.java:108
↓ 1 callersMethodconvert2HealthCheckConfigVOList
(String groupName, List<BaseClusterHealthConfig> configList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/HealthScoreVOConverter.java:56
↓ 1 callersMethodconvert2HealthScoreBaseResultVOList
(List<HealthScoreResult> healthScoreResultList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/HealthScoreVOConverter.java:39
↓ 1 callersMethodconvert2HealthScoreResultList
聚合数据
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:435
↓ 1 callersMethodconvert2JobDetail
(Job job, ReassignJobDetail reassignJobDetail)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:252
↓ 1 callersMethodconvert2KafkaBrokerConfigDetailList
(List<String> configNameList, Properties properties)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaConfigConverter.java:25
↓ 1 callersMethodconvert2KafkaBrokerConfigVOList
(List<KafkaConfigDetail> configList, List<BrokerConfigPO> diffPOList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerConfigManagerImpl.java:47
↓ 1 callersMethodconvert2KafkaChangeRecordVOList
(List<KafkaChangeRecordPO> poList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ChangeRecordVOConverter.java:12
↓ 1 callersMethodconvert2KafkaConfigDetail
(ConfigEntry configEntry, Map<String, ConfigDef.ConfigKey> configKeyMap)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaConfigConverter.java:97
↓ 1 callersMethodconvert2KafkaControllerVO
(KafkaController kafkaController, Broker kafkaControllerBroker)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:238
↓ 1 callersMethodconvert2KafkaTopicConfigDetailList
(List<Properties> configNameAndDocList, Properties presentConfig)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaConfigConverter.java:54
↓ 1 callersMethodconvert2MirrorMakerBasicVOList
( List<ConnectCluster> clusterList, List<ConnectorPO> poList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:67
↓ 1 callersMethodconvert2MirrorMakerStateVO
(List<ConnectorPO> connectorPOList,List<WorkerConnector> workerConnectorList,List<ConnectWorker> workerList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:523
↓ 1 callersMethodconvert2PartitionList
(Long clusterPhyId, TopicDescription description)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/PartitionConverter.java:14
↓ 1 callersMethodconvert2PartitionMap
(List<TopicAssignedCount> assignedCountList, Integer replicaNum, List<Integer> filterPartitionIdList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/assign/TopicAssignedCount.java:68
↓ 1 callersMethodconvert2ReassignJobDetail
(ReassignJobPO jobPO, List<ReassignSubJobPO> subJobPOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:138
↓ 1 callersMethodconvert2ReassignJobDetailDataGroupByTopic
(List<ReassignSubJobPO> subJobPOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:159
↓ 1 callersMethodconvert2SubJobPartitionDetailVOList
(ReassignJobDetailDataGroupByTopic detailDataGroupByTopic)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:234
↓ 1 callersMethodconvert2SubJobReplicaMoveDetailList
(List<ReassignJobDetailDataGroupByTopic> reassignTopicDetailsList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:320
↓ 1 callersMethodconvert2SubJobReplicaScalaDetailList
(List<ReassignJobDetailDataGroupByTopic> reassignTopicDetailsList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ReassignConverter.java:293
↓ 1 callersMethodconvert2TopicList
(List<TopicPO> poList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicConverter.java:42
↓ 1 callersMethodconvert2TopicMetadataCombineExistVO
(String topicName, Topic topic)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:26
↓ 1 callersMethodconvert2TopicMetadataVOList
(List<Topic> topicList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:58
↓ 1 callersMethodconvert2TopicPOAndIgnoreTime
(TopicCreateParam createParam)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicConverter.java:82
↓ 1 callersMethodconvert2TopicPartitionVO
(Partition partition, PartitionMetrics metrics)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:125
↓ 1 callersMethodconvert2TopicRecordVO
(String topicName, ConsumerRecord<String, String> consumerRecord)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:43
↓ 1 callersMethodconvert2Znode
(ClusterPhy clusterPhy, Tuple<byte[], Stat> dataAndStat, String path)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ZnodeConverter.java:14
↓ 1 callersMethodconvertAndSupplyMirrorMakerInfo
(ConnectCluster connectCluster, List<Triple<KSConnectorInfo, List<String>, KSConnectorStateInfo>> connectorFul
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:161
↓ 1 callersMethodconvertId2Host
( Long clusterId, Table<String/*metric*/, Long/*brokerId*/, List<MetricPointVO>> table
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:479
↓ 1 callersMethodcountAllBrokers
获取总的Broker数
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerService.java:69
↓ 1 callersMethodcountBrokerConfigDiffsFromDB
(Long clusterPhyId, List<String> excludeConfigs)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:24
↓ 1 callersMethodcountByConnectClusterIdFromDB
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorService.java:36
↓ 1 callersMethodcountJobsByCluster
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:119
↓ 1 callersMethodcountKafkaAclFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/KafkaAclService.java:13
↓ 1 callersMethodcountKafkaUserAndDistinctFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/KafkaAclService.java:17
↓ 1 callersMethodcreateClientProperties
(ClusterPhy clusterPhy)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/KafkaConsumerFactory.java:44
↓ 1 callersMethodcreateFutures
(Collection<String> groupIds)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1206
↓ 1 callersMethodcreateIndex
创建索引
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:306
↓ 1 callersMethodcreateIndexTemplateIfNotExist
创建索引模板
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:354
↓ 1 callersMethodcreateInternal
(AdminClientConfig config, TimeoutProcessorFactory timeoutProcessorFactory)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:269
↓ 1 callersMethodcreateJmxConnector
private method
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxConnectorWrap.java:164
↓ 1 callersMethodcreateJmxConnectorWrap
(Long clusterPhyId, Integer brokerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java:130
↓ 1 callersMethodcreateJmxConnectorWrap
(Long connectorClusterId, String workerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:59
↓ 1 callersMethodcreateKafkaAcl
创建ACL
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/OpKafkaAclService.java:11
↓ 1 callersMethodcreateKafkaAdminClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminClient.java:94
↓ 1 callersMethodcreateKafkaUser
新增KafkaUser
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:20
↓ 1 callersMethodcreateKafkaUserWithTokenEncrypted
新增KafkaUser
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/KafkaUserManager.java:12
↓ 1 callersMethodcreateLogContext
(String clientId)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:335
↓ 1 callersMethodcreateMirrorMaker
(MirrorMakerCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:22
↓ 1 callersMethodcreateReassignmentPlanJson
创建迁移计划Json @param dtoList @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/ReassignManager.java:18
↓ 1 callersMethodcreateReplicaChangePlanJson
创建副本变更Json @param dtoList @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/ReassignManager.java:25
↓ 1 callersMethodcreateRequest
Create an AbstractRequest.Builder for this Call. @param timeoutMs The timeout in milliseconds. @return The AbstractRequest builder.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:586
↓ 1 callersFunctioncreateStylesheetLink
(ident, path)
km-console/packages/layout-clusters-fe/config/registerApps.js:41
↓ 1 callersMethodcreateZKClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:109
↓ 1 callersMethodcurNode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:509
↓ 1 callersFunctiond
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:11
↓ 1 callersFunctiond
()
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
↓ 1 callersFunctiondE
(e,r,o)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctiondO
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctiondS
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctiondb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctiondc
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctiondealTableRequestParams
({ searchKeywords, pageNo, pageSize, sorter, filters, isPhyId = undefined }: any)
km-console/packages/layout-clusters-fe/src/constants/common.ts:81
↓ 1 callersMethoddelIndexByName
删除索引
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:409
↓ 1 callersFunctiondelUser
(record: UserProps)
km-console/packages/config-manager-fe/src/pages/UserManage/UserTabContent.tsx:229
↓ 1 callersMethoddelete
删除迁移任务
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:20
↓ 1 callersMethoddeleteByUpdateTimeBeforeInDB
(Long clusterPhyId, Date beforeTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:30
↓ 1 callersMethoddeleteConnectorInDB
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:298
↓ 1 callersMethoddeleteGroupInDB
(Long clusterPhyId, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:248
↓ 1 callersMethoddeleteGroupOffsets
(GroupOffsetDeleteDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/GroupManager.java:43
↓ 1 callersMethoddeleteGroupTopicOffset
(DeleteGroupTopicParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/OpGroupService.java:13
← previousnext →3,301–3,400 of 6,956, ranked by callers