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

↓ 3 callersMethodinit

(String threadPoolName, int corePoolSize, int maxPoolSize, int queueSize)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:26

↓ 3 callersMethodinitLocalCache

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/NetUtils.java:58

↓ 3 callersMethodisScram

(Integer authType)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/cluster/ClusterAuthTypeEnum.java:64

↓ 3 callersFunctioniteratorFor

(e)

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

↓ 3 callersFunctioniu

(e,t)

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

↓ 3 callersFunctionjM

(t)

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

↓ 3 callersFunctionjc

(n)

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

↓ 3 callersFunctionjd

(t,e,n,i)

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

↓ 3 callersMethodjdbcPassword

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/MySQLTestContainer.java:45

↓ 3 callersMethodjdbcUrl

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/MySQLTestContainer.java:50

↓ 3 callersMethodjdbcUsername

()

km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/MySQLTestContainer.java:40

↓ 3 callersFunctionje

(e,t)

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

↓ 3 callersFunctionjf

(e)

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

↓ 3 callersFunctionjg

(t)

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

↓ 3 callersFunctionji

(n)

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

↓ 3 callersFunctionjk

(t)

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

↓ 3 callersFunctionjn

(e)

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

↓ 3 callersFunctionk

(n,t)

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

↓ 3 callersFunctionk

(t,e)

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

↓ 3 callersFunctionkC

(t,e)

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

↓ 3 callersFunctionke

(n,t,r)

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

↓ 3 callersFunctionkh

(e,t,n)

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

↓ 3 callersFunctionl

(e)

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

↓ 3 callersFunctionlD

(t)

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

↓ 3 callersMethodlistBrokerMetricsByBrokerIds

获取集群 clusterPhyId 中每个 metric 的指定 brokers 在指定时间[startTime、endTime]区间内所有的指标

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java:109

↓ 3 callersMethodlistByClusterAndType

按照集群ID查询

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/HaActiveStandbyRelationService.java:22

↓ 3 callersMethodlistCheckResult

(Long clusterPhyId)

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

↓ 3 callersMethodlistClusterMetricsFromES

listClusterMetricsFromES @param dto @return

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

↓ 3 callersMethodlistConnectClusterMetricsFromES

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

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

↓ 3 callersMethodlistPOs

(Long firstClusterId, HaResTypeEnum haResTypeEnum)

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

↓ 3 callersMethodlistTopicMetricsByTopics

获取每个 metric 指定个 topic 的指标

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

↓ 3 callersMethodlistTopicMetricsFromES

从 es 中获取聚合计算之后的指标用于页面展示 @param dto @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:57

↓ 3 callersFunctionlk

(t,e)

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

↓ 3 callersFunctionlp

(t,e)

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

↓ 3 callersFunctionm

(n)

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

↓ 3 callersFunctionmD

(t,e)

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

↓ 3 callersFunctionmE

(t)

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

↓ 3 callersMethodmetricMap2VO

(Long clusterId, Map<String/*metric*/, Map<T, List<MetricPointVO>>> metricsMap )

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

↓ 3 callersFunctionmh

(t,e,n,i)

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

↓ 3 callersMethodmodifyBrokerConfig

(KafkaBrokerConfigModifyParam modifyParam, String operator)

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/BrokerConfigManager.java:18

↓ 3 callersMethodmodifyTopicConfig

修改Topic配置 @param kafkaTopicConfigParam 修改信息 @param operator 操作人 @return

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicConfigService.java:23

↓ 3 callersFunctionn

(e,t,n)

km-console/packages/layout-clusters-fe/static/js/single-spa-react.js:1

↓ 3 callersFunctionnD

(t,e)

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

↓ 3 callersFunctionnE

(t,e)

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

↓ 3 callersFunctionnM

(t)

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

↓ 3 callersFunctionne

(t,e,n,i)

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

↓ 3 callersFunctionnh

(t,e,n,i,r,o,a)

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

↓ 3 callersFunctionnormalizeValue

(e)

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

↓ 3 callersFunctionnt

(t,e)

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

↓ 3 callersFunctionnw

(t,e,n,i)

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

↓ 3 callersFunctiono

