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 callersMethodgetBrokerLogDirs
(Long clusterPhyId, Integer brokerId, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/BrokerManager.java:12
↓ 1 callersMethodgetBrokerMetricPoints
(@PathVariable Long clusterPhyId, @PathVariable I
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerMetricController.java:40
↓ 1 callersMethodgetBrokerReplicaSummaries
(Integer brokerId, List<Partition> partitionList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:367
↓ 1 callersFunctiongetBrokerState
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:34
↓ 1 callersMethodgetBrokerVersionFromKafka
(Long clusterId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:235
↓ 1 callersMethodgetBrokerVersionFromKafkaWithCacheFirst
优先从本地缓存中获取Broker的版本信息 @param @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerService.java:64
↓ 1 callersMethodgetBrokerVersionList
(Long clusterPhyId, List<Broker> brokerList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:249
↓ 1 callersMethodgetBrokersFromAdminClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:339
↓ 1 callersMethodgetBrokersFromZKClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:322
↓ 1 callersMethodgetByClassNamePer
(String classNamePre, Class<T> clazz)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/BaseExtendFactory.java:22
↓ 1 callersMethodgetByHandlerNamePer
根据类名前缀获取接口BaseHandle的实现类实例 注意： handleNamePre 需要保证全局唯一
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/HandleFactory.java:21
↓ 1 callersMethodgetById
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:96
↓ 1 callersMethodgetByName
(String configName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/health/HealthCheckNameEnum.java:242
↓ 1 callersMethodgetByStatsType
(String statsType)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:100
↓ 1 callersMethodgetByValue
(String value)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/connect/ConnectStatusEnum.java:33
↓ 1 callersFunctiongetCardInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectCard.tsx:52
↓ 1 callersFunctiongetCardInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectDetailCard.tsx:42
↓ 1 callersFunctiongetCardInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ZookeeperCard.tsx:50
↓ 1 callersFunctiongetCardInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerCard.tsx:52
↓ 1 callersFunctiongetCartInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/LoadRebalanceCardBar.tsx:38
↓ 1 callersFunctiongetCartInfo
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ACLsCardBar.tsx:15
↓ 1 callersFunctiongetChangeLog
(pageSize = 10)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/ChangeLog.tsx:34
↓ 1 callersFunctiongetChartConfig
(title: string, metricLength: number, showLegend = true)
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/config.tsx:54
↓ 1 callersMethodgetClassRequestMappingValue
通过反射获取带有@RequestMapping的Controller @param handler 请求处理器 @return @RequestMapping的value
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/interceptor/PermissionInterceptor.java:84
↓ 1 callersMethodgetClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:38
↓ 1 callersMethodgetClient
(Long clusterPhyId, Integer brokerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java:46
↓ 1 callersMethodgetClient
(Long connectorClusterId, String workerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:46
↓ 1 callersMethodgetClusterByCluster
(Long clusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:63
↓ 1 callersMethodgetClusterByClusterName
(String clusterPhyName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyService.java:26
↓ 1 callersMethodgetClusterConnectorsOverview
(Long clusterPhyId, ClusterConnectorsOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterConnectorsManager.java:12
↓ 1 callersMethodgetClusterConnectorsState
(Long clusterPhyId)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterConnectorsManager.java:14
↓ 1 callersMethodgetClusterLatestMetrics
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:81
↓ 1 callersFunctiongetClusterList
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/TopicMirror.tsx:76
↓ 1 callersMethodgetClusterMirrorMakersOverview
(Long clusterPhyId, ClusterMirrorMakersOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:34
↓ 1 callersMethodgetClusterName
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:29
↓ 1 callersMethodgetClusterPhyBrokersOverview
获取缓存查询结果 & broker 表查询结果并集 @param clusterPhyId kafka 物理集群 id @param dto 封装分页查询参数对象 @return 返回获取到的缓存查询结果 & broker 表查询结果并集
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterBrokersManager.java:18
↓ 1 callersMethodgetClusterPhyBrokersState
根据物理集群id获取集群对应broker状态信息 @param clusterPhyId 物理集群 id @return 返回根据物理集群id获取到的集群对应broker状态信息
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterBrokersManager.java:25
↓ 1 callersMethodgetClusterPhyTopicsOverview
(Long clusterPhyId, ClusterTopicsOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterTopicsManager.java:11
↓ 1 callersMethodgetClusterPhyZookeepersOverview
(Long clusterPhyId, ClusterZookeepersOverviewDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterZookeepersManager.java:16
↓ 1 callersMethodgetClusterPhyZookeepersState
(Long clusterPhyId)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterZookeepersManager.java:14
↓ 1 callersMethodgetClusterPhysBasic
()
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/MultiClusterPhyManager.java:32
↓ 1 callersMethodgetClusterPhysDashboard
查询多集群大盘 @param dto 分页信息 @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/MultiClusterPhyManager.java:30
↓ 1 callersMethodgetClusterPhysHealthState
()
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/MultiClusterPhyManager.java:23
↓ 1 callersMethodgetClusterPhysState
获取所有集群的状态 @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/MultiClusterPhyManager.java:21
↓ 1 callersMethodgetClusterVersionList
获取系统已存在的kafka版本列表 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyService.java:75
↓ 1 callersMethodgetCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigGroupEnum.java:33
↓ 1 callersMethodgetCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigDiffTypeEnum.java:26
↓ 1 callersMethodgetCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigStatusEnum.java:25
↓ 1 callersFunctiongetColmns
(arg: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroups.tsx:8
↓ 1 callersFunctiongetColmns
(arg: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Replicator.tsx:11
↓ 1 callersMethodgetConfigNamesAndDocs
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:149
↓ 1 callersFunctiongetConfigurationColmns
(arg: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/config.tsx:4
↓ 1 callersFunctiongetConnectClusters
()
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:154
↓ 1 callersFunctiongetConnectClusters
()
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnectorUseJSON.tsx:31
↓ 1 callersFunctiongetConnectClustersList
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:158
↓ 1 callersMethodgetConnectWorkerFromDB
(Long connectorClusterId, String workerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:113
↓ 1 callersMethodgetConnectWorkerMetricByJMX
(Long connectClusterId, String workerId, String metric)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterMetricServiceImpl.java:198
↓ 1 callersMethodgetConnectorFromDB
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:135
↓ 1 callersMethodgetConnectorInfoFromCluster
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:70
↓ 1 callersMethodgetConnectorMetric
(Long connectClusterId, String workerId, String connectorName, String metric, ConnectorTypeEnum connectorType)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:265
↓ 1 callersFunctiongetConnectorPluginConfig
(pluginName: string)
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:176
↓ 1 callersFunctiongetConnectorPlugins
()
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:167
↓ 1 callersMethodgetConnectorStateInfoFromCluster
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorService.java:28
↓ 1 callersMethodgetConnectorStateInfoFromCluster
(Long connectClusterId, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:80
↓ 1 callersMethodgetConnectorStateInfoFromCluster
(ConnectCluster connectCluster, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:306
↓ 1 callersMethodgetConnectorStateVO
(Long connectClusterId, String connectorName)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/ConnectorManager.java:15
↓ 1 callersMethodgetConnectorTaskMetric
(Long connectClusterId, String workerId, String connectorName, Integer taskId, String metric, ConnectorTypeEnu
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:373
↓ 1 callersMethodgetConnectorTopicsFromCluster
(ConnectCluster connectCluster, String connectorName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:273
↓ 1 callersFunctiongetConnectorsColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/config.tsx:96
↓ 1 callersFunctiongetConnectorsDetailColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/config.tsx:317
↓ 1 callersFunctiongetConsumersMetadata
(hashData: HashData)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroupDetail.tsx:239
↓ 1 callersFunctiongetConsumersMetadata
(hashData: HashData)
km-console/packages/layout-clusters-fe/src/pages/Consumers/ConsumerGroupDetail.tsx:214
↓ 1 callersFunctiongetConsumersMetadata
(hashData: HashData)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/ExpandedRow.tsx:202
↓ 1 callersMethodgetContextByFileName
(String fileName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/template/TemplateLoaderUtil.java:25
↓ 1 callersFunctiongetControllerChangeLogListColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerControllerChangeLog/config.tsx:6
↓ 1 callersMethodgetControllerFromAdminClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:131
↓ 1 callersMethodgetControllerFromKafka
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/KafkaControllerService.java:13
↓ 1 callersMethodgetControllerFromZKClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:184
↓ 1 callersFunctiongetControlsStatus
()
km-console/packages/layout-clusters-fe/src/pages/CommonRoute.tsx:67
↓ 1 callersMethodgetCredentialString
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafkauser/KafkaUser.java:41
↓ 1 callersMethodgetDataAndIgnoreCheckBSLegal
(String bootstrapServers, Properties clientProps)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterValidateServiceImpl.java:107
↓ 1 callersFunctiongetDataLogsColmns
()
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/config.tsx:75
↓ 1 callersMethodgetDatabaseDelegate
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:192
↓ 1 callersMethodgetDateTimeStr
(long time)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:221
↓ 1 callersFunctiongetDefaultMetricData
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/DetailChart/index.tsx:126
↓ 1 callersMethodgetDelay
(TimeUnit unit)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/common/FutureTaskDelayQueueData.java:26
↓ 1 callersFunctiongetDetail
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/BrokersDetail.tsx:105
↓ 1 callersFunctiongetDetailChartConfig
(title: string, sliderPos: readonly [number, number])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/config.tsx:66
↓ 1 callersFunctiongetDetailColumn
(clusterId: number)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/config.tsx:174
↓ 1 callersMethodgetDimensionCodeIfSupport
(Long kafkaClusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/AbstractHealthCheckService.java:31
↓ 1 callersMethodgetDimensionHealthResult
(Long clusterPhyId, List<Integer> dimensionCodeList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:288
↓ 1 callersMethodgetDslByFileName
获取查询语句
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dsls/DslLoaderUtil.java:44
↓ 1 callersMethodgetExistPartitionNum
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/topic/TopicPartitionExpandParam.java:50
↓ 1 callersMethodgetFirstTaskByReplace
(Map<Integer,Integer> bParallelNum, Integer parallelNum,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:103
↓ 1 callersFunctiongetFormConfig
(topicMetaData: any, info = {} as any, partitionLists: any, consumerGroupList: any)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/config.tsx:165
↓ 1 callersFunctiongetFormConfig
(params: any)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/config.tsx:100
↓ 1 callersMethodgetFormatMonthByOffset
(int offset)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:303
↓ 1 callersMethodgetFromZookeeperCluster
(Long clusterPhyId, String host, Integer port, ZKConfig zkConfig)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperServiceImpl.java:149
↓ 1 callersFunctiongetGroupBasicData
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:732
↓ 1 callersFunctiongetGroupColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/config.tsx:24
← previousnext →3,501–3,600 of 6,956, ranked by callers