Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/FSLibrary/MissionHistoryPubnetParallelCatchupV2.fs
Original file line number Diff line number Diff line change
Expand Up @@ -369,7 +369,7 @@ let dumpLogs (context: MissionContext, podName: String) =
for i in lineStart .. logLines.Count - 1 do
LogInfo "%s" logLines.[i]

let filename = sprintf "%s.log" podName
let filename = sprintf "FAILED-last%dlines-%s.log" failedJobLogFileLineCount podName
context.destination.WriteLines filename (logLines.ToArray())
stream.Close()

Expand Down
23 changes: 23 additions & 0 deletions src/FSLibrary/StellarNamespaceContent.fs
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st
let ingresses : Set<string> ref = ref Set.empty
let jobs : Set<string> ref = ref Set.empty
let daemonSets : Set<string> ref = ref Set.empty
let deployments : Set<string> ref = ref Set.empty

let ignoreError f =
try
Expand Down Expand Up @@ -96,6 +97,18 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st
propagationPolicy = "Foreground"
))

let delDeployment (name: string) =
LogInfo "Deleting Deployment %s" name
ApiRateLimit.sleepUntilNextRateLimitedApiCallTime (apiRateLimit)

ignoreError
(fun _ ->
kube.DeleteNamespacedDeployment(
namespaceParameter = namespaceProperty,
name = name,
propagationPolicy = "Foreground"
))

let cleanSet (f: 'a -> unit) (s: Set<'a> ref) : unit =
Set.iter f (!s)
s := Set.empty
Expand All @@ -109,6 +122,7 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st
member self.Cleanup() =
cleanSet delService services
cleanSet delStatefulSet statefulSets
cleanSet delDeployment deployments
cleanSet delConfigMap configMaps
cleanSet delIngress ingresses
cleanSet delJob jobs
Expand All @@ -126,6 +140,8 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st

member self.Add(daemonSet: V1DaemonSet) = addOne daemonSets daemonSet.Metadata.Name

member self.Add(deployment: V1Deployment) = addOne deployments deployment.Metadata.Name

member self.Del(service: V1Service) = delOne delService services service.Metadata.Name

member self.Del(configMap: V1ConfigMap) = delOne delConfigMap configMaps configMap.Metadata.Name
Expand All @@ -138,6 +154,8 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st

member self.Del(daemonSet: V1DaemonSet) = delOne delDaemonSet daemonSets daemonSet.Metadata.Name

member self.Del(deployment: V1Deployment) = delOne delDeployment deployments deployment.Metadata.Name

member self.AddAll() =
ApiRateLimit.sleepUntilNextRateLimitedApiCallTime (apiRateLimit)

Expand Down Expand Up @@ -169,3 +187,8 @@ type NamespaceContent(kube: Kubernetes, apiRateLimit: int, namespaceProperty: st

for d in kube.ListNamespacedDaemonSet(namespaceParameter = namespaceProperty).Items do
self.Add(d)

ApiRateLimit.sleepUntilNextRateLimitedApiCallTime (apiRateLimit)

for d in kube.ListNamespacedDeployment(namespaceParameter = namespaceProperty).Items do
self.Add(d)