MCPcopy Create free account

hub / github.com/GrailStack/Janus / functions

Functions941 in github.com/GrailStack/Janus

↓ 2 callersMethodinstance
()
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/RandomLoadBalancer.java:21
↓ 2 callersMethodinstance
()
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/IpConsistentHashLoadBalancer.java:21
↓ 2 callersMethodinternetIp
获取外网IP @return
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:200
↓ 2 callersMethodisEnable
true:enable false:disable @return
janus-core/src/main/java/org/xujin/janus/core/filter/Filter.java:46
↓ 2 callersMethodisPortUsed
check port used @param port @return
janus-sdk/src/main/java/org/xujin/janus/damon/utils/NetUtil.java:50
↓ 2 callersMethodisValidAddress
valid Inet4Address @param address @return
janus-sdk/src/main/java/org/xujin/janus/damon/utils/IpUtil.java:34
↓ 2 callersMethodisValidAddress
valid Inet4Address @param address @return
janus-core/src/main/java/org/xujin/janus/core/netty/utils/IpUtils.java:31
↓ 2 callersMethodisValidV6Address
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 callersMethodisValidV6Address
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 callersMethodisValidate
()
janus-sdk/src/main/java/org/xujin/janus/damon/client/connect/ConnectClient.java:14
↓ 2 callersMethodisValidate
()
janus-core/src/main/java/org/xujin/janus/core/netty/client/connect/ConnectClient.java:20
↓ 2 callersMethodload
()
janus-config/src/main/java/org/xujin/janus/config/LocalConfigLoader.java:15
↓ 2 callersMethodloadBalancer
(LoadBalancer loadBalancer)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:222
↓ 2 callersMethodloadClass
(final String name, final boolean resolve)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:167
↓ 2 callersMethodneedCallBack
(boolean needCallBack)
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:103
↓ 2 callersMethodnormalizeV6Address
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 callersMethodnormalizeV6Address
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 callersMethodonError
process retry error @param context @param throwable
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/AsyncRetryResult.java:44
↓ 2 callersMethodpayload
(Object payload)
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:108
↓ 2 callersMethodpredicate
(Predicate<FilterContext> predicate)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:242
↓ 2 callersMethodprevious
previous filter @param context
janus-core/src/main/java/org/xujin/janus/core/filter/FilterChain.java:53
↓ 2 callersMethodprotocol
(String protocol)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:217
↓ 2 callersMethodreadProperties
(String propertiesFile)
janus-config/src/main/java/org/xujin/janus/config/util/ConfigFileUtils.java:42
↓ 2 callersMethodreadYaml
(String yamlFile, Class<T> tClass)
janus-config/src/main/java/org/xujin/janus/config/util/ConfigFileUtils.java:19
↓ 2 callersMethodremoveGarbage
(String s)
janus-core/src/main/java/org/xujin/janus/core/util/NameUtils.java:31
↓ 2 callersMethodremoveHeaders
(Map<String, String> config, HttpHeaders httpHeaders)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AbstractHeaderFilter.java:24
↓ 2 callersMethodremoveRouteResilience
由于熔断器和重试器的参数无法实现动态替换,所以涉及到熔断器和重试参数变更的时候,移除路由对应的熔断器和重试器; 在执行到熔断器和重试器的filter时,如果发现找不到该路由对应的,则新建 @param routeId @param changedFilterConfigs
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:173
↓ 2 callersMethodrun
(FilterContext context, int index)
janus-core/src/main/java/org/xujin/janus/core/filter/FilterChain.java:59
↓ 2 callersMethodrun
()
janus-core/src/main/java/org/xujin/janus/core/netty/server/BaseCallback.java:8
↓ 2 callersMethodselect
(List<ServerNode> serverNode)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/loadbalancer/IpConsistentHashLoadBalancer.java:25
↓ 2 callersMethodsendCallBack
(String requestID, String requestMethod, int processResult, String errorMessage)
janus-config/src/main/java/org/xujin/janus/config/admin/client/AdminRequests.java:43
↓ 2 callersMethodsetHost
(String host)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:78
↓ 2 callersMethodsetId
(String id)
janus-config/src/main/java/org/xujin/janus/config/app/RouteConfig.java:61
↓ 2 callersMethodsetId
(String id)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:62
↓ 2 callersMethodsetJsonResponse
(String content, HttpResponseStatus status)
janus-core/src/main/java/org/xujin/janus/core/context/FilterContext.java:49
↓ 2 callersMethodsetKeys
(List<String> keys)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AbstractHeaderFilter.java:65
↓ 2 callersMethodsetMetadata
(Map<String, Object> metadata)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:144
↓ 2 callersMethodsetName
(String name)
janus-config/src/main/java/org/xujin/janus/config/app/FilterConfig.java:53
↓ 2 callersMethodsetProtocol
(String protocol)
janus-config/src/main/java/org/xujin/janus/config/app/RouteConfig.java:85
↓ 2 callersMethodsetResponse
(String content, HttpResponseStatus status, String contentType)
janus-core/src/main/java/org/xujin/janus/core/context/FilterContext.java:53
↓ 2 callersMethodsetRoutesConfig
(RoutesConfig routeConfigList)
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:54
↓ 2 callersMethodsort
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 callersMethodupdate
(Route route)
janus-core/src/main/java/org/xujin/janus/core/route/RouteRepo.java:66
↓ 1 callersMethodadd
(String name, Retry retry)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:28
↓ 1 callersMethodadd
(String name, CircuitBreaker circuitBreaker)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:30
↓ 1 callersMethodaddFilter
(Filter filter)
janus-core/src/main/java/org/xujin/janus/core/route/Route.java:148
↓ 1 callersMethodaddForRoute
(Route route)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:38
↓ 1 callersMethodaddForRoute
(Route route)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:40
↓ 1 callersMethodaddListener
(Consumer consumer)
janus-config/src/main/java/org/xujin/janus/config/observer/ClassFileChangedObserver.java:14
↓ 1 callersMethodaddListener
(Consumer<ConfigChangeCmd> consumer)
janus-config/src/main/java/org/xujin/janus/config/observer/ConfigChangeObserver.java:16
↓ 1 callersMethodaddOrUpdate
(Predicate predicate)
janus-core/src/main/java/org/xujin/janus/core/predicates/PredicateRepo.java:26
↓ 1 callersMethodaddOrUpdate
(Filter filter)
janus-core/src/main/java/org/xujin/janus/core/filter/FilterRepo.java:34
↓ 1 callersMethodasyncSend
(String remoteAddress, JanusCmdMsg cmdMsg)
janus-sdk/src/main/java/org/xujin/janus/damon/JanusCmdClient.java:81
↓ 1 callersMethodbuildEurekaConfigProperties
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 callersMethodbuildEurekaInstanceConfig
(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 callersMethodbuildFailResponse
()
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:138
↓ 1 callersMethodbuildNacosConfigProperties
(String registryUrl)
janus-registry/janus-registry-nacos/src/main/java/org/xujin/janus/registry/nacos/NacosRegistryServiceImpl.java:41
↓ 1 callersMethodbuildServiceNode
(InstanceInfo instanceInfo)
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:105
↓ 1 callersMethodbuildSuccessResponse
()
janus-sdk/src/main/java/org/xujin/janus/damon/exchange/JanusCmdMsg.java:132
↓ 1 callersMethodchangeBaseConfig
处理路由配置变化,包括了Filter变化处理 @param routeChangeCmd
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:60
↓ 1 callersMethodchangeFilterConfig
Filter参数变更处理;单独抽一种类型处理,因为Filter可能会比较多,这样一个filter变化时可以避免传输太多数据 @param routeChangeCmd
janus-core/src/main/java/org/xujin/janus/core/listener/RouteChangeListener.java:115
↓ 1 callersMethodchangeGlobalFilter
全局Filter配置变化处理 @param changeItem
janus-core/src/main/java/org/xujin/janus/core/listener/ConfigChangeListener.java:42
↓ 1 callersMethodchangeOnLine
(boolean changeStatus)
janus-core/src/main/java/org/xujin/janus/core/netty/NettyServer.java:169
↓ 1 callersMethodcheckDynamicClassConfig
(DynamicClassConfig dynamicClassConfig)
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:59
↓ 1 callersMethodcheckMember
()
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:81
↓ 1 callersMethodcheckServerConfig
(NettyServerConfig nettyServerConfig)
janus-core/src/main/java/org/xujin/janus/core/netty/NettyServer.java:85
↓ 1 callersMethodclear
()
janus-sdk/src/main/java/org/xujin/janus/damon/client/connect/ConnectClientPool.java:43
↓ 1 callersMethodclear
()
janus-core/src/main/java/org/xujin/janus/core/netty/client/connect/ConnectClientPool.java:49
↓ 1 callersMethodcombineFilters
combine system filter and user config filters @param routeConfig @return
janus-core/src/main/java/org/xujin/janus/core/route/RouteLoader.java:72
↓ 1 callersMethodcombinePredicate
(RouteConfig routeConfig)
janus-core/src/main/java/org/xujin/janus/core/route/RouteLoader.java:114
↓ 1 callersMethodcompareTo
@param o @return
janus-core/src/main/java/org/xujin/janus/core/filter/Filter.java:74
↓ 1 callersMethodcompileGroovyFile
compile source code and register to registry
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:126
↓ 1 callersMethodcompileJavaFile
(File file)
janus-core/src/main/java/org/xujin/janus/core/dynamic/DynamicFileManger.java:139
↓ 1 callersMethodcreateEurekaClient
()
janus-registry/janus-registry-eureka/src/main/java/org/xujin/janus/registry/eurake/EurekaRegistryServiceImpl.java:57
↓ 1 callersMethodcreateOrReplaceFile
(String path, String filterName, String content)
janus-config/src/main/java/org/xujin/janus/config/admin/processer/SendFileProcessor.java:64
↓ 1 callersMethoddefaultConfig
()
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryFactory.java:37
↓ 1 callersMethoddefaultConfig
()
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerFactory.java:42
↓ 1 callersMethoddeserialize
(byte[] bytes, Class<T> clazz)
janus-sdk/src/main/java/org/xujin/janus/damon/serializer/impl/KryoSerializer.java:59
↓ 1 callersMethoddestroy
set service status down
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/RegistryService.java:25
↓ 1 callersMethoddoCompile
(String name, String sourceCode)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:104
↓ 1 callersMethoddoExecute
(Object payload)
janus-config/src/main/java/org/xujin/janus/config/admin/processer/AbstractProcessor.java:42
↓ 1 callersMethoddoFilter
(FilterContext context)
janus-filter/src/main/java/org/xujin/janus/filter/filters/AuthTokenFilter.java:30
↓ 1 callersMethoddoFilter
(FilterContext context)
janus-core/src/main/java/org/xujin/janus/core/filter/filters/AbstractSyncFilter.java:29
↓ 1 callersMethoddoFilter
(FilterContext context)
janus-core/src/main/java/org/xujin/janus/core/filter/filters/AbstractAsyncFilter.java:40
↓ 1 callersMethodequals
(Object o)
janus-registry/janus-registry-base/src/main/java/org/xujin/janus/registry/ServerNode.java:90
↓ 1 callersMethodfail
(String message)
janus-start/src/main/java/org/xujin/janus/JanusServerApplication.java:48
↓ 1 callersMethodfiles
()
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:145
↓ 1 callersMethodforNameWithCallerClassLoader
(String name, Class<?> caller)
janus-core/src/main/java/org/xujin/janus/core/util/ClassHelper.java:19
↓ 1 callersMethodfrom
(String slidingWindowType)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:94
↓ 1 callersMethodfromFilterArg
(Map<String, String> filterArg)
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:66
↓ 1 callersMethodfromFilterArg
(Map<String, String> filterArg)
janus-core/src/main/java/org/xujin/janus/core/resilience/breaker/BreakerRepo.java:67
↓ 1 callersMethodgetAdminName
()
janus-config/src/main/java/org/xujin/janus/config/ApplicationConfig.java:70
↓ 1 callersMethodgetAdminRemoteAddress
()
janus-config/src/main/java/org/xujin/janus/config/admin/client/AbstractRequest.java:77
↓ 1 callersMethodgetAllRetry
()
janus-core/src/main/java/org/xujin/janus/core/resilience/retry/RetryRepo.java:62
↓ 1 callersMethodgetApplicationName
()
janus-config/src/main/java/org/xujin/janus/config/ApplicationConfig.java:58
↓ 1 callersMethodgetArgs
()
janus-config/src/main/java/org/xujin/janus/config/app/PredicatesConfig.java:55
↓ 1 callersMethodgetClassLoader
(JavaFileManager.Location location)
janus-core/src/main/java/org/xujin/janus/core/dynamic/JdkCompiler.java:222
↓ 1 callersMethodgetClientConf
()
janus-config/src/main/java/org/xujin/janus/config/ServerConfig.java:33
↓ 1 callersMethodgetCode
()
janus-filter/src/main/java/org/xujin/janus/filter/filters/AuthTokenFilter.java:119
↓ 1 callersMethodgetCommonTags
()
janus-monitor/src/main/java/org/xujin/janus/monitor/JanusMetricsInitializer.java:51
← previousnext →201–300 of 941, ranked by callers