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

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

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

MethodlistAllBrokerByTopic

(Long clusterPhyId, String topicName)

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

MethodlistAllClusters

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:21

MethodlistAllClusters

()

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

MethodlistAllClustersTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyServiceTest.java:49

MethodlistAllConnectVersions

()

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:46

MethodlistAllKafkaVersions

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:203

MethodlistAllTasks

()

km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java:27

MethodlistAllTasks

()

km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/AbstractConnectClusterDispatchTask.java:24

MethodlistAllTopicHa

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/impl/HaActiveStandbyRelationServiceImpl.java:73

MethodlistAllVersionItem

()

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:58

MethodlistAllVersionItem

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:175

MethodlistAllVersions

()

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:34

MethodlistBrokerMetricesByBrokerIdsTest

()

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

MethodlistBrokerMetricsByTopTest

()

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

MethodlistBrokerMetricsByTopicsTest

()

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

MethodlistBrokerMetricsFromES

(Long clusterId, MetricsBrokerDTO dto)

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

MethodlistBrokersFromKafka

(ClusterPhy clusterPhy)

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

MethodlistByClusterAndType

(Long firstClusterId, HaResTypeEnum haResTypeEnum)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/impl/HaActiveStandbyRelationServiceImpl.java:62

MethodlistByGroup

(String groupName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/PlatformClusterConfigService.java:20

MethodlistByGroup

(String groupName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/impl/PlatformClusterConfigServiceImpl.java:73

MethodlistByKafkaClusterIdFromDB

(Long kafkaClusterPhyId)

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

MethodlistByKafkaClusterIdFromDB

(Long kafkaClusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/WorkerConnectorService.java:18

MethodlistByKafkaClusterIdFromDB

(Long kafkaClusterPhyId)

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

MethodlistByKafkaClusterIdFromDB

(Long kafkaClusterPhyId)

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

MethodlistCheckResultFromCache

(Long clusterPhyId, HealthCheckDimensionEnum dimensionEnum)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checkresult/HealthCheckResultService.java:21

MethodlistClusterGroups

(Long clusterPhyId)

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

MethodlistClusterMetricsByClusterIdsTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/ClusterMetricESDAOTest.java:23

MethodlistClusterMetricsFromES

(MetricsClusterPhyDTO dto)

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

MethodlistClusterPhyGroupPartitions

(Long clusterPhyId, String groupName, Long startTime, Long endTime)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:244

MethodlistClusterVersionControlItem

(@PathVariable Long clusterId, @PathVariable Integer type)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:65

MethodlistClusters

()

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

MethodlistConnectClusterMetricsFromES

(Long clusterPhyId, MetricsConnectorsDTO dto)

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

MethodlistConnectClusterMetricsFromES

从ES中获取一段时间内聚合计算之后的指标线

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterMetricService.java:24

MethodlistConnectClusterMetricsFromES

(Long clusterPhyId, MetricsConnectClustersDTO dto)

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

MethodlistFromDB

(Long connectClusterId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/WorkerConnectorService.java:16

MethodlistFromDB

(Long connectClusterId)

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

MethodlistFromDB

(Long connectClusterId)

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

MethodlistGroupByCluster

(Long clusterPhyId)

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

MethodlistGroupByTopic

(Long clusterPhyId, String topicName)

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

MethodlistGroupMetricsFromES

(Long clusterId, MetricGroupPartitionDTO dto)

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

MethodlistGroupMetricsTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/GroupMetricESDAOTest.java:74

MethodlistGroupTopicPartitionsTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/GroupMetricESDAOTest.java:42

MethodlistGroupsFromKafka

(ClusterPhy clusterPhy)

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

MethodlistKmHosts

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:39

MethodlistLatestMetricsAggByGroupTopicFromES

(Long clusterPhyId, List<GroupTopic> groupTopicList,

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

MethodlistLatestMetricsAggByGroupTopicTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/GroupMetricESDAOTest.java:28

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectMetricService.java:25

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricPOFields

()

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

MethodlistMetricsFromES

(Long clusterPhyId, MetricDTO dto)

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

MethodlistMirrorMakerClusterMetricsFromES

(Long clusterPhyId, MetricsMirrorMakersDTO dto)

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

MethodlistNotAliveBrokersFromDB

(Long clusterPhyId)

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

MethodlistPartitionLatestMetricsByTopicTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/PartitionMetricESDAOTest.java:19

MethodlistPartitionLatestMetricsFromES

获取该 Group&Topic 的最近指标 @param clusterPhyId @param groupName @param topicName @param metricNames @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupMetricService.java:39

MethodlistPartitionLatestMetricsFromES

(Long clusterPhyId, String groupName, String topicName,

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

MethodlistPartitionLatestMetricsTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/GroupMetricESDAOTest.java:52

MethodlistPartitionPOByCluster

(Long clusterPhyId)

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

MethodlistPartitionsFromKafka

(ClusterPhy clusterPhy)

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

MethodlistPluginsFromCluster

(Long connectClusterId)

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

MethodlistRecentUpdateTopicNamesFromDB

(Long clusterPhyId, Integer time)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:27

MethodlistRecentUpdateTopicNamesFromDB

(Long clusterPhyId, Integer time)

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

MethodlistTopicLatestMetricTest

()

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

MethodlistTopicLatestMetricsFromES

(Long clusterPhyId, List<String> topicNames, List<String> metricNames)

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

MethodlistTopicMaxMinMetrics

(Long clusterPhyId, List<String> topics, String metric, boolean max, Long startTime, Long endTime)

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:40

MethodlistTopicMaxMinMetricsTest

()

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

MethodlistTopicMetricsFromES

(Long clusterId, MetricsTopicDTO dto)

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

MethodlistTopicMetricsFromESTest

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/km/core/TopicMetricServiceTest.java:26

MethodlistTopicWithLatestMetricsTest

()

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

MethodlistTopicsFromKafka

(ClusterPhy clusterPhy)

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

MethodlistUserMetricItem

(@PathVariable Long clusterId, @PathVariable Integer type, HttpServletRequest request)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:72

MethodlistUserMetricItem

(Long clusterId, Integer type, String operator)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:228

MethodlistZnodeChildren

(Long clusterPhyId, String path, String keyword)

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

Functionln

(e,t)

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

Functionlo

(n,t)

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

FunctionloadMoreData

()

km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/List.tsx:198

Functionlocation

()

km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1

MethodlogiSecuritySqlSessionFactory

( @Qualifier("logiSecurityDataSource") DataSource dataSource)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/LogiSecurityDataSourceConfig.java:21

MethodlogiSecuritySqlSessionTemplate

( @Qualifier("logiSecuritySqlSessionFactory") SqlSessionFactory sqlSessionFactory)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/LogiSecurityDataSourceConfig.java:30

Functionlogout

()

km-console/packages/layout-clusters-fe/src/app.tsx:67

Functionlr

(n,t)

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

Functionlu

(n,t)

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

Functionlu

()

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

Functionm

()

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

FunctionmL

()

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

Functionma

(n)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/KnowStreaming.java:27

Methodmain

(String[] args)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/AESUtils.java:57

Methodmain

(String[] args)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/VersionUtil.java:113

Methodmain

(String []args)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KafkaReplicaAssignUtil.java:77

← previous next →6,101–6,200 of 6,956, ranked by callers