@RestService(name="transport", catalog="watch", repair=false) public class TransportWatchService extends AbstractWatchService
限定符和类型 | 字段和说明 |
---|---|
protected Application |
application |
static int |
RET_TRANSPORT_ADDR_EXISTS |
static int |
RET_TRANSPORT_ADDR_ILLEGAL |
static int |
RET_TRANSPORT_GROUP_NOT_EXISTS |
protected TransportFactory |
transportFactory |
RET_WATCH_PARAMS_ILLEGAL, RET_WATCH_RUN_EXCEPTION
构造器和说明 |
---|
TransportWatchService() |
限定符和类型 | 方法和说明 |
---|---|
RetResult |
addNode(java.lang.String group,
java.lang.String addr,
int port) |
java.util.List<TransportGroupInfo> |
listNodes() |
RetResult |
removeNode(java.lang.String group,
java.lang.String addr,
int port) |
RetResult |
test1() |
RetResult |
test2() |
RetResult |
test3() |
RetResult |
test4() |
getExecutor, runAsync
@Comment(value="\u4e0d\u5b58\u5728\u7684Group\u8282\u70b9") public static final int RET_TRANSPORT_GROUP_NOT_EXISTS
@Comment(value="\u975e\u6cd5\u7684Node\u8282\u70b9IP\u5730\u5740") public static final int RET_TRANSPORT_ADDR_ILLEGAL
@Comment(value="Node\u8282\u70b9IP\u5730\u5740\u5df2\u5b58\u5728") public static final int RET_TRANSPORT_ADDR_EXISTS
protected Application application
protected TransportFactory transportFactory
@RestMapping(name="listnodes", auth=false, comment="\u83b7\u53d6\u6240\u6709Node\u8282\u70b9") public java.util.List<TransportGroupInfo> listNodes()
@RestMapping(name="addnode", auth=false, comment="\u52a8\u6001\u589e\u52a0\u6307\u5b9aGroup\u7684Node\u8282\u70b9") public RetResult addNode(@RestParam(name="group",comment="Group\u8282\u70b9\u540d") java.lang.String group, @RestParam(name="addr",comment="\u8282\u70b9IP") java.lang.String addr, @RestParam(name="port",comment="\u8282\u70b9\u7aef\u53e3") int port) throws java.io.IOException
java.io.IOException
@RestMapping(name="removenode", auth=false, comment="\u52a8\u6001\u5220\u9664\u6307\u5b9aGroup\u7684Node\u8282\u70b9") public RetResult removeNode(@RestParam(name="group",comment="Group\u8282\u70b9\u540d") java.lang.String group, @RestParam(name="addr",comment="\u8282\u70b9IP") java.lang.String addr, @RestParam(name="port",comment="\u8282\u70b9\u7aef\u53e3") int port) throws java.io.IOException
java.io.IOException
@RestMapping(name="test1", auth=false, comment="\u9884\u7559") public RetResult test1()
@RestMapping(name="test2", auth=false, comment="\u9884\u7559") public RetResult test2()
@RestMapping(name="test3", auth=false, comment="\u9884\u7559") public RetResult test3()
@RestMapping(name="test4", auth=false, comment="\u9884\u7559") public RetResult test4()