Skip to content
Permalink
Browse files
Adds CDN examples
  • Loading branch information
zack-shoylev committed May 1, 2015
1 parent b607011 commit d19ff7d4ebdb52cb339bb6e1d3e5f99a82b66c5f
Showing 6 changed files with 465 additions and 14 deletions.
@@ -1,25 +1,25 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.jclouds.examples.rackspace;

import java.io.IOException;

import org.jclouds.examples.rackspace.cdn.CreateService;
import org.jclouds.examples.rackspace.cdn.UpdateService;
import org.jclouds.examples.rackspace.cloudblockstorage.*;
import org.jclouds.examples.rackspace.clouddns.*;
import org.jclouds.examples.rackspace.cloudfiles.*;
@@ -30,6 +30,8 @@
import org.jclouds.examples.rackspace.cloudservers.*;
import org.jclouds.examples.rackspace.clouddatabases.*;
import org.jclouds.examples.rackspace.autoscale.*;
import org.jclouds.examples.rackspace.cdn.*;
import org.jclouds.openstack.poppy.v1.domain.*;

/**
* This example smoke tests all of the other examples in these packages.
@@ -119,5 +121,10 @@ private void smokeTest(String[] args) throws IOException {
ProducerConsumer.main(args);
PublishSubscribe.main(args);
StreamMessages.main(args);

CreateService.main(args);
UpdateService.main(args);
PurgeServiceAssets.main(args);
DeleteService.main(args);
}
}
@@ -0,0 +1,27 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.jclouds.examples.rackspace.cdn;

/**
* Constants used by the Rackspace Examples.
*/
public class Constants {
// The provider configures jclouds To use the Rackspace Cloud (US)
// To use the Rackspace Cloud (UK) set the system property or default value to "rackspace-cdn-uk"
public static final String PROVIDER = System.getProperty("provider.cs", "rackspace-cdn-us");
}
@@ -0,0 +1,129 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.jclouds.examples.rackspace.cdn;

import static org.jclouds.examples.rackspace.cdn.Constants.PROVIDER;

import java.io.Closeable;
import java.io.IOException;
import java.net.URI;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

import org.jclouds.ContextBuilder;
import org.jclouds.logging.slf4j.config.SLF4JLoggingModule;
import org.jclouds.openstack.poppy.v1.PoppyApi;
import org.jclouds.openstack.poppy.v1.domain.Caching;
import org.jclouds.openstack.poppy.v1.domain.Domain;
import org.jclouds.openstack.poppy.v1.domain.Origin;
import org.jclouds.openstack.poppy.v1.domain.Restriction;
import org.jclouds.openstack.poppy.v1.features.FlavorApi;
import org.jclouds.openstack.poppy.v1.features.ServiceApi;

import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableSet;
import com.google.common.io.Closeables;
import com.google.common.util.concurrent.Uninterruptibles;
import com.google.inject.Module;