(n,t)

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

↓ 3 callersFunctiono_

(t,e)

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

↓ 3 callersFunctionoc

(n)

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

↓ 3 callersFunctionoe

(a)

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

↓ 3 callersFunctionoe

()

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

↓ 3 callersFunctionok

(e)

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

↓ 3 callersFunctionol

(e)

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

↓ 3 callersFunctiononClose

()

km-console/packages/layout-clusters-fe/src/components/TopicJob/PreviewTaskPlan.tsx:25

↓ 3 callersFunctiononClose

()

km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:902

↓ 3 callersFunctiononClose

()

km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:933

↓ 3 callersFunctiononDrawerClose

()

km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:182

↓ 3 callersFunctiononDrawerClose

()

km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:136

↓ 3 callersFunctiononExpand

(metricName: string)

km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:291

↓ 3 callersFunctionot

(s,t)

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

↓ 3 callersFunctionot

(e)

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

↓ 3 callersFunctionou

(e)

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

↓ 3 callersFunctionp

()

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

↓ 3 callersFunctionpL

(t)

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

↓ 3 callersMethodparseBrokerMetadata

()

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

↓ 3 callersMethodparseExecuteAssignmentArgs

(Long clusterPhyId, String reassignmentJson)

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignService.java:55

↓ 3 callersFunctionpb

(t,e)

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

↓ 3 callersFunctionpe

()

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

↓ 3 callersFunctionpn

(t)

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

↓ 3 callersMethodpostObjectWithJsonContent

POST请求 @param url 请求地址 @param postBody 请求内容 @param resultType 期望返回的类型 @param <T> 泛型T @return T

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

↓ 3 callersMethodprocess

处理方法 @return @throws Throwable

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java:39

↓ 3 callersFunctionps

(e,t)

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

↓ 3 callersMethodput2Queue

(ConnectClusterLoadChangedEvent event)

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/schedule/ScheduleFlushConnectClusterTask.java:83

↓ 3 callersMethodput2Queue

(ClusterPhyLoadChangedEvent event)

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/schedule/ScheduleFlushClusterTask.java:88

↓ 3 callersFunctionqM

(t)

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

↓ 3 callersFunctionqO

(t,e,n)

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

↓ 3 callersFunctionqT

(t,e,n)

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

↓ 3 callersFunctionqa

(e)

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

↓ 3 callersFunctionqf

(e,t)

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

↓ 3 callersFunctionqn

(t,e,n,i)

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

↓ 3 callersMethodqueryNames

(ObjectName name, QueryExp query)

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxConnectorWrap.java:144

↓ 3 callersFunctionr

(e,n,r,i,o)

km-console/packages/layout-clusters-fe/static/js/system.min.js:4

↓ 3 callersFunctionrC

(t)

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

↓ 3 callersFunctionrG

(t)

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

↓ 3 callersFunctionra

(t,e,n,i,r)

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

↓ 3 callersMethodreInitDueIOException

()

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxConnectorWrap.java:225

↓ 3 callersFunctionreloadClusterList

(pageSize = DEFAULT_PAGE_SIZE)

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

↓ 3 callersMethodremove

移除缓存 @param clusterPhyId 物理集群ID

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/AbstractZKWatcher.java:64

↓ 3 callersFunctionrenderLine

(record: any, metricName: string)

km-console/packages/layout-clusters-fe/src/pages/TopicList/index.tsx:139

↓ 3 callersFunctionrenderLine

(record: any, metricName: string)

km-console/packages/layout-clusters-fe/src/pages/Connect/config.tsx:77

↓ 3 callersFunctionrenderLine

(record: any, metricName: string)

km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/config.tsx:77

↓ 3 callersFunctionrenderTableInfo

()

km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:471

↓ 3 callersFunctionrenderValue

(v: string | number | ((visibleType?: boolean) => JSX.Element), visibleType?: boolean)

km-console/packages/layout-clusters-fe/src/components/CardBar/index.tsx:26

↓ 3 callersFunctionrf

(t,e)

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

↓ 3 callersFunctionrk

(t,e)

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

↓ 3 callersFunctionrn

(t)

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

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