Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GrailStack/Janus
/ functions
Functions
941 in github.com/GrailStack/Janus
⨍
Functions
941
◇
Types & classes
220
↓ 2 callers
Method
instance
()
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/RandomLoadBalancer.java:21
↓ 2 callers
Method
instance
()
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/IpConsistentHashLoadBalancer.java:21
↓ 2 callers
Method
internetIp
获取外网IP @return
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:200
↓ 2 callers
Method
isEnable
true:enable false:disable @return
janus-core/src/main/java/org/xujin/janus/core/filter/Filter.java:46
↓ 2 callers
Method
isPortUsed
check port used @param port @return
janus-sdk/src/main/java/org/xujin/janus/damon/utils/NetUtil.java:50
↓ 2 callers
Method
isValidAddress
valid Inet4Address @param address @return
janus-sdk/src/main/java/org/xujin/janus/damon/utils/IpUtil.java:34
↓ 2 callers
Method
isValidAddress
valid Inet4Address @param address @return
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:31
↓ 2 callers
Method
isValidV6Address
valid Inet6Address, if an ipv6 address is reachable. @param address @return
janus-sdk/src/main/java/org/xujin/janus/damon/utils/IpUtil.java:51
↓ 2 callers
Method
isValidV6Address
valid Inet6Address, if an ipv6 address is reachable. @param address @return
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:48
↓ 2 callers
Method
isValidate
()
janus-sdk/src/main/java/org/xujin/janus/damon/client/connect/ConnectClient.java:14
↓ 2 callers
Method
isValidate
()
janus-core/src/main/java/org/xujin/janus/core/netty/client/connect/ConnectClient.java:20
↓ 2 callers
Method
load
()
janus-config/src/main/java/org/xujin/janus/config/LocalConfigLoader.java:15
↓ 2 callers
Method
loadBalancer
(LoadBalancer loadBalancer)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:222
↓ 2 callers
Method
loadClass
(final String name, final boolean resolve)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:167
↓ 2 callers
Method
needCallBack
(boolean needCallBack)
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:103
↓ 2 callers
Method
normalizeV6Address
normalize the ipv6 Address, convert scope name to scope id. <p> e.g. convert fe80:0:0:0:894:aeec:f37d:23e1%en0 to fe80:0:0:0:894:aeec:f37d:23e1%5 <p>
janus-sdk/src/main/java/org/xujin/janus/damon/utils/IpUtil.java:79
↓ 2 callers
Method
normalizeV6Address
normalize the ipv6 Address, convert scope name to scope id. e.g. convert fe80:0:0:0:894:aeec:f37d:23e1%en0 to fe80:0:0:0:894:aeec:f37d:23e1%5 Th
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:76
↓ 2 callers
Method
onError
process retry error @param context @param throwable
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/AsyncRetryResult.java:44
↓ 2 callers
Method
payload
(Object payload)
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:108
↓ 2 callers
Method
predicate
(Predicate<FilterContext> predicate)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:242
↓ 2 callers
Method
previous
previous filter @param context
janus-core/src/main/java/org/xujin/janus/core/filter/FilterChain.java:53
↓ 2 callers
Method
protocol
(String protocol)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:217
↓ 2 callers
Method
readProperties
(String propertiesFile)
janus-config/src/main/java/org/xujin/janus/config/util/ConfigFileUtils.java:42
↓ 2 callers
Method
readYaml
(String yamlFile, Class<T> tClass)
janus-config/src/main/java/org/xujin/janus/config/util/ConfigFileUtils.java:19
↓ 2 callers
Method
removeGarbage
(String s)
janus-core/src/main/java/org/xujin/janus/core/util/NameUtils.java:31
↓ 2 callers
Method
removeHeaders
(Map<String, String> config, HttpHeaders httpHeaders)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AbstractHeaderFilter.java:24
↓ 2 callers
Method
removeRouteResilience
由于熔断器和重试器的参数无法实现动态替换,所以涉及到熔断器和重试参数变更的时候,移除路由对应的熔断器和重试器; 在执行到熔断器和重试器的filter时,如果发现找不到该路由对应的,则新建 @param routeId @param changedFilterConfigs
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:173
↓ 2 callers
Method
run
(FilterContext context, int index)
janus-core/src/main/java/org/xujin/janus/core/filter/FilterChain.java:59
↓ 2 callers
Method
run
()
janus-core/src/main/java/org/xujin/janus/core/netty/server/BaseCallback.java:8
↓ 2 callers
Method
select
(List<ServerNode> serverNode)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/IpConsistentHashLoadBalancer.java:25
↓ 2 callers
Method
sendCallBack
(String requestID, String requestMethod, int processResult, String errorMessage)
janus-config/src/main/java/org/xujin/janus/config/admin/client/AdminRequests.java:43
↓ 2 callers
Method
setHost
(String host)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:78
↓ 2 callers
Method
setId
(String id)
janus-config/src/main/java/org/xujin/janus/config/app/RouteConfig.java:61
↓ 2 callers
Method
setId
(String id)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:62
↓ 2 callers
Method
setJsonResponse
(String content, HttpResponseStatus status)
janus-core/src/main/java/org/xujin/janus/core/context/FilterContext.java:49
↓ 2 callers
Method
setKeys
(List<String> keys)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AbstractHeaderFilter.java:65
↓ 2 callers
Method
setMetadata
(Map<String, Object> metadata)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:144
↓ 2 callers
Method
setName
(String name)
janus-config/src/main/java/org/xujin/janus/config/app/FilterConfig.java:53
↓ 2 callers
Method
setProtocol
(String protocol)
janus-config/src/main/java/org/xujin/janus/config/app/RouteConfig.java:85
↓ 2 callers
Method
setResponse
(String content, HttpResponseStatus status, String contentType)
janus-core/src/main/java/org/xujin/janus/core/context/FilterContext.java:53
↓ 2 callers
Method
setRoutesConfig
(RoutesConfig routeConfigList)
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:54
↓ 2 callers
Method
sort
sort filter PRE_IN>>IN>>ENDPOINT>>OUT>>AFTER_OUT in same filterType use filter order() @param originalFilters @return
janus-core/src/main/java/org/xujin/janus/core/filter/FilterSort.java:19
↓ 2 callers
Method
update
(Route route)
janus-core/src/main/java/org/xujin/janus/core/route/RouteRepo.java:66
↓ 1 callers
Method
add
(String name, Retry retry)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:28
↓ 1 callers
Method
add
(String name, CircuitBreaker circuitBreaker)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:30
↓ 1 callers
Method
addFilter
(Filter filter)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:148
↓ 1 callers
Method
addForRoute
(Route route)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:38
↓ 1 callers
Method
addForRoute
(Route route)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:40
↓ 1 callers
Method
addListener
(Consumer consumer)
janus-config/src/main/java/org/xujin/janus/config/observer/ClassFileChangedObserver.java:14
↓ 1 callers
Method
addListener
(Consumer<ConfigChangeCmd> consumer)
janus-config/src/main/java/org/xujin/janus/config/observer/ConfigChangeObserver.java:16
↓ 1 callers
Method
addOrUpdate
(Predicate predicate)
janus-core/src/main/java/org/xujin/janus/core/predicates/PredicateRepo.java:26
↓ 1 callers
Method
addOrUpdate
(Filter filter)
janus-core/src/main/java/org/xujin/janus/core/filter/FilterRepo.java:34
↓ 1 callers
Method
asyncSend
(String remoteAddress, JanusCmdMsg cmdMsg)
janus-sdk/src/main/java/org/xujin/janus/damon/JanusCmdClient.java:81
↓ 1 callers
Method
buildEurekaConfigProperties
Build the Properties whose {@link java.util.Map.Entry entries} are retrieved from URL @param registryUrls the {@link URL url} to connect Eureka @retu
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:118
↓ 1 callers
Method
buildEurekaInstanceConfig
(String appName, String ipAddress, int port, Map<String, String> metadata)
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:68
↓ 1 callers
Method
buildFailResponse
()
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:138
↓ 1 callers
Method
buildNacosConfigProperties
(String registryUrl)
janus-registry/janus-registry-nacos/src/main/java/org/xujin/janus/registry/nacos/NacosRegistryServiceImpl.java:41
↓ 1 callers
Method
buildServiceNode
(InstanceInfo instanceInfo)
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:105
↓ 1 callers
Method
buildSuccessResponse
()
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:132
↓ 1 callers
Method
changeBaseConfig
处理路由配置变化,包括了Filter变化处理 @param routeChangeCmd
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:60
↓ 1 callers
Method
changeFilterConfig
Filter参数变更处理;单独抽一种类型处理,因为Filter可能会比较多,这样一个filter变化时可以避免传输太多数据 @param routeChangeCmd
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:115
↓ 1 callers
Method
changeGlobalFilter
全局Filter配置变化处理 @param changeItem
janus-core/src/main/java/org/xujin/janus/core/listener/ConfigChangeListener.java:42
↓ 1 callers
Method
changeOnLine
(boolean changeStatus)
janus-core/src/main/java/org/xujin/janus/core/netty/NettyServer.java:169
↓ 1 callers
Method
checkDynamicClassConfig
(DynamicClassConfig dynamicClassConfig)
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:59
↓ 1 callers
Method
checkMember
()
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:81
↓ 1 callers
Method
checkServerConfig
(NettyServerConfig nettyServerConfig)
janus-core/src/main/java/org/xujin/janus/core/netty/NettyServer.java:85
↓ 1 callers
Method
clear
()
janus-sdk/src/main/java/org/xujin/janus/damon/client/connect/ConnectClientPool.java:43
↓ 1 callers
Method
clear
()
janus-core/src/main/java/org/xujin/janus/core/netty/client/connect/ConnectClientPool.java:49
↓ 1 callers
Method
combineFilters
combine system filter and user config filters @param routeConfig @return
janus-core/src/main/java/org/xujin/janus/core/route/RouteLoader.java:72
↓ 1 callers
Method
combinePredicate
(RouteConfig routeConfig)
janus-core/src/main/java/org/xujin/janus/core/route/RouteLoader.java:114
↓ 1 callers
Method
compareTo
@param o @return
janus-core/src/main/java/org/xujin/janus/core/filter/Filter.java:74
↓ 1 callers
Method
compileGroovyFile
compile source code and register to registry
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:126
↓ 1 callers
Method
compileJavaFile
(File file)
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:139
↓ 1 callers
Method
createEurekaClient
()
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:57
↓ 1 callers
Method
createOrReplaceFile
(String path, String filterName, String content)
janus-config/src/main/java/org/xujin/janus/config/admin/processer/SendFileProcessor.java:64
↓ 1 callers
Method
defaultConfig
()
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryFactory.java:37
↓ 1 callers
Method
defaultConfig
()
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerFactory.java:42
↓ 1 callers
Method
deserialize
(byte[] bytes, Class<T> clazz)
janus-sdk/src/main/java/org/xujin/janus/damon/serializer/impl/KryoSerializer.java:59
↓ 1 callers
Method
destroy
set service status down
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/RegistryService.java:25
↓ 1 callers
Method
doCompile
(String name, String sourceCode)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:104
↓ 1 callers
Method
doExecute
(Object payload)
janus-config/src/main/java/org/xujin/janus/config/admin/processer/AbstractProcessor.java:42
↓ 1 callers
Method
doFilter
(FilterContext context)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AuthTokenFilter.java:30
↓ 1 callers
Method
doFilter
(FilterContext context)
janus-core/src/main/java/org/xujin/janus/core/filter/filters/AbstractSyncFilter.java:29
↓ 1 callers
Method
doFilter
(FilterContext context)
janus-core/src/main/java/org/xujin/janus/core/filter/filters/AbstractAsyncFilter.java:40
↓ 1 callers
Method
equals
(Object o)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:90
↓ 1 callers
Method
fail
(String message)
janus-start/src/main/java/org/xujin/janus/JanusServerApplication.java:48
↓ 1 callers
Method
files
()
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:145
↓ 1 callers
Method
forNameWithCallerClassLoader
(String name, Class<?> caller)
janus-core/src/main/java/org/xujin/janus/core/util/ClassHelper.java:19
↓ 1 callers
Method
from
(String slidingWindowType)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:94
↓ 1 callers
Method
fromFilterArg
(Map<String, String> filterArg)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:66
↓ 1 callers
Method
fromFilterArg
(Map<String, String> filterArg)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:67
↓ 1 callers
Method
getAdminName
()
janus-config/src/main/java/org/xujin/janus/config/ApplicationConfig.java:70
↓ 1 callers
Method
getAdminRemoteAddress
()
janus-config/src/main/java/org/xujin/janus/config/admin/client/AbstractRequest.java:77
↓ 1 callers
Method
getAllRetry
()
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:62
↓ 1 callers
Method
getApplicationName
()
janus-config/src/main/java/org/xujin/janus/config/ApplicationConfig.java:58
↓ 1 callers
Method
getArgs
()
janus-config/src/main/java/org/xujin/janus/config/app/PredicatesConfig.java:55
↓ 1 callers
Method
getClassLoader
(JavaFileManager.Location location)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:222
↓ 1 callers
Method
getClientConf
()
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:33
↓ 1 callers
Method
getCode
()
janus-filter/src/main/java/org/xujin/janus/filter/filters/AuthTokenFilter.java:119
↓ 1 callers
Method
getCommonTags
()
janus-monitor/src/main/java/org/xujin/janus/monitor/JanusMetricsInitializer.java:51
← previous
next →
201–300 of 941, ranked by callers