MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metrics/ConnectorMetricCollectorTask.java:25
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metrics/ConnectClusterMetricCollectorTask.java:25
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/mm2/metrics/MirrorMakerCollectorTask.java:26
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metadata/SyncConnectorTask.java:27
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metadata/SyncWorkerConnectorTask.java:44
MethodprocessClusterTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:37
MethodprocessSubTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java:21
MethodprocessSubTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java:22
MethodprocessSubTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java:22
MethodprocessSubTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metrics/AbstractAsyncMetricsDispatchTask.java:22
MethodprocessSubTask
(ConnectCluster connectCluster, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metadata/AbstractAsyncMetadataDispatchTask.java:22
MethodprocessTask
(List<ClusterPhy> subTaskList, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java:32
MethodprocessTask
(List<ConnectCluster> subTaskList, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/AbstractConnectClusterDispatchTask.java:29
Methodprovide
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:444
Methodprovide
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:457
Methodprovide
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:476
Functionpt
()
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
Functionpt
(t,n,e,r,o)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
MethodputForObject
PUT请求 @param url 请求地址 @param request 请求内容 @param responseType 期望返回的类型 @param <T> 泛型T @return T
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:303
MethodputMetric
(String key, Float value)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/BaseMetricESPO.java:34
MethodputMetrics
(Map<String, Float> metrics)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/BaseMetricESPO.java:38
MethodputObjectWithJsonContentAndHeader
POST请求 @param url 请求地址 @param request 请求内容 @param responseType 期望返回的类型 @param <T> 泛型T @return T
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:331
MethodputPlatformClusterConfig
(@Validated @RequestBody List<PlatformClusterConfigDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/config/PlatformClusterConfigController.java:43
FunctionqL
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionqP
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionqa
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:109
Functionqf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:91
Functionqf
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionqg
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Functionqh
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:90
Functionqj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:55
Functionqo
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:81
Functionqs
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
MethodqueryCount
(Long clusterPhyId, PaginationSortDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ControllerChangeLogServiceImpl.java:26
MethodqueryCount
(Map<String, Object> params)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/ControllerChangeLogDAO.java:16
FunctionrB
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionrD
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionrN
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
MethodrandomString
生成固定长度的随机字符串
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:216
FunctionrankChange
(oldIndex: number, newIndex: number)
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:371
FunctionrankChange
(oldIndex: number, newIndex: number)
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:78
FunctionreadBlobAsArrayBuffer
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
FunctionrefreshClick
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/Messages.tsx:88
FunctionregisterApplication
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
MethodregisterHandler
(VersionItemTypeEnum typeEnum, String methodName, Function<VersionItemParam, Object> func)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/impl/VersionControlServiceImpl.java:55
MethodremoveClusterPhyById
(Long clusterPhyId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:126
FunctionremoveErrorHandler
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
MethodremoveVersion
(String indexName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:17
Functionrender
(cnt: Pick<RoleProps, 'authedUserCnt'>, record: RoleProps)
km-console/packages/config-manager-fe/src/pages/UserManage/RoleTabContent.tsx:425
Functionrender
(roleList)
km-console/packages/config-manager-fe/src/pages/UserManage/UserTabContent.tsx:279
Functionrender
(content)
km-console/packages/config-manager-fe/src/pages/ConfigManage/index.tsx:266
Functionrender
(content)
km-console/packages/config-manager-fe/src/pages/OperationLog/index.tsx:43
Functionrender
(config: any, record: any)
km-console/packages/layout-clusters-fe/src/components/CardBar/index.tsx:136
Functionrender
(name: string, record: any)
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:106
Functionrender
(type: number)
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/index.tsx:117
Functionrender
(t: any, r: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/ExpandedRow.tsx:35
Functionrender
(t: any, r: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:84
Functionrender
(t: string, r: any)
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/config.tsx:75
Functionrender
(t: any, r: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/config.tsx:214
Functionrender
(config: any, record: any)
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/config.tsx:190
Functionrender
(t: any, r: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/config.tsx:50
Functionrender
(name: string)
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:335
Methodreplace
(PartitionPO po)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/partition/PartitionDAO.java:9
Methodreplace
(GroupMemberPO po)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/group/GroupMemberDAO.java:9
Methodreplace
(BrokerConfigPO po)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/broker/BrokerConfigDAO.java:9
Methodreplace
(HealthCheckResultPO healthCheckResultPO)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/health/HealthCheckResultDAO.java:11
MethodreplaceAndReturnIdInDB
(ConnectClusterMetadata metadata)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:49
MethodreplaceBrokerConfigDiff
(BrokerConfigPO po)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:130
MethodreplaceKafkaUserByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:473
MethodreplaceKafkaUserByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:450
MethodresetGroupOffsets
(Long clusterPhyId, String groupName, Map<TopicPartition, Long> offsetMap, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:34
MethodresetGroupOffsets
(Long clusterPhyId, String groupName,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:329
MethodresetGroupOffsets
(@Validated @RequestBody GroupOffsetResetDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/group/GroupController.java:36
MethodresetGroupOffsets
(GroupOffsetResetDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:253
FunctionresetList
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:229
FunctionresetOffset
(record: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Detail.tsx:108
FunctionresetTable
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:54
MethodrestTemplate
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:39
MethodrestartConnector
(Long connectClusterId, String connectorName, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:147
MethodrestartMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:204
MethodresumeConnector
(Long connectClusterId, String connectorName, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:112
MethodresumeMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:254
FunctionretryOption
(taskId: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/Detail.tsx:115
MethodretrySleepTime
(int retryTims)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpTimeoutRetry.java:42
Functionrf
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:82
Functionrh
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:91
Functionrj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:55
Functionrl
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:110
FunctionrootClick
()
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/Detail.tsx:55
FunctionrowChange
(newCategorys: string[])
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:169
Functionrr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:26
Functionrun
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:299
Functionrun
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:107
MethodrunInitScriptIfRequired
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:197
MethodrunnableTask
(String taskName, Integer timeoutUnisMs, Callable<T> callable)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureNoWaitUtil.java:51
Functions
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:11
Functions
(t)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionsB
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionsC
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionsC
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
← previousnext →6,501–6,600 of 6,956, ranked by callers