MCPcopy Create free account

hub / github.com/bafuka/HotArmor / functions

Functions307 in github.com/bafuka/HotArmor

↓ 1 callersMethodstart
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteConsumer.java:33
↓ 1 callersMethodsubscribe
订阅配置变更 @param listener 配置变更监听器,接收新的规则列表
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/ConfigSource.java:21
↓ 1 callersMethodsubscribe
订阅缓存失效消息 @param listener 消息监听器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/BroadcastNotifier.java:32
↓ 1 callersMethodsubscribePromotion
订阅热点晋升消息 @param listener 热点晋升监听器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/BroadcastNotifier.java:39
↓ 1 callersMethodunsubscribe
取消订阅
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/BroadcastNotifier.java:44
↓ 1 callersMethodupdateRule
更新规则(比对差异) @param oldRule 旧规则 @param newRule 新规则
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:464
↓ 1 callersMethodupdateRules
更新规则(增量更新) 会自动比对差异,决定是热更新参数还是重建实例 @param rules 新的规则列表
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/RuleManager.java:31
↓ 1 callersMethodvalidateConsistencyConfig
验证一致性配置
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:406
↓ 1 callersMethodvalidateL1Config
验证 L1 缓存配置
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:302
↓ 1 callersMethodvalidateL2Config
验证 L2 过滤配置
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:329
↓ 1 callersMethodvalidateL3Config
验证 L3 热点配置
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:351
↓ 1 callersMethodvalidateL4Config
验证 L4 加载配置
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:373
MethodDefaultConsistencyManager
(L1CacheEngine<?> l1CacheEngine, L4SafeLoader<?> l4SafeLoader,
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/DefaultConsistencyManager.java:67
MethodDefaultHotArmorAspectHandler
(L1CacheEngine<Object> l1CacheEngine, L2NoiseFilter l2NoiseFilter,
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/impl/DefaultHotArmorAspectHandler.java:48
MethodDefaultRuleManager
(CaffeineL1CacheEngine<?> l1CacheEngine, CaffeineL2NoiseFilter l2NoiseFilter,
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:67
MethodHotArmorAspect
(SpelExpressionParser spelParser, HotArmorAspectHandler aspectHandler)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/HotArmorAspect.java:31
MethodHotArmorAutoConfiguration
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:53
MethodHotArmorConfigInitializer
(ConfigSource configSource, RuleManager ruleManager)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:246
MethodHotArmorLoadException
(String message, Throwable cause, HotArmorContext context,
hotarmor-core/src/main/java/cn/bafuka/hotarmor/exception/HotArmorLoadException.java:24
MethodInternalMessageListener
(InvalidationListener invalidationListener, PromotionListener promotionL
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RedisBroadcastNotifier.java:169
MethodLoadFailureReason
(String description)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/exception/HotArmorLoadException.java:71
MethodLocalYamlConfigSource
(HotArmorProperties properties)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/LocalYamlConfigSource.java:29
MethodMessageListener
(RocketMQDelayedDeleteConsumer consumer)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteConsumer.java:87
MethodNacosConfigSource
(String serverAddr, String namespace, String dataId, String group)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/NacosConfigSource.java:59
MethodRedisBroadcastNotifier
(RedisTemplate<String, Object> redisTemplate, RedisMessageListenerContainer
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RedisBroadcastNotifier.java:53
MethodRedissonL4SafeLoader
(RedissonClient redissonClient, RedisTemplate<String, Object> redisTemplate)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/RedissonL4SafeLoader.java:41
MethodRocketMQDelayedDeleteConsumer
(L4SafeLoader<?> l4SafeLoader)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteConsumer.java:29
MethodRocketMQDelayedDeleteProducer
(RocketMQTemplate rocketMQTemplate, String topic)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteProducer.java:27
MethodaroundCache
拦截 @HotArmorCache 注解
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/HotArmorAspect.java:39
MethodaroundEvict
拦截 @HotArmorEvict 注解
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/HotArmorAspect.java:90
Methodbenchmark
压测接口:批量查询商品(模拟热点访问)
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/ProductController.java:90
Methodbenchmark
压测接口:批量查询用户(模拟热点访问)
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/UserController.java:102
MethodcaffeineL1CacheEngine
L1 缓存引擎
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:69
MethodcaffeineL2NoiseFilter
L2 噪音过滤器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:78
MethodclearAll
清空所有规则
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/RuleManager.java:58
MethodconsistencyManager
一致性管理器(DelayedDeleteProducer 为可选依赖)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:146
MethodcreateProduct
创建商品
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/ProductController.java:52
MethodcreateProduct
创建商品 @param product 商品信息 @return 创建的商品
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/ProductService.java:58
MethodcreateUser
创建用户
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/UserController.java:64
MethodcreateUser
创建用户 @param user 用户信息 @return 创建的用户
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/UserService.java:74
MethoddeleteFromRedis
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/RedissonL4SafeLoader.java:207
MethoddeleteImmediately
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteProducer.java:58
MethoddeleteProduct
删除商品
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/ProductController.java:78
MethoddeleteProduct
删除商品 @param productId 商品ID
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/ProductService.java:83
MethoddeleteUser
删除用户
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/UserController.java:90
MethoddeleteUser
删除用户 @param userId 用户ID
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/UserService.java:100
Methodget
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL1CacheEngine.java:74
MethodgetAllCounters
获取所有计数器(用于监控) @return 计数器映射
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL2NoiseFilter.java:142
MethodgetAllProducts
查询所有商品
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/ProductController.java:39
MethodgetAllProducts
查询所有商品 @return 商品列表
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/ProductService.java:48
MethodgetAllRules
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:190
MethodgetAllRules
获取所有规则(用于监控) @return 规则映射
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/SentinelL3HotspotDetector.java:120
MethodgetAllUsers
查询所有用户
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/UserController.java:51
MethodgetAllUsers
查询所有用户 @return 用户列表
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/UserService.java:64
MethodgetCount
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL2NoiseFilter.java:122
MethodgetCurrentConfig
获取当前配置(同步方式) @return 当前的规则列表
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/ConfigSource.java:28
MethodgetCurrentConfig
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/NacosConfigSource.java:97
MethodgetCurrentQps
获取当前 QPS @param resource 资源名称 @return 当前 QPS 值
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/L3HotspotDetector.java:41
MethodgetCurrentQps
(String resource)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/SentinelL3HotspotDetector.java:89
MethodgetDescription
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/exception/HotArmorLoadException.java:75
MethodgetExecutor
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/NacosConfigSource.java:183
MethodgetProductById
根据ID查询商品(热点商品会被晋升到L1缓存) @param productId 商品ID @return 商品信息
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/ProductService.java:31
MethodgetRule
查看具体资源的配置
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/DiagnosticController.java:113
MethodgetRule
(String resource)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:185
MethodgetSentinelRules
查看 Sentinel 规则
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/DiagnosticController.java:52
MethodgetStats
获取命中率等统计信息 @param resource 资源名称 @return 统计信息
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/L1CacheEngine.java:49
MethodgetStats
(String resource)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL1CacheEngine.java:136
MethodgetType
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/LocalYamlConfigSource.java:63
MethodgetType
()
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spi/impl/NacosConfigSource.java:124
MethodgetUserById
根据ID查询用户(使用HotArmor缓存) 这个方法会经过三级漏斗防护 @param userId 用户ID @return 用户信息
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/UserService.java:32
MethodgetUserById
(Long userId)
hotarmor-core/src/test/java/cn/bafuka/hotarmor/spel/DefaultSpelExpressionParserTest.java:280
MethodgetUserByIdAndType
(Long userId, String type)
hotarmor-core/src/test/java/cn/bafuka/hotarmor/spel/DefaultSpelExpressionParserTest.java:287
MethodgetUserByUsername
根据用户名查询用户
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/UserController.java:39
MethodgetUserByUsername
根据用户名查询用户 @param username 用户名 @return 用户信息
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/service/UserService.java:50
MethodhandleCache
(ProceedingJoinPoint joinPoint, HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/impl/DefaultHotArmorAspectHandler.java:60
MethodhandleDelete
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteConsumer.java:45
MethodhandleEvict
(ProceedingJoinPoint joinPoint, HotArmorContext context, boolean beforeInvocation
hotarmor-core/src/main/java/cn/bafuka/hotarmor/aspect/impl/DefaultHotArmorAspectHandler.java:103
MethodhandlePromotion
(HotArmorContext context, Object value)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/DefaultConsistencyManager.java:171
MethodhandleUpdate
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/DefaultConsistencyManager.java:99
Methodhealth
健康检查
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/controller/DiagnosticController.java:84
MethodhotArmorAspect
AOP 切面
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:229
MethodhotArmorAspectHandler
切面处理器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:209
MethodhotArmorConfigInitializer
配置源初始化器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:197
Methodinitialize
初始化规则管理器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/RuleManager.java:16
Methodinitialize
初始化一致性管理器
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/ConsistencyManager.java:14
Methodinvalidate
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL1CacheEngine.java:110
MethodinvalidateResource
(String resource)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/CaffeineL1CacheEngine.java:125
MethodisHotspot
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/SentinelL3HotspotDetector.java:34
Methodload
(HotArmorContext context, Function<Object, V> dbLoader)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/dataplane/impl/RedissonL4SafeLoader.java:56
MethodloadRules
(List<HotArmorRule> rules)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/control/impl/DefaultRuleManager.java:91
MethodlocalYamlConfigSource
本地 YAML 配置源
hotarmor-core/src/main/java/cn/bafuka/hotarmor/autoconfigure/HotArmorAutoConfiguration.java:188
Methodmain
(String[] args)
hotarmor-example/src/main/java/cn/bafuka/hotarmor/example/HotArmorExampleApplication.java:14
MethodonInvalidate
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/DefaultConsistencyManager.java:274
MethodonMessage
(String message)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RocketMQDelayedDeleteConsumer.java:91
MethodonMessage
(Message message, byte[] pattern)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RedisBroadcastNotifier.java:177
MethodonPromote
(HotArmorContext context, Object value)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/DefaultConsistencyManager.java:297
MethodparseCondition
(String expression, ProceedingJoinPoint joinPoint, Class<?> targetClass, Stri
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spel/DefaultSpelExpressionParser.java:57
MethodparseKey
(String expression, ProceedingJoinPoint joinPoint, Class<?> targetClass, String meth
hotarmor-core/src/main/java/cn/bafuka/hotarmor/spel/DefaultSpelExpressionParser.java:33
Methodpublish
(HotArmorContext context)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RedisBroadcastNotifier.java:61
MethodpublishPromotion
(HotArmorContext context, Object value)
hotarmor-core/src/main/java/cn/bafuka/hotarmor/consistency/impl/RedisBroadcastNotifier.java:81
← previousnext →101–200 of 307, ranked by callers