Package jetbrains.buildServer.clouds.server.impl

Class CloudStateHolder

java.lang.Object

jetbrains.buildServer.clouds.server.impl.CloudStateHolder

All Implemented Interfaces:

CloudInstancesProviderCallback, CloudInstancesProviderExtendedCallback

public class CloudStateHolder
extends Object
implements CloudInstancesProviderExtendedCallback

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CloudStateHolder.ChangeState
static class	CloudStateHolder.CollectedCloudState
static class	CloudStateHolder.ImageState
static class	CloudStateHolder.ImageStateKey
static class	CloudStateHolder.InstanceState
static class	CloudStateHolder.InstanceStateKey
static class	CloudStateHolder.ProfileState
static class	CloudStateHolder.ProfileStateKey
static class	CloudStateHolder.StateBase<K>

Constructor Summary

Constructors

Constructor	Description
CloudStateHolder(CloudInstancesProvider provider, RunningAgentsTracker runningAgentsTracker, CloudManagerBase cloudManagerBase)

Method Summary

Modifier and Type	Method	Description
void	clearState()	Drops all images from all profiles.
CloudStateHolder.CollectedCloudState	collectImageState(CloudStateHolder.ImageStateKey imageStateKey)
void	collectState()
CloudStateHolder.ImageState	findImageByKey(CloudStateHolder.ImageStateKey imageStateKey)
CloudStateHolder.InstanceState	findInstanceByKey(CloudStateHolder.InstanceStateKey instanceStateKey)
CloudStateHolder.ProfileState	findProfileByKey(String projectId, String profileId)
CloudStateHolder.ProfileState	findProfileByKey(CloudStateHolder.ProfileStateKey key)
Set<CloudStateHolder.ImageStateKey>	getAllImageKeys()
Set<CloudStateHolder.InstanceStateKey>	getAllInstanceKeys()
Map<CloudStateHolder.ImageStateKey,CloudStateHolder.ChangeState>	getProcessedImages()
Map<CloudStateHolder.InstanceStateKey,CloudStateHolder.ChangeState>	getProcessedInstances()
Map<CloudStateHolder.ProfileStateKey,CloudStateHolder.ChangeState>	getProcessedProfiles()
Map<CloudStateHolder.ProfileStateKey,CloudStateHolder.ProfileState>	getProfiles()
boolean	isInitialized()
void	processClient(CloudProfile profile)	process client
void	processClientError(CloudProfile profile, CloudErrorInfo cloudErrorInfo)	Called if - client error occoured
boolean	processImage(CloudProfile profile, CloudImage image)	Indicates whether to process this particular image.
void	processImageError(CloudProfile profile, CloudImage image)	Called if - image error occoured
void	processImageEx(CloudProfile profile, CloudImage image, CanStartNewInstanceResult canStart)
boolean	processInstance(CloudProfile profile, CloudInstance instance)	Processes instance and indicates whether to process next allocated instance
void	processInstanceError(CloudProfile profile, CloudInstance instance)	Called if - instance error occoured
void	processInstanceExpired(CloudProfile profile, CloudClientEx client, CloudInstance instance)	Called if - instance is expired and should be terminated waiting if necessary for the current build to finish
void	processInstanceMaintained(CloudProfile profile, CloudClientEx client, CloudInstance instance)	Called if - instance is maintained (should not be terminated)
void	processNotReady(CloudProfile profile)	Called if - client is still connecting - client error occoured - image error occoured - instance error occoured
void	removeImage(CloudStateHolder.ImageStateKey imageStateKey)
void	removeInstance(CloudStateHolder.InstanceStateKey instanceStateKey)
void	setInitialized()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CloudStateHolder

public CloudStateHolder(@NotNull
                        CloudInstancesProvider provider,
                        @NotNull
                        RunningAgentsTracker runningAgentsTracker,
                        @NotNull
                        CloudManagerBase cloudManagerBase)

Method Detail

getProfiles

public Map<CloudStateHolder.ProfileStateKey,CloudStateHolder.ProfileState> getProfiles()

collectState

public void collectState()

collectImageState

@NotNull
public CloudStateHolder.CollectedCloudState collectImageState(@NotNull
                                                              CloudStateHolder.ImageStateKey imageStateKey)

getProcessedProfiles

public Map<CloudStateHolder.ProfileStateKey,CloudStateHolder.ChangeState> getProcessedProfiles()

getProcessedImages

