Functions — github.com/didi/KnowStreaming

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070

MethodgetMethodName

(Long connectClusterId, String action)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectVersionControlService.java:41

MethodgetMetricFromHealthService

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:311

MethodgetMetricFromJmx

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/replica/impl/ReplicaMetricServiceImpl.java:165

MethodgetMetricFromJmx

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionMetricServiceImpl.java:241

MethodgetMetricFromKafkaByControllerJMX

从某一个 controller 的 JMX 中获取指标再聚合得到集群的指标 @param metricParam @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:669

MethodgetMetricFromKafkaByJMX

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:282

MethodgetMetricFromKafkaByJMX

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:282

MethodgetMetricFromKafkaByTotalBrokerJmx

从JMX中获取指标

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:447

MethodgetMetricFromKafkaByTotalBrokersJMX

从所有broker的 JMX 中获取指标再聚合得到集群的指标

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:707

MethodgetMetricFromKafkaByTotalPartitionOfBrokerJmx

从JMX中获取LogSize

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:384

MethodgetMetricFromMonitorCmd

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:223

MethodgetMetricFromServerCmd

private method

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:173

MethodgetMetricHealthScore

获取group的健康分指标 @param param @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupMetricServiceImpl.java:274

MethodgetMetricHealthScore

回去 topic 健康分指标 @param param @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:371

MethodgetMetricHealthScore

获取 broker 的健康分 @param metricParam @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:315

MethodgetMetricHealthScore

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:213

MethodgetMetricHealthScore

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerMetricServiceImpl.java:208

MethodgetMetricInSync

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/replica/impl/ReplicaMetricServiceImpl.java:119

MethodgetMetricJustForTest

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupMetricServiceImpl.java:238

MethodgetMetricMessages

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/replica/impl/ReplicaMetricServiceImpl.java:141

MethodgetMetricPointsFromES

(Long clusterId, String topicName, MetricDTO dto)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:248

MethodgetMetricPointsFromES

从ES中获取聚合计算之后的一个指标点

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerMetricService.java:32

MethodgetMetricPointsFromES

(Long clusterPhyId, Integer brokerId, MetricDTO dto)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:187

MethodgetMetricPointsFromES

(Long clusterId, MetricDTO metricDTO)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterMetricService.java:42

MethodgetMetricPointsFromES

(Long clusterId, MetricDTO dto)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:274

MethodgetMetricRunningStatus

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:222

MethodgetMetricsLine

(@PathVariable Long clusterPhyId, @RequestBody MetricDTO dto)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/zk/ZookeeperMetricsController.java:42

MethodgetMirrorMakerHealthCheckResult

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checkresult/impl/HealthCheckResultServiceImpl.java:158

MethodgetMirrorMakerLatestMetrics

