Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/didi/KnowStreaming
/ functions
Functions
6,956 in github.com/didi/KnowStreaming
⨍
Functions
6,956
◇
Types & classes
1,070
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/index.tsx:83
Function
onTableChange
(curPagination: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/HistoryDrawer.tsx:159
Function
onTableChange
(curPagination: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:222
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/index.tsx:55
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Consumers/index.tsx:140
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerList/index.tsx:69
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/Configuration.tsx:65
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerDetail/DataLogs.tsx:53
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/Workers.tsx:47
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/Detail.tsx:39
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:82
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/Detail.tsx:14
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:84
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/BrokerControllerChangeLog/index.tsx:61
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Detail.tsx:133
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/ExpandedRow.tsx:209
Function
onTableChange
(pagination: any, filters: any, sorter: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/index.tsx:57
Function
onTableChange
(curPagination: any)
km-console/packages/layout-clusters-fe/src/pages/SecurityUsers/index.tsx:420
Function
onclose
()
km-console/packages/layout-clusters-fe/src/pages/Jobs/index.tsx:146
Function
onclose
()
km-console/packages/layout-clusters-fe/src/pages/TopicList/index.tsx:319
Function
oo
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:75
Function
op
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Method
operateConnectors
(@Validated @RequestBody ConnectorActionDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectorController.java:61
Method
operateMM2s
(@Validated @RequestBody MirrorMaker2ActionDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerController.java:48
Function
optionConnect
(record: any, action: string)
km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:106
Function
optionConnect
(record: any, action: string)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:108
Function
optionFn
(taskId: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/Detail.tsx:43
Function
or
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:27
Function
ot
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Function
ou
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:44
Function
ow
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
p
(e,t)
km-console/packages/layout-clusters-fe/static/js/single-spa-react.js:1
Function
pC
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
pE
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
pG
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
pa
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:102
Method
pageWorkByKafkaClusterPhy
(Long kafkaClusterPhyId, PaginationBaseDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/worker/impl/WorkerServiceImpl.java:77
Method
paginationQuery
(Long clusterPhyId, PaginationSortDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ControllerChangeLogServiceImpl.java:31
Method
paginationQuery
(Map<String, Object> params)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/ControllerChangeLogDAO.java:14
Method
pagingByCluster
(Long clusterPhyId, PaginationBaseDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/change/record/impl/KafkaChangeRecordServiceImpl.java:50
Method
pagingClusterGroupsOverview
(Long clusterPhyId, ClusterGroupSummaryDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:154
Method
pagingClusterWithLatestMetricsFromES
(List<Long> clusterIds, List<SearchT
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterMetricService.java:45
Method
pagingClusterWithLatestMetricsFromES
(List<Long> clusterIds, List<
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:283
Method
pagingClusterWithLatestMetricsTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/ClusterMetricESDAOTest.java:78
Method
pagingControllerHistories
(Long clusterPhyId, Integer pageNo, Integer pageSize, String brokerHostSearchKeyword)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkacontroller/impl/KafkaControllerServiceImpl.java:119
Method
pagingGroupMembers
(Long clusterPhyId, String topicName,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/GroupService.java:65
Method
pagingGroupMembers
(Long clusterPhyId, String topicName,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java:247
Method
pagingGroupMembers
(Long clusterPhyId, String topicName,
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:96
Method
pagingGroupTopicConsumedMetrics
(Long clusterPhyId, St
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:180
Method
pagingGroupTopicMembers
(Long clusterPhyId, String groupName, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:120
Method
pagingJobs
(Long clusterPhyId, JobPaginationDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:272
Method
pagingJobs
(@PathVariable Long clusterPhyId, @RequestBody JobPaginationDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:65
Method
pagingKafkaUserFromDB
(Long clusterPhyId, PaginationBaseDTO dto)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:347
Method
pagingTopicGroupsOverview
(Long clusterPhyId, String topicName, String searchGroupName, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:307
Method
pagingTopicWithLatestMetricsFromES
(Long clusterId, List<String> metricNameList,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:270
Method
pagingTopicWithLatestMetricsFromESTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/core/TopicMetricServiceTest.java:49
Method
parseAndInitData
(Long clusterPhyId, String host, int port, String cmdData)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ConfigCmdDataParser.java:40
Method
parseAndInitData
(Long clusterPhyId, String host, int port, String cmdData)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java:34
Method
parseAndInitData
(Long clusterPhyId, String host, int port, String cmdData)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java:39
Method
parseExecuteAssignmentArgs
(Long clusterPhyId, String reassignmentJson)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:174
Method
path
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:44
Function
pathToActiveWhen
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Function
pc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:94
Function
periodtimeChange
(e: any)
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/NodeSelect.tsx:47
Function
pf
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
Function
pg
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
pj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:54
Function
planClose
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:356
Function
po
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:77
Method
postObjectWithJsonContentAndHeader
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:71
Function
pr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28
Method
preHandle
拦截预处理 @return boolean false:拦截, 不向下执行, true:放行
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/interceptor/PermissionInterceptor.java:45
Method
preferredReplicaElection
优先副本选举
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/OpPartitionService.java:13
Method
preferredReplicaElection
(Long clusterPhyId, List<TopicPartition> tpList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/OpPartitionServiceImpl.java:61
Method
preferredReplicaElectionByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/OpPartitionServiceImpl.java:95
Method
preferredReplicaElectionByZKClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/OpPartitionServiceImpl.java:76
Function
preview
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:252
Function
priorityChange
(e: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:372
Method
process
(Job job, JobActionEnum action, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:85
Method
process
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpTimeoutRetry.java:31
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/BrokerMetricCollectorTask.java:23
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ClusterMetricCollectorTask.java:23
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/ZookeeperMetricCollectorTask.java:23
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/GroupMetricCollectorTask.java:27
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/PartitionMetricCollectorTask.java:24
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/TopicMetricCollectorTask.java:23
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/KMJobTask.java:22
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/job/CommunityReassignJobTask.java:26
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaGroupTask.java:34
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaAclTask.java:24
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerConfigDiffTask.java:41
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncConnectClusterAndWorkerTask.java:52
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncBrokerTask.java:28
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicTask.java:28
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicConfigTask.java:43
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncKafkaUserTask.java:29
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncPartitionTask.java:32
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncZookeeperTask.java:25
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncControllerTask.java:34
Method
processClusterTask
(ClusterPhy clusterPhy, long triggerTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java:33
← previous
next →
6,401–6,500 of 6,956, ranked by callers