前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >聊聊consul的NewService

聊聊consul的NewService

原创
作者头像
code4it
修改2019-07-25 10:09:53
7150
修改2019-07-25 10:09:53
举报
文章被收录于专栏:码匠的流水账

本文主要研究一下consul的NewService

NewService

consul-api-1.4.1-sources.jar!/com/ecwid/consul/v1/agent/model/NewService.java

代码语言:javascript
复制
public class NewService {
​
    @SerializedName("ID")
    private String id;
​
    @SerializedName("Name")
    private String name;
​
    @SerializedName("Tags")
    private List<String> tags;
​
    @SerializedName("Address")
    private String address;
​
    @SerializedName("Meta")
    private Map<String, String> meta;
​
    @SerializedName("Port")
    private Integer port;
​
    @SerializedName("EnableTagOverride")
    private Boolean enableTagOverride;
​
    @SerializedName("Check")
    private Check check;
​
    @SerializedName("Checks")
    private List<Check> checks;
​
    public String getId() {
        return id;
    }
​
    public void setId(String id) {
        this.id = id;
    }
​
    public String getName() {
        return name;
    }
​
    public void setName(String name) {
        this.name = name;
    }
​
    public List<String> getTags() {
        return tags;
    }
​
    public void setTags(List<String> tags) {
        this.tags = tags;
    }
​
    public String getAddress() {
        return address;
    }
​
    public void setAddress(String address) {
        this.address = address;
    }
​
    public Map<String, String> getMeta() {
        return meta;
    }
​
    public void setMeta(Map<String, String> meta) {
        this.meta = meta;
    }
​
    public Integer getPort() {
        return port;
    }
​
    public void setPort(Integer port) {
        this.port = port;
    }
​
    public Boolean getEnableTagOverride() {
        return enableTagOverride;
    }
​
    public void setEnableTagOverride(Boolean enableTagOverride) {
        this.enableTagOverride = enableTagOverride;
    }
​
    public Check getCheck() {
        return check;
    }
​
    public void setCheck(Check check) {
        this.check = check;
    }
​
    public List<Check> getChecks() {
        return checks;
    }
​
    public void setChecks(List<Check> checks) {
        this.checks = checks;
    }
​
    @Override
    public String toString() {
        return "NewService{" +
                "id='" + id + '\'' +
                ", name='" + name + '\'' +
                ", tags=" + tags +
                ", address='" + address + '\'' +
                ", meta=" + meta +
                ", port=" + port +
                ", enableTagOverride=" + enableTagOverride +
                ", check=" + check +
                ", checks=" + checks +
                '}';
    }
​
}
  • NewService定义了id、name、tags、address、meta、port、enableTagOverride、check、checks属性

NewService.Check

consul-api-1.4.1-sources.jar!/com/ecwid/consul/v1/agent/model/NewService.java

代码语言:javascript
复制
    public static class Check {
​
        @SerializedName("Script")
        private String script;
​
        @SerializedName("Interval")
        private String interval;
​
        @SerializedName("TTL")
        private String ttl;
​
        @SerializedName("HTTP")
        private String http;
​
        @SerializedName("Method")
        private String method;
​
        @SerializedName("Header")
        private Map<String, List<String>> header;
​
        @SerializedName("TCP")
        private String tcp;
​
        @SerializedName("Timeout")
        private String timeout;
​
        @SerializedName("DeregisterCriticalServiceAfter")
        private String deregisterCriticalServiceAfter;
​
        @SerializedName("TLSSkipVerify")
        private Boolean tlsSkipVerify;
​
        @SerializedName("Status")
        private String status;
​
        public String getScript() {
            return script;
        }
​
        public void setScript(String script) {
            this.script = script;
        }
​
        public String getInterval() {
            return interval;
        }
​
        public void setInterval(String interval) {
            this.interval = interval;
        }
​
        public String getTtl() {
            return ttl;
        }
​
        public void setTtl(String ttl) {
            this.ttl = ttl;
        }
​
        public String getHttp() {
            return http;
        }
​
        public void setHttp(String http) {
            this.http = http;
        }
​
        public String getMethod() {
            return method;
        }
​
        public void setMethod(String method) {
            this.method = method;
        }
​
        public Map<String, List<String>> getHeader() {
            return header;
        }
​
        public void setHeader(Map<String, List<String>> header) {
            this.header = header;
        }
​
        public String getTcp() {
            return tcp;
        }
​
        public void setTcp(String tcp) {
            this.tcp = tcp;
        }
​
        public String getTimeout() {
            return timeout;
        }
​
        public void setTimeout(String timeout) {
            this.timeout = timeout;
        }
​
        public String getDeregisterCriticalServiceAfter() {
            return deregisterCriticalServiceAfter;
        }
​
        public void setDeregisterCriticalServiceAfter(String deregisterCriticalServiceAfter) {
            this.deregisterCriticalServiceAfter = deregisterCriticalServiceAfter;
        }
​
        public Boolean getTlsSkipVerify() {
            return tlsSkipVerify;
        }
​
        public void setTlsSkipVerify(Boolean tlsSkipVerify) {
            this.tlsSkipVerify = tlsSkipVerify;
        }
​
        public String getStatus() {
            return status;
        }
​
        public void setStatus(String status) {
            this.status = status;
        }
​
        @Override
        public String toString() {
            return "Check{" +
                    "script='" + script + '\'' +
                    ", interval='" + interval + '\'' +
                    ", ttl='" + ttl + '\'' +
                    ", http='" + http + '\'' +
                    ", method='" + method + '\'' +
                    ", header=" + header +
                    ", tcp='" + tcp + '\'' +
                    ", timeout='" + timeout + '\'' +
                    ", deregisterCriticalServiceAfter='" + deregisterCriticalServiceAfter + '\'' +
                    ", tlsSkipVerify=" + tlsSkipVerify +
                    ", status='" + status + '\'' +
                    '}';
        }
    }
  • NewService.Check定义了script、interval、ttl、http、method、header、tcp、timeout、deregisterCriticalServiceAfter、tlsSkipVerify、status属性

AgentConsulClient

consul-api-1.4.1-sources.jar!/com/ecwid/consul/v1/agent/AgentConsulClient.java

代码语言:javascript
复制
public final class AgentConsulClient implements AgentClient {
​
    private final ConsulRawClient rawClient;
​
    //......
​
    public Response<Void> agentServiceRegister(NewService newService) {
        return agentServiceRegister(newService, null);
    }
​
    public Response<Void> agentServiceRegister(NewService newService, String token) {
        UrlParameters tokenParam = token != null ? new SingleUrlParameters("token", token) : null;
​
        String json = GsonFactory.getGson().toJson(newService);
        RawResponse rawResponse = rawClient.makePutRequest("/v1/agent/service/register", json, tokenParam);
​
        if (rawResponse.getStatusCode() == 200) {
            return new Response<Void>(null, rawResponse);
        } else {
            throw new OperationException(rawResponse);
        }
    }
​
    //......
}
  • AgentConsulClient的agentServiceRegister方法使用rawClient向/v1/agent/service/register这个url发送put请求,把newService的json数据发送过去

小结

  • NewService定义了id、name、tags、address、meta、port、enableTagOverride、check、checks属性
  • NewService.Check定义了script、interval、ttl、http、method、header、tcp、timeout、deregisterCriticalServiceAfter、tlsSkipVerify、status属性
  • AgentConsulClient的agentServiceRegister方法使用rawClient向/v1/agent/service/register这个url发送put请求,把newService的json数据发送过去

doc

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • NewService
  • NewService.Check
  • AgentConsulClient
  • 小结
  • doc
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档