PluginEnum.java 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340
  1. /*
  2. * Licensed to the Apache Software Foundation (ASF) under one or more
  3. * contributor license agreements. See the NOTICE file distributed with
  4. * this work for additional information regarding copyright ownership.
  5. * The ASF licenses this file to You under the Apache License, Version 2.0
  6. * (the "License"); you may not use this file except in compliance with
  7. * the License. You may obtain a copy of the License at
  8. *
  9. * http://www.apache.org/licenses/LICENSE-2.0
  10. *
  11. * Unless required by applicable law or agreed to in writing, software
  12. * distributed under the License is distributed on an "AS IS" BASIS,
  13. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. * See the License for the specific language governing permissions and
  15. * limitations under the License.
  16. */
  17. package org.apache.shenyu.common.enums;
  18. import java.util.Arrays;
  19. import java.util.List;
  20. import java.util.Map;
  21. import java.util.stream.Collectors;
  22. /**
  23. * PluginEnum.
  24. */
  25. public enum PluginEnum {
  26. /**
  27. * Global plugin enum.
  28. */
  29. GLOBAL(-1, 0, "global"),
  30. /**
  31. * Tcp plugin enum.
  32. */
  33. TCP(0, 0, "tcp"),
  34. /**
  35. * Mqtt plugin enum.
  36. */
  37. MQTT(0, 0, "mqtt"),
  38. /**
  39. * the mock plugin enum.
  40. */
  41. MOCK(8, 0, "mock"),
  42. /**
  43. * the cache plugin enum.
  44. */
  45. CACHE(10, 0, "cache"),
  46. /**
  47. * Monitor plugin enum.
  48. */
  49. METRICS(15, 0, "metrics"),
  50. /**
  51. * Sign plugin enum.
  52. */
  53. SIGN(20, 0, "sign"),
  54. /**
  55. * Jwt plugin enum.
  56. */
  57. JWT(30, 0, "jwt"),
  58. /**
  59. * OAuth2 plugin enum.
  60. */
  61. OAUTH2(40, 0, "oauth2"),
  62. /**
  63. * Casdoor plugin enum.
  64. */
  65. CASDOOR(40, 0, "casdoor"),
  66. /**
  67. * Maxkey plugin enum.
  68. */
  69. MAXKEY(40, 0, "maxkey"),
  70. /**
  71. * Waf plugin enum.
  72. */
  73. WAF(50, 0, "waf"),
  74. /**
  75. * Rate limiter plugin enum.
  76. */
  77. RATE_LIMITER(60, 0, "rateLimiter"),
  78. /**
  79. * Param mapping plugin enum.
  80. */
  81. PARAM_MAPPING(70, 0, "paramMapping"),
  82. /**
  83. * Context path plugin enum.
  84. */
  85. CONTEXT_PATH(80, 0, "contextPath"),
  86. /**
  87. * Rewrite plugin enum.
  88. */
  89. REWRITE(90, 0, "rewrite"),
  90. /**
  91. * Cryptor request plugin enum.
  92. */
  93. CRYPTOR_REQUEST(100, 0, "cryptorRequest"),
  94. /**
  95. * Redirect plugin enum.
  96. */
  97. REDIRECT(110, 0, "redirect"),
  98. /**
  99. * Request plugin enum.
  100. */
  101. REQUEST(120, 0, "request"),
  102. /**
  103. * GeneralContext plugin enum.
  104. */
  105. GENERAL_CONTEXT(125, 0, "generalContext"),
  106. /**
  107. * Hystrix plugin enum.
  108. */
  109. HYSTRIX(130, 0, "hystrix"),
  110. /**
  111. * Sentinel plugin enum.
  112. */
  113. SENTINEL(140, 0, "sentinel"),
  114. /**
  115. * Resilence4J plugin enum.
  116. */
  117. RESILIENCE4J(150, 0, "resilience4j"),
  118. /**
  119. * Logging console plugin enum.
  120. */
  121. LOGGING_CONSOLE(160, 0, "loggingConsole"),
  122. /**
  123. * Logging RocketMQ plugin enum.
  124. */
  125. LOGGING_ROCKETMQ(170, 0, "loggingRocketMQ"),
  126. /**
  127. * Logging AliYun sls enums.
  128. */
  129. LOGGING_ALIYUN_SLS(175, 0, "loggingAliyunSls"),
  130. /**
  131. * Logging Tencent cls enums.
  132. */
  133. LOGGING_TENCENT_CLS(176, 0, "loggingTencentCls"),
  134. /**
  135. * Logging Kafka plugin enum.
  136. */
  137. LOGGING_KAFKA(180, 0, "loggingKafka"),
  138. /**
  139. * Logging Pulsar plugin enum.
  140. */
  141. LOGGING_PULSAR(185, 0, "loggingPulsar"),
  142. /**
  143. * Logging ElasticSearch plugin enum.
  144. */
  145. LOGGING_ELASTIC_SEARCH(190, 0, "loggingElasticSearch"),
  146. /**
  147. * Logging ClickHouse plugin enum.
  148. */
  149. LOGGING_CLICK_HOUSE(195, 0, "loggingClickHouse"),
  150. /**
  151. * Divide plugin enum.
  152. */
  153. DIVIDE(200, 0, "divide"),
  154. /**
  155. * springCloud plugin enum.
  156. */
  157. SPRING_CLOUD(200, 0, "springCloud"),
  158. /**
  159. * webSocket plugin enum.
  160. */
  161. WEB_SOCKET(200, 0, "websocket"),
  162. /**
  163. * Uri plugin enum.
  164. */
  165. URI(205, 0, "uri"),
  166. /**
  167. * Web client plugin enum.
  168. */
  169. WEB_CLIENT(210, 0, "webClient"),
  170. /**
  171. * Netty http client plugin enum.
  172. */
  173. NETTY_HTTP_CLIENT(210, 0, "nettyHttpClient"),
  174. /**
  175. * ModifyResponse plugin enum.
  176. */
  177. MODIFY_RESPONSE(220, 0, "modifyResponse"),
  178. /**
  179. * Param transform plugin enum.
  180. */
  181. RPC_PARAM_TRANSFORM(300, 0, "paramTransform"),
  182. /**
  183. * Dubbo plugin enum.
  184. */
  185. DUBBO(310, 0, "dubbo"),
  186. /**
  187. * Sofa plugin enum.
  188. */
  189. SOFA(310, 0, "sofa"),
  190. /**
  191. * Tars plugin enum.
  192. */
  193. TARS(310, 0, "tars"),
  194. /**
  195. * GPRC plugin enum.
  196. */
  197. GRPC(310, 0, "grpc"),
  198. /**
  199. * Motan plugin enum.
  200. */
  201. MOTAN(310, 0, "motan"),
  202. /**
  203. * Motan plugin enum.
  204. */
  205. BRPC(310, 0, "brpc"),
  206. /**
  207. * Cryptor response plugin enum.
  208. */
  209. CRYPTOR_RESPONSE(410, 0, "cryptorResponse"),
  210. /**
  211. * Response plugin enum.
  212. */
  213. RESPONSE(420, 0, "response"),
  214. /**
  215. * Key-auth plugin enum.
  216. */
  217. KEY_AUTH(430, 0, "keyAuth");
  218. /**
  219. * When the application starts, the plugin is cached and we can obtained by name.
  220. * When there are duplicate plugin names, it can be detected and resolved at compile time.
  221. */
  222. private static final Map<String, PluginEnum> PLUGIN_ENUM_MAP = Arrays.stream(PluginEnum.values()).collect(Collectors.toMap(plugin -> plugin.name, plugin -> plugin));
  223. private final int code;
  224. private final int role;
  225. private final String name;
  226. /**
  227. * all args constructor.
  228. *
  229. * @param code code
  230. * @param role role
  231. * @param name name
  232. */
  233. PluginEnum(final int code, final int role, final String name) {
  234. this.code = code;
  235. this.role = role;
  236. this.name = name;
  237. }
  238. /**
  239. * get code.
  240. *
  241. * @return code code
  242. */
  243. public int getCode() {
  244. return code;
  245. }
  246. /**
  247. * get role.
  248. *
  249. * @return role role
  250. */
  251. public int getRole() {
  252. return role;
  253. }
  254. /**
  255. * get name.
  256. *
  257. * @return name name
  258. */
  259. public String getName() {
  260. return name;
  261. }
  262. /**
  263. * get plugin enum by name.
  264. *
  265. * @param name plugin name.
  266. * @return plugin enum.
  267. */
  268. public static PluginEnum getPluginEnumByName(final String name) {
  269. return PLUGIN_ENUM_MAP.getOrDefault(name, PluginEnum.GLOBAL);
  270. }
  271. /**
  272. * get upstream plugin names.
  273. *
  274. * @return List string
  275. */
  276. public static List<String> getUpstreamNames() {
  277. return Arrays.asList(DIVIDE.name, GRPC.name, TARS.name, SPRING_CLOUD.name, DUBBO.name);
  278. }
  279. }