Skip to content

Commit

Permalink
Merge "nodepool-builder - log expose - slight refactor"
Browse files Browse the repository at this point in the history
  • Loading branch information
Zuul CI authored and Gerrit Code Review committed Oct 24, 2023
2 parents fd48134 + bbd58a2 commit 263501a
Show file tree
Hide file tree
Showing 8 changed files with 38 additions and 26 deletions.
24 changes: 9 additions & 15 deletions controllers/nodepool.go
Original file line number Diff line number Diff line change
Expand Up @@ -350,7 +350,6 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
base.MkVolumeSecret(NodepoolProvidersSecretsName),
base.MkEmptyDirVolume("nodepool-config"),
base.MkEmptyDirVolume("nodepool-home-ssh"),
base.MkEmptyDirVolume("nodepool-log"),
r.commonToolingVolume(),
{
Name: "nodepool-builder-ssh-key",
Expand Down Expand Up @@ -380,10 +379,6 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
Name: builderIdent,
MountPath: "/var/lib/nodepool",
},
{
Name: "nodepool-log",
MountPath: "/var/log/nodepool",
},
configScriptVolumeMount,
{
Name: "nodepool-tooling-vol",
Expand Down Expand Up @@ -426,12 +421,12 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
"statsd_mapping": utils.Checksum([]byte(nodepoolStatsdMappingConfig)),
// When the Secret ResourceVersion field change (when edited) we force a nodepool-builder restart
"nodepool-providers-secrets": string(nodepoolProvidersSecrets.ResourceVersion),
"serial": "7",
"serial": "8",
}

initContainer := base.MkContainer("nodepool-builder-init", base.BusyboxImage)

