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

FunctiongetDetailInfo

(record: any)

km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:95

FunctiongetDetailInfo

(record: any)

km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:97

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:84

MethodgetDimensionCodeIfSupport

(Long kafkaClusterPhyId)

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

MethodgetDoubleValuePerMin

(String interval, String value)

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

MethodgetDriverClassName

()

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

MethodgetEndpoints

()

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

MethodgetForString

GET请求 @param url 请求地址 @param headers 请求头 @return T

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

FunctiongetFormConfig

()

km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/config.ts:126

MethodgetGroupActivesCount

(VersionItemParam metricParam)

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

MethodgetGroupDeadCount

(VersionItemParam metricParam)

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

MethodgetGroupEmptyCount

(VersionItemParam metricParam)

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

MethodgetGroupFromDB

(Long clusterPhyId, String groupName)

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

MethodgetGroupFromDB

(Long clusterPhyId, String groupName)

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

MethodgetGroupFromKafka

(ClusterPhy clusterPhy, String groupName)

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

FunctiongetGroupInfo

(groupName: string)

km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroups.tsx:98

MethodgetGroupMetadataCombineExist

(@PathVariable Long clusterPhyId,

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

MethodgetGroupRebalancedCount

(VersionItemParam metricParam)

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

MethodgetGroupState

获取group的状态 @param param @return

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

MethodgetGroupStateFromDB

(Long clusterPhyId, String groupName)

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

MethodgetGroupTopicFromDB

(Long clusterPhyId, String groupName, String topicName)

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

MethodgetGroupTopicsOverview

(@PathVariable Long clusterPhyId, @Pa

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

MethodgetGroupsBasic

(@PathVariable Long clusterPhyId)

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

MethodgetGroupsCount

(VersionItemParam metricParam)

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

MethodgetGroupsFromDB

(Long clusterPhyId)

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

MethodgetGroupsOverview

(@PathVariable Long clusterPhyId, ClusterGroupSummaryDTO dto)

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

MethodgetHealthCheckAggResult

(Long clusterPhyId, HealthCheckDimensionEnum dimensionEnum, String resNme)

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

MethodgetHealthCheckConfig

(@PathVariable Long clusterPhyId)

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

FunctiongetHealthconfig

()

km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/HealthySetting.tsx:36

MethodgetHourInfo

(Date time)

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

MethodgetJMXInfo

(Long clusterPhyId, String action)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseKafkaVersionControlService.java:46

MethodgetJMXInfo

(Long connectClusterId, String action)

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

MethodgetJdbcUrl

()

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

MethodgetJobDetail

(@PathVariable Long clusterPhyId, @PathVariable Long jobId)

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

MethodgetJobDetailsGroupByTopic

(Long jobId)

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

MethodgetJobModifyDetail

(Long clusterPhyId, Long jobId)

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

MethodgetJobModifyDetail

(@PathVariable Long clusterPhyId, @PathVariable Long jobId)

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

MethodgetJobNodeTraffic

(Long clusterPhyId, Long jobId)

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

MethodgetJobNodeTraffic

(@PathVariable Long clusterPhyId, @PathVariable Long jobId)

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

MethodgetJobs

(VersionItemParam metricParam)

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

MethodgetJobsFailed

(VersionItemParam metricParam)

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

MethodgetJobsRunning

(VersionItemParam metricParam)

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

MethodgetJobsSuccess

(VersionItemParam metricParam)

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

MethodgetJobsWaiting

(VersionItemParam metricParam)

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

MethodgetKafkaController

(Long clusterPhyId, boolean addWatch)

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

MethodgetKafkaControllerHistory

(@PathVariable Long clusterPhyId, PaginationBaseDTO dto)

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

MethodgetKafkaControllersFromDB

(List<Long> clusterPhyIdList, boolean notIncludeNotAlive)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/KafkaControllerService.java:21

MethodgetKafkaInZKConfigChangedHistory

(@PathVariable Long clusterPhyId,

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

MethodgetKafkaUserByClusterIdFromDB

(Long clusterPhyId, String searchKafkaUserName)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:359

MethodgetKafkaUserByKafkaClient

(VersionItemParam itemParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:577

MethodgetKafkaUserByZKClient

(VersionItemParam itemParam)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:550

MethodgetKafkaUserFromKafka

(Long clusterPhyId)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:219

MethodgetKafkaUserTokenWithEncrypt

(Long clusterPhyId, String kafkaUser)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/impl/KafkaUserManagerImpl.java:57

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetKey

()

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

MethodgetLagRelevantFromAdminClient

获取Lag相关指标, 包括lag，consumedOffset partitionEndOffset

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

MethodgetLastDayOfTheMonth

获取当前月的最后一天的 @param time 时间 @return

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

MethodgetLatestBrokerMetrics

(@PathVariable Long clusterPhyId, @PathVariable Integer

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

MethodgetLatestClusterMetrics

(@PathVariable Long clusterPhyId, @RequestBody List<String> metricsNames)

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

MethodgetLatestMetrics

(@PathVariable Long clusterPhyId, @RequestBody List<String> metricsNames)

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

MethodgetLatestMetricsFromCache

(Long clusterPhyId)

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

MethodgetLatestMetricsFromCache

优先从本地缓存获取metrics信息

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

MethodgetLatestMetricsFromCache

(Long clusterPhyId)

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

MethodgetLatestMetricsFromES

从ES获取指标

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionMetricService.java:28

MethodgetLatestMetricsFromES

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

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

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<Integer> brokerIdList)

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

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<ClusterConnectorDTO> connectorNameList, List<String> metricNameList)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/ConnectorMetricService.java:31

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<ClusterConnectorDTO> connectorNameList, List<String> metricsNames)

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

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<Tuple<Long, String>> mirrorMakerList, List<String> metricNameList)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/MirrorMakerMetricService.java:25

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<Tuple<Long, String>> mirrorMakerList, List<String> metricNameList)

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

MethodgetLatestMetricsFromES

获取多个存储在ES中的指标数据，最新的一条即可

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

MethodgetLatestMetricsFromES

(Long clusterPhyId, List<String> metricNames)

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

MethodgetLeadersSkew

(VersionItemParam metricParam)

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

FunctiongetLeafCheckboxData

()

km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:218

MethodgetLivenessCheckPorts

@return the ports on which to check if the container is ready @deprecated use {@link #getLivenessCheckPortNumbers()} instead

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

MethodgetLogDirByKafkaClient

(VersionItemParam itemParam)

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

MethodgetLogSizeFromClient

(VersionItemParam metricParam)

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

MethodgetLogSizeFromJmx

(VersionItemParam metricParam)

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

MethodgetMD5

获取MD5值 @param str @return

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:40

MethodgetMM2Configs

(@PathVariable Long connectClusterId, @PathVariable String connectorName)

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

MethodgetMM2Configs

(Long connectClusterId, String connectorName)

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

FunctiongetMemoryUnit

(value: number)

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

MethodgetMessage

()

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

MethodgetMessageSize

获取集群的 messageSize

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

MethodgetMessages

(VersionItemParam param)

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

MethodgetMethodName

(Long clusterPhyId, String action)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseKafkaVersionControlService.java:39

← previous next →5,601–5,700 of 6,956, ranked by callers