Skip to content
Snippets Groups Projects
Commit 8a3dd7a5 authored by Jeremy Scott's avatar Jeremy Scott Committed by Derek Su
Browse files

Implement which container logs to select

parent e5f0d0be
Branches
Tags
No related merge requests found
...@@ -709,13 +709,18 @@ func createPersistentVolumeSource(volumeType string, path string) (pvs v1.Persis ...@@ -709,13 +709,18 @@ func createPersistentVolumeSource(volumeType string, path string) (pvs v1.Persis
return pvs, nil return pvs, nil
} }
// saveHelperPodLogs takes what is in stdout/stderr from the helper
// pod and logs it to the provisioner's logs. Returns an error if we
// can't retrieve the helper pod logs.
func saveHelperPodLogs(pod *v1.Pod) (err error) { func saveHelperPodLogs(pod *v1.Pod) (err error) {
defer func() { defer func() {
err = errors.Wrapf(err, "failed to save %s logs", pod.Name) err = errors.Wrapf(err, "failed to save %s logs", pod.Name)
}() }()
// save helper pod logs // save helper pod logs
podLogOpts := v1.PodLogOptions{} podLogOpts := v1.PodLogOptions{
Container: "helper-pod",
}
config, err := rest.InClusterConfig() config, err := rest.InClusterConfig()
if err != nil { if err != nil {
return fmt.Errorf("unable to retrieve in cluster config: %s", err.Error()) return fmt.Errorf("unable to retrieve in cluster config: %s", err.Error())
...@@ -734,7 +739,7 @@ func saveHelperPodLogs(pod *v1.Pod) (err error) { ...@@ -734,7 +739,7 @@ func saveHelperPodLogs(pod *v1.Pod) (err error) {
buf := new(bytes.Buffer) buf := new(bytes.Buffer)
_, err = io.Copy(buf, podLogs) _, err = io.Copy(buf, podLogs)
if err != nil { if err != nil {
return fmt.Errorf("error in copy information from podLogs to buf: %s", err.Error()) return fmt.Errorf("error in copying information from podLogs to buf: %s", err.Error())
} }
podLogs.Close() podLogs.Close()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment