本文整理汇总了Java中org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest类的典型用法代码示例。如果您正苦于以下问题：Java CreateServiceInstanceBindingRequest类的具体用法？Java CreateServiceInstanceBindingRequest怎么用？Java CreateServiceInstanceBindingRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
CreateServiceInstanceBindingRequest类属于org.springframework.cloud.servicebroker.model包，在下文中一共展示了CreateServiceInstanceBindingRequest类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: should_map_create_service_instance_binding_request
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void should_map_create_service_instance_binding_request() throws Exception {
SuffixedServiceInstanceBindingRequestMapper mapper = new SuffixedServiceInstanceBindingRequestMapper("-suffix");
Map<String, Object> bindResource = new HashMap<>();
bindResource.put("resource1", "value1");
Map<String, Object> parameters = new HashMap<>();
parameters.put("parameter1", "value1");
Assert.assertEquals(new CreateServiceInstanceBindingRequest("serviceDefinitionId",
"planId",
"appGuid",
bindResource,
parameters)
.withBindingId("bindingId")
.withServiceInstanceId("serviceInstanceId"),
mapper.map(new CreateServiceInstanceBindingRequest("serviceDefinitionId-suffix",
"planId-suffix",
"appGuid",
bindResource,
parameters)
.withBindingId("bindingId")
.withServiceInstanceId("serviceInstanceId")));
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:27，代码来源:SuffixedServiceInstanceBindingRequestMapperTest.java
示例2: should_proxy_create_service_instance_binding_request_to_filtered_broker
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void should_proxy_create_service_instance_binding_request_to_filtered_broker() throws Exception {
CreateServiceInstanceBindingRequest request = new CreateServiceInstanceBindingRequest()
.withServiceInstanceId("instance_id")
.withBindingId("binding_id");
ResponseEntity<CreateServiceInstanceAppBindingResponse> response = new ResponseEntity<CreateServiceInstanceAppBindingResponse>(new CreateServiceInstanceAppBindingResponse(), HttpStatus.CREATED);
given(this.serviceInstanceBindingServiceClient.createServiceInstanceBinding("instance_id", "binding_id", request))
.willReturn(response);
final ResponseEntity<CreateServiceInstanceAppBindingResponse> forEntity = this.restTemplate.getForEntity("/v2/service_instances/{instance_id}/service_bindings/{binding_id}",
CreateServiceInstanceAppBindingResponse.class, "instance_id", "binding_id");
Assert.assertEquals(response.getBody(), forEntity);
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:17，代码来源:ServiceInstanceBindingFilterBrokerIntegrationTest.java
示例3: givenBoundedAppExists
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test(expected = ClientV2Exception.class)
public void fail_to_create_create_security_group_should_raise_exception_so_that_CC_requests_unbinding_action_to_clean_up_target_broker_related_resources() throws Exception {
givenBoundedAppExists(this.cloudFoundryClient, "app_guid");
givenServicePlan(this.cloudFoundryClient, "plan-id", "service-id");
givenService(this.cloudFoundryClient, "service-id", "service-broker-id");
givenServiceBroker(this.cloudFoundryClient, "service-broker-id", "service-broker-name");
givenServiceInstance(this.cloudFoundryClient, "service-instance-id", "service-instance-name", "plan-id");
givenCreateSecurityGroupsFails(this.cloudFoundryClient, "test-securitygroup-name");
Map<String, Object> credentials = new HashMap<>();
credentials.put("uri", TEST_URI);
Map<String, Object> bindResources = new HashMap<>();
bindResources.put(ServiceBindingResource.BIND_RESOURCE_KEY_APP.toString(), "app_guid");
createSecurityGroup
.run(
new CreateServiceInstanceBindingRequest("service-id", "plan-id", null, bindResources, null)
.withBindingId("test-securitygroup-name")
.withServiceInstanceId("service-instance-id"),
new CreateServiceInstanceAppBindingResponse().withCredentials(credentials)
);
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:24，代码来源:CreateSecurityGroupTest.java
示例4: createServiceInstanceBinding
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public CreateServiceInstanceBindingResponse createServiceInstanceBinding(
CreateServiceInstanceBindingRequest request)
throws ServiceInstanceBindingExistsException,
ServiceBrokerException {
try {
BindingWorkflow workflow = getWorkflow(request);
LOG.info("creating binding");
workflow.checkIfUserExists();
String secretKey = workflow.createBindingUser();
LOG.info("building binding response");
Map<String, Object> credentials = workflow.getCredentials(secretKey,
request.getParameters());
ServiceInstanceBinding binding = workflow.getBinding(credentials);
LOG.info("saving binding...");
repository.save(binding);
LOG.info("binding saved.");
return workflow.getResponse(credentials);
} catch (IOException | JAXBException | EcsManagementClientException e) {
throw new ServiceBrokerException(e);
}
}
开发者ID:codedellemc，项目名称:ecs-cf-service-broker，代码行数:27，代码来源:EcsServiceInstanceBindingService.java
示例5: buildCreateAppBindingRequest
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
public static CreateServiceInstanceBindingRequest buildCreateAppBindingRequest() {
CreateServiceInstanceBindingRequest request = CreateServiceInstanceBindingRequest.builder()
.serviceDefinitionId(ServiceFixture.getSimpleService().getId())
.planId(PlanFixture.getPlanOne().getId())
.bindResource(BindResource.builder()
.appGuid(APP_GUID)
.build())
.context(ContextFixture.getContext())
.parameters(ParametersFixture.getParameters())
.build();
request.setBindingId(SERVICE_INSTANCE_BINDING_ID);
request.setServiceInstanceId(SERVICE_INSTANCE_ID);
return request;
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:17，代码来源:ServiceInstanceBindingFixture.java
示例6: buildCreateRouteBindingRequest
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
public static CreateServiceInstanceBindingRequest buildCreateRouteBindingRequest() {
CreateServiceInstanceBindingRequest request = CreateServiceInstanceBindingRequest.builder()
.serviceDefinitionId(ServiceFixture.getSimpleService().getId())
.planId(PlanFixture.getPlanOne().getId())
.bindResource(BindResource.builder()
.route(ROUTE)
.build())
.context(ContextFixture.getContext())
.parameters(ParametersFixture.getParameters())
.build();
request.setBindingId(SERVICE_INSTANCE_BINDING_ID);
request.setServiceInstanceId(SERVICE_INSTANCE_ID);
return request;
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:17，代码来源:ServiceInstanceBindingFixture.java
示例7: createBindingToRouteSucceeds
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void createBindingToRouteSucceeds() throws Exception {
CreateServiceInstanceBindingRequest request = ServiceInstanceBindingFixture.buildCreateRouteBindingRequest();
CreateServiceInstanceRouteBindingResponse response = ServiceInstanceBindingFixture.buildCreateBindingResponseForRoute(false);
when(serviceInstanceBindingService.createServiceInstanceBinding(eq(request)))
.thenReturn(response);
setupCatalogService(request.getServiceDefinitionId());
mockMvc.perform(put(buildCreateUrl(false))
.content(DataFixture.toJson(request))
.accept(MediaType.APPLICATION_JSON)
.contentType(MediaType.APPLICATION_JSON))
.andExpect(status().isCreated())
.andExpect(jsonPath("$.credentials").doesNotExist())
.andExpect(jsonPath("$.syslog_drain_url").doesNotExist())
.andExpect(jsonPath("$.volume_mounts").doesNotExist())
.andExpect(jsonPath("$.route_service_url", is(response.getRouteServiceUrl())));
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:20，代码来源:ServiceInstanceBindingControllerIntegrationTest.java
示例8: createBindingToRouteWithExistingSucceeds
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void createBindingToRouteWithExistingSucceeds() throws Exception {
CreateServiceInstanceBindingRequest request = ServiceInstanceBindingFixture.buildCreateRouteBindingRequest();
CreateServiceInstanceRouteBindingResponse response =
ServiceInstanceBindingFixture.buildCreateBindingResponseForRoute(true);
when(serviceInstanceBindingService.createServiceInstanceBinding(eq(request)))
.thenReturn(response);
setupCatalogService(request.getServiceDefinitionId());
mockMvc.perform(put(buildCreateUrl(false))
.content(DataFixture.toJson(request))
.accept(MediaType.APPLICATION_JSON)
.contentType(MediaType.APPLICATION_JSON))
.andExpect(status().isOk())
.andExpect(jsonPath("$.credentials").doesNotExist())
.andExpect(jsonPath("$.syslog_drain_url").doesNotExist())
.andExpect(jsonPath("$.volume_mounts").doesNotExist())
.andExpect(jsonPath("$.route_service_url", is(response.getRouteServiceUrl())));
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:21，代码来源:ServiceInstanceBindingControllerIntegrationTest.java
示例9: createBindingWithVolumeSucceeds
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void createBindingWithVolumeSucceeds() throws Exception {
CreateServiceInstanceBindingRequest request = createRequest;
CreateServiceInstanceAppBindingResponse response = ServiceInstanceBindingFixture.buildCreateAppBindingResponseWithVolumeMount();
when(serviceInstanceBindingService.createServiceInstanceBinding(eq(request)))
.thenReturn(response);
VolumeMount volumeMount = response.getVolumeMounts().get(0);
SharedVolumeDevice device = (SharedVolumeDevice) volumeMount.getDevice();
setupCatalogService(request.getServiceDefinitionId());
mockMvc.perform(put(buildCreateUrl(false))
.content(DataFixture.toJson(request))
.accept(MediaType.APPLICATION_JSON)
.contentType(MediaType.APPLICATION_JSON))
.andExpect(status().isCreated())
.andExpect(jsonPath("$.credentials").doesNotExist())
.andExpect(jsonPath("$.syslog_drain_url").doesNotExist())
.andExpect(jsonPath("$.volume_mounts[0].driver", is(volumeMount.getDriver())))
.andExpect(jsonPath("$.volume_mounts[0].container_dir", is(volumeMount.getContainerDir())))
.andExpect(jsonPath("$.volume_mounts[0].mode", is(volumeMount.getMode().toString())))
.andExpect(jsonPath("$.volume_mounts[0].device_type", is(volumeMount.getDeviceType().toString())))
.andExpect(jsonPath("$.volume_mounts[0].device.volume_id", is(device.getVolumeId())))
.andExpect(jsonPath("$.volume_mounts[0].device.mount_config", is(device.getMountConfig())));
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:26，代码来源:ServiceInstanceBindingControllerIntegrationTest.java
示例10: createServiceInstanceBinding
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@PutMapping(value = {
"/{cfInstanceId}/v2/service_instances/{instanceId}/service_bindings/{bindingId}",
"/v2/service_instances/{instanceId}/service_bindings/{bindingId}"
})
public ResponseEntity<?> createServiceInstanceBinding(@PathVariable Map<String, String> pathVariables,
@PathVariable("instanceId") String serviceInstanceId,
@PathVariable("bindingId") String bindingId,
@RequestHeader(value = API_INFO_LOCATION_HEADER, required = false) String apiInfoLocation,
@RequestHeader(value = ORIGINATING_IDENTITY_HEADER, required = false) String originatingIdentityString,
@Valid @RequestBody CreateServiceInstanceBindingRequest request) {
request.setServiceInstanceId(serviceInstanceId);
request.setBindingId(bindingId);
request.setServiceDefinition(getServiceDefinition(request.getServiceDefinitionId()));
setCommonRequestFields(request, pathVariables.get("cfInstanceId"), apiInfoLocation, originatingIdentityString);
log.debug("Creating a service instance binding: request={}", request);
CreateServiceInstanceBindingResponse response = serviceInstanceBindingService.createServiceInstanceBinding(request);
log.debug("Creating a service instance binding succeeded: serviceInstanceId={}, bindingId={}, response={}",
serviceInstanceId, bindingId, response);
return new ResponseEntity<>(response, response.isBindingExisted() ? HttpStatus.OK : HttpStatus.CREATED);
}
开发者ID:spring-cloud，项目名称:spring-cloud-cloudfoundry-service-broker，代码行数:25，代码来源:ServiceInstanceBindingController.java
示例11: newServiceInstanceBindingCreatedSuccessfully
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void newServiceInstanceBindingCreatedSuccessfully()
throws ServiceBrokerException, ServiceInstanceBindingExistsException {
when(admin.getCredentialsFromSensors(anyString(), anyString(), any(Predicate.class), any(Predicate.class), any(Predicate.class), any(Predicate.class))).thenReturn(new AsyncResult<>(Collections.<String, Object>emptyMap()));
when(admin.hasEffector(anyString(), anyString(), anyString())).thenReturn(new AsyncResult<>(false));
when(instanceRepository.findOne(anyString(), anyBoolean())).thenReturn(serviceInstance);
when(serviceDefinition.getMetadata()).thenReturn(ImmutableMap.of());
when(brooklynCatalogService.getServiceDefinition(anyString())).thenReturn(serviceDefinition);
when(serviceInstance.getEntityId()).thenReturn("entityId");
CreateServiceInstanceBindingRequest request = new CreateServiceInstanceBindingRequest(serviceInstance.getServiceDefinitionId(), "planId", "appGuid", null);
CreateServiceInstanceBindingResponse binding = bindingService.createServiceInstanceBinding(request.withBindingId(SVC_INST_BIND_ID));
assertNotNull(binding);
// TODO assert binding was completed successfully
//assertEquals(SVC_INST_BIND_ID, binding.getServiceBindingId());
}
开发者ID:cloudfoundry-incubator，项目名称:apache-brooklyn-service-broker，代码行数:18，代码来源:BrooklynServiceInstanceBindingServiceTest.java
示例12: createServiceInstanceBinding
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public CreateServiceInstanceBindingResponse createServiceInstanceBinding(final CreateServiceInstanceBindingRequest request) {
final String bindingId = request.getBindingId();
final String serviceInstanceId = request.getServiceInstanceId();
ServiceInstanceBinding binding = bindingRepository.findOne(bindingId);
if (binding != null) {
throw new ServiceInstanceBindingExistsException(serviceInstanceId, bindingId);
}
ServiceInstance instance = instanceRepository.findOne(serviceInstanceId);
if (instance == null) {
throw new CloudKarafkaServiceException("Instance don't exist :" + serviceInstanceId);
}
final Map<String, Object> credentials = new HashMap<String, Object>(){
{
put("brokers", instance.getCloudKarafkaBrokers());
put("ca", instance.getCloudKarafkaCa());
put("cert", instance.getCloudKarafkaCert());
put("id", instance.getCloudKarafkaId());
put("private_key", instance.getCloudKarafkaPrivateKey());
put("topic_prefix", instance.getCloudKarafkaTopicPrefix());
put("brokers",instance.getCloudKarafkaBrokers());
put("message",instance.getCloudKarafkaMessage());
}};
binding = new ServiceInstanceBinding(bindingId, serviceInstanceId, credentials, null, request.getBoundAppGuid());
bindingRepository.save(binding);
return new CreateServiceInstanceAppBindingResponse().withCredentials(credentials);
}
开发者ID:ipolyzos，项目名称:cloudkarafka-broker，代码行数:33，代码来源:CloudKarafkaServiceInstanceBindingService.java
示例13: serviceBindingWithParms
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Bean
public ServiceBinding serviceBindingWithParms() {
Map<String, Object> params = new HashMap<>();
long l = System.currentTimeMillis();
params.put(POSTGRES_DB, "testDb" + l);
params.put(POSTGRES_USER, "testUser" + l);
params.put(POSTGRES_PASSWORD, "testPassw0rd");
CreateServiceInstanceBindingRequest request = new CreateServiceInstanceBindingRequest(null, null, null, null, params);
return new ServiceBinding(request);
}
开发者ID:cf-platform-eng，项目名称:my-postgres-broker，代码行数:13，代码来源:TestConfig.java
示例14: createServiceInstanceBinding
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public CreateServiceInstanceBindingResponse createServiceInstanceBinding(CreateServiceInstanceBindingRequest request) {
String bindingId = request.getBindingId();
String serviceInstanceId = request.getServiceInstanceId();
ServiceInstanceBinding binding = bindingRepository.findOne(bindingId);
if (binding != null) {
throw new ServiceInstanceBindingExistsException(serviceInstanceId, bindingId);
}
String database = serviceInstanceId;
String username = bindingId;
// TODO Password Generator
String password = "password";
// TODO check if user already exists in the DB
mongo.createUser(database, username, password);
Map<String, Object> credentials =
Collections.singletonMap("uri", (Object) mongo.getConnectionString(database, username, password));
binding = new ServiceInstanceBinding(bindingId, serviceInstanceId, credentials, null, request.getBoundAppGuid());
bindingRepository.save(binding);
return new CreateServiceInstanceAppBindingResponse().withCredentials(credentials);
}
开发者ID:cf-platform-eng，项目名称:mongodb-broker，代码行数:29，代码来源:MongoServiceInstanceBindingService.java
示例15: buildCreateRequest
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
private CreateServiceInstanceBindingRequest buildCreateRequest() {
Map<String, Object> bindResource =
Collections.singletonMap(ServiceBindingResource.BIND_RESOURCE_KEY_APP.toString(), (Object) "app_guid");
return new CreateServiceInstanceBindingRequest(instance.getServiceDefinitionId(), instance.getPlanId(),
"app_guid", bindResource)
.withServiceInstanceId(instance.getServiceInstanceId())
.withBindingId(instanceBinding.getId());
}
开发者ID:cf-platform-eng，项目名称:mongodb-broker，代码行数:9，代码来源:MongoServiceInstanceBindingServiceTest.java
示例16: createServiceInstanceBinding
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public CreateServiceInstanceBindingResponse createServiceInstanceBinding(CreateServiceInstanceBindingRequest request) {
preBinding(request);
final CreateServiceInstanceBindingRequest req = mapper.map(request);
final ResponseEntity<CreateServiceInstanceAppBindingResponse> response = client.createServiceInstanceBinding(req.getServiceInstanceId(), req.getBindingId(), req);
postBinding(request, response.getBody());
return response.getBody();
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:9，代码来源:ServiceInstanceBindingServiceProxy.java
示例17: map
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public CreateServiceInstanceBindingRequest map(CreateServiceInstanceBindingRequest request) {
return new CreateServiceInstanceBindingRequest(withoutSuffix(request.getServiceDefinitionId(), serviceOfferingSuffix),
withoutSuffix(request.getPlanId(), serviceOfferingSuffix),
request.getAppGuid(),
request.getBindResource(),
request.getParameters())
.withBindingId(request.getBindingId())
.withServiceInstanceId(request.getServiceInstanceId());
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:11，代码来源:SuffixedServiceInstanceBindingRequestMapper.java
示例18: run
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Override
public void run(CreateServiceInstanceBindingRequest request, CreateServiceInstanceAppBindingResponse response) {
Assert.notNull(response);
Assert.notNull(response.getCredentials());
final Destination destination = ConnectionInfoFactory.fromCredentials(response.getCredentials());
if (!trustedDestinationSpecification.isSatisfiedBy(destination)) {
log.warn("Cannot open security group for destination {}. Destination is out of allowed range [{}].", destination, trustedDestinationSpecification);
throw new NotAllowedDestination(destination);
}
log.debug("creating security group for credentials {}.", response.getCredentials());
try {
final SecurityGroupEntity securityGroup = Mono.when(
getRuleDescription(cloudFoundryClient, request.getBindingId(), request.getServiceInstanceId()),
getSpaceId(cloudFoundryClient, request.getBoundAppGuid())
).then(function((description, spaceId) -> create(getSecurityGroupName(request), destination, description, spaceId)))
.doOnError(t -> log.error("Fail to create security group. Error details {}", t))
.block();
log.debug("Security Group {} created", securityGroup.getName());
} catch (Exception e) {
log.error("Fail to create Security Group. Error details {}", e);
ReflectionUtils.rethrowRuntimeException(e);
}
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:28，代码来源:CreateSecurityGroup.java
示例19: should_create_security_group
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test
public void should_create_security_group() throws Exception {
givenBoundedAppExists(this.cloudFoundryClient, "app_guid");
givenServicePlan(this.cloudFoundryClient, "plan-id", "service-id");
givenService(this.cloudFoundryClient, "service-id", "service-broker-id");
givenServiceBroker(this.cloudFoundryClient, "service-broker-id", "service-broker-name");
givenServiceInstance(this.cloudFoundryClient, "service-instance-id", "service-instance-name", "plan-id");
givenCreateSecurityGroupsSucceeds(this.cloudFoundryClient, "test-securitygroup-name");
Map<String, Object> credentials = new HashMap<>();
credentials.put("uri", TEST_URI);
Map<String, Object> bindResources = new HashMap<>();
bindResources.put(ServiceBindingResource.BIND_RESOURCE_KEY_APP.toString(), "app_guid");
createSecurityGroup
.run(
new CreateServiceInstanceBindingRequest("service-id", "plan-id", null, bindResources, null)
.withBindingId("test-securitygroup-name")
.withServiceInstanceId("service-instance-id"),
new CreateServiceInstanceAppBindingResponse().withCredentials(credentials)
);
Mockito.verify(cloudFoundryClient.securityGroups())
.create(CreateSecurityGroupRequest.builder()
.name("test-securitygroup-name")
.spaceId("space_id")
.rule(RuleEntity.builder()
.description(RULE_DESCRIPTION)
.protocol(Protocol.TCP)
.ports("3306")
.destination("127.0.0.1")
.build())
.build());
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:37，代码来源:CreateSecurityGroupTest.java
示例20: should_block_until_create_security_group_returns
import org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest; //导入依赖的package包/类
@Test(expected = ClientV2Exception.class)
public void should_block_until_create_security_group_returns() throws Exception {
givenBoundedAppExists(this.cloudFoundryClient, "app_guid");
givenServicePlan(this.cloudFoundryClient, "plan-id", "service-id");
givenService(this.cloudFoundryClient, "service-id", "service-broker-id");
givenServiceBroker(this.cloudFoundryClient, "service-broker-id", "service-broker-name");
givenServiceInstance(this.cloudFoundryClient, "service-instance-id", "service-instance-name", "plan-id");
givenCreateSecurityGroupsFailsWithDelay(this.cloudFoundryClient, "test-securitygroup-name");
Map<String, Object> credentials = new HashMap<>();
credentials.put("uri", TEST_URI);
Map<String, Object> bindResources = new HashMap<>();
bindResources.put(ServiceBindingResource.BIND_RESOURCE_KEY_APP.toString(), "app_guid");
createSecurityGroup
.run(
new CreateServiceInstanceBindingRequest("service-id", "plan-id", null, bindResources, null)
.withBindingId("test-securitygroup-name")
.withServiceInstanceId("service-instance-id"),
new CreateServiceInstanceAppBindingResponse().withCredentials(credentials)
);
Mockito.verify(cloudFoundryClient.securityGroups())
.create(CreateSecurityGroupRequest.builder()
.name("test-securitygroup-name")
.spaceId("space_id")
.rule(RuleEntity.builder()
.description(RULE_DESCRIPTION)
.protocol(Protocol.TCP)
.ports("3306")
.destination("127.0.0.1")
.build())
.build());
}
开发者ID:orange-cloudfoundry，项目名称:sec-group-broker-filter，代码行数:35，代码来源:CreateSecurityGroupTest.java
注：本文中的org.springframework.cloud.servicebroker.model.CreateServiceInstanceBindingRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论