@Beta public interface ServerPool extends DynamicCluster, LocationOwner<ServerPoolLocation,ServerPool>
INBOUND_PORTS
config key as part of the pool's
PROVISIONING_PROPERTIES
.
For example, in YAML:
- type: brooklyn.entity.pool.ServerPool brooklyn.config: # Suitable for TomcatServers provisioning.properties: inboundPorts: [22, 31880, 8443, 8080, 31001, 1099]This is a limitation of Brooklyn that will be addressed in a future release.
DynamicCluster.NodePlacementStrategy, DynamicCluster.ZoneFailureDetector
BrooklynObject.TagSupport
Configurable.ConfigurationSupport
Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
Modifier and Type | Field and Description |
---|---|
static MethodEffector<java.util.Collection<Entity>> |
ADD_MACHINES_FROM_SPEC |
static AttributeSensor<java.lang.Integer> |
AVAILABLE_COUNT |
static AttributeSensor<java.lang.Integer> |
CLAIMED_COUNT |
static ConfigKey<java.lang.Integer> |
INITIAL_SIZE |
static ConfigKey<EntitySpec<?>> |
MEMBER_SPEC |
AVAILABILITY_ZONE_NAMES, CLUSTER, CLUSTER_MEMBER, CUSTOM_CHILD_FLAGS, ENABLE_AVAILABILITY_ZONES, ENTITY_QUARANTINED, FACTORY, FAILED_SUB_LOCATIONS, FIRST_MEMBER_SPEC, INITIAL_QUORUM_SIZE, NUM_AVAILABILITY_ZONES, QUARANTINE_FAILED_ENTITIES, QUARANTINE_GROUP, REMOVAL_STRATEGY, RESIZE_BY_DELTA, SERVICE_STATE_ACTUAL, SUB_LOCATIONS, ZONE_FAILURE_DETECTOR, ZONE_PLACEMENT_STRATEGY
FIRST, FIRST_MEMBER, GROUP_MEMBERS, MEMBER_DELEGATE_CHILDREN, MEMBER_DELEGATE_NAME_FORMAT, RUNNING_QUORUM_CHECK, UP_QUORUM_CHECK
GROUP_SIZE, MEMBER_ADDED, MEMBER_REMOVED
RESTART, SERVICE_UP, START, STOP
REPLACE_MEMBER
DYNAMIC_LOCATION, DYNAMIC_LOCATION_STATUS, LOCATION_DEFINITION, LOCATION_FLAGS, LOCATION_NAME, LOCATION_NAME_PREFIX, LOCATION_NAME_SUFFIX, LOCATION_SPEC
Modifier and Type | Method and Description |
---|---|
Entity |
addExistingMachine(MachineLocation machine)
Sets the pool to use an existing
MachineLocation as a member. |
java.util.Collection<Entity> |
addExistingMachinesFromSpec(java.lang.String spec)
Adds additional machines to the pool by resolving the given spec.
|
MachineLocation |
claimMachine(java.util.Map<?,?> flags) |
void |
releaseMachine(MachineLocation machine) |
addNode, resizeByDelta, setFactory, setMemberSpec, setRemovalStrategy, setZoneFailureDetector, setZonePlacementStrategy
setMembers, setMembers
addChild, addChild, addMember, addMemberChild, addMemberChild, getCurrentSize, getMembers, hasMember, removeMember
addEnricher, addEnricher, addFeed, addGroup, addPolicy, addPolicy, addTag, clearParent, containsTag, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEnrichers, getEntityType, getGroups, getIconUrl, getId, getLocations, getParent, getPolicies, getTags, invoke, removeChild, removeEnricher, removeGroup, removePolicy, removeTag, setParent
getCatalogItemId, getTagSupport, tags
config, setConfig
getCurrentSize, resize
replaceMember
createLocation, deleteLocation, getDynamicLocation, isLocationAvailable
static final ConfigKey<java.lang.Integer> INITIAL_SIZE
static final AttributeSensor<java.lang.Integer> AVAILABLE_COUNT
static final AttributeSensor<java.lang.Integer> CLAIMED_COUNT
static final ConfigKey<EntitySpec<?>> MEMBER_SPEC
static final MethodEffector<java.util.Collection<Entity>> ADD_MACHINES_FROM_SPEC
MachineLocation claimMachine(java.util.Map<?,?> flags) throws NoMachinesAvailableException
NoMachinesAvailableException
void releaseMachine(MachineLocation machine)
Entity addExistingMachine(MachineLocation machine)
MachineLocation
as a member. Existing locations
will count towards the capacity of the pool but will not be terminated when the pool is
stopped.machine
- An existing machine.MEMBER_SPEC
.java.util.Collection<Entity> addExistingMachinesFromSpec(java.lang.String spec)
spec
- A location spec, e.g. byon:(hosts="user@10.9.1.1,user@10.9.1.2,user@10.9.1.3")
MEMBER_SPEC
.