Examples of CreateEnsembleOptions

Examples of io.fabric8.api.CreateEnsembleOptions

103
104
105
106
107
108
109
110
    @Override
    public void addToCluster(List<String> containers, Map<String, Object> options) {
        assertValid();
        RuntimeProperties sysprops = runtimeProperties.get();
        CreateEnsembleOptions createEnsembleOptions = ClusterBootstrapManager.getCreateEnsembleOptions(sysprops, options);
        addToCluster(containers, createEnsembleOptions);
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

111
112
113
114
115
116
117
118
    @Override
    public void removeFromCluster(List<String> containers, Map<String, Object> options) {
        assertValid();
        RuntimeProperties sysprops = runtimeProperties.get();
        CreateEnsembleOptions createEnsembleOptions = ClusterBootstrapManager.getCreateEnsembleOptions(sysprops, options);
        removeFromCluster(containers, createEnsembleOptions);
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

437
438
439
440
441
442
443
444
        });
    }

    public void addToCluster(List<String> containers) {
        assertValid();
        CreateEnsembleOptions options = CreateEnsembleOptions.builder().zookeeperPassword(fabricService.get().getZookeeperPassword()).build();
        addToCluster(containers, options);
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

467
468
469
470
471
472
473
474
    public void removeFromCluster(List<String> containers) {
        assertValid();
        Builder<?> builder = CreateEnsembleOptions.builder();
        String password = fabricService.get().getZookeeperPassword();
        CreateEnsembleOptions options = builder.zookeeperPassword(password).build();
        removeFromCluster(containers, options);
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

87
88
89
90
91
92
93
94
95
96
97
    @Test
    public void testLocalFabricCluster() throws Exception {

        Builder<?> builder = CreateEnsembleOptions.builder().agentEnabled(false).clean(true).zookeeperPassword(ADMIN_PASSWORD).waitForProvision(false);
        CreateEnsembleOptions options = builder.build();

        ZooKeeperClusterBootstrap bootstrap = ServiceLocator.getRequiredService(ZooKeeperClusterBootstrap.class);
        bootstrap.create(options);

        FabricService fabricService = ServiceLocator.getRequiredService(FabricService.class);
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
        if (userProps.get(username) == null) {
            userProps.put(username, password + "," + role);
        }

        CreateEnsembleOptions answer = builder.users(userProps).withUser(username, password, role).build();
        LOG.debug("Creating ensemble with options: {}", answer);

        System.setProperty(ZkDefs.GLOBAL_RESOLVER_PROPERTY, answer.getGlobalResolver());
        System.setProperty(ZkDefs.LOCAL_RESOLVER_PROPERTY, answer.getResolver());
        System.setProperty(ZkDefs.MANUAL_IP, answer.getManualIp());
        System.setProperty(ZkDefs.BIND_ADDRESS, answer.getBindAddress());
        System.setProperty(ZkDefs.MINIMUM_PORT, "" + answer.getMinimumPort());
        System.setProperty(ZkDefs.MAXIMUM_PORT, "" + answer.getMaximumPort());

        return answer;
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

140
141
142
143
144
145
146
147
    @Override
    public void createCluster(Map<String, Object> options) {
        assertValid();
        RuntimeProperties sysprops = runtimeProperties.get();
        CreateEnsembleOptions createEnsembleOptions = ClusterBootstrapManager.getCreateEnsembleOptions(sysprops, options);
        bootstrap.get().create(createEnsembleOptions);
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

34
35
36
37
38
39
40
41
    @Test
    public void testBootstrapConfiguration() {
        ServiceLocator.awaitService(BootstrapComplete.class);
        BootstrapConfiguration bootConfig = ServiceLocator.getRequiredService(BootstrapConfiguration.class);
        CreateEnsembleOptions options = bootConfig.getBootstrapOptions();
        Assert.assertFalse("Ensemble start", options.isEnsembleStart());
    }
View Full Code Here

Examples of io.fabric8.api.CreateEnsembleOptions

96
97
98
99
100
101
102
103
104
105
106
    @Activate
    void activate(BundleContext bundleContext, Map<String, ?> configuration) throws Exception {
        this.bundleContext = bundleContext;
        this.configurer.configure(configuration, this);
        BootstrapConfiguration bootConfig = bootstrapConfiguration.get();
        CreateEnsembleOptions options = bootConfig.getBootstrapOptions();
        if (options.isEnsembleStart()) {
            startBundles(options);
        }
        activateComponent();
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.