initContainer.Command = []string{"bash", "-c", "mkdir -p ~/dib; /usr/local/bin/generate-config.sh"}
initContainer.Command = []string{"bash", "-c", "mkdir -p ~/dib ~/builds; /usr/local/bin/generate-config.sh"}
initContainer.Env = append(r.getNodepoolConfigEnvs(),
base.MkEnvVar("NODEPOOL_CONFIG_FILE", "nodepool-builder.yaml"),
)
Expand Down Expand Up @@ -469,8 +464,9 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
buildLogsContainer := base.MkContainer("build-logs-httpd", HTTPDImage)
buildLogsContainer.VolumeMounts = []apiv1.VolumeMount{
{
Name: "nodepool-log",
MountPath: "/var/www/html/dib",
Name: builderIdent,
SubPath: "builds",
MountPath: "/var/www/html/builds",
},
{
Name: "nodepool-builder-extra-config-vol",
Expand All @@ -481,9 +477,9 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
buildLogsContainer.Ports = []apiv1.ContainerPort{
base.MkContainerPort(buildLogsHttpdPort, buildLogsHttpdPortName),
}
buildLogsContainer.ReadinessProbe = base.MkReadinessHTTPProbe("/dib", buildLogsHttpdPort)
buildLogsContainer.StartupProbe = base.MkStartupHTTPProbe("/dib", buildLogsHttpdPort)
buildLogsContainer.LivenessProbe = base.MkLiveHTTPProbe("/dib", buildLogsHttpdPort)
buildLogsContainer.ReadinessProbe = base.MkReadinessHTTPProbe("/builds", buildLogsHttpdPort)
buildLogsContainer.StartupProbe = base.MkStartupHTTPProbe("/builds", buildLogsHttpdPort)
buildLogsContainer.LivenessProbe = base.MkLiveHTTPProbe("/builds", buildLogsHttpdPort)
nb.Spec.Template.Spec.Containers = append(nb.Spec.Template.Spec.Containers,
buildLogsContainer,
)
Expand All @@ -508,9 +504,7 @@ func (r *SFController) DeployNodepoolBuilder(statsdExporterVolume apiv1.Volume,
pvcReadiness := r.reconcileExpandPVC(builderIdent+"-"+builderIdent+"-0", r.cr.Spec.Nodepool.Builder.Storage)

routeReady := r.ensureHTTPSRoute(r.cr.Name+"-nodepool-builder", "nodepool", buildLogsHttpdPortName, "/builds",
buildLogsHttpdPort, map[string]string{
"haproxy.router.openshift.io/rewrite-target": "/dib",
}, r.cr.Spec.FQDN, r.cr.Spec.LetsEncrypt)
buildLogsHttpdPort, map[string]string{}, r.cr.Spec.FQDN, r.cr.Spec.LetsEncrypt)

var isReady = r.IsStatefulSetReady(&current) && routeReady && pvcReadiness

Expand Down
1 change: 1 addition & 0 deletions controllers/static/nodepool/generate-config.sh
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ zookeeper-tls:
key: /tls/client/tls.key
# images-dir is mandatory key for nodepool-builder process
images-dir: /var/lib/nodepool/dib
build-log-dir: /var/lib/nodepool/builds/logs
EOF

if [ "$CONFIG_REPO_SET" == "TRUE" ]; then
Expand Down
2 changes: 1 addition & 1 deletion controllers/static/nodepool/httpd-build-logs-dir.conf
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<VirtualHost *>
AddType text/plain .log

<Directory "/var/www/html/dib/">
<Directory "/var/www/html/builds/">
Options Indexes SymLinksIfOwnerMatch
Require all granted
IndexOptions FancyIndexing HTMLTable NameWidth=* SuppressDescription
Expand Down
26 changes: 21 additions & 5 deletions controllers/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -239,14 +239,30 @@ func (r *SFUtilContext) ensureRoute(route apiroutev1.Route, name string) bool {
return false
} else {
// Route already exist - check if we need to update the Route
// Use the String repr of the RouteSpec to compare for changes
needUpdate := false

// First check the route annotations
if (len(route.Annotations) == 0 && len(current.Annotations) != 0) || (len(route.Annotations) != 0 && len(current.Annotations) == 0) {
current.Annotations = route.Annotations
needUpdate = true
}
if len(route.Annotations) != 0 && len(current.Annotations) != 0 {
if !utils.MapEquals(&route.Annotations, &current.Annotations) {
current.Annotations = route.Annotations
needUpdate = true
}
}

// Use the String repr of the RouteSpec to compare for Spec changes
// This comparaison mechanics may fail in case of some Route Spec default values
// not specified in the wanted version.
wantedRepr := route.Spec.String()
currentRepr := current.Spec.String()
if wantedRepr != currentRepr {
r.log.V(1).Info("Updating route...", "name", name)
if route.Spec.String() != current.Spec.String() {
current.Spec = route.Spec
needUpdate = true
}

if needUpdate {
r.log.V(1).Info("Updating route...", "name", name)
r.UpdateR(&current)
return false
}
Expand Down
4 changes: 2 additions & 2 deletions roles/health-check/check-service-uri/tasks/main.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -89,13 +89,13 @@

- name: Attempt to access Nodepool builder build logs
ansible.builtin.uri:
url: "https://{{ nodepool_host }}/builds/"
url: "https://{{ nodepool_host }}/builds"
method: GET
return_content: true
validate_certs: "{{ validate_certs }}"
status_code: [200, 503]
register: this
until:
- this.status == 200
- "'Index of /dib' in this.content"
- "'Index of /builds' in this.content"
retries: "{{ retries }}"
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@
- name: "Check that witness message is available in build logs"
ansible.builtin.shell: |
kubectl exec nodepool-builder-0 -- bash -c "grep 'Hello from build of {{ nodepool_diskimage_name }}' /var/log/nodepool/builds/*"
kubectl exec nodepool-builder-0 -- bash -c "grep 'Hello from build of {{ nodepool_diskimage_name }}' /var/lib/nodepool/builds/logs/*"
register: witness
until: witness is success
delay: 5
Expand Down
1 change: 1 addition & 0 deletions roles/post/get-k8s-resources/tasks/main.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@
- configmaps
- jobs
- pvc
- routes
- csvs
- installplans
- sub
Expand Down
4 changes: 2 additions & 2 deletions roles/post/get-nodepool-builds-logs/tasks/main.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
path: "{{ output_dir }}"
state: absent

- name: "Fetch nodepool-builder /var/log/nodepool/builds content locally in {{ output_dir }}"
- name: "Fetch nodepool-builder /var/lib/nodepool/builds/logs content locally in {{ output_dir }}"
ansible.builtin.command: |
kubectl cp nodepool-builder-0:/var/log/nodepool/builds -c nodepool-builder {{ output_dir }}
kubectl cp nodepool-builder-0:/var/lib/nodepool/builds/logs -c nodepool-builder {{ output_dir }}
failed_when: false

0 comments on commit 263501a

Please sign in to comment.