Package com.atlassian.bamboo.agent.ephemeral

Class KubernetesExecutor

java.lang.Object

com.atlassian.bamboo.agent.ephemeral.KubernetesExecutor

Direct Known Subclasses:

LoggingKubernetesExecutor

public class KubernetesExecutor
extends Object

Constructor Summary

Constructors

Constructor	Description
KubernetesExecutor(BambooHomeLocator homeLocator, String kubectlCmd)

Method Summary

Modifier and Type	Method	Description
@NotNull DeleteAgentPodResult	deleteAgentPod(@Nullable String pathToConfig, @NotNull String podName)
@NotNull DeleteAgentPodsResult	deleteAgentPods(@NotNull EphemeralAgentsConfiguration config)
@NotNull DeleteAgentPodsResult	deleteAgentPods(@Nullable String pathToConfig, @NotNull List<String> podNames)
@NotNull DeleteAgentPodsResult	deleteAgentPodsIfNotInPhase(@NotNull EphemeralAgentsConfiguration config, @NotNull List<PodPhase> podPhasesToSkip)
@NotNull DeleteAgentPodsResult	deleteNonActiveAgentPods(@NotNull EphemeralAgentsConfiguration config)
String	describePod(@NotNull EphemeralAgentsConfiguration config, @NotNull String podName)
String	getPod(@NotNull EphemeralAgentsConfiguration config, @NotNull String podName)
@NotNull PodContainerLogsResult	getPodContainerLogs(@Nullable String pathToConfig, @NotNull String podName, @NotNull Optional<String> containerName, @NotNull Optional<Integer> resultsLimit, @NotNull Optional<String> afterTimestamp)
GetPodsJsonResult	getPodJsonResults(@NotNull EphemeralAgentsConfiguration config)
String	getPods(@NotNull EphemeralAgentsConfiguration config)
@NotNull LaunchAgentPodResult	launchAgentPod(@Nullable String pathToConfig, @NotNull File fileWithPodTemplate)
@NotNull LaunchAgentPodResult	launchAgentPod(@Nullable String pathToConfig, @NotNull File fileWithPodTemplate, @NotNull String podName, @NotNull String launchingPurposeKey, int retryCounter)
@NotNull TestConnectionResult	testConnection(@Nullable String pathToConfig)

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesExecutor

public KubernetesExecutor(BambooHomeLocator homeLocator,
                          String kubectlCmd)

Method Detail

testConnection

@NotNull
public @NotNull TestConnectionResult testConnection(@Nullable
                                                    @Nullable String pathToConfig)

launchAgentPod

@NotNull
public @NotNull LaunchAgentPodResult launchAgentPod(@Nullable
                                                    @Nullable String pathToConfig,
                                                    @NotNull
                                                    @NotNull File fileWithPodTemplate)

launchAgentPod

@NotNull
public @NotNull LaunchAgentPodResult launchAgentPod(@Nullable
                                                    @Nullable String pathToConfig,
                                                    @NotNull
                                                    @NotNull File fileWithPodTemplate,
                                                    @NotNull
                                                    @NotNull String podName,
                                                    @NotNull
                                                    @NotNull String launchingPurposeKey,
                                                    int retryCounter)

getPods

public String getPods(@NotNull
                      @NotNull EphemeralAgentsConfiguration config)

getPodJsonResults

public GetPodsJsonResult getPodJsonResults(@NotNull
                                           @NotNull EphemeralAgentsConfiguration config)

getPod

public String getPod(@NotNull
                     @NotNull EphemeralAgentsConfiguration config,
                     @NotNull
                     @NotNull String podName)

describePod

public String describePod(@NotNull
                          @NotNull EphemeralAgentsConfiguration config,
                          @NotNull
                          @NotNull String podName)
                   throws KubernetesExecutorException

Throws:

KubernetesExecutorException

deleteAgentPod

@NotNull
public @NotNull DeleteAgentPodResult deleteAgentPod(@Nullable
                                                    @Nullable String pathToConfig,
                                                    @NotNull
                                                    @NotNull String podName)

deleteAgentPods

@NotNull
public @NotNull DeleteAgentPodsResult deleteAgentPods(@NotNull
                                                      @NotNull EphemeralAgentsConfiguration config)

deleteAgentPods

@NotNull
public @NotNull DeleteAgentPodsResult deleteAgentPods(@Nullable
                                                      @Nullable String pathToConfig,
                                                      @NotNull
                                                      @NotNull List<String> podNames)

deleteAgentPodsIfNotInPhase

@NotNull
public @NotNull DeleteAgentPodsResult deleteAgentPodsIfNotInPhase(@NotNull
                                                                  @NotNull EphemeralAgentsConfiguration config,
                                                                  @NotNull
                                                                  @NotNull List<PodPhase> podPhasesToSkip)

deleteNonActiveAgentPods

@NotNull
public @NotNull DeleteAgentPodsResult deleteNonActiveAgentPods(@NotNull
                                                               @NotNull EphemeralAgentsConfiguration config)

getPodContainerLogs

@NotNull
public @NotNull PodContainerLogsResult getPodContainerLogs(@Nullable
                                                           @Nullable String pathToConfig,
                                                           @NotNull
                                                           @NotNull String podName,
                                                           @NotNull
                                                           @NotNull Optional<String> containerName,
                                                           @NotNull
                                                           @NotNull Optional<Integer> resultsLimit,
                                                           @NotNull
                                                           @NotNull Optional<String> afterTimestamp)