public Map<CloudStateHolder.ImageStateKey,CloudStateHolder.ChangeState> getProcessedImages()

getProcessedInstances

public Map<CloudStateHolder.InstanceStateKey,CloudStateHolder.ChangeState> getProcessedInstances()

isInitialized

public boolean isInitialized()

setInitialized

public void setInitialized()

findProfileByKey

@Nullable
public CloudStateHolder.ProfileState findProfileByKey(@NotNull
                                                      String projectId,
                                                      @NotNull
                                                      String profileId)

findProfileByKey

public CloudStateHolder.ProfileState findProfileByKey(@NotNull
                                                      CloudStateHolder.ProfileStateKey key)

findImageByKey

@Nullable
public CloudStateHolder.ImageState findImageByKey(@NotNull
                                                  CloudStateHolder.ImageStateKey imageStateKey)

findInstanceByKey

@Nullable
public CloudStateHolder.InstanceState findInstanceByKey(@NotNull
                                                        CloudStateHolder.InstanceStateKey instanceStateKey)

getAllInstanceKeys

public Set<CloudStateHolder.InstanceStateKey> getAllInstanceKeys()

getAllImageKeys

public Set<CloudStateHolder.ImageStateKey> getAllImageKeys()

removeImage

public void removeImage(@NotNull
                        CloudStateHolder.ImageStateKey imageStateKey)

removeInstance

public void removeInstance(@NotNull
                           CloudStateHolder.InstanceStateKey instanceStateKey)

clearState

public void clearState()

Drops all images from all profiles. This is done to reinit state from DB to ensure they are in sync

processNotReady

public void processNotReady(@NotNull
                            CloudProfile profile)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - client is still connecting - client error occoured - image error occoured - instance error occoured

Specified by:

processNotReady in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

processClientError

public void processClientError(@NotNull
                               CloudProfile profile,
                               @NotNull
                               CloudErrorInfo cloudErrorInfo)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - client error occoured

Specified by:

processClientError in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

processClient

public void processClient(@NotNull
                          CloudProfile profile)

Description copied from interface: CloudInstancesProviderExtendedCallback

process client

Specified by:

processClient in interface CloudInstancesProviderExtendedCallback

processImageError

public void processImageError(@NotNull
                              CloudProfile profile,
                              @NotNull
                              CloudImage image)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - image error occoured

Specified by:

processImageError in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

image - errorneous image

processImage

public boolean processImage(@NotNull
                            CloudProfile profile,
                            @NotNull
                            CloudImage image)

Description copied from interface: CloudInstancesProviderCallback

Indicates whether to process this particular image. Unlike CloudInstancesProviderCallback.processInstance(CloudProfile, CloudInstance) returning false will skip just this image and continue further processing

Specified by:

processImage in interface CloudInstancesProviderCallback

Returns:

true to process this image

processInstanceError

public void processInstanceError(@NotNull
                                 CloudProfile profile,
                                 @NotNull
                                 CloudInstance instance)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - instance error occoured

Specified by:

processInstanceError in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

instance - errorneous instance

processInstance

public boolean processInstance(@NotNull
                               CloudProfile profile,
                               @NotNull
                               CloudInstance instance)

Description copied from interface: CloudInstancesProviderCallback

Processes instance and indicates whether to process next allocated instance

Specified by:

processInstance in interface CloudInstancesProviderCallback

Parameters:

profile - profile

instance - instance

Returns:

true to continue iteration and false otherwise

processImageEx

public void processImageEx(@NotNull
                           CloudProfile profile,
                           @NotNull
                           CloudImage image,
                           @NotNull
                           CanStartNewInstanceResult canStart)

processInstanceExpired

public void processInstanceExpired(@NotNull
                                   CloudProfile profile,
                                   @NotNull
                                   CloudClientEx client,
                                   @NotNull
                                   CloudInstance instance)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - instance is expired and should be terminated waiting if necessary for the current build to finish

Specified by:

processInstanceExpired in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

instance - expired instance

processInstanceMaintained

public void processInstanceMaintained(@NotNull
                                      CloudProfile profile,
                                      @NotNull
                                      CloudClientEx client,
                                      @NotNull
                                      CloudInstance instance)

Description copied from interface: CloudInstancesProviderExtendedCallback

Called if - instance is maintained (should not be terminated)

Specified by:

processInstanceMaintained in interface CloudInstancesProviderExtendedCallback

Parameters:

profile - profile

instance - expired instance