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

MethodgetTodayBegin

()

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

MethodgetTopBrokerIdsTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:86

MethodgetTopic

(Long clusterPhyId, String topicName)

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

MethodgetTopicAclBindings

(@PathVariable Long clusterPhyId, @PathVariable

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:99

MethodgetTopicAclFromDB

(Long clusterPhyId, String topicName)

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

MethodgetTopicAvgMetricFromJmx

(VersionItemParam param)

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

MethodgetTopicBrokerAll

(Long clusterPhyId, String topicName, String searchBrokerHost)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:96

MethodgetTopicBrokers

(@PathVariable Long clusterPhyId, @PathVariable String top

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:64

MethodgetTopicBrokersPartitionsSummary

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:73

MethodgetTopicBrokersPartitionsSummary

(Long clusterPhyId, String topicName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:276

MethodgetTopicConfigByKafkaClient

(VersionItemParam itemParam)

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

MethodgetTopicConfigByZKClient

private method

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

MethodgetTopicConfigFromKafka

(Long clusterPhyId, String topicName)

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

MethodgetTopicFromCacheFirst

(Long clusterPhyId, String topicName)

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

FunctiongetTopicGroupPartitionsHistory

(hashData: HashData)

km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroupDetail.tsx:214

MethodgetTopicGroupsBasic

(@PathVariable Long clusterPhyId, @PathVariable String topicName)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:136

MethodgetTopicGroupsOverview

(@PathVariable Long clusterPhyId, @Pa

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:143

MethodgetTopicLatestMetricByBrokerIdTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/TopicMetricESDAOTest.java:72

MethodgetTopicLatestMetricTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/TopicMetricESDAOTest.java:82

MethodgetTopicLatestMetrics

(@PathVariable Long clusterPhyId, @PathVariable String to

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:127

MethodgetTopicLatestMetricsFromES

(Long clusterPhyId, Integer brokerId, String topicName, List<String> metricNames)

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

MethodgetTopicMessages

(@PathVariable Long clusterPhyId, @PathVariable String

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:90

MethodgetTopicMessages

(Long clusterPhyId, String topicName, TopicRecordDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:139

MethodgetTopicMetricPoints

(@PathVariable Long clusterPhyId, @PathVariable St

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:118

MethodgetTopicMirrorFetchLag

(VersionItemParam param)

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

MethodgetTopicPartitionMapFromKafka

(Long clusterPhyId, String topicName)

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

MethodgetTopicPartitionMetricListAvg

(VersionItemParam metricParam)

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

MethodgetTopicPartitionMetricListMax

(VersionItemParam metricParam)

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

MethodgetTopicPartitionMetricListMin

(VersionItemParam metricParam)

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

MethodgetTopicPartitionMetricListSum

(VersionItemParam metricParam)

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

MethodgetTopicPartitions

(@PathVariable Long clusterPhyId, @PathVariable S

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:81

MethodgetTopicPartitions

(Long clusterPhyId, String topicName, List<String> metricsNames)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:234

MethodgetTopicSize

获取集群的Topic个数

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

MethodgetTopicSizeFromCacheFirst

(Long clusterPhyId)

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

MethodgetTopicState

(@PathVariable Long clusterPhyId, @PathVariable String topicName)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicStateController.java:57

MethodgetTopicState

(Long clusterPhyId, String topicName)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:184

MethodgetTopicsAggsMetricsValueTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/TopicMetricESDAOTest.java:40

MethodgetTopicsMetadata

(@PathVariable Long clusterPhyId, @PathVariable String to

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicController.java:81

MethodgetTopicsMetadataCombineExist

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicController.java:71

MethodgetTopicsMirrorInfo

(Long clusterPhyId, String topicName)

km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/impl/MirrorTopicServiceImpl.java:102

MethodgetTopicsMirrorInfo

(@PathVariable Long clusterPhyId, @PathVariable

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorTopicController.java:44

MethodgetTotalCount

()

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

MethodgetTotalLogSize

获取集群的 totalLogSize @param metricParam @return

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

MethodgetValue

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:30

MethodgetValue

()

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

MethodgetValue

()

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

MethodgetVersion

()

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/znode/brokers/BrokerMetadata.java:123

MethodgetVersionControlItem

(String version, Integer type, String itemName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/impl/VersionControlServiceImpl.java:126

MethodgetVersionFromCacheFirst

(Long clusterPhyId)

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/plugin/impl/PluginServiceImpl.java:41

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterMetricServiceImpl.java:67

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

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

MethodgetVersionItemType

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicConfigManagerImpl.java:44

MethodgetWeekInfo

(Date time)

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

MethodgetWorkerConnectorListFromCluster

(ConnectCluster connectCluster, String connectorName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/impl/WorkerConnectorServiceImpl.java:118

MethodgetWriteIndexNameByEnv

根据环境信息获取写入索引名称 @param indexName @return

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

MethodgetYearInfo

(Date time)

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

MethodgetYesterday

(Date time)

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

MethodgetZKAvailable

(VersionItemParam metricParam)

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

MethodgetZKCount

(VersionItemParam metricParam)

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

MethodgetZKData

(@RequestParam("clusterPhyId") Long clusterPhyId, @RequestParam String cmd

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/util/UtilsController.java:54

MethodgetZnode

(Long clusterPhyId, String path)

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

MethodgetZnodeVO

(Long clusterPhyId, String path)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterZookeepersManagerImpl.java:127

Functiongh

(t,e)

km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45

Functiongi

(e)

km-console/packages/layout-clusters-fe/static/js/antd.min.js:23

Functiongl

(t,e)

km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45

Functiongo

(n,t)

km-console/packages/layout-clusters-fe/static/js/lodash.min.js:77

Functiongr

(n,t)

km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28

Functiongy

()

km-console/packages/layout-clusters-fe/static/js/antd.min.js:23

Functionh

()

km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1

FunctionhI

(t)

km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45

Functionha

(n,t,r)

km-console/packages/layout-clusters-fe/static/js/lodash.min.js:101

Functionha

(a,b,c)

km-console/packages/layout-clusters-fe/static/js/react.production.min.js:10

MethodhandleCreation

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:49

MethodhandleDataChange

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:59

FunctionhandleDelOk

()

km-console/packages/layout-clusters-fe/src/pages/TopicList/Delete.tsx:16

FunctionhandleDelOk

()

km-console/packages/layout-clusters-fe/src/pages/Connect/Delete.tsx:13

FunctionhandleDelOk

()

km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/Delete.tsx:13

FunctionhandleDelOk

()

km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Delete.tsx:15

MethodhandleDeletion

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:54

FunctionhandleDocumentClick

(e: Event)

km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/CustomCheckGroup.tsx:23

MethodhandleException

(Exception e)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/handler/CustomGlobalExceptionHandler.java:41

MethodhandleFailure

(Throwable e)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1180

← previous next →5,801–5,900 of 6,956, ranked by callers