A B C D E F G H I J K L M N O P Q R S T U V W Z 

A

abortClusterJob(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Abort the cluster operation that is currently running for the given cluster.
AbstractAuthHandler - Class in co.cask.coopr.http.handler
Abstract handler that provides some base methods for authenticating and authorizing requests.
AbstractAuthHandler(TenantStore) - Constructor for class co.cask.coopr.http.handler.AbstractAuthHandler
 
AbstractBaseEntityCodec<T extends BaseEntity> - Class in co.cask.coopr.codec.json.current
Base codec for serializing and deserializing a BaseEntity.
AbstractBaseEntityCodec() - Constructor for class co.cask.coopr.codec.json.current.AbstractBaseEntityCodec
 
AbstractCodec<T> - Class in co.cask.coopr.codec.json
Utility methods for serializing and deserializing objects to/from json.
AbstractCodec() - Constructor for class co.cask.coopr.codec.json.AbstractCodec
 
AbstractPluginSpecification - Class in co.cask.coopr.spec.plugin
Plugin specification, including what parameters are supported and required and what types of resources are supported.
AbstractPluginSpecification(BaseEntity.Builder, Map<ParameterType, ParametersSpecification>, Map<String, ResourceTypeSpecification>) - Constructor for class co.cask.coopr.spec.plugin.AbstractPluginSpecification
 
AbstractPluginSpecification.Builder<T extends AbstractPluginSpecification> - Class in co.cask.coopr.spec.plugin
Base builder for plugin specifications.
AbstractPluginSpecification.Builder() - Constructor for class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
AbstractStoreModule - Class in co.cask.coopr.store.guice
 
AbstractStoreModule() - Constructor for class co.cask.coopr.store.guice.AbstractStoreModule
 
AbstractTemplate - Class in co.cask.coopr.spec.template
 
AbstractTemplate(BaseEntity.Builder, ClusterDefaults, Compatibilities, Constraints, Administration, Set<Link>) - Constructor for class co.cask.coopr.spec.template.AbstractTemplate
 
AbstractTemplate.Builder<T extends AbstractTemplate,V extends AbstractTemplate.Builder<T,V>> - Class in co.cask.coopr.spec.template
Builder for creating templates.
AbstractTemplate.Builder() - Constructor for class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
AbstractTemplateCodec<T extends AbstractTemplate> - Class in co.cask.coopr.codec.json.current
Abstract Codec for template serializing/deserializing.
AbstractTemplateCodec() - Constructor for class co.cask.coopr.codec.json.current.AbstractTemplateCodec
 
Account - Class in co.cask.coopr.account
An Account represents all information about a user, such as the user id and tenant id.
Account(String, String) - Constructor for class co.cask.coopr.account.Account
 
account - Variable in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
accountErrorSnippet - Variable in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
ActionOnService - Class in co.cask.coopr.scheduler
Represents an action to perform on a service.
ActionOnService(ProvisionerAction, String) - Constructor for class co.cask.coopr.scheduler.ActionOnService
 
Actions - Class in co.cask.coopr.scheduler
Class describing what ProvisionerActions are only on hardware and not on services, which actions rollback other actions, which actions retry other actions, the order ProvisionerActions should be performed in order to carry out specific ClusterActions, and action dependencies.
Actions.Dependency - Class in co.cask.coopr.scheduler
Represents action dependency between services.
Actions.Dependency(ProvisionerAction, ProvisionerAction) - Constructor for class co.cask.coopr.scheduler.Actions.Dependency
 
Actions.Dependency(ProvisionerAction, ProvisionerAction, boolean) - Constructor for class co.cask.coopr.scheduler.Actions.Dependency
 
add(String, Element) - Method in interface co.cask.coopr.common.queue.QueueGroup
Adds the given elements to the specified queue.
add(Element) - Method in interface co.cask.coopr.common.queue.TrackingQueue
Adds element to the queue.
add(T) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
add(ResourceMeta) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Add the resource metadata to the store.
add(ResourceMeta) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
addAction(Node.Action) - Method in class co.cask.coopr.cluster.Node
Add an action to the list of actions that have been performed on the node.
addAll(Collection<? extends T>) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
addAttempt() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Add a new attempt at this task.
addChangeIfValid(ClusterLayoutChange) - Method in class co.cask.coopr.layout.change.ClusterLayoutTracker
Adds a change to the layout if the change can be applied to the current layout, returning whether or not the change was added.
addChildFields(T, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractBaseEntityCodec
Add child specific fields to the json object.
addChildFields(T, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractTemplateCodec
 
addChildFields(AutomatorType, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.AutomatorTypeCodec
 
addChildFields(ClusterTemplate, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterTemplateCodec
 
addChildFields(HardwareType, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.HardwareTypeCodec
 
addChildFields(ImageType, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ImageTypeCodec
 
addChildFields(PartialTemplate, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.PartialTemplateCodec
 
addChildFields(Provider, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ProviderCodec
 
addChildFields(ProviderType, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ProviderTypeCodec
 
addChildFields(Service, JsonObject, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceCodec
 
addClusterServices(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Add specific services to a cluster.
addDependency(TaskNode, TaskNode) - Method in class co.cask.coopr.scheduler.dag.TaskDag
Defines a dependency between task fromNode to toNode.
addFields(Map<String, Object>) - Method in class co.cask.coopr.spec.Provider
Add some fields to the provisioner fields.
addIPAddress(String, String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
addResource(String) - Method in class co.cask.coopr.common.conf.Configuration
Add a configuration resource.
addResource(URL) - Method in class co.cask.coopr.common.conf.Configuration
Add a configuration resource.
addResource(InputStream) - Method in class co.cask.coopr.common.conf.Configuration
Add a configuration resource.
addResources(ResourceType, ResourceTypeSpecification, Collection<ResourceMeta>) - Method in class co.cask.coopr.provisioner.plugin.ResourceCollection
Add resources of the given type and format with the given metadata.
ADDRESSES - Static variable in class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 
addResults(JsonObject) - Method in class co.cask.coopr.cluster.Node
Add the provisioner results from a task to the current provisioner results.
addService(Service) - Method in class co.cask.coopr.cluster.Node
Add a service to the node.
AddServiceChangeIterator - Class in co.cask.coopr.layout.change
Return all the ways in which the given cluster layout can be expanded by adding the given service to one or more nodes in the cluster layout.
AddServiceChangeIterator(ClusterLayout, String) - Constructor for class co.cask.coopr.layout.change.AddServiceChangeIterator
 
AddServicesChange - Class in co.cask.coopr.layout.change
Adds services to specified number of nodes of given nodelayouts in a cluster.
AddServicesChange(Multiset<NodeLayout>, String) - Constructor for class co.cask.coopr.layout.change.AddServicesChange
 
AddServicesChange(Multiset<NodeLayout>, Set<String>) - Constructor for class co.cask.coopr.layout.change.AddServicesChange
 
AddServicesRequest - Class in co.cask.coopr.http.request
Request for add services to a cluster.
AddServicesRequest(Map<String, Object>, Set<String>) - Constructor for class co.cask.coopr.http.request.AddServicesRequest
Create a request to add services to a cluster.
AddServicesRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a AddServicesRequest, used so some validation is done on required fields.
AddServicesRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.AddServicesRequestCodec
 
addServicesToCluster(Cluster, Set<Node>, Set<String>) - Method in class co.cask.coopr.layout.ClusterLayoutUpdater
 
addServicesToCluster(Cluster, Set<Node>, Set<String>) - Method in class co.cask.coopr.layout.Solver
Add services to a cluster, returning which nodes were affected by the change or null if there was no way to add the services to the cluster.
addServicesToNodeLayout(NodeLayout, Set<String>) - Static method in class co.cask.coopr.layout.NodeLayout
Create a new NodeLayout by adding a set of services to the given NodeLayout.
addServiceToNodeLayout(NodeLayout, String) - Static method in class co.cask.coopr.layout.NodeLayout
Create a new NodeLayout by adding a service to the given NodeLayout.
addStage(Set<String>) - Method in class co.cask.coopr.scheduler.task.ClusterJob
Add a stage of tasks to the job.
addTaskNode(TaskNode) - Method in class co.cask.coopr.scheduler.dag.TaskDag
Add a node without any edges, meaning nothing depends on this node (yet).
ADMIN_USER - Static variable in class co.cask.coopr.common.conf.Constants
 
AdminHandler - Class in co.cask.coopr.http.handler
Handler for getting, adding, modifying, and deleting admin defined entities.
administration - Variable in class co.cask.coopr.spec.template.AbstractTemplate
 
administration - Variable in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
Administration - Class in co.cask.coopr.spec.template
Defines settings for cluster administration like lease duration, etc.
Administration(LeaseDuration) - Constructor for class co.cask.coopr.spec.template.Administration
 
AdministrationCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Administration.
AdministrationCodec() - Constructor for class co.cask.coopr.codec.json.current.AdministrationCodec
 
advanceStage() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Move on to the next stage.
API_BASE - Static variable in class co.cask.coopr.common.conf.Constants
 
API_KEY_HEADER - Static variable in class co.cask.coopr.common.conf.Constants
 
applyChange(ClusterLayout) - Method in class co.cask.coopr.layout.change.AddServicesChange
 
applyChange(Cluster, Set<Node>, Map<String, Service>) - Method in class co.cask.coopr.layout.change.AddServicesChange
 
applyChange(ClusterLayout) - Method in interface co.cask.coopr.layout.change.ClusterLayoutChange
Apply the change to the given ClusterLayout.
applyChange(Cluster, Set<Node>, Map<String, Service>) - Method in interface co.cask.coopr.layout.change.ClusterLayoutChange
Apply the change to a set of nodes, returning nodes that have changed.
arrayToString(String[]) - Static method in class co.cask.coopr.common.utils.StringUtils
Given an array of strings, return a comma-separated list of its elements.
asyncCancel() - Method in class co.cask.coopr.common.zookeeper.LeaderElection
Withdraw from the leader election process asynchronously.
AutomatorType - Class in co.cask.coopr.spec.plugin
An Automator type defines what parameters admins need to provide to a ServiceAction in order for the provisioner automator plugin to do its job.
AutomatorType.Builder - Class in co.cask.coopr.spec.plugin
Builder for creating automator types.
AutomatorType.Builder() - Constructor for class co.cask.coopr.spec.plugin.AutomatorType.Builder
 
AutomatorTypeCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a AutomatorType.
AutomatorTypeCodec() - Constructor for class co.cask.coopr.codec.json.current.AutomatorTypeCodec
 

B

BaseEntity - Class in co.cask.coopr.spec
A base for entities that require a name and optionally support an icon, description, and label.
BaseEntity(BaseEntity.Builder) - Constructor for class co.cask.coopr.spec.BaseEntity
 
BaseEntity.Builder<T extends BaseEntity> - Class in co.cask.coopr.spec
Base builder for creating admin entities.
BaseEntity.Builder() - Constructor for class co.cask.coopr.spec.BaseEntity.Builder
 
BaseEntityStoreView - Class in co.cask.coopr.store.entity
Abstract EntityStoreView that represents entities as json.
BaseEntityStoreView(Gson) - Constructor for class co.cask.coopr.store.entity.BaseEntityStoreView
 
BaseEntityStoreView.EntityType - Enum in co.cask.coopr.store.entity
Types of entities.
BaseSQLClusterStoreView - Class in co.cask.coopr.store.cluster
Base abstract class for ClusterStoreView using a SQL database as the persistent store.
BaseSQLEntityStoreView - Class in co.cask.coopr.store.entity
Base implementation of BaseEntityStoreView using a sql database as the persistent store.
BaseSQLNodeStoreView - Class in co.cask.coopr.store.node
Base abstract class for NodeStoreView using a SQL database as the persistent store.
bindCommon() - Method in class co.cask.coopr.store.guice.AbstractStoreModule
 
bootstrapResources(Account) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Bootstrap an account's resources by copying what the superadmin has into the account.
bootstrapTenant(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
 
build() - Method in class co.cask.coopr.cluster.Cluster.Builder
 
build() - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
build() - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
build() - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
build() - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
build() - Method in class co.cask.coopr.spec.HardwareType.Builder
 
build() - Method in class co.cask.coopr.spec.ImageType.Builder
 
build() - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
build() - Method in class co.cask.coopr.spec.plugin.AutomatorType.Builder
 
build() - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
build() - Method in class co.cask.coopr.spec.plugin.PluginFields.Builder
 
build() - Method in class co.cask.coopr.spec.plugin.ProviderType.Builder
 
build() - Method in class co.cask.coopr.spec.Provider.Builder
 
build() - Method in class co.cask.coopr.spec.service.Service.Builder
 
build() - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
build() - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
build() - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
build() - Method in class co.cask.coopr.spec.template.ClusterTemplate.Builder
 
build() - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
build() - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
 
build() - Method in class co.cask.coopr.spec.template.PartialTemplate.Builder
 
builder() - Static method in class co.cask.coopr.cluster.Cluster
Get a builder for creating a cluster object.
builder() - Static method in class co.cask.coopr.cluster.NodeProperties
Get a builder for building node properties.
builder() - Static method in class co.cask.coopr.common.security.CipherProvider
Get a builder for creating a cipher provider.
builder() - Static method in class co.cask.coopr.http.request.ClusterCreateRequest
Get a builder for creating cluster create requests.
builder() - Static method in class co.cask.coopr.spec.HardwareType
Get a builder for creating a hardware type.
builder() - Static method in class co.cask.coopr.spec.ImageType
Get a builder for creating a image type.
builder() - Static method in class co.cask.coopr.spec.plugin.AutomatorType
Get a builder for creating automator types.
builder() - Static method in class co.cask.coopr.spec.plugin.FieldSchema
Get a builder for creating a field schema.
builder() - Static method in class co.cask.coopr.spec.plugin.PluginFields
Get a builder for creating plugin fields.
builder() - Static method in class co.cask.coopr.spec.plugin.ProviderType
Get a builder for creating provider types.
builder() - Static method in class co.cask.coopr.spec.Provider
Get a builder for creating a provider.
builder() - Static method in class co.cask.coopr.spec.service.Service
Get a builder for creating a service.
builder() - Static method in class co.cask.coopr.spec.service.ServiceDependencies
Get a builder for creating service dependencies.
builder() - Static method in class co.cask.coopr.spec.template.ClusterDefaults
Get a builder for creating cluster defaults.
builder() - Static method in class co.cask.coopr.spec.template.ClusterTemplate
Get a builder for creating cluster templates.
builder() - Static method in class co.cask.coopr.spec.template.Compatibilities
Get a builder for creating compatibilities.
builder() - Static method in class co.cask.coopr.spec.template.LeaseDuration
 
builder() - Static method in class co.cask.coopr.spec.template.PartialTemplate
Get a builder for creating partial templates.

C

calcInitialLease(String) - Method in class co.cask.coopr.spec.template.LeaseDuration
Calculate the initial lease to use given the initial lease here and a requested initial lease.
calcInitialLease(long) - Method in class co.cask.coopr.spec.template.LeaseDuration
Calculate the initial lease to use given the initial lease here and a requested initial lease.
CALLBACK_CLASS - Static variable in class co.cask.coopr.common.conf.Constants
 
CallbackContext - Class in co.cask.coopr.scheduler.callback
Context that a ClusterCallback can take place in, giving the callback read access to cluster data and user information that would normally be accessible to the owner of the cluster.
CallbackContext(ClusterStoreService, UserStore, Account) - Constructor for class co.cask.coopr.scheduler.callback.CallbackContext
 
CallbackData - Class in co.cask.coopr.scheduler.callback
Data that a ClusterCallback may use before and after cluster jobs.
CallbackData(CallbackData.Type, Cluster, ClusterJob) - Constructor for class co.cask.coopr.scheduler.callback.CallbackData
 
CallbackData.Type - Enum in co.cask.coopr.scheduler.callback
Type of callback the data is for.
CallbackScheduler - Class in co.cask.coopr.scheduler
Polls a queue which contains CallbackData for performing cluster operation callbacks before starting an operation and upon success or failure of an operation.
canApplyChange(ClusterLayout) - Method in class co.cask.coopr.layout.change.AddServicesChange
 
canApplyChange(ClusterLayout) - Method in interface co.cask.coopr.layout.change.ClusterLayoutChange
Returns whether or not the change can be applied to the given ClusterLayout.
cancel() - Method in class co.cask.coopr.common.zookeeper.LeaderElection
Withdraw from the leader election process.
CapacityException - Exception in co.cask.coopr.provisioner
Thrown to indicate that there was a problem with provisioner capacity.
CapacityException(String) - Constructor for exception co.cask.coopr.provisioner.CapacityException
New exception with error message.
CapacityException(String, Throwable) - Constructor for exception co.cask.coopr.provisioner.CapacityException
 
CapacityException(Throwable) - Constructor for exception co.cask.coopr.provisioner.CapacityException
 
changeClusterParameter(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Changes a cluster parameter like lease time.
changeExpireTime(String, Account, long) - Method in class co.cask.coopr.cluster.ClusterService
Changes expire time of a cluster.
CipherProvider - Class in co.cask.coopr.common.security
Creates Ciphers given some cipher parameters.
CipherProvider.Builder - Class in co.cask.coopr.common.security
Builder for creating a cipher provider.
CipherProvider.Builder() - Constructor for class co.cask.coopr.common.security.CipherProvider.Builder
 
clear() - Method in class co.cask.coopr.common.conf.Configuration
Clears all keys from the configuration.
clear() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
clear() - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
clear() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
clearData() - Method in class co.cask.coopr.store.cluster.SQLClusterStoreService
 
clearData() - Method in class co.cask.coopr.store.entity.SQLEntityStoreService
 
clearData() - Method in class co.cask.coopr.store.node.SQLNodeStoreService
 
clearData() - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreService
 
clearData() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
clearData() - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
clearData() - Method in class co.cask.coopr.store.user.SQLUserStore
 
clearTasks() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Clear all tasks for the job.
Cluster - Class in co.cask.coopr.cluster
Represents a cluster of machines.
Cluster.Builder - Class in co.cask.coopr.cluster
Builds a cluster object.
Cluster.Builder() - Constructor for class co.cask.coopr.cluster.Cluster.Builder
 
Cluster.Status - Enum in co.cask.coopr.cluster
Cluster status.
CLUSTER_CLEANUP_SECS - Static variable in class co.cask.coopr.common.conf.Constants
 
CLUSTER_NAMESPACE - Static variable in class co.cask.coopr.common.conf.Constants.Lock
 
CLUSTER_TEMPLATES - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
ClusterAction - Enum in co.cask.coopr.scheduler
Actions that can be performed on a cluster.
ClusterCallback - Interface in co.cask.coopr.scheduler.callback
Executes some code before a job starts and after a job completes.
ClusterCleanup - Class in co.cask.coopr.scheduler
Run cleanup tasks.
ClusterCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Cluster.
ClusterCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterCodec
 
ClusterConfigureRequest - Class in co.cask.coopr.http.request
Request for reconfiguring a cluster.
ClusterConfigureRequest(Map<String, Object>, JsonObject, Boolean) - Constructor for class co.cask.coopr.http.request.ClusterConfigureRequest
 
ClusterConfigureRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ClusterConfigureRequest, used so some validation is done on required fields.
ClusterConfigureRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterConfigureRequestCodec
 
ClusterCreateRequest - Class in co.cask.coopr.http.request
Request to create a cluster, containing values for optional cluster settings.
ClusterCreateRequest.Builder - Class in co.cask.coopr.http.request
Builder for creating cluster create requests.
ClusterCreateRequest.Builder() - Constructor for class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
ClusterCreateRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ClusterCreateRequest, used so some validation is done on required fields.
ClusterCreateRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterCreateRequestCodec
 
clusterDefaults - Variable in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
clusterDefaults - Variable in class co.cask.coopr.spec.template.AbstractTemplate
 
ClusterDefaults - Class in co.cask.coopr.spec.template
Default values for a cluster.
ClusterDefaults.Builder - Class in co.cask.coopr.spec.template
Builder for creating cluster defaults.
ClusterDefaults.Builder() - Constructor for class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
ClusterDefaultsCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ClusterTemplate.
ClusterDefaultsCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterDefaultsCodec
 
ClusterDetails - Class in co.cask.coopr.cluster
Full cluster details, including the cluster object itself, all nodes in the cluster, and the progress of the last job performed on the cluster.
ClusterDetails(Cluster, Set<Node>, ClusterJob) - Constructor for class co.cask.coopr.cluster.ClusterDetails
 
ClusterDetails(Cluster, List<Link>, Set<Node>, ClusterJobProgress, String) - Constructor for class co.cask.coopr.cluster.ClusterDetails
 
ClusterDetailsCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing ClusterDetails.
ClusterDetailsCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterDetailsCodec
 
clusterExists(String) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
clusterExists(String) - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Return whether or not the cluster with the given id exists or not, where existence is determined by whether or not the cluster is in the store, and not by whether or not there is an active cluster with the given id.
clusterExists(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
ClusterHandler - Class in co.cask.coopr.http.handler
Handler for performing cluster operations.
ClusterJob - Class in co.cask.coopr.scheduler.task
A job contains information related to what needs to be done to perform and coordinate a cluster operation.
ClusterJob(JobId, ClusterAction) - Constructor for class co.cask.coopr.scheduler.task.ClusterJob
Create a cluster job with the given job id that represent the given action to perform on a cluster across all services and nodes on the cluster.
ClusterJob(JobId, ClusterAction, Set<String>, Set<String>) - Constructor for class co.cask.coopr.scheduler.task.ClusterJob
Create a cluster job with the given job id that represent the given action to perform on a cluster, for the given services on the given nodes.
ClusterJob.Status - Enum in co.cask.coopr.scheduler.task
Job status.
ClusterJobProgress - Class in co.cask.coopr.cluster
Summary of the progress of a ClusterJob.
ClusterJobProgress(ClusterJob) - Constructor for class co.cask.coopr.cluster.ClusterJobProgress
 
ClusterLayout - Class in co.cask.coopr.layout
Class describing the layout of a cluster, giving a mapping of NodeLayout to how many nodes use that layout.
ClusterLayout(Constraints, Multiset<NodeLayout>) - Constructor for class co.cask.coopr.layout.ClusterLayout
 
ClusterLayoutChange - Interface in co.cask.coopr.layout.change
Represents some change to a ClusterLayout, such as adding a service to some of the nodes.
ClusterLayoutFinder - Class in co.cask.coopr.layout
Class that takes in an ordered list of NodeLayouts by preference, ClusterTemplate, number of machines, and a set of services to place on the cluster, and figures out how many of each type of node should be used to satisfy constraints in the template.
ClusterLayoutFinder(List<NodeLayout>, ClusterTemplate, Set<String>, int) - Constructor for class co.cask.coopr.layout.ClusterLayoutFinder
 
ClusterLayoutTracker - Class in co.cask.coopr.layout.change
Helper for keeping track of changes made to a ClusterLayout.
ClusterLayoutTracker(ClusterLayout) - Constructor for class co.cask.coopr.layout.change.ClusterLayoutTracker
Create a layout change tracker given some starting layout.
ClusterLayoutUpdater - Class in co.cask.coopr.layout
Class that takes in an existing cluster and a request to update the cluster in some way, whether its by adding services, removing services, adding nodes, or removing nodes.
ClusterLayoutUpdater() - Constructor for class co.cask.coopr.layout.ClusterLayoutUpdater
 
ClusterOperationRequest - Class in co.cask.coopr.http.request
Request to perform some cluster operation that needs to communicate with a provider.
ClusterOperationRequest(Map<String, Object>) - Constructor for class co.cask.coopr.http.request.ClusterOperationRequest
 
ClusterOperationRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ClusterOperationRequest, used so some validation is done on required fields.
ClusterOperationRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterOperationRequestCodec
 
ClusterOwnerEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to the cluster owner.
ClusterOwnerEvaluator() - Constructor for class co.cask.coopr.macro.eval.ClusterOwnerEvaluator
 
ClusterScheduler - Class in co.cask.coopr.scheduler
Schedule clusters to be provisioned.
ClusterService - Class in co.cask.coopr.cluster
Service for performing operations on clusters.
ClusterService(ClusterStoreService, EntityStoreService, TenantProvisionerService, QueueService, LockService, ServerStats, Solver, IdService, CredentialStore, Gson, TemplateMerger) - Constructor for class co.cask.coopr.cluster.ClusterService
 
ClusterStats - Class in co.cask.coopr.management
Counters for different cluster actions used for JMX.
ClusterStats() - Constructor for class co.cask.coopr.management.ClusterStats
 
ClusterStatusResponse - Class in co.cask.coopr.http.request
The response to a cluster status call.
ClusterStatusResponse(Cluster, ClusterJob) - Constructor for class co.cask.coopr.http.request.ClusterStatusResponse
 
ClusterStore - Interface in co.cask.coopr.store.cluster
A full view of the cluster store for management purposes.
ClusterStoreService - Interface in co.cask.coopr.store.cluster
Service for getting a ClusterStoreView for different an account that will restrict what parts of the actual store can be viewed or edited.
ClusterStoreView - Interface in co.cask.coopr.store.cluster
A view of the cluster store as seen by a given account.
ClusterSummary - Class in co.cask.coopr.cluster
Summary of a Cluster, used in responding to REST API calls.
ClusterSummary(Cluster, ClusterJob) - Constructor for class co.cask.coopr.cluster.ClusterSummary
 
ClusterTask - Class in co.cask.coopr.scheduler.task
A task is some action that must be executed on a single node in the cluster.
ClusterTask(ProvisionerAction, TaskId, String, String, ClusterAction, String, Account) - Constructor for class co.cask.coopr.scheduler.task.ClusterTask
 
ClusterTask.Status - Enum in co.cask.coopr.scheduler.task
Task status.
ClusterTaskFilter - Class in co.cask.coopr.store.cluster
Class specifying filters to use when querying for cluster tasks.
ClusterTaskFilter(String, String, String, String, Long, Long, MetricService.Periodicity, TimeUnit) - Constructor for class co.cask.coopr.store.cluster.ClusterTaskFilter
 
ClusterTemplate - Class in co.cask.coopr.spec.template
A cluster template defines different types of clusters that will be available for users to create.
ClusterTemplate(BaseEntity.Builder, ClusterDefaults, Compatibilities, Constraints, Administration, Set<Link>, Parent, Set<Include>) - Constructor for class co.cask.coopr.spec.template.ClusterTemplate
 
ClusterTemplate.Builder - Class in co.cask.coopr.spec.template
Builder for creating cluster templates.
ClusterTemplate.Builder() - Constructor for class co.cask.coopr.spec.template.ClusterTemplate.Builder
 
ClusterTemplateCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ClusterTemplate.
ClusterTemplateCodec() - Constructor for class co.cask.coopr.codec.json.current.ClusterTemplateCodec
 
co.cask.coopr.account - package co.cask.coopr.account
User account related classes.
co.cask.coopr.cluster - package co.cask.coopr.cluster
Cluster and Node objects.
co.cask.coopr.codec.json - package co.cask.coopr.codec.json
Codecs for serializing object to json and deserializing objects from json.
co.cask.coopr.codec.json.current - package co.cask.coopr.codec.json.current
Codecs for serializing and deserializing current versions of objects to and from json.
co.cask.coopr.codec.json.guice - package co.cask.coopr.codec.json.guice
Guice classes for binding codec related classes.
co.cask.coopr.common.conf - package co.cask.coopr.common.conf
Configuration constants and defaults.
co.cask.coopr.common.conf.guice - package co.cask.coopr.common.conf.guice
Guice modules for configuration classes.
co.cask.coopr.common.daemon - package co.cask.coopr.common.daemon
Common classes for running daemons.
co.cask.coopr.common.queue - package co.cask.coopr.common.queue
Queues implemented on top of zookeeper.
co.cask.coopr.common.queue.guice - package co.cask.coopr.common.queue.guice
Guice modules for queue classes.
co.cask.coopr.common.security - package co.cask.coopr.common.security
Common security related utilities.
co.cask.coopr.common.utils - package co.cask.coopr.common.utils
Common utilities.
co.cask.coopr.common.zookeeper - package co.cask.coopr.common.zookeeper
Zookeeper utilities.
co.cask.coopr.common.zookeeper.guice - package co.cask.coopr.common.zookeeper.guice
Guice modules for zookeeper classes.
co.cask.coopr.common.zookeeper.lib - package co.cask.coopr.common.zookeeper.lib
Zookeeper utility libraries.
co.cask.coopr.http - package co.cask.coopr.http
Http handlers implementing REST endpoints.
co.cask.coopr.http.guice - package co.cask.coopr.http.guice
Guice modules for http classes.
co.cask.coopr.http.handler - package co.cask.coopr.http.handler
Http handlers.
co.cask.coopr.http.handler.auth - package co.cask.coopr.http.handler.auth
 
co.cask.coopr.http.request - package co.cask.coopr.http.request
Http requests.
co.cask.coopr.layout - package co.cask.coopr.layout
Classes related to solving cluster layouts.
co.cask.coopr.layout.change - package co.cask.coopr.layout.change
Classes related to changing cluster layouts.
co.cask.coopr.macro - package co.cask.coopr.macro
This package implements a simple macro expansion.
co.cask.coopr.macro.eval - package co.cask.coopr.macro.eval
This package implements classes for evaluating different types of macros.
co.cask.coopr.management - package co.cask.coopr.management
Stats for monitoring and managing the server.
co.cask.coopr.management.guice - package co.cask.coopr.management.guice
Guice modules for jmx classes.
co.cask.coopr.metrics - package co.cask.coopr.metrics
 
co.cask.coopr.provisioner - package co.cask.coopr.provisioner
Classes for interacting with provisioners.
co.cask.coopr.provisioner.guice - package co.cask.coopr.provisioner.guice
Guice modules for provisioner classes.
co.cask.coopr.provisioner.mock - package co.cask.coopr.provisioner.mock
Mock provisioner for integration testing.
co.cask.coopr.provisioner.plugin - package co.cask.coopr.provisioner.plugin
Classes for managing provisioner plugin data.
co.cask.coopr.runtime - package co.cask.coopr.runtime
Classes that can be run with main functions.
co.cask.coopr.scheduler - package co.cask.coopr.scheduler
Schedules threads for solving cluster layouts and planning and coordinating cluster jobs and tasks.
co.cask.coopr.scheduler.callback - package co.cask.coopr.scheduler.callback
Hooks for adding custom logic before and after cluster operations.
co.cask.coopr.scheduler.dag - package co.cask.coopr.scheduler.dag
Classes for creating and linearizing task DAGs.
co.cask.coopr.scheduler.guice - package co.cask.coopr.scheduler.guice
Guice modules for scheduler classes.
co.cask.coopr.scheduler.task - package co.cask.coopr.scheduler.task
Classes for coordinating tasks and jobs.
co.cask.coopr.spec - package co.cask.coopr.spec
Specifications for admin definable entities.
co.cask.coopr.spec.plugin - package co.cask.coopr.spec.plugin
Specifications for provisioner plugins.
co.cask.coopr.spec.service - package co.cask.coopr.spec.service
Specifications for services.
co.cask.coopr.spec.template - package co.cask.coopr.spec.template
Specifications for cluster templates.
co.cask.coopr.store - package co.cask.coopr.store
Persistent stores for admin definable entities, clusters, jobs, tasks, and nodes.
co.cask.coopr.store.cluster - package co.cask.coopr.store.cluster
Persistent store for clusters, jobs, tasks, and nodes.
co.cask.coopr.store.credential - package co.cask.coopr.store.credential
Classes for getting, setting, and deleting sensitive information in memory.
co.cask.coopr.store.entity - package co.cask.coopr.store.entity
Persistent store for admin definable entities.
co.cask.coopr.store.guice - package co.cask.coopr.store.guice
Guice modules for store classes.
co.cask.coopr.store.node - package co.cask.coopr.store.node
Persistent store for nodes.
co.cask.coopr.store.provisioner - package co.cask.coopr.store.provisioner
Persistent store for provisioner information.
co.cask.coopr.store.tenant - package co.cask.coopr.store.tenant
Persistent store for tenant information.
co.cask.coopr.store.user - package co.cask.coopr.store.user
 
co.cask.coopr.upgrade - package co.cask.coopr.upgrade
 
CodecModules - Class in co.cask.coopr.codec.json.guice
Guice module for binding serialization/deserialization related classes.
CodecModules() - Constructor for class co.cask.coopr.codec.json.guice.CodecModules
 
compare(NodeLayout, NodeLayout) - Method in class co.cask.coopr.layout.NodeLayoutComparator
 
compareTo(Node) - Method in class co.cask.coopr.cluster.Node
 
compatibilities - Variable in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
compatibilities - Variable in class co.cask.coopr.spec.template.AbstractTemplate
 
Compatibilities - Class in co.cask.coopr.spec.template
Defines hardwaretypes, imagetypes, and services that a cluster is compatible with.
Compatibilities.Builder - Class in co.cask.coopr.spec.template
Builder for creating Compatibilities.
Compatibilities.Builder() - Constructor for class co.cask.coopr.spec.template.Compatibilities.Builder
 
CompatibilitiesCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Compatibilities.
CompatibilitiesCodec() - Constructor for class co.cask.coopr.codec.json.current.CompatibilitiesCodec
 
compatibleWithHardwareType(String) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given hardware type is compatible.
compatibleWithHardwareTypes(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given hardware types are compatible.
compatibleWithImageType(String) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given image type is compatible.
compatibleWithImageTypes(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given image types are compatible.
compatibleWithService(String) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given service is compatible.
compatibleWithServices(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities
Return whether or not the given services are compatible.
completeAction(Node) - Method in class co.cask.coopr.scheduler.task.NodeService
Complete an action on a node.
completeJob(ClusterJob, Cluster) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.COMPLETE and the status of the given cluster to Cluster.Status.ACTIVE.
completeTask(ClusterTask, int) - Method in class co.cask.coopr.scheduler.task.TaskService
Complete a task by setting the status of the task to ClusterTask.Status.COMPLETE and the status time to the current timestamp and the status code to the given code.
Configurable - Interface in co.cask.coopr.common.conf
Interface defining the object is configurable.
CONFIGURABLE_STATES - Static variable in enum co.cask.coopr.cluster.Cluster.Status
 
Configuration - Class in co.cask.coopr.common.conf
Provides access to configuration parameters.
Configuration() - Constructor for class co.cask.coopr.common.conf.Configuration
A new configuration.
Configuration(Configuration) - Constructor for class co.cask.coopr.common.conf.Configuration
A new configuration with the same settings cloned from another.
Configuration.IntegerRanges - Class in co.cask.coopr.common.conf
A class that represents a set of positive integer ranges.
Configuration.IntegerRanges() - Constructor for class co.cask.coopr.common.conf.Configuration.IntegerRanges
 
Configuration.IntegerRanges(String) - Constructor for class co.cask.coopr.common.conf.Configuration.IntegerRanges
 
ConfigurationModule - Class in co.cask.coopr.common.conf.guice
Guice module that binds Configuration to a specific configuration instance.
ConfigurationModule() - Constructor for class co.cask.coopr.common.conf.guice.ConfigurationModule
 
ConfigurationModule(Configuration) - Constructor for class co.cask.coopr.common.conf.guice.ConfigurationModule
 
configure() - Method in class co.cask.coopr.common.conf.guice.ConfigurationModule
 
configure() - Method in class co.cask.coopr.common.queue.guice.QueueModule
 
configure() - Method in class co.cask.coopr.common.zookeeper.guice.ZookeeperModule
 
configure() - Method in class co.cask.coopr.http.guice.HttpModule
 
configure() - Method in class co.cask.coopr.management.guice.ManagementModule
 
configure() - Method in class co.cask.coopr.provisioner.guice.ProvisionerModule
 
configure() - Method in class co.cask.coopr.scheduler.guice.SchedulerModule
 
configure() - Method in class co.cask.coopr.store.guice.AbstractStoreModule
 
Constants - Class in co.cask.coopr.common.conf
Constants used by the system.
Constants() - Constructor for class co.cask.coopr.common.conf.Constants
 
Constants.CredentialStore - Class in co.cask.coopr.common.conf
Config settings for the crendential store.
Constants.CredentialStore() - Constructor for class co.cask.coopr.common.conf.Constants.CredentialStore
 
Constants.HandlersNames - Class in co.cask.coopr.common.conf
Handlers names constants.
Constants.HandlersNames() - Constructor for class co.cask.coopr.common.conf.Constants.HandlersNames
 
Constants.HttpCallback - Class in co.cask.coopr.common.conf
HttpPostClusterCallback config settings.
Constants.HttpCallback() - Constructor for class co.cask.coopr.common.conf.Constants.HttpCallback
 
Constants.LocalFilePluginStore - Class in co.cask.coopr.common.conf
Constants for the local file store implementation for plugin resources.
Constants.LocalFilePluginStore() - Constructor for class co.cask.coopr.common.conf.Constants.LocalFilePluginStore
 
Constants.Lock - Class in co.cask.coopr.common.conf
Lock related constants.
Constants.Lock() - Constructor for class co.cask.coopr.common.conf.Constants.Lock
 
Constants.MemcachedCredentialStore - Class in co.cask.coopr.common.conf
Config settings for the memcached credential store.
Constants.MemcachedCredentialStore() - Constructor for class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 
Constants.Metrics - Class in co.cask.coopr.common.conf
Metric config settings.
Constants.Metrics() - Constructor for class co.cask.coopr.common.conf.Constants.Metrics
 
Constants.Queue - Class in co.cask.coopr.common.conf
Queue related constants.
Constants.Queue() - Constructor for class co.cask.coopr.common.conf.Constants.Queue
 
constraints - Variable in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
constraints - Variable in class co.cask.coopr.spec.template.AbstractTemplate
 
Constraints - Class in co.cask.coopr.spec.template
Constraints for how a cluster can be laid out.
Constraints(Map<String, ServiceConstraint>, LayoutConstraint, SizeConstraint) - Constructor for class co.cask.coopr.spec.template.Constraints
 
ConstraintsCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Constraints.
ConstraintsCodec() - Constructor for class co.cask.coopr.codec.json.current.ConstraintsCodec
 
contains(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
containsAll(Collection<?>) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
containsKey(Object) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
containsKey(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
containsValue(Object) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
containsValue(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
copyEntities(Account, Account) - Method in interface co.cask.coopr.store.entity.EntityStoreService
Copy all entities from one account to another.
copyEntities(Account, Account) - Method in class co.cask.coopr.store.entity.SQLEntityStoreService
 
create(Gson, TypeToken<T>) - Method in class co.cask.coopr.codec.json.LowercaseEnumTypeAdapterFactory
 
create() - Static method in class co.cask.coopr.common.conf.Configuration
Creates an instance of configuration with default and site values.
createCluster(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.ClusterHandler
Create a new cluster.
createCurrentBuilder() - Method in class co.cask.coopr.codec.json.guice.CodecModules
 
createDerbyIndex(DBConnectionPool, String, String, String...) - Static method in class co.cask.coopr.store.DBHelper
Create an index on given columns in a table for an embedded derby table.
createDerbyTableIfNotExists(String, DBConnectionPool) - Static method in class co.cask.coopr.store.DBHelper
Try and create a table if it doesn't already exist.
createHostname(String, String, int, String) - Static method in class co.cask.coopr.scheduler.task.NodeService
Creates a unique hostname from the cluster name, cluster id, and node number.
createInitializedCipher(int) - Method in class co.cask.coopr.common.security.CipherProvider
Create a cipher initialized to the given mode.
createInsertStatement(Connection) - Method in class co.cask.coopr.store.DBPut
 
createInString(int) - Static method in class co.cask.coopr.store.DBHelper
Create a string for an IN clause in a sql query given the number of arguments that will be in the list.
createNode(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.NodeHandler
 
createOrSet(ZKClient, String, byte[], CreateMode) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
createOrSet(ZKClient, String, byte[], CreateMode, boolean) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
Acts as ZKClient.create(String, byte[], org.apache.zookeeper.CreateMode, boolean) if node does not exist, otherwise as ZKClient.setData(String, byte[]).
createResourceBodyConsumer(Account, ResourceType, String, HttpResponder) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Create a body consumer for streaming resource contents into the persistent store.
createTenant(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Add a tenant, optionally bootstrapping it with entities from the superadmin.
createUpdateStatement(Connection) - Method in class co.cask.coopr.store.DBPut
 
CREDENTIAL_STORE_CLASS - Static variable in class co.cask.coopr.common.conf.Constants
 
CredentialStore - Interface in co.cask.coopr.store.credential
Credential store for getting, setting, and wiping sensitive information such as user credentials.

D

DaemonMain - Class in co.cask.coopr.common.daemon
A abstract base class for bridging standard main method to method invoked through apache commons-daemon jsvc.
DaemonMain() - Constructor for class co.cask.coopr.common.daemon.DaemonMain
 
DATA_DIR - Static variable in class co.cask.coopr.common.conf.Constants.LocalFilePluginStore
 
DB_MAX_ACTIVE_CONNECTIONS - Static variable in class co.cask.coopr.common.conf.Constants
 
DB_PASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
DB_USER - Static variable in class co.cask.coopr.common.conf.Constants
 
DB_VALIDATION_QUERY - Static variable in class co.cask.coopr.common.conf.Constants
 
DBConnectionPool - Class in co.cask.coopr.store
Connection pool for databases using JDBC.
dbConnectionPool - Variable in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
DBHelper - Class in co.cask.coopr.store
Helper methods for performing database administrative operations.
DBHelper() - Constructor for class co.cask.coopr.store.DBHelper
 
DBPut - Class in co.cask.coopr.store
Interface used to put an object into a database by first trying to perform an update, and then performing an insert if the update did not affect any rows.
DBPut() - Constructor for class co.cask.coopr.store.DBPut
 
DBQueryExecutor - Class in co.cask.coopr.store
Executes prepared statements against databases while taking care of serialization/deserialization of blobs.
decodeAndDecryptString(byte[]) - Method in class co.cask.coopr.common.security.Encryptor
Base64 decode then decrypt the given bytes, assuming it was a string that was encrypted and encoded using the same encryption transformation as this class.
decodeRequestBody(HttpRequest, HttpResponder, Type, Gson) - Static method in class co.cask.coopr.http.HttpHelper
Decode the request body into the given type of object using the give gson instance.
DEFAULT_FAILURE_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
DEFAULT_MAX_CONNECTIONS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
DEFAULT_SOCKET_TIMEOUT - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
DEFAULT_START_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
DEFAULT_SUCCESS_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
DEFAULT_SUPERADMIN - Static variable in class co.cask.coopr.spec.Tenant
 
DEFAULT_TIMEOUT - Static variable in class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 
DEFAULT_TTL - Static variable in class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 
DEFAULT_VERSION - Static variable in class co.cask.coopr.common.conf.Constants
 
delete(ZKClient, String, boolean) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
delete(ZKClient, String, int, boolean) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
Acts as ZKClient.delete(String) if passed ignoreIfAbsent param is false.
delete(Account, ResourceType, String, int) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Delete the given resource.
delete(Account, ResourceType, String) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Delete all versions of the given resource.
delete(String, int) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Delete the given version of the given resource from the store.
delete(String, int) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
deleteAutomatorType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Delete a specific AutomatorType.
deleteAutomatorType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Delete a specific AutomatorType.
deleteAutomatorType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteAutomatorType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteAutomatorType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the AutomatorType associated with the given unique name.
deleteAutomatorType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the AutomatorType associated with the given unique name.
deleteAutomatorTypeResource(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Delete all versions of the given resource.
deleteAutomatorTypeResourceVersion(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Delete a specific version of the given resource.
deleteCluster(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Delete a specific cluster that is deletable by the user.
deleteCluster(String) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
deleteCluster(String) - Method in interface co.cask.coopr.store.cluster.ClusterStoreView
Delete the cluster that has the given id.
deleteCluster(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
deleteClusterJob(JobId) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Deletes the cluster job that has the given id.
deleteClusterJob(JobId) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
deleteClusterTask(TaskId) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Deletes the cluster task that has the given id.
deleteClusterTask(TaskId) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
deleteClusterTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific ClusterTemplate.
deleteClusterTemplate(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific ClusterTemplate.
deleteClusterTemplate(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteClusterTemplate(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteClusterTemplate(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ClusterTemplate associated with the given unique name.
deleteClusterTemplate(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ClusterTemplate associated with the given unique name and version.
deleteEntity(BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Delete all entities of given type and name from persistent store.
deleteEntity(BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Delete the entity of given type, name and version from persistent store.
deleteEntity(BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.SQLAdminEntityStoreView
 
deleteEntity(BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.SQLAdminEntityStoreView
 
deleteEntity(BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.SQLUserEntityStoreView
 
deleteEntity(BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.SQLUserEntityStoreView
 
deleteHardwareType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific HardwareType.
deleteHardwareType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific HardwareType.
deleteHardwareType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteHardwareType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteHardwareType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the HardwareType associated with the given unique name.
deleteHardwareType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the HardwareType associated with the given unique name and version.
deleteImageType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific ImageType.
deleteImageType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific ImageType.
deleteImageType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteImageType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteImageType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ImageType associated with the given unique name.
deleteImageType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ImageType associated with the given unique name and version.
deleteNode(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.NodeHandler
 
deleteNode(String) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Delete the node with the given id.
deleteNode(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
deleteNode(String) - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
deleteNode(String) - Method in interface co.cask.coopr.store.node.NodeStoreView
Delete the node with the given id.
deleteNode(String) - Method in class co.cask.coopr.store.node.SQLNodeStore
 
deletePartialTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific PartialTemplate.
deletePartialTemplate(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific PartialTemplate.
deletePartialTemplate(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deletePartialTemplate(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deletePartialTemplate(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the PartialTemplate associated with the given unique name.
deletePartialTemplate(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the PartialTemplate associated with the given unique name.
deleteProfile(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.UserHandler
Delete the profile for an account.
deleteProfile(Account) - Method in class co.cask.coopr.store.user.SQLUserStore
 
deleteProfile(Account) - Method in interface co.cask.coopr.store.user.UserStore
Delete the profile for an account.
deleteProvider(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific Provider.
deleteProvider(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific Provider.
deleteProvider(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteProvider(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteProvider(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the Provider associated with the given unique name.
deleteProvider(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the Provider associated with the given unique name and version.
deleteProviderType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Delete a specific ProviderType.
deleteProviderType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Delete a specific ProviderType.
deleteProviderType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteProviderType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteProviderType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ProviderType associated with the given unique name.
deleteProviderType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the ProviderType associated with the given unique name.
deleteProviderTypeResource(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Delete all versions of the given resource.
deleteProviderTypeResourceVersion(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Delete a specific version of the given resource.
deleteProvisioner(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Delete a provisioner.
deleteProvisioner(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Delete the given provisioner, queueing a job to reassign its workers to different provisioners.
deleteProvisioner(String) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Delete the provisioner with the given id.
deleteProvisioner(String) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
deleteResource(Account, ResourceType, String, int) - Method in class co.cask.coopr.store.provisioner.LocalFilePluginStore
 
deleteResource(Account, ResourceType, String, int) - Method in interface co.cask.coopr.store.provisioner.PluginStore
Delete a plugin resource.
deleteService(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific Service.
deleteService(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Delete a specific Service.
deleteService(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteService(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
deleteService(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the Service associated with the given unique name.
deleteService(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Delete the Service associated with the given unique name and version.
deleteTenant(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Delete the specified tenant.
deleteTenant(Provisioner, String) - Method in class co.cask.coopr.provisioner.HttpProvisionerRequestService
 
deleteTenant(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerHandler
 
deleteTenant(String) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Delete a tenant from the store.
deleteTenant(Provisioner, String) - Method in interface co.cask.coopr.provisioner.ProvisionerRequestService
Make a request to the provisioner to delete the given tenant.
deleteTenantByName(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Delete the given tenant.
deleteTenantByName(String) - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
deleteTenantByName(String) - Method in interface co.cask.coopr.store.tenant.TenantStore
Delete the Tenant associated with the given name.
description - Variable in class co.cask.coopr.spec.BaseEntity.Builder
 
description - Variable in class co.cask.coopr.spec.BaseEntity
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractBaseEntityCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AddServicesRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AdministrationCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterConfigureRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterCreateRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterDefaultsCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterDetailsCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterOperationRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.CompatibilitiesCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ConstraintsCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.FieldSchemaCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.FinishTaskRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.LayoutConstraintCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.LeaseDurationCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.NodeCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.NodePropertiesRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ParametersSpecificationCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.PluginResourceMetaCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ProvisionerCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ResourceTypeSpecificationCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceActionCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceConstraintCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceDependenciesCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceStageDependenciesCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.SizeConstraintCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.TakeTaskRequestCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.TaskConfigCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.TenantCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.TenantSpecificationCodec
 
deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.TenantWriteRequestCodec
 
deserialize(byte[]) - Method in interface co.cask.coopr.common.zookeeper.lib.Serializer
Deserialize the bytes into an object.
deserializeBlob(Blob, Class<T>) - Method in class co.cask.coopr.store.DBQueryExecutor
Deserialize a blob into an object.
deserializeCluster(JsonElement, JsonDeserializationContext) - Static method in class co.cask.coopr.codec.json.current.ClusterCodec
 
destroy() - Method in class co.cask.coopr.common.daemon.DaemonMain
Invoked by jsvc for resource cleanup.
destroy() - Method in class co.cask.coopr.runtime.MockProvisionerMain
Invoked by jsvc for resource cleanup.
destroy() - Method in class co.cask.coopr.runtime.ServerMain
Invoked by jsvc for resource cleanup.
doMain(String[]) - Method in class co.cask.coopr.common.daemon.DaemonMain
The main method.
dropDerbyDB() - Static method in class co.cask.coopr.store.DBHelper
Drop all embedded derby dbs.
dropTask(ClusterTask) - Method in class co.cask.coopr.scheduler.task.TaskService
Drop a task by setting the status of the task to ClusterTask.Status.DROPPED and the status time to the current timestamp.
dumpConfiguration(Configuration, Writer) - Static method in class co.cask.coopr.common.conf.Configuration
Writes out all the parameters and their properties (final and resource) to the given Writer The format of the output would be { "properties" : [ {key1,value1,key1.isFinal,key1.resource}, {key2,value2, key2.isFinal,key2.resource}...

E

ElectionHandler - Interface in co.cask.coopr.common.zookeeper
Handles events of election/un-election of leader.
Element - Class in co.cask.coopr.common.queue
The element to be placed in the TrackingQueue.
Element(String, String) - Constructor for class co.cask.coopr.common.queue.Element
Queue element with the given id and value.
Element(String) - Constructor for class co.cask.coopr.common.queue.Element
Queue element with the given value and an automatically generated id.
EMBEDDED_DERBY_DRIVER - Static variable in class co.cask.coopr.common.conf.Constants
 
EMPTY - Static variable in class co.cask.coopr.spec.template.SizeConstraint
 
EMPTY_ADMINISTRATION - Static variable in class co.cask.coopr.spec.template.Administration
 
EMPTY_CLUSTER_DEFAULTS - Static variable in class co.cask.coopr.spec.template.ClusterDefaults
 
EMPTY_COMPATIBILITIES - Static variable in class co.cask.coopr.spec.template.Compatibilities
 
EMPTY_CONSTRAINTS - Static variable in class co.cask.coopr.spec.template.Constraints
 
EMPTY_LAYOUT_CONSTRAINT - Static variable in class co.cask.coopr.spec.template.LayoutConstraint
 
EMPTY_SERVICE_DEPENDENCIES - Static variable in class co.cask.coopr.spec.service.ServiceDependencies
 
EMPTY_SERVICE_STAGE_DEPENDENCIES - Static variable in class co.cask.coopr.spec.service.ServiceStageDependencies
 
EMPTY_SPECIFICATION - Static variable in class co.cask.coopr.spec.plugin.ParametersSpecification
 
EMPTY_STRING_ARRAY - Static variable in class co.cask.coopr.common.utils.StringUtils
 
ENCRYPT_ENABLED - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
ENCRYPT_IV_HEX - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
ENCRYPT_TRANSFORMATION - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
encryptAndEncodeString(String) - Method in class co.cask.coopr.common.security.Encryptor
Encrypt then base64 encode the given input string.
EncryptedCredentialStore - Class in co.cask.coopr.store.credential
Abstract base for implementations of CredentialStore that encrypt values before storing in whatever the storage engine is.
EncryptedCredentialStore(Configuration) - Constructor for class co.cask.coopr.store.credential.EncryptedCredentialStore
 
Encryptor - Class in co.cask.coopr.common.security
Transforms plaintext to and from ciphertext, also providing utilities to encode/decode ciphertext in Base64 so the results can be used as strings.
Encryptor(CipherProvider) - Constructor for class co.cask.coopr.common.security.Encryptor
 
ensureExists(ZKClient, String) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
Acts as create(path, null, CreateMode.PERSISTENT, true) if node doesn't exist.
EntityStoreService - Interface in co.cask.coopr.store.entity
Service that returns views of the entity store as seen by tenant admins.
EntityStoreView - Interface in co.cask.coopr.store.entity
A view of the entity store for adding, modifying, retrieving, and deleting entities that are accessible by a tenant admin user.
entrySet() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
entrySet() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
equals(Object) - Method in class co.cask.coopr.account.Account
 
equals(Object) - Method in class co.cask.coopr.cluster.Cluster
 
equals(Object) - Method in class co.cask.coopr.cluster.ClusterDetails
 
equals(Object) - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
equals(Object) - Method in class co.cask.coopr.cluster.ClusterSummary
 
equals(Object) - Method in class co.cask.coopr.cluster.Node
 
equals(Object) - Method in class co.cask.coopr.cluster.NodeProperties
 
equals(Object) - Method in class co.cask.coopr.common.queue.QueueMetrics
 
equals(Object) - Method in class co.cask.coopr.common.utils.ImmutablePair
Returns whether some other object "is equal" to this object.
equals(Object) - Method in class co.cask.coopr.http.request.ClusterConfigureRequest
 
equals(Object) - Method in class co.cask.coopr.http.request.ClusterCreateRequest
 
equals(Object) - Method in class co.cask.coopr.http.request.ClusterOperationRequest
 
equals(Object) - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
equals(Object) - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
equals(Object) - Method in class co.cask.coopr.http.request.TakeTaskRequest
 
equals(Object) - Method in class co.cask.coopr.http.request.TenantWriteRequest
 
equals(Object) - Method in class co.cask.coopr.layout.change.AddServicesChange
 
equals(Object) - Method in class co.cask.coopr.layout.ClusterLayout
 
equals(Object) - Method in class co.cask.coopr.layout.NodeLayout
 
equals(Object) - Method in class co.cask.coopr.macro.eval.HostServiceEvaluator
 
equals(Object) - Method in class co.cask.coopr.macro.eval.IPSelfEvaluator
 
equals(Object) - Method in class co.cask.coopr.macro.eval.IPServiceEvaluator
 
equals(Object) - Method in class co.cask.coopr.macro.eval.ServiceCardinalityEvaluator
 
equals(Object) - Method in class co.cask.coopr.macro.eval.ServiceEvaluator
 
equals(Object) - Method in class co.cask.coopr.macro.Expression
 
equals(Object) - Method in class co.cask.coopr.metrics.Interval
 
equals(Object) - Method in class co.cask.coopr.metrics.TimeSeries
 
equals(Object) - Method in class co.cask.coopr.provisioner.plugin.ResourceMeta
 
equals(Object) - Method in class co.cask.coopr.provisioner.plugin.ResourceType
 
equals(Object) - Method in class co.cask.coopr.provisioner.Provisioner
 
equals(Object) - Method in class co.cask.coopr.provisioner.ProvisionerHeartbeat
 
equals(Object) - Method in class co.cask.coopr.scheduler.ActionOnService
 
equals(Object) - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
equals(Object) - Method in class co.cask.coopr.scheduler.callback.CallbackData
 
equals(Object) - Method in class co.cask.coopr.scheduler.dag.TaskDag
 
equals(Object) - Method in class co.cask.coopr.scheduler.dag.TaskNode
 
equals(Object) - Method in class co.cask.coopr.scheduler.SolverRequest
 
equals(Object) - Method in class co.cask.coopr.scheduler.task.ClusterJob
 
equals(Object) - Method in class co.cask.coopr.scheduler.task.ClusterTask
 
equals(Object) - Method in class co.cask.coopr.scheduler.task.TaskConfig
 
equals(Object) - Method in class co.cask.coopr.scheduler.task.TaskServiceAction
 
equals(Object) - Method in class co.cask.coopr.spec.BaseEntity
 
equals(Object) - Method in class co.cask.coopr.spec.HardwareType
 
equals(Object) - Method in class co.cask.coopr.spec.ImageType
 
equals(Object) - Method in class co.cask.coopr.spec.Link
 
equals(Object) - Method in class co.cask.coopr.spec.NamedEntity
 
equals(Object) - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
 
equals(Object) - Method in class co.cask.coopr.spec.plugin.FieldSchema
 
equals(Object) - Method in class co.cask.coopr.spec.plugin.ParametersSpecification
 
equals(Object) - Method in class co.cask.coopr.spec.plugin.PluginFields
 
equals(Object) - Method in class co.cask.coopr.spec.plugin.ResourceTypeSpecification
 
equals(Object) - Method in class co.cask.coopr.spec.Provider
 
equals(Object) - Method in class co.cask.coopr.spec.service.Service
 
equals(Object) - Method in class co.cask.coopr.spec.service.ServiceAction
 
equals(Object) - Method in class co.cask.coopr.spec.service.ServiceDependencies
 
equals(Object) - Method in class co.cask.coopr.spec.service.ServiceStageDependencies
 
equals(Object) - Method in class co.cask.coopr.spec.template.AbstractTemplate
 
equals(Object) - Method in class co.cask.coopr.spec.template.Administration
 
equals(Object) - Method in class co.cask.coopr.spec.template.ClusterTemplate
 
equals(Object) - Method in class co.cask.coopr.spec.template.Compatibilities
 
equals(Object) - Method in class co.cask.coopr.spec.template.Constraints
 
equals(Object) - Method in class co.cask.coopr.spec.template.Include
 
equals(Object) - Method in class co.cask.coopr.spec.template.LayoutConstraint
 
equals(Object) - Method in class co.cask.coopr.spec.template.LeaseDuration
 
equals(Object) - Method in class co.cask.coopr.spec.template.Parent
 
equals(Object) - Method in class co.cask.coopr.spec.template.PartialTemplate
 
equals(Object) - Method in class co.cask.coopr.spec.template.ServiceConstraint
 
equals(Object) - Method in class co.cask.coopr.spec.template.SizeConstraint
 
equals(Object) - Method in class co.cask.coopr.spec.Tenant
 
equals(Object) - Method in class co.cask.coopr.spec.TenantSpecification
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.ClusterOwnerEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in interface co.cask.coopr.macro.eval.Evaluator
Evaluate the macro expression on the given node of the given cluster, with the given cluster nodes.
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.HostSelfEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.HostServiceEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.IPSelfEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.IPServiceEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.ServiceCardinalityEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.eval.ServiceInstanceEvaluator
 
evaluate(Cluster, Set<Node>, Node) - Method in class co.cask.coopr.macro.Expression
Evaluate the expression for a given cluster.
Evaluator - Interface in co.cask.coopr.macro.eval
Evaluator for a specific type of expression, such as an IP expression or a hostname expression.
evaluatorFor(String, Integer) - Static method in class co.cask.coopr.macro.eval.Evaluators
 
Evaluators - Class in co.cask.coopr.macro.eval
Parses a macro string and returns the correct evaluator for expanding the macro.
Evaluators() - Constructor for class co.cask.coopr.macro.eval.Evaluators
 
executePut(Connection) - Method in class co.cask.coopr.store.DBPut
Execute the put using the given connection.
executor() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerService
 
executor() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerWorkerService
 
executor() - Method in class co.cask.coopr.provisioner.mock.MockWorker
 
exists(String) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Checks whether or not any version of the given resource exists.
exists(String, int) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Checks whether or not a specific version of the given resource exists.
exists(String) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
exists(String, int) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
expand(String, Cluster, Set<Node>, Node) - Static method in class co.cask.coopr.macro.Expander
Given a text that may contain macros, validate and expand all macros in the context of the given cluster nodes, and on the specified node.
expand(JsonElement, List<String>, Cluster, Set<Node>, Node) - Static method in class co.cask.coopr.macro.Expander
Given a JSON tree, find the element specified by the path (or the root if path is null).
Expander - Class in co.cask.coopr.macro
A simple macro expander.
Expander() - Constructor for class co.cask.coopr.macro.Expander
 
exportConfig(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Export all providers, hardware types, image types, services, cluster templates and partial templates.
Expression - Class in co.cask.coopr.macro
An expression represents a single macro.
Expression(Evaluator, String, String) - Constructor for class co.cask.coopr.macro.Expression
Constructor with all argument.
EXTERNAL - Static variable in class co.cask.coopr.common.conf.Constants.HandlersNames
 
EXTERNAL_ENABLE_SSL - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_PORT - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_SSL_KEYPASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_SSL_KEYSTORE_PASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_SSL_KEYSTORE_PATH - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_SSL_TRUST_KEYPASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
EXTERNAL_SSL_TRUST_KEYSTORE_PATH - Static variable in class co.cask.coopr.common.conf.Constants
 
ExternalHandlerServer - Class in co.cask.coopr.http
Netty service for running the server that manages external API.

F

failAction(Node, String, String) - Method in class co.cask.coopr.scheduler.task.NodeService
Fail an action on a node with optional logs on what went wrong.
failedBeforeCreate() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Return whether or not the task failed before it could create any resources, such as a node or a disk.
failJob(ClusterJob) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.FAILED and persists it to the store.
failJobAndSetClusterStatus(ClusterJob, Cluster, Cluster.Status, String) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to some given status.
failJobAndSetClusterStatus(ClusterJob, Cluster) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to the default failure status as given in ClusterAction.getFailureStatus().
failJobAndTerminateCluster(ClusterJob, Cluster, String) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.FAILED and the status of the given cluster to Cluster.Status.TERMINATED.
failTask(ClusterTask, int) - Method in class co.cask.coopr.scheduler.task.TaskService
Fail a task by setting the status of the task to ClusterTask.Status.FAILED and the status time to the current timestamp and the status code to the given code.
FAILURE_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
FAILURE_URL - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
FieldSchema - Class in co.cask.coopr.spec.plugin
A description of some field that the corresponding provisioner plugin understands, defining what type of value is expected for the field.
FieldSchema.Builder - Class in co.cask.coopr.spec.plugin
Builds a FieldSchema.
FieldSchema.Builder() - Constructor for class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
FieldSchemaCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a FieldSchema.
FieldSchemaCodec() - Constructor for class co.cask.coopr.codec.json.current.FieldSchemaCodec
 
FIND_MAX_VERSION - Static variable in class co.cask.coopr.common.conf.Constants
 
findValidNodeCounts() - Method in class co.cask.coopr.layout.ClusterLayoutFinder
Get how many of each node type to use in the cluster, or null if there is no possible cluster layout that satisfies all cluster constraints.
finishClusterTask(FinishTaskRequest) - Method in class co.cask.coopr.scheduler.task.TaskQueueService
Records the status of a finished task from provisioner.
FinishTaskRequest - Class in co.cask.coopr.http.request
Request sent by provisioners for finishing a task that was performed perform.
FinishTaskRequest(String, String, String, String, String, String, Integer, String, Map<String, String>, JsonObject) - Constructor for class co.cask.coopr.http.request.FinishTaskRequest
 
FinishTaskRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a FinishTaskRequest.
FinishTaskRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.FinishTaskRequestCodec
 
follower() - Method in interface co.cask.coopr.common.zookeeper.ElectionHandler
This method will get invoked when a participant is a follower in a leader election process.
FOREVER_LEASE_DURATION - Static variable in class co.cask.coopr.spec.template.LeaseDuration
 
from(Cluster, Node, Service, JsonObject, ProvisionerAction, Collection<Node>) - Static method in class co.cask.coopr.scheduler.task.TaskConfig
Create a task config from the given input.
from(BaseEntity) - Static method in class co.cask.coopr.spec.BaseEntity
Create an admin entity from another admin entity.
fromLiveFlags(boolean, boolean) - Static method in enum co.cask.coopr.provisioner.plugin.ResourceStatus
Return the status that corresponds to the given values of being live and slated to be live.
fromNode(Node) - Static method in class co.cask.coopr.layout.NodeLayout
Return the node layout of a given Node.
fromNodes(Set<Node>, Constraints) - Static method in class co.cask.coopr.layout.ClusterLayout
Derive a ClusterLayout from a set of Nodes and some Constraints.
fromString(String) - Static method in class co.cask.coopr.scheduler.task.JobId
Convert a string representation of a job id into an object while validating that the string is correctly formatted.
fromString(String) - Static method in class co.cask.coopr.scheduler.task.TaskId
Returns a task id from a string, validating that the string is a valid id.

G

generateNodeLayoutPreferences() - Method in class co.cask.coopr.layout.NodeLayoutGenerator
Get an ordered list of possible NodeLayouts to use in the cluster.
get(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property, null if no such property exists.
get(String, String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name.
get(Object) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
get(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
get(String, String) - Method in interface co.cask.coopr.store.credential.CredentialStore
Get the fields for the given tenant and cluster.
get(String, String) - Method in class co.cask.coopr.store.credential.EncryptedCredentialStore
 
get(String, String) - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
get(String, int) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get the metadata for the given resource name and version.
get(String, int) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getAccount() - Method in class co.cask.coopr.cluster.Cluster
Get the account of the owner of the cluster.
getAccount() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Retrieves the account this task is created by.
getAccountProfile() - Method in class co.cask.coopr.scheduler.callback.CallbackContext
Get the profile of the account that owns the cluster, or null if none exists.
getAccountView(Account) - Method in interface co.cask.coopr.store.provisioner.PluginMetaStoreService
Get a view of the metadata store for the given account.
getAccountView(Account) - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreService
 
getAction() - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
getAction() - Method in class co.cask.coopr.cluster.Node.Action
Get the action, such as create, confirm, bootstrap, install, configure, etc.
getAction() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getAction() - Method in class co.cask.coopr.scheduler.ActionOnService
 
getAction() - Method in class co.cask.coopr.scheduler.task.TaskServiceAction
Get the service action to perform.
getActionDependencies() - Method in class co.cask.coopr.scheduler.Actions
Get the set of Actions.Dependency describing which ProvisionerActions depend on other ProvisionerActions for service provisioner actions.
getActionOrder() - Method in class co.cask.coopr.scheduler.Actions
Get the order ProvisionerActions should be performed in order to carry out different ClusterActions.
getActions() - Method in class co.cask.coopr.cluster.Node
Get the list of actions that have been performed on the node.
getActionstatus() - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
getActionstatus() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getAdministration() - Method in class co.cask.coopr.spec.template.AbstractTemplate
Get administration settings like lease time for managing the cluster.
getAll(Account, ResourceType, ResourceStatus) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get all resource metadata of the given type that belong to the given account that have the given status.
getAll(Account, ResourceType, String, ResourceStatus) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get all metadata for versions of the given resource that have the given status.
getAll() - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable map of resource name to all metadata with that name.
getAll(ResourceStatus) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable map of resource name to all metadata with that name with the given status.
getAll(String) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable set of all resource metadata for the given resource name.
getAll(String, ResourceStatus) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable set of all resource metadata for the given resource name with the given status.
getAll() - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getAll(ResourceStatus) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getAll(String) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getAll(String, ResourceStatus) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getAllAutomatorTypeModules(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Get a mapping of all resources of the given type for the given automator type.
getAllAutomatorTypeResourceVersions(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Get a list of all versions of the given resource of the given type for the given automator type.
getAllAutomatorTypes() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllAutomatorTypes() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all AutomatorTypes.
getAllClusters() - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getAllClusters() - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get an immutable list of all clusters in the store.
getAllClusters() - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getAllClusterSummaries() - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getAllClusterSummaries(Set<Cluster.Status>) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getAllClusterSummaries() - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get an immutable list of summaries of all clusters in the store.
getAllClusterSummaries(Set<Cluster.Status>) - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get an immutable list of summaries of all clusters in the store that are in one of the given cluster states.
getAllClusterSummaries() - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getAllClusterSummaries(Set<Cluster.Status>) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getAllClusterTemplates() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllClusterTemplates() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all ClusterTemplates.
getAllHardwareTypes() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllHardwareTypes() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all HardwareTypes.
getAllImageTypes() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllImageTypes() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all ImageTypes.
getAllLatestEntities(BaseEntityStoreView.EntityType, Function<byte[], T>) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Get all entities of the given type from persistent store.
getAllLatestEntities(BaseEntityStoreView.EntityType, Function<byte[], T>) - Method in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
getAllNodes() - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
getAllNodes() - Method in interface co.cask.coopr.store.node.NodeStoreView
Get an immutable set of all nodes in the store.
getAllNodes() - Method in class co.cask.coopr.store.node.SQLNodeStore
 
getAllPartialTemplates() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllPartialTemplates() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all PartialTemplates.
getAllProviders() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllProviders() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all Providers.
getAllProviderTypeModules(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Get a mapping of all resources of the given type for the given provider type.
getAllProviderTypeResourceVersions(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Get a list of all versions of the given resource of the given type for the given provider type.
getAllProviderTypes() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllProviderTypes() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all ProviderTypes.
getAllProvisioners() - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Get an immutable collection of all provisioners for external display, with tenant ids mapped to tenant names.
getAllProvisioners() - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get all provisioners in the system.
getAllProvisioners() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getAllQueueGroups() - Method in interface co.cask.coopr.common.queue.QueueService
 
getAllServices() - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAllServices() - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get all Services.
getAllTenants(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Get all tenants.
getAllTenants() - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
getAllTenants() - Method in interface co.cask.coopr.store.tenant.TenantStore
Get an immutable list of all tenants.
getAllTenantSpecifications() - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Get an unmodifiable collection of all tenant specifications.
getAllTenantSpecifications() - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
getAllTenantSpecifications() - Method in interface co.cask.coopr.store.tenant.TenantStore
Get an immutable list of all TenantSpecification.
getAndAuthenticateAccount(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AbstractAuthHandler
Gets the user and tenant from the request and authenticates, returning null and writing an error message to the responder if there was an error getting or authenticating the user and tenant.
getAssignedTenants() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get all tenants that have been assigned workers.
getAssignedTenants() - Method in class co.cask.coopr.provisioner.Provisioner
Get the unmodifiable set of tenants that are assigned to the provisioner.
getAssignedWorkers(String) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get the number of workers assigned to the given tenant.
getAssignedWorkers(String) - Method in class co.cask.coopr.provisioner.Provisioner
Get the number of workers assigned to the given tenant on this provisioner.
getAutomatorResource(HttpRequest, HttpResponder, String, String, String, String, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Get the contents of a specific resource.
getAutomators() - Method in class co.cask.coopr.cluster.NodeProperties
Get an immutable set of the names of the automators that can perform actions on the node.
getAutomatorType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific AutomatorType if readable by the user.
getAutomatorType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific AutomatorType if readable by the user.
getAutomatorType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAutomatorType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getAutomatorType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the AutomatorType associated with the given unique name or null if no such automator type exists.
getAutomatorType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the AutomatorType associated with the given unique name or null if no such automator type exists.
getAutomatorTypes(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all AutomatorTypes readable by the user.
getBeingConsumed(String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Get all elements being consumed from a specific queue.
getBeingConsumed() - Method in interface co.cask.coopr.common.queue.TrackingQueue
Get all QueuedElement that are being consumed.
getBlobColumn() - Method in enum co.cask.coopr.store.entity.BaseEntityStoreView.EntityType
 
getBoolean(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a boolean.
getBoolean(String, boolean) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a boolean.
getBootstrap() - Method in class co.cask.coopr.management.ProvisionerStats
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractBaseEntityCodec
Get a builder initialized with child specific fields.
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractTemplateCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.AutomatorTypeCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterTemplateCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.HardwareTypeCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ImageTypeCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.PartialTemplateCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ProviderCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ProviderTypeCodec
 
getBuilder(JsonObject, JsonDeserializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceCodec
 
getCapacityFree() - Method in class co.cask.coopr.provisioner.Provisioner
Get the number of workers that can be added to the provisioner.
getCapacityTotal() - Method in class co.cask.coopr.provisioner.Provisioner
Get the total capacity of the provisioner.
getChanges() - Method in class co.cask.coopr.layout.change.ClusterLayoutTracker
Get the changes that were applied to the starting cluster layout.
getChildrenOrNull(ZKClient, String) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
getChildrenOrNull(ZKClient, String, Watcher) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
Acts as ZKClient.getChildren(String, Watcher) if node exists.
getClass(String, Class<?>) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a Class.
getClass(String, Class<? extends U>, Class<U>) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a Class implementing the interface specified by xface.
getClass(T) - Static method in class co.cask.coopr.common.utils.ReflectionUtils
Return the correctly-typed Class of the given object.
getClassByName(String) - Method in class co.cask.coopr.common.conf.Configuration
Load a class by name.
getClassByNameOrNull(String) - Method in class co.cask.coopr.common.conf.Configuration
Load a class by name, returning null rather than throwing an exception if it couldn't be loaded.
getClasses(String, Class<?>...) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as an array of Class.
getClassLoader() - Method in class co.cask.coopr.common.conf.Configuration
Get the ClassLoader for this job.
getCluster() - Method in class co.cask.coopr.cluster.ClusterDetails
Get the cluster.
getCluster(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get a specific cluster visible to the user.
getCluster() - Method in class co.cask.coopr.scheduler.callback.CallbackData
Get the cluster that is being operated on.
getCluster(String) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getCluster(String) - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get a specific cluster by id.
getCluster(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusterAction() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the ClusterAction this job is trying to perform.
getClusterAction() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the cluster level action this task is for.
getClusterConfig(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get the config used by the cluster.
getClusterConfig() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the cluster config with macros expanded.
getClusterCreateLock(String) - Method in class co.cask.coopr.common.zookeeper.LockService
 
getClusterDefaults() - Method in class co.cask.coopr.spec.template.AbstractTemplate
Get the ClusterDefaults that will be used unless the user replaces them at create time.
getClusterExistsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getClusterExistsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getClusterExistsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getClusterId() - Method in class co.cask.coopr.cluster.Node
Get the id of the cluster the node is a part of.
getClusterid() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getClusterId() - Method in class co.cask.coopr.http.request.NodePropertiesRequest
 
getClusterId() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the id of the cluster this job is for.
getClusterId() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the id of the cluster this task is for.
getClusterId() - Method in class co.cask.coopr.scheduler.task.JobId
Get the id of the cluster the job is for.
getClusterId() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the id of the cluster this task is for.
getClusterId() - Method in class co.cask.coopr.scheduler.task.TaskId
 
getClusterId() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves cluster id of this filter.
getClusterJob(JobId) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Get a cluster job by its id.
getClusterJob(JobId) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusterJobs(String, int) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getClusterJobs(String, int) - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get all jobs performed or being performed on the given cluster owned by the given user.
getClusterJobs(String, int) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusterLock(String, String) - Method in class co.cask.coopr.common.zookeeper.LockService
 
getClusterNodes(String) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getClusterNodes(String) - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get an immutable set of all nodes belonging to a specific cluster.
getClusterNodes(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusters(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get all clusters visible to the user.
getClusterServices(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get all services on a specific cluster visible to the user.
getClusterStats() - Method in class co.cask.coopr.management.ServerStats
 
getClusterStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getClusterStatus(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get the status of a specific cluster visible to the user.
getClusterStatuses(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.RPCHandler
Get the cluster status for all clusters readable by the user making the request.
getClusterStoreView() - Method in class co.cask.coopr.scheduler.callback.CallbackContext
Get a read only view of the cluster store as seen by the owner of the cluster.
getClusterSummaries(Account, Set<Cluster.Status>) - Method in class co.cask.coopr.cluster.ClusterService
Get a list of summaries of all clusters visible to the given account that are in one of the given states.
getClusterTask(TaskId) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Get a cluster task by its id.
getClusterTask(TaskId) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusterTasks(ClusterTaskFilter) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Retrieves tasks according to the filter filters.
getClusterTasks(ClusterTaskFilter) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getClusterTemplate() - Method in class co.cask.coopr.cluster.Cluster
Get the ClusterTemplate used with the cluster.
getClusterTemplate() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getClusterTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ClusterTemplate if readable by the user.
getClusterTemplate(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ClusterTemplate if readable by the user.
getClusterTemplate() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the name of the ClusterTemplate to use for cluster creation.
getClusterTemplate() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves cluster template of this filter.
getClusterTemplate(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getClusterTemplate(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getClusterTemplate(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ClusterTemplate associated with the given unique name or null if no such cluster template exists.
getClusterTemplate(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ClusterTemplate associated with the given unique name and version or null if no such cluster template exists.
getClusterTemplateName() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Retrieves template name of the cluster this task is for.
getClusterTemplates(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all ClusterTemplates readable by the user.
getCompatibilities() - Method in class co.cask.coopr.spec.template.AbstractTemplate
Get the Compatibilities for the cluster.
getConcreteBuilder() - Method in class co.cask.coopr.codec.json.current.AbstractTemplateCodec
 
getConcreteBuilder() - Method in class co.cask.coopr.codec.json.current.ClusterTemplateCodec
 
getConcreteBuilder() - Method in class co.cask.coopr.codec.json.current.PartialTemplateCodec
 
getConf() - Method in interface co.cask.coopr.common.conf.Configurable
Return the configuration used by this object.
getConfig() - Method in class co.cask.coopr.cluster.Cluster
Get the cluster config json object.
getConfig() - Method in class co.cask.coopr.http.request.ClusterConfigureRequest
 
getConfig() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the configuration to use for the cluster, with null meaning to use the template defaults.
getConfig() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the configuration json object needed by the provisioner.
getConfig() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the admin defined config for the cluster.
getConfigure() - Method in class co.cask.coopr.management.ProvisionerStats
 
getConfirm() - Method in class co.cask.coopr.management.ProvisionerStats
 
getConflicts() - Method in class co.cask.coopr.spec.service.ServiceDependencies
Get the set of services this service conflicts with.
getConfResourceAsInputStream(String) - Method in class co.cask.coopr.common.conf.Configuration
Get an input stream attached to the configuration resource with the given name.
getConfResourceAsReader(String) - Method in class co.cask.coopr.common.conf.Configuration
Get a Reader attached to the configuration resource with the given name.
getConnection() - Method in class co.cask.coopr.store.DBConnectionPool
Get a Connection from the pool with auto commit on.
getConnection(boolean) - Method in class co.cask.coopr.store.DBConnectionPool
Get a Connection from the pool with auto commit set to the given value.
getConstraints() - Method in class co.cask.coopr.layout.ClusterLayout
 
getConstraints() - Method in class co.cask.coopr.spec.template.AbstractTemplate
Get the constraints that specify how the cluster should be laid out.
getConsumerId() - Method in interface co.cask.coopr.common.queue.QueuedElement
Get the consumer id of the consumer that has taken this element.
getCreate() - Method in class co.cask.coopr.management.ClusterStats
 
getCreate() - Method in class co.cask.coopr.management.ProvisionerStats
 
getCreateTime() - Method in class co.cask.coopr.cluster.Cluster
Get the timestamp in milliseconds of when the cluster was created.
getCreateTime() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getCurrentLayout() - Method in class co.cask.coopr.layout.change.ClusterLayoutTracker
Get the current layout of the cluster.
getCurrentStage() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get all the task ids for the current stage.
getCurrentStageNumber() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the current stage number.
getData() - Method in class co.cask.coopr.metrics.TimeSeries
 
getDataOrNull(ZKClient, String) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
getDataOrNull(ZKClient, String, Watcher) - Static method in class co.cask.coopr.common.zookeeper.ZKClientExt
Acts as ZKClient.getData(String, Watcher) if node exists.
getDefaultValue() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get the default value for the field that should be used.
getDelete() - Method in class co.cask.coopr.management.ClusterStats
 
getDelete() - Method in class co.cask.coopr.management.ProvisionerStats
 
getDeleteClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getDeleteClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getDeleteClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getDependencies() - Method in class co.cask.coopr.spec.service.Service
Get the ServiceDependencies of this service.
getDependencies() - Method in class co.cask.coopr.spec.service.ServiceStageDependencies
Get all dependencies.
getDescription() - Method in class co.cask.coopr.cluster.Cluster
Get the description of the cluster.
getDescription() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getDescription() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the description of the cluster.
getDescription() - Method in class co.cask.coopr.spec.BaseEntity
Get the description of the entity, or null if none exists.
getDescription() - Method in class co.cask.coopr.spec.TenantSpecification
 
getDirectDependentActions(String, ProvisionerAction) - Method in class co.cask.coopr.scheduler.ServiceDependencyResolver
Given a service and action, return a set of ActionOnService describing what other actions on services must be performed before the given service and action can be performed.
getDnsSuffix() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the DNS suffix to use for hostnames of nodes in the cluster, with null meaning to use the template defaults.
getDnsSuffix() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the dns suffix to use for hostnames of nodes in the cluster.
getDroppedProvisionerStats() - Method in class co.cask.coopr.management.ServerStats
 
getDroppedProvisionerStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getElement() - Method in class co.cask.coopr.common.queue.GroupElement
Get the element that was taken.
getElement() - Method in interface co.cask.coopr.common.queue.QueuedElement
Get the queued Element.
getEnd() - Method in class co.cask.coopr.metrics.TimeSeries
 
getEnd() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves end date of this filter.
getEntity(BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Get the specified entity from some persistent store.
getEntity(BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
getEnum(String, Class<T>) - Method in class co.cask.coopr.common.conf.Configuration
Return value matching this enumerated type.
getEnum(String, T) - Method in class co.cask.coopr.common.conf.Configuration
Return value matching this enumerated type.
getExpireTime() - Method in class co.cask.coopr.cluster.Cluster
Get the timestamp in milliseconds of when the cluster will expire.
getExpireTime() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getExpiringClusters(long) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Returns an immutable set of all ACTIVE or INCOMPLETE clusters that expire before timestamp.
getExpiringClusters(long) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getFailedClusterStats() - Method in class co.cask.coopr.management.ServerStats
 
getFailedClusterStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getFailedProvisionerStats() - Method in class co.cask.coopr.management.ServerStats
 
getFailedProvisionerStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getFailureStatus() - Method in enum co.cask.coopr.scheduler.ClusterAction
 
getFields() - Method in class co.cask.coopr.spec.plugin.ParametersSpecification
Get the immutable mapping of field name to the FieldSchema to use for the field.
getFields() - Method in class co.cask.coopr.spec.service.ServiceAction
Get the fields the automator plugin will need to perform the action.
getFile(String, String) - Method in class co.cask.coopr.common.conf.Configuration
Get a local file name under a directory named in dirsProp with the given path.
getFirst() - Method in class co.cask.coopr.common.utils.ImmutablePair
Returns first object from pair.
getFlavor() - Method in class co.cask.coopr.cluster.NodeProperties
Get the flavor of the node.
getFloat(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a float.
getFloat(String, float) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a float.
getFormat() - Method in class co.cask.coopr.spec.plugin.ResourceTypeSpecification
Get the format of the resource.
getFreeCapacity() - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get the total amount of free capacity available across all provisioners.
getFreeCapacity() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getFrom() - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
getHardwaretype() - Method in class co.cask.coopr.cluster.NodeProperties
Get the name of the hardware type of the node.
getHardwareType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific HardwareType if readable by the user.
getHardwareType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific HardwareType if readable by the user.
getHardwareType(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all HardwareTypes readable by the user.
getHardwareType() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the name of the HardwareType to use across the entire cluster or null if the template default should be used.
getHardwaretype() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the name of the hardware type to use on all nodes in the cluster.
getHardwareType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getHardwareType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getHardwareType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the HardwareType associated with the given unique name or null if no such hardware type exists.
getHardwareType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the HardwareType associated with the given unique name and version or null if no such hardware type exists.
getHardwareTypeName() - Method in class co.cask.coopr.layout.NodeLayout
Get the name of the HardwareType used on the node.
getHardwaretypes() - Method in class co.cask.coopr.spec.template.Compatibilities
Get the set of hardware types that are compatible with the cluster.
getHighestVersion(String) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get the highest version of given resource, or 0 if the resource does not exist.
getHighestVersion(String) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getHost() - Method in class co.cask.coopr.provisioner.Provisioner
Get the host the provisioner is running on.
getHostId() - Method in class co.cask.coopr.scheduler.dag.TaskNode
Get the id of the Node associated with this task node.
getHostname() - Method in class co.cask.coopr.cluster.NodeProperties
Get the hostname of the node.
getHostname() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getIcon() - Method in class co.cask.coopr.spec.BaseEntity
Get the link to the icon for the entity.
getId() - Method in class co.cask.coopr.cluster.Cluster
Get the id of the cluster.
getId() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getId() - Method in class co.cask.coopr.cluster.Node
Get the id of the node.
getId() - Method in class co.cask.coopr.common.queue.Element
Id of the element.
getId() - Method in class co.cask.coopr.provisioner.Provisioner
Get the id of the provisioner.
getId() - Method in class co.cask.coopr.scheduler.task.JobId
Get the id as a string.
getId() - Method in class co.cask.coopr.scheduler.task.TaskId
 
getId() - Method in class co.cask.coopr.spec.Tenant
 
getId() - Method in enum co.cask.coopr.store.entity.BaseEntityStoreView.EntityType
 
getImage() - Method in class co.cask.coopr.cluster.NodeProperties
Get the image of the node.
getImagetype() - Method in class co.cask.coopr.cluster.NodeProperties
Get the name of the image type of the node.
getImageType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ImageType if readable by the user.
getImageType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ImageType if readable by the user.
getImageType(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all ImageTypes readable by the user.
getImageType() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the name of the ImageType to use across the entire cluster or null if the template default should be used.
getImagetype() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the name of the image type to use on all nodes in the cluster.
getImageType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getImageType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getImageType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ImageType associated with the given unique name or null if no such image type exists.
getImageType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ImageType associated with the given unique name or null if no such image type exists.
getImageTypeName() - Method in class co.cask.coopr.layout.NodeLayout
Get the name of the ImageType used on the node.
getImagetypes() - Method in class co.cask.coopr.spec.template.Compatibilities
Get the set of image types that are compatible with the cluster.
getIncludes() - Method in class co.cask.coopr.spec.template.ClusterTemplate
Get the partial template names from this cluster template.
getInitial() - Method in class co.cask.coopr.spec.template.LeaseDuration
Get the initial lease time in seconds, with 0 meaning forever.
getInitialLeaseDuration() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the lease duration to use for the cluster, with 0 meaning no lease.
getInProgress() - Method in class co.cask.coopr.common.queue.QueueMetrics
 
getInstall() - Method in class co.cask.coopr.management.ProvisionerStats
 
getInstall() - Method in class co.cask.coopr.spec.service.ServiceDependencies
Get the install time dependencies.
getInstance() - Static method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get the instance of the store.
getInstance() - Static method in class co.cask.coopr.scheduler.Actions
 
getInstances(String, Class<U>) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a List of objects implementing the interface specified by xface.
getInt(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name configuration property as an int.
getInt(String, int) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as an int.
getIntialize() - Method in class co.cask.coopr.management.ProvisionerStats
 
getIPAddress(String) - Method in class co.cask.coopr.cluster.NodeProperties
Get a specific type of IP address of the node.
getIPAddresses() - Method in class co.cask.coopr.cluster.NodeProperties
Get an immutable mapping of IP type to IP address.
getIpaddresses() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getIsReversed() - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
getJob() - Method in class co.cask.coopr.scheduler.callback.CallbackData
Get the job being performed or about to be performed on the cluster.
getJobId() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the id of the job.
getJobId() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the id of the job this task is a part of.
getJobId() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the id of the job this task is for.
getJobId() - Method in class co.cask.coopr.scheduler.task.TaskId
 
getJobLock(String, String) - Method in class co.cask.coopr.common.zookeeper.LockService
 
getJobNum() - Method in class co.cask.coopr.scheduler.task.JobId
Get the job number part of the id.
getJobNum() - Method in class co.cask.coopr.scheduler.task.TaskId
 
getJobStatus() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the status of the job.
getJsonRequest() - Method in class co.cask.coopr.scheduler.SolverRequest
Get the serialized request details.
getKeyFromKeyStore(KeyStore, String, String) - Static method in class co.cask.coopr.common.security.KeyHelper
 
getKeyStore(String, String) - Static method in class co.cask.coopr.common.security.KeyHelper
 
getKeyStore(String, String, String) - Static method in class co.cask.coopr.common.security.KeyHelper
 
getLabel() - Method in class co.cask.coopr.spec.BaseEntity
Get the label of the entity, or null if none exists.
getLabel() - Method in class co.cask.coopr.spec.Link
 
getLabel() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get the user friendly label for the field.
getLatestJobId() - Method in class co.cask.coopr.cluster.Cluster
Get the id of the most recent job performed, or being performed, on the cluster.
getLayout() - Method in class co.cask.coopr.layout.ClusterLayout
Returns the cluster layout, which maps each node layout to how many nodes have that layout.
getLayoutConstraint() - Method in class co.cask.coopr.spec.template.Constraints
Get the LayoutConstraint for the cluster.
getLeaseDuration() - Method in class co.cask.coopr.spec.template.Administration
Get the LeaseDuration used in administration of the cluster.
getLinks() - Method in class co.cask.coopr.cluster.ClusterDetails
Get an immutable list of links that should be exposed as specified by the cluster template.
getLinks() - Method in class co.cask.coopr.cluster.Node
Get an immutable list of service links on the node.
getLinks() - Method in class co.cask.coopr.spec.service.Service
Get an immutable set of links the service wants to expose.
getLinks() - Method in class co.cask.coopr.spec.template.AbstractTemplate
Get immutable set of cluster links to services on the cluster.
getLiveResources(Account) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get the active resources for a given account.
getLiveResources() - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable set of all resources that are currently live.
getLiveResources() - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getLiveTenants() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get all tenants that have live running workers.
getLiveTenants() - Method in class co.cask.coopr.provisioner.Provisioner
Get the unmodifiable set of tenants that have live workers on the provisioner.
getLiveWorkers(String) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get the number of live workers running for the given tenant.
getLiveWorkers(String) - Method in class co.cask.coopr.provisioner.Provisioner
Get the number of live workers for the given tenant on this provisioner.
getLong(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name configuration property as a long.
getLong(String, long) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a long.
getLongBytes(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a long or human readable format.
getLongBytes(String, long) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a long or human readable format.
getMax() - Method in class co.cask.coopr.spec.template.LeaseDuration
Get the maximum lease time in seconds, with 0 meaning forever.
getMax() - Method in class co.cask.coopr.spec.template.SizeConstraint
Get the maximum size allowed.
getMaxClusters() - Method in class co.cask.coopr.spec.TenantSpecification
 
getMaxCount() - Method in class co.cask.coopr.spec.template.ServiceConstraint
Get the maximum count of the service in the cluster.
getMaxNodes() - Method in class co.cask.coopr.spec.TenantSpecification
 
getMessage() - Method in class co.cask.coopr.cluster.ClusterDetails
Get the status message of the most recent job performed on the cluster, including any running job.
getMin() - Method in class co.cask.coopr.spec.template.SizeConstraint
Get the minimum size allowed.
getMinCount() - Method in class co.cask.coopr.spec.template.ServiceConstraint
Get the minimum count of the service in the cluster.
getMissingFields() - Method in exception co.cask.coopr.cluster.MissingFieldsException
 
getMissingFields(ParameterType, Set<String>) - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
Get an immutable list of missing required fields for the given parameter type from the given input set of fields.
getModule() - Method in class co.cask.coopr.codec.json.guice.CodecModules
Get a module that binds gson to an object that serializes/deserializes current versions of objects.
getName() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getName() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the name of the cluster.
getName() - Method in class co.cask.coopr.scheduler.task.TaskServiceAction
Get the name of the service.
getName() - Method in class co.cask.coopr.spec.NamedEntity
Get the name of the entity.
getName() - Method in class co.cask.coopr.spec.template.Include
 
getName() - Method in class co.cask.coopr.spec.template.Parent
 
getNameForId(String) - Method in class co.cask.coopr.store.tenant.SQLTenantStore
Get the name of the tenant with the given id.
getNameForId(String) - Method in interface co.cask.coopr.store.tenant.TenantStore
Get the name of the tenant that has the given id, or null if the tenant does not exist.
getNewClusterId() - Method in class co.cask.coopr.common.zookeeper.IdService
Get a unique id that can be used for a new cluster.
getNewJobId(String) - Method in class co.cask.coopr.common.zookeeper.IdService
Get a unique job id that can be used for new ClusterJobs.
getNewTaskId(JobId) - Method in class co.cask.coopr.common.zookeeper.IdService
Get a unique task id that can be used for new ClusterTasks.
getNode(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.NodeHandler
Get a node visible to the user.
getNode(String) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Get the node with the given id.
getNode(String) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getNode(String) - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
getNode(String) - Method in interface co.cask.coopr.store.node.NodeStoreView
Get the node with the given id.
getNode(String) - Method in class co.cask.coopr.store.node.SQLNodeStore
 
getNodeId() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the id of the node the task will run on.
getNodeId() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the id of the node this task should run on.
getNodeIDs() - Method in class co.cask.coopr.cluster.Cluster
Get the set of node ids in the cluster.
getNodeMap() - Method in class co.cask.coopr.scheduler.JobPlanner
 
getNodenum() - Method in class co.cask.coopr.cluster.NodeProperties
Get the number of the node in the cluster.
getNodeProperties(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.RPCHandler
Get properties of nodes from a specific cluster visible to the user.
getNodeProperties() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the properties of the node the task should be performed on.
getNodes() - Method in class co.cask.coopr.cluster.ClusterDetails
Get an immutable set of all nodes in the cluster.
getNodes(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.NodeHandler
Get all nodes visible to the user.
getNodes() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the mapping of node id to node properties for all nodes in the cluster.
getNodesUsage(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.MetricHandler
Retrieves statistics of nodes usage for given filter.
getNodesUsage(ClusterTaskFilter) - Method in class co.cask.coopr.metrics.MetricService
Calculate statistics of nodes usage for given ClusterTaskFilter.
getNonsensitive() - Method in class co.cask.coopr.spec.plugin.PluginFields
Get the immutable map of nonsensitive field keys to values.
getNonTerminatedClusters() - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
getNonTerminatedClusters() - Method in interface co.cask.coopr.store.cluster.ReadOnlyClusterStoreView
Get an immutable list of all clusters in the store that are not in the terminated state.
getNonTerminatedClusters() - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getNthServiceNode(Set<Node>, int) - Method in class co.cask.coopr.macro.eval.ServiceEvaluator
Get the n'th node from the given cluster nodes that have the service.
getNum(PreparedStatement) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries for a single number, returning the value of the number or 0 if there are no results.
getNumAssignedWorkers(String) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get the number of workers assigned to the given tenant across all provisioners.
getNumAssignedWorkers(String) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getNumAttempts() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the number of times this task has been attempted.
getNumMachines() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the number of machines that should be used in the cluster.
getNumNodes() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getOptions() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get the possible values the field can take if the type of field is "select".
getOrWait(String) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
getOwnerId() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getParameters() - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
Get an immutable mapping of ParameterType to ParametersSpecification for that type.
getParametersSpecification(ParameterType) - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
Get the specification for parameters of the given type.
getParent() - Method in class co.cask.coopr.spec.template.ClusterTemplate
Get the parent template name.
getPartialTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific PartialTemplate if readable by the user.
getPartialTemplate(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific PartialTemplate if readable by the user.
getPartialTemplate(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getPartialTemplate(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getPartialTemplate(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the PartialTemplate associated with the given unique name or null if no such provider exists.
getPartialTemplate(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the PartialTemplate associated with the given unique name or null if no such provider exists.
getPartialTemplates(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all PartialTemplates readable by the user.
getPath() - Method in enum co.cask.coopr.common.queue.QueueType
 
getPath() - Method in class co.cask.coopr.common.zookeeper.ZKClientExt.SetResult
Returns null if no new node was created, otherwise the new node path.
getPattern(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a Pattern.
getPattern(String, Pattern) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a Pattern.
getPeriodicity() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves MetricService.Periodicity of this filter.
getPermissions() - Method in class co.cask.coopr.spec.plugin.ResourceTypeSpecification
Get the permissions of the resource.
getPlanForJob(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get the task plan for an operation that has taken place or is currently taking place on a cluster.
getPlannedNodes() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get cluster nodes to include in job planning.
getPlannedServices() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get cluster services to include in job planning.
getPlansForCluster(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Get all plans for cluster operations that have taken place or are currently taking place on a cluster.
getPluginName() - Method in class co.cask.coopr.provisioner.plugin.ResourceType
Get the plugin name.
getPluginType() - Method in class co.cask.coopr.provisioner.plugin.ResourceType
Get the plugin type.
getPort() - Method in class co.cask.coopr.provisioner.Provisioner
Get the port the provisioner is running on.
getProfile(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.UserHandler
Get the profile for an account.
getProfile(Account) - Method in class co.cask.coopr.store.user.SQLUserStore
 
getProfile(Account) - Method in interface co.cask.coopr.store.user.UserStore
Get the profile for a given account.
getProgress() - Method in class co.cask.coopr.cluster.ClusterDetails
Get the progress of the most recent job performed on the cluster, including any running job.
getProgress() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getProperties() - Method in class co.cask.coopr.cluster.Node
Get node properties, such as IP address and hostname.
getProperties() - Method in class co.cask.coopr.http.request.NodePropertiesRequest
 
getProps() - Method in class co.cask.coopr.common.conf.Configuration
 
getProvider() - Method in class co.cask.coopr.cluster.Cluster
Get the Provider used to create and delete machines for the cluster.
getProvider() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getProvider(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific Provider if readable by the user.
getProvider(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific Provider if readable by the user.
getProvider() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the name of the provider to use for node creation and deletion.
getProvider() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the provider to use to perform node operations.
getProvider() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the name of the provider to use to create the cluster.
getProvider(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getProvider(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getProvider(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the Provider associated with the given unique name or null if no such provider exists.
getProvider(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the Provider associated with the given unique name and version or null if no such provider exists.
getProviderFields() - Method in class co.cask.coopr.http.request.ClusterOperationRequest
Get an immutable copy of the provider fields.
getProviderMap() - Method in class co.cask.coopr.spec.HardwareType
Get the provider map for this hardware type.
getProviderMap() - Method in class co.cask.coopr.spec.ImageType
Get the provider map for this image type.
getProviders(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all Providers readable by the user.
getProviderType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ProviderType if readable by the user.
getProviderType(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific ProviderType if readable by the user.
getProviderType() - Method in class co.cask.coopr.spec.Provider
Get the type of the provider.
getProviderType(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getProviderType(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getProviderType(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ProviderType associated with the given unique name or null if no such provider type exists.
getProviderType(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the ProviderType associated with the given unique name or null if no such provider type exists.
getProviderTypeResource(HttpRequest, HttpResponder, String, String, String, String, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Get the contents of a specific resource.
getProviderTypes(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all ProviderTypes readable by the user.
getProvides() - Method in class co.cask.coopr.spec.service.ServiceDependencies
Get the set of services this service provides.
getProvisioner(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Get the specified provisioner.
getProvisioner(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Get the provisioner for the given id for external display, with tenant ids mapped to tenant names, or null if none exists.
getProvisioner(String) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get the provisioner for the given id.
getProvisioner(String) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getProvisionerActions() - Method in class co.cask.coopr.spec.service.Service
Get the mapping of ProvisionerAction to ServiceAction for this service.
getProvisionerFields() - Method in class co.cask.coopr.spec.Provider
Get fields needed by provisioners for this provider.
getProvisionerId() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getProvisionerId() - Method in class co.cask.coopr.http.request.TakeTaskRequest
 
getProvisionerResults() - Method in class co.cask.coopr.cluster.Node
Get data returned by provisioners that should be passed on to future tasks.
getProvisionerResults() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the payload returned by provisioners that should be passed on to current and future tasks.
getProvisioners(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Get all provisioners in the system.
getProvisionerStats() - Method in class co.cask.coopr.management.ServerStats
 
getProvisionerStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getProvisionersWithFreeCapacity() - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get all provisioners that have free capacity above zero.
getProvisionersWithFreeCapacity() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getQueryItem(PreparedStatement, Class<T>) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a single item, deserializing the item and returning it or null if the item does not exist.
getQueryList(PreparedStatement, Class<T>) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a list of items, deserializing the items and returning an immutable list of them.
getQueryList(PreparedStatement, Class<T>, int) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a list of at most limit items, deserializing the items and returning an immutable list of them.
getQueryList(PreparedStatement, Class<F>, Function<F, T>) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a list of at most limit items, deserializing the items and performing a transform before before placing the transformed object into the output, finally returning an immutable list of transformed items.
getQueryList(PreparedStatement, Class<F>, Function<F, T>, int) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a list of at most limit items, deserializing the items and performing a transform before before placing the transformed object into the output, finally returning an immutable list of transformed items.
getQuerySet(PreparedStatement, Class<T>) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries the store for a set of items, deserializing the items and returning an immutable set of them.
getQueued(String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Get all elements that are queued in the specific queue.
getQueued() - Method in class co.cask.coopr.common.queue.QueueMetrics
 
getQueued() - Method in interface co.cask.coopr.common.queue.TrackingQueue
Get all QueuedElement in the queue that are not being consumed.
getQueueGroup(QueueType) - Method in interface co.cask.coopr.common.queue.QueueService
 
getQueueLength() - Method in class co.cask.coopr.management.ServerStats
 
getQueueLength() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getQueueMetrics(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a mapping of tenant to provisioner queue metrics for that tenant.
getQueueName() - Method in class co.cask.coopr.common.queue.GroupElement
Get the name of the queue the element was taken from.
getQueueNames() - Method in interface co.cask.coopr.common.queue.QueueGroup
Get the name of all queues in the group.
getRange(String) - Method in class co.cask.coopr.common.conf.Configuration
Parse the given attribute as a set of integer ranges.
getRange(String, String) - Method in class co.cask.coopr.common.conf.Configuration
Parse the given attribute as a set of integer ranges.
getRaw(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property, without doing variable expansion.If the key is deprecated, it returns the value of the first key which replaces the deprecated key and is not null.
getRemove() - Method in class co.cask.coopr.management.ProvisionerStats
 
getRequiredFields() - Method in class co.cask.coopr.spec.plugin.ParametersSpecification
Get the immutable set of required field combinations, one of which must be satisfied.
getRequiredHardwareTypes() - Method in class co.cask.coopr.spec.template.ServiceConstraint
Get the set of required hardware type names.
getRequiredImageTypes() - Method in class co.cask.coopr.spec.template.ServiceConstraint
Get the set of required image type names.
getRequiredServices() - Method in class co.cask.coopr.spec.service.ServiceDependencies
Get the set of required services, which are services that must also be on the same cluster.
getRequires() - Method in class co.cask.coopr.spec.service.ServiceStageDependencies
Get the set of required services.
getResource(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the URL for the named resource.
getResourceInputStream(Account, ResourceType, String, int) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get an input stream for reading the plugin resource.
getResourceInputStream(Account, ResourceType, String, int) - Method in class co.cask.coopr.store.provisioner.LocalFilePluginStore
 
getResourceInputStream(Account, ResourceType, String, int) - Method in interface co.cask.coopr.store.provisioner.PluginStore
Get an input stream for reading a plugin resource.
getResourceLock(String, String, String, String, String) - Method in class co.cask.coopr.common.zookeeper.LockService
 
getResourceOutputStream(Account, ResourceType, String, int) - Method in class co.cask.coopr.store.provisioner.LocalFilePluginStore
Get an output stream for the given resource.
getResourceOutputStream(Account, ResourceType, String, int) - Method in interface co.cask.coopr.store.provisioner.PluginStore
Get an output stream for writing a plugin resource.
getResources() - Method in class co.cask.coopr.provisioner.plugin.ResourceCollection
 
getResources() - Method in class co.cask.coopr.provisioner.ProvisionerTenant
Get the resources for the tenant on the provisioner.
getResourcesToSync(Account) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get the resources that should be synced for a given account.
getResourcesToSync() - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Get an immutable set of all resources that are slated to be active after the next sync.
getResourcesToSync() - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
getResourceTypes() - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
Get an immutable mapping of resource type to ResourceTypeSpecification for that type.
getResourceTypeView(Account, ResourceType) - Method in interface co.cask.coopr.store.provisioner.PluginMetaStoreService
Get a view of the metadata store for the given account and resource type.
getResourceTypeView(ResourceType) - Method in interface co.cask.coopr.store.provisioner.PluginMetaStoreView
Get a view of the metadata store for the given resource type.
getResourceTypeView(Account, ResourceType) - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreService
 
getResourceTypeView(ResourceType) - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreView
 
getRestart() - Method in class co.cask.coopr.http.request.ClusterConfigureRequest
 
getResult() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getRetryAction() - Method in class co.cask.coopr.scheduler.Actions
Get a mapping of ProvisionerActions that should be run to retry another failed ProvisionerAction.
getRetryTask(ClusterTask) - Method in class co.cask.coopr.scheduler.task.TaskService
Get tasks that must be run in order to retry the given task that failed on a given node in a given cluster.
getRollbackActions() - Method in class co.cask.coopr.scheduler.Actions
Get a mapping of ProvisionerActions that should be run to roll back another failed ProvisionerAction.
getRunningTasks(long) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Returns an immutable set of all IN_PROGRESS tasks that were submitted before timestamp.
getRunningTasks(long) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
getRuntime() - Method in class co.cask.coopr.spec.service.ServiceDependencies
Get the run time dependencies.
getSecond() - Method in class co.cask.coopr.common.utils.ImmutablePair
Return second object from pair.
getSelectAllClustersStatement(Connection) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSelectAllClustersStatement(Connection) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSelectAllClustersStatement(Connection) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSelectClusterJobsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSelectClusterJobsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSelectClusterJobsStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSelectClusterNodesStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSelectClusterNodesStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSelectClusterNodesStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSelectClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSelectClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSelectClusterStatement(Connection, long) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSelectMaxVersionStatement(Connection, BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
getSelectNonTerminatedClusters(Connection) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSelectNonTerminatedClusters(Connection) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSelectNonTerminatedClusters(Connection) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSelectStatement(Connection, BaseEntityStoreView.EntityType, String, int) - Method in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
getSensitive() - Method in class co.cask.coopr.spec.plugin.PluginFields
Get the immutable map of sensitive field keys to values.
getService() - Method in class co.cask.coopr.cluster.Node.Action
Get the service name the action is for, or empty if this is not a service action.
getService(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific Service if readable by the user.
getService(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Get a specific Service if readable by the user.
getService() - Method in class co.cask.coopr.scheduler.ActionOnService
 
getService() - Method in class co.cask.coopr.scheduler.dag.TaskNode
Get the name of the service the task is for or empty if the task is a task on the machine on not on a service on the machine.
getService() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the service this task is for or empty if the task is unrelated to a service.
getService(String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getService(String, int) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
getService(String) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the Service associated with the given unique name or null if no such service exists.
getService(String, int) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Get the Service associated with the given unique name and version or null if no such service exists.
getServiceConstraints() - Method in class co.cask.coopr.spec.template.Constraints
Get the mapping from service name to ServiceConstraint.
getServiceInstanceNum(Node, List<Node>) - Method in class co.cask.coopr.macro.eval.ServiceEvaluator
Get the instance number of the node.
getServiceMap() - Method in class co.cask.coopr.scheduler.JobPlanner
 
getServiceNames() - Method in class co.cask.coopr.layout.NodeLayout
Get the names of services on the node sorted in their natural order.
getServices() - Method in class co.cask.coopr.cluster.Cluster
Get the names of services placed on the cluster.
getServices() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getServices() - Method in class co.cask.coopr.cluster.Node
Get the set of Services on the node.
getServices() - Method in class co.cask.coopr.cluster.NodeProperties
Get an immutable set of the names of the services on the node.
getServices(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Get all Services readable by the user.
getServices() - Method in class co.cask.coopr.http.request.AddServicesRequest
Get the services to add to the cluster.
getServices() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
Get the set of service names to place on the cluster.
getServices() - Method in class co.cask.coopr.http.request.NodePropertiesRequest
 
getServices() - Method in class co.cask.coopr.spec.template.ClusterDefaults
Get the immutable set of services to place on a cluster by default.
getServices() - Method in class co.cask.coopr.spec.template.Compatibilities
Get the set of services that are compatible with the cluster.
getServicesThatMustCoexist() - Method in class co.cask.coopr.spec.template.LayoutConstraint
Get the set of service sets that must coexist on the same node in the cluster.
getServicesThatMustNotCoexist() - Method in class co.cask.coopr.spec.template.LayoutConstraint
Get the set of service sets that must not coexist on the same node in the cluster.
getSetClusterStatement(Connection, long, Cluster, byte[]) - Method in class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
getSetClusterStatement(Connection, long, Cluster, byte[]) - Method in class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
getSetClusterStatement(Connection, long, Cluster, byte[]) - Method in class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
getSizeConstraint() - Method in class co.cask.coopr.spec.template.Constraints
Get the SizeConstraint for the cluster.
getSolve() - Method in class co.cask.coopr.management.ClusterStats
 
getSpecification() - Method in class co.cask.coopr.spec.Tenant
 
getSshUser() - Method in class co.cask.coopr.cluster.NodeProperties
Get the user the provisioner will use to use to ssh in to the node.
getStagedTasks() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the ids of tasks that need to be run in order to perform the cluster operation broken down into stages.
getStart() - Method in class co.cask.coopr.management.ProvisionerStats
 
getStart() - Method in class co.cask.coopr.metrics.TimeSeries
 
getStart() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves start date of this filter.
getStat() - Method in class co.cask.coopr.common.zookeeper.ZKClientExt.SetResult
Returns null if new node was created, otherwise the result of the set operation.
getStatus() - Method in class co.cask.coopr.cluster.Cluster
Get the Cluster.Status of the cluster.
getStatus() - Method in class co.cask.coopr.cluster.ClusterSummary
 
getStatus() - Method in class co.cask.coopr.cluster.Node.Action
Get the status of the action.
getStatus() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getStatus() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getStatus() - Method in class co.cask.coopr.provisioner.plugin.ResourceMeta
Get the status.
getStatus() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the latest task attempt status.
getStatusCode() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the latest task attempt status.
getStatusMessage() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get the status message for the job.
getStatusMessage() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the latest task attempt status message.
getStatusTime() - Method in class co.cask.coopr.cluster.Node.Action
Get the timestamp in milliseconds for the last time the status was updated for the action.
getStatusTime() - Method in interface co.cask.coopr.common.queue.QueuedElement
Get the timestamp in milliseconds of the last time a status update was performed on the element.
getStatusTime() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the latest task attempt status time.
getStderr() - Method in class co.cask.coopr.cluster.Node.Action
Get stderr associated with the action.
getStderr() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getStdout() - Method in class co.cask.coopr.cluster.Node.Action
Get stdout associated with the action.
getStdout() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getStep() - Method in class co.cask.coopr.spec.template.LeaseDuration
Get the step size in seconds to use when extending a lease, with 0 meaning any step size.
getStepscompleted() - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
getStepscompleted() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getStepstotal() - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
getStepstotal() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
getStop() - Method in class co.cask.coopr.management.ProvisionerStats
 
getString(PreparedStatement) - Method in class co.cask.coopr.store.DBQueryExecutor
Queries for a single string, returning the value of the string or null if there are no results.
getStringCollection(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as a collection of Strings.
getStringCollection(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Returns a collection of strings.
getStrings(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as an array of Strings.
getStrings(String, String...) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as an array of Strings.
getStrings(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Returns an arraylist of strings.
getSubmitTime() - Method in class co.cask.coopr.cluster.Node.Action
Get the timestamp in milliseconds when the action was submitted.
getSubmitTime() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the latest task attempt submit time.
getSuccessfulClusterStats() - Method in class co.cask.coopr.management.ServerStats
 
getSuccessfulClusterStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getSuccessfulProvisionerStats() - Method in class co.cask.coopr.management.ServerStats
 
getSuccessfulProvisionerStats() - Method in interface co.cask.coopr.management.ServerStatsMXBean
 
getSystemView() - Method in interface co.cask.coopr.store.cluster.ClusterStoreService
Get the full view of the cluster store for system operations.
getSystemView() - Method in class co.cask.coopr.store.cluster.SQLClusterStoreService
 
getSystemView() - Method in interface co.cask.coopr.store.node.NodeStoreService
Get the full view of the node store for system operations.
getSystemView() - Method in class co.cask.coopr.store.node.SQLNodeStoreService
 
getTableName() - Method in enum co.cask.coopr.store.entity.BaseEntityStoreView.EntityType
 
getTaskId() - Method in class co.cask.coopr.cluster.Node.Action
Get the id of the task for this action.
getTaskId() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getTaskId() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the id of the task.
getTaskId() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the id of the task.
getTaskName() - Method in class co.cask.coopr.scheduler.dag.TaskNode
Get the name of the task to execute.
getTaskName() - Method in class co.cask.coopr.scheduler.task.ClusterTask
Get the ProvisionerAction that this task executes.
getTaskName() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
Get the name of the task.
getTaskNum() - Method in class co.cask.coopr.scheduler.task.TaskId
 
getTaskQueueMetricsSnapshot() - Method in class co.cask.coopr.scheduler.task.TaskQueueService
Get a snapshot of the number of queued and in progress elements for all queues in the task queues.
getTaskQueueMetricsSnapshot(String) - Method in class co.cask.coopr.scheduler.task.TaskQueueService
Get the queue metrics for the given tenant.
getTaskServiceAction() - Method in class co.cask.coopr.scheduler.task.TaskConfig
Get the condensed service object containing just the relevant action to perform.
getTaskStatus() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Get a mapping of all task ids to their status.
getTenant(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Get a specific tenant by name.
getTenant() - Method in class co.cask.coopr.http.request.TenantWriteRequest
 
getTenantByID(String) - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
getTenantByID(String) - Method in interface co.cask.coopr.store.tenant.TenantStore
Get the Tenant associated with the given id or null if none exists.
getTenantByName(String) - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
getTenantByName(String) - Method in interface co.cask.coopr.store.tenant.TenantStore
Get the Tenant associated with the given name or null if none exists.
getTenantId() - Method in class co.cask.coopr.account.Account
 
getTenantId() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getTenantId() - Method in class co.cask.coopr.http.request.TakeTaskRequest
 
getTenantId() - Method in class co.cask.coopr.provisioner.mock.MockWorker
Get the tenant the worker is for.
getTenantId() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves tenant id of this filter.
getTenantProvisionerLock() - Method in class co.cask.coopr.common.zookeeper.LockService
 
getTenantProvisioners(String) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get all provisioners that are assigned workers for the given tenant.
getTenantProvisioners(String) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getTenantSpecification(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Get a tenant specification by tenant name.
getThis() - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
getThis() - Method in class co.cask.coopr.spec.template.ClusterTemplate.Builder
 
getThis() - Method in class co.cask.coopr.spec.template.PartialTemplate.Builder
 
getTime() - Method in class co.cask.coopr.metrics.Interval
 
getTimedOutProvisioners(long) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Get all provisioners that have not sent a heartbeat since the given timestamp in milliseconds.
getTimedOutProvisioners(long) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
getTimestamp(long) - Static method in class co.cask.coopr.store.DBHelper
Get a Timestamp for the given timestamp in milliseconds.
getTimeUnit() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves TimeUnit of this filter.
getTip() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get the tip or user friendly description of the field.
getTo() - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
getTotal() - Method in class co.cask.coopr.common.queue.QueueMetrics
 
getTrimmed(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the value of the name property as a trimmed String, null if no such property exists.
getTrimmedStringCollection(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as a collection of Strings, trimmed of the leading and trailing whitespace.
getTrimmedStringCollection(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Splits a comma separated value String, trimming leading and trailing whitespace on each value.
getTrimmedStrings(String) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as an array of Strings, trimmed of the leading and trailing whitespace.
getTrimmedStrings(String, String...) - Method in class co.cask.coopr.common.conf.Configuration
Get the comma delimited values of the name property as an array of Strings, trimmed of the leading and trailing whitespace.
getTrimmedStrings(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Splits a comma separated value String, trimming leading and trailing whitespace on each value.
getType() - Method in class co.cask.coopr.scheduler.callback.CallbackData
Get the type of callback the data is for.
getType() - Method in class co.cask.coopr.scheduler.SolverRequest
Get type of solver request, which indicates both what the solver should do, and how to deserialize the request details.
getType() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get the type of value expected for the field.
getType() - Method in class co.cask.coopr.spec.service.ServiceAction
Get the type of provisioner to use.
getTypeName() - Method in class co.cask.coopr.provisioner.plugin.ResourceType
Get the name of the resource type.
getUrl() - Method in class co.cask.coopr.spec.Link
 
getUsage() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Get a mapping of tenant to number of live running workers.
getUsage() - Method in class co.cask.coopr.provisioner.Provisioner
Get an immutable mapping of tenants to number of live workers for that tenant.
getUsage() - Method in class co.cask.coopr.provisioner.ProvisionerHeartbeat
Get usage information for the provisioner.
getUserId() - Method in class co.cask.coopr.account.Account
 
getUserId() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
Retrieves user id of this filter.
getUses() - Method in class co.cask.coopr.spec.service.ServiceStageDependencies
Get the set of used services.
getValByRegex(String) - Method in class co.cask.coopr.common.conf.Configuration
get keys matching the the regex.
getValue() - Method in class co.cask.coopr.common.queue.Element
Value of the element.
getValue(T) - Method in class co.cask.coopr.management.StatCounter
 
getValue() - Method in class co.cask.coopr.metrics.Interval
 
getVersion() - Method in class co.cask.coopr.provisioner.plugin.ResourceMeta
Get the version.
getVersion() - Method in class co.cask.coopr.spec.BaseEntity
Retrieves the version of the entity.
getVersion(BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Retrieves highest version of entity.
getVersion(BaseEntityStoreView.EntityType, String) - Method in class co.cask.coopr.store.entity.BaseSQLEntityStoreView
 
getView(Account) - Method in interface co.cask.coopr.store.cluster.ClusterStoreService
Get a view of the cluster store as seen by the given account.
getView(Account) - Method in class co.cask.coopr.store.cluster.SQLClusterStoreService
 
getView(Account) - Method in interface co.cask.coopr.store.entity.EntityStoreService
Get a view of the entity store as seen by the given account.
getView(Account) - Method in class co.cask.coopr.store.entity.SQLEntityStoreService
 
getView(Account) - Method in interface co.cask.coopr.store.node.NodeStoreService
Get a view of the node store as seen by the given account.
getView(Account) - Method in class co.cask.coopr.store.node.SQLNodeStoreService
 
getWorkerId() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
getWorkerId() - Method in class co.cask.coopr.http.request.TakeTaskRequest
 
getWorkerId() - Method in class co.cask.coopr.provisioner.mock.MockWorker
Get the id of the worker.
getWorkers() - Method in class co.cask.coopr.provisioner.ProvisionerTenant
Get the number of workers for the tenant on the provisioner.
getWorkers() - Method in class co.cask.coopr.spec.TenantSpecification
 
GROUP_TYPES - Static variable in enum co.cask.coopr.common.queue.QueueType
 
GroupElement - Class in co.cask.coopr.common.queue
An element taken from a QueueGroup, indicating which queue the element was taken from as well as the element itself.
GroupElement(String, Element) - Constructor for class co.cask.coopr.common.queue.GroupElement
Create a group element where the given element was taken from the given queue.
groupFields(Map<String, Object>) - Method in class co.cask.coopr.spec.plugin.ProviderType
Given a map of field name to value, filter out all fields that are not admin overridable fields or user fields, and group fields by type.

H

handleFinishTask(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.TaskHandler
Finish a previously taken task by reporting a status code for execution of the task.
handleHeartbeat(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Heartbeat containing provisioner usage information and indicating that it is still alive.
handleHeartbeat(String, ProvisionerHeartbeat) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Handle the heartbeat of a provisioner, updating the last heartbeat time of the provisioner and updating the number of live workers running on the provisioner for each tenant it is responsible for.
handleTakeTask(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.TaskHandler
Take a task from the queue to execute.
HARDWARE_TYPES - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
HardwareType - Class in co.cask.coopr.spec
A hardware type defines some hardware that will be used when constructing a cluster, as well as a mapping to different providers and information needed by the provisioner to create the hardware for each provider, which should contain the provider specific flavor and any other information needed to create the hardware.
HardwareType.Builder - Class in co.cask.coopr.spec
Builder for creating a hardware type.
HardwareType.Builder() - Constructor for class co.cask.coopr.spec.HardwareType.Builder
 
HardwareTypeCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a HardwareType.
HardwareTypeCodec() - Constructor for class co.cask.coopr.codec.json.current.HardwareTypeCodec
 
hashCode() - Method in class co.cask.coopr.account.Account
 
hashCode() - Method in class co.cask.coopr.cluster.Cluster
 
hashCode() - Method in class co.cask.coopr.cluster.ClusterDetails
 
hashCode() - Method in class co.cask.coopr.cluster.ClusterJobProgress
 
hashCode() - Method in class co.cask.coopr.cluster.ClusterSummary
 
hashCode() - Method in class co.cask.coopr.cluster.Node
 
hashCode() - Method in class co.cask.coopr.cluster.NodeProperties
 
hashCode() - Method in class co.cask.coopr.common.queue.QueueMetrics
 
hashCode() - Method in class co.cask.coopr.common.utils.ImmutablePair
Returns a hash code value for this object.
hashCode() - Method in class co.cask.coopr.http.request.ClusterConfigureRequest
 
hashCode() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
 
hashCode() - Method in class co.cask.coopr.http.request.ClusterOperationRequest
 
hashCode() - Method in class co.cask.coopr.http.request.ClusterStatusResponse
 
hashCode() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
hashCode() - Method in class co.cask.coopr.http.request.TakeTaskRequest
 
hashCode() - Method in class co.cask.coopr.http.request.TenantWriteRequest
 
hashCode() - Method in class co.cask.coopr.layout.change.AddServicesChange
 
hashCode() - Method in class co.cask.coopr.layout.ClusterLayout
 
hashCode() - Method in class co.cask.coopr.layout.NodeLayout
 
hashCode() - Method in class co.cask.coopr.macro.eval.HostServiceEvaluator
 
hashCode() - Method in class co.cask.coopr.macro.eval.IPSelfEvaluator
 
hashCode() - Method in class co.cask.coopr.macro.eval.IPServiceEvaluator
 
hashCode() - Method in class co.cask.coopr.macro.eval.ServiceCardinalityEvaluator
 
hashCode() - Method in class co.cask.coopr.macro.eval.ServiceEvaluator
 
hashCode() - Method in class co.cask.coopr.macro.Expression
 
hashCode() - Method in class co.cask.coopr.metrics.Interval
 
hashCode() - Method in class co.cask.coopr.metrics.TimeSeries
 
hashCode() - Method in class co.cask.coopr.provisioner.plugin.ResourceMeta
 
hashCode() - Method in class co.cask.coopr.provisioner.plugin.ResourceType
 
hashCode() - Method in class co.cask.coopr.provisioner.Provisioner
 
hashCode() - Method in class co.cask.coopr.provisioner.ProvisionerHeartbeat
 
hashCode() - Method in class co.cask.coopr.scheduler.ActionOnService
 
hashCode() - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
hashCode() - Method in class co.cask.coopr.scheduler.callback.CallbackData
 
hashCode() - Method in class co.cask.coopr.scheduler.dag.TaskDag
 
hashCode() - Method in class co.cask.coopr.scheduler.dag.TaskNode
 
hashCode() - Method in class co.cask.coopr.scheduler.SolverRequest
 
hashCode() - Method in class co.cask.coopr.scheduler.task.ClusterJob
 
hashCode() - Method in class co.cask.coopr.scheduler.task.ClusterTask
 
hashCode() - Method in class co.cask.coopr.scheduler.task.TaskConfig
 
hashCode() - Method in class co.cask.coopr.scheduler.task.TaskServiceAction
 
hashCode() - Method in class co.cask.coopr.spec.BaseEntity
 
hashCode() - Method in class co.cask.coopr.spec.HardwareType
 
hashCode() - Method in class co.cask.coopr.spec.ImageType
 
hashCode() - Method in class co.cask.coopr.spec.Link
 
hashCode() - Method in class co.cask.coopr.spec.NamedEntity
 
hashCode() - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
 
hashCode() - Method in class co.cask.coopr.spec.plugin.FieldSchema
 
hashCode() - Method in class co.cask.coopr.spec.plugin.ParametersSpecification
 
hashCode() - Method in class co.cask.coopr.spec.plugin.PluginFields
 
hashCode() - Method in class co.cask.coopr.spec.plugin.ResourceTypeSpecification
 
hashCode() - Method in class co.cask.coopr.spec.Provider
 
hashCode() - Method in class co.cask.coopr.spec.service.Service
 
hashCode() - Method in class co.cask.coopr.spec.service.ServiceAction
 
hashCode() - Method in class co.cask.coopr.spec.service.ServiceDependencies
 
hashCode() - Method in class co.cask.coopr.spec.service.ServiceStageDependencies
 
hashCode() - Method in class co.cask.coopr.spec.template.Administration
 
hashCode() - Method in class co.cask.coopr.spec.template.ClusterTemplate
 
hashCode() - Method in class co.cask.coopr.spec.template.Compatibilities
 
hashCode() - Method in class co.cask.coopr.spec.template.Constraints
 
hashCode() - Method in class co.cask.coopr.spec.template.Include
 
hashCode() - Method in class co.cask.coopr.spec.template.LayoutConstraint
 
hashCode() - Method in class co.cask.coopr.spec.template.LeaseDuration
 
hashCode() - Method in class co.cask.coopr.spec.template.Parent
 
hashCode() - Method in class co.cask.coopr.spec.template.PartialTemplate
 
hashCode() - Method in class co.cask.coopr.spec.template.ServiceConstraint
 
hashCode() - Method in class co.cask.coopr.spec.template.SizeConstraint
 
hashCode() - Method in class co.cask.coopr.spec.Tenant
 
hashCode() - Method in class co.cask.coopr.spec.TenantSpecification
 
hasNext() - Method in class co.cask.coopr.layout.change.AddServiceChangeIterator
 
hasNext() - Method in class co.cask.coopr.layout.SlottedCombinationIterator
 
hasNextStage() - Method in class co.cask.coopr.scheduler.task.ClusterJob
Return whether or not there is another stage of tasks to execute.
hasResults(PreparedStatement) - Method in class co.cask.coopr.store.DBQueryExecutor
Performs the query and returns whether or not there are results.
HOST - Static variable in class co.cask.coopr.common.conf.Constants
 
HostSelfEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to the hostname of the specified node.
HostSelfEvaluator() - Constructor for class co.cask.coopr.macro.eval.HostSelfEvaluator
 
HostServiceEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to be a list of the hostnames of nodes in the cluster that contain a given service.
HostServiceEvaluator(String, Integer) - Constructor for class co.cask.coopr.macro.eval.HostServiceEvaluator
 
HttpHelper - Class in co.cask.coopr.http
Helper class for http handlers.
HttpHelper() - Constructor for class co.cask.coopr.http.HttpHelper
 
HttpModule - Class in co.cask.coopr.http.guice
Guice bindings for http related classes.
HttpModule() - Constructor for class co.cask.coopr.http.guice.HttpModule
 
HttpPostClusterCallback - Class in co.cask.coopr.scheduler.callback
Executes before and after hooks by sending an HTTP POST request to some configurable endpoints, with the post body containing the cluster and job objects, assuming there is a valid url assigned to the start, success, and/or failure urls.
HttpPostClusterCallback() - Constructor for class co.cask.coopr.scheduler.callback.HttpPostClusterCallback
 
HttpProvisionerRequestService - Class in co.cask.coopr.provisioner
Service that makes http calls with retries to provisioners for different provisioner operations, such as deleting a tenant or putting tenant information.

I

icon - Variable in class co.cask.coopr.spec.BaseEntity.Builder
 
icon - Variable in class co.cask.coopr.spec.BaseEntity
 
ID_INCREMENT_BY - Static variable in class co.cask.coopr.common.conf.Constants
 
ID_START_NUM - Static variable in class co.cask.coopr.common.conf.Constants
 
IdService - Class in co.cask.coopr.common.zookeeper
Uses Zookeeper for creating new unique ids.
IdService.Type - Enum in co.cask.coopr.common.zookeeper
Different types of objects that require Ids.
IMAGE_TYPES - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
ImageType - Class in co.cask.coopr.spec
Image type defines different images to use on on clusters, and include information needed by provisioners to provision machines from different providers.
ImageType.Builder - Class in co.cask.coopr.spec
Builder for creating a image type.
ImageType.Builder() - Constructor for class co.cask.coopr.spec.ImageType.Builder
 
ImageTypeCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ImageType.
ImageTypeCodec() - Constructor for class co.cask.coopr.codec.json.current.ImageTypeCodec
 
ImmutablePair<A,B> - Class in co.cask.coopr.common.utils
An ImmutablePair consists of two elements within.
importConfig(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Imports all providers, image types, hardware types, services, cluster templates and partial templates from a file.
Include - Class in co.cask.coopr.spec.template
Includes for template
Include(String) - Constructor for class co.cask.coopr.spec.template.Include
 
IncompleteClusterException - Exception in co.cask.coopr.macro
Thrown to indicate that a macro referenced a service that is not configured for the cluster.
IncompleteClusterException(String) - Constructor for exception co.cask.coopr.macro.IncompleteClusterException
New exception with error message.
increaseValue(long) - Method in class co.cask.coopr.metrics.Interval
 
incrementStat(T) - Method in class co.cask.coopr.management.StatCounter
 
init(String[]) - Method in class co.cask.coopr.common.daemon.DaemonMain
Invoked by jsvc to initialize the program.
init(String[]) - Method in class co.cask.coopr.runtime.MockProvisionerMain
 
init(String[]) - Method in class co.cask.coopr.runtime.ServerMain
 
initialize(Configuration) - Method in interface co.cask.coopr.scheduler.callback.ClusterCallback
Initialize the cluster callback.
initialize(Configuration) - Method in class co.cask.coopr.scheduler.callback.HttpPostClusterCallback
 
initialize(Configuration) - Method in class co.cask.coopr.store.provisioner.LocalFilePluginStore
 
initialize(Configuration) - Method in interface co.cask.coopr.store.provisioner.PluginStore
Initialize the store.
InProcessCredentialStore - Class in co.cask.coopr.store.credential
Credential store that stores sensitive data in memory in the server process.
InProcessCredentialStore() - Constructor for class co.cask.coopr.store.credential.InProcessCredentialStore
 
insertTasksAfterCurrentStage(List<String>) - Method in class co.cask.coopr.scheduler.task.ClusterJob
Inserts a list of tasks after this stage.
INTERNAL - Static variable in class co.cask.coopr.common.conf.Constants.HandlersNames
 
INTERNAL_ENABLE_SSL - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_PORT - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_SSL_KEYPASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_SSL_KEYSTORE_PASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_SSL_KEYSTORE_PATH - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_SSL_TRUST_KEYPASSWORD - Static variable in class co.cask.coopr.common.conf.Constants
 
INTERNAL_SSL_TRUST_KEYSTORE_PATH - Static variable in class co.cask.coopr.common.conf.Constants
 
InternalHandlerServer - Class in co.cask.coopr.http
Netty service for running the server that manages internal API.
Interval - Class in co.cask.coopr.metrics
Class for presenting time - start date of time period, and some data point.
Interval(long) - Constructor for class co.cask.coopr.metrics.Interval
 
InvalidClusterException - Exception in co.cask.coopr.layout
Thrown to indicate that a cluster is invalid.
InvalidClusterException(String) - Constructor for exception co.cask.coopr.layout.InvalidClusterException
New exception with error message.
InvalidClusterException(String, Throwable) - Constructor for exception co.cask.coopr.layout.InvalidClusterException
 
InvalidClusterException(Throwable) - Constructor for exception co.cask.coopr.layout.InvalidClusterException
 
IPSelfEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to an ip address on the specified node.
IPSelfEvaluator(String) - Constructor for class co.cask.coopr.macro.eval.IPSelfEvaluator
 
IPServiceEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to be a list of the ip addresses of nodes in the cluster that contain a given service.
IPServiceEvaluator(String, String, Integer) - Constructor for class co.cask.coopr.macro.eval.IPServiceEvaluator
 
isAdmin() - Method in class co.cask.coopr.account.Account
 
isBootstrap() - Method in class co.cask.coopr.http.request.TenantWriteRequest
 
isCompatibleWithTemplate(ClusterTemplate) - Method in class co.cask.coopr.layout.ClusterLayout
 
isDeprecated(String) - Static method in class co.cask.coopr.common.conf.Configuration
checks whether the given key is deprecated.
isEmbeddedDerbyDB() - Method in class co.cask.coopr.store.DBConnectionPool
Returns whether or not the connection pool is connected to an embedded Derby db.
isEmpty() - Method in class co.cask.coopr.common.conf.Configuration.IntegerRanges
 
isEmpty() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
isEmpty() - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
isEmpty() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
isHardwareAction() - Method in enum co.cask.coopr.spec.ProvisionerAction
 
isImmutable() - Method in class co.cask.coopr.spec.template.PartialTemplate
Get immutability of partial template.
isIncluded(int) - Method in class co.cask.coopr.common.conf.Configuration.IntegerRanges
Is the given value in the set of ranges.
isInstallTimeAction() - Method in enum co.cask.coopr.spec.ProvisionerAction
 
isLive() - Method in enum co.cask.coopr.provisioner.plugin.ResourceStatus
Whether or not the resource is live, meaning it is the version of the resource being used on the provisioners.
isLiveAfterSync() - Method in enum co.cask.coopr.provisioner.plugin.ResourceStatus
Whether or not the resource is slated to be live, meaning it is the version of the resource that will be used on the provisioners after the next sync call.
isOverride() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get whether or not the admin defined value can be overwritten by the user.
isRuntimeAction() - Method in enum co.cask.coopr.spec.ProvisionerAction
 
isSensitive() - Method in class co.cask.coopr.spec.plugin.FieldSchema
Get whether or not the field is sensitive and should not be persisted to disk.
isSuperadmin() - Method in class co.cask.coopr.account.Account
 
isValid() - Method in class co.cask.coopr.layout.ClusterLayout
Returns whether or not the cluster layout is valid based on the constraints it has.
isValidDNSSuffix(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Check if the given DNS suffix is valid by checking that each label is at least 1 and at most 63 characters in length.
iterator() - Method in class co.cask.coopr.common.conf.Configuration.IntegerRanges
 
iterator() - Method in class co.cask.coopr.common.conf.Configuration
 
iterator() - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 

J

JDBC_CONNECTION_STRING - Static variable in class co.cask.coopr.common.conf.Constants
 
JDBC_DRIVER - Static variable in class co.cask.coopr.common.conf.Constants
 
JobId - Class in co.cask.coopr.scheduler.task
Job ids are of the form clusterid-jobid, where ids are numeric.
JobId(String, long) - Constructor for class co.cask.coopr.scheduler.task.JobId
 
JobPlanner - Class in co.cask.coopr.scheduler
Given a ClusterJob and a set of Nodes belonging to the cluster, the planner will create a plan for carrying out the job, based on the type of job being performed and dependencies between cluster services.
JobPlanner(ClusterJob, Set<Node>) - Constructor for class co.cask.coopr.scheduler.JobPlanner
 
JobScheduler - Class in co.cask.coopr.scheduler
Schedules a cluster job.

K

KEY_ALIAS - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
KEY_PASSWORD - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
KeyHelper - Class in co.cask.coopr.common.security
Helper class to load KeyStores.
KeyHelper() - Constructor for class co.cask.coopr.common.security.KeyHelper
 
keySet() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
keySet() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
KEYSTORE_PASSWORD - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
KEYSTORE_PATH - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 
KEYSTORE_TYPE - Static variable in class co.cask.coopr.common.conf.Constants.CredentialStore
 

L

label - Variable in class co.cask.coopr.spec.BaseEntity.Builder
 
label - Variable in class co.cask.coopr.spec.BaseEntity
 
LayoutConstraint - Class in co.cask.coopr.spec.template
A Layout constraint specifies sets of services that must coexist on the same node, and sets of services that must not coexist on the same node in a cluster.
LayoutConstraint(Set<Set<String>>, Set<Set<String>>) - Constructor for class co.cask.coopr.spec.template.LayoutConstraint
 
LayoutConstraintCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a LayoutConstraint.
LayoutConstraintCodec() - Constructor for class co.cask.coopr.codec.json.current.LayoutConstraintCodec
 
leader() - Method in interface co.cask.coopr.common.zookeeper.ElectionHandler
This method will get invoked when a participant becomes a leader in a leader election process.
LeaderElection - Class in co.cask.coopr.common.zookeeper
Performs leader election as specified in Zookeeper recipes.
LeaderElection(ZKClient, String, ElectionHandler) - Constructor for class co.cask.coopr.common.zookeeper.LeaderElection
 
LeaseDuration - Class in co.cask.coopr.spec.template
Defines lease duration for a cluster.
LeaseDuration.Builder - Class in co.cask.coopr.spec.template
Builder for LeaseDuration.
LeaseDuration.Builder() - Constructor for class co.cask.coopr.spec.template.LeaseDuration.Builder
 
LeaseDurationCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a LeaseDuration.
LeaseDurationCodec() - Constructor for class co.cask.coopr.codec.json.current.LeaseDurationCodec
 
linearize() - Method in class co.cask.coopr.scheduler.dag.TaskDag
Linearize the DAG into a list of stages, where each stage is a set of tasks that can be executed in parallel, and where each task in a stage can only be executed once all the tasks in the previous stage have successfully completed.
linearizeDependentTasks() - Method in class co.cask.coopr.scheduler.JobPlanner
Create a plan of tasks to be executed in order to perform the cluster operation.
Link - Class in co.cask.coopr.spec
Specification to expose a link at the cluster or node level.
Link(String, String) - Constructor for class co.cask.coopr.spec.Link
 
links - Variable in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
links - Variable in class co.cask.coopr.spec.template.AbstractTemplate
 
LINKS_TYPE - Static variable in class co.cask.coopr.codec.json.current.AbstractTemplateCodec
 
LOCAL_DATA_DIR - Static variable in class co.cask.coopr.common.conf.Constants
 
LocalFilePluginStore - Class in co.cask.coopr.store.provisioner
Plugin store that writes resources to the local file system.
LocalFilePluginStore() - Constructor for class co.cask.coopr.store.provisioner.LocalFilePluginStore
 
lock() - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
 
lockInterruptibly() - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
 
LockService - Class in co.cask.coopr.common.zookeeper
Service for getting locks that makes sure different types of locks have different zookeeper namespaces.
LowercaseEnumTypeAdapterFactory - Class in co.cask.coopr.codec.json
Adapter for lowercasing enums.
LowercaseEnumTypeAdapterFactory() - Constructor for class co.cask.coopr.codec.json.LowercaseEnumTypeAdapterFactory
 

M

main(String[]) - Static method in class co.cask.coopr.common.conf.Configuration
For debugging.
main(String[]) - Static method in class co.cask.coopr.runtime.MockProvisionerMain
 
main(String[]) - Static method in class co.cask.coopr.runtime.ServerMain
 
main(String[]) - Static method in class co.cask.coopr.upgrade.UpgradeTo0_9_9
 
ManagementModule - Class in co.cask.coopr.management.guice
Guice module for binding management related classes.
ManagementModule() - Constructor for class co.cask.coopr.management.guice.ManagementModule
 
MAX_ACTION_RETRIES - Static variable in class co.cask.coopr.common.conf.Constants
 
MAX_CLUSTER_SIZE - Static variable in class co.cask.coopr.common.conf.Constants
 
MAX_CONNECTIONS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
MAX_PER_NODE_LOG_LENGTH - Static variable in class co.cask.coopr.common.conf.Constants
 
MAX_PER_NODE_NUM_ACTIONS - Static variable in class co.cask.coopr.common.conf.Constants
 
MemcachedCredentialStore - Class in co.cask.coopr.store.credential
Memcached backed implementation of CredentialStore.
merge(Collection<AbstractTemplate>, ClusterTemplate) - Method in class co.cask.coopr.spec.template.TemplateMerger
Merge all templates in order into new cluster template.
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class co.cask.coopr.http.handler.auth.SecurityAuthenticationHttpHandler
 
MetricHandler - Class in co.cask.coopr.http.handler
Handler for performing metric operations.
MetricService - Class in co.cask.coopr.metrics
Util for performing metric operations.
MetricService(ClusterStore) - Constructor for class co.cask.coopr.metrics.MetricService
 
MetricService.Periodicity - Enum in co.cask.coopr.metrics
 
MissingClusterException - Exception in co.cask.coopr.scheduler.task
Thrown to indicate that there was a problem creating a cluster job or task.
MissingClusterException(String) - Constructor for exception co.cask.coopr.scheduler.task.MissingClusterException
New exception with error message.
MissingClusterException(String, Throwable) - Constructor for exception co.cask.coopr.scheduler.task.MissingClusterException
 
MissingClusterException(Throwable) - Constructor for exception co.cask.coopr.scheduler.task.MissingClusterException
 
MissingEntityException - Exception in co.cask.coopr.scheduler.task
Thrown to indicate that some type of entity is missing.
MissingEntityException(String) - Constructor for exception co.cask.coopr.scheduler.task.MissingEntityException
New exception with error message.
MissingEntityException(String, Throwable) - Constructor for exception co.cask.coopr.scheduler.task.MissingEntityException
 
MissingEntityException(Throwable) - Constructor for exception co.cask.coopr.scheduler.task.MissingEntityException
 
MissingFieldsException - Exception in co.cask.coopr.cluster
An exception indicating there are required fields that are missing.
MissingFieldsException(List<Map<String, FieldSchema>>) - Constructor for exception co.cask.coopr.cluster.MissingFieldsException
 
MockProvisionerHandler - Class in co.cask.coopr.provisioner.mock
Mock Provisioner REST APIs.
MockProvisionerHandler() - Constructor for class co.cask.coopr.provisioner.mock.MockProvisionerHandler
 
MockProvisionerMain - Class in co.cask.coopr.runtime
Mock provisioner.
MockProvisionerMain() - Constructor for class co.cask.coopr.runtime.MockProvisionerMain
 
MockProvisionerService - Class in co.cask.coopr.provisioner.mock
Mock provisioner that will register itself, periodically heartbeat, and deregister itself on shutdown.
MockProvisionerService(String, String, int, long, long, int) - Constructor for class co.cask.coopr.provisioner.mock.MockProvisionerService
 
MockProvisionerTenantStore - Class in co.cask.coopr.provisioner.mock
Mock in memory store for keeping track of how many workers each tenant should have as well as how many workers each tenant has live.
MockProvisionerWorkerService - Class in co.cask.coopr.provisioner.mock
Mock service that will spin up and shut down mock workers for tenants.
MockProvisionerWorkerService(String, String, int, long, long, int) - Constructor for class co.cask.coopr.provisioner.mock.MockProvisionerWorkerService
Create a worker service for the given provisioner id that talks to the given server url for tasks and has the given capacity.
MockWorker - Class in co.cask.coopr.provisioner.mock
Mock worker that periodically takes a task and finishes it without performing any actual work.
MockWorker(String, String, String, String, ScheduledExecutorService, long, long, int, CloseableHttpClient) - Constructor for class co.cask.coopr.provisioner.mock.MockWorker
 

N

name - Variable in class co.cask.coopr.spec.BaseEntity.Builder
 
name - Variable in class co.cask.coopr.spec.NamedEntity
 
NamedEntity - Class in co.cask.coopr.spec
A named entity has a name that must only consist of alphanumeric characters, underscore, period, and dash.
NamedEntity(String) - Constructor for class co.cask.coopr.spec.NamedEntity
 
NETTY_EXEC_NUM_THREADS - Static variable in class co.cask.coopr.common.conf.Constants
 
NETTY_WORKER_NUM_THREADS - Static variable in class co.cask.coopr.common.conf.Constants
 
newCondition() - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
Currently not supported and will always throw UnsupportedOperationException.
newInstance(Class<T>, Configuration) - Static method in class co.cask.coopr.common.utils.ReflectionUtils
Create an object for the given class and initialize it from conf.
next() - Method in class co.cask.coopr.layout.change.AddServiceChangeIterator
 
next() - Method in class co.cask.coopr.layout.SlottedCombinationIterator
 
Node - Class in co.cask.coopr.cluster
Represents a machine in a cluster.
Node(String, String, Set<Service>, NodeProperties) - Constructor for class co.cask.coopr.cluster.Node
 
Node(String, String, Set<Service>, NodeProperties, List<Node.Action>, JsonObject) - Constructor for class co.cask.coopr.cluster.Node
 
Node.Action - Class in co.cask.coopr.cluster
Defines an action on a node.
Node.Action(String, String, String) - Constructor for class co.cask.coopr.cluster.Node.Action
 
Node.Status - Enum in co.cask.coopr.cluster
Node status.
NodeCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Node.
NodeCodec() - Constructor for class co.cask.coopr.codec.json.current.NodeCodec
 
nodeExists(String) - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
nodeExists(String) - Method in interface co.cask.coopr.store.node.NodeStoreView
Return whether or not the node with the given id exists or not, where existence is determined by whether or not the node is in the store, and not by whether or not there is an active node with the given id.
nodeExists(String) - Method in class co.cask.coopr.store.node.SQLNodeStore
 
NodeHandler - Class in co.cask.coopr.http.handler
Handler for performing node operations.
NodeLayout - Class in co.cask.coopr.layout
Defines the layout of a node, which is a hardware type, an image type, and a set of services.
NodeLayout(String, String, Set<String>) - Constructor for class co.cask.coopr.layout.NodeLayout
 
NodeLayoutComparator - Class in co.cask.coopr.layout
Comparator for NodeLayout objects, which allows specifying preferences for hardware types and image types.
NodeLayoutComparator(List<String>, List<String>) - Constructor for class co.cask.coopr.layout.NodeLayoutComparator
 
NodeLayoutGenerator - Class in co.cask.coopr.layout
Generates an ordered list of NodeLayouts sorted by preference given a ClusterTemplate, set of names of services that should be placed on the cluster, set of allowed HardwareTypes, and set of allowed ImageTypes.
NodeLayoutGenerator(ClusterTemplate, Set<String>, Set<String>, Set<String>) - Constructor for class co.cask.coopr.layout.NodeLayoutGenerator
 
NodeProperties - Class in co.cask.coopr.cluster
Properties of a node.
NodeProperties.Builder - Class in co.cask.coopr.cluster
Builder for creating node properties.
NodeProperties.Builder() - Constructor for class co.cask.coopr.cluster.NodeProperties.Builder
 
NodePropertiesRequest - Class in co.cask.coopr.http.request
Request for node properties in a cluster.
NodePropertiesRequest(String, Set<String>, Set<String>) - Constructor for class co.cask.coopr.http.request.NodePropertiesRequest
 
NodePropertiesRequestCodec - Class in co.cask.coopr.codec.json.current
Deserializes NodePropertiesRequest.
NodePropertiesRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.NodePropertiesRequestCodec
 
NodeService - Class in co.cask.coopr.scheduler.task
Service for performing actions on Nodes.
NodeStore - Interface in co.cask.coopr.store.node
A full view of the node store for management purposes.
NodeStoreService - Interface in co.cask.coopr.store.node
/** Service for getting a NodeStoreView for different an account that will restrict what parts of the actual store can be viewed or edited.
NodeStoreView - Interface in co.cask.coopr.store.node
A view of the node store as seen by a given account.
numResources(Account) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Get the number of all versions of all resources in the account.
numResources() - Method in interface co.cask.coopr.store.provisioner.PluginMetaStoreView
Get the number of resources in the metadata store, including all versions of all resources in any state.
numResources() - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreView
 

O

of(A, B) - Static method in class co.cask.coopr.common.utils.ImmutablePair
 
of(String, String, String) - Static method in class co.cask.coopr.spec.template.LeaseDuration
 
of(long, long, long) - Static method in class co.cask.coopr.spec.template.LeaseDuration
 
onFailure(CallbackData, CallbackContext) - Method in interface co.cask.coopr.scheduler.callback.ClusterCallback
Execute some method after a cluster job fails.
onFailure(CallbackData, CallbackContext) - Method in class co.cask.coopr.scheduler.callback.HttpPostClusterCallback
 
onStart(CallbackData, CallbackContext) - Method in interface co.cask.coopr.scheduler.callback.ClusterCallback
Execute some method before a cluster job starts, returning whether or not the job can proceed or whether it should be failed.
onStart(CallbackData, CallbackContext) - Method in class co.cask.coopr.scheduler.callback.HttpPostClusterCallback
 
onSuccess(CallbackData, CallbackContext) - Method in interface co.cask.coopr.scheduler.callback.ClusterCallback
Execute some method after a cluster completes successfully.
onSuccess(CallbackData, CallbackContext) - Method in class co.cask.coopr.scheduler.callback.HttpPostClusterCallback
 

P

parameters - Variable in class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
parameters - Variable in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
 
ParametersSpecification - Class in co.cask.coopr.spec.plugin
Provisioner parameters describe what fields the provisioner plugin understands and which fields are required.
ParametersSpecification(Map<String, FieldSchema>, Set<Set<String>>) - Constructor for class co.cask.coopr.spec.plugin.ParametersSpecification
 
ParametersSpecificationCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ParametersSpecification.
ParametersSpecificationCodec() - Constructor for class co.cask.coopr.codec.json.current.ParametersSpecificationCodec
 
ParameterType - Enum in co.cask.coopr.spec.plugin
Type of parameter for ProviderType and AutomatorType.
Parent - Class in co.cask.coopr.spec.template
A parent for extend template.
Parent(String) - Constructor for class co.cask.coopr.spec.template.Parent
 
parse() - Method in class co.cask.coopr.macro.Parser
Parse the input and return the resulting expression.
Parser - Class in co.cask.coopr.macro
Parses a macro expression.
Parser(String) - Constructor for class co.cask.coopr.macro.Parser
Construct a parser from a string.
PARTIAL_TEMPLATES - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
PartialTemplate - Class in co.cask.coopr.spec.template
 
PartialTemplate.Builder - Class in co.cask.coopr.spec.template
Builder for creating partial templates.
PartialTemplate.Builder() - Constructor for class co.cask.coopr.spec.template.PartialTemplate.Builder
 
PartialTemplateCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a PartialTemplate.
PartialTemplateCodec() - Constructor for class co.cask.coopr.codec.json.current.PartialTemplateCodec
 
pauseClusterJob(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Pause the cluster operation that is currently running for the given cluster.
PLUGIN_NAMESPACE - Static variable in class co.cask.coopr.common.conf.Constants.Lock
 
PLUGIN_RESOURCE_CHUNK_SIZE - Static variable in class co.cask.coopr.common.conf.Constants
 
PLUGIN_STORE_CLASS - Static variable in class co.cask.coopr.common.conf.Constants
 
PluginFields - Class in co.cask.coopr.spec.plugin
Plugin fields grouped based on the type of field it is.
PluginFields.Builder - Class in co.cask.coopr.spec.plugin
Builder for creating plugin fields.
PluginFields.Builder() - Constructor for class co.cask.coopr.spec.plugin.PluginFields.Builder
 
PluginHandler - Class in co.cask.coopr.http.handler
Handler for plugin resource related operations, such as uploading resources, staging, and recalling resources, and syncing resources.
PluginMetaStoreService - Interface in co.cask.coopr.store.provisioner
Service that provides views for reading and writing to and from the plugin resource metadata store.
PluginMetaStoreView - Interface in co.cask.coopr.store.provisioner
View of the plugin metadata persistent store for some account.
PluginResourceMetaCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing ResourceMeta objects.
PluginResourceMetaCodec() - Constructor for class co.cask.coopr.codec.json.current.PluginResourceMetaCodec
 
PluginResourceTypeView - Interface in co.cask.coopr.store.provisioner
A view of the plugin resource metadata store.
PluginStore - Interface in co.cask.coopr.store.provisioner
Persistent store for plugin data.
PluginType - Enum in co.cask.coopr.provisioner.plugin
Type of plugin.
populateLinks(Cluster, Set<Node>) - Method in class co.cask.coopr.cluster.Node
Get all service links on the node, combine them all, and expand any macros in them.
postClusterTemplate(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified ClusterTemplate.
postHardwareType(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified HardwareType.
postImageType(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified ImageType.
postPartialTemplate(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified PartialTemplate.
postProvider(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified Provider.
postService(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Add the specified Service.
Provider - Class in co.cask.coopr.spec
Machine providers are instances of some ProviderType like openstack, aws, rackspace, or joyent that can provision machines.
Provider.Builder - Class in co.cask.coopr.spec
Builder for creating a provider.
Provider.Builder() - Constructor for class co.cask.coopr.spec.Provider.Builder
 
ProviderCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Provider.
ProviderCodec() - Constructor for class co.cask.coopr.codec.json.current.ProviderCodec
 
PROVIDERS - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
ProviderType - Class in co.cask.coopr.spec.plugin
A Provider type defines what parameters admins and users need to provide to a Provider in order for it to provide machines properly.
ProviderType.Builder - Class in co.cask.coopr.spec.plugin
Builder for creating provider types.
ProviderType.Builder() - Constructor for class co.cask.coopr.spec.plugin.ProviderType.Builder
 
ProviderTypeCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ProviderType.
ProviderTypeCodec() - Constructor for class co.cask.coopr.codec.json.current.ProviderTypeCodec
 
Provisioner - Class in co.cask.coopr.provisioner
Provisioner information, such as the total capacity of the provisioner and how many workers are assigned and live for each tenant the provisioner has.
Provisioner(String, String, Integer, Integer, Map<String, Integer>, Map<String, Integer>) - Constructor for class co.cask.coopr.provisioner.Provisioner
 
PROVISIONER_REQUEST_CONNECT_TIMEOUT_MS - Static variable in class co.cask.coopr.common.conf.Constants
 
PROVISIONER_REQUEST_MAX_RETRIES - Static variable in class co.cask.coopr.common.conf.Constants
 
PROVISIONER_REQUEST_MS_BETWEEN_RETRIES - Static variable in class co.cask.coopr.common.conf.Constants
 
PROVISIONER_REQUEST_SOCKET_TIMEOUT_MS - Static variable in class co.cask.coopr.common.conf.Constants
 
PROVISIONER_TIMEOUT_CHECK_INTERVAL_SECS - Static variable in class co.cask.coopr.common.conf.Constants
 
PROVISIONER_TIMEOUT_SECS - Static variable in class co.cask.coopr.common.conf.Constants
 
ProvisionerAction - Enum in co.cask.coopr.spec
Type of provisioner actions.
ProvisionerCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a Provisioner.
ProvisionerCodec() - Constructor for class co.cask.coopr.codec.json.current.ProvisionerCodec
 
ProvisionerHandler - Class in co.cask.coopr.http.handler
Handles requests from provisioners to register themselves, send heartbeats, delete themselves, and get plugin resources.
ProvisionerHeartbeat - Class in co.cask.coopr.provisioner
Data sent in a provisioner heartbeat.
ProvisionerHeartbeat(Map<String, Integer>) - Constructor for class co.cask.coopr.provisioner.ProvisionerHeartbeat
 
ProvisionerModule - Class in co.cask.coopr.provisioner.guice
Guice module for injection of provisioner related classes.
ProvisionerModule() - Constructor for class co.cask.coopr.provisioner.guice.ProvisionerModule
 
ProvisionerRequestService - Interface in co.cask.coopr.provisioner
Service for making requests to provisioners.
ProvisionerStats - Class in co.cask.coopr.management
Provisioner stats for JMX.
ProvisionerStats() - Constructor for class co.cask.coopr.management.ProvisionerStats
 
ProvisionerStore - Interface in co.cask.coopr.store.provisioner
Persistent store for provisioner related information, such as capacity used.
ProvisionerTenant - Class in co.cask.coopr.provisioner
Tenant information to send to a specific provisioner.
ProvisionerTenant(int, ResourceCollection) - Constructor for class co.cask.coopr.provisioner.ProvisionerTenant
 
put(String, T) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
put(String, T) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
putAll(Map<? extends String, ? extends T>) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
putAll(Map<? extends String, ? extends T>) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
putAutomatorType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Writes a AutomatorType.
putClusterConfig(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Overwrite the config used by an active cluster.
putClusterTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a ClusterTemplate.
putHardwareType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a HardwareType.
putImageType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a ImageType.
putNonsensitive(String, Object) - Method in class co.cask.coopr.spec.plugin.PluginFields.Builder
 
putPartialTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a PartialTemplate.
putProvider(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a Provider.
putProviderType(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Writes a ProviderType.
putSensitive(String, Object) - Method in class co.cask.coopr.spec.plugin.PluginFields.Builder
 
putService(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.AdminHandler
Writes a Service.
putTenant(Provisioner, String, ResourceCollection) - Method in class co.cask.coopr.provisioner.HttpProvisionerRequestService
 
putTenant(Provisioner, String, ResourceCollection) - Method in interface co.cask.coopr.provisioner.ProvisionerRequestService
Make a request to the provisioner to set the tenant information, such as number of workers and plugin resources it should be using.
putTenantResources(Provisioner, String, ResourceCollection) - Method in class co.cask.coopr.provisioner.HttpProvisionerRequestService
 
putTenantResources(Provisioner, String, ResourceCollection) - Method in interface co.cask.coopr.provisioner.ProvisionerRequestService
Make a request to the provisioner to set the plugin resources it should be using.
putTenantWorkers(Provisioner, String) - Method in class co.cask.coopr.provisioner.HttpProvisionerRequestService
 
putTenantWorkers(Provisioner, String) - Method in interface co.cask.coopr.provisioner.ProvisionerRequestService
Make a request to the provisioner to set the number of workers for the given tenant.

Q

QUEUE_CACHE_SECONDS - Static variable in class co.cask.coopr.common.conf.Constants.Metrics
 
QueuedElement - Interface in co.cask.coopr.common.queue
Represents an Element that is queued.
QueueGroup - Interface in co.cask.coopr.common.queue
A group of TrackingQueues that usually serve a similar purpose.
QueueMetrics - Class in co.cask.coopr.common.queue
A snapshot of metrics related to a TrackingQueue.
QueueMetrics(int, int) - Constructor for class co.cask.coopr.common.queue.QueueMetrics
 
QueueModule - Class in co.cask.coopr.common.queue.guice
Guice module for binding queue related classes and instances.
QueueModule(ZKClient) - Constructor for class co.cask.coopr.common.queue.guice.QueueModule
 
QueueService - Interface in co.cask.coopr.common.queue
Manages queue groups.
QueueType - Enum in co.cask.coopr.common.queue
Types of Queues.
QuotaException - Exception in co.cask.coopr.provisioner
Thrown to indicate that there was some quota violation.
QuotaException(String) - Constructor for exception co.cask.coopr.provisioner.QuotaException
New exception with error message.
QuotaException(String, Throwable) - Constructor for exception co.cask.coopr.provisioner.QuotaException
 
QuotaException(Throwable) - Constructor for exception co.cask.coopr.provisioner.QuotaException
 

R

ReadOnlyClusterStoreView - Interface in co.cask.coopr.store.cluster
A read-only view of the cluster store as seen by a given account.
rebalanceTenantWorkers(String) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Rebalance workers for the tenant across the provisioners.
recall(Account, ResourceType, String, int) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Recall the given resource for the given account.
recall(String, int) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Recall the given resource, moving a resource in the staged state into the inactive state, or moving a resource in the active state into the recalled state.
recall(String, int) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
recallAutomatorTypeModule(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Recall a particular resource version, which means that version of the resource will get removed from provisioners on the next sync call.
recallProviderTypeModule(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Recall a particular resource version, which means that version of the resource will get removed from provisioners on the next sync call.
recordProgress(String, String, String, TrackingQueue.ConsumingStatus, String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Records progress of consuming the given element from the given queue.
recordProgress(String, String, TrackingQueue.ConsumingStatus, String) - Method in interface co.cask.coopr.common.queue.TrackingQueue
Records progress of consuming the element.
ReentrantDistributedLock - Class in co.cask.coopr.common.zookeeper.lib
A reentrant distributed lock implementation that uses ZooKeeper using the receipt described in http://zookeeper.apache.org/doc/trunk/recipes.html#sc_recipes_Locks
ReentrantDistributedLock(ZKClient, String) - Constructor for class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
Creates a distributed lock instance.
ReflectionUtils - Class in co.cask.coopr.common.utils
General reflection utils.
ReflectionUtils() - Constructor for class co.cask.coopr.common.utils.ReflectionUtils
 
reloadConfiguration() - Method in class co.cask.coopr.common.conf.Configuration
Reload configuration from previously added resources.
remove(String, String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Remove the specified element from the specified queue.
remove(String) - Method in interface co.cask.coopr.common.queue.TrackingQueue
Removes element from the queue by element id.
remove(Object) - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
remove(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
remove(Object) - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
remove() - Method in class co.cask.coopr.layout.change.AddServiceChangeIterator
 
remove() - Method in class co.cask.coopr.layout.SlottedCombinationIterator
 
removeAll() - Method in interface co.cask.coopr.common.queue.QueueGroup
Remove all elements from all queues in the group.
removeAll(String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Remove all elements from a specific queue in the group.
removeAll() - Method in interface co.cask.coopr.common.queue.TrackingQueue
Removes all elements from the queue.
removeAll(Collection<?>) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
removeFirstAction() - Method in class co.cask.coopr.cluster.Node
Remove the first action in the list of actions that have been performed on the node.
removeLastChange() - Method in class co.cask.coopr.layout.change.ClusterLayoutTracker
Remove the last change performed on the cluster layout.
removeTenantAssignments(String) - Method in class co.cask.coopr.provisioner.Provisioner
Remove all assigned workers for the given tenant from this provisioner.
requestAbortJob(String, Account) - Method in class co.cask.coopr.cluster.ClusterService
 
requestAddServices(String, Account, AddServicesRequest) - Method in class co.cask.coopr.cluster.ClusterService
Put in a request to add services to an active cluster.
requestClusterCreate(ClusterCreateRequest, Account) - Method in class co.cask.coopr.cluster.ClusterService
Submit a request to create a cluster, creating a placeholder cluster object and adding a task to solve for a layout to the solver queue.
requestClusterDelete(String, Account, ClusterOperationRequest) - Method in class co.cask.coopr.cluster.ClusterService
Request deletion of a given cluster that the user has permission to delete.
requestClusterReconfigure(String, Account, ClusterConfigureRequest) - Method in class co.cask.coopr.cluster.ClusterService
Put in a request to reconfigure services on an active cluster.
requestPauseJob(String, Account) - Method in class co.cask.coopr.cluster.ClusterService
Request to pause a cluster job that is currently running.
requestResumeJob(String, Account) - Method in class co.cask.coopr.cluster.ClusterService
Request to resume a cluster job that was previously paused.
requestServiceRuntimeAction(String, Account, ClusterAction, String, ClusterOperationRequest) - Method in class co.cask.coopr.cluster.ClusterService
Put in a request to perform an action on a specific service on an active cluster, or on all cluster services.
resolveTemplate(Account, ClusterTemplate) - Method in class co.cask.coopr.cluster.ClusterService
Build cluster template from provided includes and parents.
resolveTemplate(Account, String) - Method in class co.cask.coopr.cluster.ClusterService
Build cluster template from provided includes and parents.
resolveTemplate(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.AdminHandler
Resolve cluster template from template with includes and extends.
ResourceCollection - Class in co.cask.coopr.provisioner.plugin
Collection of resources for a specific tenant.
ResourceCollection() - Constructor for class co.cask.coopr.provisioner.plugin.ResourceCollection
 
ResourceCollectionCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing a ResourceCollection for use in sending requests to provisioners.
ResourceCollectionCodec() - Constructor for class co.cask.coopr.codec.json.current.ResourceCollectionCodec
 
ResourceMeta - Class in co.cask.coopr.provisioner.plugin
Metadata about a plugin resource, including a name, version, and status.
ResourceMeta(String, int) - Constructor for class co.cask.coopr.provisioner.plugin.ResourceMeta
 
ResourceMeta(String, Integer, ResourceStatus) - Constructor for class co.cask.coopr.provisioner.plugin.ResourceMeta
 
ResourceService - Class in co.cask.coopr.provisioner.plugin
Service for managing plugin modules.
ResourceStatus - Enum in co.cask.coopr.provisioner.plugin
Status of a plugin resource.
ResourceType - Class in co.cask.coopr.provisioner.plugin
Type of plugin resource.
ResourceType(PluginType, String, String) - Constructor for class co.cask.coopr.provisioner.plugin.ResourceType
 
ResourceTypeFormat - Enum in co.cask.coopr.spec.plugin
Format of a resource type.
resourceTypes - Variable in class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
ResourceTypeSpecification - Class in co.cask.coopr.spec.plugin
Specification for a plugin resource type.
ResourceTypeSpecification(ResourceTypeFormat, String) - Constructor for class co.cask.coopr.spec.plugin.ResourceTypeSpecification
 
ResourceTypeSpecificationCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ResourceTypeSpecification.
ResourceTypeSpecificationCodec() - Constructor for class co.cask.coopr.codec.json.current.ResourceTypeSpecificationCodec
 
restartAllClusterServices(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Restarts all services on the cluster, taking into account service dependencies for order of service stops and starts.
restartClusterService(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Restarts the specified service on the cluster, plus all services that depend on it, taking into account service dependencies for order of service stops and starts.
resumeClusterJob(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Resume the cluster operation that is currently paused for the given cluster.
retainAll(Collection<?>) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
RPCHandler - Class in co.cask.coopr.http.handler
Handler for RPCs.
run() - Method in class co.cask.coopr.scheduler.CallbackScheduler
 
run() - Method in class co.cask.coopr.scheduler.ClusterCleanup
 
run() - Method in class co.cask.coopr.scheduler.ClusterScheduler
 
run() - Method in class co.cask.coopr.scheduler.JobScheduler
 
run() - Method in class co.cask.coopr.scheduler.SolverScheduler
 
run() - Method in class co.cask.coopr.scheduler.TenantProvisionerCleanup
 
run() - Method in class co.cask.coopr.scheduler.WorkerBalanceScheduler
 
run() - Method in class co.cask.coopr.upgrade.UpgradeTo0_9_9
 
runOneIteration() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerService
 
runOneIteration() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerWorkerService
 
runOneIteration() - Method in class co.cask.coopr.provisioner.mock.MockWorker
 
runtimeDependsOn(String, String) - Method in class co.cask.coopr.scheduler.ServiceDependencyResolver
Returns whether or not service1 depends on service2 in some way for runtime actions, either directly or indirectly.
runtimeRequires(String...) - Static method in class co.cask.coopr.spec.service.ServiceDependencies
Create service dependencies that only have runtime required dependencies.

S

satisfiesConstraints(Constraints, Set<String>) - Method in class co.cask.coopr.layout.NodeLayout
Determine if this is a valid node layout some constraints and the set of all services that are also on the cluster.
satisfiesServiceConstraints(Map<String, ServiceConstraint>) - Method in class co.cask.coopr.layout.NodeLayout
Determine if this is a valid node layout given the service constraints.
satisfiesTenantQuotas(String, int, int) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Verify that tenant cluster and node quotas would not be exceeded if the given number of additional clusters and nodes would be added.
satisfiesTenantQuotas(Tenant, int, int) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Verify that tenant cluster and node quotas would not be exceeded if the given number of additional clusters and nodes would be added.
SchedulableTask - Class in co.cask.coopr.scheduler.task
A Gson serializable task object that will be handed off to provisioners.
SchedulableTask(ClusterTask, TaskConfig) - Constructor for class co.cask.coopr.scheduler.task.SchedulableTask
 
scheduler() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerService
 
scheduler() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerWorkerService
 
scheduler() - Method in class co.cask.coopr.provisioner.mock.MockWorker
 
Scheduler - Class in co.cask.coopr.scheduler
Runs the different schedulers for solving cluster layouts and planning and coordinating cluster jobs.
SCHEDULER_INTERVAL_SECS - Static variable in class co.cask.coopr.common.conf.Constants
 
SchedulerModule - Class in co.cask.coopr.scheduler.guice
Guice module for binding scheduler related classes.
SchedulerModule(Configuration, ListeningExecutorService, ListeningExecutorService) - Constructor for class co.cask.coopr.scheduler.guice.SchedulerModule
 
SecurityAuthenticationHttpHandler - Class in co.cask.coopr.http.handler.auth
Security handler that intercept HTTP message and validates the access token in header Authorization field.
SecurityAuthenticationHttpHandler(String, TokenValidator, CConfiguration, AccessTokenTransformer, DiscoveryServiceClient) - Constructor for class co.cask.coopr.http.handler.auth.SecurityAuthenticationHttpHandler
 
serialize(T, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.AbstractBaseEntityCodec
 
serialize(Administration, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.AdministrationCodec
 
serialize(Cluster, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterCodec
 
serialize(ClusterDefaults, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterDefaultsCodec
 
serialize(ClusterDetails, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ClusterDetailsCodec
 
serialize(Compatibilities, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.CompatibilitiesCodec
 
serialize(Constraints, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ConstraintsCodec
 
serialize(FieldSchema, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.FieldSchemaCodec
 
serialize(LayoutConstraint, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.LayoutConstraintCodec
 
serialize(LeaseDuration, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.LeaseDurationCodec
 
serialize(ResourceMeta, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.PluginResourceMetaCodec
 
serialize(ResourceCollection, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ResourceCollectionCodec
 
serialize(ResourceTypeSpecification, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ResourceTypeSpecificationCodec
 
serialize(ServiceAction, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceActionCodec
 
serialize(ServiceConstraint, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceConstraintCodec
 
serialize(ServiceDependencies, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceDependenciesCodec
 
serialize(ServiceStageDependencies, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.ServiceStageDependenciesCodec
 
serialize(TaskConfig, Type, JsonSerializationContext) - Method in class co.cask.coopr.codec.json.current.TaskConfigCodec
 
serialize(T) - Method in interface co.cask.coopr.common.zookeeper.lib.Serializer
Serialize the value into bytes.
serializeCluster(Cluster, JsonSerializationContext) - Static method in class co.cask.coopr.codec.json.current.ClusterCodec
 
Serializer<T> - Interface in co.cask.coopr.common.zookeeper.lib
Serializes objects of type T into byte[] and back.
ServerMain - Class in co.cask.coopr.runtime
Main class that starts up all services.
ServerMain() - Constructor for class co.cask.coopr.runtime.ServerMain
 
ServerStats - Class in co.cask.coopr.management
Collects Server stats for JMX.
ServerStats() - Constructor for class co.cask.coopr.management.ServerStats
 
ServerStatsMXBean - Interface in co.cask.coopr.management
MXBean for Server Stats.
Service - Class in co.cask.coopr.spec.service
A service defines a set of services it is dependent on, as well as a mapping of ProvisionerAction to ServiceAction that provisioners will need to execute when performing cluster operations such as creation and deletion.
Service.Builder - Class in co.cask.coopr.spec.service
Builder for creating a service.
Service.Builder() - Constructor for class co.cask.coopr.spec.service.Service.Builder
 
SERVICE_ACTIONABLE_STATES - Static variable in enum co.cask.coopr.cluster.Cluster.Status
 
SERVICE_RUNTIME_ACTIONS - Static variable in enum co.cask.coopr.scheduler.ClusterAction
 
ServiceAction - Class in co.cask.coopr.spec.service
Actions that provisioner automator plugins can execute on a service on a node.
ServiceAction(String, Map<String, String>) - Constructor for class co.cask.coopr.spec.service.ServiceAction
 
ServiceActionCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ServiceAction.
ServiceActionCodec() - Constructor for class co.cask.coopr.codec.json.current.ServiceActionCodec
 
ServiceCardinalityEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to be the number of nodes in the cluster that contain a given service.
ServiceCardinalityEvaluator(String) - Constructor for class co.cask.coopr.macro.eval.ServiceCardinalityEvaluator
 
ServiceCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a Service.
ServiceCodec() - Constructor for class co.cask.coopr.codec.json.current.ServiceCodec
 
ServiceConstraint - Class in co.cask.coopr.spec.template
Service constraints restrict what hardware and images are allowed for some service.
ServiceConstraint(Set<String>, Set<String>, Integer, Integer) - Constructor for class co.cask.coopr.spec.template.ServiceConstraint
 
ServiceConstraintCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ServiceConstraint.
ServiceConstraintCodec() - Constructor for class co.cask.coopr.codec.json.current.ServiceConstraintCodec
 
ServiceDependencies - Class in co.cask.coopr.spec.service
Service dependencies define what a service provides, other services it conflicts with, install time dependencies, and runtime dependencies.
ServiceDependencies.Builder - Class in co.cask.coopr.spec.service
Builder for creating service dependencies.
ServiceDependencies.Builder() - Constructor for class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
ServiceDependenciesCodec - Class in co.cask.coopr.codec.json.current
Codec for serializing/deserializing a ServiceDependencies.
ServiceDependenciesCodec() - Constructor for class co.cask.coopr.codec.json.current.ServiceDependenciesCodec
 
ServiceDependencyResolver - Class in co.cask.coopr.scheduler
This dependency resolver takes services placed on a cluster, some ClusterAction that needs to be performed, and determines for a given ProvisionerAction to be performed on a Service, what other actions need to be performed on what services before the given action can be performed.
ServiceDependencyResolver(Actions, Map<String, Service>) - Constructor for class co.cask.coopr.scheduler.ServiceDependencyResolver
 
ServiceEvaluator - Class in co.cask.coopr.macro.eval
Base class for evaluating service based macros.
ServiceEvaluator(String) - Constructor for class co.cask.coopr.macro.eval.ServiceEvaluator
 
ServiceInstanceEvaluator - Class in co.cask.coopr.macro.eval
Evaluates a macro that expands to be the instance number of the given node that contains the given service.
ServiceInstanceEvaluator(String) - Constructor for class co.cask.coopr.macro.eval.ServiceInstanceEvaluator
 
serviceName - Variable in class co.cask.coopr.macro.eval.ServiceEvaluator
 
SERVICES - Static variable in class co.cask.coopr.http.handler.AdminHandler
 
ServiceStageDependencies - Class in co.cask.coopr.spec.service
Service stage dependencies are dependencies specific to a stage of service life.
ServiceStageDependencies(Set<String>, Set<String>) - Constructor for class co.cask.coopr.spec.service.ServiceStageDependencies
Create stage dependencies with the given requires and uses rules.
ServiceStageDependenciesCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a ServiceStageDependencies.
ServiceStageDependenciesCodec() - Constructor for class co.cask.coopr.codec.json.current.ServiceStageDependenciesCodec
 
set(String, String) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property.
set(String, String, Map<String, Object>) - Method in interface co.cask.coopr.store.credential.CredentialStore
Set fields for the given tenant and cluster.
set(String, String, Map<String, Object>) - Method in class co.cask.coopr.store.credential.EncryptedCredentialStore
 
set(String, String, Map<String, Object>) - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
setAccount(Account) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setAdministration(Administration) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setAssignedWorkers(String, int) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Set the number of assigned workers for a given tenant.
setAutomators(Set<String>) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setBaseFields(String, String, String, String, int) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setBoolean(String, boolean) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to a boolean.
setBooleanIfUnset(String, boolean) - Method in class co.cask.coopr.common.conf.Configuration
Set the given property, if it is currently unset.
setClass(String, Class<?>, Class<?>) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to the name of a theClass implementing the given interface xface.
setClassLoader(ClassLoader) - Method in class co.cask.coopr.common.conf.Configuration
Set the class loader that will be used to load the various objects.
setClusterDefaults(ClusterDefaults) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setClusterTemplate(ClusterTemplate) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setClusterTemplate(ClusterTemplate) - Method in class co.cask.coopr.cluster.Cluster
Set the cluster template to use for cluster operations.
setClusterTemplateName(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setCompatibilities(Compatibilities) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setConf(Configuration) - Method in interface co.cask.coopr.common.conf.Configurable
Set the configuration to be used by this object.
setConfig(JsonObject) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setConfig(JsonObject) - Method in class co.cask.coopr.cluster.Cluster
Set the config for the cluster.
setConfig(JsonObject) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setConfig(JsonObject) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setConflicts(Set<String>) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setConflicts(String...) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setConstraints(Constraints) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setCreateTime(long) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setDefaultValue(Object) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setDependencies(ServiceDependencies) - Method in class co.cask.coopr.spec.service.Service.Builder
 
setDescription(String) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setDescription(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setDescription(String) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setDescription(String) - Method in class co.cask.coopr.spec.service.Service.Builder
 
setDescription(String) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setDNSSuffix(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setDNSSuffix(String) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setEnum(String, T) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to the given type.
setExpireTime(long) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setExpireTime(long) - Method in class co.cask.coopr.cluster.Cluster
Set the expire time of the cluster as a timestamp in milliseconds.
setFlavor(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setFloat(String, float) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to a float.
setHardwaretype(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setHardwaretype(String) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setHardwareTypeName(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setHardwaretypes(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setHardwaretypes(String...) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setHeartbeat(String, long) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Set the last heartbeat time of the given provisioner to the given timestamp in milliseconds.
setHeartbeat(String, long) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
setHostname(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setHostname(String) - Method in class co.cask.coopr.cluster.NodeProperties
Set the hostname of the node.
setIcon(String) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setIcon(String) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setID(String) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setIfUnset(String, String) - Method in class co.cask.coopr.common.conf.Configuration
Sets a property if it is currently unset.
setImage(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setImagetype(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setImagetype(String) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setImageTypeName(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setImagetypes(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setImagetypes(String...) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setImmutable(boolean) - Method in class co.cask.coopr.spec.template.PartialTemplate.Builder
 
setInClause(PreparedStatement, Set<Cluster.Status>, int) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
setIncludes(Set<Include>) - Method in class co.cask.coopr.spec.template.ClusterTemplate.Builder
 
setInitial(long) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
 
setInitial(String) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
Sets initial using timestamp format specified in LeaseDuration.getTimestamp(String).
setInitialLeaseDuration(Long) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setInstallDependencies(ServiceStageDependencies) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setInt(String, int) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to an int.
setIPAddresses(Map<String, String>) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setIpaddresses(Map<String, String>) - Method in class co.cask.coopr.cluster.NodeProperties
Set the IP addresses of the node.
setIVHex(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setJobStatus(ClusterJob.Status) - Method in class co.cask.coopr.scheduler.task.ClusterJob
Set the status of the entire job.
setKey(Key) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setKeyAlias(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setKeyPassword(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setKeystorePassword(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setKeystorePath(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setKeystoreType(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setLabel(String) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setLabel(String) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setLatestJobID(String) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setLatestJobId(String) - Method in class co.cask.coopr.cluster.Cluster
Set the latest job of the cluster.
setLinks(Set<Link>) - Method in class co.cask.coopr.spec.service.Service.Builder
 
setLinks(Set<Link>) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setLiveTenantWorkers(String, int) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerTenantStore
Set the number of live workers running for a given tenant.
setLong(String, long) - Method in class co.cask.coopr.common.conf.Configuration
Set the value of the name property to a long.
setMax(long) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
 
setMax(String) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
Sets max using timestamp format specified in LeaseDuration.getTimestamp(String).
setName(String) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setName(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setName(String) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setName(String) - Method in class co.cask.coopr.spec.service.Service.Builder
 
setName(String) - Method in class co.cask.coopr.spec.template.AbstractTemplate.Builder
 
setNodenum(int) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setNodes(Set<String>) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setNodes(Set<String>) - Method in class co.cask.coopr.cluster.Cluster
Set the ids of the nodes in the cluster.
setNumMachines(Integer) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setOptions(Set<String>) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setOverride(Boolean) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setParameters(Map<ParameterType, ParametersSpecification>) - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
setParent(Parent) - Method in class co.cask.coopr.spec.template.ClusterTemplate.Builder
 
setPattern(String, Pattern) - Method in class co.cask.coopr.common.conf.Configuration
Set the given property to Pattern.
setProvider(Provider) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setProvider(Provider) - Method in class co.cask.coopr.cluster.Cluster
Set the provider to use for creating and deleting machines.
setProvider(String) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setProviderFields(Map<String, Object>) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setProviderMap(Map<String, Map<String, String>>) - Method in class co.cask.coopr.spec.HardwareType.Builder
 
setProviderMap(Map<String, Map<String, String>>) - Method in class co.cask.coopr.spec.ImageType.Builder
 
setProviderName(String) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setProviderType(String) - Method in class co.cask.coopr.spec.Provider.Builder
 
setProvides(Set<String>) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setProvides(String...) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setProvisionerActions(Map<ProvisionerAction, ServiceAction>) - Method in class co.cask.coopr.spec.service.Service.Builder
 
setProvisionerFields(Map<String, Object>) - Method in class co.cask.coopr.spec.Provider.Builder
 
setQueueLength(int) - Method in class co.cask.coopr.management.ServerStats
 
setQuietMode(boolean) - Method in class co.cask.coopr.common.conf.Configuration
Set the quietness-mode.
setResourceTypes(Map<String, ResourceTypeSpecification>) - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification.Builder
 
setRuntimeDependencies(ServiceStageDependencies) - Method in class co.cask.coopr.spec.service.ServiceDependencies.Builder
 
setSensitive(Boolean) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setServiceNames(Set<String>) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setServiceNames(Set<String>) - Method in class co.cask.coopr.http.request.ClusterCreateRequest.Builder
 
setServices(Set<String>) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setServices(Set<String>) - Method in class co.cask.coopr.cluster.Cluster
Set the names of the services on the cluster.
setServices(Set<Service>) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setServices(Set<String>) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setServices(String...) - Method in class co.cask.coopr.spec.template.ClusterDefaults.Builder
 
setServices(Set<String>) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setServices(String...) - Method in class co.cask.coopr.spec.template.Compatibilities.Builder
 
setSSHUser(String) - Method in class co.cask.coopr.cluster.NodeProperties.Builder
 
setStatus(Cluster.Status) - Method in class co.cask.coopr.cluster.Cluster.Builder
 
setStatus(Cluster.Status) - Method in class co.cask.coopr.cluster.Cluster
Set the status of the cluster.
setStatus(Node.Status) - Method in class co.cask.coopr.cluster.Node.Action
Set the status of the action.
setStatus(ClusterTask.Status) - Method in class co.cask.coopr.scheduler.task.ClusterTask
Sets the status for the latest task attempt.
setStatusCode(int) - Method in class co.cask.coopr.scheduler.task.ClusterTask
Sets the status code for the latest task attempt.
setStatusMessage(String) - Method in class co.cask.coopr.scheduler.task.ClusterJob
Set the status message for the job.
setStatusMessage(String) - Method in class co.cask.coopr.scheduler.task.ClusterTask
Sets the status message for the latest task attempt.
setStatusTime(long) - Method in class co.cask.coopr.cluster.Node.Action
Set the timestamp in milliseconds for the last time the status was updated for the action.
setStatusTime(long) - Method in class co.cask.coopr.scheduler.task.ClusterTask
Sets the status time for the latest task attempt.
setStderr(String) - Method in class co.cask.coopr.cluster.Node.Action
Set stderr for the action.
setStdout(String) - Method in class co.cask.coopr.cluster.Node.Action
Set stdout for the action.
setStep(long) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
 
setStep(String) - Method in class co.cask.coopr.spec.template.LeaseDuration.Builder
Sets step using timestamp format specified in LeaseDuration.getTimestamp(String).
setStrings(String, String...) - Method in class co.cask.coopr.common.conf.Configuration
Set the array of string values for the name property as as comma delimited values.
setSubmitTime(long) - Method in class co.cask.coopr.scheduler.task.ClusterTask
Sets the submit time for the latest task attempt.
setTaskStatus(String, ClusterTask.Status) - Method in class co.cask.coopr.scheduler.task.ClusterJob
Set the status of a specific task.
setTip(String) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setTransformation(String) - Method in class co.cask.coopr.common.security.CipherProvider.Builder
 
setType(String) - Method in class co.cask.coopr.spec.plugin.FieldSchema.Builder
 
setUsage(Map<String, Integer>) - Method in class co.cask.coopr.provisioner.Provisioner
Sets the usage information for this provisioner, which contains number of live workers per tenant.
setVersion(int) - Method in class co.cask.coopr.spec.BaseEntity.Builder
 
setVersion(int) - Method in class co.cask.coopr.spec.BaseEntity
Sets the version of the entity.
shutDown() - Method in class co.cask.coopr.common.zookeeper.IdService
 
shutDown() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerService
 
shutDown() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerWorkerService
 
shutDown() - Method in class co.cask.coopr.provisioner.mock.MockWorker
 
shutDown() - Method in class co.cask.coopr.provisioner.plugin.ResourceService
 
shutDown() - Method in class co.cask.coopr.scheduler.Scheduler
 
shutDown() - Method in class co.cask.coopr.store.cluster.SQLClusterStoreService
 
shutDown() - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
shutDown() - Method in class co.cask.coopr.store.credential.MemcachedCredentialStore
 
shutDown() - Method in class co.cask.coopr.store.credential.SQLCredentialStore
 
shutDown() - Method in class co.cask.coopr.store.entity.SQLEntityStoreService
 
shutDown() - Method in class co.cask.coopr.store.node.SQLNodeStoreService
 
shutDown() - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreService
 
shutDown() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
shutDown() - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
shutDown() - Method in class co.cask.coopr.store.user.SQLUserStore
 
size() - Method in class co.cask.coopr.common.conf.Configuration
Return the number of keys in the configuration.
size(String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Get the size (both queued and being consumed) of a specific queue.
size() - Method in interface co.cask.coopr.common.queue.TrackingQueue
Get the size of the queue (both queued and being consumed).
size() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
size() - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
size() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
SizeConstraint - Class in co.cask.coopr.spec.template
A size constraint on the cluster, enforcing some min and/or max on the number of nodes in the cluster.
SizeConstraint(Integer, Integer) - Constructor for class co.cask.coopr.spec.template.SizeConstraint
 
SizeConstraintCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a SizeConstraint, used to make sure the constructor is called correctly.
SizeConstraintCodec() - Constructor for class co.cask.coopr.codec.json.current.SizeConstraintCodec
 
SlottedCombinationIterator - Class in co.cask.coopr.layout
Iterator through all possibilities of X items placed into Y slots, where as many of the leftmost slots are used up as possible.
SlottedCombinationIterator(int[]) - Constructor for class co.cask.coopr.layout.SlottedCombinationIterator
Create an iterator that starts at the initial state given.
SlottedCombinationIterator(int[], int[]) - Constructor for class co.cask.coopr.layout.SlottedCombinationIterator
Create an iterator that starts at the initial state given, and which uses the given max counts.
SlottedCombinationIterator(int, int) - Constructor for class co.cask.coopr.layout.SlottedCombinationIterator
Create an iterator with the number of slots given and the number of items given.
SlottedCombinationIterator(int, int, int[]) - Constructor for class co.cask.coopr.layout.SlottedCombinationIterator
Create an iterator with the number of slots given and the number of items given, with a maximum number of items in each slot specified by the max counts array.
SOCKET_TIMEOUT - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
solveClusterNodes(Cluster, ClusterCreateRequest) - Method in class co.cask.coopr.layout.Solver
Given a Cluster and ClusterCreateRequest, return a mapping of node id to Node describing how the cluster should be laid out.
Solver - Class in co.cask.coopr.layout
The solver takes a cluster template, a number of machines, and figures out what services to put on what hardware and images in order to satisfy the cluster constraints.
SOLVER_NUM_THREADS - Static variable in class co.cask.coopr.common.conf.Constants
 
SolverRequest - Class in co.cask.coopr.scheduler
Wrapper around different types of cluster requests that require solver interaction.
SolverRequest(SolverRequest.Type, String) - Constructor for class co.cask.coopr.scheduler.SolverRequest
Create a request of the given type, with corresponding request details serialized as a json string.
SolverRequest.Type - Enum in co.cask.coopr.scheduler
Type of solver request.
SolverScheduler - Class in co.cask.coopr.scheduler
Polls a queue which contains ClusterCreateRequest and a cluster id, and runs the solver to determine what the cluster layout should be for the specified cluster and cluster request.
sortServiceNodes(Set<Node>) - Method in class co.cask.coopr.macro.eval.ServiceEvaluator
Filter the given nodes to only include nodes with the service on it, and sort all those nodes by node number.
SQLAdminClusterStoreView - Class in co.cask.coopr.store.cluster
The cluster store as viewed by a tenant admin.
SQLAdminClusterStoreView(DBConnectionPool, Account, DBQueryExecutor) - Constructor for class co.cask.coopr.store.cluster.SQLAdminClusterStoreView
 
SQLAdminEntityStoreView - Class in co.cask.coopr.store.entity
Implementation of BaseSQLEntityStoreView from the view of a tenant admin.
SQLAdminNodeStoreView - Class in co.cask.coopr.store.node
The node store as viewed by a tenant admin.
SQLAdminNodeStoreView(DBConnectionPool, Account, DBQueryExecutor) - Constructor for class co.cask.coopr.store.node.SQLAdminNodeStoreView
 
SQLClusterStore - Class in co.cask.coopr.store.cluster
A full view of the cluster store backed by a sql database.
SQLClusterStoreService - Class in co.cask.coopr.store.cluster
Service for getting views of the cluster store.
SQLClusterStoreService(DBConnectionPool, DBQueryExecutor) - Constructor for class co.cask.coopr.store.cluster.SQLClusterStoreService
 
SQLCredentialStore - Class in co.cask.coopr.store.credential
SQL DB backed implementation of EncryptedCredentialStore.
SQLEntityStoreService - Class in co.cask.coopr.store.entity
Implementation of EntityStoreService that provides views of the entity store backed by a SQL database.
SQLNodeStore - Class in co.cask.coopr.store.node
A full view of the node store backed by a sql database.
SQLNodeStore(DBConnectionPool, DBQueryExecutor) - Constructor for class co.cask.coopr.store.node.SQLNodeStore
 
SQLNodeStoreService - Class in co.cask.coopr.store.node
Service for getting views of the node store.
SQLNodeStoreService(DBConnectionPool, DBQueryExecutor) - Constructor for class co.cask.coopr.store.node.SQLNodeStoreService
 
SQLPluginMetaStoreService - Class in co.cask.coopr.store.provisioner
SQL database backed implementation of PluginMetaStoreService.
SQLPluginMetaStoreView - Class in co.cask.coopr.store.provisioner
View of the plugin metadata persistent store for a given account, backed by a SQL database.
SQLPluginMetaStoreView(DBConnectionPool, DBQueryExecutor, Account) - Constructor for class co.cask.coopr.store.provisioner.SQLPluginMetaStoreView
 
SQLPluginResourceTypeView - Class in co.cask.coopr.store.provisioner
SQL database backed implementation of PluginResourceTypeView.
SQLProvisionerStore - Class in co.cask.coopr.store.provisioner
Implementation of the ProvisionerStore using a SQL database for persistent storage.
SQLSystemClusterStoreView - Class in co.cask.coopr.store.cluster
The cluster store as viewed by the system.
SQLSystemClusterStoreView(DBConnectionPool, DBQueryExecutor) - Constructor for class co.cask.coopr.store.cluster.SQLSystemClusterStoreView
 
SQLSystemNodeStoreView - Class in co.cask.coopr.store.node
The node store as viewed by the system.
SQLSystemNodeStoreView(DBConnectionPool, DBQueryExecutor) - Constructor for class co.cask.coopr.store.node.SQLSystemNodeStoreView
 
SQLTenantStore - Class in co.cask.coopr.store.tenant
Implementation of TenantStore using a SQL database as the persistent store.
SQLUserClusterStoreView - Class in co.cask.coopr.store.cluster
The cluster store as viewed by a tenant user.
SQLUserClusterStoreView(DBConnectionPool, Account, DBQueryExecutor) - Constructor for class co.cask.coopr.store.cluster.SQLUserClusterStoreView
 
SQLUserEntityStoreView - Class in co.cask.coopr.store.entity
Implementation of BaseEntityStoreView from the view of a tenant user.
SQLUserNodeStoreView - Class in co.cask.coopr.store.node
The node store as viewed by a tenant user.
SQLUserStore - Class in co.cask.coopr.store.user
SQL database backed implementation of UserStore.
stage(Account, ResourceType, String, int) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Atomically stage the specified resource version for the given account and recall the previous staged version.
stage(String, int) - Method in interface co.cask.coopr.store.provisioner.PluginResourceTypeView
Atomically stage an inactive resource version and deactivate the current staged version if there is one.
stage(String, int) - Method in class co.cask.coopr.store.provisioner.SQLPluginResourceTypeView
 
stageAutomatorTypeModule(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Stage a particular resource version, which means that version of the resource will get pushed to provisioners on the next sync call.
stageProviderTypeModule(HttpRequest, HttpResponder, String, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Stage a particular resource version, which means that version of the resource will get pushed to provisioners on the next sync call.
start() - Method in class co.cask.coopr.common.daemon.DaemonMain
Invoked by jsvc to start the program.
start() - Method in class co.cask.coopr.runtime.MockProvisionerMain
 
start() - Method in class co.cask.coopr.runtime.ServerMain
 
START_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
START_URL - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
startAction(Node, String, String, String) - Method in class co.cask.coopr.scheduler.task.NodeService
Start an action on a node.
startAllClusterServices(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Starts all services on the cluster, taking into account service dependencies for order of service starts.
startClusterService(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Starts the specified service, plus all services it depends on, on the cluster.
startJob(ClusterJob, Cluster) - Method in class co.cask.coopr.scheduler.task.TaskService
Sets the status of the given job to ClusterJob.Status.RUNNING and add it to the queue to be run.
startTask(ClusterTask) - Method in class co.cask.coopr.scheduler.task.TaskService
Starts a task by setting the status of the task to ClusterTask.Status.IN_PROGRESS and the submit time to the current timestamp.
startUp() - Method in class co.cask.coopr.common.zookeeper.IdService
 
startUp() - Method in class co.cask.coopr.provisioner.mock.MockProvisionerService
 
startUp() - Method in class co.cask.coopr.provisioner.mock.MockWorker
 
startUp() - Method in class co.cask.coopr.provisioner.plugin.ResourceService
 
startUp() - Method in class co.cask.coopr.scheduler.Scheduler
 
startUp() - Method in class co.cask.coopr.store.cluster.SQLClusterStoreService
 
startUp() - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
startUp() - Method in class co.cask.coopr.store.credential.MemcachedCredentialStore
 
startUp() - Method in class co.cask.coopr.store.credential.SQLCredentialStore
 
startUp() - Method in class co.cask.coopr.store.entity.SQLEntityStoreService
 
startUp() - Method in class co.cask.coopr.store.node.SQLNodeStoreService
 
startUp() - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreService
 
startUp() - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
startUp() - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
startUp() - Method in class co.cask.coopr.store.user.SQLUserStore
 
StatCounter<T> - Class in co.cask.coopr.management
 
StatCounter() - Constructor for class co.cask.coopr.management.StatCounter
 
status(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.StatusHandler
Returns the status of the server, which just returns OK if it is handling requests.
StatusHandler - Class in co.cask.coopr.http.handler
Serves status URL.
StatusHandler() - Constructor for class co.cask.coopr.http.handler.StatusHandler
 
stop() - Method in class co.cask.coopr.common.daemon.DaemonMain
Invoked by jsvc to stop the program.
stop() - Method in class co.cask.coopr.runtime.MockProvisionerMain
Invoked by jsvc to stop the program.
stop() - Method in class co.cask.coopr.runtime.ServerMain
Invoked by jsvc to stop the program.
stopAllClusterServices(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Stops all services on the cluster, taking into account service dependencies for order of service stops.
stopClusterService(HttpRequest, HttpResponder, String, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Stops the specified service on the cluster, plus all services that depend on it, taking into account service dependencies for order of service stops.
StoreModule - Class in co.cask.coopr.store.guice
Guice module for binding store related classes.
StoreModule(Configuration) - Constructor for class co.cask.coopr.store.guice.StoreModule
 
string2long(String) - Static method in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
Convert a string to long.
StringUtils - Class in co.cask.coopr.common.utils
Utility for strings.
StringUtils() - Constructor for class co.cask.coopr.common.utils.StringUtils
 
StringUtils.TraditionalBinaryPrefix - Enum in co.cask.coopr.common.utils
The traditional binary prefixes, kilo, mega, ..., exa, which can be represented by a 64-bit integer.
stripLeadingDigits(String) - Static method in class co.cask.coopr.common.utils.StringUtils
Strip all leading digits from a string.
SUCCESS_TRIGGERS - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
SUCCESS_URL - Static variable in class co.cask.coopr.common.conf.Constants.HttpCallback
 
SUPERADMIN - Static variable in class co.cask.coopr.account.Account
 
SUPERADMIN_TENANT - Static variable in class co.cask.coopr.common.conf.Constants
 
SuperadminHandler - Class in co.cask.coopr.http.handler
Handler for performing tenant operations.
symbol - Variable in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
 
syncClusterTemplate(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ClusterHandler
Sync the cluster template of the cluster to the current version of the cluster template.
syncClusterToCurrentTemplate(String, Account) - Method in class co.cask.coopr.cluster.ClusterService
Sync the template of the cluster to the current version of the template.
SynchronizedZKMap<T> - Class in co.cask.coopr.common.zookeeper.lib
Synchronized (across threads and different processes) implementation of Map backed by Zookeeper.
SynchronizedZKMap(ZKClient, String, Serializer<T>) - Constructor for class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
SynchronizedZKMap(ZKClient, Serializer<T>) - Constructor for class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
syncPlugins(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.PluginHandler
Push staged resources to the provisioners, and remove recalled resources from the provisioners.
syncResourceMeta(Account, ResourceCollection) - Method in class co.cask.coopr.provisioner.plugin.ResourceService
Update the metadata store, syncing the resources in the given collection for the given account.
syncResources(Account) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Get a snapshot of what plugin resources are slated to be active on the provisioners that are running workers for the given account, and push those resources to the provisioners.
syncResources(ResourceCollection) - Method in interface co.cask.coopr.store.provisioner.PluginMetaStoreView
Atomically sync all resources in the given collection to be live, and any other resource not given to not be live.
syncResources(ResourceCollection) - Method in class co.cask.coopr.store.provisioner.SQLPluginMetaStoreView
 
SyntaxException - Exception in co.cask.coopr.macro
Used to indicate a syntax error in a macro string.
SyntaxException(String) - Constructor for exception co.cask.coopr.macro.SyntaxException
New syntax exception with error message.

T

take(String, String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Take an element from a specific queue in the group, or null if there are no elements to take.
take(String) - Method in interface co.cask.coopr.common.queue.TrackingQueue
Take next available element from the queue act on it.
takeIterator(String) - Method in interface co.cask.coopr.common.queue.QueueGroup
Get an iterator that will take elements from each queue in the group in a round robin fashion until it reaches a state where there are no more elements to take from any queue.
takeNextClusterTask(TakeTaskRequest) - Method in class co.cask.coopr.scheduler.task.TaskQueueService
Returns the next task from task queue that can be handed out for provisioning.
TakeTaskRequest - Class in co.cask.coopr.http.request
Request sent by provisioners for taking a task to perform.
TakeTaskRequest(String, String, String) - Constructor for class co.cask.coopr.http.request.TakeTaskRequest
 
TakeTaskRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a TakeTaskRequest.
TakeTaskRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.TakeTaskRequestCodec
 
TASK_NAMESPACE - Static variable in class co.cask.coopr.common.conf.Constants.Lock
 
TASK_TIMEOUT_SECS - Static variable in class co.cask.coopr.common.conf.Constants
 
TaskConfig - Class in co.cask.coopr.scheduler.task
The config section of a cluster task sent to provisioners.
TaskConfig(NodeProperties, Provider, Map<String, NodeProperties>, TaskServiceAction, JsonObject, JsonObject) - Constructor for class co.cask.coopr.scheduler.task.TaskConfig
 
TaskConfigCodec - Class in co.cask.coopr.codec.json.current
To serialize/deserialize a TaskConfig.
TaskConfigCodec() - Constructor for class co.cask.coopr.codec.json.current.TaskConfigCodec
 
TaskDag - Class in co.cask.coopr.scheduler.dag
A DAG (directed acyclic graph) to linearize a set of dependent tasks.
TaskDag() - Constructor for class co.cask.coopr.scheduler.dag.TaskDag
 
TaskHandler - Class in co.cask.coopr.http.handler
Handles requests to take and finish tasks from provisioners.
TaskId - Class in co.cask.coopr.scheduler.task
Task ids are of the format clusterid-jobnum-tasknum, where all ids and numbers are numeric.
TaskId(JobId, long) - Constructor for class co.cask.coopr.scheduler.task.TaskId
 
TaskNode - Class in co.cask.coopr.scheduler.dag
Represents an action as a node of the TaskDag.
TaskNode(String, String, String) - Constructor for class co.cask.coopr.scheduler.dag.TaskNode
 
TaskQueueService - Class in co.cask.coopr.scheduler.task
Manages handing out tasks from task queue, and recording status after the task is done.
TaskService - Class in co.cask.coopr.scheduler.task
Service for performing operations on ClusterTasks.
TaskServiceAction - Class in co.cask.coopr.scheduler.task
Service in a TaskConfig, containing the name of the service and the action to be performed.
TaskServiceAction(String, ServiceAction) - Constructor for class co.cask.coopr.scheduler.task.TaskServiceAction
 
TemplateImmutabilityException - Exception in co.cask.coopr.spec.template
Template exception can be caused by template immutability.
TemplateImmutabilityException(String) - Constructor for exception co.cask.coopr.spec.template.TemplateImmutabilityException
New exception with error message.
TemplateImmutabilityException(String, Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateImmutabilityException
 
TemplateImmutabilityException(Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateImmutabilityException
 
TemplateMerger - Class in co.cask.coopr.spec.template
A template merger used for construction cluster templates from includes and parent extends.
TemplateMerger() - Constructor for class co.cask.coopr.spec.template.TemplateMerger
 
TemplateNotFoundException - Exception in co.cask.coopr.spec.template
Template exception can be caused by template missing.
TemplateNotFoundException(String) - Constructor for exception co.cask.coopr.spec.template.TemplateNotFoundException
New exception with error message.
TemplateNotFoundException(String, Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateNotFoundException
 
TemplateNotFoundException(Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateNotFoundException
 
TemplateValidationException - Exception in co.cask.coopr.spec.template
Template exception can be caused if template doe's not pass validation.
TemplateValidationException(String) - Constructor for exception co.cask.coopr.spec.template.TemplateValidationException
New exception with error message.
TemplateValidationException(String, Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateValidationException
 
TemplateValidationException(Throwable) - Constructor for exception co.cask.coopr.spec.template.TemplateValidationException
 
Tenant - Class in co.cask.coopr.spec
A tenant contains the id, plus fields.
Tenant(String, TenantSpecification) - Constructor for class co.cask.coopr.spec.Tenant
 
TENANT_HEADER - Static variable in class co.cask.coopr.common.conf.Constants
 
TENANT_NAMESPACE - Static variable in class co.cask.coopr.common.conf.Constants.Lock
 
TenantCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a Tenant.
TenantCodec() - Constructor for class co.cask.coopr.codec.json.current.TenantCodec
 
TenantProvisionerCleanup - Class in co.cask.coopr.scheduler
Time out provisioners and perform cleanup.
TenantProvisionerService - Class in co.cask.coopr.provisioner
Service for managing provisioners.
TenantSpecification - Class in co.cask.coopr.spec
A tenant as seen from external world, meaning it contains the name and settings for a tenant, but no id.
TenantSpecification(String, String, Integer, Integer, Integer) - Constructor for class co.cask.coopr.spec.TenantSpecification
 
TenantSpecification(String, Integer, Integer, Integer) - Constructor for class co.cask.coopr.spec.TenantSpecification
 
TenantSpecificationCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a TenantSpecification.
TenantSpecificationCodec() - Constructor for class co.cask.coopr.codec.json.current.TenantSpecificationCodec
 
TenantStore - Interface in co.cask.coopr.store.tenant
Store for adding, modifying, retrieving, and deleting tenants.
TenantWriteRequest - Class in co.cask.coopr.http.request
A request to add a tenant.
TenantWriteRequest(TenantSpecification) - Constructor for class co.cask.coopr.http.request.TenantWriteRequest
 
TenantWriteRequest(TenantSpecification, Boolean) - Constructor for class co.cask.coopr.http.request.TenantWriteRequest
 
TenantWriteRequestCodec - Class in co.cask.coopr.codec.json.current
Codec for deserializing a TenantWriteRequest, used so some validation is done on required fields.
TenantWriteRequestCodec() - Constructor for class co.cask.coopr.codec.json.current.TenantWriteRequestCodec
 
TIMEOUT - Static variable in class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 
timeoutProvisioners(long) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Delete and reassign workers for provisioners that have not sent a heartbeat since the given timestamp in milliseconds.
TimeSeries - Class in co.cask.coopr.metrics
Class for presenting time series.
TimeSeries(long, long, List<Interval>) - Constructor for class co.cask.coopr.metrics.TimeSeries
 
toArray() - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
toArray(T1[]) - Method in class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
toBytes(T, Type) - Method in class co.cask.coopr.store.DBQueryExecutor
Serialize the given object into json, then into bytes of that json.
toHighestPriority(String) - Method in interface co.cask.coopr.common.queue.TrackingQueue
Promotes element to the top of the queue.
toString() - Method in class co.cask.coopr.account.Account
 
toString() - Method in class co.cask.coopr.cluster.Cluster
 
toString() - Method in class co.cask.coopr.cluster.Node.Action
 
toString() - Method in class co.cask.coopr.cluster.Node
 
toString() - Method in class co.cask.coopr.cluster.NodeProperties
 
toString() - Method in class co.cask.coopr.common.conf.Configuration.IntegerRanges
 
toString() - Method in class co.cask.coopr.common.conf.Configuration
 
toString() - Method in class co.cask.coopr.common.queue.Element
 
toString() - Method in class co.cask.coopr.common.queue.QueueMetrics
 
toString() - Method in class co.cask.coopr.common.utils.ImmutablePair
Returns a string representation of ImmutablePair object.
toString() - Method in class co.cask.coopr.http.request.ClusterCreateRequest
 
toString() - Method in class co.cask.coopr.http.request.ClusterOperationRequest
 
toString() - Method in class co.cask.coopr.http.request.FinishTaskRequest
 
toString() - Method in class co.cask.coopr.http.request.TenantWriteRequest
 
toString() - Method in class co.cask.coopr.layout.change.AddServicesChange
 
toString() - Method in class co.cask.coopr.layout.NodeLayout
 
toString() - Method in class co.cask.coopr.metrics.TimeSeries
 
toString() - Method in class co.cask.coopr.provisioner.plugin.ResourceMeta
 
toString() - Method in class co.cask.coopr.provisioner.plugin.ResourceType
 
toString() - Method in class co.cask.coopr.provisioner.Provisioner
 
toString() - Method in class co.cask.coopr.provisioner.ProvisionerHeartbeat
 
toString() - Method in class co.cask.coopr.scheduler.ActionOnService
 
toString() - Method in class co.cask.coopr.scheduler.Actions.Dependency
 
toString() - Method in class co.cask.coopr.scheduler.Actions
 
toString() - Method in class co.cask.coopr.scheduler.callback.CallbackData
 
toString() - Method in class co.cask.coopr.scheduler.dag.TaskDag
 
toString() - Method in class co.cask.coopr.scheduler.dag.TaskNode
 
toString() - Method in class co.cask.coopr.scheduler.task.ClusterJob
 
toString() - Method in class co.cask.coopr.scheduler.task.ClusterTask
 
toString() - Method in class co.cask.coopr.scheduler.task.JobId
 
toString() - Method in class co.cask.coopr.scheduler.task.SchedulableTask
 
toString() - Method in class co.cask.coopr.scheduler.task.TaskConfig
 
toString() - Method in class co.cask.coopr.scheduler.task.TaskId
 
toString() - Method in class co.cask.coopr.scheduler.task.TaskServiceAction
 
toString() - Method in class co.cask.coopr.spec.BaseEntity
 
toString() - Method in class co.cask.coopr.spec.HardwareType
 
toString() - Method in class co.cask.coopr.spec.ImageType
 
toString() - Method in class co.cask.coopr.spec.Link
 
toString() - Method in class co.cask.coopr.spec.NamedEntity
 
toString() - Method in class co.cask.coopr.spec.plugin.AbstractPluginSpecification
 
toString() - Method in class co.cask.coopr.spec.plugin.FieldSchema
 
toString() - Method in class co.cask.coopr.spec.plugin.ParametersSpecification
 
toString() - Method in class co.cask.coopr.spec.Provider
 
toString() - Method in class co.cask.coopr.spec.service.Service
 
toString() - Method in class co.cask.coopr.spec.service.ServiceAction
 
toString() - Method in class co.cask.coopr.spec.service.ServiceDependencies
 
toString() - Method in class co.cask.coopr.spec.template.Administration
 
toString() - Method in class co.cask.coopr.spec.template.ClusterDefaults
 
toString() - Method in class co.cask.coopr.spec.template.ClusterTemplate
 
toString() - Method in class co.cask.coopr.spec.template.Compatibilities
 
toString() - Method in class co.cask.coopr.spec.template.Constraints
 
toString() - Method in class co.cask.coopr.spec.template.LayoutConstraint
 
toString() - Method in class co.cask.coopr.spec.template.LeaseDuration
 
toString() - Method in class co.cask.coopr.spec.template.PartialTemplate
 
toString() - Method in class co.cask.coopr.spec.template.ServiceConstraint
 
toString() - Method in class co.cask.coopr.spec.Tenant
 
toString() - Method in class co.cask.coopr.spec.TenantSpecification
 
toString() - Method in class co.cask.coopr.store.cluster.ClusterTaskFilter
 
TrackingQueue - Interface in co.cask.coopr.common.queue
Queue that tracks consuming of the elements and may re-add elements that were attempted to be consumed.
TrackingQueue.ConsumingStatus - Enum in co.cask.coopr.common.queue
Defines Tracking Queue Consuming Status.
TrackingQueue.PossessionState - Enum in co.cask.coopr.common.queue
Defines PossessionState.
tryAddTenantAssignments(String, int) - Method in class co.cask.coopr.provisioner.Provisioner
Try assigning additional workers to a tenant, capping out if the number to add would make the total assignments go over the total capacity of the provisioner.
tryLock() - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
 
tryLock(long, TimeUnit) - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
 
tryRemoveTenantAssignments(String, int) - Method in class co.cask.coopr.provisioner.Provisioner
Try removing assigned workers from a tenant, capping out if the number to remove is greater than the number currently assigned.
TTL - Static variable in class co.cask.coopr.common.conf.Constants.MemcachedCredentialStore
 

U

unlock() - Method in class co.cask.coopr.common.zookeeper.lib.ReentrantDistributedLock
 
unset(String) - Method in class co.cask.coopr.common.conf.Configuration
Unset a previously set property.
updateNode(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.NodeHandler
 
UpgradeTo0_9_9 - Class in co.cask.coopr.upgrade
Upgrades database to work with Coopr 0.9.9.
UpgradeTo0_9_9(DBConnectionPool, SQLClusterStoreService) - Constructor for class co.cask.coopr.upgrade.UpgradeTo0_9_9
 
uploadAutomatorTypeModule(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Add an automator type resource.
uploadProviderTypeModule(HttpRequest, HttpResponder, String, String, String) - Method in class co.cask.coopr.http.handler.PluginHandler
Add a provider type resource.
USER_HEADER - Static variable in class co.cask.coopr.common.conf.Constants
 
UserHandler - Class in co.cask.coopr.http.handler
Handler for managing users.
UserStore - Interface in co.cask.coopr.store.user
Persistent store for user accounts and their associated profiles.

V

validate(String) - Static method in class co.cask.coopr.macro.Expander
Given a text that may contain macros, validate the syntax of all macros.
validateServicesToAdd(Cluster, Set<String>) - Method in class co.cask.coopr.layout.Solver
Validate whether or not a set of services are allowed to be added to a cluster.
value - Variable in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
 
valueOf(String) - Static method in enum co.cask.coopr.cluster.Cluster.Status
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.cluster.Node.Status
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.common.queue.QueueType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.common.queue.TrackingQueue.ConsumingStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.common.queue.TrackingQueue.PossessionState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
Returns the enum constant of this type with the specified name.
valueOf(char) - Static method in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
 
valueOf(String) - Static method in enum co.cask.coopr.common.zookeeper.IdService.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.metrics.MetricService.Periodicity
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.provisioner.plugin.PluginType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.provisioner.plugin.ResourceStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.scheduler.callback.CallbackData.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.scheduler.ClusterAction
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.scheduler.SolverRequest.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.scheduler.task.ClusterJob.Status
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.scheduler.task.ClusterTask.Status
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.spec.plugin.ParameterType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.spec.plugin.ResourceTypeFormat
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.spec.ProvisionerAction
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum co.cask.coopr.store.entity.BaseEntityStoreView.EntityType
Returns the enum constant of this type with the specified name.
values() - Static method in enum co.cask.coopr.cluster.Cluster.Status
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.cluster.Node.Status
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.common.queue.QueueType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.common.queue.TrackingQueue.ConsumingStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.common.queue.TrackingQueue.PossessionState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.common.utils.StringUtils.TraditionalBinaryPrefix
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.common.zookeeper.IdService.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class co.cask.coopr.common.zookeeper.lib.SynchronizedZKMap
 
values() - Method in class co.cask.coopr.common.zookeeper.lib.ZKMap
 
values() - Static method in enum co.cask.coopr.metrics.MetricService.Periodicity
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.provisioner.plugin.PluginType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.provisioner.plugin.ResourceStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.scheduler.callback.CallbackData.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.scheduler.ClusterAction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.scheduler.SolverRequest.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.scheduler.task.ClusterJob.Status
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.scheduler.task.ClusterTask.Status
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.spec.plugin.ParameterType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.spec.plugin.ResourceTypeFormat
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.spec.ProvisionerAction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum co.cask.coopr.store.entity.BaseEntityStoreView.EntityType
Returns an array containing the constants of this enum type, in the order they are declared.
verify(int) - Method in class co.cask.coopr.spec.template.SizeConstraint
Verifies that the given number of machines meets the size constraint.
version - Variable in class co.cask.coopr.spec.BaseEntity.Builder
 
version - Variable in class co.cask.coopr.spec.BaseEntity
 

W

wipe(String, String) - Method in interface co.cask.coopr.store.credential.CredentialStore
Wipe out the fields for the tenant and cluster.
wipe() - Method in interface co.cask.coopr.store.credential.CredentialStore
Wipe out all fields for all tenants and all clusters.
wipe(String, String) - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
wipe() - Method in class co.cask.coopr.store.credential.InProcessCredentialStore
 
wipe(String, String) - Method in class co.cask.coopr.store.credential.MemcachedCredentialStore
 
wipe() - Method in class co.cask.coopr.store.credential.MemcachedCredentialStore
 
wipe(String, String) - Method in class co.cask.coopr.store.credential.SQLCredentialStore
 
wipe() - Method in class co.cask.coopr.store.credential.SQLCredentialStore
 
WORKER_BALANCE - Static variable in class co.cask.coopr.common.conf.Constants.Queue
 
WorkerBalanceScheduler - Class in co.cask.coopr.scheduler
Balances number of workers to place on each provisioner.
writeAutomatorType(AutomatorType) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeAutomatorType(AutomatorType) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given AutomatorType to the store.
writeCluster(Cluster) - Method in class co.cask.coopr.store.cluster.BaseSQLClusterStoreView
 
writeCluster(Cluster) - Method in interface co.cask.coopr.store.cluster.ClusterStoreView
Write a cluster to the store using its id.
writeCluster(Cluster) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
writeClusterJob(ClusterJob) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Write a cluster job to the store.
writeClusterJob(ClusterJob) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
writeClusterTask(ClusterTask) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Write a cluster task to the store using its id.
writeClusterTask(ClusterTask) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
writeClusterTemplate(ClusterTemplate) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeClusterTemplate(ClusterTemplate) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given ClusterTemplate to the store.
writeComplete(ChannelHandlerContext, WriteCompletionEvent) - Method in class co.cask.coopr.http.handler.auth.SecurityAuthenticationHttpHandler
 
writeEntity(BaseEntityStoreView.EntityType, String, int, byte[]) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
Write the specified entity to some persistent store.
writeEntity(BaseEntityStoreView.EntityType, String, int, byte[]) - Method in class co.cask.coopr.store.entity.SQLAdminEntityStoreView
 
writeEntity(BaseEntityStoreView.EntityType, String, int, byte[]) - Method in class co.cask.coopr.store.entity.SQLUserEntityStoreView
 
writeHardwareType(HardwareType) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeHardwareType(HardwareType) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given HardwareType to the store.
writeImageType(ImageType) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeImageType(ImageType) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given ImageType to the store.
writeNode(Node) - Method in interface co.cask.coopr.store.cluster.ClusterStore
Write the given node to the store.
writeNode(Node) - Method in class co.cask.coopr.store.cluster.SQLClusterStore
 
writeNode(Node) - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
writeNode(Node) - Method in interface co.cask.coopr.store.node.NodeStoreView
Write a node to the store using its id.
writeNode(Node) - Method in class co.cask.coopr.store.node.SQLNodeStore
 
writeNodes(Set<Node>) - Method in class co.cask.coopr.store.node.BaseSQLNodeStoreView
 
writeNodes(Set<Node>) - Method in interface co.cask.coopr.store.node.NodeStoreView
Write a set of nodes to the store using its id.
writeNodes(Set<Node>) - Method in class co.cask.coopr.store.node.SQLNodeStore
 
writePartialTemplate(PartialTemplate) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writePartialTemplate(PartialTemplate) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given PartialTemplate to the store.
writeProfile(HttpRequest, HttpResponder) - Method in class co.cask.coopr.http.handler.UserHandler
Write an account profile.
writeProfile(Account, Map<String, Object>) - Method in class co.cask.coopr.store.user.SQLUserStore
 
writeProfile(Account, Map<String, Object>) - Method in interface co.cask.coopr.store.user.UserStore
Write the profile for a given account.
writeProvider(Provider) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeProvider(Provider) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given Provider to the store.
writeProviderType(ProviderType) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeProviderType(ProviderType) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given ProviderType to the store.
writeProvisioner(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.ProvisionerHandler
Write a provisioner.
writeProvisioner(Provisioner) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Write a provisioner, and queue jobs to rebalance workers for all tenants in the system.
writeProvisioner(Provisioner) - Method in interface co.cask.coopr.store.provisioner.ProvisionerStore
Write the given provisioner.
writeProvisioner(Provisioner) - Method in class co.cask.coopr.store.provisioner.SQLProvisionerStore
 
writeRequested(ChannelHandlerContext, MessageEvent) - Method in class co.cask.coopr.http.handler.auth.SecurityAuthenticationHttpHandler
 
writeService(Service) - Method in class co.cask.coopr.store.entity.BaseEntityStoreView
 
writeService(Service) - Method in interface co.cask.coopr.store.entity.EntityStoreView
Write the given Service to the store.
writeTenant(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.http.handler.SuperadminHandler
Write the specified tenant.
writeTenant(HttpRequest, HttpResponder, String) - Method in class co.cask.coopr.provisioner.mock.MockProvisionerHandler
 
writeTenant(Tenant) - Method in class co.cask.coopr.store.tenant.SQLTenantStore
 
writeTenant(Tenant) - Method in interface co.cask.coopr.store.tenant.TenantStore
Write the given Tenant to the store.
writeTenantSpecification(TenantSpecification) - Method in class co.cask.coopr.provisioner.TenantProvisionerService
Write the tenant to the store and balance the tenant workers across provisioners.
writeXml(OutputStream) - Method in class co.cask.coopr.common.conf.Configuration
Write out the non-default properties in this configuration to the given OutputStream.
writeXml(Writer) - Method in class co.cask.coopr.common.conf.Configuration
Write out the non-default properties in this configuration to the given Writer.

Z

ZKClientExt - Class in co.cask.coopr.common.zookeeper
Extension to standard operations provided by ZKClient.
ZKClientExt.SetResult - Class in co.cask.coopr.common.zookeeper
ZKClientExt.SetResult(String, Stat) - Constructor for class co.cask.coopr.common.zookeeper.ZKClientExt.SetResult
 
ZKCollection<T> - Class in co.cask.coopr.common.zookeeper.lib
Implementation of Collection backed by Zookeeper.
ZKCollection(ZKClient, String, Serializer<T>) - Constructor for class co.cask.coopr.common.zookeeper.lib.ZKCollection
 
ZKMap<T> - Class in co.cask.coopr.common.zookeeper.lib
Implementation of Map backed by Zookeeper.
ZKMap(ZKClient, String, Serializer<T>) - Constructor for class co.cask.coopr.common.zookeeper.lib.ZKMap
 
ZOOKEEPER_NAMESPACE - Static variable in class co.cask.coopr.common.conf.Constants
 
ZOOKEEPER_QUORUM - Static variable in class co.cask.coopr.common.conf.Constants
 
ZOOKEEPER_SESSION_TIMEOUT_MILLIS - Static variable in class co.cask.coopr.common.conf.Constants
 
ZookeeperModule - Class in co.cask.coopr.common.zookeeper.guice
Guice module for binding zookeeper related classes.
ZookeeperModule(ZKClient) - Constructor for class co.cask.coopr.common.zookeeper.guice.ZookeeperModule
 
A B C D E F G H I J K L M N O P Q R S T U V W Z 

Copyright © 2013-2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.