123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340 |
- /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
- package org.apache.shenyu.common.enums;
- import java.util.Arrays;
- import java.util.List;
- import java.util.Map;
- import java.util.stream.Collectors;
- /**
- * PluginEnum.
- */
- public enum PluginEnum {
- /**
- * Global plugin enum.
- */
- GLOBAL(-1, 0, "global"),
-
- /**
- * Tcp plugin enum.
- */
- TCP(0, 0, "tcp"),
-
- /**
- * Mqtt plugin enum.
- */
- MQTT(0, 0, "mqtt"),
- /**
- * the mock plugin enum.
- */
- MOCK(8, 0, "mock"),
-
- /**
- * the cache plugin enum.
- */
- CACHE(10, 0, "cache"),
-
- /**
- * Monitor plugin enum.
- */
- METRICS(15, 0, "metrics"),
-
- /**
- * Sign plugin enum.
- */
- SIGN(20, 0, "sign"),
-
- /**
- * Jwt plugin enum.
- */
- JWT(30, 0, "jwt"),
-
- /**
- * OAuth2 plugin enum.
- */
- OAUTH2(40, 0, "oauth2"),
- /**
- * Casdoor plugin enum.
- */
- CASDOOR(40, 0, "casdoor"),
- /**
- * Maxkey plugin enum.
- */
- MAXKEY(40, 0, "maxkey"),
- /**
- * Waf plugin enum.
- */
- WAF(50, 0, "waf"),
-
- /**
- * Rate limiter plugin enum.
- */
- RATE_LIMITER(60, 0, "rateLimiter"),
-
- /**
- * Param mapping plugin enum.
- */
- PARAM_MAPPING(70, 0, "paramMapping"),
-
- /**
- * Context path plugin enum.
- */
- CONTEXT_PATH(80, 0, "contextPath"),
-
- /**
- * Rewrite plugin enum.
- */
- REWRITE(90, 0, "rewrite"),
-
- /**
- * Cryptor request plugin enum.
- */
- CRYPTOR_REQUEST(100, 0, "cryptorRequest"),
-
- /**
- * Redirect plugin enum.
- */
- REDIRECT(110, 0, "redirect"),
-
- /**
- * Request plugin enum.
- */
- REQUEST(120, 0, "request"),
-
- /**
- * GeneralContext plugin enum.
- */
- GENERAL_CONTEXT(125, 0, "generalContext"),
-
- /**
- * Hystrix plugin enum.
- */
- HYSTRIX(130, 0, "hystrix"),
-
- /**
- * Sentinel plugin enum.
- */
- SENTINEL(140, 0, "sentinel"),
-
- /**
- * Resilence4J plugin enum.
- */
- RESILIENCE4J(150, 0, "resilience4j"),
-
- /**
- * Logging console plugin enum.
- */
- LOGGING_CONSOLE(160, 0, "loggingConsole"),
-
- /**
- * Logging RocketMQ plugin enum.
- */
- LOGGING_ROCKETMQ(170, 0, "loggingRocketMQ"),
- /**
- * Logging AliYun sls enums.
- */
- LOGGING_ALIYUN_SLS(175, 0, "loggingAliyunSls"),
- /**
- * Logging Tencent cls enums.
- */
- LOGGING_TENCENT_CLS(176, 0, "loggingTencentCls"),
- /**
- * Logging Kafka plugin enum.
- */
- LOGGING_KAFKA(180, 0, "loggingKafka"),
- /**
- * Logging Pulsar plugin enum.
- */
- LOGGING_PULSAR(185, 0, "loggingPulsar"),
- /**
- * Logging ElasticSearch plugin enum.
- */
- LOGGING_ELASTIC_SEARCH(190, 0, "loggingElasticSearch"),
- /**
- * Logging ClickHouse plugin enum.
- */
- LOGGING_CLICK_HOUSE(195, 0, "loggingClickHouse"),
-
- /**
- * Divide plugin enum.
- */
- DIVIDE(200, 0, "divide"),
-
- /**
- * springCloud plugin enum.
- */
- SPRING_CLOUD(200, 0, "springCloud"),
-
- /**
- * webSocket plugin enum.
- */
- WEB_SOCKET(200, 0, "websocket"),
-
- /**
- * Uri plugin enum.
- */
- URI(205, 0, "uri"),
-
- /**
- * Web client plugin enum.
- */
- WEB_CLIENT(210, 0, "webClient"),
-
- /**
- * Netty http client plugin enum.
- */
- NETTY_HTTP_CLIENT(210, 0, "nettyHttpClient"),
-
- /**
- * ModifyResponse plugin enum.
- */
- MODIFY_RESPONSE(220, 0, "modifyResponse"),
-
- /**
- * Param transform plugin enum.
- */
- RPC_PARAM_TRANSFORM(300, 0, "paramTransform"),
-
- /**
- * Dubbo plugin enum.
- */
- DUBBO(310, 0, "dubbo"),
-
- /**
- * Sofa plugin enum.
- */
- SOFA(310, 0, "sofa"),
-
- /**
- * Tars plugin enum.
- */
- TARS(310, 0, "tars"),
-
- /**
- * GPRC plugin enum.
- */
- GRPC(310, 0, "grpc"),
-
- /**
- * Motan plugin enum.
- */
- MOTAN(310, 0, "motan"),
- /**
- * Motan plugin enum.
- */
- BRPC(310, 0, "brpc"),
- /**
- * Cryptor response plugin enum.
- */
- CRYPTOR_RESPONSE(410, 0, "cryptorResponse"),
-
- /**
- * Response plugin enum.
- */
- RESPONSE(420, 0, "response"),
- /**
- * Key-auth plugin enum.
- */
- KEY_AUTH(430, 0, "keyAuth");
-
- /**
- * When the application starts, the plugin is cached and we can obtained by name.
- * When there are duplicate plugin names, it can be detected and resolved at compile time.
- */
- private static final Map<String, PluginEnum> PLUGIN_ENUM_MAP = Arrays.stream(PluginEnum.values()).collect(Collectors.toMap(plugin -> plugin.name, plugin -> plugin));
-
- private final int code;
-
- private final int role;
-
- private final String name;
-
- /**
- * all args constructor.
- *
- * @param code code
- * @param role role
- * @param name name
- */
- PluginEnum(final int code, final int role, final String name) {
- this.code = code;
- this.role = role;
- this.name = name;
- }
-
- /**
- * get code.
- *
- * @return code code
- */
- public int getCode() {
- return code;
- }
-
- /**
- * get role.
- *
- * @return role role
- */
- public int getRole() {
- return role;
- }
-
- /**
- * get name.
- *
- * @return name name
- */
- public String getName() {
- return name;
- }
-
- /**
- * get plugin enum by name.
- *
- * @param name plugin name.
- * @return plugin enum.
- */
- public static PluginEnum getPluginEnumByName(final String name) {
- return PLUGIN_ENUM_MAP.getOrDefault(name, PluginEnum.GLOBAL);
- }
-
- /**
- * get upstream plugin names.
- *
- * @return List string
- */
- public static List<String> getUpstreamNames() {
- return Arrays.asList(DIVIDE.name, GRPC.name, TARS.name, SPRING_CLOUD.name, DUBBO.name);
- }
- }
|