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 callersMethodbatchCreateMirrorTopic
@param dtoList @return
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/MirrorTopicService.java:16
↓ 1 callersMethodbatchDeleteMirrorTopic
@param dtoList @return
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/MirrorTopicService.java:22
↓ 1 callersMethodbatchInsert
批量写入
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:239
↓ 1 callersMethodbatchInsertStats
批量插入索引统计信息 @param statsInfo @return
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:129
↓ 1 callersMethodbatchModifyInDB
(List<ConnectClusterDTO> dtoList, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:33
↓ 1 callersMethodbatchReplace
(List<PlatformClusterConfigPO> poList, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/PlatformClusterConfigService.java:14
↓ 1 callersMethodbatchReplaceChangedConfig
(Long clusterPhyId, List<TopicConfig> topicConfigList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:43
↓ 1 callersMethodbatchReplaceGroupMembers
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:369
↓ 1 callersMethodbatchReplaceGroups
(Long clusterPhyId, List<Group> newGroupList, Set<String> getFailedGroupSet)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:417
↓ 1 callersMethodbatchReplaceGroupsAndMembers
批量更新DB @param clusterPhyId 集群ID @param newGroupList 新的group列表 @param getFailedGroupSet 元信息获取失败的group列表
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:42
↓ 1 callersMethodbatchReplaceKafkaUserInDB
operate DB-Method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:48
↓ 1 callersMethodbatchReplaceTopicHA
新增或者变更，支持幂等
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/HaActiveStandbyRelationService.java:12
↓ 1 callersMethodbeat
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:48
↓ 1 callersMethodbootstrapServers
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/KMTestEnvService.java:75
↓ 1 callersMethodborrowClientTryInitIfNotExist
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:92
↓ 1 callersMethodbrokerChanged
(Long startTime)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxConnectorWrap.java:80
↓ 1 callersMethodbrokerMetric2SinkPoint
private method
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:81
↓ 1 callersMethodbuildAggsDslMap
(String aggType, StringBuilder sb, String metricName, Map<String, String> agg
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:357
↓ 1 callersMethodbuildBrokerMetadataSeq
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/OpTopicManagerImpl.java:175
↓ 1 callersMethodbuildDescribeConfigsOptions
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:229
↓ 1 callersMethodbuildDescribeConfigsOptions
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:147
↓ 1 callersMethodbuildEsClient
(String address, String password,String clusterName, String version)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:507
↓ 1 callersMethodbuildMatchDsl
构建如下dsl语句 { "match": { "groupName": "g-know-streaming-123456" } }, { "match": { "groupName": "g-know-streaming-123456" } }
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:203
↓ 1 callersMethodbuildMetricsClusterPhyDTO
(List<Long> clusterIdList, MetricDTO metricDTO)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java:172
↓ 1 callersMethodbuildMetricsConnectorsDTO
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:464
↓ 1 callersMethodbuildMetricsConnectorsDTO
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterConnectorsManagerImpl.java:119
↓ 1 callersMethodbuildPrefixDsl
(SearchFuzzy fuzzy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:322
↓ 1 callersMethodbuildTopicOverviewMetricsDTO
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterTopicsManagerImpl.java:90
↓ 1 callersFunctionc
()
km-console/packages/layout-clusters-fe/static/js/system.min.js:4
↓ 1 callersFunctionca
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:101
↓ 1 callersMethodcalAndUpdateHealthCheckResult
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java:38
↓ 1 callersMethodcalAndUpdateHealthCheckResult
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:42
↓ 1 callersMethodcalBrokerHealthMetrics
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:16
↓ 1 callersMethodcalClusterBrokersHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:355
↓ 1 callersMethodcalClusterConnectsHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:384
↓ 1 callersMethodcalClusterGroupsHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:338
↓ 1 callersMethodcalClusterHealthMetrics
健康指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:15
↓ 1 callersMethodcalClusterMirrorMakersHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:414
↓ 1 callersMethodcalClusterTopicsHealthMetrics
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:321
↓ 1 callersMethodcalConnectorHealthMetrics
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:20
↓ 1 callersMethodcalGroupCount
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:55
↓ 1 callersMethodcalGroupHealthMetrics
(Long clusterPhyId, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:18
↓ 1 callersMethodcalMirrorMakerHealthMetrics
(Long connectClusterId, String mirrorMakerName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:21
↓ 1 callersMethodcalTopicHealthMetrics
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:17
↓ 1 callersMethodcalZookeeperHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/HealthStateService.java:19
↓ 1 callersMethodcalZookeeperHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:191
↓ 1 callersFunctioncalcStatus
()
km-console/packages/layout-clusters-fe/src/pages/Jobs/ExpandedRow.tsx:136
↓ 1 callersFunctioncalculateChartColor
(i: number)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/DetailChart/index.tsx:39
↓ 1 callersMethodcalculateNextAllowedRetryMs
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1558
↓ 1 callersFunctioncalculateSliderRange
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:452
↓ 1 callersMethodcallHasExpired
Check whether a call should be timed out. The remaining milliseconds until the next timeout will be updated. @param call The call. @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:687
↓ 1 callersMethodcanCancelJob
当前的任务状态, 能否取消任务
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:78
↓ 1 callersMethodcanExecuteJob
当前的任务状态, 能否执行任务
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:62
↓ 1 callersMethodcanNotDeleteJob
当前的任务状态, 不能删除任务
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:70
↓ 1 callersFunctioncancel
(record: any)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:76
↓ 1 callersMethodchangReassignmentThrottles
(ExecuteReassignParam executeReassignParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignService.java:53
↓ 1 callersMethodcheckAndGetResult
(ClusterParam clusterParam, Map<String, BaseClusterHealt
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java:103
↓ 1 callersMethodcheckAndGetResult
(ClusterParam clusterParam, Map<String, BaseClusterHealt
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:107
↓ 1 callersMethodcheckAndRemoveIfIllegal
(Long clusterPhyId, List<Broker> allAliveBrokerList)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java:59
↓ 1 callersMethodcheckAndSetSuccessIfFinished
(ReassignJobPO jobPO, ReassignResult reassignmentResult)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:568
↓ 1 callersMethodcheckCreateMirrorMakerParamAndUnifyData
(MirrorMakerCreateDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:471
↓ 1 callersMethodcheckExistInDB
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/change/record/impl/KafkaChangeRecordServiceImpl.java:61
↓ 1 callersMethodcheckFieldLegal
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:393
↓ 1 callersMethodcheckFieldModifyToDBLegal
(ClusterPhyPO clusterPhyPO, String operator)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/cluster/ClusterPhyPO.java:103
↓ 1 callersMethodcheckFirstElementIsEquals
校验两个list的第一个元素是否相等,以","分隔元素。 @param str1 @param str2 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:272
↓ 1 callersMethodcheckIfIgnore
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:328
↓ 1 callersMethodcheckKafkaLegal
(String bootstrapServers, Properties clientProps, String zookeeper)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterValidateService.java:13
↓ 1 callersMethodcheckParallelNum
(Map<Integer,Integer> bParallelNum, Set<Integer> newReplicas,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:87
↓ 1 callersMethodcheckParamLegalAndModifyOriginData
(Long jobId, ReplaceReassignJob replaceReassignJob, String creator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:650
↓ 1 callersMethodcheckPrefix
(String prefix)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/NamedThreadFactory.java:34
↓ 1 callersMethodcheckTrickJumpLogin
开启trick方式登录后，当前用户是否可以登录
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/trick/TrickJumpLoginService.java:18
↓ 1 callersMethodcheckZKAndBSLegal
(String bootstrapServers, Properties clientProps, String zookeeper)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterValidateServiceImpl.java:75
↓ 1 callersFunctionci
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctioncl
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersMethodclearHolder
清除SpringContextHolder中的ApplicationContext为Null
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/SpringTool.java:49
↓ 1 callersMethodcloseKafkaAdminClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminClient.java:69
↓ 1 callersMethodcloseLdapContext
(LdapContext ctx)
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/ldap/remote/LdapAuthentication.java:158
↓ 1 callersMethodcloseZKClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:88
↓ 1 callersMethodclusterMetric2SinkPoint
(List<ClusterMetrics> clusterMetrics)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:95
↓ 1 callersMethodcollectBrokerMetricsFromKafka
(Long clusterId, Integer brokerId, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:141
↓ 1 callersMethodcollectClusterMetricsFromKafka
从Kafka获取指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterMetricService.java:22
↓ 1 callersMethodcollectConnectClusterMetricsFromKafka
(Long connectClusterPhyId, String connectorName, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:133
↓ 1 callersMethodcollectConnectClusterMetricsFromKafka
( Long connectClusterPhyId, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterMetricServiceImpl.java:104
↓ 1 callersMethodcollectConnectMetrics
(ConnectCluster connectCluster)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/AbstractConnectMetricCollector.java:25
↓ 1 callersMethodcollectConnectMetrics
(ConnectCluster connectCluster)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/mm2/MirrorMakerMetricCollector.java:56
↓ 1 callersMethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/AbstractKafkaMetricCollector.java:25
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/BrokerMetricCollector.java:76
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/PartitionMetricCollector.java:76
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/GroupMetricCollector.java:84
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/TopicMetricCollector.java:87
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/ConnectConnectorMetricCollector.java:77
↓ 1 callersMethodcollectMetrics
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/mm2/MirrorMakerMetricCollector.java:86
↓ 1 callersMethodcollectMetricsFromZookeeper
(ZookeeperMetricParam param)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:94
↓ 1 callersMethodcollectPartitionsMetricsFromKafka
(Long clusterPhyId, String topicName, List<String> metricNameList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionMetricService.java:18
↓ 1 callersMethodcollectTopicMetricsFromKafka
(Long clusterId, String topic, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:127
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/AbstractMetricCollector.java:18
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/BrokerMetricCollector.java:69
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/ClusterMetricCollector.java:83
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/PartitionMetricCollector.java:69
↓ 1 callersMethodcollectorType
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/ZookeeperMetricCollector.java:107
← previousnext →3,201–3,300 of 6,956, ranked by callers