- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for preStartContainer (0.2 sec)
-
pkg/kubelet/cm/devicemanager/endpoint.go
ContainerRequests: []*pluginapi.ContainerAllocateRequest{ {DevicesIDs: devs}, }, }) } // preStartContainer issues PreStartContainer gRPC call to the device plugin. func (e *endpointImpl) preStartContainer(devs []string) (*pluginapi.PreStartContainerResponse, error) { if e.isStopped() { return nil, fmt.Errorf(errEndpointStopped, e) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 11:05:20 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/kubelet/cm/internal_container_lifecycle.go
"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager" ) type InternalContainerLifecycle interface { PreCreateContainer(pod *v1.Pod, container *v1.Container, containerConfig *runtimeapi.ContainerConfig) error PreStartContainer(pod *v1.Pod, container *v1.Container, containerID string) error PostStopContainer(containerID string) error } // Implements InternalContainerLifecycle interface. type internalContainerLifecycleImpl struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 06:43:12 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/fake_internal_container_lifecycle.go
func (f *fakeInternalContainerLifecycle) PreCreateContainer(pod *v1.Pod, container *v1.Container, containerConfig *runtimeapi.ContainerConfig) error { return nil } func (f *fakeInternalContainerLifecycle) PreStartContainer(pod *v1.Pod, container *v1.Container, containerID string) error { return nil } func (f *fakeInternalContainerLifecycle) PostStopContainer(containerID string) error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 08:08:02 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go
GetPreferredAllocationAvailable: m.getPreferredAllocationFlag, } return options, nil } // PreStartContainer resets the devices received func (m *Stub) PreStartContainer(ctx context.Context, r *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error) { klog.InfoS("PreStartContainer", "request", r) return &pluginapi.PreStartContainerResponse{}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 11:19:10 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
// Stops resourceName2 endpoint. Verifies its stopTime is set, allocate and // preStartContainer calls return errors. e2.client.Disconnect() as.False(e2.stopTime.IsZero()) _, err = e2.allocate([]string{"Device1"}) reflect.DeepEqual(err, fmt.Errorf(errEndpointStopped, e2)) _, err = e2.preStartContainer([]string{"Device1"}) reflect.DeepEqual(err, fmt.Errorf(errEndpointStopped, e2))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
} m.mutex.Unlock() devs := devices.UnsortedList() klog.V(4).InfoS("Issuing a PreStartContainer call for container", "containerName", contName, "podUID", podUID) _, err := eI.e.preStartContainer(devs) if err != nil { return fmt.Errorf("device plugin PreStartContainer rpc failed with err: %v", err) } // TODO: Add metrics support for init RPC return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
return s.Message(), ErrCreateContainer } err = m.internalLifecycle.PreStartContainer(pod, container, containerID) if err != nil { s, _ := grpcstatus.FromError(err) m.recordContainerEvent(pod, container, containerID, v1.EventTypeWarning, events.FailedToStartContainer, "Internal PreStartContainer hook failed: %v", s.Message()) return s.Message(), ErrPreStartHook }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0)