- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 282 for agrave (2.52 sec)
-
tests/test_tutorial/test_response_model/test_tutorial003_01.py
"password": "fighter", "email": "******@****.***", "full_name": "Grave Dohl", }, ) assert response.status_code == 200, response.text assert response.json() == { "username": "foo", "email": "******@****.***", "full_name": "Grave Dohl", } def test_openapi_schema(): response = client.get("/openapi.json")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Aug 04 20:47:07 UTC 2023 - 5.6K bytes - Viewed (0) -
tests/test_tutorial/test_response_model/test_tutorial003_py310.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Aug 04 20:47:07 UTC 2023 - 5.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
t.Fatalf("timed out waiting for %v", et) } } } // MatchOrFail expects the provided events to arrive, skipping unmatched events func (fx *Updater) MatchOrFail(t test.Failer, events ...Event) { t.Helper() fx.matchOrFail(t, false, events...) } // StrictMatchOrFail expects the provided events to arrive, and nothing else func (fx *Updater) StrictMatchOrFail(t test.Failer, events ...Event) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/request/WorkerAction.java
// action will have the build operation associated. By using the responder, we ensure that all // messages arrive on the same incoming queue in the build process and the completed message will only // arrive after all log messages have been processed. result = workerLogEventListener.withWorkerLoggingProtocol(responder, new Callable<Object>() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 27 08:22:48 UTC 2024 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/notfoundhandler/not_found_handler.go
// // Note that we don't want to add additional checks to the readyz path as it might prevent fixing bricked clusters. // This specific handler is meant to "protect" requests that arrive before the paths and handlers are fully initialized. func New(serializer runtime.NegotiatedSerializer, isMuxAndDiscoveryCompleteFn func(ctx context.Context) bool) *Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 21 13:25:33 UTC 2021 - 2.5K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go
expectedDidOverrideInhibitDelay: false, expectedPodToGracePeriodOverride: map[string]int64{"normal-pod-nil-grace-period": 20, "critical-pod-nil-grace-period": 10, "normal-pod-grace-period": 2, "critical-pod-grace-period": 2, "normal-pod-long-grace-period": 20}, }, { desc: "no override (total=30, critical=0)",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 29.8K bytes - Viewed (0) -
src/go/parser/testdata/chans.go2
func (s *Sender[T]) Send(v T) bool { select { case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[T]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[T any] struct { values <-chan T
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 24 19:44:06 UTC 2020 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz.go
// as well as livez and readyz. The livez grace period is defined by the value of the // command-line flag --livez-grace-period; before the grace period elapses, the livez health checks // will default to healthy. One may want to set a grace period in order to prevent the kubelet from restarting // the kube-apiserver due to long-ish boot sequences. Readyz health checks, on the other hand, have no grace period,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup_test.go
now := time.Now() t.Logf("Wait starting, N=%d, grace: %s, at: %s", n, grace, now) activeAt, activeNow, err := target.Wait(func(count int) (RateLimiter, context.Context, context.CancelFunc) { defer close(waitingCh) // no deadline in context, Wait will wait forever, we want to measure // how long it takes for the requests to drain. return rate.NewLimiter(rate.Limit(n/int(grace.Seconds())), 1), context.Background(), func() {} })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 8.6K bytes - Viewed (0) -
src/internal/types/testdata/check/chans.go
func (s *Sender[T]) Send(v T) bool { select { case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[T]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[T any] struct { values <-chan T
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 1.7K bytes - Viewed (0)