org.apache.brooklyn.api.entity.Group.addChild()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(12.6k)|赞(0)|评价(0)|浏览(92)

本文整理了Java中org.apache.brooklyn.api.entity.Group.addChild()方法的一些代码示例，展示了Group.addChild()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Group.addChild()方法的具体详情如下：
包路径：org.apache.brooklyn.api.entity.Group
类名称：Group
方法名：addChild

Group.addChild介绍

[英]As in super, but note this does NOT by default add it as a member; see #addMemberChild(Entity)
[中]与super一样，但请注意，默认情况下不会将其添加为成员；参见#addMemberChild（实体）

代码示例

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public void addHost(DockerHost host) {
  SshMachineLocation machine = host.getDynamicLocation().getMachine();
  EntitySpec<?> spec = EntitySpec.create(sensors().get(SDN_AGENT_SPEC))
      .configure(OverlayPlugin.SDN_PROVIDER, this)
      .configure(OverlayPlugin.DOCKER_HOST, host);
  OverlayPlugin agent = (OverlayPlugin) getAgents().addChild(spec);
  getAgents().addMember(agent);
  agent.start(ImmutableList.of(machine));
  if (LOG.isDebugEnabled()) LOG.debug("{} added overlay plugin {}", this, agent);
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public void addHost(DockerHost host) {
  SshMachineLocation machine = host.getDynamicLocation().getMachine();
  EntitySpec<?> spec = EntitySpec.create(sensors().get(SDN_AGENT_SPEC))
      .configure(WeaveRouter.SDN_PROVIDER, this)
      .configure(WeaveRouter.DOCKER_HOST, host);
  WeaveRouter agent = (WeaveRouter) getAgents().addChild(spec);
  getAgents().addMember(agent);
  agent.start(ImmutableList.of(machine));
  LOG.debug("{} added Weave service {}", this, agent);
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public void addHost(DockerHost host) {
  SshMachineLocation machine = host.getDynamicLocation().getMachine();
  EntitySpec<?> spec = EntitySpec.create(sensors().get(SDN_AGENT_SPEC))
      .configure(CalicoNode.SDN_PROVIDER, this)
      .configure(CalicoNode.DOCKER_HOST, host)
      .configure(CalicoNode.ETCD_NODE, host.sensors().get(DockerHost.ETCD_NODE));
  CalicoNode agent = (CalicoNode) getAgents().addChild(spec);
  getAgents().addMember(agent);
  agent.start(ImmutableList.of(machine));
  if (LOG.isDebugEnabled()) LOG.debug("{} added calico plugin {}", this, agent);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

@Test(groups="Integration") // because takes 4s or so
public void testBucketDistributionWithRescan() {
  Group group = app.createAndManageChild(EntitySpec.create(BasicGroup.class));
  final DynamicMultiGroup dmg = app.createAndManageChild(
      EntitySpec.create(DynamicMultiGroup.class)
          .configure(ENTITY_FILTER, instanceOf(TestEntity.class))
          .configure(BUCKET_FUNCTION, bucketFromAttribute(SENSOR))
          .configure(RESCAN_INTERVAL, 1L)
  );
  EntitySpec<TestEntity> childSpec = EntitySpec.create(TestEntity.class);
  TestEntity child1 = group.addChild(EntitySpec.create(childSpec).displayName("child1"));
  TestEntity child2 = group.addChild(EntitySpec.create(childSpec).displayName("child2"));
  
  checkDistribution(group, dmg, childSpec, child1, child2);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

@Test(groups = "Integration")
public void testNginxInstancesConfiguredWithUrlMappings() {
  DynamicCluster c1 = app.createAndManageChild(EntitySpec.create(DynamicCluster.class)
      .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(JBoss7Server.class))
      .configure("initialSize", 1)
      .configure(JavaWebAppService.NAMED_WARS, ImmutableList.of(getTestWar())));
  UrlMapping urlMapping = urlMappings.addChild(EntitySpec.create(UrlMapping.class)
      .configure("domain", "localhost")
      .configure("path", "/hello-world($|/.*)")
      .configure("target", c1));
  
  loadBalancerCluster = app.createAndManageChild(EntitySpec.create(LoadBalancerCluster.class)
      .configure("urlMappings", urlMappings)
      .configure(LoadBalancerCluster.MEMBER_SPEC, nginxSpec)
      .configure("initialSize", 1));
  app.start(ImmutableList.of(localhostProvisioningLoc));
  
  assertEquals(findNginxs().size(), 1);
  
  String hostname = "localhost";
  List<String> pathsFor200 = ImmutableList.of("hello-world", "hello-world/");
  assertNginxsResponsiveEvenutally(findNginxs(), hostname, pathsFor200);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

@Test
public void testBucketDistributionFromSubscription() {
  Group group = app.createAndManageChild(EntitySpec.create(BasicGroup.class));
  final DynamicMultiGroup dmg = app.createAndManageChild(
      EntitySpec.create(DynamicMultiGroup.class)
          .configure(ENTITY_FILTER, instanceOf(TestEntity.class))
          .configure(BUCKET_FUNCTION, bucketFromAttribute(SENSOR))
  );
  app.subscriptions().subscribeToChildren(group, SENSOR, new SensorEventListener<String>() {
    @Override
    public void onEvent(SensorEvent<String> event) { dmg.rescanEntities(); }
  });
  EntitySpec<TestEntity> childSpec = EntitySpec.create(TestEntity.class);
  TestEntity child1 = group.addChild(EntitySpec.create(childSpec).displayName("child1"));
  TestEntity child2 = group.addChild(EntitySpec.create(childSpec).displayName("child2"));
  checkDistribution(group, dmg, childSpec, child1, child2);
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

public static final VirtualNetwork createNetwork(final SdnProvider provider, final String networkId) {
  boolean createNetwork = false;
  Cidr subnetCidr = null;
  VirtualNetwork network = null;
  synchronized (provider.getNetworkMutex()) {
    subnetCidr = provider.getSubnetCidr(networkId);
    if (subnetCidr == null) {
      subnetCidr = provider.getNextSubnetCidr(networkId);
      createNetwork = true;
    }
  }
  if (createNetwork) {
    // Get a CIDR for the subnet from the availabkle pool and create a virtual network
    EntitySpec<VirtualNetwork> networkSpec = EntitySpec.create(VirtualNetwork.class)
        .configure(SdnAttributes.SDN_PROVIDER, provider)
        .configure(VirtualNetwork.NETWORK_ID, networkId)
        .configure(VirtualNetwork.NETWORK_CIDR, subnetCidr);
    // Start and then add this virtual network as a child of SDN_NETWORKS
    network = provider.sensors().get(SdnProvider.SDN_NETWORKS).addChild(networkSpec);
    Entities.start(network, provider.getLocations());
    Entities.waitForServiceUp(network);
  } else {
    network = lookupNetwork(provider, networkId);
  }
  return network;
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

dmgs.add(dmg);
TestEntity child = group.addChild(EntitySpec.create(TestEntity.class).displayName("child"+i));
child.sensors().set(SENSOR, "bucketA");
childs.add(child);

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

@Test(groups = "Integration")
public void testDiscardUrlMapping() throws Exception {
  //cluster 0 mounted at localhost1 /
  DynamicCluster c0 = app.createAndManageChild(EntitySpec.create(DynamicCluster.class)
      .configure("initialSize", 1)
      .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
      .configure(JavaWebAppService.ROOT_WAR, getTestWar()));
  UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
      .configure("domain", "localhost1")
      .configure("target", c0));
  nginx = app.createAndManageChild(EntitySpec.create(NginxController.class)
      .configure("urlMappings", urlMappingsGroup));
  
  app.start(ImmutableList.of(localLoc));
  int port = nginx.getAttribute(NginxController.PROXY_HTTP_PORT);
  
  HttpTestUtils.assertHttpStatusCodeEventuallyEquals("http://localhost1:"+port+"", 200);
  // Discard, and confirm that subsequently get a 404 instead
  u0.discard();
  
  HttpTestUtils.assertHttpStatusCodeEventuallyEquals("http://localhost1:"+port+"", 404);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
    .configure(JavaWebAppService.ROOT_WAR, getTestWar()));
final UrlMapping u1 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost1")
    .configure("target", c1));

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

@Test(groups = "Integration")
public void testUrlMappingRemovedWhenMappingEntityRemoved() throws Exception {
  DynamicCluster c0 = app.createAndManageChild(EntitySpec.create(DynamicCluster.class)
      .configure("initialSize", 1)
      .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
      .configure(JavaWebAppService.ROOT_WAR, getTestWar()));
  UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
      .configure("domain", "localhost2")
      .configure("target", c0));
  
  nginx = app.createAndManageChild(EntitySpec.create(NginxController.class)
      .configure("domain", "localhost")
      .configure("port", "8000+")
      .configure("portNumberSensor", WebAppService.HTTP_PORT)
      .configure("urlMappings", urlMappingsGroup));
  
  app.start(ImmutableList.of(localLoc));
  int port = nginx.getAttribute(NginxController.PROXY_HTTP_PORT);
  
  // Wait for deployment to be successful
  HttpTestUtils.assertHttpStatusCodeEventuallyEquals("http://localhost2:"+port+"/", 200);
  
  // Now remove mapping; will no longer route requests
  Entities.unmanage(u0);
  HttpTestUtils.assertHttpStatusCodeEventuallyEquals("http://localhost2:"+port+"/", 404);
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure("initialSize", 1)); 
UrlMapping origMapping = origUrlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost1")
    .configure("target", origServerPool)

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
    .configure(JavaWebAppService.ROOT_WAR, getTestWar()));
UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost1")
    .configure("target", c0));

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
    .configure(JavaWebAppService.NAMED_WARS, ImmutableList.of(getTestWar())));
