MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
MethodJmxAttribute
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxAttribute.java:173
MethodJmxConnectorWrap
(String clientLogIdent, Long brokerStartupTime, String jmxHost, Integer jmxPort, JmxAuthConfig jmxConfig)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxConnectorWrap.java:48
MethodJmxEnum
(Integer port, String message)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/jmx/JmxEnum.java:16
MethodJmxName
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/jmx/JmxName.java:92
FunctionJo
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:82
MethodJobActionEnum
(int status, String value)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobActionEnum.java:17
MethodJobConstant
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/JobConstant.java:4
MethodJobHandleEnum
(Integer type, String message)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobHandleEnum.java:16
MethodJobStatus
按照状态，直接进行聚合
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/job/JobStatus.java:33
MethodJobStatusEnum
(int status, String value)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:17
MethodJobTypeEnum
(Integer type, String message)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobTypeEnum.java:18
MethodJobTypeVO
(Integer type, String message)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/job/JobTypeVO.java:17
FunctionJobsList
(props: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/index.tsx:18
FunctionJoyrideTooltip
(props: TooltipRenderProps)
km-console/packages/layout-clusters-fe/src/components/TourGuide/index.tsx:24
FunctionJr
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:34
FunctionJt
(t)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
FunctionJu
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionK
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
FunctionKB
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionKR
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
MethodKSConfigUtils
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/KSConfigUtils.java:15
MethodKSDescribeGroupsResult
(final Map<String, KafkaFuture<KSGroupDescription>> futures)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSDescribeGroupsResult.java:12
MethodKSGroupDescription
(String groupId, String protocolType, Collection<K
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSGroupDescription.java:19
MethodKSListGroupsResult
(KafkaFutureImpl<Collection<Object>> future)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSListGroupsResult.java:15
MethodKSMemberConnectAssignment
(ConnectProtocol.Assignment assignment, ConnectProtocol.WorkerState workerState)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberConnectAssignment.java:13
MethodKSMemberConsumerAssignment
Creates an instance with the specified parameters. @param topicPartitions List of topic partitions
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberConsumerAssignment.java:19
MethodKSMemberDescription
(String memberId, Optional<String> groupInstanceId,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberDescription.java:13
MethodKSMySQLContainer
@deprecated use {@link MySQLContainer(DockerImageName)} instead
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:58
MethodKSOffsetSpec
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/offset/KSOffsetSpec.java:48
MethodKSPartialKafkaAdminClient
(AdminClientConfig config, String clientId,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:339
MethodKSTimestampSpec
(long timestamp)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/offset/KSOffsetSpec.java:16
FunctionKV
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionKa
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:109
MethodKafkaAclConverter
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaAclConverter.java:19
MethodKafkaBrokerConfigModifyParam
(Long clusterPhyId, Integer brokerId, Map<String, String> changedProps, Boolean applyAll)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/config/KafkaBrokerConfigModifyParam.java:20
MethodKafkaChangeRecordPO
(Long clusterPhyId, ModuleEnum moduleEnum, Strin
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/changerecord/KafkaChangeRecordPO.java:32
MethodKafkaConfigConverter
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaConfigConverter.java:22
MethodKafkaConfigTypeEnum
(int configCode, String configName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/KafkaConfigTypeEnum.java:27
MethodKafkaConnectConstant
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/connect/KafkaConnectConstant.java:30
MethodKafkaConstant
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/KafkaConstant.java:68
MethodKafkaConsumerFactory
(ClusterPhy clusterPhy)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/KafkaConsumerFactory.java:20
MethodKafkaController
(Long clusterPhyId, Integer brokerId, Long timestamp)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafkacontroller/KafkaController.java:27
MethodKafkaReassignUtil
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KafkaReassignUtil.java:25
MethodKafkaReplicaAssignUtil
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KafkaReplicaAssignUtil.java:74
MethodKafkaTopicConfigParam
(Long clusterPhyId, String topicName, Map<String, String> changedProps)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/config/KafkaTopicConfigParam.java:16
MethodKafkaUser
(Long clusterPhyId, String name, String token, Properties props)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafkauser/KafkaUser.java:34
MethodKafkaUserPO
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/KafkaUserPO.java:25
MethodKafkaUserParam
(Long clusterPhyId, String kafkaUserName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/kafkauser/KafkaUserParam.java:14
MethodKafkaUserReplaceParam
(Long clusterPhyId, String kafkaUserName, String kafkaUserToken)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/param/kafkauser/KafkaUserReplaceParam.java:13
MethodKafkaUserVOConverter
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/KafkaUserVOConverter.java:13
FunctionKc
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:98
FunctionKf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:91
FunctionKf
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionKm
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
MethodKmAccountConfig
()
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/KmAccountConfig.java:43
FunctionKn
()
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
FunctionKo
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:81
FunctionKs
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionKy
(o)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionKz
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionL
(t,e)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
FunctionLC
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionLL
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionLOADING_SOURCE_CODE
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionLOAD_ERROR
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionLayoutContainer
()
km-console/packages/layout-clusters-fe/src/pages/index.tsx:29
FunctionLc
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:97
MethodLdapException
()
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/common/ldap/exception/LdapException.java:7
FunctionLeftSider
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:14
FunctionLf
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:89
FunctionLi
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:69
FunctionLicenseLimitModal
()
km-console/packages/layout-clusters-fe/src/app.tsx:76
MethodListConsumerGroupsResults
(Collection<Node> leaders, KafkaFutureImpl<Collection<Object>> future)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1436
FunctionLo
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:80
FunctionLoadBalance
(props: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:49
FunctionLoadRebalanceCardBar
(props: any)
km-console/packages/layout-clusters-fe/src/components/CardBar/LoadRebalanceCardBar.tsx:27
MethodLoadSQLUtil
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/utils/LoadSQLUtil.java:53
MethodLoadedClusterPhyCache
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/LoadedClusterPhyCache.java:18
FunctionLoadingState
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/HomePage.tsx:67
MethodLoggerUtil
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/LoggerUtil.java:19
FunctionLogin
()
km-console/packages/layout-clusters-fe/src/pages/Login/index.tsx:33
MethodLoginConstant
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/LoginConstant.java:33
FunctionLoginForm
(props)
km-console/packages/layout-clusters-fe/src/pages/Login/login.tsx:39
MethodLoginServiceNameEnum
(String name, String msg)
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/common/bizenum/LoginServiceNameEnum.java:25
FunctionLr
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:31
FunctionLt
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionM
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:10
FunctionM
(a,b,c,d)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:39
FunctionMC
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionMF
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionMI
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionMM2Detail
(props: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/Detail.tsx:44
FunctionMO
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
FunctionMOUNTED
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionMOUNTING
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
FunctionMetricOperateBar
({ nodeSelect = {}, hideNodeScope = false, hideGridSelect = false, onChange: onChangeCallback, openM
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/index.tsx:59
MethodMetricPointVO
(String name, Long timeStamp, String value, String aggType)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/metrics/point/MetricPointVO.java:27
MethodMetricSinkPoint
()
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/common/MetricSinkPoint.java:34
MethodMetricsTimeType
(String str)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MetricsUtils.java:195
FunctionMf
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:91
← previousnext →4,601–4,700 of 6,956, ranked by callers