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

MethodgetClusterConnectClustersBasic

(@PathVariable Long clusterPhyId)

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

MethodgetClusterConnectorsBasic

connector method

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterConnectsController.java:98

MethodgetClusterConnectorsOverview

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterConnectsController.java:110

MethodgetClusterConnectorsOverview

(Long clusterPhyId, ClusterConnectorsOverviewDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterConnectorsManagerImpl.java:58

MethodgetClusterConnectorsState

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterConnectsController.java:88

MethodgetClusterConnectorsState

(Long clusterPhyId)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterConnectorsManagerImpl.java:106

MethodgetClusterHealthCheckResultDetail

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/health/KafkaHealthController.java:37

MethodgetClusterHealthConfig

(Long clusterPhyId)

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

MethodgetClusterHealthMetrics

(VersionItemParam metricParam)

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

MethodgetClusterLatestMetricsTest

测试获取集群 clusterId 最新的统计指标

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

MethodgetClusterMM2State

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterMirrorMakersController.java:48

MethodgetClusterMetricPoints

(@PathVariable Long clusterPhyId, @RequestBody MetricDTO dto)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterMetricsController.java:51

MethodgetClusterMetricsPointTest

测试获取集群 clusterPhyId 中每个 metric 在指定时间[startTime、endTime]区间内聚合计算(avg、max)之后的统计值

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

MethodgetClusterMirrorMakersBasic

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterMirrorMakersController.java:55

MethodgetClusterMirrorMakersMetrics

(@PathVariable Long clusterPhyId, @V

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterMirrorMakersController.java:75

MethodgetClusterMirrorMakersOverview

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterMirrorMakersController.java:67

MethodgetClusterMirrorMakersOverview

(Long clusterPhyId, ClusterMirrorMakersOverviewDTO dto)

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

MethodgetClusterName

(Long connectClusterId)

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

MethodgetClusterPhyBasic

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterPhyController.java:60

MethodgetClusterPhyBasic

()

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

MethodgetClusterPhyBasicCombineExist

(@PathVariable String clusterPhyName)

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

MethodgetClusterPhyBrokersMetadata

(@PathVariable Long clusterPhyId, @Requ

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterBrokersController.java:40

MethodgetClusterPhyBrokersOverview

(@PathVariable Long clusterPhyId,

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

MethodgetClusterPhyBrokersOverview

(Long clusterPhyId, ClusterBrokersOverviewDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:63

MethodgetClusterPhyBrokersState

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterBrokersController.java:51

MethodgetClusterPhyBrokersState

(Long clusterPhyId)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterBrokersManagerImpl.java:110

MethodgetClusterPhyChangeRecords

(@PathVariable Long clusterPhyId, PaginationBaseDTO dto)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/changerecord/KafkaChangeRecordController.java:28

MethodgetClusterPhyDashboard

(@RequestBody @Validated MultiClusterDashboardDTO dto)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/MultiClusterPhyController.java:38

MethodgetClusterPhyGroupMetrics

(@PathVariable Long clusterPhyId, @RequestBody MetricGroupPartitionDTO param)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterGroupsController.java:59

MethodgetClusterPhyGroupPartitions

(@PathVariable Long clusterPhyId, @PathV

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterGroupsController.java:66

MethodgetClusterPhyMetrics

(@PathVariable Long clusterPhyId, @Validated

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

MethodgetClusterPhyMetrics

(@RequestBody MetricsClusterPhyDTO param)

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

MethodgetClusterPhyMetrics

(@PathVariable Long clusterPhyId, @Validated @RequestBody MetricsTopicDTO param)

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

MethodgetClusterPhyMetricsMultiValues

( @RequestBody MetricsClusterPhyDTO param)

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

MethodgetClusterPhyTopicsMetadata

(@PathVariable Long clusterPhyId, @RequestParam(required = false) String searchKeyword)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterTopicsController.java:44

MethodgetClusterPhyTopicsOverview

(@PathVariable Long clusterPhyId,

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

MethodgetClusterPhyTopicsOverview

(Long clusterPhyId, ClusterTopicsOverviewDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/ClusterTopicsManagerImpl.java:46

MethodgetClusterPhyZookeepersOverview

(Long clusterPhyId, ClusterZookeepersOverviewDTO dto)

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

MethodgetClusterPhyZookeepersState

(Long clusterPhyId)

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

MethodgetClusterPhysBasic

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java:121

MethodgetClusterPhysDashboard

(MultiClusterDashboardDTO dto)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java:89

MethodgetClusterPhysHealthState

()

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/MultiClusterPhyController.java:59

MethodgetClusterPhysHealthState

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java:63

MethodgetClusterPhysState

()

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

MethodgetClusterPhysState

()

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java:43

MethodgetClusterPhysVersion

()

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/MultiClusterPhyController.java:66

MethodgetClusterResHealthCheckResult

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/health/KafkaHealthController.java:76

MethodgetClusterTopicKey

(Long clusterPhyId, String topicName)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:49

MethodgetClusterVersion

(C c)

km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/AbstractMetricCollector.java:16

MethodgetClusterVersion

(ClusterPhy clusterPhy)

km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/AbstractKafkaMetricCollector.java:27

MethodgetClusterVersion

(ConnectCluster connectCluster)

km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/AbstractConnectMetricCollector.java:27

MethodgetClusterVersion

(Long connectClusterId)

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

MethodgetClusterVersionList

()

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

MethodgetClusterWorkersOverview

connector method

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

MethodgetClusterZookeeperChild

(@PathVariable Long clusterPhyId, @RequestParam Strin

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterZookeepersController.java:55

MethodgetClusterZookeeperData

(@PathVariable Long clusterPhyId, @RequestParam String path

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterZookeepersController.java:48

MethodgetClusterZookeepersOverview

(@PathVariable Long clusterPhyId,

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterZookeepersController.java:41

MethodgetClusterZookeepersState

(@PathVariable Long clusterPhyId)

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterZookeepersController.java:35

MethodgetCmd

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ConfigCmdDataParser.java:35

MethodgetCmd

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java:29

MethodgetCmd

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java:34

MethodgetCode

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/RecordResultEnum.java:26

MethodgetCode

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/version/VersionItemTypeEnum.java:65

MethodgetConfig

(Long connectClusterId, String pluginName)

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

MethodgetConfigBroker

(@PathVariable Long clusterPhyId, @PathVariab

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

MethodgetConfigTopic

(@PathVariable Long clusterPhyId, @PathVariable

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

MethodgetConnectClusterMetrics

(@PathVariable Long clusterPhyId, @Valida

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterConnectsController.java:80

MethodgetConnectCountFromKafkaByJMX

(VersionItemParam metricParam)

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

MethodgetConnectWorkerMetricAvg

(VersionItemParam metricParam)

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

MethodgetConnectWorkerMetricSum

(VersionItemParam metricParam)

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

MethodgetConnectWorkerMetricSum

(VersionItemParam metricParam)

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

MethodgetConnectorBasicCombineExist

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetConnectorConfig

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetConnectorFromKafka

(Long connectClusterId, String connectorName)

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

MethodgetConnectorHealthCheckResult

(Long clusterPhyId)

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

MethodgetConnectorLatestMetrics

(@PathVariable Long connectClusterId, @PathVaria

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

MethodgetConnectorStateVO

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetConnectorStateVO

(Long connectClusterId, String connectorName)

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

MethodgetConnectorTaskMetricsAvg

(VersionItemParam metricParam)

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

MethodgetConnectorTaskMetricsMax

(VersionItemParam metricParam)

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

MethodgetConnectorTaskMetricsSum

(VersionItemParam metricParam)

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

MethodgetConnectorTasks

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetConnectorTasks

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetConnectorType

(Long connectClusterId, String connectorName)

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

MethodgetControllerFromKafka

(ClusterPhy clusterPhy)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:42

MethodgetDataAndStat

(Long clusterPhyId, String path)

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:200

MethodgetDataFromKafka

(ConnectCluster connectCluster)

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

MethodgetDataFromKafka

(ClusterPhy clusterPhy)

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

MethodgetDataFromKafka

(ClusterPhy clusterPhy)

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

MethodgetDatabaseName

()

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

MethodgetDayInfo

(Date time)

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

MethodgetDefaultTopicConfig

(@PathVariable Long clusterPhyId)

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

MethodgetDefaultTopicConfig

(Long clusterPhyId)

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

MethodgetDefaultTopicConfigByClient

(VersionItemParam itemParam)

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

MethodgetDefaultTopicConfigByLocal

(VersionItemParam itemParam)

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

MethodgetDesc

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/RecordResultEnum.java:30

MethodgetDesc

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/OperationEnum.java:52

MethodgetDesc

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigGroupEnum.java:37

MethodgetDesc

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigDiffTypeEnum.java:30

MethodgetDesc

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigStatusEnum.java:29

← previous next →5,501–5,600 of 6,956, ranked by callers