github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 05:03:09 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #101768 from jingxu97/may/podlog

Browse Source 
Add function to copy a single pod log in podlogs
This commit is contained in:
Kubernetes Prow Robot 2021-05-06 18:37:02 -07:00 committed by GitHub
commit 5663875648
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
test/e2e/storage/podlogs/podlogs.go
View File

@ -57,11 +57,18 @@ type LogOutput struct {
// Matches harmless errors from pkg/kubelet/kubelet_pods.go. // Matches harmless errors from pkg/kubelet/kubelet_pods.go.
var expectedErrors = regexp.MustCompile(`container .* in pod .* is (terminated|waiting to start|not available)|the server could not find the requested resource`) var expectedErrors = regexp.MustCompile(`container .* in pod .* is (terminated|waiting to start|not available)|the server could not find the requested resource`)
// CopyAllLogs follows the logs of all containers in all pods, // CopyPodLogs is basically CopyPodLogs for all current or future pods in the given namespace ns
func CopyAllLogs(ctx context.Context, cs clientset.Interface, ns string, to LogOutput) error {
return CopyPodLogs(ctx, cs, ns, "", to)
}
// CopyPodLogs follows the logs of all containers in pod with the given podName,
// including those that get created in the future, and writes each log // including those that get created in the future, and writes each log
// line as configured in the output options. It does that until the // line as configured in the output options. It does that until the
// context is done or until an error occurs. // context is done or until an error occurs.
// //
// If podName is empty, it will follow all pods in the given namespace ns.
//
// Beware that there is currently no way to force log collection // Beware that there is currently no way to force log collection
// before removing pods, which means that there is a known race // before removing pods, which means that there is a known race
// between "stop pod" and "collecting log entries". The alternative // between "stop pod" and "collecting log entries". The alternative
@ -79,8 +86,15 @@ var expectedErrors = regexp.MustCompile(`container .* in pod .* is (terminated|w
// But it turned out to be rather confusing, so now a heuristic is used: if // But it turned out to be rather confusing, so now a heuristic is used: if
// log output of a container was already captured, then capturing does not // log output of a container was already captured, then capturing does not
// resume if the pod is marked for deletion. // resume if the pod is marked for deletion.
func CopyAllLogs(ctx context.Context, cs clientset.Interface, ns string, to LogOutput) error { func CopyPodLogs(ctx context.Context, cs clientset.Interface, ns, podName string, to LogOutput) error {
watcher, err := cs.CoreV1().Pods(ns).Watch(context.TODO(), meta.ListOptions{}) options := meta.ListOptions{}
if podName != "" {
options = meta.ListOptions{
FieldSelector: fmt.Sprintf("metadata.name=%s", podName),
}
}
watcher, err := cs.CoreV1().Pods(ns).Watch(context.TODO(), options)
if err != nil { if err != nil {
return errors.Wrap(err, "cannot create Pod event watcher") return errors.Wrap(err, "cannot create Pod event watcher")
} }
@ -96,7 +110,7 @@ func CopyAllLogs(ctx context.Context, cs clientset.Interface, ns string, to LogO
m.Lock() m.Lock()
defer m.Unlock() defer m.Unlock()
pods, err := cs.CoreV1().Pods(ns).List(context.TODO(), meta.ListOptions{}) pods, err := cs.CoreV1().Pods(ns).List(context.TODO(), options)
if err != nil { if err != nil {
if to.StatusWriter != nil { if to.StatusWriter != nil {
fmt.Fprintf(to.StatusWriter, "ERROR: get pod list in %s: %s\n", ns, err) fmt.Fprintf(to.StatusWriter, "ERROR: get pod list in %s: %s\n", ns, err)