MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
Functionbg
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionblur
(value: any)
km-console/packages/layout-clusters-fe/src/components/CodeMirrorFormItem/index.tsx:36
Functionbo
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:77
Functionbp
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionbr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28
Functionbt
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Methodbuild
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionControlItem.java:47
MethodbuildDuplicate
(String msg)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java:147
MethodbuildFrom
(Long clusterPhyId, String topicName, TopicPartitionInfo topicPartitionInfo)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/partition/Partition.java:46
MethodbuildFromRSAndData
(ResultStatus rs, T data)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java:125
MethodbuildMatchDslTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:43
MethodbuildNotExist
(String msg)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java:154
MethodbuildParamIllegal
(String msg)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java:161
MethodbuildRangeDslTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:35
MethodbuildSortDslTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:26
Functionbw
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionby
(o)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionc
(e,t)
km-console/packages/layout-clusters-fe/static/js/single-spa-react.js:1
Functionc
(t)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctioncE
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctioncI
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctioncM
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
MethodcalBrokerHealthMetrics
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:127
MethodcalClusterHealthMetrics
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:63
MethodcalConnectorHealthMetrics
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:221
MethodcalGroupCount
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:312
MethodcalGroupHealthMetrics
(Long clusterPhyId, String groupName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:173
MethodcalGroupStatCount
(Long clusterPhyId, GroupStateEnum stateEnum)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:320
MethodcalMirrorMakerHealthMetrics
(Long connectClusterId, String mirrorMakerName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:246
MethodcalTopicHealthMetrics
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:155
Functioncallback
(key: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/ViewJobsProgress.tsx:23
Functioncallback
(key: any)
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/AccessCluster.tsx:741
Functioncallback
(key: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/index.tsx:59
Methodcancel
(Long jobId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:310
FunctioncancelSync
(item: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Replicator.tsx:114
Functioncf
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
MethodchangReassignmentThrottles
(ExecuteReassignParam executeReassignParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:165
FunctioncheckActivityFunctions
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
MethodcheckAliveConnections
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:197
MethodcheckAndGetResult
(ClusterParam clusterParam, BaseClusterHealthConfig clusterHealthConfig)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/AbstractHealthCheckService.java:33
MethodcheckApproximateDataSize
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:233
FunctioncheckBoxChange
(e: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Messages.tsx:83
MethodcheckBrainSplit
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:93
MethodcheckBrokerNetworkProcessorAvgIdleTooLow
Broker网络处理线程平均值过低
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/broker/HealthCheckBrokerService.java:68
MethodcheckBrokerRequestQueueFull
Broker请求队列满
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/broker/HealthCheckBrokerService.java:106
FunctioncheckChange
(val: any)
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:64
MethodcheckClusterNoController
检查NoController
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java:55
MethodcheckExistKafkaUserFromDB
(Long clusterPhyId, String kafkaUser)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:60
MethodcheckFailedTaskCount
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:84
MethodcheckFailedTaskCount
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:117
MethodcheckFieldLegal
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/acl/ACLDelByResParam.java:24
MethodcheckIp
判断是否为合法IP @return the ip
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:197
MethodcheckJmxClient
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/JmxClientLegalFlusher.java:27
MethodcheckKafkaLegal
(String bootstrapServers, Properties clientProps, String zookeeper)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterValidateServiceImpl.java:47
MethodcheckOutstandingRequests
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:114
MethodcheckReBalanceTooFrequently
检查Group re-balance太频繁
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/group/HealthCheckGroupService.java:62
FunctioncheckRep
(_: any, value: any[])
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:253
FunctioncheckRep
(_: any, value: any[])
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:217
MethodcheckReplicationLatencyMsMax
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:141
MethodcheckSentRate
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:269
MethodcheckStartupFailurePercentage
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectClusterService.java:74
FunctioncheckTopic
(_: any, value: any[])
km-console/packages/layout-clusters-fe/src/components/TopicJob/TopicMirror.tsx:89
MethodcheckTopicNoLeader
检查NoLeader
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/topic/HealthCheckTopicService.java:105
MethodcheckTopicUnderReplicatedPartition
检查Topic长期未同步
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/topic/HealthCheckTopicService.java:73
MethodcheckTotalRecordErrors
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:170
MethodcheckTrickJumpLogin
(HttpServletRequest request)
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/trick/impl/TrickJumpLoginServiceImpl.java:35
MethodcheckUnassignedTaskCount
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:96
MethodcheckUnassignedTaskCount
(Tuple<ClusterParam, BaseClusterHealthConfig> paramTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:129
MethodcheckWatchCount
(Tuple<ClusterParam, BaseClusterHealthConfig> singleConfigSimpleTuple)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:161
FunctioncheckedBoxChange
(e: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Configuration.tsx:84
FunctioncheckedBoxChange
(e: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/Configuration.tsx:78
FunctionchildrenRowChange
(curCategory: string, keys: string[])
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:204
Functioncj
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:42
Methodcleanup
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/BaseTestContainer.java:6
Methodcleanup
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/MySQLTestContainer.java:62
Methodcleanup
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/kafka/KafkaTestContainer.java:20
FunctionclearForm
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:289
FunctionclearForm
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:179
FunctionclusterChange
(val: number[])
km-console/packages/layout-clusters-fe/src/components/TopicJob/TopicMirror.tsx:131
Functioncm
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functioncn
(e,t,n,s,i)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Functionco
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:76
MethodcollectClusterMetricsFromKafka
(Long clusterId, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:204
MethodcollectConnectClusterMetricsFromKafka
(Long connectClusterPhyId, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterMetricService.java:19
MethodcollectConnectClusterMetricsFromKafkaWithCacheFirst
从Kafka获取指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorMetricService.java:20
MethodcollectConnectClusterMetricsFromKafkaWithCacheFirst
(Long connectClusterPhyId, String connectorName, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:112
MethodcollectConnectClusterMetricsFromKafkaWithCacheFirst
从Kafka获取指标
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterMetricService.java:18
MethodcollectConnectClusterMetricsFromKafkaWithCacheFirst
(Long connectClusterPhyId, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterMetricServiceImpl.java:84
MethodcollectConnectMetrics
(ConnectCluster connectCluster)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/ConnectConnectorMetricCollector.java:41
MethodcollectConnectMetrics
(ConnectCluster connectCluster)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/ConnectClusterMetricCollector.java:36
MethodcollectGroupMetricsFromKafka
(Long clusterId, String groupName, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupMetricServiceImpl.java:79
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/BrokerMetricCollector.java:41
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/ClusterMetricCollector.java:36
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/PartitionMetricCollector.java:40
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/ZookeeperMetricCollector.java:51
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/GroupMetricCollector.java:42
MethodcollectKafkaMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/TopicMetricCollector.java:46
MethodcollectMetrics
(ClusterPhy clusterPhy)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/AbstractKafkaMetricCollector.java:32
MethodcollectMetrics
(ConnectCluster connectCluster)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/AbstractConnectMetricCollector.java:32
MethodcollectMirrorMakerMetricsFromKafka
(Long connectClusterPhyId, String mirrorMakerName, List<MirrorMakerTopic> mirrorMakerTopicList, String metricN
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerMetricServiceImpl.java:99
← previousnext →5,101–5,200 of 6,956, ranked by callers