- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 812 for Req (0.02 sec)
-
maven-model-builder/src/test/java/org/apache/maven/model/building/SimpleProblemCollector.java
} public void add(ModelProblemCollectorRequest req) { switch (req.getSeverity()) { case FATAL: if (!fatals.contains(req.getMessage())) { fatals.add(req.getMessage()); } break; case ERROR: if (!errors.contains(req.getMessage())) { errors.add(req.getMessage()); } break;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Sep 11 16:17:26 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
} }() userDefined := make(map[string]string, len(req.UserMetadata)) for k, v := range req.UserMetadata { userDefined[k] = v } userDefined[xhttp.AmzObjectTagging] = s3utils.TagEncode(req.UserTags) if opts.Kind != nil { encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx) if err != nil { errs[idx] = err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/xds/nds.go
kind.GRPCRoute, ) func ndsNeedsPush(req *model.PushRequest) bool { if req == nil { return true } if !req.Full { // NDS generally handles full push. We only allow partial pushes, when headless endpoints change. return headlessEndpointsUpdated(req) } // If none set, we will always push if len(req.ConfigsUpdated) == 0 { return true } for config := range req.ConfigsUpdated {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/kms/kes.go
return nil, errDecryptionFailed(err) } return plaintext, nil } // MAC generates the checksum of the given req.Message using the key // with the req.Name at the KMS. func (c *kesConn) MAC(ctx context.Context, req *MACRequest) ([]byte, error) { mac, err := c.client.HMAC(context.Background(), req.Name, req.Message) if err != nil { if errors.Is(err, kes.ErrKeyNotFound) { return nil, ErrKeyNotFound }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade_test.go
} defer conn.Close() })) defer server.Close() req, err := http.NewRequest("GET", server.URL, nil) if err != nil { t.Fatalf("%d: error creating request: %s", i, err) } req.Header.Set("Connection", testCase.connectionHeader) req.Header.Set("Upgrade", testCase.upgradeHeader) client := &http.Client{} resp, err := client.Do(req) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 20:10:42 UTC 2017 - 2.2K bytes - Viewed (0) -
src/net/http/cgi/cgi_main.go
os.Exit(0) } Serve(http.HandlerFunc(func(rw http.ResponseWriter, req *http.Request) { if req.FormValue("nil-request-body") == "1" { fmt.Fprintf(rw, "nil-request-body=%v\n", req.Body == nil) return } rw.Header().Set("X-Test-Header", "X-Test-Value") req.ParseForm() if req.FormValue("no-body") == "1" { return } if eb, ok := req.Form["exact-body"]; ok { io.WriteString(rw, eb[0]) return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.1K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
func (s *DiscoveryServer) processDeltaRequest(req *discovery.DeltaDiscoveryRequest, con *Connection) error { stype := v3.GetShortType(req.TypeUrl) deltaLog.Debugf("ADS:%s: REQ %s resources sub:%d unsub:%d nonce:%s", stype, con.ID(), len(req.ResourceNamesSubscribe), len(req.ResourceNamesUnsubscribe), req.ResponseNonce) if req.TypeUrl == v3.HealthInfoType {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
return func(w http.ResponseWriter, req *http.Request) { if isDryRun(req.URL) { scope.err(errors.NewBadRequest("dryRun is not supported"), w, req) return } namespace, name, err := scope.Namer.Name(req) if err != nil { scope.err(err, w, req) return } ctx := req.Context() ctx = request.WithNamespace(ctx, namespace)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/fifo_list.go
} } } } func addToQueueSum(sum *queueSum, req *request) { sum.InitialSeatsSum += req.InitialSeats() sum.MaxSeatsSum += req.MaxSeats() sum.TotalWorkSum += req.totalWork() } func deductFromQueueSum(sum *queueSum, req *request) { sum.InitialSeatsSum -= req.InitialSeats() sum.MaxSeatsSum -= req.MaxSeats() sum.TotalWorkSum -= req.totalWork()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 16:05:53 UTC 2021 - 3.9K bytes - Viewed (0)