- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NodePrepareResources (0.3 sec)
-
pkg/kubelet/cm/dra/plugin/client.go
} return existingPlugin, nil } func (p *plugin) NodePrepareResources( ctx context.Context, req *drapb.NodePrepareResourcesRequest, opts ...grpc.CallOption, ) (*drapb.NodePrepareResourcesResponse, error) { logger := klog.FromContext(ctx) logger.V(4).Info(log("calling NodePrepareResources rpc"), "request", req) conn, err := p.getOrCreateGRPCConn() if err != nil { return nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
if claimInfo.isPrepared() { return nil } // This saved claim will be used to update ClaimInfo cache // after NodePrepareResources GRPC succeeds resourceClaims[claimInfo.ClaimUID] = resourceClaim // Loop through all plugins and prepare for calling NodePrepareResources. for _, resourceHandle := range claimInfo.ResourceHandles { claim := &drapb.Claim{ Namespace: claimInfo.Namespace,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/client_test.go
) type fakeV1alpha3GRPCServer struct { drapbv1alpha3.UnimplementedNodeServer } var _ drapbv1alpha3.NodeServer = &fakeV1alpha3GRPCServer{} func (f *fakeV1alpha3GRPCServer) NodePrepareResources(ctx context.Context, in *drapbv1alpha3.NodePrepareResourcesRequest) (*drapbv1alpha3.NodePrepareResourcesResponse, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager_test.go
unprepareResourceCalls atomic.Uint32 prepareResourcesResponse *drapbv1.NodePrepareResourcesResponse unprepareResourcesResponse *drapbv1.NodeUnprepareResourcesResponse } func (s *fakeDRADriverGRPCServer) NodePrepareResources(ctx context.Context, req *drapbv1.NodePrepareResourcesRequest) (*drapbv1.NodePrepareResourcesResponse, error) { s.prepareResourceCalls.Add(1) if s.timeout != nil { time.Sleep(*s.timeout) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0)