- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for RequestReceived (0.3 sec)
-
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/policy/checker_test.go
test(t, "namespaced", audit.LevelRequest, nil, []audit.Stage{audit.StageRequestReceived, audit.StageResponseStarted, audit.StageResponseComplete}, "only audit panic", "getPods", "default") test(t, "cluster", audit.LevelRequest, nil, []audit.Stage{audit.StageRequestReceived}, "omit RequestReceived", "getPods", "default")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 12 15:06:14 UTC 2021 - 15.1K bytes - Viewed (0) -
pkg/client/tests/remotecommand_test.go
var ( streamIn io.Reader streamOut, streamErr io.Writer ) localOut := &bytes.Buffer{} localErr := &bytes.Buffer{} requestReceived := make(chan struct{}) server := httptest.NewServer(fakeServer(t, requestReceived, name, exec, testCase.Stdin, testCase.Stdout, testCase.Stderr, testCase.Error, testCase.Tty, testCase.MessageCount, testCase.ServerProtocols)) defer server.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 10.2K bytes - Viewed (0) -
pkg/kubelet/config/http_test.go
t.Fatalf("Unexpected error extracting from URL: %v", err) } update := (<-ch).(kubetypes.PodUpdate) headerVal := fakeHandler.RequestReceived.Header["Metadata-Flavor"] if len(headerVal) != 1 || headerVal[0] != "Google" { t.Errorf("Header missing expected entry %v. Got %v", header, fakeHandler.RequestReceived.Header) } if len(update.Pods) != 1 { t.Errorf("Received wrong number of pods, expected one: %v", update.Pods) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/audit/types.go
type Stage string // Valid audit stages. const ( // The stage for events generated as soon as the audit handler receives the request, and before it // is delegated down the handler chain. StageRequestReceived Stage = "RequestReceived" // The stage for events generated once the response headers are sent, but before the response body // is sent. This stage is only generated for long-running requests (e.g. watch).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 09:18:23 UTC 2023 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/audit/v1/types.go
type Stage string // Valid audit stages. const ( // The stage for events generated as soon as the audit handler receives the request, and before it // is delegated down the handler chain. StageRequestReceived Stage = "RequestReceived" // The stage for events generated once the response headers are sent, but before the response body // is sent. This stage is only generated for long-running requests (e.g. watch).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:24:10 UTC 2023 - 14.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 22.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/audit.go
// flush before sending a response. ModeBlocking = "blocking" // ModeBlockingStrict is the same as ModeBlocking, except when there is // a failure during audit logging at RequestReceived stage, the whole // request to apiserver will fail. ModeBlockingStrict = "blocking-strict" ) // AllowedModes is the modes known for audit backends. var AllowedModes = []string{ ModeBatch, ModeBlocking,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 24 06:30:04 UTC 2022 - 20.3K bytes - Viewed (0)