Package io.fabric8.process.manager

Examples of io.fabric8.process.manager.Installation

82
83
84
85
86
87
88
89
90
91
92
    @Override
    public Result execute(UIExecutionContext context) throws Exception {
        Kubernetes kubernetes = getKubernetes();

        String idText = replicationControllerId.getValue();
        ReplicationControllerSchema replicationController = kubernetes.getReplicationController(idText);
        if (replicationController == null) {
            System.out.println("No replicationController for id: " + idText);
        } else {
            executeReplicationController(replicationController);
        }
View Full Code Here
60
61
62
63
64
65
66
67
68
    }

    @Override
    public Result execute(UIExecutionContext uiExecutionContext) throws Exception {
        Kubernetes kubernetes = getKubernetes();
        ServiceListSchema services = kubernetes.getServices();
        printServices(services, System.out);
        return null;
    }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
132
133
134
        if (container != null) {
            container.setProvisionResult(Container.PROVISION_DOWNLOADING);
        }
        ProcessManager procManager = processManager;
        Map<String,String> initialEnvironmentVariables = new HashMap<String, String>();
        Installation installation = createInstallation(procManager, container, options, metadata, initialEnvironmentVariables);
        if (container != null) {
            container.setProvisionResult(Container.PROVISION_FINALIZING);
        }
        if (installation != null) {
            installation.getController().start();
        }
        return metadata;
    }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
145
146
147
    }


    @Override
    public void start(Container container) {
        Installation installation = getInstallation(container);
        if (installation != null) {
            try {
                installation.getController().start();
            } catch (Exception e) {
                handleException("Starting container " + container.getId(), e);
            }
        }
    }
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
157
158
159
        }
    }

    @Override
    public void stop(Container container) {
        Installation installation = getInstallation(container);
        if (installation != null) {
            try {
                installation.getController().stop();
                container.setProvisionResult(Container.PROVISION_STOPPED);
                owner.deleteContainerZooKeeperPaths(installation, container);
            } catch (Exception e) {
                handleException("Stopping container " + container.getId(), e);
            }
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
171
172
173
        }
    }

    @Override
    public void destroy(Container container) {
        Installation installation = getInstallation(container);
        if (installation != null) {
            try {
                installation.getController().stop();
                owner.deleteContainerZooKeeperPaths(installation, container);
            } catch (Exception e) {
                LOG.info("Failed to stop process for container " + container.getId() + ". " + e, e);
            }
            processManager.uninstall(installation);
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
205
206
                if (installation.getUrl() != null && !installation.getUrl().toString().equals(config.getUrl())) {
                    // the url has changed so its a full re-installation
                    LOG.info("Re-installing " + container.getId() + " due container distribution url changed to: " + config.getUrl());
                    destroy(container);

                    Installation newInstallation = createInstallation(processManager, container, options, metadata, initialEnvironmentVariables);
                    try {
                        newInstallation.getController().install();
                        start(container);
                    } catch (Exception e) {
                        handleException("Error installing container " + container.getId(), e);
                    }
View Full Code Here
369
370
371
372
373
374
375
376
377
378
379
            if (type != null) {
                container.setType(type);
            }
        }

        Installation installation = null;
        try {
            if (ChildContainers.isJavaContainer(fabricService, options)) {
                LOG.debug("Java container detected - installing jar. Configuration: ", options);
                JavaContainerConfig javaConfig = createJavaContainerConfig(options);
                InstallOptions parameters = createJavaInstallOptions(container, metadata, options, javaConfig, environmentVariables);
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
        return null;
    }

    @Override
    public ChildContainerController getControllerForContainer(Container container) {
        Installation installation = getProcessManager().getInstallation(container.getId());
        ChildContainerController answer = null;
        if (installation != null) {
            answer = createProcessManagerController();
        }
        return answer;
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
        if (manager != null && fabric != null) {
            ImmutableMap<String, Installation> map = manager.listInstallationMap();
            ImmutableSet<Map.Entry<String, Installation>> entries = map.entrySet();
            for (Map.Entry<String, Installation> entry : entries) {
                String id = entry.getKey();
                Installation installation = entry.getValue();
                try {
                    Container container = null;
                    try {
                        container = fabric.getContainer(id);
                    } catch (Exception e) {
View Full Code Here
TOP

Related Classes of io.fabric8.process.manager.Installation

  • com.fasterxml.jackson.core.JsonFactory
  • com.fasterxml.jackson.core.JsonParser
  • com.fasterxml.jackson.databind.JsonNode
  • com.fasterxml.jackson.databind.ObjectMapper
  • com.google.mockwebserver.MockResponse
  • com.google.mockwebserver.RecordedRequest
  • io.fabric8.container.process.ProcessControllerFactoryService
  • io.fabric8.container.process.ProcessManagerController
  • io.fabric8.etcd.api.Response
  • io.fabric8.etcd.core.AbstractMockWebServerTest
    • 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.