MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
Function_f
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
Function_g
(t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function_i
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function_k
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function_o
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:77
Function_p
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function_r
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28
Function_w
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functiona
(e,t)
km-console/packages/layout-clusters-fe/static/js/single-spa-react.js:1
Functiona
()
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
Functiona
(e)
km-console/packages/layout-clusters-fe/static/js/system.min.js:4
FunctionaD
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionaO
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionaP
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionaa
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:101
MethodabstractInit
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/ZKWatcherManager.java:29
Functionac
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:93
MethodaclBindings
(@PathVariable Long clusterPhyId, @RequestBody @Validate
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterSecuritiesController.java:44
Functionaction
()
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
MethodactionTask
(TaskActionDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/impl/WorkerConnectorServiceImpl.java:96
MethodactionTask
(@Validated @RequestBody TaskActionDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaTaskController.java:27
Functionadd
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:84
Methodadd
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:65
Methodadd
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:63
MethodaddAndSetId
(ReassignJobPO po)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/reassign/ReassignJobDAO.java:9
MethodaddAndSetId
(ClusterPhyPO clusterPhyPO)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/cluster/ClusterPhyDAO.java:9
MethodaddClusterPhy
(ClusterPhyPO clusterPhyPO, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:86
MethodaddClusterPhy
(@Validated @RequestBody ClusterPhyAddDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterPhyController.java:35
MethodaddClusterPhyTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyServiceTest.java:26
MethodaddControllerChangeLog
添加Controller变化日志 @param controllerChangeLogPO 待添加Controller变化日志对象 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ControllerChangeLogService.java:15
MethodaddControllerChangeLog
(ControllerChangeLogPO controllerChangeLogPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ControllerChangeLogServiceImpl.java:20
FunctionaddErrorHandler
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
MethodaddInterceptors
(InterceptorRegistry registry)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/WebConfig.java:46
MethodaddNewToDB
(KSConnector connector)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:288
MethodaddNewTopic2DB
(TopicPO po)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:178
FunctionaddReassign
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:396
FunctionaddReassign
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:358
MethodaddResourceHandlers
(ResourceHandlerRegistry registry)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/WebConfig.java:52
FunctionaddTask
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:170
MethodaddTask
(Long clusterPhyId, JobDTO jobDTO, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:67
FunctionaddTopicMirror
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/TopicMirror.tsx:160
MethodaddViewControllers
(ViewControllerRegistry registry)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/WebConfig.java:27
MethodaddWatch
(ClusterPhy clusterPhy, KafkaZkClient kafkaZkClient)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/TopicsNodeWatcher.java:25
MethodaddWatch
(ClusterPhy clusterPhy, KafkaZkClient kafkaZkClient)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/ControllerNodeWatcher.java:25
MethodaddWatch
(ClusterPhy clusterPhy, KafkaZkClient kafkaZkClient)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/ConfigChangeNodeWatcher.java:21
MethodaddWatch
(ClusterPhy clusterPhy, KafkaZkClient kafkaZkClient)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/BrokersNodeWatcher.java:24
Functionaf
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
FunctionafterAccessCluster
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/HomePage.tsx:204
Functionaj
(a)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:40
Functional
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Methodalive
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/ZookeeperInfo.java:39
MethodallServerDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:270
MethodallServerDown
所有服务挂掉 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/ZookeeperService.java:15
MethodallServerDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperServiceImpl.java:117
MethodallVersions
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/version/VersionEnum.java:117
Functionam
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionan
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
Functionao
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:76
Functionap
(o,e,a,i)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Methodapply
(compiler)
km-console/packages/layout-clusters-fe/config/CountComponentWebpackPlugin.js:53
Methodapply
(Void v)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSDescribeGroupsResult.java:29
Functionar
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:27
MethodauthorizedOperations
authorizedOperations for this group, or null if that information is not known.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSGroupDescription.java:109
Functionaw
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionax
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionay
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionb
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:12
FunctionbB
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionbC
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionbN
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionbP
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionbR
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionbS
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionba
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:103
MethodbatchCollectMetricsFromZookeeper
(Long clusterPhyId, List<String> metricNameList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:103
MethodbatchCreateKafkaAcl
(List<AclAtomDTO> dtoList, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkaacl/impl/KafkaAclManagerImpl.java:23
MethodbatchCreateMirrorTopic
(List<MirrorTopicCreateDTO> dtoList)
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/impl/MirrorTopicServiceImpl.java:44
MethodbatchCreateMirrorTopic
(@Validated @RequestBody List<MirrorTopicCreateDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorTopicController.java:30
MethodbatchDeleteMirrorTopic
(List<MirrorTopicDeleteDTO> dtoList)
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/impl/MirrorTopicServiceImpl.java:83
MethodbatchDeleteMirrorTopic
(@Validated @RequestBody List<MirrorTopicDeleteDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorTopicController.java:37
MethodbatchDeleteTopicHA
(Long activeClusterPhyId, Long standbyClusterPhyId, List<String> topicNameList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/impl/HaActiveStandbyRelationServiceImpl.java:47
MethodbatchGetPartitionOffsetFromKafkaAdminClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:370
MethodbatchGetPartitionOffsetFromKafkaConsumerClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:442
MethodbatchModifyConnectCluster
(@Validated @RequestBody List<ConnectClusterDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectClusterController.java:36
MethodbatchModifyInDB
(List<ConnectClusterDTO> dtoList, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:146
MethodbatchReplace
(Long clusterPhyId, Integer dimension, List<HealthCheckResult> healthCheckResults)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checkresult/HealthCheckResultService.java:26
MethodbatchReplace
(Long clusterPhyId, Integer dimension, List<HealthCheckResult> healthCheckResults)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checkresult/impl/HealthCheckResultServiceImpl.java:177
MethodbatchReplace
(List<PlatformClusterConfigPO> poList, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/impl/PlatformClusterConfigServiceImpl.java:28
MethodbatchReplace
(List<PlatformClusterConfigPO> poList)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/config/PlatformClusterConfigDAO.java:11
MethodbatchReplaceChangedConfig
(Long clusterPhyId, List<TopicConfig> changedConfigList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:222
MethodbatchReplaceGroupsAndMembers
(Long clusterPhyId, List<Group> newGroupList, Set<String> getFailedGroupSet)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:207
MethodbatchReplaceInDB
(Long connectClusterId, List<WorkerConnector> workerList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/WorkerConnectorService.java:14
MethodbatchReplaceInDB
(Long connectClusterId, List<WorkerConnector> workerList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/impl/WorkerConnectorServiceImpl.java:54
MethodbatchReplaceInDB
(Long connectClusterId, List<ConnectWorker> workerList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/impl/WorkerServiceImpl.java:38
MethodbatchReplaceKafkaUserInDB
operate DB-Method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:319
MethodbatchReplaceMetadata
(Long clusterPhyId, List<Topic> presentTopicList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:191
MethodbatchReplaceTopicHA
(Long activeClusterPhyId, Long standbyClusterPhyId, List<String> topicNameList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/ha/impl/HaActiveStandbyRelationServiceImpl.java:28
Functionbe
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Functionbf
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:85
Functionbf
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
← previousnext →5,001–5,100 of 6,956, ranked by callers