Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetContainerLogs (0.24 sec)

  1. pkg/kubelet/container/testing/runtime_mock.go

    }
    
    // GetContainerLogs indicates an expected call of GetContainerLogs.
    func (mr *MockRuntimeMockRecorder) GetContainerLogs(ctx, pod, containerID, logOptions, stdout, stderr any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetContainerLogs", reflect.TypeOf((*MockRuntime)(nil).GetContainerLogs), ctx, pod, containerID, logOptions, stdout, stderr)
    }
    
    // GetImageRef mocks base method.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 27K bytes
    - Viewed (0)
  2. pkg/kubelet/container/testing/fake_runtime.go

    	status := f.PodStatus
    	return &status, f.Err
    }
    
    func (f *FakeRuntime) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, logOptions *v1.PodLogOptions, stdout, stderr io.Writer) (err error) {
    	f.Lock()
    	defer f.Unlock()
    
    	f.CalledFunctions = append(f.CalledFunctions, "GetContainerLogs")
    	return f.Err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 00:23:50 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  3. pkg/kubelet/server/server.go

    	s.addMetricsBucketMatcher("containerLogs")
    	ws = new(restful.WebService)
    	ws.
    		Path("/containerLogs")
    	ws.Route(ws.GET("/{podNamespace}/{podID}/{containerName}").
    		To(s.getContainerLogs).
    		Operation("getContainerLogs"))
    	s.restfulCont.Add(ws)
    
    	s.addMetricsBucketMatcher("configz")
    	configz.InstallHandler(s.restfulCont)
    
    	// The /runningpods endpoint is used for testing only.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  4. pkg/kubelet/container/runtime.go

    	// TODO(vmarmol): Unify pod and containerID args.
    	// GetContainerLogs returns logs of a specific container. By
    	// default, it returns a snapshot of the container log. Set 'follow' to true to
    	// stream the log. Set 'follow' to false and specify the number of lines (e.g.
    	// "100" or "all") to tail the log.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_container.go

    			changes.InitContainersToStart[l-1-i], changes.InitContainersToStart[i]
    	}
    
    	return podHasInitialized
    }
    
    // GetContainerLogs returns logs of a specific container.
    func (m *kubeGenericRuntimeManager) GetContainerLogs(ctx context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, logOptions *v1.PodLogOptions, stdout, stderr io.Writer) (err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    		// config source (apiserver). This is useful if kubelet
    		// has recently been restarted.
    		podStatus = pod.Status
    	}
    
    	// TODO: Consolidate the logic here with kuberuntime.GetContainerLogs, here we convert container name to containerID,
    	// but inside kuberuntime we convert container id back to container name and restart count.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top