org.apache.ambari.server.topology

Interface PersistedState

All Known Implementing Classes:

PersistedStateImpl

public interface PersistedState

Persistence abstraction.

Method Summary

Modifier and Type	Method and Description
Map<ClusterTopology,List<LogicalRequest>>	getAllRequests() Get all persisted requests.
LogicalRequest	getProvisionRequest(long clusterId) Returns provision request for a cluster
void	persistLogicalRequest(LogicalRequest logicalRequest, long topologyRequestId) Persist a logical request.
PersistedTopologyRequest	persistTopologyRequest(BaseClusterRequest topologyRequest) Persist a topology request.
void	registerHostName(long hostRequestId, String hostName) Registeer a host with a host request.
void	registerInTopologyHostInfo(Host host)
void	registerPhysicalTask(long logicalTaskId, long physicalTaskId) Register a physical task with a logical task.
void	removeHostRequests(long logicalRequestId, Collection<HostRequest> hostRequests) Remove the given host requests (must belong to the same topology request), and also the topology request if it does not have any host requests left.
void	setHostRequestStatus(long hostRequestId, HostRoleStatus status, String message) Update the status of the given host request.

Method Detail

persistTopologyRequest

PersistedTopologyRequest persistTopologyRequest(BaseClusterRequest topologyRequest)

Persist a topology request.

Parameters:

topologyRequest - topology request to persist

Returns:

a persisted topology request which is a wrapper around a TopologyRequest which adds an id that can be used to refer to the persisted entity

persistLogicalRequest

void persistLogicalRequest(LogicalRequest logicalRequest,
                           long topologyRequestId)

Persist a logical request.

Parameters:

logicalRequest - logical request to persist

topologyRequestId - the id of the associated topology request

registerPhysicalTask

void registerPhysicalTask(long logicalTaskId,
                          long physicalTaskId)

Register a physical task with a logical task.

Parameters:

logicalTaskId - logical task id

physicalTaskId - physical task id

registerHostName

void registerHostName(long hostRequestId,
                      String hostName)

Registeer a host with a host request.

Parameters:

hostRequestId - host request id

hostName - name of host being registered

getAllRequests

Map<ClusterTopology,List<LogicalRequest>> getAllRequests()

Get all persisted requests. This is used to replay all requests upon ambari startup.

Returns:

map of cluster topology to list of logical requests

registerInTopologyHostInfo

void registerInTopologyHostInfo(Host host)

getProvisionRequest

LogicalRequest getProvisionRequest(long clusterId)

Returns provision request for a cluster

Parameters:

clusterId -

Returns:

removeHostRequests

void removeHostRequests(long logicalRequestId,
                        Collection<HostRequest> hostRequests)

Remove the given host requests (must belong to the same topology request), and also the topology request if it does not have any host requests left.

setHostRequestStatus

void setHostRequestStatus(long hostRequestId,
                          HostRoleStatus status,
                          String message)

Update the status of the given host request.