Package com.alibaba.otter.shared.common.model.config.node

Examples of com.alibaba.otter.shared.common.model.config.node.Node

91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
        TransformRandomLoadBanlance transform = new TransformRandomLoadBanlance(pipelineId);
        transform.setNodeMonitor(nodeMonitor);
        sleep(500L);
        try {
            Node n1 = transform.next();
            Node n2 = transform.next();
            Node n3 = transform.next();
            Node n4 = transform.next();
            System.out.printf("n1[%s] n2[%s] n3[%s] n4[%s]", n1.getId(), n2.getId(), n3.getId(), n4.getId());
            want.bool(targetList.contains(n1)).is(true);
            want.bool(targetList.contains(n2)).is(true);
            want.bool(targetList.contains(n3)).is(true);
            want.bool(targetList.contains(n4)).is(true);
        } catch (InterruptedException e) {
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
        });

        ExtractRoundRobinLoadBalance extract = new ExtractRoundRobinLoadBalance(pipelineId);
        extract.setNodeMonitor(nodeMonitor);
        try {
            Node n1 = extract.next();
            Node n2 = extract.next();
            Node n3 = extract.next();
            Node n4 = extract.next();
            System.out.printf("n1[%s] n2[%s] n3[%s] n4[%s]", n1.getId(), n2.getId(), n3.getId(), n4.getId());
            want.bool(sourceList.contains(n1)).is(true);
            want.bool(sourceList.contains(n2)).is(true);
            want.bool(sourceList.contains(n3)).is(true);
            want.bool(sourceList.contains(n4)).is(true);
        } catch (InterruptedException e) {
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
        });

        TransformRoundRobinLoadBalance transform = new TransformRoundRobinLoadBalance(pipelineId);
        transform.setNodeMonitor(nodeMonitor);
        try {
            Node n1 = transform.next();
            Node n2 = transform.next();
            Node n3 = transform.next();
            Node n4 = transform.next();
            System.out.printf("n1[%s] n2[%s] n3[%s] n4[%s]", n1.getId(), n2.getId(), n3.getId(), n4.getId());
            want.bool(targetList.contains(n1)).is(true);
            want.bool(targetList.contains(n2)).is(true);
            want.bool(targetList.contains(n3)).is(true);
            want.bool(targetList.contains(n4)).is(true);
        } catch (InterruptedException e) {
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
        System.setProperty("nid", "1");
    }

    @Test
    public void test_node() {
        final Node node = new Node();
        Mockit.setUpMock(NodeCommmunicationClient.class, new Object() {

            @Mock
            public Object callManager(final Event event) {
                if (event instanceof FindNodeEvent) {
                    Long nid = ((FindNodeEvent) event).getNid();
                    node.setId(nid);
                }

                return node;
            }
        });

        Node cnode = configClientService.currentNode();
        want.bool(cnode.getId() == 1L);
        Node fnode = configClientService.findNode(2L);
        want.bool(fnode.getId() == 2L);
    }
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
        System.setProperty("nid", "1");
    }

    @Test
    public void test_node() {
        Node cnode = configClientService.currentNode();
        System.out.println(cnode);
        want.bool(cnode.getId() == 1L).is(true);
        Node fnode = configClientService.findNode(2L);
        System.out.println(fnode);
        want.bool(fnode.getId() == 2L);

        fnode = configClientService.findNode(2L);
        System.out.println(fnode);
        want.bool(fnode.getId() == 2L);
    }
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
262
263
264
        ZooKeeperClient.registerNotification(sessionExpired);
    }

    // 判断本机ip是否和node.getIp()相同
    private void checkNidVaild(String nid) {
        Node node = configClientService.currentNode();
        String hostIp = AddressUtils.getHostIp();
        String nodeIp = node.getIp();
        int nodePort = node.getPort().intValue();
        if (!AddressUtils.isHostIp(nodeIp)) {
            throw new IllegalArgumentException(
                                               String.format("node[%s] ip[%s] port[%s] , but your host ip[%s] is not matched!",
                                                             nid, nodeIp, nodePort, hostIp));
        }
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
        Assert.notNull(configClientService);
        Assert.notNull(urlFormat);
    }

    public String getUrl(Long pipelineId, String filePath) {
        Node node = configClientService.currentNode();
        Pipeline pipeline = configClientService.findPipeline(pipelineId);
        String ip = node.getIp();
        if (node.getParameters().getUseExternalIp() || pipeline.getParameters().getUseExternalIp()) {
            ip = node.getParameters().getExternalIp();

            if (StringUtils.isEmpty(ip)) {
                throw new ArchiveException(String.format("pipelineId:%s useExternalIp by nid[%s] has no external ip",
                    String.valueOf(pipelineId),
                    String.valueOf(node.getId())));
            }
        }

        Integer port = node.getParameters().getDownloadPort();// 注意为其下载端口
        if (port == null || port < 0) {
            port = defaultDownloadPort;
        }

        return MessageFormat.format(urlFormat, ip, String.valueOf(port), filePath);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
50
51
    private String              SERVER_URL           = "service:jmx:rmi://127.0.0.1/jndi/rmi://127.0.0.1:{0}/mbean";
    private boolean             alwaysCreateRegistry = false;
    private ConfigClientService configClientService;

    public void afterPropertiesSet() throws JMException, IOException {
        Node node = configClientService.currentNode();
        int port = node.getPort().intValue() + 1;
        Integer mbeanPort = node.getParameters().getMbeanPort();
        if (mbeanPort != null && mbeanPort != 0) {// 做个兼容处理，<=4.2.2版本没有mbeanPort设置
            port = mbeanPort;
        }

        String serviceUrl = MessageFormat.format(SERVER_URL, String.valueOf(port));
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
            });
        }
    }

    private String convertToAddress(Long nid) {
        Node node = ArbitrateConfigUtils.findNode(nid);
        if (node.getParameters().getUseExternalIp()) {
            return node.getParameters().getExternalIp() + ":" + node.getPort();
        } else {
            return node.getIp() + ":" + node.getPort();
        }
    }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
     * @param context
     * @throws WebxException
     */
    public void execute(@Param("nodeId") Long nodeId, @Param("pageIndex") int pageIndex,
                        @Param("searchKey") String searchKey, Context context, Navigator nav) throws Exception {
        Node node = nodeService.findById(nodeId);
        if (node.getStatus().isStart()) {
            nav.redirectTo(WebConstant.ERROR_FORBIDDEN_Link);
            return;
        }

        List<AutoKeeperCluster> zkClusters = autoKeeperClusterService.listAutoKeeperClusters();
View Full Code Here
TOP

Related Classes of com.alibaba.otter.shared.common.model.config.node.Node

  • com.alibaba.otter.manager.biz.common.arbitrate.ArbitrateConfigImpl
  • com.alibaba.otter.manager.biz.config.node.impl.NodeServiceImpl
  • com.alibaba.otter.manager.biz.remote.impl.NodeMBeanServiceImpl
  • com.alibaba.otter.manager.web.home.module.action.NodeAction
  • com.alibaba.otter.manager.web.home.module.action.PipelineAction
  • com.alibaba.otter.manager.web.home.module.screen.EditNode
  • com.alibaba.otter.manager.web.home.module.screen.NodeInfo
  • com.alibaba.otter.node.common.communication.NodeCommmunicationClient
  • com.alibaba.otter.node.common.config.ConfigClientServiceIntegration
  • com.alibaba.otter.node.common.config.ConfigClientServiceTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.