UrlMapping u1 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost1")
    .configure("target", c1));

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure("initialSize", 1)
    .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+")));
UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost")
    .configure("path", "/atC0($|/.*)")
    .configure("initialSize", 1)
    .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+")));
UrlMapping u1 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost")
    .configure("path", "/atC1($|/.*)")

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
    .configure(JavaWebAppService.ROOT_WAR, getTestWar()));
UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost1")
    .configure("target", c0));
    .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+"))
    .configure(JavaWebAppService.NAMED_WARS, ImmutableList.of(getTestWar())));
UrlMapping u1 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost2")
    .configure("path", "/hello-world($|/.*)")
    .configure("initialSize", 1)
    .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+")));
UrlMapping u2 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost3")
    .configure("path", "/c2($|/.*)")

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

.configure("initialSize", 1)
    .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(Tomcat8Server.class).configure("httpPort", "8100+")));
UrlMapping u0 = urlMappingsGroup.addChild(EntitySpec.create(UrlMapping.class)
    .configure("domain", "localhost")
    .configure("path", "/atC0($|/.*)")

代码示例来源：origin: org.apache.brooklyn/brooklyn-core

final TestEntity child3 = group.addChild(EntitySpec.create(childSpec).displayName("child3"));
child3.sensors().set(SENSOR, "bucketC");
Asserts.succeedsEventually(new Runnable() {

内容来源于网络，如有侵权，请联系作者删除！

Group

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com