- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 266 for Req (5 sec)
-
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) -
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) -
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) -
src/test/java/org/codelibs/fess/helper/AccessTokenHelperTest.java
MockletHttpServletRequest req = getMockRequest(); req.addHeader("Authorization", "Bearer " + token); assertEquals(token, accessTokenHelper.getAccessTokenFromRequest(req)); } public void test_getAccessTokenFromRequest_ok1() { final String token = accessTokenHelper.generateAccessToken(); MockletHttpServletRequest req = getMockRequest(); req.addHeader("Authorization", token);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/apis/certificates/helpers.go
return ValidateKubeletClientCSR(req, usages) == nil } func ValidateKubeletClientCSR(req *x509.CertificateRequest, usages sets.String) error { if !reflect.DeepEqual([]string{"system:nodes"}, req.Subject.Organization) { return organizationNotSystemNodesErr } if len(req.DNSNames) > 0 { return dnsSANNotAllowedErr } if len(req.EmailAddresses) > 0 { return emailSANNotAllowedErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 27 08:04:25 UTC 2022 - 4K bytes - Viewed (0) -
pilot/pkg/xds/rds.go
kind.Telemetry, kind.ProxyConfig, kind.DNSName, ) func rdsNeedsPush(req *model.PushRequest) bool { if req == nil { return true } if !req.Full { // RDS only handles full push return false } // If none set, we will always push if len(req.ConfigsUpdated) == 0 { return true } for config := range req.ConfigsUpdated { if !skippedRdsConfigs.Contains(config.Kind) { return true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 07:19:38 UTC 2024 - 1.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_hurd.go
int ioctl(int, unsigned long int, uintptr_t); */ import "C" func ioctl(fd int, req uint, arg uintptr) (err error) { r0, er := C.ioctl(C.int(fd), C.ulong(req), C.uintptr_t(arg)) if r0 == -1 && er != nil { err = er } return } func ioctlPtr(fd int, req uint, arg unsafe.Pointer) (err error) { r0, er := C.ioctl(C.int(fd), C.ulong(req), C.uintptr_t(uintptr(arg))) if r0 == -1 && er != nil { err = er } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 635 bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
var logFiltered string if !req.Delta.IsEmpty() && !con.proxy.IsProxylessGrpc() { logFiltered = " filtered:" + strconv.Itoa(len(w.ResourceNames)-len(req.Delta.Subscribed)) w = &model.WatchedResource{ TypeUrl: w.TypeUrl, ResourceNames: req.Delta.Subscribed.UnsortedList(), } } res, logdata, err := gen.Generate(con.proxy, w, req) info := "" if len(logdata.AdditionalInfo) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/xds/ecds.go
} var _ model.XdsResourceGenerator = &EcdsGenerator{} func ecdsNeedsPush(req *model.PushRequest) bool { if req == nil { return true } // If none set, we will always push if len(req.ConfigsUpdated) == 0 { return true } // Only push if config updates is triggered by EnvoyFilter, WasmPlugin, or Secret. for config := range req.ConfigsUpdated { switch config.Kind { case kind.EnvoyFilter: return true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 18:25:42 UTC 2024 - 7.2K bytes - Viewed (0)