- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 266 for Req (0.02 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/filters/authorization.go
klog.Warning("Authorization is disabled") return handler } return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() authorizationStart := time.Now() attributes, err := GetAuthorizerAttributes(ctx) if err != nil { responsewriters.InternalError(w, req, err) return } authorized, reason, err := a.Authorize(ctx, attributes) authorizationFinish := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 20 13:35:55 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/translatinghandler_test.go
expectTranslator: false, }, } for name, test := range tests { req, err := http.NewRequest("GET", "http://www.example.com/", nil) require.NoError(t, err) if test.upgrade != "" { req.Header.Add("Connection", "Upgrade") req.Header.Add("Upgrade", test.upgrade) } if len(test.version) > 0 { req.Header.Add(wsstream.WebSocketProtocolHeader, test.version) } delegate := fakeHandler{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 3.6K bytes - Viewed (0) -
pilot/pkg/xds/cds.go
} // Otherwise, only handle full pushes (skip endpoint-only updates) if !req.Full { return false } default: if !req.Full { // CDS only handles full push return false } } // If none set, we will always push if len(req.ConfigsUpdated) == 0 { return true } checkGateway := false for config := range req.ConfigsUpdated { if proxy.Type == model.Router {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 21:27:52 UTC 2024 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/storageversion.go
return handler } return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { if svm.Completed() { handler.ServeHTTP(w, req) return } ctx := req.Context() requestInfo, found := request.RequestInfoFrom(ctx) if !found { responsewriters.InternalError(w, req, errors.New("no RequestInfo found in the context")) return } // Allow non-resource requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 5K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/toolchain/DefaultToolchainManagerPrivateTest.java
// prepare MavenSession session = mock(MavenSession.class); MavenExecutionRequest req = new DefaultMavenExecutionRequest(); when(session.getRequest()).thenReturn(req); Map<String, List<ToolchainModel>> groupedToolchains = new HashMap<>(); req.setToolchains(groupedToolchains); List<ToolchainModel> basicToolchains = new ArrayList<>();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Apr 15 17:24:20 UTC 2023 - 5.7K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelProblemCollector.java
@Override public void add(ModelProblemCollectorRequest req) { int line = -1; int column = -1; String source = null; String modelId = null; if (req.getLocation() != null) { line = req.getLocation().getLineNumber(); column = req.getLocation().getColumnNumber(); if (req.getLocation().getSource() != null) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 5.5K bytes - Viewed (0) -
internal/config/policy/opa/config.go
func (a *Args) Validate() error { req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte(""))) if err != nil { return err } req.Header.Set("Content-Type", "application/json") if a.AuthToken != "" { req.Header.Set("Authorization", a.AuthToken) } client := &http.Client{Transport: a.Transport} resp, err := client.Do(req) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.2K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/generate_certs.sh
openssl genrsa -out "${WD}/clientA.key" 2048 openssl req -new -key "${WD}/clientA.key" -out "${WD}/clientA.csr" -subj "/CN=*.example.com" -config "${WD}/client.conf" openssl x509 -req -days 3650 -CA "${WD}/rootA.crt" -CAkey "${WD}/rootA.key" -set_serial 0 -in "${WD}/clientA.csr" -out "${WD}/clientA.crt" -extensions v3_req -extfile "${WD}/client.conf" openssl genrsa -out "${WD}/serverA.key" 2048
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 05 22:01:21 UTC 2023 - 5K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/grpc.go
if err != nil { return err } req := &proto.ForwardEchoRequest{ Url: "grpc://" + listener.Addr().String(), Message: "hello", TimeoutMicros: common.DurationToMicros(readyInterval), } if s.Port.XDSReadinessTLS { // TODO: using the servers key/cert is not always valid, it may not be allowed to make requests to itself req.CertFile = cert req.KeyFile = key req.CaCertFile = ca
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/transport/transport.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 22 18:58:12 UTC 2022 - 3.8K bytes - Viewed (0)