SentinelClusterConfigEntity.java

package com.alibaba.csp.sentinel.dashboard.rule.entity;

import com.alibaba.csp.sentinel.cluster.ClusterStateManager;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.RuleEntity;
import com.alibaba.csp.sentinel.slots.block.Rule;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;

import java.util.Date;
import java.util.Objects;
import java.util.Set;

/**
 * 集群机器配置
 */
@Data
public class SentinelClusterConfigEntity {
    @Data
    private static class Common implements RuleEntity {

        private String ip;

        private Integer port;

        private Date gmtCreate;

        @Override
        public Long getId() {
            return null;
        }

        @Override
        public void setId(Long id) {

        }

        @Override
        public String getApp() {
            return null;
        }

        @Override
        public Rule toRule() {
            return null;
        }

        public void initIpPort(String ip, int port) {
            setIp(ip);
            setPort(port);
        }
    }

    @Data
    public static class Mode extends Common {

        /**
         * 0-client
         * 1-server
         * -1 未指定
         * {@link  ClusterStateManager#CLUSTER_CLIENT}
         */
        private Integer mode;

        @JSONField(serialize = false)
        public boolean isClientMode() {
            return Objects.equals(this.mode, ClusterStateManager.CLUSTER_CLIENT);
        }

        @JSONField(serialize = false)
        public boolean isServerMode() {
            return Objects.equals(this.mode, ClusterStateManager.CLUSTER_SERVER);
        }
    }

    @Data
    public static class ClientConfig extends Common {
        /**
         * server的 ip
         */
        private String serverHost;
        /**
         * server的 端口
         */
        private Integer serverPort;
        /**
         * 请求超时时间 ms
         */
        private Integer requestTimeout;

        private Integer connectTimeout;
    }

    @Data
    public static class ServerFlow extends Common {
        /**
         * 最大允许qps
         */
        private Double maxAllowedQps;
    }

    @Data
    public static class ServerTransport extends Common {
        /**
         * server的 端口
         */
        private Integer serverPort;

        private Integer idleSeconds;
    }

    @Data
    public static class ServerNamespace extends Common {

        private Set<String> namespaceSet;
    }
}