/**
* Demonstrates how to create a Poppy service on Rackspace (Rackspace CDN).
* Cleans up the service on fail.
*/
public class CreateService implements Closeable {
private final PoppyApi cdnApi;
private final FlavorApi flavorApi;
private final ServiceApi serviceApi;

/**
* To get a username and API key see
* http://jclouds.apache.org/guides/rackspace/
*
* The first argument (args[0]) must be your username
* The second argument (args[1]) must be your API key
*/
public static void main(String[] args) throws IOException {
CreateService createPolicy = new CreateService(args[0], args[1]);

try {
createPolicy.createService();
}
catch (Exception e) {
e.printStackTrace();
}
finally {
createPolicy.close();
}
}

public CreateService(String username, String apiKey) {
cdnApi = ContextBuilder.newBuilder(PROVIDER)
.credentials(username, apiKey)
.buildApi(PoppyApi.class);

serviceApi = cdnApi.getServiceApi();
flavorApi = cdnApi.getFlavorApi();
}

private void createService() {

String serviceId = null;
try {
URI serviceURI = serviceApi.create(
org.jclouds.openstack.poppy.v1.domain.CreateService.builder()
.name("jclouds_test_service")
.domains(
ImmutableList.of(
// Domain might be taken already - will result in failure. Use UUID in the test
// to get a random domain.
Domain.builder().domain("www.example" + UUID.randomUUID() + ".com").build()))
.origins(ImmutableList.of(
Origin.builder()
.origin("example" + UUID.randomUUID() + ".com")
.build()))
.caching(ImmutableList.<Caching>of())
.restrictions(ImmutableList.<Restriction>of())
.flavorId(flavorApi.list().first().get().getId())
.build()
);
String path = serviceURI.getPath();
serviceId = path.substring(path.lastIndexOf('/') + 1);

System.out.println("Created Poppy service with id " + serviceId);
System.out.println("Waiting for service to deploy");

// Not available in 1.9.0; available in SNAPSHOT
//ServicePredicates.awaitDeployed(serviceApi).apply(serviceApi.get(serviceId));
Uninterruptibles.sleepUninterruptibly(30, TimeUnit.SECONDS);
} catch (Exception e) {
// Cleanup on fail
if (serviceId != null) {
serviceApi.delete(serviceId);
}
}
}

/**
* Always close your service when you're done with it.
*
* Note that closing quietly like this is not necessary in Java 7.
* You would use try-with-resources in the main method instead.
*/
public void close() throws IOException {
Closeables.close(cdnApi, true);
}
}
@@ -0,0 +1,100 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.jclouds.examples.rackspace.cdn;

import static org.jclouds.examples.rackspace.cdn.Constants.PROVIDER;

import java.io.Closeable;
import java.io.IOException;

import org.jclouds.ContextBuilder;
import org.jclouds.logging.slf4j.config.SLF4JLoggingModule;
import org.jclouds.openstack.poppy.v1.PoppyApi;
import org.jclouds.openstack.poppy.v1.domain.Service;
import org.jclouds.openstack.poppy.v1.features.ServiceApi;

import com.google.common.collect.ImmutableSet;
import com.google.common.io.Closeables;
import com.google.inject.Module;

/**
* Updates a Poppy service. (Rackspace CDN).
* This operation internally diffs a target Service with a currently exsiting source service
* and automatically sends the json-patch diff to Poppy, which applies it.
*/
public class DeleteService implements Closeable {
private final PoppyApi cdnApi;
private final ServiceApi serviceApi;

/**
* To get a username and API key see
* http://jclouds.apache.org/guides/rackspace/
*
* The first argument (args[0]) must be your username
* The second argument (args[1]) must be your API key
*/
public static void main(String[] args) throws IOException {
DeleteService deleteService = new DeleteService(args[0], args[1]);

try {
deleteService.deleteService();
}
catch (Exception e) {
e.printStackTrace();
}
finally {
deleteService.close();
}
}

public DeleteService(String username, String apiKey) {
Iterable<Module> modules = ImmutableSet.<Module> of(new SLF4JLoggingModule());
cdnApi = ContextBuilder.newBuilder(PROVIDER)
.credentials(username, apiKey)
.modules(modules)
.buildApi(PoppyApi.class);

serviceApi = cdnApi.getServiceApi();
}

private void deleteService() {

String serviceId = null;
try {
// Delete all services

for (Service service : serviceApi.list().concat().toList()) {
System.out.println("Delete service " + service.getId());
serviceApi.delete(service.getId());
}

} finally {
// Do nothing on fail
}
}

/**
* Always close your service when you're done with it.
*
* Note that closing quietly like this is not necessary in Java 7.
* You would use try-with-resources in the main method instead.
*/
public void close() throws IOException {
Closeables.close(cdnApi, true);
}
}

0 comments on commit d19ff7d

Please sign in to comment.