- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 339 for preds (0.05 sec)
-
pkg/kubelet/apis/podresources/server_v1.go
if !types.IsRestartableInitContainer(&container) { continue } pRes.Containers = append(pRes.Containers, p.getContainerResources(pod, &container)) } } for _, container := range pod.Spec.Containers { pRes.Containers = append(pRes.Containers, p.getContainerResources(pod, &container)) } podResources[i] = &pRes } response := &podresourcesv1.ListPodResourcesResponse{ PodResources: podResources,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 13:00:09 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/credentialprovider/keyring_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 15 10:47:22 UTC 2023 - 15.1K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
} locker := &lockRESTServer{ ll: &localLocker{ mutex: sync.Mutex{}, lockMap: make(map[string][]lockRequesterInfo), }, } creds := globalActiveCred token, err := authenticateNode(creds.AccessKey, creds.SecretKey, "") if err != nil { t.Fatal(err) } return fsDir, locker, token } // Test function to remove lock entries from map based on name & uid combination
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 23 17:26:21 UTC 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/kubeinject/google.go
} func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) { creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform") if err != nil { return nil, fmt.Errorf("finding default GCP credentials: %w", err) } return &oauth2.Transport{ Base: tr, Source: creds.TokenSource, }, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.2K bytes - Viewed (0) -
cmd/signature-v2_test.go
t.Fatal(err) } creds := globalActiveCred policy := "policy" testCases := []struct { accessKey string policy string signature string errCode APIErrorCode }{ {"invalidAccessKey", policy, calculateSignatureV2(policy, creds.SecretKey), ErrInvalidAccessKeyID}, {creds.AccessKey, policy, calculateSignatureV2("random", creds.SecretKey), ErrSignatureDoesNotMatch},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tpu_colocate_splits.cc
llvm::SmallVector<Operation*> predecessors; for (Value operand : op->getOperands()) { if (Operation* pred = operand.getDefiningOp()) { int result_number = llvm::cast<OpResult>(operand).getResultNumber(); if (auto pred_island = llvm::dyn_cast<tf_executor::IslandOp>(pred)) { Value yield_operand = pred_island.GetYield().getOperand(result_number); predecessors.push_back(yield_operand.getDefiningOp());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 27 18:44:34 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/registry/core/componentstatus/rest.go
} if options != nil { if options.LabelSelector != nil { pred.Label = options.LabelSelector } if options.FieldSelector != nil { pred.Field = options.FieldSelector } } return pred } func matchesPredicate(status api.ComponentStatus, pred *storage.SelectionPredicate) bool { // currently no fields except the generic meta fields are supported for predicate matching
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 5.1K bytes - Viewed (0) -
docs/lambda/README.md
python lambda_handler.py * Serving Flask app 'webhook' * Debug mode: off WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead. * Running on http://127.0.0.1:5000 Press CTRL+C to quit ``` ## Start MinIO with Lambda target Register MinIO with a Lambda function, we are calling our target name as `function`, but you may call it any other friendly name of your choice. ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Apr 04 19:15:28 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/grpc.go
// Create the TLS credentials creds, errCreds := credentials.NewServerTLSFromFile(s.TLSCert, s.TLSKey) if errCreds != nil { epLog.Errorf("could not load TLS keys: %s", errCreds) } opts = append(opts, grpc.Creds(creds)) } else if s.Port.XDSServer { epLog.Infof("Listening GRPC (over xDS-configured mTLS) on %v", p) creds, err := xdscreds.NewServerCredentials(xdscreds.ServerOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1.go
p.devicesProvider.UpdateAllocatedDevices() for i, pod := range pods { pRes := v1alpha1.PodResources{ Name: pod.Name, Namespace: pod.Namespace, Containers: make([]*v1alpha1.ContainerResources, len(pod.Spec.Containers)), } for j, container := range pod.Spec.Containers { pRes.Containers[j] = &v1alpha1.ContainerResources{ Name: container.Name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:01 UTC 2023 - 2.6K bytes - Viewed (0)