MCPcopy Create free account

hub / github.com/didi/KnowStreaming / types & classes

Types & classes1,070 in github.com/didi/KnowStreaming

Class
km-console/packages/layout-clusters-fe/config/CoverHtmlWebpackPlugin.js:71
Class
km-console/packages/layout-clusters-fe/config/CountComponentWebpackPlugin.js:5
ClassACLAtomParam
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/acl/ACLAtomParam.java:16
ClassACLDelByResParam
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/acl/ACLDelByResParam.java:14
EnumACL_OPERATION
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:None
EnumACL_PATTERN_TYPE
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:None
EnumACL_PERMISSION_TYPE
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:None
EnumACL_RESOURCE_TYPE
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:None
ClassAESUtils
kafka-user Token的加解密传输
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/AESUtils.java:14
ClassAbstractAsyncCommonDispatchTask
other相关任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractAsyncCommonDispatchTask.java:13
ClassAbstractAsyncMetadataDispatchTask
元数据同步相关任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/AbstractAsyncMetadataDispatchTask.java:14
ClassAbstractAsyncMetadataDispatchTask
元数据同步相关任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metadata/AbstractAsyncMetadataDispatchTask.java:14
ClassAbstractAsyncMetricsDispatchTask
指标采集相关任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/AbstractAsyncMetricsDispatchTask.java:14
ClassAbstractAsyncMetricsDispatchTask
Metrics相关任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/metrics/AbstractAsyncMetricsDispatchTask.java:14
ClassAbstractClusterLoadedChangedHandler
加载的集群发生变化的处理类 @author zengqiao @date 22/02/25
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/AbstractClusterLoadedChangedHandler.java:16
ClassAbstractClusterPhyDispatchTask
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/AbstractClusterPhyDispatchTask.java:13
ClassAbstractConnectClusterChangeHandler
@author wyb @date 2022/11/7
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/AbstractConnectClusterChangeHandler.java:15
ClassAbstractConnectClusterDispatchTask
@author wyb @date 2022/11/7
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/AbstractConnectClusterDispatchTask.java:17
ClassAbstractConnectMetricCollector
@author didi
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/connect/AbstractConnectMetricCollector.java:17
ClassAbstractDispatchTask
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:20
ClassAbstractHealthCheckService
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/AbstractHealthCheckService.java:18
ClassAbstractHealthCheckTask
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/AbstractHealthCheckTask.java:22
ClassAbstractHealthCheckTask
@author wyb @date 2022/11/8
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/AbstractHealthCheckTask.java:26
ClassAbstractKafkaMetricCollector
@author didi
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/AbstractKafkaMetricCollector.java:17
ClassAbstractMetricCollector
@author didi
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/AbstractMetricCollector.java:15
ClassAbstractMetricESSender
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/AbstractMetricESSender.java:13
ClassAbstractMonitorSinkService
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:20
ClassAbstractReassignJobDetailData
@author zengqiao @date 22/05/06
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/reassign/job/detail/AbstractReassignJobDetailData.java:11
ClassAbstractReassignJobHandler
通用Job 和 具体的ReassignJob 的中间层,将 job 的相关操作,转到 reassignJob 中
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:33
ClassAbstractTopicConfig
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/kafka/AbstractTopicConfig.java:10
ClassAbstractZKHandler
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/AbstractZKHandler.java:13
ClassAbstractZKWatcher
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/AbstractZKWatcher.java:15
InterfaceAccessClusterDrawerProps
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/AccessCluster.tsx:717
ClassAclAtomDTO
@author zengqiao @date 22/03/01
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/dto/acl/AclAtomDTO.java:15
ClassAclBindingVO
@author zengqiao @date 22/02/28
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/acl/AclBindingVO.java:12
ClassAclController
@author zengqiao @date 22/02/23
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/acl/AclController.java:24
ClassAdminClientRunnable
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:700
ClassAdminOperateException
@author d06679 @date 2019/2/21
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/AdminOperateException.java:11
ClassAdminRunTimeException
平台错误基类 @author d06679 @date 2019/3/13
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/AdminRunTimeException.java:11
ClassAdminTaskCodeException
@author d06679 @date 2019/2/21
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/AdminTaskCodeException.java:11
ClassAdminTaskException
@author d06679 @date 2019/2/21
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/AdminTaskException.java:11
EnumAggTypeEnum
聚合方式
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/AggTypeEnum.java:8
ClassApiCallThreadPoolService
@author wyb @date 2023/2/22
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/utils/ApiCallThreadPoolService.java:16
ClassApiPrefix
Api前缀 @author zengqiao @date 20/4/16
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/ApiPrefix.java:8
InterfaceAssignUser
km-console/packages/config-manager-fe/src/pages/UserManage/config.ts:42
ClassBackoffUtils
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/BackoffUtils.java:3
ClassBaseClusterConfigValue
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/BaseClusterConfigValue.java:7
ClassBaseClusterHealthConfig
单集群的配置
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/healthcheck/BaseClusterHealthConfig.java:10
ClassBaseConnectMetricService
@author wyb @date 2022/11/9
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectMetricService.java:12
ClassBaseConnectVersionControlService
@author wyb @date 2022/11/8
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectVersionControlService.java:17
ClassBaseConnectorMetricESDAO
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:22
ClassBaseDTO
@author d06679 @date 2019/3/13
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/dto/BaseDTO.java:11
ClassBaseESDAO
直接操作es集群的dao
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/BaseESDAO.java:11
ClassBaseESPO
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/BaseESPO.java:3
ClassBaseEntity
@author d06679 @date 2019/3/22
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/BaseEntity.java:12
ClassBaseException
平台错误基类 @author d06679 @date 2019/3/13
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/exception/BaseException.java:11
ClassBaseExtendFactory
从SpringContent中获取指定接口的类的实例 使用例子参考 HandleFactory @author linyunan @date 2021-04-25
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/BaseExtendFactory.java:18
ClassBaseFourLetterWordCmdData
四字命令结果数据的基础类
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/BaseFourLetterWordCmdData.java:8
InterfaceBaseHandle
基础handle标识, 搭配 BaseExtendFactory 使用 @author linyunan @date 2021-04-25
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/BaseHandle.java:9
ClassBaseJobCreateContent
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/job/content/BaseJobCreateContent.java:5
ClassBaseKafkaVersionControlService
@author didi
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseKafkaVersionControlService.java:16
ClassBaseMetricESDAO
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:31
ClassBaseMetricESPO
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/BaseMetricESPO.java:19
ClassBaseMetricEvent
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BaseMetricEvent.java:9
ClassBaseMetricService
@author didi
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:20
ClassBaseMetricVersionMetric
@author didi
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/BaseMetricVersionMetric.java:16
ClassBaseMetrics
@author zengqiao @date 20/6/16
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java:18
ClassBasePO
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/BasePO.java:10
ClassBaseResult
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/BaseResult.java:10
ClassBaseTestContainer
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/BaseTestContainer.java:3
ClassBaseTimeVO
@author d06679 @date 2019/3/13
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/BaseTimeVO.java:13
ClassBaseVO
@author d06679 @date 2019/3/13
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/BaseVO.java:11
ClassBaseVersionControlService
@author didi
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseVersionControlService.java:25
ClassBatchPartitionParam
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/partition/BatchPartitionParam.java:10
ClassBeanUtil
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/BeanUtil.java:10
ClassBroker
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java:21
ClassBrokerBasicVO
集群Broker信息 @author zengqiao @date 22/02/23
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/broker/BrokerBasicVO.java:14
InterfaceBrokerConfigDAO
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/broker/BrokerConfigDAO.java:7
InterfaceBrokerConfigManager
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/BrokerConfigManager.java:9
ClassBrokerConfigManagerImpl
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerConfigManagerImpl.java:24
ClassBrokerConfigPO
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/broker/BrokerConfigPO.java:11
InterfaceBrokerConfigService
Kafka相关配置接口 @author zengqiao @date 22/03/03
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:16
ClassBrokerConfigServiceImpl
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:44
ClassBrokerController
@author zengqiao @date 22/02/23
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerController.java:26
InterfaceBrokerDAO
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/broker/BrokerDAO.java:7
ClassBrokerHealthCheckTask
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/BrokerHealthCheckTask.java:11
InterfaceBrokerManager
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/BrokerManager.java:9
ClassBrokerManagerImpl
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerManagerImpl.java:22
ClassBrokerMetadata
@author zengqiao @date 19/4/3 存储Broker的元信息, 元信息对应的ZK节点是/brokers/ids/{brokerId} 节点结构: { "listener_security_protocol_map":{"SASL_PLAINTEXT":"SASL_
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/znode/brokers/BrokerMetadata.java:53
ClassBrokerMetadataCombineExistVO
@author zengqiao @date 20/4/29
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/metadata/BrokerMetadataCombineExistVO.java:12
ClassBrokerMetadataVO
@author zengqiao @date 19/7/12
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/metadata/BrokerMetadataVO.java:12
ClassBrokerMetricCollector
@author didi
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/metric/kafka/BrokerMetricCollector.java:28
ClassBrokerMetricCollectorTask
@author didi
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metrics/BrokerMetricCollectorTask.java:13
ClassBrokerMetricController
@author zengqiao @date 22/02/23
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerMetricController.java:24
ClassBrokerMetricESDAO
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java:21
ClassBrokerMetricESDAOTest
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:18
ClassBrokerMetricESSender
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/BrokerMetricESSender.java:16
ClassBrokerMetricEvent
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BrokerMetricEvent.java:11
ClassBrokerMetricPO
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/metrice/BrokerMetricPO.java:9
ClassBrokerMetricParam
@author didi
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/metric/BrokerMetricParam.java:10
next →1–100 of 1,070, ranked by callers