MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
Functionug
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionul
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:111
Functionun
(e,t,n)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/GroupMetrics.java:63
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/ReplicationMetrics.java:24
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BrokerMetrics.java:43
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/ClusterMetrics.java:44
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java:47
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/ZookeeperMetrics.java:24
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/TopicMetrics.java:57
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/PartitionMetrics.java:30
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/mm2/MirrorMakerTopicPartitionMetrics.java:28
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/mm2/MirrorMakerMetrics.java:42
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/connect/ConnectWorkerMetrics.java:23
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/connect/ConnectorMetrics.java:31
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/connect/ConnectorTaskMetrics.java:28
Methodunique
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/connect/ConnectClusterMetrics.java:28
FunctionunloadApplication
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionunregisterApplication
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Functionunstable_forceFrameRate
()
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:27
Functionunstable_now
()
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:27
Functionuo
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:75
MethodupdateAliveBrokers
(Long clusterPhyId, List<Broker> presentAliveBrokerList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:110
MethodupdateConnectorConfig
(Long connectClusterId, String connectorName, Properties configs, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/OpConnectorService.java:23
MethodupdateConnectorConfig
(Long connectClusterId, String connectorName, Properties configs, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:253
MethodupdateConnectorConfig
(Long connectClusterId, String connectorName, Properties configs, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/impl/ConnectorManagerImpl.java:40
MethodupdateJobTrafficLimit
(Long clusterPhyId, Long jobId, Long limit, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:316
MethodupdateJobTrafficLimit
(@PathVariable Long clusterPhyId, @PathVariable Long jobId, @PathVariable Long limit)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:107
MethodupdateLimit
(Job job, Long limit, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:80
MethodupdatePartitionNum
(Long clusterPhyId, String topicName, Integer partitionNum)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:239
MethodupdatePartitions
(Long clusterPhyId, String topicName, List<Partition> kafkaPartitionList, List<PartitionPO> dbPartitionList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:313
MethodupdateTask
(Long clusterPhyId, JobDTO task, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:116
MethodupdateUserMetricItem
(@PathVariable Long clusterId, @PathVariable Integer type, @Valid
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/version/VersionController.java:79
MethodupdateUserMetricItem
(Long clusterId, Integer type, UserMetricConfigDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/impl/VersionControlManagerImpl.java:269
Functionur
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:26
FunctionurlParser
()
km-console/packages/layout-clusters-fe/src/constants/common.ts:126
Functionus
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Methodv1
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/Triple.java:16
Methodv2
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/Triple.java:25
FunctionvL
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionvO
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionva
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:102
Methodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchSort.java:29
Methodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchRange.java:20
Methodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchQuery.java:44
Methodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchShould.java:40
Methodvalid
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/search/SearchFuzzy.java:23
Methodvalid
Returns a future which yields just the valid listings. This future never fails with an error, no matter what happens. Errors are completely ignored.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSListGroupsResult.java:63
MethodvalidAclOperations
(final int authorizedOperations)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1407
Methodvalidate
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/OperationEnum.java:69
MethodvalidateConnectors
(@Validated @RequestBody ConnectorCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectorController.java:92
MethodvalidateConnectors
(@Validated @RequestBody MirrorMakerCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerController.java:70
MethodvalidateConnectors
(MirrorMakerCreateDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:429
MethodvalidateKafka
(@RequestBody ValidateKafkaDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/util/UtilsController.java:39
Functionvalidator
(_, value)
km-console/packages/config-manager-fe/src/pages/UserManage/RoleTabContent.tsx:228
Functionvalidator
(_, value)
km-console/packages/config-manager-fe/src/pages/UserManage/UserTabContent.tsx:159
Functionvalidator
(params: any, value: string)
km-console/packages/layout-clusters-fe/src/pages/Login/config.tsx:150
Functionvalidator
(_, value)
km-console/packages/layout-clusters-fe/src/pages/TopicList/Create.tsx:190
Functionvalidator
(_, value)
km-console/packages/layout-clusters-fe/src/pages/TopicList/Delete.tsx:86
Functionvalidator
(_: any, value: string)
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:480
Functionvalidator
(rule, value)
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnectorUseJSON.tsx:175
Functionvalidator
(_, value)
km-console/packages/layout-clusters-fe/src/pages/Connect/Delete.tsx:80
Functionvalidator
(_: any, value: string)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:381
Functionvalidator
(_, value)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/Delete.tsx:80
Functionvalidator
(rule, value)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2JSON.tsx:170
Functionvalidator
(_, value)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Delete.tsx:87
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerDetailCard.tsx:73
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectCard.tsx:79
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ConnectDetailCard.tsx:87
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/LoadRebalanceCardBar.tsx:67
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ZookeeperCard.tsx:65
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/MirrorMakerCard.tsx:79
Functionvalue
()
km-console/packages/layout-clusters-fe/src/components/CardBar/ACLsCardBar.tsx:35
MethodvalueOf
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigGroupEnum.java:41
MethodvalueOf
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigDiffTypeEnum.java:34
MethodvalueOf
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/config/ConfigStatusEnum.java:33
MethodvalueOfStatus
(int status)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobActionEnum.java:34
MethodverifyAndUpdateStatue
(Long jobId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:350
MethodverifyLogin
(AccountLoginDTO loginDTO, HttpServletRequest request,
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/ldap/LdapLoginServiceImpl.java:55
MethodverifyPartitionReassignments
(ExecuteReassignParam executeReassignParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:156
MethodverifyTaskByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:325
MethodverifyTaskByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:302
Methodversion
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/self/SelfController.java:33
Methodversion
()
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/self/impl/SelfManagerImpl.java:57
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ZookeeperMetricVersionItems.java:53
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/GroupMetricVersionItems.java:27
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/BrokerMetricVersionItems.java:51
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ReplicaMetricVersionItems.java:29
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/TopicMetricVersionItems.java:44
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/PartitionMetricVersionItems.java:30
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java:126
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/ConnectClusterMetricVersionItems.java:47
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/ConnectorMetricVersionItems.java:119
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/MirrorMakerMetricVersionItems.java:52
MethodversionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java:49
Functionvf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
Functionvk
(r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionvm
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionvn
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Functionvo
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:77
← previousnext →6,801–6,900 of 6,956, ranked by callers