MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

↓ 1 callersFunctionhandleSave
(row: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceEditTable.tsx:80
↓ 1 callersMethodhandleSingleESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:345
↓ 1 callersMethodhandleSingleESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/ClusterMetricESDAO.java:164
↓ 1 callersMethodhandleSingleESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java:192
↓ 1 callersMethodhandleTopBrokerESQueryResponse
(ESQueryResponse response, List<String> metricNameList, int topN)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java:254
↓ 1 callersMethodhandleTopConnectClusterESQueryResponse
(ESQueryResponse response, List<String> metricNameList, int topN)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/cluster/ConnectClusterMetricESDAO.java:199
↓ 1 callersMethodhandleTopConnectorESQueryResponse
(ESQueryResponse response,
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:247
↓ 1 callersMethodhandleUnsupportedVersionException
Handle an UnsupportedVersionException. @param exception The exception. @return True if the exception can be handled; false otherwis
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:612
↓ 1 callersMethodhandleWorkerMetadata
(Long connectClusterId, KSGroupDescription ksGroupDescription)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncConnectClusterAndWorkerTask.java:90
↓ 1 callersMethodhandleZKClientNotExist
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/AbstractZKWatcher.java:30
↓ 1 callersMethodhasActiveExternalCalls
(Collection<Call> calls)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:980
↓ 1 callersMethodhasNoInterceptor
是否需要拦截 just for test
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/interceptor/PermissionInterceptor.java:106
↓ 1 callersFunctionhd
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionhe
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:51
↓ 1 callersFunctionho
(r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionhp
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionht
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 1 callersFunctionhy
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctioniM
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionic
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:93
↓ 1 callersFunctionik
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctioninfo
(content: JointContent, duration?: ConfigDuration, onClose?: ConfigOnClose)
km-console/packages/layout-clusters-fe/src/components/Message/index.tsx:40
↓ 1 callersFunctioninit
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:155
↓ 1 callersMethodinit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/BrokersNodeChangeHandler.java:41
↓ 1 callersMethodinit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:39
↓ 1 callersMethodinit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/TopicsNodeChangeHandler.java:41
↓ 1 callersMethodinit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/AbstractZKHandler.java:24
↓ 1 callersMethodinit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ConfigNotificationNodeChangeHandler.java:42
↓ 1 callersMethodinitBrokerUsed
(Map<Integer, List<Integer>> currentPartitionMap, List<Integer> brokerIdList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:450
↓ 1 callersFunctioninitChart
()
km-console/packages/layout-clusters-fe/src/components/CardBar/StateChart.tsx:17
↓ 1 callersMethodinitKafkaConsumerPool
(ClusterPhy clusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:111
↓ 1 callersMethodinitLoginContext
@see com.didiglobal.logi.security.service.impl.LoginServiceImpl@initLoginContext 由于initLoginContext是私有方法,因此当前拷贝了一份代码出来
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/interceptor/PermissionInterceptor.java:114
↓ 1 callersMethodinitMap
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/VersionControlMetricService.java:27
↓ 1 callersMethodinitMetricFieldAndNameList
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:32
↓ 1 callersMethodinitMetricFieldAndNameList
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectMetricService.java:21
↓ 1 callersMethodinitRegisterVCHandler
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:39
↓ 1 callersMethodinitRegisterVCHandler
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectMetricService.java:27
↓ 1 callersMethodinitWithMetric
(Long connectClusterId, String mirrorMakerName, String clusterAlias, String topicName, Integer partitionId, St
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/mm2/MirrorMakerTopicPartitionMetrics.java:33
↓ 1 callersMethodinsert
(Job task)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:451
↓ 1 callersMethodinsertAndIgnoreDuplicate
(KafkaAclPO kafkaAclPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:248
↓ 1 callersMethodinsertAndIgnoreDuplicate
(KafkaAclPO kafkaAclPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:168
↓ 1 callersMethodinsertAndIgnoreDuplicateException
(KafkaController kafkaController, String controllerHost, String controllerRack)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:51
↓ 1 callersMethodinterceptorCheck
(HttpServletRequest request, HttpServletResponse response, String requestMappingValue, List<String> whiteMappi
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/ldap/LdapLoginServiceImpl.java:110
↓ 1 callersFunctionio
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionio
(n,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionisArgsProps
(content: JointContent)
km-console/packages/config-manager-fe/src/components/Message/index.tsx:14
↓ 1 callersFunctionisArgsProps
(content: JointContent)
km-console/packages/layout-clusters-fe/src/components/Message/index.tsx:14
↓ 1 callersMethodisClusterSupport
判断 item 是否被 clusterId 对应的版本支持 @param version @param item @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/VersionControlService.java:83
↓ 1 callersMethodisCreateIfNotExist
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/dto/group/GroupOffsetResetDTO.java:42
↓ 1 callersFunctionisDataView
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
↓ 1 callersMethodisExistBlank
存在空
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ValidateUtils.java:47
↓ 1 callersMethodisHaTopic
(Long clusterPhyId, String topicName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:118
↓ 1 callersMethodisInternal
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:622
↓ 1 callersMethodisKafkaClusterDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:547
↓ 1 callersMethodisMetricField
检查 str 是不是一个 fieldName @param str
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:90
↓ 1 callersMethodisMetricName
检查 str 是不是一个 metricName @param str
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:82
↓ 1 callersMethodisMetricName
(String str)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorMetricService.java:35
↓ 1 callersMethodisMetricName
(String str)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterMetricService.java:26
↓ 1 callersMethodisOpenTrickJumpLogin
是否开启trick的方式登录
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/trick/TrickJumpLoginService.java:13
↓ 1 callersMethodisPre
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/EnvUtil.java:11
↓ 1 callersMethodisSearchIndexNameMatchNoExpTemplate
查询索引是否匹配没有时间分区的索引模板表达式 @param searchIndexName @param templateExp 索引表达式不带 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:353
↓ 1 callersMethodisTokenEqual2CredentialProps
(Long clusterPhyId, Properties credentialProps, String token)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:44
↓ 1 callersMethoditemSupportDesc
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:317
↓ 1 callersFunctioniv
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionjb
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionjf
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionjh
(u)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionjj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:52
↓ 1 callersMethodjobPO2JobVO
(JobPO jobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:509
↓ 1 callersMethodjobPOS2JobVOS
(List<JobPO> jobPOS)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:503
↓ 1 callersFunctionjr
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionjudgePage404
()
km-console/packages/layout-clusters-fe/src/app.tsx:57
↓ 1 callersFunctionjv
(r,o,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionjy
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionkC
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionkR
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionka
(t,e,n,i,r,o,a,s,l)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionkd
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionke
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:179
↓ 1 callersFunctionki
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:67
↓ 1 callersFunctionkj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:52
↓ 1 callersFunctionkm
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionks
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionlb
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionld
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionlf
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodlistAliveBrokersFromCacheFirst
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:164
↓ 1 callersMethodlistAll
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checkresult/HealthCheckResultService.java:16
↓ 1 callersMethodlistAll
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/cache/LoadedConnectClusterCache.java:32
↓ 1 callersMethodlistAllBrokersFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:179
↓ 1 callersMethodlistAllClusters
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:80
↓ 1 callersMethodlistAllJobByClusterId
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:428
↓ 1 callersMethodlistAllLatest
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/kafkacontroller/KafkaControllerDAO.java:11
↓ 1 callersMethodlistAllTasks
返回所有的任务 @return
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:37
↓ 1 callersMethodlistAllTopicHa
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/HaActiveStandbyRelationService.java:24
↓ 1 callersMethodlistAllVersionItem
查询当前所有的兼容性(指标、前端操作)配置信息 @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/VersionControlManager.java:17
↓ 1 callersMethodlistBrokerMetricsFromES
从ES中获取一段时间内聚合计算之后的指标线
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerMetricService.java:27
↓ 1 callersMethodlistByConnectClusterIdFromDB
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:119
↓ 1 callersMethodlistByKafkaCluster
(Long kafkaClusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:82
↓ 1 callersMethodlistByKafkaClusterIdFromDB
(Long kafkaClusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorService.java:32
← previousnext →3,801–3,900 of 6,956, ranked by callers