本文整理汇总了Java中org.cloudfoundry.client.lib.domain.CloudService类的典型用法代码示例。如果您正苦于以下问题:Java CloudService类的具体用法?Java CloudService怎么用?Java CloudService使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
CloudService类属于org.cloudfoundry.client.lib.domain包,在下文中一共展示了CloudService类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createService
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Override
public void createService(CloudService service) {
assertSpaceProvided("create service");
Assert.notNull(service, "Service must not be null");
Assert.notNull(service.getName(), "Service name must not be null");
Assert.notNull(service.getLabel(), "Service label must not be null");
Assert.notNull(service.getPlan(), "Service plan must not be null");
CloudServicePlan cloudServicePlan = findPlanForService(service);
HashMap<String, Object> serviceRequest = new HashMap<String, Object>();
serviceRequest.put("space_guid", sessionSpace.getMeta().getGuid());
serviceRequest.put("name", service.getName());
serviceRequest.put("service_plan_guid", cloudServicePlan.getMeta().getGuid());
getRestTemplate().postForObject(getUrl("/v2/service_instances"), serviceRequest, String.class);
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:17,代码来源:CloudControllerClientImpl.java
示例2: getServices
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Override
public List<CloudService> getServices() {
Map<String, Object> urlVars = new HashMap<String, Object>();
String urlPath = "/v2";
if (sessionSpace != null) {
urlVars.put("space", sessionSpace.getMeta().getGuid());
urlPath = urlPath + "/spaces/{space}";
}
urlPath = urlPath + "/service_instances?inline-relations-depth=1&return_user_provided_service_instances=true";
List<Map<String, Object>> resourceList = getAllResources(urlPath, urlVars);
List<CloudService> services = new ArrayList<CloudService>();
for (Map<String, Object> resource : resourceList) {
if (hasEmbeddedResource(resource, "service_plan")) {
fillInEmbeddedResource(resource, "service_plan", "service");
}
services.add(resourceMapper.mapResource(resource, CloudService.class));
}
return services;
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:20,代码来源:CloudControllerClientImpl.java
示例3: createUserProvidedServiceDelegate
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
private void createUserProvidedServiceDelegate(CloudService service, Map<String, Object> credentials, String syslogDrainUrl) {
assertSpaceProvided("create service");
Assert.notNull(credentials, "Service credentials must not be null");
Assert.notNull(service, "Service must not be null");
Assert.notNull(service.getName(), "Service name must not be null");
Assert.isNull(service.getLabel(), "Service label is not valid for user-provided services");
Assert.isNull(service.getProvider(), "Service provider is not valid for user-provided services");
Assert.isNull(service.getVersion(), "Service version is not valid for user-provided services");
Assert.isNull(service.getPlan(), "Service plan is not valid for user-provided services");
HashMap<String, Object> serviceRequest = new HashMap<>();
serviceRequest.put("space_guid", sessionSpace.getMeta().getGuid());
serviceRequest.put("name", service.getName());
serviceRequest.put("credentials", credentials);
if (syslogDrainUrl != null && !syslogDrainUrl.equals("")) {
serviceRequest.put("syslog_drain_url", syslogDrainUrl);
}
getRestTemplate().postForObject(getUrl("/v2/user_provided_service_instances"), serviceRequest, String.class);
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:21,代码来源:CloudControllerClientImpl.java
示例4: getAppsBoundToService
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private List<UUID> getAppsBoundToService(CloudService cloudService) {
List<UUID> appGuids = new ArrayList<UUID>();
String urlPath = "/v2";
Map<String, Object> urlVars = new HashMap<String, Object>();
if (sessionSpace != null) {
urlVars.put("space", sessionSpace.getMeta().getGuid());
urlPath = urlPath + "/spaces/{space}";
}
urlVars.put("q", "name:" + cloudService.getName());
urlPath = urlPath + "/service_instances?q={q}";
List<Map<String, Object>> resourceList = getAllResources(urlPath, urlVars);
for (Map<String, Object> resource : resourceList) {
fillInEmbeddedResource(resource, "service_bindings");
List<Map<String, Object>> bindings = CloudEntityResourceMapper.getEntityAttribute(resource, "service_bindings", List.class);
for (Map<String, Object> binding : bindings) {
String appId = CloudEntityResourceMapper.getEntityAttribute(binding, "app_guid", String.class);
if (appId != null) {
appGuids.add(UUID.fromString(appId));
}
}
}
return appGuids;
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:25,代码来源:CloudControllerClientImpl.java
示例5: mapServiceInstanceResource
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private CloudServiceInstance mapServiceInstanceResource(Map<String, Object> resource) {
CloudServiceInstance serviceInstance = new CloudServiceInstance(getMeta(resource), getNameOfResource(resource));
serviceInstance.setType(getEntityAttribute(resource, "type", String.class));
serviceInstance.setDashboardUrl(getEntityAttribute(resource, "dashboard_url", String.class));
serviceInstance.setCredentials(getEntityAttribute(resource, "credentials", Map.class));
Map<String, Object> servicePlanResource = getEmbeddedResource(resource, "service_plan");
if (servicePlanResource != null) {
serviceInstance.setServicePlan(mapServicePlanResource(servicePlanResource));
}
CloudService service = mapServiceResource(resource);
serviceInstance.setService(service);
List<Map<String, Object>> bindingsResource = getEmbeddedResourceList(getEntity(resource), "service_bindings");
List<CloudServiceBinding> bindings = new ArrayList<>(bindingsResource.size());
for (Map<String, Object> bindingResource : bindingsResource) {
bindings.add(mapServiceBinding(bindingResource));
}
serviceInstance.setBindings(bindings);
return serviceInstance;
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:26,代码来源:CloudEntityResourceMapper.java
示例6: getCreateDeleteService
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Test
public void getCreateDeleteService() throws MalformedURLException {
String serviceName = "mysql-test";
createMySqlService(serviceName);
CloudService service = connectedClient.getService(serviceName);
assertNotNull(service);
assertEquals(serviceName, service.getName());
assertTimeWithinRange("Creation time should be very recent", service.getMeta().getCreated().getTime(), FIVE_MINUTES);
connectedClient.deleteService(serviceName);
List<CloudService> services = connectedClient.getServices();
assertNotNull(services);
assertEquals(0, services.size());
}
开发者ID:SAP,项目名称:cf-java-client-sap,代码行数:17,代码来源:CloudFoundryClientTest.java
示例7: createOrUpdateServices
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
private Map<String, ServiceOperationType> createOrUpdateServices(ExecutionWrapper execution, CloudFoundryOperations client,
List<CloudServiceExtended> services, Map<String, CloudService> existingServices, Map<String, List<ServiceKey>> serviceKeys,
Map<String, List<String>> defaultTags) throws SLException, FileStorageException {
Map<String, ServiceOperationType> triggeredOperations = new TreeMap<>();
for (CloudServiceExtended service : services) {
CloudService existingService = existingServices.get(service.getName());
List<String> defaultTagsForService = defaultTags.get(service.getLabel());
ServiceOperationType triggeredOperation = createOrUpdateService(execution, client, service, existingService,
defaultTagsForService);
triggeredOperations.put(service.getName(), triggeredOperation);
List<ServiceKey> serviceKeysForService = serviceKeys.getOrDefault(service.getName(), Collections.emptyList());
createOrUpdateServiceKeys(serviceKeysForService, service, existingService, client, execution);
}
return triggeredOperations;
}
开发者ID:SAP,项目名称:cf-mta-deploy-service,代码行数:17,代码来源:CreateOrUpdateServicesStep.java
示例8: attemptToUpdateServiceParameters
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
private void attemptToUpdateServiceParameters(CloudFoundryOperations client, String serviceName, Map<String, Object> parameters) {
assertServiceAttributes(serviceName, parameters);
CloudService service = client.getService(serviceName);
RestTemplate restTemplate = getRestTemplate(client);
String cloudControllerUrl = getCloudControllerUrl(client);
if (service.isUserProvided()) {
attemptToUpdateServiceParameter(SERVICE_CREDENTIALS, parameters, restTemplate,
getUrl(cloudControllerUrl, getUpdateServiceUrl(USER_PROVIDED_SERVICE_INSTANCES_URL, service.getMeta().getGuid().toString(),
ACCEPTS_INCOMPLETE_FALSE)));
return;
}
attemptToUpdateServiceParameter(SERVICE_PARAMETERS, parameters, restTemplate, getUrl(cloudControllerUrl,
getUpdateServiceUrl(SERVICE_INSTANCES_URL, service.getMeta().getGuid().toString(), ACCEPTS_INCOMPLETE_FALSE)));
}
开发者ID:SAP,项目名称:cf-mta-deploy-service,代码行数:18,代码来源:ServiceUpdater.java
示例9: getDatabaseServiceFromServiceKey
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
private DatabaseService getDatabaseServiceFromServiceKey(CloudServiceKey cloudServiceKey, DatabaseRef databaseRef, String org, String space) {
CloudService cloudService = cloudServiceKey.getService();
DatabaseService databaseService = new DatabaseService(
cloudService.getMeta().getGuid().toString(),
cloudService.getName(),
org,
space,
cloudServiceKey.getMeta().getGuid().toString()
);
if (!this.databaseServiceRepo.exists(cloudService.getMeta().getGuid().toString())) {
databaseService.setDatabaseRef(databaseRef);
this.databaseServiceRepo.save(databaseService);
return databaseService;
}
DatabaseService databaseServiceDao = this.databaseServiceRepo.findOne(cloudService.getMeta().getGuid().toString());
this.updateDatabaseService(databaseService, databaseServiceDao);
return databaseServiceDao;
}
开发者ID:orange-cloudfoundry,项目名称:db-dumper-service,代码行数:20,代码来源:DatabaseRefManager.java
示例10: createService
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
protected void createService(CloudService cloudService) {
try {
logger.info("Creating service {} from {} with plan {} ", cloudService.getName(), cloudService.getLabel(), cloudService.getPlan());
cfClientToPopulate.createService(cloudService);
if (!this.isFinishedCreatingService(cloudService)) {
fail("Cannot create service '" + cloudService.getName() + "'");
}
} catch (HttpServerErrorException e) {
if (!e.getStatusCode().equals(HttpStatus.BAD_GATEWAY)) {
throw e;
} else {
String skipMessage = "Bad gateway error, skipping test";
this.reportIntegration.setSkipped(true);
this.reportIntegration.setSkippedReason(skipMessage);
assumeTrue(skipMessage, false);
}
}
}
开发者ID:orange-cloudfoundry,项目名称:db-dumper-service,代码行数:20,代码来源:AbstractIntegrationWithRealCfClientTest.java
示例11: when_getting_user_service_it_should_give_the_correct_one_or_null_if_user_dont_have_access
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Test
public void when_getting_user_service_it_should_give_the_correct_one_or_null_if_user_dont_have_access() {
CloudService cloudService = cloudFoundryServiceKeyManager.getUserService(cloudServiceName, "token", "org", "space");
assertThat(cloudService).isNotNull();
assertThat(cloudService.getName()).isEqualTo(cloudServiceName);
cloudService = cloudFoundryServiceKeyManager.getUserService(cloudServiceName, "token", null, null);
assertThat(cloudService).isNotNull();
assertThat(cloudService.getName()).isEqualTo(cloudServiceName);
cloudService = cloudFoundryServiceKeyManager.getUserService(CloudFoundryClientFake.SERVICE_NOT_ACCESSIBLE, "token", "org", "space");
assertThat(cloudService).isNull();
cloudService = cloudFoundryServiceKeyManager.getUserService(CloudFoundryClientFake.SERVICE_NOT_ACCESSIBLE, "token", null, null);
assertThat(cloudService).isNull();
}
开发者ID:orange-cloudfoundry,项目名称:db-dumper-service,代码行数:17,代码来源:CloudFoundryServiceKeyManagerTest.java
示例12: checkSafeTarget
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
public static void checkSafeTarget(HarnessProperties cred) throws Exception {
// To avoid junits deleting contents of a target by accident, ensure
// the target is empty
CloudFoundryOperations ops = createExternalClient(cred);
List<CloudApplication> apps = ops.getApplications();
if (apps != null && !apps.isEmpty()) {
throw CloudErrorUtil.toCoreException(NLS.bind(
"Empty Cloud target required to run junits. Existing number of applications {0} found in: server = {1}, org = {2}, space = {3}",
new Object[] { apps.size(), cred.getApiUrl(), cred.getOrg(), cred.getSpace() }));
}
List<CloudService> services = ops.getServices();
if (services != null && !services.isEmpty()) {
throw CloudErrorUtil.toCoreException(NLS.bind(
"Empty Cloud target required to run junits. Existing number of services {0} found in: server = {1}, org = {2}, space = {3}",
new Object[] { services.size(), cred.getApiUrl(), cred.getOrg(), cred.getSpace() }));
}
}
开发者ID:eclipse,项目名称:cft,代码行数:21,代码来源:CloudFoundryTestFixture.java
示例13: copy
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
/**
* Copy the deployment info, with any known mutable values set as copies as
* well. Therefore, if an info property is a list of values (e.g. list of
* bound services), modifying the list in the copy will not affect the list
* of values in the original version.
* @return non-null copy of this info.
*/
public ApplicationDeploymentInfo copy() {
ApplicationDeploymentInfo info = new ApplicationDeploymentInfo(getDeploymentName());
info.setMemory(getMemory());
info.setStaging(getStaging());
info.setInstances(getInstances());
info.setArchive(getArchive());
if (getServices() != null) {
info.setServices(new ArrayList<CloudService>(getServices()));
}
if (getUris() != null) {
info.setUris(new ArrayList<String>(getUris()));
}
if (getEnvVariables() != null) {
info.setEnvVariables(new ArrayList<EnvironmentVariable>(getEnvVariables()));
}
return info;
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:30,代码来源:ApplicationDeploymentInfo.java
示例14: getDeleteServicesRequest
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
BaseClientRequest<List<CloudService>> getDeleteServicesRequest(final List<String> services) {
return new BehaviourRequest<List<CloudService>>(Messages.DockerFoundryServerBehaviour_DELETE_SERVICES) {
@Override
protected List<CloudService> doRun(DockerClient client, SubMonitor progress) throws CoreException {
SubMonitor serviceProgress = SubMonitor.convert(progress, services.size());
for (String service : services) {
serviceProgress.subTask(NLS.bind(Messages.DockerFoundryServerBehaviour_DELETING_SERVICE, service));
// client.deleteService(service);
serviceProgress.worked(1);
}
// return client.getServices();
return null;
}
};
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:18,代码来源:DockerFoundryServerBehaviour.java
示例15: getCreateServicesRequest
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
BaseClientRequest<List<CloudService>> getCreateServicesRequest(final CloudService[] services) {
return new BehaviourRequest<List<CloudService>>(Messages.DockerFoundryServerBehaviour_CREATE_SERVICES) {
@Override
protected List<CloudService> doRun(DockerClient client, SubMonitor progress) throws CoreException {
SubMonitor serviceProgress = SubMonitor.convert(progress, services.length);
for (CloudService service : services) {
serviceProgress.subTask(NLS.bind(Messages.DockerFoundryServerBehaviour_CREATING_SERVICE,
service.getName()));
// client.createService(service);
serviceProgress.worked(1);
}
// return client.getServices();
return null;
}
};
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:19,代码来源:DockerFoundryServerBehaviour.java
示例16: compare
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Override
public int compare(Viewer viewer, Object e1, Object e2) {
if (e1 instanceof DockerContainerInfo && e1 instanceof DockerContainerInfo) {
// InstanceStats stats1 = ((DockerContainerInfo) e1).getStats();
// InstanceStats stats2 = ((InstanceStatsAndInfo) e2).getStats();
// return stats1.getId().compareTo(stats2.getId());
DockerContainerInfo d1 = (DockerContainerInfo)e1;
DockerContainerInfo d2 = (DockerContainerInfo)e2;
return d1.hashCode() - d2.hashCode();
}
if (e1 instanceof CloudService && e2 instanceof CloudService) {
CloudService service1 = (CloudService) e1;
CloudService service2 = (CloudService) e2;
return service1.getName().compareTo(service2.getName());
}
if (e1 instanceof IModule && e2 instanceof IModule) {
IModule m1 = (IModule) e1;
IModule m2 = (IModule) e2;
return m1.getName().compareTo(m2.getName());
}
return super.compare(viewer, e1, e2);
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:23,代码来源:DockerFoundryViewerSorter.java
示例17: getColumnText
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
public String getColumnText(Object element, int columnIndex) {
if (element instanceof CloudService) {
CloudService service = (CloudService) element;
switch (columnIndex) {
case 0:
return service.getName();
case 1:
return service.getLabel();
case 2:
return service.getPlan();
case 3:
return service.getVersion();
}
}
return null;
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:17,代码来源:ServicesLabelProvider.java
示例18: validateDrop
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@Override
public boolean validateDrop(Object target, int operation, TransferData type) {
overrideOperation(DND.DROP_COPY);
// if (application == null)
// return false;
if (operation == DND.DROP_COPY || operation == DND.DROP_DEFAULT) {
if (LocalSelectionTransfer.getTransfer().isSupportedType(type)) {
IStructuredSelection selection = (IStructuredSelection) LocalSelectionTransfer.getTransfer()
.getSelection();
Object[] objects = selection.toArray();
for (Object obj : objects) {
if (obj instanceof CloudService) {
return true;
}
}
}
}
return false;
}
开发者ID:osswangxining,项目名称:dockerfoundry,代码行数:21,代码来源:ServicesViewerDropListener.java
示例19: tearDown
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
@After
public void tearDown() {
List<CloudApplication> cloudApps = cfClient.getApplications();
for (CloudApplication cloudApp : cloudApps) {
if (cloudApp.getName().contains(getTestAppName())) {
cfClient.deleteApplication(cloudApp.getName());
}
}
List<CloudService> cloudServices = cfClient.getServices();
for (CloudService cloudService : cloudServices) {
if (cloudService.getName().contains(getTestAppName())) {
cfClient.deleteService(cloudService.getName());
}
}
clearDomain(getTestDomainName(), true);
clearDomain(getDefaultDomain(), false);
cfClient.logout();
}
开发者ID:orange-cloudfoundry,项目名称:elpaaso-core,代码行数:22,代码来源:AbstractCfAdapterIT.java
示例20: createService
import org.cloudfoundry.client.lib.domain.CloudService; //导入依赖的package包/类
/**
* Creates a new service in Bluemix.
* Note that you can get the services and plans available in Bluemix through the
* "cf marketplace" command.
*
* @param label
* the service's label (e.g. "sqldb").
* @param name
* the service's name.
* @param plan
* the service's plan.
*
* @throws BluemixClientException
*/
public void createService(String label, String name, String plan)
throws BluemixClientException {
if (null == label || null == name || null == plan) {
String message = "Invalid arguments. label, name and plan can not be null.";
throw new BluemixClientException(message);
}
LOGGER.info("Creating a new service...");
CloudService service = new CloudService();
service.setLabel(label);
service.setName(name);
service.setPlan(plan);
client.createService(service);
}
开发者ID:marianafranco,项目名称:bluemix-cf-client,代码行数:30,代码来源:BluemixClient.java
注:本文中的org.cloudfoundry.client.lib.domain.CloudService类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论