(@PathVariable Long connectClusterId, @PathV

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerStateController.java:59

MethodgetMirrorMakerState

(Long connectClusterId, String connectName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:332

MethodgetMirrorMakerStateVO

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerStateController.java:38

MethodgetMirrorMakerStateVO

(Long clusterPhyId)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:279

MethodgetMirrorMakerTopicList

(ConnectorPO mirrorMaker, Map<String, MirrorMakerTopic> mirrorMakerTopicMap)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerServiceImpl.java:82

MethodgetMirrorMakerTopicMap

(Long connectClusterId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerServiceImpl.java:36

FunctiongetMountedApps

()

km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2

FunctiongetNumUnit

(value: number)

km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:91

MethodgetObjectWithJsonContent

GET请求 @param url 请求地址 @param params 请求参数 @param resultType 返回类型 @param <T> 泛型T @return T

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:83

MethodgetObjectWithParamsAndHeader

GET请求 @param url 请求地址 @param headers 请求头 @param params 请求参数 @param resultType 返回类型 @param <T> 泛型T @return T

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:124

MethodgetOffsetRelevantMetrics

private method

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionMetricServiceImpl.java:168

MethodgetOneRunningJobId

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:466

MethodgetPartitionBeginAndEndOffsetFromKafka

(Long clusterPhyId, String topicName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:225

MethodgetPartitionByTopicAndPartitionId

(Long clusterPhyId, String topicName, Integer partitionId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:176

MethodgetPartitionFromCacheFirst

(Long clusterPhyId, String topicName, Integer partitionId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:160

MethodgetPartitionNoLeaderSize

获取集群无Leader的partition个数

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:400

MethodgetPartitionOffsetFromKafka

(Long clusterPhyId, String topicName, KSOffsetSpec offsetSpec)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:203

MethodgetPartitionSize

获取集群的Partition个数

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:387

MethodgetPartitionsSkew

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:325

MethodgetPassedCount

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/health/HealthCheckAggResult.java:41

MethodgetPassword

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:153

MethodgetPlatformClusterConfig

(@PathVariable Long clusterId, @PathVariable String groupName)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/config/PlatformClusterConfigController.java:33

MethodgetPluginConfig

(@PathVariable Long connectClusterId, @PathVariable String pluginName)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectPluginController.java:45

MethodgetQueryString

根据map中的参数构建url+queryString @param url 请求地址 @param params 请求参数 @return 请求url

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:209

MethodgetReassignmentTopicsOverview

查询信息

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/reassign/CommunityReassignController.java:52

MethodgetReassignmentTopicsOverview

(ReassignTopicOverviewDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/impl/ReassignManagerImpl.java:99

MethodgetReplicaMetricPoints

(@PathVariable Long clusterPhyId, @PathVariable

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/replica/ReplicaMetricsController.java:29

MethodgetReplicaSizeFromCacheFirst

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:145

MethodgetReplicasCount

(VersionItemParam param)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:346

MethodgetReplicasCount

(VersionItemParam metricParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:490

MethodgetResList

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/group/HealthCheckGroupService.java:44

MethodgetResList

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/topic/HealthCheckTopicService.java:51

MethodgetResList

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/broker/HealthCheckBrokerService.java:45

MethodgetResList

(Long connectClusterId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:57

MethodgetResList

(Long connectClusterId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectClusterService.java:50

MethodgetResList

(Long connectClusterId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:78

MethodgetResList

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java:37

MethodgetResultStatus

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/ESRunTimeException.java:33

MethodgetResultStatus

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/AdminRunTimeException.java:25

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/BrokerMetricPO.java:30

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/GroupMetricPO.java:35

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/TopicMetricPO.java:45

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/ReplicationMetricPO.java:35

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/ZookeeperMetricPO.java:20

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/PartitionMetricPO.java:35

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/ClusterMetricPO.java:33

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/mm2/MirrorMakerMetricPO.java:35

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/connect/ConnectClusterMetricPO.java:26

MethodgetRoutingValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/connect/ConnectorMetricPO.java:35

FunctiongetSearchKeywords

(value: string)

km-console/packages/layout-clusters-fe/src/pages/GroupList/index.tsx:66

FunctiongetSearchKeywords

(value: string)

km-console/packages/layout-clusters-fe/src/pages/Jobs/index.tsx:88

FunctiongetSearchKeywords

(value: string)

km-console/packages/layout-clusters-fe/src/pages/BrokerList/index.tsx:74

FunctiongetSearchKeywords

(value: string)

km-console/packages/layout-clusters-fe/src/pages/BrokerControllerChangeLog/index.tsx:66

MethodgetServerStartTime

(Long clusterPhyId, String jmxHost, Integer jmxPort, JmxConfig jmxConfig)

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/jmx/impl/JmxDAOImpl.java:53

MethodgetSortInterval

获取时间点对应聚合时间段 @param intervalTime @param timePoint @return

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MetricsUtils.java:42

MethodgetStatus

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/connect/ConnectActionEnum.java:25

MethodgetStatus

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/connect/ConnectStatusEnum.java:43

MethodgetStr

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MetricsUtils.java:199

MethodgetStr

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/EnvUtil.java:88

MethodgetSubJobPartitionDetail

(Long clusterPhyId, Long jobId, String topic)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:196

MethodgetSubJobPartitionDetail

(Job job, String topic)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:133

MethodgetSubJobPartitionDetail

(@PathVariable Long clusterPhyId, @PathVariable Long jobId, @PathVariable String topic)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:93

FunctiongetTableData

()

km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:50

MethodgetTaskDetail

(Job job)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:123

MethodgetTaskModifyDetail

(Job job)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:66

MethodgetTaskOverview

(Long connectClusterId, String connectorName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/WorkerConnectorManager.java:14

MethodgetTaskOverview

(Long connectClusterId, String connectorName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/impl/WorkerConnectorManageImpl.java:30

MethodgetTaskOverview

(Long connectClusterId, String connectorName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:353

MethodgetTestQueryString

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:158

MethodgetThisMonthRemainDay

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:282

FunctiongetTimeUnit

(value: number)

km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:90

MethodgetTimeoutUnitSec

()

km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:147

← previous next →5,701–5,800 of 6,956, ranked by callers