MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
Methodmain
(String[] args)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:341
Methodmap2Obj
(Map<String, Object> map, Class<?> clz)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:245
MethodmaxVersion
(long maxVersion)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:62
Functionmb
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionmc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:95
Functionme
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:36
MethodmergeMapList
(List<Map<K, V>> mapList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:219
MethodmethodArgumentNotValidException
处理参数异常并返回 @param me 异常 @return
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/handler/CustomGlobalExceptionHandler.java:25
MethodmethodName
(String methodName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMethodInfo.java:17
FunctionmetricSelectCallback
(newMetricNames: (string | number)[])
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:399
FunctionmetricSelectCallback
([newMetrics]: [CheckboxStatus[], any])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:190
Methodmetrics
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/self/SelfController.java:26
Methodmetrics
()
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/self/impl/SelfManagerImpl.java:38
Functionmf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:85
Functionmf
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:183
MethodminVersion
(long minVersion)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:50
Functionmj
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:54
Functionmo
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:78
Methodmodify
修改迁移任务
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:25
Methodmodify
(Long jobId, ReplaceReassignJob replaceReassignJob, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:173
Methodmodify
(Job job, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:57
Methodmodify
(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/ZKWatcherManager.java:75
Methodmodify
(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:70
Methodmodify
(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:68
Methodmodify
(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaJMXClient.java:102
Methodmodify
(ClusterPhy newClusterPhy, ClusterPhy oldClusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminClient.java:52
Methodmodify
(ConnectCluster newConnectCluster, ConnectCluster oldConnectCluster)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:130
MethodmodifyBrokerConfig
(KafkaBrokerConfigModifyParam kafkaBrokerConfigModifyParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:22
MethodmodifyBrokerConfig
(KafkaBrokerConfigModifyParam kafkaBrokerConfigModifyParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:86
MethodmodifyBrokerConfig
(KafkaBrokerConfigModifyParam modifyParam, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerConfigManagerImpl.java:80
MethodmodifyBrokerConfigByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:228
MethodmodifyBrokerConfigByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:208
MethodmodifyClusterPhyById
(ClusterPhyPO clusterPhyPO, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:162
MethodmodifyClusterPhyById
(@Validated @RequestBody ClusterPhyModifyDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterPhyController.java:51
MethodmodifyConnectors
(@Validated @RequestBody ConnectorCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectorController.java:76
MethodmodifyJobById
(@PathVariable Long clusterPhyId, @RequestBody JobDTO jobDTO)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:58
MethodmodifyKafkaBrokerConfig
(@Validated @RequestBody KafkaConfigModifyBrokerDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/config/KafkaConfigController.java:104
MethodmodifyKafkaTopicConfig
(@Validated @RequestBody KafkaConfigModifyTopicDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/config/KafkaConfigController.java:119
MethodmodifyKafkaUser
(KafkaUserReplaceParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:178
MethodmodifyKafkaUserToken
(@Validated @RequestBody ClusterKafkaUserTokenDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/kafkauser/KafkaUserController.java:47
MethodmodifyKafkaUserWithTokenEncrypted
(ClusterKafkaUserTokenDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/impl/KafkaUserManagerImpl.java:43
MethodmodifyMM2s
(@Validated @RequestBody MirrorMakerCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerController.java:63
MethodmodifyMirrorMakerConfig
(MirrorMakerCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:179
MethodmodifyThrottle
(Long jobId, Long throttleUnitB, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:219
MethodmodifyThrottleTaskByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:229
MethodmodifyThrottleTaskByZKClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:189
MethodmodifyTopicConfig
(KafkaTopicConfigParam kafkaTopicConfigParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:105
MethodmodifyTopicConfigByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:233
MethodmodifyTopicConfigByZKClientAndNodeVersionV1
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:256
MethodmodifyTopicConfigByZKClientAndNodeVersionV2
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:287
MethodmonitorName
monitor 服务的名称 @return
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:36
MethodmonitorName
()
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/prometheus/PrometheusService.java:42
FunctionmountRootParcel
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Functionmr
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:29
Functionmt
(t)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionnA
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionnL
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionnN
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionna
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:99
Functionna
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Methodname
(String name)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:44
FunctionnavigateToUrl
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Functionnc
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:92
Functionnd
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
MethodneedRecord
(boolean success)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/RecordResultEnum.java:34
MethodneedRetry
(Exception e)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpTimeoutRetry.java:36
MethodnewThread
Creates a new {@link Thread} @see java.util.concurrent.ThreadFactory#newThread(java.lang.Runnable)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/NamedThreadFactory.java:43
Functionnf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:82
Functionnh
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:91
Functionnj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:54
Functionnl
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:110
Functionnn
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionnodeChange
(val: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:279
FunctionnodeChange
(val: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/ClusterNorms.tsx:50
FunctionnodeChange
(val: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:298
FunctionnodeScopeChange
(data: any, isTop?: any)
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/index.tsx:95
Functionnr
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:26
Functionnu
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionnw
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionoA
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionoN
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionoa
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:100
Functionod
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionof
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:83
Functionoj
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:54
Functionon
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
MethodonApplicationEvent
(ClusterPhyDeletedEvent event)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterDeletedListener.java:17
MethodonApplicationEvent
(ClusterPhyAddedEvent event)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java:23
MethodonApplicationEvent
(MirrorMakerMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/mm2/MirrorMakerMetricESSender.java:29
MethodonApplicationEvent
(GroupMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/GroupMetricESSender.java:25
MethodonApplicationEvent
(PartitionMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/PartitionMetricESSender.java:25
MethodonApplicationEvent
(ClusterMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/ClusterMetricESSender.java:25
MethodonApplicationEvent
(ZookeeperMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/ZookeeperMetricESSender.java:25
MethodonApplicationEvent
(BrokerMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/BrokerMetricESSender.java:25
MethodonApplicationEvent
(TopicMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/TopicMetricESSender.java:25
MethodonApplicationEvent
(ConnectClusterMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/connect/ConnectClusterMetricESSender.java:29
MethodonApplicationEvent
(ConnectorMetricEvent event)
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/connect/ConnectorMetricESSender.java:29
MethodonApplicationEvent
(ClusterPhyLoadChangedEvent event)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/AbstractClusterLoadedChangedHandler.java:27
MethodonApplicationEvent
(ConnectClusterLoadChangedEvent event)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/AbstractConnectClusterChangeHandler.java:28
MethodonApplicationEvent
(BaseMetricEvent event)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:38
← previousnext →6,201–6,300 of 6,956, ranked by callers